| Modifier and Type | Method and Description |
|---|---|
void |
cMsg.connect()
Method to connect to a particular domain.
|
static java.lang.String |
cMsgUtilities.constructServerName(java.lang.String s)
This method tests its input argument to see if it is in the proper format
for a server; namely, "host:port".
|
void |
cMsg.disconnect()
Method to close the connection to the domain.
|
void |
cMsg.flush(int timeout)
Method to force cMsg client to send pending communications with domain.
|
java.math.BigInteger |
cMsgPayloadItem.getBigInt()
Gets the payload item as a BigInteger object.
|
java.math.BigInteger[] |
cMsgPayloadItem.getBigIntArray()
Gets the payload item as an array of BigInteger objects.
|
byte[] |
cMsgPayloadItem.getBinary()
Gets the payload item as a byte array object holding binary data.
|
byte[][] |
cMsgPayloadItem.getBinaryArray()
Gets the payload item as an array of byte array objects holding binary data.
|
static java.lang.String |
cMsgUtilities.getBroadcastAddress(java.lang.String ip)
Given a local IP address as an argument, this method will return its
broadcast or subnet address.
|
byte |
cMsgPayloadItem.getByte()
Gets the payload item as a byte (8-bit integer).
|
byte[] |
cMsgPayloadItem.getByteArray()
Gets the payload item as an array of bytes (8-bit integers).
|
double |
cMsgPayloadItem.getDouble()
Gets the payload item as a double.
|
double[] |
cMsgPayloadItem.getDoubleArray()
Gets the payload item as an array of doubles.
|
float |
cMsgPayloadItem.getFloat()
Gets the payload item as a float.
|
float[] |
cMsgPayloadItem.getFloatArray()
Gets the payload item as an array of floats.
|
int |
cMsgPayloadItem.getInt()
Gets the payload item as a int (32-bit integer).
|
int[] |
cMsgPayloadItem.getIntArray()
Gets the payload item as an array of ints (32-bit integers).
|
long |
cMsgPayloadItem.getLong()
Gets the payload item as a long (64-bit integer).
|
long[] |
cMsgPayloadItem.getLongArray()
Gets the payload item as an array of longs (64-bit integers).
|
static java.lang.String |
cMsgUtilities.getMatchingLocalIpAddress(java.lang.String ip)
Given an IP address as an argument, this method will return that if it matches
one of the local IP addresses.
|
cMsgMessage |
cMsgPayloadItem.getMessage()
Gets the payload item as a cMsgMessage object.
|
cMsgMessage[] |
cMsgPayloadItem.getMessageArray()
Gets the payload item as an array of cMsgMessage objects.
|
short |
cMsgPayloadItem.getShort()
Gets the payload item as a short (16-bit integer).
|
short[] |
cMsgPayloadItem.getShortArray()
Gets the payload item as an array of shorts (16-bit integers).
|
java.lang.String |
cMsgPayloadItem.getString()
Gets the payload item as a String object.
|
java.lang.String[] |
cMsgPayloadItem.getStringArray()
Gets the payload item as an array of String objects.
|
cMsgMessage |
cMsg.monitor(java.lang.String command)
This method is a synchronous call to receive a message containing monitoring data
which describes the state of the domain the user is connected to.
|
cMsgMessage |
cMsgMessage.nullResponse()
Creates a proper response message to this message which was sent by a client calling
sendAndGet.
|
java.lang.String |
cMsgMessage.payloadToString()
This method converts the message payload to a printable string in XML format.
|
cMsgMessage |
cMsgMessage.response()
Creates a proper response message to this message which was sent by a client calling
sendAndGet.
|
void |
cMsg.send(cMsgMessage message)
Method to send a message to the domain for further distribution.
|
cMsgMessage |
cMsg.sendAndGet(cMsgMessage message,
int timeout)
The message is sent as it would be in the
cMsg.send(cMsgMessage) method. |
void |
cMsgMessage.setByteArray(byte[] b,
int offset,
int length)
Copy byte array into message by copying "length" number of elements
starting at "offset".
|
void |
cMsgMessage.setByteArray(java.nio.ByteBuffer buf)
Copy buffer data into message's byte array.
|
void |
cMsgMessage.setByteArrayEndian(int endian)
Set endianness of the byte array data.
|
void |
cMsgMessage.setByteArrayLength(int length)
Set byte array length of data of interest.
|
void |
cMsgMessage.setByteArrayNoCopy(byte[] b,
int offset,
int length)
Set byte array to the given argument without copying the byte array
itself - only the reference is copied.
|
void |
cMsgMessage.setByteArrayOffset(int offset)
Set byte array index to region of interest.
|
protected int |
cMsgMessage.setFieldsFromText(java.lang.String text,
int flag)
This method takes a string representation of the whole compound payload,
including the system (hidden) fields of the message,
as it gets sent over the network and converts it into the standard message
payload.
|
void |
cMsgMessage.setHistoryLengthMax(int historyLengthMax)
Sets the maximum number of entries this message keeps of its history of various parameters.
|
void |
cMsg.setUDL(java.lang.String UDL)
Set the UDL of the client.
|
void |
cMsg.shutdownClients(java.lang.String client,
boolean includeMe)
Method to shutdown the given clients.
|
void |
cMsg.shutdownServers(java.lang.String server,
boolean includeMyServer)
Method to shutdown the given servers.
|
cMsgSubscriptionHandle |
cMsg.subscribe(java.lang.String subject,
java.lang.String type,
cMsgCallbackInterface cb,
java.lang.Object userObj)
Method to subscribe to receive messages of a subject and type from the domain.
|
cMsgMessage |
cMsg.subscribeAndGet(java.lang.String subject,
java.lang.String type,
int timeout)
This method is like a one-time subscribe.
|
int |
cMsg.syncSend(cMsgMessage message,
int timeout)
Method to send a message to the domain for further distribution
and wait for a response from the domain that got it.
|
void |
cMsg.unsubscribe(cMsgSubscriptionHandle handle)
Method to unsubscribe a previous subscription to receive messages of a subject and type
from the domain.
|
| Constructor and Description |
|---|
cMsg(java.lang.String UDL,
java.lang.String name,
java.lang.String description)
Constructor which creates the object used to connect to the UDL (domain) specified.
|
cMsgPayloadItem(java.lang.String name,
java.math.BigInteger big)
Construct a payload item from an unsigned 64-bit integer.
|
cMsgPayloadItem(java.lang.String name,
java.math.BigInteger[] bigs)
Construct a payload item from an array of unsigned 64-bit integers.
|
cMsgPayloadItem(java.lang.String name,
java.math.BigInteger[] bigs,
java.lang.String txt,
int noHeadLen,
boolean isSystem)
Construct a payload item from an array of unsigned 64-bit integers.
|
cMsgPayloadItem(java.lang.String name,
java.math.BigInteger big,
java.lang.String txt,
int noHeadLen,
boolean isSystem)
Construct a payload item from an unsigned 64-bit integer.
|
cMsgPayloadItem(java.lang.String name,
byte b)
Construct a payload item from an 8-bit integer.
|
cMsgPayloadItem(java.lang.String name,
byte[] b)
Construct a payload item from an array of 8-bit integers.
|
cMsgPayloadItem(java.lang.String name,
byte[][] b)
Construct a payload item from an array of byte arrays containing binary data.
|
cMsgPayloadItem(java.lang.String name,
byte[][] b,
int[] end)
Construct a payload item from an array of byte arrays containing binary data.
|
cMsgPayloadItem(java.lang.String name,
byte[][] b,
int[] end,
java.lang.String txt,
int noHeadLen,
boolean isSystem)
Construct a payload item from an array of byte arrays containing binary data.
|
cMsgPayloadItem(java.lang.String name,
byte[] b,
int end)
Construct a payload item from a byte array containing binary data.
|
cMsgPayloadItem(java.lang.String name,
byte[] b,
int end,
java.lang.String txt,
int noHeadLen,
boolean isSystem)
Construct a payload item from a byte array containing binary data.
|
cMsgPayloadItem(java.lang.String name,
byte[] b,
java.lang.String txt,
int noHeadLen,
boolean isSystem)
Construct a payload item from an array of 8-bit integers.
|
cMsgPayloadItem(java.lang.String name,
byte b,
java.lang.String txt,
int noHeadLen,
boolean isSystem)
Construct a payload item from an 8-bit integer.
|
cMsgPayloadItem(java.lang.String name,
cMsgMessage msg)
Construct a payload item from a cMsgMessage object.
|
cMsgPayloadItem(java.lang.String name,
cMsgMessage[] msgs)
Construct a payload item from an array of cMsgMessage objects.
|
cMsgPayloadItem(java.lang.String name,
cMsgMessage[] msgs,
java.lang.String txt,
int noHeadLen,
boolean isSystem)
Construct a payload item from an array of cMsgMessage objects.
|
cMsgPayloadItem(java.lang.String name,
cMsgMessage msg,
java.lang.String txt,
int noHeadLen,
boolean isSystem)
Construct a payload item from a cMsgMessage object.
|
cMsgPayloadItem(java.lang.String name,
double d)
Construct a payload item from a double.
|
cMsgPayloadItem(java.lang.String name,
double[] d)
Construct a payload item from an array of doubles.
|
cMsgPayloadItem(java.lang.String name,
double[] d,
java.lang.String txt,
int noHeadLen,
boolean isSystem)
Construct a payload item from an array of doubles.
|
cMsgPayloadItem(java.lang.String name,
double d,
java.lang.String txt,
int noHeadLen,
boolean isSystem)
Construct a payload item from a double.
|
cMsgPayloadItem(java.lang.String name,
float f)
Construct a payload item from a float.
|
cMsgPayloadItem(java.lang.String name,
float[] f)
Construct a payload item from an array of floats.
|
cMsgPayloadItem(java.lang.String name,
float[] f,
java.lang.String txt,
int noHeadLen,
boolean isSystem)
Construct a payload item from an array of floats.
|
cMsgPayloadItem(java.lang.String name,
float f,
java.lang.String txt,
int noHeadLen,
boolean isSystem)
Construct a payload item from a float.
|
cMsgPayloadItem(java.lang.String name,
int i)
Construct a payload item from a 32-bit integer.
|
cMsgPayloadItem(java.lang.String name,
int[] i)
Construct a payload item from an array of 32-bit integers.
|
cMsgPayloadItem(java.lang.String name,
int[] i,
java.lang.String txt,
int noHeadLen,
boolean isSystem,
boolean unsigned)
Construct a payload item from an array of 32-bit integers.
|
cMsgPayloadItem(java.lang.String name,
int i,
boolean isSystem)
Constructor for hidden system fields.
|
cMsgPayloadItem(java.lang.String name,
int i,
java.lang.String txt,
int noHeadLen,
boolean isSystem)
Construct a payload item from a 32-bit integer.
|
cMsgPayloadItem(java.lang.String name,
long l)
Construct a payload item from a 64-bit integer.
|
cMsgPayloadItem(java.lang.String name,
long[] l)
Construct a payload item from an array of 64-bit integers.
|
cMsgPayloadItem(java.lang.String name,
long[] l,
boolean isSystem)
Constructor for hidden system fields like cMsgSenderTimeHistory.
|
cMsgPayloadItem(java.lang.String name,
long[] l,
java.lang.String txt,
int noHeadLen,
boolean isSystem,
boolean unsigned)
Construct a payload item from an array of 64-bit integers.
|
cMsgPayloadItem(java.lang.String name,
long l,
java.lang.String txt,
int noHeadLen,
boolean isSystem)
Construct a payload item from a 64-bit integer.
|
cMsgPayloadItem(java.lang.String name,
short s)
Construct a payload item from a 16-bit integer.
|
cMsgPayloadItem(java.lang.String name,
short[] s)
Construct a payload item from an array of 16-bit integers.
|
cMsgPayloadItem(java.lang.String name,
short[] s,
java.lang.String txt,
int noHeadLen,
boolean isSystem,
boolean unsigned)
Construct a payload item from an array of 16-bit integers.
|
cMsgPayloadItem(java.lang.String name,
short s,
java.lang.String txt,
int noHeadLen,
boolean isSystem)
Construct a payload item from a 16-bit integer.
|
cMsgPayloadItem(java.lang.String name,
java.lang.String s)
Construct a payload item from a String object.
|
cMsgPayloadItem(java.lang.String name,
java.lang.String[] s)
Construct a payload item from a String array.
|
cMsgPayloadItem(java.lang.String name,
java.lang.String[] s,
boolean isSystem)
Constructor for hidden system fields like cMsgSenderHistory.
|
cMsgPayloadItem(java.lang.String name,
java.lang.String[] s,
java.lang.String txt,
int noHeadLen,
boolean isSystem)
Construct a payload item from a String array.
|
cMsgPayloadItem(java.lang.String name,
java.lang.String s,
boolean isSystem)
Constructor for hidden system fields.
|
cMsgPayloadItem(java.lang.String name,
java.lang.String s,
java.lang.String txt,
int noHeadLen,
boolean isSystem)
Construct a payload item from a String object.
|
cMsgPayloadItem(java.lang.String name,
T[] ta)
Construct a payload item from an array of objects implementing the Number interface.
|
| Modifier and Type | Method and Description |
|---|---|
void |
cMsgConsumer.run()
This method is executed as a thread.
|
void |
cMsgProducer.run()
This method is executed as a thread.
|
void |
cMsgGetResponder.run()
This method is executed as a thread.
|
void |
cMsgMonitor.run()
This method is executed as a thread.
|
void |
cMsgGetConsumer.run()
This method is executed as a thread.
|
void |
rcClientKiller.run() |
void |
cMsgPayloadProducer.run()
This method is executed as a thread.
|
void |
cMsgShutdowner.run()
Run as a stand-alone application.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CA.connect()
Connects to CA channel after parsing UDL.
|
void |
CA.disconnect()
Disconnects from CA channel.
|
void |
CA.flush(int timeout)
Complete what the "send" method started -- write the double value to channel
for real.
|
void |
CA.send(cMsgMessage msg)
Set double value of channel from message's text field.
|
cMsgSubscriptionHandle |
CA.subscribe(java.lang.String subject,
java.lang.String type,
cMsgCallbackInterface cb,
java.lang.Object userObj)
Does a CA "monitor on" for this channel.
|
cMsgMessage |
CA.subscribeAndGet(java.lang.String subject,
java.lang.String type,
int timeout)
Get the channel's value and place it in the return message's text field.
|
void |
CA.unsubscribe(cMsgSubscriptionHandle obj)
Does a CA "monitor off" for this channel.
|
| Modifier and Type | Method and Description |
|---|---|
void |
cMsg.connect()
Method to connect to the domain server from this client.
|
java.util.HashSet<java.lang.String> |
cMsgServerClient.connect(int fromNsTcpPort,
int fromNsMulticastPort,
boolean isOriginator,
java.lang.String cloudPassword,
java.lang.String clientPassword,
boolean multicasting)
Method to connect to the domain server from a cMsg server acting as a bridge.
|
protected void |
cMsg.connectWithMulticast()
Method to multicast in order to find the domain server from this client.
|
(package private) cMsg.ParsedUDL |
cMsg.parseUDL(java.lang.String udl)
Method to parse the Universal Domain Locator (UDL) into its various components.
|
void |
cMsg.send(cMsgMessage message)
Method to send a message to the domain for further distribution.
|
cMsgMessage |
cMsg.sendAndGet(cMsgMessage message,
int timeout)
The message is sent as it would be in the
cMsgDomainInterface.send(org.jlab.coda.cMsg.cMsgMessage) method and a single synchronous
response is received. |
void |
cMsg.setUDL(java.lang.String UDL)
Set the UDL of the client which may be a semicolon separated list of UDLs in this domain.
|
void |
cMsg.shutdownClients(java.lang.String client,
boolean includeMe)
Method to shutdown the given client(s).
|
void |
cMsg.shutdownServers(java.lang.String server,
boolean includeMyServer)
Method to shutdown the given server(s).
|
cMsgSubscriptionHandle |
cMsg.subscribe(java.lang.String subject,
java.lang.String type,
cMsgCallbackInterface cb,
java.lang.Object userObj)
Method to subscribe to receive messages of a subject and type from the domain.
|
cMsgMessage |
cMsg.subscribeAndGet(java.lang.String subject,
java.lang.String type,
int timeout)
This method is like a one-time subscribe.
|
int |
cMsg.syncSend(cMsgMessage message,
int timeout)
Method to send a message to the domain for further distribution
and wait for a response from the subdomain handler that got it.
|
(package private) void |
cMsg.talkToNameServerFromClient(java.net.Socket socket)
This method gets the host and port of the domain server from the name server.
|
(package private) java.util.HashSet<java.lang.String> |
cMsgServerClient.talkToNameServerFromServer(java.net.Socket socket,
int cloudStatus,
int fromNSTcpPort,
int fromNSMulticastPort,
boolean isOriginator,
java.lang.String cloudPassword,
java.lang.String clientPassword)
This method gets the host and port of the domain server from the name server.
|
void |
cMsg.unsubscribe(cMsgSubscriptionHandle obj)
Method to unsubscribe a previous subscription to receive messages of a subject and type
from the domain.
|
| Constructor and Description |
|---|
cMsg()
Constructor which does NOT automatically try to connect to the name server specified.
|
cMsgServerClient(cMsgNameServer nameServer)
Constructor.
|
| Constructor and Description |
|---|
MonitorPanel(java.lang.String udl,
Monitor tabbedPane)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
cMsgServerSubscribeInfo.addSubscription()
Calling this method means this client is now subscribed to this sub/type/namespace.
|
java.util.Set<java.lang.String> |
cMsgServerBridge.connect(boolean isOriginator,
java.lang.String cloudPassword,
java.lang.String clientPassword,
boolean multicasting)
Method to connect to server.
|
| Constructor and Description |
|---|
cMsgDomainServer(cMsgNameServer nameServer,
cMsgClientData info,
boolean noUdp,
int debug)
Constructor.
|
cMsgDomainServerSelect(cMsgNameServer nameServer,
int clientsMax,
int debug,
boolean noUdp)
Constructor.
|
cMsgServerBridge(cMsgNameServer nameServer,
java.lang.String serverName,
int thisNsTcpPort,
int thisNsUdpPort)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
cMsgMessageDeliverer.deliverMessage(cMsgMessage msg,
int msgType)
Method to deliver a message from a domain server's subdomain handler to a client.
|
void |
cMsgMessageDeliverer.deliverMessage(int i,
int j,
int msgType)
Method to deliver an integer from a domain server's subdomain handler to a client.
|
void |
cMsgMessageDeliverer.deliverMessage(java.lang.String[] strs,
int msgType)
Method to deliver an array of string from a domain server's subdomain handler to a client.
|
void |
CA.handleClientShutdown()
Method to handle a client or domain server (and therefore subdomain handler) shutdown.
|
void |
LogFile.handleClientShutdown()
Close file if no one else is using it.
|
void |
Queue.handleClientShutdown()
Close connection to database.
|
void |
Database.handleClientShutdown()
Method to handle a client or domain server (and therefore subdomain handler) shutdown.
|
void |
Et.handleClientShutdown()
Dump leftover events, then close the ET system.
|
void |
SmartSockets.handleClientShutdown()
Close connection to smartsockets server.
|
void |
cMsg.handleSendAndGetRequest(cMsgMessageFull message)
Method to synchronously get a single message from a responder to a
message being sent by the client.
|
void |
FileQueue.handleSendAndGetRequest(cMsgMessageFull message)
Returns message at head of queue.
|
void |
Queue.handleSendAndGetRequest(cMsgMessageFull msg)
Returns message at head of queue.
|
void |
TcpServer.handleSendAndGetRequest(cMsgMessageFull msg)
Sends text string to server to execute, returns result.
|
void |
Database.handleSendAndGetRequest(cMsgMessageFull msg)
Executes sql statement in message text field, returns resultset as payload arrays.
|
void |
CA.handleSendRequest(cMsgMessageFull msg)
Method to handle a message sent by a domain client.
|
void |
LogFile.handleSendRequest(cMsgMessageFull msg)
Write message to a file.
|
void |
cMsg.handleSendRequest(cMsgMessageFull message)
This method handles a message sent by regular (non-server) client.
|
void |
FileQueue.handleSendRequest(cMsgMessageFull msg)
Write message to queue file.
|
void |
Queue.handleSendRequest(cMsgMessageFull msg)
Inserts message into SQL database table via JDBC.
|
void |
Et.handleSendRequest(cMsgMessageFull msg)
If there are no events to work with, get chunk number of empty events from
the ET system.
|
void |
SmartSockets.handleSendRequest(cMsgMessageFull msg)
Forwards message to smartsockets system.
|
void |
cMsg.handleServerSendAndGetRequest(cMsgMessageFull message,
java.lang.String namespace)
Method to synchronously get a single message from a responder to a message
being sent by the server client.
|
int |
cMsg.handleServerSendAndGetRequest(cMsgMessageFull message,
java.lang.String namespace,
cMsgNotifier notifier)
Method to synchronously get a single message from a responder to a
message being sent by the client.
|
void |
cMsg.handleServerSubscribeAndGetRequest(java.lang.String subject,
java.lang.String type,
cMsgNotifier notifier)
Method for regular client to synchronously get a single message from
the server for a one-time subscription of a subject and type.
|
void |
cMsg.handleServerSubscribeRequest(java.lang.String subject,
java.lang.String type,
java.lang.String namespace)
Method to handle subscribe request sent by another cMsg server (server client).
|
void |
cMsg.handleServerUnsubscribeRequest(java.lang.String subject,
java.lang.String type,
java.lang.String namespace)
Method to handle unsubscribe request sent by another cMsg server (server client).
|
void |
cMsg.handleShutdownClientsRequest(java.lang.String client,
boolean includeMe)
Method to handle request to shutdown clients sent by client.
|
void |
CA.handleSubscribeAndGetRequest(java.lang.String subject,
java.lang.String type,
int id)
Method to synchronously get a single message from the server for a one-time
subscription of a subject and type.
|
void |
cMsg.handleSubscribeAndGetRequest(java.lang.String subject,
java.lang.String type,
int id)
Method for regular client to synchronously get a single message from
the server for a one-time subscription of a subject and type.
|
void |
CA.handleSubscribeRequest(java.lang.String subject,
java.lang.String type,
int receiverSubscribeId)
Performs CA monitorOn.
|
void |
cMsg.handleSubscribeRequest(java.lang.String subject,
java.lang.String type,
int id)
Method to handle subscribe request sent by regular client.
|
void |
SmartSockets.handleSubscribeRequest(java.lang.String subject,
java.lang.String type,
int id)
Subscribe to receive smartsockets messages.
|
int |
CA.handleSyncSendRequest(cMsgMessageFull msg)
Method to handle a message sent by a domain client in synchronous mode.
|
int |
LogFile.handleSyncSendRequest(cMsgMessageFull msg)
Write message to a file.
|
int |
cMsg.handleSyncSendRequest(cMsgMessageFull message)
Method to handle message sent by client in synchronous mode.
|
int |
FileQueue.handleSyncSendRequest(cMsgMessageFull msg)
Write message to queue file.
|
int |
Queue.handleSyncSendRequest(cMsgMessageFull msg)
Inserts message into SQL database table via JDBC.
|
int |
Database.handleSyncSendRequest(cMsgMessageFull msg)
Executes sql statement in message text field.
|
int |
Et.handleSyncSendRequest(cMsgMessageFull msg)
If there are no events to work with, get chunk number of empty events from
the ET system.
|
void |
cMsg.handleUnSendAndGetRequest(int id)
Method to handle remove sendAndGet request sent by any client
(hidden from user).
|
void |
cMsg.handleUnsubscribeAndGetRequest(java.lang.String subject,
java.lang.String type,
int id)
Method to handle a remove subscribeAndGet request sent by client
(hidden from user).
|
void |
CA.handleUnsubscribeRequest(java.lang.String subject,
java.lang.String type,
int receiverSubscribeId)
Performs CA monitorOff.
|
void |
cMsg.handleUnsubscribeRequest(java.lang.String subject,
java.lang.String type,
int id)
Method to handle unsubscribe request sent by regular client.
|
void |
cMsg.localSend(cMsgMessage message,
java.lang.String namespace)
This method handles a message sent by a local bridge object's callback.
|
void |
CA.registerClient(cMsgClientInfo info)
Creates JCA, context, and channel objects.
|
void |
LogFile.registerClient(cMsgClientInfo info)
Open file in which to store messages using append mode.
|
void |
cMsg.registerClient(cMsgClientInfo info)
Method to register a domain client.
|
void |
FileQueue.registerClient(cMsgClientInfo info)
Creates files to store messages in.
|
void |
Queue.registerClient(cMsgClientInfo info)
Creates separate database connection for each client connection.
|
void |
TcpServer.registerClient(cMsgClientInfo info)
Connects to tcpserver.
|
void |
Database.registerClient(cMsgClientInfo info)
Creates separate database connection for each client connection.
|
void |
Dummy.registerClient(cMsgClientInfo info) |
void |
Et.registerClient(cMsgClientInfo info)
Open ET system and attach to GrandCentral station.
|
void |
SmartSockets.registerClient(cMsgClientInfo info)
Connect to smartsockets server.
|
void |
LogFile.setUDLRemainder(java.lang.String UDLRemainder)
Method to give the subdomain handler the appropriate part
of the UDL the client used to talk to the domain server.
|
void |
cMsg.setUDLRemainder(java.lang.String UDLRemainder)
This method gives this subdomain handler the appropriate part
of the UDL the client used to talk to the domain server.
|
void |
FileQueue.setUDLRemainder(java.lang.String UDLRemainder)
Method to give the subdomain handler the appropriate part
of the UDL the client used to talk to the domain server.
|
void |
Queue.setUDLRemainder(java.lang.String UDLRemainder)
Method to give the subdomain handler the appropriate part
of the UDL the client used to talk to the domain server.
|
void |
TcpServer.setUDLRemainder(java.lang.String UDLRemainder)
Method to give the subdomain handler the appropriate part
of the UDL the client used to talk to the domain server.
|
void |
Database.setUDLRemainder(java.lang.String UDLRemainder)
Method to give the subdomain handler the appropriate part
of the UDL the client used to talk to the domain server.
|
void |
Et.setUDLRemainder(java.lang.String udlRemainder)
Parse arg to get ET system file, method to open ET system, chunk size.
|
void |
SmartSockets.setUDLRemainder(java.lang.String UDLRemainder)
Method to give the subdomain handler the appropriate part
of the UDL the client used to talk to the domain server.
|
| Modifier and Type | Method and Description |
|---|---|
void |
cMsgDomainAdapter.connect()
Method to connect to a particular domain.
|
void |
cMsgDomainInterface.connect()
Method to connect to a particular domain.
|
void |
cMsgDeliverMessageInterface.deliverMessage(cMsgMessage msg,
int msgType)
Method to deliver a message from a domain server's subdomain handler to a client.
|
void |
cMsgDeliverMessageInterface.deliverMessage(int i,
int j,
int msgType)
Method to deliver 2 integers from a domain server's subdomain handler to a client.
|
void |
cMsgDeliverMessageInterface.deliverMessage(java.lang.String[] strs,
int msgType)
Method to deliver an array of strings from a domain server's subdomain handler to a client.
|
void |
cMsgDomainAdapter.disconnect()
Method to close the connection to the domain.
|
void |
cMsgDomainInterface.disconnect()
Method to close the connection to the domain.
|
void |
cMsgDomainAdapter.flush(int timeout)
Method to force cMsg client to send pending communications with domain.
|
void |
cMsgDomainInterface.flush(int timeout)
Method to force cMsg client to send pending communications with domain.
|
void |
cMsgSubdomainInterface.handleClientShutdown()
Method to handle a client or domain server (and therefore subdomain handler) shutdown.
|
void |
cMsgSubdomainAdapter.handleClientShutdown()
Method to handle a client or domain server (and therefore subdomain handler) shutdown.
|
void |
cMsgSubdomainInterface.handleSendAndGetRequest(cMsgMessageFull message)
Method to synchronously get a single message by sending out a
message which is responded to by its receiver(s).
|
void |
cMsgSubdomainAdapter.handleSendAndGetRequest(cMsgMessageFull message)
Method to synchronously get a single message by sending out a
message which is responded to by its receiver(s).
|
void |
cMsgSubdomainInterface.handleSendRequest(cMsgMessageFull message)
Method to handle a message sent by a domain client.
|
void |
cMsgSubdomainAdapter.handleSendRequest(cMsgMessageFull message)
Method to handle a message sent by a domain client.
|
void |
cMsgSubdomainInterface.handleShutdownClientsRequest(java.lang.String client,
boolean includeMe)
Method to handle a request to shutdown clients sent by a domain client.
|
void |
cMsgSubdomainAdapter.handleShutdownClientsRequest(java.lang.String client,
boolean includeMe)
Method to handle a request to shutdown clients sent by a domain client.
|
void |
cMsgSubdomainInterface.handleSubscribeAndGetRequest(java.lang.String subject,
java.lang.String type,
int id)
Method to synchronously get a single message from the server for a one-time
subscription of a subject and type.
|
void |
cMsgSubdomainAdapter.handleSubscribeAndGetRequest(java.lang.String subject,
java.lang.String type,
int id)
Method to synchronously get a single message from the server for a one-time
subscription of a subject and type.
|
void |
cMsgSubdomainInterface.handleSubscribeRequest(java.lang.String subject,
java.lang.String type,
int id)
Method to handle a subscribe request sent by a domain client.
|
void |
cMsgSubdomainAdapter.handleSubscribeRequest(java.lang.String subject,
java.lang.String type,
int id)
Method to handle a subscribe request sent by a domain client.
|
int |
cMsgSubdomainInterface.handleSyncSendRequest(cMsgMessageFull message)
Method to handle a message sent by a domain client in synchronous mode.
|
int |
cMsgSubdomainAdapter.handleSyncSendRequest(cMsgMessageFull message)
Method to handle a message sent by a domain client in synchronous mode.
|
void |
cMsgSubdomainInterface.handleUnSendAndGetRequest(int id)
Method to remove a sendAndGet request previously sent by a domain client.
|
void |
cMsgSubdomainAdapter.handleUnSendAndGetRequest(int id)
Method to remove a sendAndGet request previously sent by a domain client.
|
void |
cMsgSubdomainInterface.handleUnsubscribeAndGetRequest(java.lang.String subject,
java.lang.String type,
int id)
Method to remove a subscribeAndGet request previously sent by a domain client.
|
void |
cMsgSubdomainAdapter.handleUnsubscribeAndGetRequest(java.lang.String subject,
java.lang.String type,
int id)
Method to remove a subscribeAndGet request previously sent by a domain client.
|
void |
cMsgSubdomainInterface.handleUnsubscribeRequest(java.lang.String subject,
java.lang.String type,
int id)
Method to handle an unsubscribe request sent by a domain client.
|
void |
cMsgSubdomainAdapter.handleUnsubscribeRequest(java.lang.String subject,
java.lang.String type,
int id)
Method to handle an unsubscribe request sent by a domain client.
|
cMsgMessage |
cMsgDomainAdapter.monitor(java.lang.String command)
This method is a synchronous call to receive a message containing monitoring data
which describes the state of the cMsg domain the user is connected to.
|
cMsgMessage |
cMsgDomainInterface.monitor(java.lang.String command)
This method is a synchronous call to receive a message containing monitoring data
which describes the state of the cMsg domain the user is connected to.
|
cMsgMessageFull |
cMsgMessageFull.nullResponse()
Creates a proper response message to this message which was sent by a client calling
sendAndGet.
|
static cMsgMessage |
cMsgMessageFull.parseXml(java.lang.String XML)
This method parses an XML string representing a cMsg message
(using a DOM parser) and turns it into a cMsg message.
|
void |
cMsgSubdomainInterface.registerClient(cMsgClientInfo info)
Method to register a domain client.
|
void |
cMsgSubdomainAdapter.registerClient(cMsgClientInfo info)
Method to register a domain client.
|
cMsgMessageFull |
cMsgMessageFull.response()
Creates a proper response message to this message which was sent by a client calling
sendAndGet.
|
void |
cMsgDomainAdapter.send(cMsgMessage message)
Method to send a message to the domain for further distribution.
|
void |
cMsgDomainInterface.send(cMsgMessage message)
Method to send a message to the domain for further distribution.
|
cMsgMessage |
cMsgDomainAdapter.sendAndGet(cMsgMessage message,
int timeout)
The message is sent as it would be in the
cMsgDomainInterface.send(org.jlab.coda.cMsg.cMsgMessage) method and a single synchronous
response is received. |
cMsgMessage |
cMsgDomainInterface.sendAndGet(cMsgMessage message,
int timeout)
The message is sent as it would be in the
cMsgDomainInterface.send(org.jlab.coda.cMsg.cMsgMessage) method and a single synchronous
response is received. |
int |
cMsgMessageFull.setFieldsFromText(java.lang.String text,
int flag)
This method takes a string representation of the whole compound payload,
including the system (hidden) fields of the message,
as it gets sent over the network and converts it into the standard message
payload.
|
void |
cMsgDomainAdapter.setUDL(java.lang.String UDL)
Set the UDL of the client.
|
void |
cMsgDomainInterface.setUDL(java.lang.String UDL)
Set the UDL of the client.
|
void |
cMsgSubdomainInterface.setUDLRemainder(java.lang.String UDLRemainder)
Method to give the subdomain handler the appropriate part
of the UDL the client used to talk to the domain server.
|
void |
cMsgSubdomainAdapter.setUDLRemainder(java.lang.String UDLRemainder)
Method to give the subdomain handler the appropriate part
of the UDL the client used to talk to the domain server.
|
void |
cMsgDomainAdapter.shutdownClients(java.lang.String client,
boolean includeMe)
Method to shutdown the given client(s).
|
void |
cMsgDomainInterface.shutdownClients(java.lang.String client,
boolean includeMe)
Method to shutdown the given client(s).
|
void |
cMsgDomainAdapter.shutdownServers(java.lang.String server,
boolean includeMyServer)
Method to shutdown the given server(s).
|
void |
cMsgDomainInterface.shutdownServers(java.lang.String server,
boolean includeMyServer)
Method to shutdown the given server(s).
|
cMsgSubscriptionHandle |
cMsgDomainAdapter.subscribe(java.lang.String subject,
java.lang.String type,
cMsgCallbackInterface cb,
java.lang.Object userObj)
Method to subscribe to receive messages of a subject and type from the domain.
|
cMsgSubscriptionHandle |
cMsgDomainInterface.subscribe(java.lang.String subject,
java.lang.String type,
cMsgCallbackInterface cb,
java.lang.Object userObj)
Method to subscribe to receive messages of a subject and type from the domain.
|
cMsgMessage |
cMsgDomainAdapter.subscribeAndGet(java.lang.String subject,
java.lang.String type,
int timeout)
This method is like a one-time subscribe.
|
cMsgMessage |
cMsgDomainInterface.subscribeAndGet(java.lang.String subject,
java.lang.String type,
int timeout)
This method is like a one-time subscribe.
|
int |
cMsgDomainAdapter.syncSend(cMsgMessage message,
int timeout)
Method to send a message to the domain for further distribution
and wait for a response from the subdomain handler that got it.
|
int |
cMsgDomainInterface.syncSend(cMsgMessage message,
int timeout)
Method to send a message to the domain for further distribution
and wait for a response from the subdomain handler that got it.
|
void |
cMsgDomainAdapter.unsubscribe(cMsgSubscriptionHandle handle)
Method to unsubscribe a previous subscription to receive messages of a subject and type
from the domain.
|
void |
cMsgDomainInterface.unsubscribe(cMsgSubscriptionHandle handle)
Method to unsubscribe a previous subscription to receive messages of a subject and type
from the domain.
|
| Constructor and Description |
|---|
cMsgMessageFull(java.io.File file)
Constructor reading file generated by writing cMsgMessage.toString() output.
|
cMsgMessageFull(java.lang.String XML)
Constructor using XML string generated by cMsgMessage.toString().
|
| Modifier and Type | Method and Description |
|---|---|
void |
EmuClient.connect()
Method to connect to the server from this client.
|
void |
EmuClient.flush(int timeout)
Method to force cMsg client to send pending communications with domain.
|
(package private) void |
EmuClient.parseUDL(java.lang.String udlRemainder)
Method to parse the Universal Domain Locator (UDL) into its various components.
|
void |
EmuClient.send(cMsgMessage message)
Method to send a message to the Emu domain server.
|
| Constructor and Description |
|---|
EmuClient()
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
File.connect()
Opens a file.
|
void |
File.flush(int timeout)
Flushes output.
|
void |
File.send(cMsgMessage msg)
Writes to file.
|
int |
File.syncSend(cMsgMessage message,
int timeout)
Calls send to write to file.
|
| Modifier and Type | Method and Description |
|---|---|
void |
RunControl.connect()
Method to connect to the codaComponent server from this client.
|
void |
RunControl.flush(int timeout)
Does nothing in this domain.
|
cMsgMessage |
RunControl.monitor(java.lang.String command)
This method is a synchronous call to receive a message containing monitoring data
from the rc multicast server specified in the UDL.
|
(package private) void |
RunControl.parseUDL(java.lang.String udlRemainder)
Method to parse the Universal Domain Locator (UDL) into its various components.
|
void |
RunControl.send(cMsgMessage message)
Method to send a message to the domain server for further distribution.
|
cMsgSubscriptionHandle |
RunControl.subscribe(java.lang.String subject,
java.lang.String type,
cMsgCallbackInterface cb,
java.lang.Object userObj)
Method to subscribe to receive messages of a subject and type from the rc server.
|
void |
RunControl.unsubscribe(cMsgSubscriptionHandle obj)
Method to unsubscribe a previous subscription to receive messages of a subject and type
from the rc server.
|
| Modifier and Type | Method and Description |
|---|---|
void |
RCMulticast.connect()
Method to connect to rc clients from this server.
|
void |
RCMulticast.send(cMsgMessage message)
Method to send an abort command to the rc client.
|
cMsgSubscriptionHandle |
RCMulticast.subscribe(java.lang.String subject,
java.lang.String type,
cMsgCallbackInterface cb,
java.lang.Object userObj)
Method to subscribe to receive messages from rc clients.
|
void |
RCMulticast.unsubscribe(cMsgSubscriptionHandle obj)
Method to unsubscribe a previous subscription to receive messages of a subject and type
from the domain.
|
| Constructor and Description |
|---|
rcListeningThread(RCMulticast server,
int port)
Constructor.
|
RCMulticast() |
| Modifier and Type | Method and Description |
|---|---|
void |
RCServer.connect()
Method to connect to the rc client from this server.
|
void |
RCServer.send(cMsgMessage message)
Method to send a message/command to the rc client.
|
cMsgMessage |
RCServer.sendAndGet(cMsgMessage message,
int timeout)
The message is sent as it would be in the
RCServer.send(org.jlab.coda.cMsg.cMsgMessage) method except that the
senderToken and creator are set. |
void |
RCServer.setUDL(java.lang.String UDL)
Set the UDL of the client which may be a semicolon separated
list of (sub)UDLs in this domain.
|
cMsgSubscriptionHandle |
RCServer.subscribe(java.lang.String subject,
java.lang.String type,
cMsgCallbackInterface cb,
java.lang.Object userObj)
This is a method to subscribe to receive messages of a subject and type from the rc client.
|
cMsgMessage |
RCServer.subscribeAndGet(java.lang.String subject,
java.lang.String type,
int timeout)
This method is like a one-time subscribe.
|
int |
RCServer.syncSend(cMsgMessage message,
int timeout)
Method to send a "ping" command to the rc client.
|
void |
RCServer.unsubscribe(cMsgSubscriptionHandle obj)
Method to unsubscribe a previous subscription.
|
| Constructor and Description |
|---|
rcListeningThread(RCServer server)
Constructor for regular clients.
|
RCServer()
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ConstructorInfo.addPrimitiveArg(java.lang.String name,
java.lang.String value)
Add to the argument list a primitive type (except char) with the given value.
|
void |
ConstructorInfo.addPrimitiveArg(java.lang.String name,
java.lang.String value,
int index)
Add to the argument list a primitive type (except char) with the given value
at the given index into the existing list of arguments.
|
void |
ConstructorInfo.addReferenceArg(java.lang.String className,
ConstructorInfo info)
Add to the argument list a reference type with the information necessary
to construct it.
|
void |
ConstructorInfo.addReferenceArg(java.lang.String className,
ConstructorInfo info,
int index)
Add to the argument list a reference type with the information necessary
to construct it at the given index into the existing list of arguments.
|
void |
Commander.connectToServer(java.lang.String udl,
java.lang.String name,
java.lang.String description)
Connect to the specified cMsg server.
|
void |
Commander.findExecutors(int milliseconds)
Find all executors currently running.
|
void |
Commander.kill(ExecutorInfo exec,
boolean killProcesses)
Kill the specified executor and, optionally, all processes it has started.
|
void |
Commander.killAll(boolean killProcesses)
Kill all executors and, optionally, all processes they have started.
|
boolean |
Commander.reconnectToServer()
Tries to connect to the last cMsg server successfully connected to.
|
java.util.List<CommandReturn> |
Commander.startCommandInWindows(java.util.List<ExecutorInfo> executors,
java.lang.String command,
int widthChars,
int heightChars)
This method is example of how to make a bunch of identical xterm windows
fill the screen in a conveniently packed manner and run a single given command
in each of the xterms.
|
java.util.List<CommandReturn> |
Commander.startCommandsInWindows(java.util.List<ExecutorInfo> executors,
java.util.List<java.lang.String> commands,
int widthChars,
int heightChars)
This method is example of how to make a bunch of identical xterm windows
fill the screen in a conveniently packed manner and run a single, different
command in each of the xterms.
|
(package private) CommandReturn |
Commander.startProcess(ExecutorInfo exec,
java.lang.String cmd,
boolean monitor,
boolean wait,
CommandCallback callback,
java.lang.Object userObject,
int timeout)
Start an external process using the specified executor.
|
CommandReturn |
Commander.startProcess(ExecutorInfo exec,
java.lang.String cmd,
boolean monitor,
CommandCallback callback,
java.lang.Object userObject)
This method is an asynchronous means of starting an external process
using the specified executor.
|
CommandReturn |
Commander.startProcess(ExecutorInfo exec,
java.lang.String cmd,
boolean monitor,
int timeout)
This method is a synchronous means of starting an external process
using the specified executor and waiting for it to finish.
|
(package private) CommandReturn |
Commander.startThread(ExecutorInfo exec,
java.lang.String className,
boolean wait,
CommandCallback callback,
java.lang.Object userObject,
int timeout,
ConstructorInfo constructorArgs)
Starts an internal thread in the specified executor and immediately
returns.
|
(package private) CommandReturn |
Commander.startThread(ExecutorInfo exec,
java.lang.String className,
CommandCallback callback,
java.lang.Object userObject,
ConstructorInfo constructorArgs)
This method is an asynchronous means of starting an internal thread
in the specified executor and immediately returns.
|
CommandReturn |
Commander.startThread(ExecutorInfo exec,
java.lang.String className,
int timeout,
ConstructorInfo constructorArgs)
This method is a synchronous means of starting an internal thread
in the specified executor and waiting for it to finish.
|
java.util.List<CommandReturn> |
Commander.startWindows(ExecutorInfo exec,
java.lang.String title,
int count,
int widthChars,
int heightChars)
This method is example of how to make a bunch of identical xterm windows
fill the screen in a conveniently packed manner.
|
CommandReturn |
Commander.startXterm(ExecutorInfo exec,
java.lang.String cmd,
java.lang.String geometry,
java.lang.String title)
Start an xterm and run the specified command in it using the specified executor.
|
void |
Commander.stop(ExecutorInfo exec,
CommandReturn commandReturn)
Stop the given process or thread on the specified executor.
|
void |
Commander.stop(ExecutorInfo exec,
int commandId)
Stop the given process or thread on the specified executor.
|
void |
Commander.stopAll()
Stop all processes and threads on all executors.
|
void |
Commander.stopAll(ExecutorInfo exec)
Stop all processes and threads on the specified executor.
|
| Constructor and Description |
|---|
Commander(java.lang.String udl,
java.lang.String name,
java.lang.String description,
java.lang.String password)
Create this object given parameters needed to make a connection to the
cMsg server.
|
Executor(java.lang.String password,
java.lang.String udl,
java.lang.String name)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TCPS.connect()
Method to connect to the TCPServer from this client.
|
void |
TCPS.send(cMsgMessage message)
Method to send a message/command to the TCPServer.
|
| Modifier and Type | Method and Description |
|---|---|
void |
jniEtTrial.getData(int byteSize,
java.nio.ByteBuffer b) |
void |
jniEtTrial.init(java.lang.String fileName,
int memByteSize) |
static void |
RCMulticastServer.main(java.lang.String[] args) |
static void |
RCClientReconnect.main(java.lang.String[] args) |
static void |
cMsgTestRcServer.main(java.lang.String[] args) |
static void |
cMsgTestRcClient.main(java.lang.String[] args) |
void |
jniEtTrial.putData(int byteSize,
int offset,
java.nio.ByteBuffer b) |
void |
RCMulticastServer.run() |
void |
VardanServer.run()
This method is executed as a thread.
|
void |
RCClientReconnect.run() |
void |
UnsubTest.run()
This method is executed as a thread.
|
void |
etTest.run()
This method is executed as a thread.
|
void |
connectTest.run()
This method is executed as a thread.
|
void |
cMsgTestRcServer.run() |
void |
DoubleTestReceiver.run()
This method is executed as a thread.
|
void |
regexpUDL.run()
This method is executed as a thread.
|
void |
DoubleTestSender.run()
This method is executed as a thread.
|
void |
cMsgTest.run()
This method is executed as a thread.
|
void |
VardanClient.run()
This method is executed as a thread.
|
void |
cMsgTestRcClient.run() |
void |
cMsgTestPayload.run()
This method is executed as a thread.
|
void |
DoubleTest.run()
This method is executed as a thread.
|
void |
VardanProducer.run()
This method is executed as a thread.
|