"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "test/testudp.cpp" between
muscle8.20.zip and muscle8.30.zip

About: MUSCLE (Multi User Server Client Linking Environment) is a messaging server and networking API. The included server program ("muscled") lets its clients message each other, and/or store information in its serverside hierarchical database.

testudp.cpp  (muscle8.20):testudp.cpp  (muscle8.30)
skipping to change at line 76 skipping to change at line 76
UDPSocketDataIORef udpIORef(new UDPSocketDataIO(s, false)); UDPSocketDataIORef udpIORef(new UDPSocketDataIO(s, false));
(void) udpIORef()->SetPacketSendDestination(IPAddressAndPort(target, 3960, tr ue)); (void) udpIORef()->SetPacketSendDestination(IPAddressAndPort(target, 3960, tr ue));
printf("Set UDP send destination to [%s]\n", udpIORef()->GetPacketSendDestina tion().ToString()()); printf("Set UDP send destination to [%s]\n", udpIORef()->GetPacketSendDestina tion().ToString()());
AbstractMessageIOGatewayRef agw = CreateUDPGateway(useTextGateway, useRawGate way, udpIORef); AbstractMessageIOGatewayRef agw = CreateUDPGateway(useTextGateway, useRawGate way, udpIORef);
StdinDataIO stdinIO(false); StdinDataIO stdinIO(false);
QueueGatewayMessageReceiver stdinInQueue; QueueGatewayMessageReceiver stdinInQueue;
PlainTextMessageIOGateway stdinGateway; PlainTextMessageIOGateway stdinGateway;
stdinGateway.SetDataIO(DataIORef(&stdinIO, false)); stdinGateway.SetDataIO(DummyDataIORef(stdinIO));
const int stdinFD = stdinIO.GetReadSelectSocket().GetFileDescriptor(); const int stdinFD = stdinIO.GetReadSelectSocket().GetFileDescriptor();
QueueGatewayMessageReceiver inQueue; QueueGatewayMessageReceiver inQueue;
SocketMultiplexer multiplexer; SocketMultiplexer multiplexer;
printf("UDP Event loop starting...\n"); printf("UDP Event loop starting...\n");
while(s()) while(s())
{ {
const int fd = s.GetFileDescriptor(); const int fd = s.GetFileDescriptor();
multiplexer.RegisterSocketForReadReady(fd); multiplexer.RegisterSocketForReadReady(fd);
if (agw()->HasBytesToOutput()) multiplexer.RegisterSocketForWriteReady(fd) ; if (agw()->HasBytesToOutput()) multiplexer.RegisterSocketForWriteReady(fd) ;
 End of changes. 1 change blocks. 
1 lines changed or deleted 1 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)