Copernicus  2.0
 All Classes Namespaces Files Functions Variables
cpc.server.state.server_state Namespace Reference

Classes

class  ServerState
 

Functions

def stateSaveLoop
 
def establishConnections
 
def establishOutboundConnection
 
def establishOutBoundConnections
 
def establishInboundConnection
 
def establishInboundConnections
 
def sendKeepAlive
 
def reestablishConnections
 

Variables

tuple log = logging.getLogger('cpc.server.state')
 

Function Documentation

def cpc.server.state.server_state.establishConnections (   serverState)
def cpc.server.state.server_state.establishInboundConnection (   node,
  serverState 
)
def cpc.server.state.server_state.establishInboundConnections (   serverState)
for each node that is not connected
try to establish an inbound connection
def cpc.server.state.server_state.establishOutboundConnection (   node)
def cpc.server.state.server_state.establishOutBoundConnections ( )
def cpc.server.state.server_state.reestablishConnections (   serverState)
Tries to periodically check for nodes that have gone down and reestablish
 connections to them
def cpc.server.state.server_state.sendKeepAlive (   conf)
    Sends a message for each connected node in order to keep the
    connection alive
def cpc.server.state.server_state.stateSaveLoop (   serverState,
  conf 
)
Function for the state saving thread.

Variable Documentation

tuple cpc.server.state.server_state.log = logging.getLogger('cpc.server.state')