Copernicus  2.0
 All Classes Namespaces Files Functions Variables
cpc.server.message.server_message.ServerMessage Class Reference
Inheritance diagram for cpc.server.message.server_message.ServerMessage:
cpc.network.server_to_server_message.ServerToServerMessage

Public Member Functions

def pingServer
 
def workerReadyForwardedRequest
 
def commandFinishedForwardedRequest
 
def heartbeatForwardedRequest
 
def deadWorkerFetchRequest
 
def pullAssetRequest
 
def clearAssetRequest
 
- Public Member Functions inherited from cpc.network.server_to_server_message.ServerToServerMessage
def initialize
 
def delegateMessage
 

Additional Inherited Members

- Static Public Member Functions inherited from cpc.network.server_to_server_message.ServerToServerMessage
def connectToSelf
 
def getNetworkTopology
 
def requestNetworkTopology
 
- Public Attributes inherited from cpc.network.server_to_server_message.ServerToServerMessage
 endNode
 
 hostNode
 
 host
 
 port
 
 serverId
 

Detailed Description

Server-to-server messages.
   These messages can be sent to any node in the network

Member Function Documentation

def cpc.server.message.server_message.ServerMessage.clearAssetRequest (   self,
  cmdID 
)
def cpc.server.message.server_message.ServerMessage.commandFinishedForwardedRequest (   self,
  cmdID,
  workerServer,
  projectServer,
  returncode,
  cputime,
  haveData 
)
A server-to-sever request doing command-finished. Used in
    forwarding non-local command-finished requests.
def cpc.server.message.server_message.ServerMessage.deadWorkerFetchRequest (   self,
  workerDir,
  runDir 
)
A server-to-sever request for fetching a set of run directories
   from a dead worker's output.
def cpc.server.message.server_message.ServerMessage.heartbeatForwardedRequest (   self,
  workerID,
  workerDir,
  workerServer,
  iteration,
  heartbeatItemsXML 
)
A server-to-sever request doing heartbeat signal. Used in
   forwarding non-local heartbeat requests.
def cpc.server.message.server_message.ServerMessage.pingServer (   self,
  serverId 
)
def cpc.server.message.server_message.ServerMessage.pullAssetRequest (   self,
  cmdID,
  assetType 
)
def cpc.server.message.server_message.ServerMessage.workerReadyForwardedRequest (   self,
  workerID,
  archdata,
  topology,
  originatingServer,
  heartbeatInterval,
  originatingClient = None 
)

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