Differences From Artifact [99717b7858]:
- File src/OFRunLoop.m — part of check-in [c4c40e01a8] at 2024-05-01 23:14:36 on branch sctp — OFSCTPSocket: Add support for packet flags (user: js, size: 40991) [annotate] [blame] [check-ins using]
To Artifact [0a75a2f08b]:
- File
src/OFRunLoop.m
— part of check-in
[816c13da9b]
at
2024-05-01 23:23:46
on branch sctp
— OFSCTPSocket: Rename packet to message
Let's use the proper terminology for the protocol. (user: js, size: 40994) [annotate] [blame] [check-ins using]
| ︙ | ︙ | |||
220 221 222 223 224 225 226 | @public # ifdef OF_HAVE_BLOCKS OFSCTPSocketAsyncSendDataBlock _block; # endif OFData *_data; uint16_t _streamID; uint32_t _PPID; | | | 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 | @public # ifdef OF_HAVE_BLOCKS OFSCTPSocketAsyncSendDataBlock _block; # endif OFData *_data; uint16_t _streamID; uint32_t _PPID; OFSCTPMessageFlags _flags; } @end # endif #endif @implementation OFRunLoopState - (instancetype)init |
| ︙ | ︙ | |||
1038 1039 1040 1041 1042 1043 1044 |
# ifdef OF_HAVE_SCTP
@implementation OFRunLoopSCTPReceiveQueueItem
- (bool)handleObject: (id)object
{
size_t length;
uint16_t streamID;
uint32_t PPID;
| | | 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051 1052 |
# ifdef OF_HAVE_SCTP
@implementation OFRunLoopSCTPReceiveQueueItem
- (bool)handleObject: (id)object
{
size_t length;
uint16_t streamID;
uint32_t PPID;
OFSCTPMessageFlags flags;
id exception = nil;
@try {
length = [object receiveIntoBuffer: _buffer
length: _length
streamID: &streamID
PPID: &PPID
|
| ︙ | ︙ | |||
1484 1485 1486 1487 1488 1489 1490 | QUEUE_ITEM } + (void)of_addAsyncSendForSCTPSocket: (OFSCTPSocket *)sock data: (OFData *)data streamID: (uint16_t)streamID PPID: (uint32_t)PPID | | | 1484 1485 1486 1487 1488 1489 1490 1491 1492 1493 1494 1495 1496 1497 1498 |
QUEUE_ITEM
}
+ (void)of_addAsyncSendForSCTPSocket: (OFSCTPSocket *)sock
data: (OFData *)data
streamID: (uint16_t)streamID
PPID: (uint32_t)PPID
flags: (OFSCTPMessageFlags)flags
mode: (OFRunLoopMode)mode
# ifdef OF_HAVE_BLOCKS
block: (OFSCTPSocketAsyncSendDataBlock)block
# endif
delegate: (id <OFSCTPSocketDelegate>)delegate
{
NEW_WRITE(OFRunLoopSCTPSendQueueItem, sock, mode)
|
| ︙ | ︙ |