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

Public Member Functions

def startExecThreads
 
def startConnectServerThread
 
def startKeepAliveThread
 
def startReestablishConnectionThread
 
def doQuit
 
def getQuit
 
def getLocalAssets
 
def getRemoteAssets
 
def getSessionHandler
 
def getProjectList
 
def getCmdQueue
 
def getRunningCmdList
 
def getWorkerDataList
 
def getCmdLocation
 
def write
 
def saveProject
 
def read
 
def readProjectState
 
def getWorkerStates
 
def setWorkerState
 
def addReadableSocket
 
def removeReadableSocket
 

Public Attributes

 conf
 
 quit
 
 quitlock
 
 cmdQueue
 
 projectlist
 
 taskExecThreads
 
 workerDataList
 
 runningCmdList
 
 localAssets
 
 remoteAssets
 
 sessionHandler
 
 workerStates
 
 stateSaveThread
 
 updateThread
 
 keepAliveThread
 
 reestablishConnectionThread
 
 readableSocketLock
 
 readableSockets
 
 connectServerThread
 

Detailed Description

Maintains the server state. Must provide synchronized access 
   because the server is threaded.

   No threads are to be started in the __init__ method, but rather
   in the startExecThreads method. This is because the ServerState
   is initialized before the server forks. The main process would
   take those threads with it to the grave

Member Function Documentation

def cpc.server.state.server_state.ServerState.addReadableSocket (   self,
  socket 
)
def cpc.server.state.server_state.ServerState.doQuit (   self)
set the quit state to true
def cpc.server.state.server_state.ServerState.getCmdLocation (   self,
  cmdID 
)
Get the argument command location.
def cpc.server.state.server_state.ServerState.getCmdQueue (   self)
Get the run queue as an object.
def cpc.server.state.server_state.ServerState.getLocalAssets (   self)
Get the localassets object
def cpc.server.state.server_state.ServerState.getProjectList (   self)
Get the list of projects as an object.
def cpc.server.state.server_state.ServerState.getQuit (   self)
get the quit state
def cpc.server.state.server_state.ServerState.getRemoteAssets (   self)
Get the remoteassets object
def cpc.server.state.server_state.ServerState.getRunningCmdList (   self)
Get the running command list.
def cpc.server.state.server_state.ServerState.getSessionHandler (   self)
Get the session handler
def cpc.server.state.server_state.ServerState.getWorkerDataList (   self)
Get the worker directory list.
def cpc.server.state.server_state.ServerState.getWorkerStates (   self)
def cpc.server.state.server_state.ServerState.read (   self)
def cpc.server.state.server_state.ServerState.readProjectState (   self,
  projectName 
)
def cpc.server.state.server_state.ServerState.removeReadableSocket (   self,
  socket 
)
def cpc.server.state.server_state.ServerState.saveProject (   self,
  project 
)
def cpc.server.state.server_state.ServerState.setWorkerState (   self,
  state,
  workerData,
  originating 
)
def cpc.server.state.server_state.ServerState.startConnectServerThread (   self)
def cpc.server.state.server_state.ServerState.startExecThreads (   self)
Start the exec threads.
def cpc.server.state.server_state.ServerState.startKeepAliveThread (   self)
def cpc.server.state.server_state.ServerState.startReestablishConnectionThread (   self)
def cpc.server.state.server_state.ServerState.write (   self)
Write the full server state out to all appropriate files.

Member Data Documentation

cpc.server.state.server_state.ServerState.cmdQueue
cpc.server.state.server_state.ServerState.conf
cpc.server.state.server_state.ServerState.connectServerThread
cpc.server.state.server_state.ServerState.keepAliveThread
cpc.server.state.server_state.ServerState.localAssets
cpc.server.state.server_state.ServerState.projectlist
cpc.server.state.server_state.ServerState.quit
cpc.server.state.server_state.ServerState.quitlock
cpc.server.state.server_state.ServerState.readableSocketLock
cpc.server.state.server_state.ServerState.readableSockets
cpc.server.state.server_state.ServerState.reestablishConnectionThread
cpc.server.state.server_state.ServerState.remoteAssets
cpc.server.state.server_state.ServerState.runningCmdList
cpc.server.state.server_state.ServerState.sessionHandler
cpc.server.state.server_state.ServerState.stateSaveThread
cpc.server.state.server_state.ServerState.taskExecThreads
cpc.server.state.server_state.ServerState.updateThread
cpc.server.state.server_state.ServerState.workerDataList
cpc.server.state.server_state.ServerState.workerStates

The documentation for this class was generated from the following file: