Lines Matching refs:pid
103 reliable_ack_packet_id_present (struct reliable_ack *ack, packet_id_type pid)
107 if (ack->packet_id[i] == pid)
114 reliable_ack_read_packet_id (struct buffer *buf, packet_id_type *pid)
120 *pid = ntohpid (net_pid);
122 (packet_id_print_type)*pid, buf->len);
132 reliable_ack_acknowledge_packet_id (struct reliable_ack *ack, packet_id_type pid)
134 if (!reliable_ack_packet_id_present (ack, pid) && ack->len < RELIABLE_ACK_SIZE)
136 ack->packet_id[ack->len++] = pid;
138 (packet_id_print_type)pid, ack->len);
143 (packet_id_print_type)pid, ack->len);
156 packet_id_type pid;
167 pid = ntohpid (net_pid);
168 ack->packet_id[ack->len++] = pid;
213 packet_id_type pid = ack->packet_id[i];
214 packet_id_type net_pid = htonpid (pid);
216 dmsg (D_REL_DEBUG, "ACK write ID " packet_id_format " (ack->len=%d, n=%d)", (packet_id_print_type)pid, ack->len, n);
247 packet_id_type pid;
255 if (!buf_read (buf, &pid, sizeof (pid)))
257 pid = ntohpid (pid);
258 buf_printf (&out, " " packet_id_format, (packet_id_print_type)pid);
327 packet_id_type pid = ack->packet_id[i];
331 if (e->active && e->packet_id == pid)
334 "ACK received for pid " packet_id_format ", deleting from send buffer",
335 (packet_id_print_type)pid);
342 msg (M_INFO, "ACK " packet_id_format ", wake=%d", pid, wake);
642 packet_id_type pid, int opcode)
653 e->packet_id = pid;
656 ASSERT (!reliable_pid_min (pid, rel->packet_id));