379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
|
# ifdef OF_HAVE_BLOCKS
if (_block != NULL)
return _block(object, _buffer, length, address, exception);
else {
# endif
bool (*func)(id, SEL, OFUDPSocket *, void *, size_t,
of_udp_socket_address_t address, id, id) =
(bool (*)(id, SEL, OFUDPSocket *, void *, size_t,
of_udp_socket_address_t, id, id))
[_target methodForSelector: _selector];
return func(_target, _selector, object, _buffer, length,
address, _context, exception);
# ifdef OF_HAVE_BLOCKS
}
# endif
}
# ifdef OF_HAVE_BLOCKS
- (void)dealloc
{
[_block release];
[super dealloc];
|
|
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
|
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
|
# ifdef OF_HAVE_BLOCKS
if (_block != NULL)
return _block(object, _buffer, length, address, exception);
else {
# endif
bool (*func)(id, SEL, OFUDPSocket *, void *, size_t,
of_udp_socket_address_t, id, id) =
(bool (*)(id, SEL, OFUDPSocket *, void *, size_t,
of_udp_socket_address_t, id, id))
[_target methodForSelector: _selector];
return func(_target, _selector, object, _buffer, length,
address, _context, exception);
# ifdef OF_HAVE_BLOCKS
}
# endif
}
# ifdef OF_HAVE_BLOCKS
- (void)dealloc
{
[_block release];
[super dealloc];
}
# endif
@end
@implementation OFRunLoop_UDPSendQueueItem
- (bool)handleObject: (id)object
{
id exception = nil;
@try {
[object sendBuffer: _buffer
length: _length
receiver: &_receiver];
} @catch (id e) {
exception = e;
}
# ifdef OF_HAVE_BLOCKS
if (_block != NULL) {
_length = _block(object, &_buffer,
(exception == nil ? _length : 0), &_receiver, exception);
return (_length > 0);
} else {
# endif
size_t (*func)(id, SEL, OFUDPSocket *, const void *, size_t,
of_udp_socket_address_t *, id, id) =
(size_t (*)(id, SEL, OFUDPSocket *, const void *, size_t,
of_udp_socket_address_t *, id, id))
[_target methodForSelector: _selector];
_length = func(_target, _selector, object, &_buffer,
(exception == nil ? _length : 0), &_receiver, _context,
exception);
return (_length > 0);
# ifdef OF_HAVE_BLOCKS
}
# endif
}
# ifdef OF_HAVE_BLOCKS
- (void)dealloc
{
[_block release];
[super dealloc];
|
555
556
557
558
559
560
561
562
563
564
565
566
567
568
|
queueItem->_target = [target retain];
queueItem->_selector = selector;
queueItem->_context = [context retain];
queueItem->_buffer = buffer;
queueItem->_length = length;
})
}
# ifdef OF_HAVE_BLOCKS
+ (void)of_addAsyncReadForStream: (OFStream *)stream
buffer: (void *)buffer
length: (size_t)length
block: (of_stream_async_read_block_t)block
{
|
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
|
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
|
queueItem->_target = [target retain];
queueItem->_selector = selector;
queueItem->_context = [context retain];
queueItem->_buffer = buffer;
queueItem->_length = length;
})
}
+ (void)of_addAsyncSendForUDPSocket: (OFUDPSocket *)socket
buffer: (const void *)buffer
length: (size_t)length
receiver: (of_udp_socket_address_t)receiver
target: (id)target
selector: (SEL)selector
context: (id)context
{
ADD_WRITE(OFRunLoop_UDPSendQueueItem, socket, {
queueItem->_target = [target retain];
queueItem->_selector = selector;
queueItem->_context = [context retain];
queueItem->_buffer = buffer;
queueItem->_length = length;
queueItem->_receiver = receiver;
})
}
# ifdef OF_HAVE_BLOCKS
+ (void)of_addAsyncReadForStream: (OFStream *)stream
buffer: (void *)buffer
length: (size_t)length
block: (of_stream_async_read_block_t)block
{
|
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
|
+ (void)of_addAsyncReceiveForUDPSocket: (OFUDPSocket *)socket
buffer: (void *)buffer
length: (size_t)length
block: (of_udp_socket_async_receive_block_t)
block
{
ADD_READ(OFRunLoop_UDPReceiveQueueItem, socket, {
queueItem->_buffer = buffer;
queueItem->_length = length;
queueItem->_block = [block copy];
})
}
# endif
# undef ADD_READ
# undef ADD_WRITE
+ (void)of_cancelAsyncRequestsForObject: (id)object
|
>
>
>
>
>
>
>
>
>
>
>
>
>
>
|
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
|
+ (void)of_addAsyncReceiveForUDPSocket: (OFUDPSocket *)socket
buffer: (void *)buffer
length: (size_t)length
block: (of_udp_socket_async_receive_block_t)
block
{
ADD_READ(OFRunLoop_UDPReceiveQueueItem, socket, {
queueItem->_block = [block copy];
queueItem->_buffer = buffer;
queueItem->_length = length;
})
}
+ (void)of_addAsyncSendForUDPSocket: (OFUDPSocket *)socket
buffer: (const void *)buffer
length: (size_t)length
receiver: (of_udp_socket_address_t)receiver
block: (of_udp_socket_async_send_block_t)block
{
ADD_WRITE(OFRunLoop_UDPSendQueueItem, socket, {
queueItem->_block = [block copy];
queueItem->_buffer = buffer;
queueItem->_length = length;
queueItem->_receiver = receiver;
})
}
# endif
# undef ADD_READ
# undef ADD_WRITE
+ (void)of_cancelAsyncRequestsForObject: (id)object
|