Searched refs:pending_replies (Results 1 – 3 of 3) sorted by relevance
64 BusExpireList *pending_replies; /**< List of pending replies */ member440 connections->pending_replies = bus_expire_list_new (bus_context_get_loop (context), in bus_connections_new()444 if (connections->pending_replies == NULL) in bus_connections_new()457 bus_expire_list_free (connections->pending_replies); in bus_connections_new()516 bus_expire_list_free (connections->pending_replies); in bus_connections_unref()1569 bus_expire_list_remove_link (connections->pending_replies, link); in bus_pending_reply_expired()1589 link = bus_expire_list_get_first_link (connections->pending_replies); in bus_connection_drop_pending_replies()1595 next = bus_expire_list_get_next_link (connections->pending_replies, in bus_connection_drop_pending_replies()1609 bus_expire_list_remove_link (connections->pending_replies, in bus_connection_drop_pending_replies()1628 bus_expire_list_recheck_immediately (connections->pending_replies); in bus_connection_drop_pending_replies()[all …]
297 DBusHashTable *pending_replies; /**< Hash of message serials to #DBusPendingCall. */ member505 pending = _dbus_hash_table_lookup_int (connection->pending_replies, in _dbus_connection_queue_received_message_link()943 if (!_dbus_hash_table_insert_int (connection->pending_replies, in _dbus_connection_attach_pending_call_unlocked()958 if (!_dbus_hash_table_insert_int (connection->pending_replies, in _dbus_connection_attach_pending_call_unlocked()1015 _dbus_hash_table_remove_int (connection->pending_replies, in _dbus_connection_detach_pending_call_unlocked()1031 _dbus_hash_table_remove_int (connection->pending_replies, in _dbus_connection_detach_pending_call_and_unlock()1262 DBusHashTable *pending_replies; in _dbus_connection_new_for_transport() local1270 pending_replies = NULL; in _dbus_connection_new_for_transport()1285 pending_replies = in _dbus_connection_new_for_transport()1289 if (pending_replies == NULL) in _dbus_connection_new_for_transport()[all …]
251 struct server_request *pending_replies; member1422 struct server_request *req = port->pending_replies; in server_port_flush()1437 EVUTIL_ASSERT(req != port->pending_replies); in server_port_flush()1438 req = port->pending_replies; in server_port_flush()1710 port->pending_replies = NULL; in evdns_add_server_port_with_base()1994 if (port->pending_replies) { in evdns_server_request_respond()1995 req->prev_pending = port->pending_replies->prev_pending; in evdns_server_request_respond()1996 req->next_pending = port->pending_replies; in evdns_server_request_respond()2001 port->pending_replies = req; in evdns_server_request_respond()2021 if (port->pending_replies) in evdns_server_request_respond()[all …]