32
33
34
35
36
37
38
39
40
41
42
43
44
45
|
- (void)testSCTPSocket
{
OFSCTPSocket *server, *client, *accepted;
OFSocketAddress address;
char buffer[6];
uint16_t streamID;
uint32_t PPID;
server = [OFSCTPSocket socket];
client = [OFSCTPSocket socket];
@try {
address = [server bindToHost: @"127.0.0.1" port: 0];
} @catch (OFBindSocketFailedException *e) {
|
>
|
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
- (void)testSCTPSocket
{
OFSCTPSocket *server, *client, *accepted;
OFSocketAddress address;
char buffer[6];
uint16_t streamID;
uint32_t PPID;
OFSCTPPacketFlags flags;
server = [OFSCTPSocket socket];
client = [OFSCTPSocket socket];
@try {
address = [server bindToHost: @"127.0.0.1" port: 0];
} @catch (OFBindSocketFailedException *e) {
|
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
|
[client connectToHost: @"127.0.0.1"
port: OFSocketAddressIPPort(&address)];
accepted = [server accept];
OTAssertEqualObjects(OFSocketAddressString(accepted.remoteAddress),
@"127.0.0.1");
[client sendBuffer: "Hello!" length: 6 streamID: 1 PPID: 1234];
[accepted receiveIntoBuffer: buffer
length: 6
streamID: &streamID
PPID: &PPID];
OTAssertEqual(memcmp(buffer, "Hello!", 6), 0);
OTAssertEqual(streamID, 1);
OTAssertEqual(PPID, 1234);
}
@end
|
|
>
>
>
>
|
>
>
|
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
|
[client connectToHost: @"127.0.0.1"
port: OFSocketAddressIPPort(&address)];
accepted = [server accept];
OTAssertEqualObjects(OFSocketAddressString(accepted.remoteAddress),
@"127.0.0.1");
[client sendBuffer: "Hello!"
length: 6
streamID: 1
PPID: 1234
flags: OFSCTPPacketUnordered];
[accepted receiveIntoBuffer: buffer
length: 6
streamID: &streamID
PPID: &PPID
flags: &flags];
OTAssertEqual(memcmp(buffer, "Hello!", 6), 0);
OTAssertEqual(streamID, 1);
OTAssertEqual(PPID, 1234);
OTAssertTrue(flags & OFSCTPPacketUnordered);
}
@end
|