adaptor 457 lib/common/mainloop.c struct gio_to_qb_poll *adaptor = (struct gio_to_qb_poll *)data; adaptor 464 lib/common/mainloop.c CRM_ASSERT(adaptor->is_used > 0); adaptor 466 lib/common/mainloop.c return (adaptor->fn(fd, condition, adaptor->data) == 0); adaptor 472 lib/common/mainloop.c struct gio_to_qb_poll *adaptor = (struct gio_to_qb_poll *)data; adaptor 474 lib/common/mainloop.c adaptor->is_used--; adaptor 475 lib/common/mainloop.c CRM_ASSERT(adaptor->is_used >= 0); adaptor 477 lib/common/mainloop.c if (adaptor->is_used == 0) { adaptor 478 lib/common/mainloop.c crm_trace("Marking adaptor %p unused", adaptor); adaptor 479 lib/common/mainloop.c adaptor->source = 0; adaptor 524 lib/common/mainloop.c struct gio_to_qb_poll *adaptor; adaptor 528 lib/common/mainloop.c res = qb_array_index(gio_map, fd, (void **)&adaptor); adaptor 534 lib/common/mainloop.c crm_trace("Adding fd=%d to mainloop as adaptor %p", fd, adaptor); adaptor 536 lib/common/mainloop.c if (add && adaptor->source) { adaptor 540 lib/common/mainloop.c if (!add && !adaptor->is_used) { adaptor 552 lib/common/mainloop.c if (adaptor->source) { adaptor 553 lib/common/mainloop.c g_source_remove(adaptor->source); adaptor 554 lib/common/mainloop.c adaptor->source = 0; adaptor 560 lib/common/mainloop.c adaptor->fn = fn; adaptor 561 lib/common/mainloop.c adaptor->events = evts; adaptor 562 lib/common/mainloop.c adaptor->data = data; adaptor 563 lib/common/mainloop.c adaptor->p = p; adaptor 564 lib/common/mainloop.c adaptor->is_used++; adaptor 565 lib/common/mainloop.c adaptor->source = adaptor 567 lib/common/mainloop.c gio_read_socket, adaptor, gio_poll_destroy); adaptor 580 lib/common/mainloop.c crm_trace("Added to mainloop with gsource id=%d", adaptor->source); adaptor 581 lib/common/mainloop.c if (adaptor->source > 0) { adaptor 605 lib/common/mainloop.c struct gio_to_qb_poll *adaptor; adaptor 608 lib/common/mainloop.c if (qb_array_index(gio_map, fd, (void **)&adaptor) == 0) { adaptor 609 lib/common/mainloop.c if (adaptor->source) { adaptor 610 lib/common/mainloop.c g_source_remove(adaptor->source); adaptor 611 lib/common/mainloop.c adaptor->source = 0;