Classes | |
class | ServerHandler |
Public Member Functions | |
void | setup () |
void | tearDown () |
void | testSendAfterIncomingQueueShutdown () throws InterruptedException |
void | testSendAfterOutgoingQueueShutdown () throws InterruptedException |
void | testSendAfterServerChannelClosed () throws InterruptedException |
void | testSendAndReceiveLatchedMessage () throws InterruptedException |
void | testSendAndReceiveMessage () throws InterruptedException |
Private Member Functions | |
Channel | buildServerChannel () |
TcpClient | connect (TcpClientManager TcpClientManager, Channel serverChannel) |
CountDownLatch | expectMessage (IncomingMessageQueue< std_msgs.String > incomingMessageQueue) throws InterruptedException |
void | expectMessages () throws InterruptedException |
void | startRepeatingPublisher () |
Private Attributes | |
ExecutorService | executorService |
std_msgs.String | expectedMessage |
IncomingMessageQueue < std_msgs.String > | firstIncomingMessageQueue |
TcpClientManager | firstTcpClientManager |
OutgoingMessageQueue< Message > | outgoingMessageQueue |
IncomingMessageQueue < std_msgs.String > | secondIncomingMessageQueue |
TcpClientManager | secondTcpClientManager |
Static Private Attributes | |
static final boolean | DEBUG = false |
static final Log | log = LogFactory.getLog(MessageQueueIntegrationTest.class) |
static final int | QUEUE_CAPACITY = 128 |
Definition at line 65 of file MessageQueueIntegrationTest.java.
Channel org.ros.internal.transport.MessageQueueIntegrationTest.buildServerChannel | ( | ) | [inline, private] |
Definition at line 147 of file MessageQueueIntegrationTest.java.
TcpClient org.ros.internal.transport.MessageQueueIntegrationTest.connect | ( | TcpClientManager | TcpClientManager, |
Channel | serverChannel | ||
) | [inline, private] |
Definition at line 175 of file MessageQueueIntegrationTest.java.
CountDownLatch org.ros.internal.transport.MessageQueueIntegrationTest.expectMessage | ( | IncomingMessageQueue< std_msgs.String > | incomingMessageQueue | ) | throws InterruptedException [inline, private] |
Definition at line 179 of file MessageQueueIntegrationTest.java.
void org.ros.internal.transport.MessageQueueIntegrationTest.expectMessages | ( | ) | throws InterruptedException [inline, private] |
Definition at line 192 of file MessageQueueIntegrationTest.java.
void org.ros.internal.transport.MessageQueueIntegrationTest.setup | ( | ) | [inline] |
Definition at line 111 of file MessageQueueIntegrationTest.java.
void org.ros.internal.transport.MessageQueueIntegrationTest.startRepeatingPublisher | ( | ) | [inline, private] |
Definition at line 137 of file MessageQueueIntegrationTest.java.
void org.ros.internal.transport.MessageQueueIntegrationTest.tearDown | ( | ) | [inline] |
Definition at line 132 of file MessageQueueIntegrationTest.java.
void org.ros.internal.transport.MessageQueueIntegrationTest.testSendAfterIncomingQueueShutdown | ( | ) | throws InterruptedException [inline] |
Definition at line 230 of file MessageQueueIntegrationTest.java.
void org.ros.internal.transport.MessageQueueIntegrationTest.testSendAfterOutgoingQueueShutdown | ( | ) | throws InterruptedException [inline] |
Definition at line 248 of file MessageQueueIntegrationTest.java.
void org.ros.internal.transport.MessageQueueIntegrationTest.testSendAfterServerChannelClosed | ( | ) | throws InterruptedException [inline] |
Definition at line 239 of file MessageQueueIntegrationTest.java.
void org.ros.internal.transport.MessageQueueIntegrationTest.testSendAndReceiveLatchedMessage | ( | ) | throws InterruptedException [inline] |
Definition at line 209 of file MessageQueueIntegrationTest.java.
void org.ros.internal.transport.MessageQueueIntegrationTest.testSendAndReceiveMessage | ( | ) | throws InterruptedException [inline] |
Definition at line 200 of file MessageQueueIntegrationTest.java.
final boolean org.ros.internal.transport.MessageQueueIntegrationTest.DEBUG = false [static, private] |
Definition at line 67 of file MessageQueueIntegrationTest.java.
ExecutorService org.ros.internal.transport.MessageQueueIntegrationTest.executorService [private] |
Definition at line 72 of file MessageQueueIntegrationTest.java.
std_msgs.String org.ros.internal.transport.MessageQueueIntegrationTest.expectedMessage [private] |
Definition at line 78 of file MessageQueueIntegrationTest.java.
IncomingMessageQueue<std_msgs.String> org.ros.internal.transport.MessageQueueIntegrationTest.firstIncomingMessageQueue [private] |
Definition at line 76 of file MessageQueueIntegrationTest.java.
TcpClientManager org.ros.internal.transport.MessageQueueIntegrationTest.firstTcpClientManager [private] |
Definition at line 73 of file MessageQueueIntegrationTest.java.
final Log org.ros.internal.transport.MessageQueueIntegrationTest.log = LogFactory.getLog(MessageQueueIntegrationTest.class) [static, private] |
Definition at line 68 of file MessageQueueIntegrationTest.java.
OutgoingMessageQueue<Message> org.ros.internal.transport.MessageQueueIntegrationTest.outgoingMessageQueue [private] |
Definition at line 75 of file MessageQueueIntegrationTest.java.
final int org.ros.internal.transport.MessageQueueIntegrationTest.QUEUE_CAPACITY = 128 [static, private] |
Definition at line 70 of file MessageQueueIntegrationTest.java.
IncomingMessageQueue<std_msgs.String> org.ros.internal.transport.MessageQueueIntegrationTest.secondIncomingMessageQueue [private] |
Definition at line 77 of file MessageQueueIntegrationTest.java.
TcpClientManager org.ros.internal.transport.MessageQueueIntegrationTest.secondTcpClientManager [private] |
Definition at line 74 of file MessageQueueIntegrationTest.java.