|
|
|
@ -167,7 +167,7 @@ static bool compare_slice_buffer_with_buffer(grpc_slice_buffer *slices, const ch |
|
|
|
|
slice = grpc_slice_from_static_buffer(write_buffer, kBufferSize); |
|
|
|
|
grpc_slice_buffer_add(&write_slices, slice); |
|
|
|
|
init_event_closure(&write_done, &write); |
|
|
|
|
grpc_endpoint_write(ep_, &write_slices, &write_done); |
|
|
|
|
grpc_endpoint_write(ep_, &write_slices, &write_done, nullptr); |
|
|
|
|
|
|
|
|
|
XCTAssertEqual([self waitForEvent:&write timeout:kWriteTimeout], YES); |
|
|
|
|
XCTAssertEqual(reinterpret_cast<grpc_error *>(write), GRPC_ERROR_NONE); |
|
|
|
@ -224,7 +224,7 @@ static bool compare_slice_buffer_with_buffer(grpc_slice_buffer *slices, const ch |
|
|
|
|
slice = grpc_slice_from_static_buffer(write_buffer, kBufferSize); |
|
|
|
|
grpc_slice_buffer_add(&write_slices, slice); |
|
|
|
|
init_event_closure(&write_done, &write); |
|
|
|
|
grpc_endpoint_write(ep_, &write_slices, &write_done); |
|
|
|
|
grpc_endpoint_write(ep_, &write_slices, &write_done, nullptr); |
|
|
|
|
|
|
|
|
|
XCTAssertEqual([self waitForEvent:&write timeout:kWriteTimeout], YES); |
|
|
|
|
XCTAssertEqual(reinterpret_cast<grpc_error *>(write), GRPC_ERROR_NONE); |
|
|
|
@ -273,7 +273,7 @@ static bool compare_slice_buffer_with_buffer(grpc_slice_buffer *slices, const ch |
|
|
|
|
slice = grpc_slice_from_static_buffer(write_buffer, kBufferSize); |
|
|
|
|
grpc_slice_buffer_add(&write_slices, slice); |
|
|
|
|
init_event_closure(&write_done, &write); |
|
|
|
|
grpc_endpoint_write(ep_, &write_slices, &write_done); |
|
|
|
|
grpc_endpoint_write(ep_, &write_slices, &write_done, nullptr); |
|
|
|
|
|
|
|
|
|
XCTAssertEqual([self waitForEvent:&write timeout:kWriteTimeout], YES); |
|
|
|
|
XCTAssertEqual(reinterpret_cast<grpc_error *>(write), GRPC_ERROR_NONE); |
|
|
|
|