gnustep/libs-base
0
0
Fork 0
mirror of https://github.com/gnustep/libs-base.git synced 2025-04-22 16:33:29 +00:00
Code Issues Projects Releases Packages Wiki Activity

(announce_new_connection): New function.

Browse source 
(announce_broken_connection): New function.
(main): Register new functions for notifications.  Send messages back
to clients to test reply port mechanism.


git-svn-id: svn+ssh://svn.gna.org/svn/gnustep/libs/base/trunk@1073 72102866-910b-0410-8b05-ffd578937521
This commit is contained in:
Andrew McCallum 1996-03-06 14:45:09 +00:00
parent fa6177e350
commit ed8cc76c38
1 changed files with 61 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

66
Testing/tcpport-server.m
View file

@ -1,18 +1,74 @@
#include <stdio.h>
#include <objects/TcpPort.h>
#include <objects/Notification.h>
#include <objects/Invocation.h>
int main ()
id announce_new_connection (id notification)
{
id in_port = [notification object];
id out_port = [notification userInfo];
printf ("{%@}\n\tconnected to\n\t{%@}\n",
[out_port description], [in_port description]);
printf ("Now servicing %d connection(s).\n",
[in_port numberOfConnectedOutPorts]);
return nil;
}
id announce_broken_connection (id notification)
{
id in_port = [notification object];
id out_port = [notification userInfo];
printf ("{%@}\n\tdisconnected from\n\t{%@}\n",
[out_port description], [in_port description]);
printf ("Now servicing %d connection(s).\n",
[in_port numberOfConnectedOutPorts]);
return nil;
}
int main (int argc, char *argv[])
{
id port;
id packet;
unsigned message_count = 0;
id reply_port;
port = [TcpInPort newForReceivingFromRegisteredName: @"tcpport-test"];
while ((packet = [port receivePacketWithTimeout: 20 * 1000]))
if (argc > 1)
port = [TcpInPort newForReceivingFromRegisteredName:
[NSString stringWithCString: argv[1]]];
else
port = [TcpInPort newForReceivingFromRegisteredName: @"tcpport-test"];
[NotificationDispatcher
addObserver: nil
invocation: [[[ObjectFunctionInvocation alloc]
initWithObjectFunction: announce_broken_connection]
autorelease]
name: InPortClientBecameInvalidNotification
object: port];
[NotificationDispatcher
addObserver: nil
invocation: [[[ObjectFunctionInvocation alloc]
initWithObjectFunction: announce_new_connection]
autorelease]
name: InPortAcceptedClientNotification
object: port];
printf ("Waiting for connections.\n");
while ((packet = [port receivePacketWithTimeout: -1]))
{
message_count++;
fprintf (stdout, "received >");
fwrite ([packet streamBuffer], [packet streamEofPosition], 1, stdout);
fwrite ([packet streamBuffer] + [packet streamBufferPrefix],
[packet streamEofPosition], 1, stdout);
fprintf (stdout, "<\n");
reply_port = [packet replyPort];
[packet release];
packet = [[TcpPacket alloc] initForSendingWithCapacity: 100
replyPort: port];
[packet writeFormat: @"Your's was my message number %d",
message_count];
[reply_port sendPacket: packet withTimeout: 20 * 1000];
[packet release];
}
fprintf (stdout, "Timed out. Exiting.\n");