@@ -24,14 +24,14 @@ - (void)setUp {
24
24
queue_[0 ] = dispatch_queue_create (" PTProtocolTests.queue_[0]" , DISPATCH_QUEUE_SERIAL);
25
25
PTAssertNotNULL (queue_[0 ]);
26
26
channel_[0 ] = dispatch_io_create (DISPATCH_IO_STREAM, socket_[0 ], queue_[0 ], ^(int error) {
27
- close (socket_[0 ]);
27
+ close (self-> socket_ [0 ]);
28
28
});
29
29
PTAssertNotNULL (channel_[0 ]);
30
30
31
31
queue_[1 ] = dispatch_queue_create (" PTProtocolTests.queue_[1]" , DISPATCH_QUEUE_SERIAL);
32
32
PTAssertNotNULL (queue_[1 ]);
33
33
channel_[1 ] = dispatch_io_create (DISPATCH_IO_STREAM, socket_[1 ], queue_[1 ], ^(int error) {
34
- close (socket_[1 ]);
34
+ close (self-> socket_ [1 ]);
35
35
});
36
36
PTAssertNotNULL (channel_[1 ]);
37
37
@@ -107,7 +107,7 @@ - (void)readFrameWithClient:(int)clientIndex
107
107
XCTAssertEqual (receivedPayloadSize, expectedPayloadSize);
108
108
109
109
if (expectedPayloadSize != 0 ) {
110
- [protocol_[clientIndex] readPayloadOfSize: receivedPayloadSize overChannel: channel_[clientIndex] callback: ^(NSError *error, dispatch_data_t contiguousData, const uint8_t *buffer, size_t bufferSize) {
110
+ [self -> protocol_[clientIndex] readPayloadOfSize: receivedPayloadSize overChannel: self -> channel_[clientIndex] callback: ^(NSError *error, dispatch_data_t contiguousData, const uint8_t *buffer, size_t bufferSize) {
111
111
PTAssertNotNULL (contiguousData);
112
112
PTAssertNotNULL (buffer);
113
113
XCTAssertEqual ((uint32_t )bufferSize, receivedPayloadSize);
@@ -191,7 +191,7 @@ - (void)test3_protocol_echo_frame {
191
191
XCTAssertEqual (receivedPayloadSize, payloadSize);
192
192
193
193
// Reply on channel 1
194
- [protocol_[1 ] sendFrameOfType: PTFrameTypeTestPingReply tag: receivedFrameTag withPayload: nil overChannel: channel_[1 ] callback: ^(NSError *error) {
194
+ [self -> protocol_[1 ] sendFrameOfType: PTFrameTypeTestPingReply tag: receivedFrameTag withPayload: nil overChannel: self -> channel_[1 ] callback: ^(NSError *error) {
195
195
if (error) XCTFail (@" sendFrameOfType failed: %@ " , error);
196
196
}];
197
197
}];
@@ -326,7 +326,7 @@ - (void)test6_protocol_transmit_multiple_frames_with_payload {
326
326
};
327
327
328
328
if (payloadSize) {
329
- [protocol_[1 ] readPayloadOfSize: payloadSize overChannel: channel_[1 ] callback: ^(NSError *error, dispatch_data_t contiguousData, const uint8_t *buffer, size_t bufferSize) {
329
+ [self -> protocol_[1 ] readPayloadOfSize: payloadSize overChannel: self -> channel_[1 ] callback: ^(NSError *error, dispatch_data_t contiguousData, const uint8_t *buffer, size_t bufferSize) {
330
330
PTAssertNotNULL (contiguousData);
331
331
PTAssertNotNULL (buffer);
332
332
XCTAssertEqual ((uint32_t )bufferSize, payloadSize);
0 commit comments