Package | Description |
---|---|
com.bensherman.rtlsdrdjava.tcpcli | |
jimpatrizi.com.netrtl |
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.BlockingQueue<Message> |
TcpClient.completedMsgQueue
When a client writes a message to the server, once the response has been
retrieved, this queue is updated with the Message instance describing the
pair.
|
private java.util.Queue<Message> |
TcpSocketReader.msgsWaitingForResponseQueue
Queue of messages which are waiting for their associated responses to be
received from the server
|
private java.util.concurrent.BlockingQueue<Message> |
TcpClient.sendMsgQueue
New messages to be sent to the server are placed in this queue.
|
Modifier and Type | Method and Description |
---|---|
Message |
TcpClient.getCompletedMessage()
THIS CALL BLOCKS on completedMsgQueue.
|
(package private) Message |
TcpSocketReader.getResponseFromSocket()
Each call to this function is intended to build a response for the oldest
message which hasn't been responded to.
|
(package private) Message |
TcpSocketReader.pollMostRecentlyRespondedToMsgAndSetResponse(java.lang.String response,
Message.ResponseType responseMsgType)
Executes poll() on msgsWaitingForResponseQueue, which should always contain
at least one Message when this function is executed.
|
(package private) Message |
TcpClient.takeMsgFromSendMsgQueue()
Calls take() on the send message queue, causing the calling thread to block.
|
Modifier and Type | Method and Description |
---|---|
(package private) void |
TcpClient.addToCompletedMsgQueue(Message completedMsg)
Add a completed Message instance (i.e.
|
(package private) void |
TcpSocketReader.addToWaitingForResponseQueue(Message msgNeedingResponse)
Adds the message specified by the parameter to the queue of messages which
are waiting for a response.
|
private void |
TcpSocketWriter.write(Message msg)
Writes the message specified by the parameter, followed by a newline to the
server.
|
Modifier and Type | Method and Description |
---|---|
private void |
ResponseListener.handleErrorMessage(Message msg)
If Error, update the UI field that had the error to show INVALID, should only happen for edittexts
|