sending
cl->sending = 0;
if (cl->ishtp_flow_ctrl_creds != 1 && !cl->sending) {
if (!cl->sending) {
cl->sending = 1;
cl->sending = 0;
int sending;
adb_iop_state = sending;
cuda_state = sending;
case sending:
macii_state = sending;
case sending:
pmu_state = sending;
case sending:
keypair->sending.is_valid = false;
keypair->sending.is_valid = false;
derive_keys(&new_keypair->sending, &new_keypair->receiving,
derive_keys(&new_keypair->receiving, &new_keypair->sending,
struct noise_symmetric_key sending;
send = keypair && READ_ONCE(keypair->sending.is_valid) &&
wg_birthdate_has_expired(keypair->sending.birthdate,
send = keypair && READ_ONCE(keypair->sending.is_valid) &&
wg_birthdate_has_expired(keypair->sending.birthdate, REKEY_AFTER_TIME)));
keypair->sending.key);
if (unlikely(!READ_ONCE(keypair->sending.is_valid)))
if (unlikely(wg_birthdate_has_expired(keypair->sending.birthdate,
WRITE_ONCE(keypair->sending.is_valid, false);
struct rpc_wait_queue sending; /* requests waiting to send */
if (!atomic_dec_and_test(&tp_vars->sending))
if (unlikely(atomic_read(&tp_vars->sending) == 0))
if (atomic_read(&tp_vars->sending) == 0)
if (unlikely(atomic_read(&tp_vars->sending) == 0))
while (atomic_read(&tp_vars->sending) != 0) {
if (atomic_dec_and_test(&tp_vars->sending))
atomic_set(&tp_vars->sending, 1);
atomic_t sending;
bool sending;
sending = hci_dev_test_flag(hdev, HCI_MESH_SENDING);
else if (!sending)
if (sending)
xprt->sending.qlen, xprt->pending.qlen,
rpc_wake_up_queued_task_set_status(&xprt->sending,
xprt->stat.sending_u += xprt->sending.qlen;
rpc_wake_up_queued_task_set_status(&xprt->sending, task, status);
rpc_init_wait_queue(&xprt->sending, "xprt_sending");
rpc_destroy_wait_queue(&xprt->sending);
if (!xprt->sending.qlen && !xprt->pending.qlen &&
rpc_sleep_on_timeout(&xprt->sending, task, NULL,
rpc_sleep_on(&xprt->sending, task, NULL);
rpc_sleep_on_timeout(&xprt->sending, task, NULL,
rpc_sleep_on(&xprt->sending, task, NULL);
if (rpc_wake_up_first_on_wq(xprtiod_workqueue, &xprt->sending,
if (rpc_wake_up_first_on_wq(xprtiod_workqueue, &xprt->sending,
if (sending)
int sending)