adaptor 455 lib/common/mainloop.c struct gio_to_qb_poll *adaptor = (struct gio_to_qb_poll *)data; adaptor 462 lib/common/mainloop.c CRM_ASSERT(adaptor->is_used > 0); adaptor 464 lib/common/mainloop.c return (adaptor->fn(fd, condition, adaptor->data) == 0); adaptor 470 lib/common/mainloop.c struct gio_to_qb_poll *adaptor = (struct gio_to_qb_poll *)data; adaptor 472 lib/common/mainloop.c adaptor->is_used--; adaptor 473 lib/common/mainloop.c CRM_ASSERT(adaptor->is_used >= 0); adaptor 475 lib/common/mainloop.c if (adaptor->is_used == 0) { adaptor 476 lib/common/mainloop.c crm_trace("Marking adaptor %p unused", adaptor); adaptor 477 lib/common/mainloop.c adaptor->source = 0; adaptor 544 lib/common/mainloop.c struct gio_to_qb_poll *adaptor; adaptor 548 lib/common/mainloop.c res = qb_array_index(gio_map, fd, (void **)&adaptor); adaptor 554 lib/common/mainloop.c crm_trace("Adding fd=%d to mainloop as adaptor %p", fd, adaptor); adaptor 556 lib/common/mainloop.c if (add && adaptor->source) { adaptor 560 lib/common/mainloop.c if (!add && !adaptor->is_used) { adaptor 572 lib/common/mainloop.c if (adaptor->source) { adaptor 573 lib/common/mainloop.c g_source_remove(adaptor->source); adaptor 574 lib/common/mainloop.c adaptor->source = 0; adaptor 580 lib/common/mainloop.c adaptor->fn = fn; adaptor 581 lib/common/mainloop.c adaptor->events = evts; adaptor 582 lib/common/mainloop.c adaptor->data = data; adaptor 583 lib/common/mainloop.c adaptor->p = p; adaptor 584 lib/common/mainloop.c adaptor->is_used++; adaptor 585 lib/common/mainloop.c adaptor->source = adaptor 587 lib/common/mainloop.c gio_read_socket, adaptor, gio_poll_destroy); adaptor 600 lib/common/mainloop.c crm_trace("Added to mainloop with gsource id=%d", adaptor->source); adaptor 601 lib/common/mainloop.c if (adaptor->source > 0) { adaptor 625 lib/common/mainloop.c struct gio_to_qb_poll *adaptor; adaptor 628 lib/common/mainloop.c if (qb_array_index(gio_map, fd, (void **)&adaptor) == 0) { adaptor 629 lib/common/mainloop.c if (adaptor->source) { adaptor 630 lib/common/mainloop.c g_source_remove(adaptor->source); adaptor 631 lib/common/mainloop.c adaptor->source = 0;