ibis.satin.impl.communication
Class Communication

java.lang.Object
  extended by ibis.satin.impl.communication.Communication
All Implemented Interfaces:
Protocol, Config

public final class Communication
extends Object
implements Config, Protocol


Field Summary
 ibis.ipl.Ibis ibis
           
 boolean paused
           
 ibis.ipl.PortType portType
           
 ibis.ipl.ReceivePort receivePort
           
 
Fields inherited from interface ibis.satin.impl.Config
abortLogger, ASSERTS, CHECKPOINT_CLUSTER, CHECKPOINT_FILE, CHECKPOINT_FIRST, CHECKPOINT_INTERVAL, CHECKPOINT_MAXFILESIZE, CHECKPOINT_PUSH, CHECKPOINT_QUITTIME, CHECKPOINTING, CLIENT, CLOSE_CONNECTIONS, CLOSED, commLogger, CONNECT_TIMEOUT, CONNECTIONS_ON_DEMAND, connLogger, COORDINATOR_QUIT_DELAY_TIME, DELETE_CLUSTER_TIME, DELETE_TIME, DETAILED_STATS, DUMP, FT_NAIVE, ftLogger, grtLogger, HANDLE_MESSAGES_IN_LATENCY, inletLogger, KEEP_INTRA_CONNECTIONS, KILL_TIME, LABEL_ROUTING_MCAST, mainLogger, MASTER_HOST, MAX_CONNECTIONS, MAX_STEAL_THROTTLE, properties, PROPERTY_PREFIX, QUEUE_STEALS, s_alg, s_asserts, s_client, s_close_connections, s_closed, s_connections_on_demand, s_cpt, s_cpt_cluster, s_cpt_file, s_cpt_first, s_cpt_interval, s_cpt_maxFileSize, s_cpt_push, s_cpt_quit, s_delete_cluster_time, s_delete_time, s_detailed_stats, s_dump, s_ft_connectTimeout, s_ft_naive, s_in_latency, s_keep_intra_connections, s_kill_time, s_masterhost, s_max_connections, s_max_steal_throttle, s_queue_steals, s_so_delay, s_so_lrmc, s_so_size, s_so_wait_time, s_stats, s_steal_wait_timeout, s_throttle_steals, s_unreliable, SO_MAX_INVOCATION_DELAY, SO_MAX_MESSAGE_SIZE, SO_WAIT_FOR_UPDATES_TIME, soBcastLogger, soLogger, spawnLogger, STATS, STEAL_WAIT_TIMEOUT, stealLogger, SUPPLIED_ALG, sysprops, THROTTLE_STEALS, UNRELIABLE
 
Fields inherited from interface ibis.satin.impl.communication.Protocol
ABORT, ABORT_AND_STORE, ASYNC_STEAL_AND_TABLE_REQUEST, ASYNC_STEAL_REPLY_FAILED, ASYNC_STEAL_REPLY_FAILED_TABLE, ASYNC_STEAL_REPLY_SUCCESS, ASYNC_STEAL_REPLY_SUCCESS_TABLE, ASYNC_STEAL_REQUEST, BARRIER_REPLY, BARRIER_REQUEST, BLOCKING_STEAL_REQUEST, CHECKPOINT, CHECKPOINT_INFO, CHECKPOINT_REQUEST, COORDINATOR_INFO, CRASH, EXIT, EXIT_REPLY, EXIT_STAGE2, FILE_WRITE_TIME, FILE_WRITE_TIME_REQ, GRT_UPDATE, JOB_RESULT_EXCEPTION, JOB_RESULT_NORMAL, PAUSE, RESULT_PUSH, RESULT_REQUEST, RESUME, SO_DEMAND, SO_INVOCATION, SO_NACK, SO_REQUEST, SO_TRANSFER, STEAL_AND_TABLE_REQUEST, STEAL_REPLY_FAILED, STEAL_REPLY_FAILED_TABLE, STEAL_REPLY_SUCCESS, STEAL_REPLY_SUCCESS_TABLE, STEAL_REQUEST
 
Constructor Summary
Communication(Satin s)
           
 
Method Summary
 void bcastMessage(byte opcode)
           
 void closeReceivePort()
           
 void closeSendPorts()
           
static ibis.ipl.ReceivePortIdentifier connect(ibis.ipl.SendPort s, ibis.ipl.IbisIdentifier ident, String name, long timeoutMillis)
           
 ibis.ipl.IbisCapabilities createIbisCapabilities()
           
 ibis.ipl.PortType createSatinPortType()
           
 void disableUpcallsForExit()
           
static void disconnect(ibis.ipl.SendPort s, ibis.ipl.ReceivePortIdentifier ident)
           
 ibis.ipl.IbisIdentifier elect(String election)
           
 ibis.ipl.IbisIdentifier electMaster()
           
 void enableConnections()
           
 void end()
           
 void handleBarrierReply(ibis.ipl.IbisIdentifier sender)
           
 void handleBarrierRequestMessage()
           
 void handleExitMessage(ibis.ipl.IbisIdentifier ident)
           
 void handleExitReply(ibis.ipl.ReadMessage m)
           
 void handleExitStageTwoMessage(ibis.ipl.IbisIdentifier ident)
           
static String opcodeToString(int opcode)
           
 void pause()
           
 void resume()
           
 void sendExitAck()
           
 void waitForAllNodes()
           
 void waitForExitReplies()
           
 void waitForExitStageTwo()
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

portType

public ibis.ipl.PortType portType

receivePort

public ibis.ipl.ReceivePort receivePort

ibis

public ibis.ipl.Ibis ibis

paused

public boolean paused
Constructor Detail

Communication

public Communication(Satin s)
Method Detail

electMaster

public ibis.ipl.IbisIdentifier electMaster()

elect

public ibis.ipl.IbisIdentifier elect(String election)

enableConnections

public void enableConnections()

createIbisCapabilities

public ibis.ipl.IbisCapabilities createIbisCapabilities()

createSatinPortType

public ibis.ipl.PortType createSatinPortType()

bcastMessage

public void bcastMessage(byte opcode)

disconnect

public static void disconnect(ibis.ipl.SendPort s,
                              ibis.ipl.ReceivePortIdentifier ident)

connect

public static ibis.ipl.ReceivePortIdentifier connect(ibis.ipl.SendPort s,
                                                     ibis.ipl.IbisIdentifier ident,
                                                     String name,
                                                     long timeoutMillis)

waitForExitReplies

public void waitForExitReplies()

sendExitAck

public void sendExitAck()

waitForExitStageTwo

public void waitForExitStageTwo()

closeSendPorts

public void closeSendPorts()

closeReceivePort

public void closeReceivePort()

end

public void end()

waitForAllNodes

public void waitForAllNodes()

handleExitReply

public void handleExitReply(ibis.ipl.ReadMessage m)

handleExitMessage

public void handleExitMessage(ibis.ipl.IbisIdentifier ident)

handleExitStageTwoMessage

public void handleExitStageTwoMessage(ibis.ipl.IbisIdentifier ident)

handleBarrierRequestMessage

public void handleBarrierRequestMessage()

disableUpcallsForExit

public void disableUpcallsForExit()

handleBarrierReply

public void handleBarrierReply(ibis.ipl.IbisIdentifier sender)

opcodeToString

public static String opcodeToString(int opcode)

pause

public void pause()

resume

public void resume()


The Ibis project