diff --git a/Testing/tcpport-client.m b/Testing/tcpport-client.m new file mode 100644 index 000000000..32a4fa637 --- /dev/null +++ b/Testing/tcpport-client.m @@ -0,0 +1,25 @@ +#include +#include + +int main () +{ + id port; + id packet; + int i; + + port = [TcpOutPort newForSendingToRegisteredName: @"tcpport-test" + onHost: @"localhost"]; + + for (i = 0; i < 5; i++) + { + packet = [[TcpPacket alloc] initForSendingWithCapacity: 100 + replyPort: nil]; + [packet writeFormat: @"Here is message number %d\n", i]; + [port sendPacket: packet withTimeout: 20 * 1000]; + [packet release]; + } + + [port close]; + + exit (0); +} diff --git a/Testing/tcpport-server.m b/Testing/tcpport-server.m new file mode 100644 index 000000000..ae1f365a0 --- /dev/null +++ b/Testing/tcpport-server.m @@ -0,0 +1,21 @@ +#include +#include + +int main () +{ + id port; + id packet; + + port = [TcpInPort newForReceivingFromRegisteredName: @"tcpport-test"]; + + while ((packet = [port receivePacketWithTimeout: 20 * 1000])) + { + fprintf (stdout, "received >"); + fwrite ([packet streamBuffer], [packet streamEofPosition], 1, stdout); + fprintf (stdout, "<\n"); + [packet release]; + } + fprintf (stdout, "Timed out. Exiting.\n"); + + exit (0); +}