/******************************************************************************
    (c) 2000 Patrick Caulfield                 patrick@debian.org

    This program is free software; you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation; either version 2 of the License, or
    any later version.

    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.
******************************************************************************/

#include <sys/types.h>
#include <sys/signal.h>
#include <stdio.h>
#include <syslog.h>
#include <unistd.h>
#include <fcntl.h>
#include <termios.h>
#include <list>
#include <queue>
#include <string>
#include <map>
#include <sstream>

#include "lat.h"
#include "utils.h"
#include "session.h"
#include "localport.h"
#include "connection.h"
#include "circuit.h"
#include "latcpcircuit.h"
#include "server.h"
#include "serversession.h"
#include "clientsession.h"
#include "queuedsession.h"

QueuedSession::QueuedSession(class LATConnection &p, LAT_SessionStartCmd *cmd,
			 ClientSession *_client,
			 unsigned char remid, unsigned char localid,
			 bool clean):
    ServerSession(p, cmd, std::string(""), 0,0, remid, localid, clean),
    client_session(_client)
{
    max_read_size = cmd->dataslotsize;
    master_fd = client_session->get_port_fd();

    debuglog(("new queued session: localid %d, remote id %d, data slot size: %d, device fd: %d\n",
	    localid, remid, max_read_size, master_fd));
}

int QueuedSession::new_session(unsigned char *_remote_node,
			       char *service, char *port,
			       unsigned char c)
{
    credit = c;
    strcpy(remote_service, service);
    strcpy(remote_port, port);

    if (!client_session) return -1;

    debuglog(("starting queued session: credit = %d\n", c));
    strcpy(remote_node, (char *)_remote_node);

    if (master_fd != -1)
    {
	fcntl(master_fd, F_SETFL, fcntl(master_fd, F_GETFL, 0) | O_NONBLOCK);
	connected = true;

	send_login_response();
	client_session->start_port();
    }
    else
    {
	return -1;
    }
    return 0;
}

QueuedSession::~QueuedSession()
{
    /* Make sure the parent class doesn't close this FD:
       it's not ours. */
    master_fd = -1;

    /* Restart the client session */
    client_session->restart_pty();
}