adaptor 446 lib/common/mainloop.c struct gio_to_qb_poll *adaptor = (struct gio_to_qb_poll *)data; adaptor 453 lib/common/mainloop.c CRM_ASSERT(adaptor->is_used > 0); adaptor 455 lib/common/mainloop.c return (adaptor->fn(fd, condition, adaptor->data) == 0); adaptor 461 lib/common/mainloop.c struct gio_to_qb_poll *adaptor = (struct gio_to_qb_poll *)data; adaptor 463 lib/common/mainloop.c adaptor->is_used--; adaptor 464 lib/common/mainloop.c CRM_ASSERT(adaptor->is_used >= 0); adaptor 466 lib/common/mainloop.c if (adaptor->is_used == 0) { adaptor 467 lib/common/mainloop.c crm_trace("Marking adaptor %p unused", adaptor); adaptor 468 lib/common/mainloop.c adaptor->source = 0; adaptor 513 lib/common/mainloop.c struct gio_to_qb_poll *adaptor; adaptor 517 lib/common/mainloop.c res = qb_array_index(gio_map, fd, (void **)&adaptor); adaptor 523 lib/common/mainloop.c crm_trace("Adding fd=%d to mainloop as adaptor %p", fd, adaptor); adaptor 525 lib/common/mainloop.c if (add && adaptor->source) { adaptor 529 lib/common/mainloop.c if (!add && !adaptor->is_used) { adaptor 541 lib/common/mainloop.c if (adaptor->source) { adaptor 542 lib/common/mainloop.c g_source_remove(adaptor->source); adaptor 543 lib/common/mainloop.c adaptor->source = 0; adaptor 549 lib/common/mainloop.c adaptor->fn = fn; adaptor 550 lib/common/mainloop.c adaptor->events = evts; adaptor 551 lib/common/mainloop.c adaptor->data = data; adaptor 552 lib/common/mainloop.c adaptor->p = p; adaptor 553 lib/common/mainloop.c adaptor->is_used++; adaptor 554 lib/common/mainloop.c adaptor->source = adaptor 556 lib/common/mainloop.c gio_read_socket, adaptor, gio_poll_destroy); adaptor 569 lib/common/mainloop.c crm_trace("Added to mainloop with gsource id=%d", adaptor->source); adaptor 570 lib/common/mainloop.c if (adaptor->source > 0) { adaptor 594 lib/common/mainloop.c struct gio_to_qb_poll *adaptor; adaptor 597 lib/common/mainloop.c if (qb_array_index(gio_map, fd, (void **)&adaptor) == 0) { adaptor 598 lib/common/mainloop.c if (adaptor->source) { adaptor 599 lib/common/mainloop.c g_source_remove(adaptor->source); adaptor 600 lib/common/mainloop.c adaptor->source = 0;