Lines Matching full:pending
59 BusExpireList *pending_replies; /**< List of pending replies */
1380 bus_pending_reply_free (BusPendingReply *pending)
1382 _dbus_verbose ("Freeing pending reply %p, replier %p receiver %p serial %u\n",
1383 pending,
1384 pending->will_send_reply,
1385 pending->will_get_reply,
1386 pending->reply_serial);
1388 dbus_free (pending);
1394 BusPendingReply *pending)
1410 pending->reply_serial))
1422 if (!bus_transaction_send_from_driver (transaction, pending->will_get_reply,
1438 BusPendingReply *pending = link->data;
1447 _dbus_verbose ("Expiring pending reply %p, replier %p receiver %p serial %u\n",
1448 pending,
1449 pending->will_send_reply,
1450 pending->will_get_reply,
1451 pending->reply_serial);
1459 pending))
1467 bus_pending_reply_free (pending);
1482 _dbus_verbose ("Dropping pending replies that involve connection %p\n",
1489 BusPendingReply *pending;
1493 pending = link->data;
1495 if (pending->will_get_reply == connection)
1497 /* We don't need to track this pending reply anymore */
1499 _dbus_verbose ("Dropping pending reply %p, replier %p receiver %p serial %u\n",
1500 pending,
1501 pending->will_send_reply,
1502 pending->will_get_reply,
1503 pending->reply_serial);
1507 bus_pending_reply_free (pending);
1509 else if (pending->will_send_reply == connection)
1514 _dbus_verbose ("Will expire pending reply %p, replier %p receiver %p serial %u\n",
1515 pending,
1516 pending->will_send_reply,
1517 pending->will_get_reply,
1518 pending->reply_serial);
1520 pending->will_send_reply = NULL;
1521 pending->expire_item.added_tv_sec = 0;
1522 pending->expire_item.added_tv_usec = 0;
1535 BusPendingReply *pending;
1547 d->pending))
1548 _dbus_assert_not_reached ("pending reply did not exist to be cancelled");
1550 bus_pending_reply_free (d->pending); /* since it's been cancelled */
1560 /* d->pending should be either freed or still
1561 * in the list of pending replies (owned by someone
1579 BusPendingReply *pending;
1598 pending = link->data;
1600 if (pending->reply_serial == reply_serial &&
1601 pending->will_get_reply == will_get_reply &&
1602 pending->will_send_reply == will_send_reply)
1611 if (pending->will_get_reply == will_get_reply)
1619 "The maximum number of pending replies per connection has been reached");
1623 pending = dbus_new0 (BusPendingReply, 1);
1624 if (pending == NULL)
1631 /* so we can see a not-yet-added pending reply */
1632 pending->expire_item.added_tv_sec = 1;
1633 pending->expire_item.added_tv_usec = 1;
1636 pending->will_get_reply = will_get_reply;
1637 pending->will_send_reply = will_send_reply;
1638 pending->reply_serial = reply_serial;
1644 bus_pending_reply_free (pending);
1649 pending))
1653 bus_pending_reply_free (pending);
1663 _dbus_list_remove (&connections->pending_replies->items, pending);
1665 bus_pending_reply_free (pending);
1669 cprd->pending = pending;
1672 _dbus_get_current_time (&pending->expire_item.added_tv_sec,
1673 &pending->expire_item.added_tv_usec);
1675 _dbus_verbose ("Added pending reply %p, replier %p receiver %p serial %u\n",
1676 pending,
1677 pending->will_send_reply,
1678 pending->will_get_reply,
1679 pending->reply_serial);
1711 BusPendingReply *pending = d->link->data;
1714 pending) == NULL);
1716 bus_pending_reply_free (pending);
1747 BusPendingReply *pending = link->data;
1749 if (pending->reply_serial == reply_serial &&
1750 pending->will_get_reply == receiving_reply &&
1751 pending->will_send_reply == sending_reply)
1753 _dbus_verbose ("Found pending reply with serial %u\n", reply_serial);
1763 _dbus_verbose ("No pending reply expected\n");
1996 * for this transaction. If we have a pending message,
