localportsession.cc

/******************************************************************************
    (c) 2001-2003 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/stat.h>
#include <sys/ioctl.h>
#ifdef HAVE_SYS_FILIO_H
#include <sys/filio.h>
#endif
#include <stdio.h>
#include <syslog.h>
#include <fcntl.h>
#include <unistd.h>
#include <termios.h>
#include <list>
#include <queue>
#include <string>
#include <map>
#include <strstream>

#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 "clientsession.h"
#include "lloginsession.h"
#include "localportsession.h"
#include "lat_messages.h"

localportSession::localportSession(class LATConnection &p, LocalPort *port,
                           unsigned char remid, unsigned char localid,
                           char *lta, int fd):
    lloginSession(p, remid, localid, lta, clean),
    localport(port),
    minimum_read(0),
    ignored_read(false)
{
    master_fd = fd;

    debuglog(("new localport session: localid %d, remote id %d, fd=%d\n",
            localid, remid, fd));

    state = STARTING;
}


localportSession::~localportSession()
{
    close (master_fd);

    // Invalidate the FD number so it doesn't get closed when
    // the superclass destructors get called.
    LATServer::Instance()->remove_fd(master_fd);
    master_fd = -1;

    // Restart PTY so it can accept new connections
    debuglog(("Restarting PTY for local session\n"));
    localport->restart_pty();
}

void localportSession::do_read()
{
    // If there are less than "minimum_read" bytes available then
    // wait until the next time around. We never leave it for more
    // than one timer tick though.
    int numbytes;
    ioctl(master_fd, FIONREAD, &numbytes);
    if (numbytes < minimum_read && !ignored_read)
    {
      ignored_read = true;
    }
    else
    {
      read_pty();
      ignored_read = false;
    }
}

void localportSession::show_status(unsigned char *node, LAT_StatusEntry *entry)
{
    // Dont show status.
}