Lines Matching refs:link
173 msg.link.next = NULL; in nxt_port_socket_write2()
174 msg.link.prev = NULL; in nxt_port_socket_write2()
319 nxt_queue_insert_tail(&port->messages, &msg->link); in nxt_port_msg_chk_insert()
476 if (msg->link.next != NULL) { in nxt_port_write_handler()
479 nxt_queue_remove(&msg->link); in nxt_port_write_handler()
480 nxt_queue_insert_tail(&port->messages, &msg->link); in nxt_port_write_handler()
498 if (msg->link.next != NULL) { in nxt_port_write_handler()
501 nxt_queue_remove(&msg->link); in nxt_port_write_handler()
502 msg->link.next = NULL; in nxt_port_write_handler()
518 if (msg->link.next == NULL) { in nxt_port_write_handler()
527 if (msg->link.next == NULL) { in nxt_port_write_handler()
582 msg = nxt_queue_link_data(lnk, nxt_port_send_msg_t, link); in nxt_port_msg_first()
694 nxt_queue_insert_tail(&port->messages, &msg->link); in nxt_port_msg_insert_tail()
1359 nxt_queue_each(msg, &port->messages, nxt_port_send_msg_t, link) { in nxt_port_error_handler()
1374 nxt_queue_remove(&msg->link); in nxt_port_error_handler()