connection.cpp

Go to the documentation of this file.

#ifndef CONNECTION_IMPLEMENTATION_FILE
#define CONNECTION_IMPLEMENTATION_FILE

/*****************************************************************************\
*                                                                             *
*  Name   : connection                                                        *
*  Author : Chris Koeritz                                                     *
*                                                                             *
*******************************************************************************
* Copyright (c) 1992-$now By Author.  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 (at your option) any later version.  This is online at:      *
*     http://www.fsf.org/copyleft/gpl.html                                    *
* Please send any updates to: fred@gruntose.com                               *
\*****************************************************************************/

#include "connection.h"

#include <basis/istring.h>
#include <basis/mutex.h>

#undef LOG
#define LOG(to_print) CLASS_EMERGENCY_LOG(diagnostic, to_print)

connection::connection()
: local_transport_id(0),
  real_transport_id(0),
  remote_host(),
  remote_transport_id(0),
  remote_connection_id(0),
  alive(false),
  liveness(),
  _the_state(DISCONNECTED),
  _state_change_time()
{
  low_level[PRIMARY_ID] = 0;
  low_level[SECONDARY_ID] = 0;
}

time_stamp connection::last_state_change() const { return _state_change_time; }

connection::states connection::state() const { return _the_state; }

void connection::conn_id(const connection_id &new_id)
{ assign_unique_id(new_id.raw_id()); }

istring connection::catalogable_name() const
{ return istring(istring::SPRINTF, "connection %d", conn_id().raw_id()); }

const char *connection::connection_state_name(states to_name)
{
  switch (to_name) {
    case DISCONNECTED: return "DISCONNECTED";
    case AWAITING_A_CLIENT: return "AWAITING_A_CLIENT";
    case REACHING_SERVER: return "REACHING_SERVER";
    case WHO_IS_CLIENT: return "WHO_IS_CLIENT";
    case HELLO_TO_SERVER: return "HELLO_TO_SERVER";
    case CONNECTED: return "CONNECTED";
    case SENDING_CLOSE: return "SENDING_CLOSE";
    case SENDING_CLOSE_ACK: return "SENDING_CLOSE_ACK";
    case DONE_CLOSING: return "DONE_CLOSING";
    default: return "UnknownState";
  }
}

void connection::state(states to_set)
{
  states old_state = _the_state;
  _the_state = to_set;
  _state_change_time.reset();  // reset time when state changed.
  // if they're saying we're connected now and we were not before, then we
  // reset the connected_since time stamp.
  if ( (to_set == CONNECTED) && (old_state != CONNECTED) )
    _connected_since = time_stamp();
}

time_stamp connection::connected_since() const { return _connected_since; }

istring connection::text_form() const
{
  return istring(istring::SPRINTF, "[%d] %s %s "
      "state=%s lowlev_conn_id=%d/%d local_transport_id=%d "
      "remote_transport_id=%d real_transport_id=%d state_change=%s addr=",
      conn_id().raw_id(), alive? "live" : "dead", 
      connected()? (istring("connected ") + _connected_since.text_form()).s()
          : "unconnected",
      connection_state_name(state()), low_level[PRIMARY_ID],
      low_level[SECONDARY_ID], local_transport_id.raw_id(),
      remote_transport_id.raw_id(), real_transport_id.raw_id(),
      _state_change_time.text_form().s())
    + remote_host.text_form();
}

bool connection::connected() const
{
  switch (state()) {
    case CONNECTED: return true;

    case SENDING_CLOSE:  // intentional fall-through.
    case SENDING_CLOSE_ACK:  // intentional fall-through.
    case DISCONNECTED:  // intentional fall-through.
    case HELLO_TO_SERVER:  // intentional fall-through.
    case WHO_IS_CLIENT:  // intentional fall-through.
    case DONE_CLOSING:  // intentional fall-through.
    default:
      return false;
  }
}


#endif //CONNECTION_IMPLEMENTATION_FILE

---