receiver
struct drbd_thread receiver;
if (first_peer_device(device)->connection->receiver.t_state != NONE)
first_peer_device(device)->connection->receiver.t_state);
connection->receiver.reset_cpu_mask = 1;
drbd_thread_init(resource, &connection->receiver, drbd_receiver, "receiver");
connection->receiver.connection = connection;
drbd_thread_stop(&connection->receiver);
drbd_thread_stop(&connection->receiver);
while (get_t_state(&connection->receiver) == RUNNING) {
drbd_thread_current_set_cpu(&connection->receiver);
if (get_t_state(&connection->receiver) == EXITING)
drbd_thread_stop_nowait(&connection->receiver);
drbd_thread_stop_nowait(&connection->receiver);
drbd_thread_restart_nowait(&connection->receiver);
drbd_thread_start(&connection->receiver);
ep_mem_access->receiver = args->attrs[idx].receiver;
if (omap->receiver)
unsigned receiver:1; /* true when we're in receiver mode */
omap->receiver = !!(msg->flags & I2C_M_RD);
omap_i2c_resize_fifo(omap, msg->len, omap->receiver);
u16 receiver;
u16 receiver;
const struct rtw89_mcc_role *receiver)
if (provider->is_go || receiver->is_gc)
.receiver = ffa_dev->vm_id,
mem_attr[n].receiver = mem_attrs[n] & U16_MAX;
.receiver = tstee->ffa_dev->vm_id,
u32 receiver;
u16 receiver;
struct ext_wait_queue *receiver)
receiver->msg = message;
__pipelined_op(wake_q, info, receiver);
struct ext_wait_queue *receiver;
receiver = wq_get_first_waiter(info, RECV);
if (receiver) {
pipelined_send(&wake_q, info, msg_ptr, receiver);
struct receiver *rcv;
struct receiver *rcv = container_of(rp, struct receiver, rcu);
struct receiver *rcv = NULL;
static inline void deliver(struct sk_buff *skb, struct receiver *rcv)
struct receiver *rcv;
rcv_cache = kmem_cache_create("can_receiver", sizeof(struct receiver),
struct receiver *r;
struct ip_ct_tcp_state *receiver,
receiver->flags & IP_CT_TCP_FLAG_WINDOW_SCALE)) {
receiver->td_scale = 0;
struct ip_ct_tcp_state *receiver = &state->seen[!dir];
if (receiver->flags & IP_CT_TCP_FLAG_SACK_PERM)
tcp_init_sender(sender, receiver,
if (receiver->td_maxwin == 0) {
receiver->td_end = receiver->td_maxend = sack;
} else if (sack == receiver->td_end + 1) {
receiver->td_end++;
tcp_init_sender(sender, receiver,
ack = sack = receiver->td_end;
ack = sack = receiver->td_end;
ack_ok = after(sack, receiver->td_end - MAXACKWINDOW(sender) - 1);
in_recv_win = receiver->td_maxwin &&
after(end, sender->td_end - receiver->td_maxwin - 1);
overshot <= receiver->td_maxwin &&
before(sack, receiver->td_end + 1)) {
if (!before(sack, receiver->td_end + 1))
receiver->td_end + 1);
in_recv_win = !receiver->td_maxwin ||
after(end, sender->td_end - receiver->td_maxwin - 1);
sender->td_end - receiver->td_maxwin - 1);
if (!after(sack, receiver->td_end - MAXACKWINDOW(sender) - 1))
receiver->td_end - MAXACKWINDOW(sender) - 1);
if (receiver->td_maxwin != 0 && after(end, sender->td_maxend))
receiver->td_maxwin += end - sender->td_maxend;
if (after(sack + win, receiver->td_maxend - 1)) {
receiver->td_maxend = sack + win;
receiver->td_maxend++;
if (ack == receiver->td_end)
receiver->flags &= ~IP_CT_TCP_FLAG_DATA_UNACKNOWLEDGED;
void unix_add_edges(struct scm_fp_list *fpl, struct unix_sock *receiver);
void unix_update_edges(struct unix_sock *receiver);
void unix_add_edges(struct scm_fp_list *fpl, struct unix_sock *receiver)
edge->successor = receiver;
receiver->scm_stat.nr_unix_fds += fpl->count_unix;
struct unix_sock *receiver;
receiver = fpl->edges[0].successor;
receiver->scm_stat.nr_unix_fds -= fpl->count_unix;
void unix_update_edges(struct unix_sock *receiver)
if (!receiver->scm_stat.nr_unix_fds) {
receiver->listener = NULL;
unix_update_graph(unix_sk(receiver->listener)->vertex);
receiver->listener = NULL;
struct snd_seq_client *receiver __free(snd_seq_client) =
if (!receiver)
snd_seq_port_use_ptr(receiver, subs->dest.port);
result = snd_seq_port_connect(client, sender, sport, receiver, dport, subs);
struct snd_seq_client *receiver __free(snd_seq_client) =
if (!receiver)
snd_seq_port_use_ptr(receiver, subs->dest.port);
result = snd_seq_port_disconnect(client, sender, sport, receiver, dport, subs);
urb = &rt->receiver;
usb_poison_urb(&rt->receiver);
struct urb receiver;
create_worker(worker + i, ctx, (void *)receiver);
int *receiver;
recvd = recv_timeout(*send_dir[i].receiver, rcv,
static void transfer_message(int sender, int receiver)
ret = recv(receiver, buf, msglen, 0);
int inflight, int receiver)
ret = sendmsg(self->fd[receiver * 2 + 1], &msg, variant->flags);
#define send_fd(inflight, receiver) \
__send_fd(_metadata, self, variant, inflight, receiver)