Home | History | Annotate | Download | only in test

Lines Matching defs:io_context

45 typedef struct io_context {
212     io_context_t *io_context;
216     err = validate_io_context(&io_context, in_context);
218         if (io_context->wakeup != NULL) {
219             ioloop_cancel_wake_event(io_context->wakeup);
220             ioloop_wakeup_release(io_context->wakeup);
224         if (io_context->connection != NULL) {
225             ioloop_comm_cancel(io_context->connection);
226             io_context->deactivated = true;
227             io_context->closed = true;
229             free(io_context);
238     io_context_t *io_context;
241     err = validate_io_context(&io_context, context);
243         if (io_context->wakeup != NULL) {
244             ioloop_cancel_wake_event(io_context->wakeup);
246         if (io_context->connection) {
247             io_context->connection = NULL;
249         io_context->closed = true;
314     io_context_t *io_context;
317     err = validate_io_context(&io_context, context);
319         if (io_context->connection) {
324         srp_server_t *server_state = io_context->host_context;
329         io_context->connection = test_state->srp_listener;
330         test_state->current_io_context = io_context;
331         io_context->connection->test_send_intercept = srp_test_send_intercept;
332         io_context->connection->test_context = server_state;
340     io_context_t *io_context = calloc(1, sizeof *io_context);
341     if (io_context == NULL) {
344     io_context->magic_cookie1 = io_context->magic_cookie2 = SRP_IO_CONTEXT_MAGIC;
345     io_context->datagram_callback = callback;
346     io_context->srp_context = context;
347     io_context->host_context = host_context;
349     io_context->wakeup = ioloop_wakeup_create();
350     if (io_context->wakeup == NULL) {
351         free(io_context);
355     *p_context = io_context;
362     io_context_t *io_context;
363     if (validate_io_context(&io_context, context) == kDNSServiceErr_NoError) {
364         INFO("wakeup on context %p srp_context %p", io_context, io_context->srp_context);
365         INFO("setting wakeup callback %p wakeup %p", io_context->wakeup_callback, io_context->wakeup);
366         if (!io_context->deactivated) {
367             io_context->wakeup_callback(io_context->srp_context);
378     io_context_t *io_context;
381     err = validate_io_context(&io_context, context);
383         INFO("setting wakeup callback %p wakeup %p", callback, io_context->wakeup);
384         io_context->wakeup_callback = callback;
385         ioloop_add_wake_event(io_context->wakeup, io_context, wakeup_callback, NULL, milliseconds);
394     io_context_t *io_context;
397     err = validate_io_context(&io_context, context);
399         ioloop_cancel_wake_event(io_context->wakeup);
408     io_context_t *io_context;
416     err = validate_io_context(&io_context, context);
418         if (io_context->connection == NULL) {
421         TEST_FAIL_CHECK(test_state, io_context->connection->datagram_callback != NULL, "srp listener has no datagram callback");
425         io_context->connection->datagram_callback(io_context->connection, actual, io_context->connection->context);