28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
@interface OFSCTPSocketTests: OTTestCase
@end
@implementation OFSCTPSocketTests
- (void)testSCTPSocket
{
OFSCTPSocket *server, *client, *accepted;
uint16_t port;
char buffer[6];
server = [OFSCTPSocket socket];
client = [OFSCTPSocket socket];
@try {
port = [server bindToHost: @"127.0.0.1" port: 0];
} @catch (OFBindSocketFailedException *e) {
switch (e.errNo) {
case EPROTONOSUPPORT:
OTSkip(@"SCTP unsupported");
default:
@throw e;
}
}
[server listen];
[client connectToHost: @"127.0.0.1" port: port];
accepted = [server accept];
OTAssertEqualObjects(OFSocketAddressString(accepted.remoteAddress),
@"127.0.0.1");
[client sendBuffer: "Hello!" length: 6];
[accepted receiveIntoBuffer: buffer length: 6];
OTAssertEqual(memcmp(buffer, "Hello!", 6), 0);
}
@end
|
|
|
|
>
|
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
|
@interface OFSCTPSocketTests: OTTestCase
@end
@implementation OFSCTPSocketTests
- (void)testSCTPSocket
{
OFSCTPSocket *server, *client, *accepted;
OFSocketAddress address;
char buffer[6];
server = [OFSCTPSocket socket];
client = [OFSCTPSocket socket];
@try {
address = [server bindToHost: @"127.0.0.1" port: 0];
} @catch (OFBindSocketFailedException *e) {
switch (e.errNo) {
case EPROTONOSUPPORT:
OTSkip(@"SCTP unsupported");
default:
@throw e;
}
}
[server listen];
[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];
[accepted receiveIntoBuffer: buffer length: 6];
OTAssertEqual(memcmp(buffer, "Hello!", 6), 0);
}
@end
|