Home
last modified time | relevance | path

Searched refs:outqueue (Results 1 - 25 of 39) sorted by relevance

12

/kernel/linux/linux-5.10/net/sctp/
H A Dstream_sched.c138 struct sctp_sched_ops *old = asoc->outqueue.sched; in sctp_sched_set_sched()
165 asoc->outqueue.sched = n; in sctp_sched_set_sched()
177 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) { in sctp_sched_set_sched()
181 n->enqueue(&asoc->outqueue, msg); in sctp_sched_set_sched()
188 asoc->outqueue.sched = &sctp_sched_fcfs; /* Always safe */ in sctp_sched_set_sched()
198 if (asoc->outqueue.sched == sctp_sched_ops[i]) in sctp_sched_get_sched()
218 return asoc->outqueue.sched->set(&asoc->stream, sid, value, gfp); in sctp_sched_set_value()
230 return asoc->outqueue.sched->get(&asoc->stream, sid, value); in sctp_sched_get_value()
277 return asoc->outqueue.sched; in sctp_sched_ops_from_stream()
H A Dsm_sideeffect.c611 asoc->outqueue.error = error; in sctp_cmd_init_failed()
652 asoc->outqueue.error = error; in sctp_cmd_assoc_failed()
802 if (sctp_outq_sack(&asoc->outqueue, chunk)) { in sctp_cmd_process_sack()
916 !sctp_outq_is_empty(&asoc->outqueue)) in sctp_cmd_new_state()
917 sctp_outq_uncork(&asoc->outqueue, GFP_ATOMIC); in sctp_cmd_new_state()
1094 /* Send the whole message, chunk by chunk, to the outqueue.
1104 sctp_outq_tail(&asoc->outqueue, chunk, gfp); in sctp_cmd_send_msg()
1106 asoc->outqueue.sched->enqueue(&asoc->outqueue, msg); in sctp_cmd_send_msg()
1301 sctp_outq_uncork(&asoc->outqueue, gf in sctp_cmd_interpreter()
[all...]
H A Dchunk.c91 error = msg->send_error ?: asoc->outqueue.error; in sctp_datamsg_destroy()
215 asoc->outqueue.out_qlen == 0 && in sctp_datamsg_from_user()
216 list_empty(&asoc->outqueue.retransmit) && in sctp_datamsg_from_user()
H A Dstream.c32 outq = &asoc->outqueue; in sctp_stream_shrink_out()
248 if (!asoc->outqueue.out_qlen) in sctp_stream_outq_is_empty()
394 if (!sctp_outq_is_empty(&asoc->outqueue)) in sctp_send_reset_assoc()
710 if (!sctp_outq_is_empty(&asoc->outqueue)) { in sctp_process_strreset_tsnreq()
746 sctp_outq_free(&asoc->outqueue); in sctp_process_strreset_tsnreq()
1018 list_splice_init(&asoc->outqueue.out_chunk_list, &temp); in sctp_process_strreset_resp()
1019 sctp_outq_free(&asoc->outqueue); in sctp_process_strreset_resp()
1020 list_splice_init(&temp, &asoc->outqueue.out_chunk_list); in sctp_process_strreset_resp()
H A DMakefile12 inqueue.o outqueue.o ulpqueue.o \
H A Dassociola.c224 sctp_outq_init(asoc, &asoc->outqueue); in sctp_association_init()
337 /* Dispose of any data lying around in the outqueue. */ in sctp_association_free()
338 sctp_outq_free(&asoc->outqueue); in sctp_association_free()
462 if (!asoc->outqueue.outstanding_bytes && !asoc->outqueue.out_qlen) in sctp_assoc_set_primary()
570 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) in sctp_assoc_rm_peer()
1511 sctp_outq_tail(&asoc->outqueue, sack, GFP_ATOMIC); in sctp_assoc_rwnd_increase()
H A Doutqueue.c10 * These functions implement the sctp_outq class. The outqueue handles
204 /* Free the outqueue structure and any related pending chunks.
273 /* Free the outqueue structure and any related pending chunks. */
358 sctp_insert_list(&asoc->outqueue.abandoned, in sctp_prsctp_prune_sent()
366 if (queue != &asoc->outqueue.retransmit && in sctp_prsctp_prune_sent()
371 asoc->outqueue.outstanding_bytes -= sctp_data_size(chk); in sctp_prsctp_prune_sent()
385 struct sctp_outq *q = &asoc->outqueue; in sctp_prsctp_prune_unsent()
432 &asoc->outqueue.retransmit, in sctp_prsctp_prune()
755 /* Cork the outqueue so queued chunks are really queued. */
1160 /* Try to flush an outqueue
[all...]
H A Dstream_sched_rr.c161 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) { in sctp_sched_rr_sched_all()
H A Doutput.c654 struct sctp_outq *q = &asoc->outqueue; in sctp_packet_can_append_data()
744 asoc->outqueue.outstanding_bytes += datasize; in sctp_packet_append_data()
H A Dstream_sched_prio.c309 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) { in sctp_sched_prio_sched_all()
/kernel/linux/linux-6.6/net/sctp/
H A Dstream_sched.c151 struct sctp_sched_ops *old = asoc->outqueue.sched; in sctp_sched_set_sched()
167 asoc->outqueue.sched = n; in sctp_sched_set_sched()
179 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) { in sctp_sched_set_sched()
183 n->enqueue(&asoc->outqueue, msg); in sctp_sched_set_sched()
190 asoc->outqueue.sched = &sctp_sched_fcfs; /* Always safe */ in sctp_sched_set_sched()
200 if (asoc->outqueue.sched == sctp_sched_ops[i]) in sctp_sched_get_sched()
220 return asoc->outqueue.sched->set(&asoc->stream, sid, value, gfp); in sctp_sched_set_value()
232 return asoc->outqueue.sched->get(&asoc->stream, sid, value); in sctp_sched_get_value()
279 return asoc->outqueue.sched; in sctp_sched_ops_from_stream()
H A Dsm_sideeffect.c643 asoc->outqueue.error = error; in sctp_cmd_init_failed()
684 asoc->outqueue.error = error; in sctp_cmd_assoc_failed()
834 if (sctp_outq_sack(&asoc->outqueue, chunk)) { in sctp_cmd_process_sack()
926 !sctp_outq_is_empty(&asoc->outqueue)) in sctp_cmd_new_state()
927 sctp_outq_uncork(&asoc->outqueue, GFP_ATOMIC); in sctp_cmd_new_state()
1103 /* Send the whole message, chunk by chunk, to the outqueue.
1113 sctp_outq_tail(&asoc->outqueue, chunk, gfp); in sctp_cmd_send_msg()
1115 asoc->outqueue.sched->enqueue(&asoc->outqueue, msg); in sctp_cmd_send_msg()
1310 sctp_outq_uncork(&asoc->outqueue, gf in sctp_cmd_interpreter()
[all...]
H A Dchunk.c91 error = msg->send_error ?: asoc->outqueue.error; in sctp_datamsg_destroy()
215 asoc->outqueue.out_qlen == 0 && in sctp_datamsg_from_user()
216 list_empty(&asoc->outqueue.retransmit) && in sctp_datamsg_from_user()
H A Dstream.c32 outq = &asoc->outqueue; in sctp_stream_shrink_out()
248 if (!asoc->outqueue.out_qlen) in sctp_stream_outq_is_empty()
394 if (!sctp_outq_is_empty(&asoc->outqueue)) in sctp_send_reset_assoc()
710 if (!sctp_outq_is_empty(&asoc->outqueue)) { in sctp_process_strreset_tsnreq()
746 sctp_outq_free(&asoc->outqueue); in sctp_process_strreset_tsnreq()
1018 list_splice_init(&asoc->outqueue.out_chunk_list, &temp); in sctp_process_strreset_resp()
1019 sctp_outq_free(&asoc->outqueue); in sctp_process_strreset_resp()
1020 list_splice_init(&temp, &asoc->outqueue.out_chunk_list); in sctp_process_strreset_resp()
H A DMakefile12 inqueue.o outqueue.o ulpqueue.o \
H A Dassociola.c227 sctp_outq_init(asoc, &asoc->outqueue); in sctp_association_init()
338 /* Dispose of any data lying around in the outqueue. */ in sctp_association_free()
339 sctp_outq_free(&asoc->outqueue); in sctp_association_free()
463 if (!asoc->outqueue.outstanding_bytes && !asoc->outqueue.out_qlen) in sctp_assoc_set_primary()
571 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) in sctp_assoc_rm_peer()
1519 sctp_outq_tail(&asoc->outqueue, sack, GFP_ATOMIC); in sctp_assoc_rwnd_increase()
H A Doutqueue.c10 * These functions implement the sctp_outq class. The outqueue handles
204 /* Free the outqueue structure and any related pending chunks.
273 /* Free the outqueue structure and any related pending chunks. */
358 sctp_insert_list(&asoc->outqueue.abandoned, in sctp_prsctp_prune_sent()
366 if (queue != &asoc->outqueue.retransmit && in sctp_prsctp_prune_sent()
371 asoc->outqueue.outstanding_bytes -= sctp_data_size(chk); in sctp_prsctp_prune_sent()
385 struct sctp_outq *q = &asoc->outqueue; in sctp_prsctp_prune_unsent()
432 &asoc->outqueue.retransmit, in sctp_prsctp_prune()
758 /* Cork the outqueue so queued chunks are really queued. */
1183 /* Try to flush an outqueue
[all...]
H A Dstream_sched_rr.c156 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) { in sctp_sched_rr_sched_all()
H A Dstream_sched_fc.c175 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) { in sctp_sched_fc_sched_all()
H A Dstream_sched_prio.c283 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) { in sctp_sched_prio_sched_all()
H A Doutput.c678 struct sctp_outq *q = &asoc->outqueue; in sctp_packet_can_append_data()
768 asoc->outqueue.outstanding_bytes += datasize; in sctp_packet_append_data()
/kernel/linux/linux-5.10/drivers/isdn/capi/
H A Dcapi.c96 struct sk_buff_head outqueue; member
200 skb_queue_purge(&mp->outqueue); in capiminor_destroy()
227 skb_queue_head_init(&mp->outqueue); in capiminor_alloc()
509 skb = __skb_dequeue(&mp->outqueue); in handle_minor_send()
536 __skb_queue_head(&mp->outqueue, skb); in handle_minor_send()
554 __skb_queue_head(&mp->outqueue, skb); in handle_minor_send()
1091 __skb_queue_tail(&mp->outqueue, skb); in capinc_tty_write()
1105 __skb_queue_tail(&mp->outqueue, skb); in capinc_tty_write()
1131 __skb_queue_tail(&mp->outqueue, skb); in capinc_tty_put_char()
1166 __skb_queue_tail(&mp->outqueue, sk in capinc_tty_flush_chars()
[all...]
/kernel/linux/linux-6.6/drivers/isdn/capi/
H A Dcapi.c97 struct sk_buff_head outqueue; member
201 skb_queue_purge(&mp->outqueue); in capiminor_destroy()
228 skb_queue_head_init(&mp->outqueue); in capiminor_alloc()
510 skb = __skb_dequeue(&mp->outqueue); in handle_minor_send()
537 __skb_queue_head(&mp->outqueue, skb); in handle_minor_send()
555 __skb_queue_head(&mp->outqueue, skb); in handle_minor_send()
1092 __skb_queue_tail(&mp->outqueue, skb); in capinc_tty_write()
1106 __skb_queue_tail(&mp->outqueue, skb); in capinc_tty_write()
1132 __skb_queue_tail(&mp->outqueue, skb); in capinc_tty_put_char()
1165 __skb_queue_tail(&mp->outqueue, sk in capinc_tty_flush_chars()
[all...]
/kernel/linux/linux-5.10/net/tipc/
H A Dtopsrv.c88 * @outqueue: pointer to first outbound message in queue
89 * @outqueue_lock: control access to the outqueue
101 struct list_head outqueue; member
102 spinlock_t outqueue_lock; /* for outqueue */
137 list_for_each_entry_safe(e, safe, &con->outqueue, list) { in tipc_conn_kref_release()
189 INIT_LIST_HEAD(&con->outqueue); in tipc_conn_alloc()
250 struct list_head *queue = &con->outqueue; in tipc_conn_send_to_sock()
333 list_add_tail(&e->list, &con->outqueue); in tipc_topsrv_queue_evt()
/kernel/linux/linux-6.6/net/tipc/
H A Dtopsrv.c89 * @outqueue: pointer to first outbound message in queue
90 * @outqueue_lock: control access to the outqueue
102 struct list_head outqueue; member
103 spinlock_t outqueue_lock; /* for outqueue */
138 list_for_each_entry_safe(e, safe, &con->outqueue, list) { in tipc_conn_kref_release()
190 INIT_LIST_HEAD(&con->outqueue); in tipc_conn_alloc()
251 struct list_head *queue = &con->outqueue; in tipc_conn_send_to_sock()
334 list_add_tail(&e->list, &con->outqueue); in tipc_topsrv_queue_evt()

Completed in 25 milliseconds

12