Skip to content

Commit 1b13a97

Browse files
damonbarrydamonbarry
committed
support updated xio_open definition
1 parent 77ab0e4 commit 1b13a97

File tree

8 files changed

+61
-32
lines changed

8 files changed

+61
-32
lines changed

Diff for: ‎azure-c-shared-utility

Diff for: ‎inc/header_detect_io.h

+1-1
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ extern "C" {
1717

1818
extern CONCRETE_IO_HANDLE headerdetectio_create(void* io_create_parameters, LOGGER_LOG logger_log);
1919
extern void headerdetectio_destroy(CONCRETE_IO_HANDLE header_detect_io);
20-
extern int headerdetectio_open(CONCRETE_IO_HANDLE header_detect_io, ON_IO_OPEN_COMPLETE on_io_open_complete, ON_BYTES_RECEIVED on_bytes_received, ON_IO_ERROR on_io_error, void* callback_context);
20+
extern int headerdetectio_open(CONCRETE_IO_HANDLE header_detect_io, ON_IO_OPEN_COMPLETE on_io_open_complete, void* on_io_open_complete_context, ON_BYTES_RECEIVED on_bytes_received, void* on_bytes_received_context, ON_IO_ERROR on_io_error, void* on_io_error_context);
2121
extern int headerdetectio_close(CONCRETE_IO_HANDLE header_detect_io, ON_IO_CLOSE_COMPLETE on_io_close_complete, void* callback_context);
2222
extern int headerdetectio_send(CONCRETE_IO_HANDLE header_detect_io, const void* buffer, size_t size, ON_SEND_COMPLETE on_send_complete, void* callback_context);
2323
extern void headerdetectio_dowork(CONCRETE_IO_HANDLE header_detect_io);

Diff for: ‎inc/saslclientio.h

+1-1
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ typedef struct SASLCLIENTIO_CONFIG_TAG
2323

2424
extern CONCRETE_IO_HANDLE saslclientio_create(void* io_create_parameters, LOGGER_LOG logger_log);
2525
extern void saslclientio_destroy(CONCRETE_IO_HANDLE sasl_client_io);
26-
extern int saslclientio_open(CONCRETE_IO_HANDLE sasl_client_io, ON_IO_OPEN_COMPLETE on_io_open_complete, ON_BYTES_RECEIVED on_bytes_received, ON_IO_ERROR on_io_error, void* callback_context);
26+
extern int saslclientio_open(CONCRETE_IO_HANDLE sasl_client_io, ON_IO_OPEN_COMPLETE on_io_open_complete, void* on_io_open_complete_context, ON_BYTES_RECEIVED on_bytes_received, void* on_bytes_received_context, ON_IO_ERROR on_io_error, void* on_io_error_context);
2727
extern int saslclientio_close(CONCRETE_IO_HANDLE sasl_client_io, ON_IO_CLOSE_COMPLETE on_io_close_complete, void* callback_context);
2828
extern int saslclientio_send(CONCRETE_IO_HANDLE sasl_client_io, const void* buffer, size_t size, ON_SEND_COMPLETE on_send_complete, void* callback_context);
2929
extern void saslclientio_dowork(CONCRETE_IO_HANDLE sasl_client_io);

Diff for: ‎src/connection.c

+2-2
Original file line numberDiff line numberDiff line change
@@ -1016,7 +1016,7 @@ int connection_open(CONNECTION_HANDLE connection)
10161016
{
10171017
if (!connection->is_underlying_io_open)
10181018
{
1019-
if (xio_open(connection->io, connection_on_io_open_complete, connection_on_bytes_received, connection_on_io_error, connection) != 0)
1019+
if (xio_open(connection->io, connection_on_io_open_complete, connection, connection_on_bytes_received, connection, connection_on_io_error, connection) != 0)
10201020
{
10211021
connection_set_state(connection, CONNECTION_STATE_END);
10221022
result = __LINE__;
@@ -1051,7 +1051,7 @@ int connection_listen(CONNECTION_HANDLE connection)
10511051
{
10521052
if (!connection->is_underlying_io_open)
10531053
{
1054-
if (xio_open(connection->io, connection_on_io_open_complete, connection_on_bytes_received, connection_on_io_error, connection) != 0)
1054+
if (xio_open(connection->io, connection_on_io_open_complete, connection, connection_on_bytes_received, connection, connection_on_io_error, connection) != 0)
10551055
{
10561056
connection_set_state(connection, CONNECTION_STATE_END);
10571057
result = __LINE__;

Diff for: ‎src/header_detect_io.c

+32-9
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,10 @@ typedef struct HEADER_DETECT_IO_INSTANCE_TAG
2323
ON_IO_CLOSE_COMPLETE on_io_close_complete;
2424
ON_IO_ERROR on_io_error;
2525
ON_BYTES_RECEIVED on_bytes_received;
26-
void* open_callback_context;
27-
void* close_callback_context;
26+
void* on_io_open_complete_context;
27+
void* on_io_close_complete_context;
28+
void* on_io_error_context;
29+
void* on_bytes_received_context;
2830
} HEADER_DETECT_IO_INSTANCE;
2931

3032
static const unsigned char amqp_header[] = { 'A', 'M', 'Q', 'P', 0, 1, 0, 0 };
@@ -33,18 +35,26 @@ static void indicate_error(HEADER_DETECT_IO_INSTANCE* header_detect_io_instance)
3335
{
3436
if (header_detect_io_instance->on_io_error != NULL)
3537
{
36-
header_detect_io_instance->on_io_error(header_detect_io_instance->open_callback_context);
38+
header_detect_io_instance->on_io_error(header_detect_io_instance->on_io_error_context);
3739
}
3840
}
3941

4042
static void indicate_open_complete(HEADER_DETECT_IO_INSTANCE* header_detect_io_instance, IO_OPEN_RESULT open_result)
4143
{
4244
if (header_detect_io_instance->on_io_open_complete != NULL)
4345
{
44-
header_detect_io_instance->on_io_open_complete(header_detect_io_instance->open_callback_context, open_result);
46+
header_detect_io_instance->on_io_open_complete(header_detect_io_instance->on_io_open_complete_context, open_result);
4547
}
4648
}
4749

50+
static void indicate_close_complete(HEADER_DETECT_IO_INSTANCE* header_detect_io_instance)
51+
{
52+
if (header_detect_io_instance->on_io_close_complete != NULL)
53+
{
54+
header_detect_io_instance->on_io_close_complete(header_detect_io_instance->on_io_close_complete_context);
55+
}
56+
}
57+
4858
static void on_underlying_io_bytes_received(void* context, const unsigned char* buffer, size_t size)
4959
{
5060
HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)context;
@@ -85,7 +95,7 @@ static void on_underlying_io_bytes_received(void* context, const unsigned char*
8595
break;
8696

8797
case IO_STATE_OPEN:
88-
header_detect_io_instance->on_bytes_received(header_detect_io_instance->open_callback_context, buffer, size);
98+
header_detect_io_instance->on_bytes_received(header_detect_io_instance->on_bytes_received_context, buffer, size);
8999
size = 0;
90100
break;
91101
}
@@ -101,6 +111,11 @@ static void on_underlying_io_close_complete(void* context)
101111
default:
102112
break;
103113

114+
case IO_STATE_CLOSING:
115+
header_detect_io_instance->io_state = IO_STATE_NOT_OPEN;
116+
indicate_close_complete(header_detect_io_instance);
117+
break;
118+
104119
case IO_STATE_WAIT_FOR_HEADER:
105120
case IO_STATE_OPENING_UNDERLYING_IO:
106121
header_detect_io_instance->io_state = IO_STATE_NOT_OPEN;
@@ -174,9 +189,13 @@ CONCRETE_IO_HANDLE headerdetectio_create(void* io_create_parameters, LOGGER_LOG
174189
{
175190
result->underlying_io = header_detect_io_config->underlying_io;
176191
result->on_io_open_complete = NULL;
192+
result->on_io_close_complete = NULL;
177193
result->on_io_error = NULL;
178194
result->on_bytes_received = NULL;
179-
result->open_callback_context = NULL;
195+
result->on_io_open_complete_context = NULL;
196+
result->on_io_close_complete_context = NULL;
197+
result->on_io_error_context = NULL;
198+
result->on_bytes_received_context = NULL;
180199

181200
result->io_state = IO_STATE_NOT_OPEN;
182201
}
@@ -196,7 +215,7 @@ void headerdetectio_destroy(CONCRETE_IO_HANDLE header_detect_io)
196215
}
197216
}
198217

199-
int headerdetectio_open(CONCRETE_IO_HANDLE header_detect_io, ON_IO_OPEN_COMPLETE on_io_open_complete, ON_BYTES_RECEIVED on_bytes_received, ON_IO_ERROR on_io_error, void* callback_context)
218+
int headerdetectio_open(CONCRETE_IO_HANDLE header_detect_io, ON_IO_OPEN_COMPLETE on_io_open_complete, void* on_io_open_complete_context, ON_BYTES_RECEIVED on_bytes_received, void* on_bytes_received_context, ON_IO_ERROR on_io_error, void* on_io_error_context)
200219
{
201220
int result;
202221

@@ -213,7 +232,9 @@ int headerdetectio_open(CONCRETE_IO_HANDLE header_detect_io, ON_IO_OPEN_COMPLETE
213232
header_detect_io_instance->on_bytes_received = on_bytes_received;
214233
header_detect_io_instance->on_io_open_complete = on_io_open_complete;
215234
header_detect_io_instance->on_io_error = on_io_error;
216-
header_detect_io_instance->open_callback_context = callback_context;
235+
header_detect_io_instance->on_bytes_received_context = on_bytes_received_context;
236+
header_detect_io_instance->on_io_open_complete_context = on_io_open_complete_context;
237+
header_detect_io_instance->on_io_error_context = on_io_error_context;
217238

218239
result = 0;
219240
}
@@ -226,7 +247,7 @@ int headerdetectio_open(CONCRETE_IO_HANDLE header_detect_io, ON_IO_OPEN_COMPLETE
226247
header_detect_io_instance->header_pos = 0;
227248
header_detect_io_instance->io_state = IO_STATE_OPENING_UNDERLYING_IO;
228249

229-
if (xio_open(header_detect_io_instance->underlying_io, on_underlying_io_open_complete, on_underlying_io_bytes_received, on_underlying_io_error, header_detect_io_instance) != 0)
250+
if (xio_open(header_detect_io_instance->underlying_io, on_underlying_io_open_complete, header_detect_io_instance, on_underlying_io_bytes_received, header_detect_io_instance, on_underlying_io_error, header_detect_io_instance) != 0)
230251
{
231252
result = __LINE__;
232253
}
@@ -260,6 +281,8 @@ int headerdetectio_close(CONCRETE_IO_HANDLE header_detect_io, ON_IO_CLOSE_COMPLE
260281
else
261282
{
262283
header_detect_io_instance->io_state = IO_STATE_CLOSING;
284+
header_detect_io_instance->on_io_close_complete = on_io_close_complete;
285+
header_detect_io_instance->on_io_close_complete_context = callback_context;
263286

264287
if (xio_close(header_detect_io_instance->underlying_io, on_underlying_io_close_complete, header_detect_io_instance) != 0)
265288
{

Diff for: ‎src/saslclientio.c

+18-12
Original file line numberDiff line numberDiff line change
@@ -53,8 +53,10 @@ typedef struct SASL_CLIENT_IO_INSTANCE_TAG
5353
ON_IO_OPEN_COMPLETE on_io_open_complete;
5454
ON_IO_CLOSE_COMPLETE on_io_close_complete;
5555
ON_IO_ERROR on_io_error;
56-
void* open_callback_context;
57-
void* close_callback_context;
56+
void* on_bytes_received_context;
57+
void* on_io_open_complete_context;
58+
void* on_io_close_complete_context;
59+
void* on_io_error_context;
5860
LOGGER_LOG logger_log;
5961
SASL_HEADER_EXCHANGE_STATE sasl_header_exchange_state;
6062
SASL_CLIENT_NEGOTIATION_STATE sasl_client_negotiation_state;
@@ -75,23 +77,23 @@ static void indicate_error(SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance)
7577
{
7678
if (sasl_client_io_instance->on_io_error != NULL)
7779
{
78-
sasl_client_io_instance->on_io_error(sasl_client_io_instance->open_callback_context);
80+
sasl_client_io_instance->on_io_error(sasl_client_io_instance->on_io_error_context);
7981
}
8082
}
8183

8284
static void indicate_open_complete(SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance, IO_OPEN_RESULT open_result)
8385
{
8486
if (sasl_client_io_instance->on_io_open_complete != NULL)
8587
{
86-
sasl_client_io_instance->on_io_open_complete(sasl_client_io_instance->open_callback_context, open_result);
88+
sasl_client_io_instance->on_io_open_complete(sasl_client_io_instance->on_io_open_complete_context, open_result);
8789
}
8890
}
8991

9092
static void indicate_close_complete(SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance)
9193
{
9294
if (sasl_client_io_instance->on_io_close_complete != NULL)
9395
{
94-
sasl_client_io_instance->on_io_close_complete(sasl_client_io_instance->close_callback_context);
96+
sasl_client_io_instance->on_io_close_complete(sasl_client_io_instance->on_io_close_complete_context);
9597
}
9698
}
9799

@@ -328,7 +330,7 @@ static int saslclientio_receive_byte(SASL_CLIENT_IO_INSTANCE* sasl_client_io_ins
328330
break;
329331

330332
case SASL_CLIENT_NEGOTIATION_OUTCOME_RCVD:
331-
sasl_client_io_instance->on_bytes_received(sasl_client_io_instance->open_callback_context, &b, 1);
333+
sasl_client_io_instance->on_bytes_received(sasl_client_io_instance->on_bytes_received_context, &b, 1);
332334
result = 0;
333335
break;
334336
}
@@ -408,7 +410,7 @@ static void on_underlying_io_bytes_received(void* context, const unsigned char*
408410
case IO_STATE_OPEN:
409411
/* Codes_SRS_SASLCLIENTIO_01_027: [When the on_bytes_received callback passed to the underlying IO is called and the SASL client IO state is IO_STATE_OPEN, the bytes shall be indicated to the user of SASL client IO by calling the on_bytes_received that was passed in saslclientio_open.] */
410412
/* Codes_SRS_SASLCLIENTIO_01_029: [The context argument shall be set to the callback_context passed in saslclientio_open.] */
411-
sasl_client_io_instance->on_bytes_received(sasl_client_io_instance->open_callback_context, buffer, size);
413+
sasl_client_io_instance->on_bytes_received(sasl_client_io_instance->on_bytes_received_context, buffer, size);
412414
break;
413415

414416
case IO_STATE_SASL_HANDSHAKE:
@@ -885,8 +887,10 @@ CONCRETE_IO_HANDLE saslclientio_create(void* io_create_parameters, LOGGER_LOG lo
885887
result->on_io_error = NULL;
886888
result->on_io_close_complete = NULL;
887889
result->logger_log = logger_log;
888-
result->open_callback_context = NULL;
889-
result->close_callback_context = NULL;
890+
result->on_bytes_received_context = NULL;
891+
result->on_io_open_complete_context = NULL;
892+
result->on_io_close_complete_context = NULL;
893+
result->on_io_error_context = NULL;
890894
result->sasl_mechanism = sasl_client_io_config->sasl_mechanism;
891895

892896
result->io_state = IO_STATE_NOT_OPEN;
@@ -915,7 +919,7 @@ void saslclientio_destroy(CONCRETE_IO_HANDLE sasl_client_io)
915919
}
916920
}
917921

918-
int saslclientio_open(CONCRETE_IO_HANDLE sasl_client_io, ON_IO_OPEN_COMPLETE on_io_open_complete, ON_BYTES_RECEIVED on_bytes_received, ON_IO_ERROR on_io_error, void* callback_context)
922+
int saslclientio_open(CONCRETE_IO_HANDLE sasl_client_io, ON_IO_OPEN_COMPLETE on_io_open_complete, void* on_io_open_complete_context, ON_BYTES_RECEIVED on_bytes_received, void* on_bytes_received_context, ON_IO_ERROR on_io_error, void* on_io_error_context)
919923
{
920924
int result = 0;
921925

@@ -938,15 +942,17 @@ int saslclientio_open(CONCRETE_IO_HANDLE sasl_client_io, ON_IO_OPEN_COMPLETE on_
938942
sasl_client_io_instance->on_bytes_received = on_bytes_received;
939943
sasl_client_io_instance->on_io_open_complete = on_io_open_complete;
940944
sasl_client_io_instance->on_io_error = on_io_error;
941-
sasl_client_io_instance->open_callback_context = callback_context;
945+
sasl_client_io_instance->on_bytes_received_context = on_bytes_received_context;
946+
sasl_client_io_instance->on_io_open_complete_context = on_io_open_complete_context;
947+
sasl_client_io_instance->on_io_error_context = on_io_error_context;
942948
sasl_client_io_instance->sasl_header_exchange_state = SASL_HEADER_EXCHANGE_IDLE;
943949
sasl_client_io_instance->sasl_client_negotiation_state = SASL_CLIENT_NEGOTIATION_NOT_STARTED;
944950
sasl_client_io_instance->header_bytes_received = 0;
945951
sasl_client_io_instance->io_state = IO_STATE_OPENING_UNDERLYING_IO;
946952

947953
/* Codes_SRS_SASLCLIENTIO_01_009: [saslclientio_open shall call xio_open on the underlying_io passed to saslclientio_create.] */
948954
/* Codes_SRS_SASLCLIENTIO_01_013: [saslclientio_open shall pass to xio_open a callback for receiving bytes and a state changed callback for the underlying_io state changes.] */
949-
if (xio_open(sasl_client_io_instance->underlying_io, on_underlying_io_open_complete, on_underlying_io_bytes_received, on_underlying_io_error, sasl_client_io_instance) != 0)
955+
if (xio_open(sasl_client_io_instance->underlying_io, on_underlying_io_open_complete, sasl_client_io_instance, on_underlying_io_bytes_received, sasl_client_io_instance, on_underlying_io_error, sasl_client_io_instance) != 0)
950956
{
951957
/* Codes_SRS_SASLCLIENTIO_01_012: [If the open of the underlying_io fails, saslclientio_open shall fail and return non-zero value.] */
952958
result = __LINE__;

Diff for: ‎tests/connection_unittests/connection_unittests.cpp

+3-3
Original file line numberDiff line numberDiff line change
@@ -91,11 +91,11 @@ TYPED_MOCK_CLASS(connection_mocks, CGlobalMock)
9191
MOCK_METHOD_END(XIO_HANDLE, TEST_IO_HANDLE);
9292
MOCK_STATIC_METHOD_1(, void, xio_destroy, XIO_HANDLE, xio)
9393
MOCK_VOID_METHOD_END();
94-
MOCK_STATIC_METHOD_5(, int, xio_open, XIO_HANDLE, io, ON_IO_OPEN_COMPLETE, on_io_open_complete, ON_BYTES_RECEIVED, on_bytes_received, ON_IO_ERROR, on_io_error, void*, callback_context)
94+
MOCK_STATIC_METHOD_7(, int, xio_open, XIO_HANDLE, io, ON_IO_OPEN_COMPLETE, on_io_open_complete, void*, on_io_open_complete_context, ON_BYTES_RECEIVED, on_bytes_received, void*, on_bytes_received_context, ON_IO_ERROR, on_io_error, void*, on_io_error_context)
9595
saved_on_bytes_received = on_bytes_received;
9696
saved_on_io_open_complete = on_io_open_complete;
9797
saved_on_io_error = on_io_error;
98-
saved_io_callback_context = callback_context;
98+
saved_io_callback_context = on_io_open_complete_context;
9999
MOCK_METHOD_END(int, 0);
100100
MOCK_STATIC_METHOD_3(, int, xio_close, XIO_HANDLE, xio, ON_IO_CLOSE_COMPLETE, on_io_close_complete, void*, callback_context)
101101
MOCK_METHOD_END(int, 0);
@@ -212,7 +212,7 @@ extern "C"
212212
{
213213
DECLARE_GLOBAL_MOCK_METHOD_3(connection_mocks, , XIO_HANDLE, xio_create, const IO_INTERFACE_DESCRIPTION*, io_interface_description, const void*, io_create_parameters, LOGGER_LOG, logger_log);
214214
DECLARE_GLOBAL_MOCK_METHOD_1(connection_mocks, , void, xio_destroy, XIO_HANDLE, xio);
215-
DECLARE_GLOBAL_MOCK_METHOD_5(connection_mocks, , int, xio_open, XIO_HANDLE, xio, ON_IO_OPEN_COMPLETE, on_io_open_complete, ON_BYTES_RECEIVED, on_bytes_received, ON_IO_ERROR, on_io_error, void*, callback_context);
215+
DECLARE_GLOBAL_MOCK_METHOD_7(connection_mocks, , int, xio_open, XIO_HANDLE, xio, ON_IO_OPEN_COMPLETE, on_io_open_complete, void*, on_io_open_complete_context, ON_BYTES_RECEIVED, on_bytes_received, void*, on_bytes_received_context, ON_IO_ERROR, on_io_error, void*, on_io_error_context);
216216
DECLARE_GLOBAL_MOCK_METHOD_3(connection_mocks, , int, xio_close, XIO_HANDLE, xio, ON_IO_CLOSE_COMPLETE, on_io_close_complete, void*, callback_context);
217217
DECLARE_GLOBAL_MOCK_METHOD_5(connection_mocks, , int, xio_send, XIO_HANDLE, xio, const void*, buffer, size_t, size, ON_SEND_COMPLETE, on_send_complete, void*, callback_context);
218218
DECLARE_GLOBAL_MOCK_METHOD_1(connection_mocks, , void, xio_dowork, XIO_HANDLE, xio);

Diff for: ‎tests/saslclientio_unittests/saslclientio_unittests.cpp

+3-3
Original file line numberDiff line numberDiff line change
@@ -147,11 +147,11 @@ TYPED_MOCK_CLASS(saslclientio_mocks, CGlobalMock)
147147
MOCK_METHOD_END(int, 0);
148148

149149
/* xio mocks */
150-
MOCK_STATIC_METHOD_5(, int, xio_open, XIO_HANDLE, xio, ON_IO_OPEN_COMPLETE, on_io_open_complete, ON_BYTES_RECEIVED, on_bytes_received, ON_IO_ERROR, on_io_error, void*, callback_context)
150+
MOCK_STATIC_METHOD_7(, int, xio_open, XIO_HANDLE, xio, ON_IO_OPEN_COMPLETE, on_io_open_complete, void*, on_io_open_complete_context, ON_BYTES_RECEIVED, on_bytes_received, void*, on_bytes_received_context, ON_IO_ERROR, on_io_error, void*, on_io_error_context)
151151
saved_on_bytes_received = on_bytes_received;
152152
saved_on_io_open_complete = on_io_open_complete;
153153
saved_on_io_error = on_io_error;
154-
saved_io_callback_context = callback_context;
154+
saved_io_callback_context = on_io_open_complete_context;
155155
MOCK_METHOD_END(int, 0);
156156
MOCK_STATIC_METHOD_3(, int, xio_close, XIO_HANDLE, xio, ON_IO_CLOSE_COMPLETE, on_io_close_complete, void*, callback_context)
157157
MOCK_METHOD_END(int, 0);
@@ -218,7 +218,7 @@ extern "C"
218218
DECLARE_GLOBAL_MOCK_METHOD_1(saslclientio_mocks, , void, sasl_frame_codec_destroy, SASL_FRAME_CODEC_HANDLE, sasl_frame_codec);
219219
DECLARE_GLOBAL_MOCK_METHOD_4(saslclientio_mocks, , int, sasl_frame_codec_encode_frame, SASL_FRAME_CODEC_HANDLE, sasl_frame_codec, const AMQP_VALUE, sasl_frame_value, ON_BYTES_ENCODED, on_bytes_encoded, void*, callback_context)
220220

221-
DECLARE_GLOBAL_MOCK_METHOD_5(saslclientio_mocks, , int, xio_open, XIO_HANDLE, xio, ON_IO_OPEN_COMPLETE, on_io_open_complete, ON_BYTES_RECEIVED, on_bytes_received, ON_IO_ERROR, on_io_error, void*, callback_context);
221+
DECLARE_GLOBAL_MOCK_METHOD_7(saslclientio_mocks, , int, xio_open, XIO_HANDLE, xio, ON_IO_OPEN_COMPLETE, on_io_open_complete, void*, on_io_open_complete_context, ON_BYTES_RECEIVED, on_bytes_received, void*, on_bytes_received_context, ON_IO_ERROR, on_io_error, void*, on_io_error_context);
222222
DECLARE_GLOBAL_MOCK_METHOD_3(saslclientio_mocks, , int, xio_close, XIO_HANDLE, xio, ON_IO_CLOSE_COMPLETE, on_io_close_complete, void*, callback_context);
223223
DECLARE_GLOBAL_MOCK_METHOD_5(saslclientio_mocks, , int, xio_send, XIO_HANDLE, xio, const void*, buffer, size_t, size, ON_SEND_COMPLETE, on_send_complete, void*, callback_context);
224224
DECLARE_GLOBAL_MOCK_METHOD_1(saslclientio_mocks, , void, xio_dowork, XIO_HANDLE, xio);

0 commit comments

Comments
 (0)