libs-base/Testing/tcpport-client.m

#include <stdio.h>
#include <base/TcpPort.h>
#include <Foundation/NSRunLoop.h>
#include <base/Invocation.h>
#include <Foundation/NSDate.h>

id handle_incoming_packet (id packet)
{
  fprintf (stdout, "received >");
  fwrite ([packet streamBuffer] + [packet streamBufferPrefix],
	  [packet streamEofPosition], 1, stdout);
  fprintf (stdout, "<\n");
  [packet release];
  return nil;
}

int main (int argc, char *argv[])
{
  id out_port;
  id in_port;
  id packet;
  int i;

  if (argc > 1)
    out_port = [TcpOutPort newForSendingToRegisteredName: 
			     [NSString stringWithCString: argv[1]]
			   onHost: @"localhost"];
  else
    out_port = [TcpOutPort newForSendingToRegisteredName: @"tcpport-test"
			   onHost: nil];

  in_port = [TcpInPort newForReceiving];

  [in_port setReceivedPacketInvocation:
	     [[[ObjectFunctionInvocation alloc]
		initWithObjectFunction: handle_incoming_packet]
	       autorelease]];

  [[NSRunLoop currentRunLoop] addPort: in_port
			      forMode: NSDefaultRunLoopMode];
  
  for (i = 0; i < 10; i++)
    {
      packet = [[TcpOutPacket alloc] initForSendingWithCapacity: 100
				     replyInPort: in_port];
      [packet writeFormat: @"Here is message number %d", i];
      [out_port sendPacket: packet timeout: 10.0];
      [packet release];

      [[NSRunLoop currentRunLoop] runUntilDate:
	[NSDate dateWithTimeIntervalSinceNow: 1.0]];
    }

  [out_port close];

  exit (0);
}