| /Linux-v5.4/net/sctp/ |
| D | stream_sched.c | 133 struct sctp_sched_ops *old = asoc->outqueue.sched; in sctp_sched_set_sched()
160 asoc->outqueue.sched = n; in sctp_sched_set_sched()
172 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) { in sctp_sched_set_sched()
176 n->enqueue(&asoc->outqueue, msg); in sctp_sched_set_sched()
183 asoc->outqueue.sched = &sctp_sched_fcfs; /* Always safe */ in sctp_sched_set_sched()
193 if (asoc->outqueue.sched == sctp_sched_ops[i]) in sctp_sched_get_sched()
213 return asoc->outqueue.sched->set(&asoc->stream, sid, value, gfp); in sctp_sched_set_value()
225 return asoc->outqueue.sched->get(&asoc->stream, sid, value); in sctp_sched_get_value()
272 return asoc->outqueue.sched; in sctp_sched_ops_from_stream()
|
| D | sm_sideeffect.c | 604 asoc->outqueue.error = error; in sctp_cmd_init_failed()
645 asoc->outqueue.error = error; in sctp_cmd_assoc_failed()
795 if (sctp_outq_sack(&asoc->outqueue, chunk)) { in sctp_cmd_process_sack()
911 !sctp_outq_is_empty(&asoc->outqueue)) in sctp_cmd_new_state()
912 sctp_outq_uncork(&asoc->outqueue, GFP_ATOMIC); in sctp_cmd_new_state()
1099 sctp_outq_tail(&asoc->outqueue, chunk, gfp); in sctp_cmd_send_msg()
1101 asoc->outqueue.sched->enqueue(&asoc->outqueue, msg); in sctp_cmd_send_msg()
1293 sctp_outq_uncork(&asoc->outqueue, gfp); in sctp_cmd_interpreter()
1308 sctp_outq_teardown(&asoc->outqueue); in sctp_cmd_interpreter()
1313 sctp_outq_uncork(&asoc->outqueue, gfp); in sctp_cmd_interpreter()
[all …]
|
| D | chunk.c | 93 error = asoc->outqueue.error; in sctp_datamsg_destroy()
217 asoc->outqueue.out_qlen == 0 && in sctp_datamsg_from_user()
218 list_empty(&asoc->outqueue.retransmit) && in sctp_datamsg_from_user()
|
| D | stream.c | 38 outq = &asoc->outqueue; in sctp_stream_outq_migrate()
238 if (!asoc->outqueue.out_qlen) in sctp_stream_outq_is_empty()
384 if (!sctp_outq_is_empty(&asoc->outqueue)) in sctp_send_reset_assoc()
700 if (!sctp_outq_is_empty(&asoc->outqueue)) { in sctp_process_strreset_tsnreq()
736 sctp_outq_free(&asoc->outqueue); in sctp_process_strreset_tsnreq()
1008 list_splice_init(&asoc->outqueue.out_chunk_list, &temp); in sctp_process_strreset_resp()
1009 sctp_outq_free(&asoc->outqueue); in sctp_process_strreset_resp()
1010 list_splice_init(&temp, &asoc->outqueue.out_chunk_list); in sctp_process_strreset_resp()
|
| D | Makefile | 12 inqueue.o outqueue.o ulpqueue.o \
|
| D | associola.c | 221 sctp_outq_init(asoc, &asoc->outqueue); in sctp_association_init()
336 sctp_outq_free(&asoc->outqueue); in sctp_association_free()
458 if (!asoc->outqueue.outstanding_bytes && !asoc->outqueue.out_qlen) in sctp_assoc_set_primary()
566 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) in sctp_assoc_rm_peer()
1516 sctp_outq_tail(&asoc->outqueue, sack, GFP_ATOMIC); in sctp_assoc_rwnd_increase()
|
| D | stream_sched_rr.c | 157 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) { in sctp_sched_rr_sched_all()
|
| D | outqueue.c | 357 sctp_insert_list(&asoc->outqueue.abandoned, in sctp_prsctp_prune_sent()
365 if (queue != &asoc->outqueue.retransmit && in sctp_prsctp_prune_sent()
370 asoc->outqueue.outstanding_bytes -= sctp_data_size(chk); in sctp_prsctp_prune_sent()
384 struct sctp_outq *q = &asoc->outqueue; in sctp_prsctp_prune_unsent()
428 &asoc->outqueue.retransmit, in sctp_prsctp_prune()
|
| D | output.c | 654 struct sctp_outq *q = &asoc->outqueue; in sctp_packet_can_append_data()
744 asoc->outqueue.outstanding_bytes += datasize; in sctp_packet_append_data()
|
| D | stream_sched_prio.c | 301 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) { in sctp_sched_prio_sched_all()
|
| D | transport.c | 677 sctp_retransmit(&t->asoc->outqueue, t, SCTP_RTXR_T3_RTX); in sctp_transport_immediate_rtx()
|
| D | auth.c | 414 list_for_each_entry(chunk, &asoc->outqueue.out_chunk_list, list) { in sctp_auth_asoc_init_active_key()
|
| D | input.c | 416 sctp_retransmit(&asoc->outqueue, t, SCTP_RTXR_PMTUD); in sctp_icmp_frag_needed()
|
| D | sm_statefuns.c | 2801 if (sctp_outq_is_empty(&asoc->outqueue)) { in sctp_sf_do_9_2_shutdown()
4975 if (sctp_outq_is_empty(&asoc->outqueue)) { in sctp_sf_do_9_2_prm_shutdown()
6056 if (sctp_outq_is_empty(&asoc->outqueue)) { in sctp_sf_autoclose_timer_expire()
|
| D | socket.c | 154 struct sctp_outq *q = &asoc->outqueue; in sctp_for_each_tx_datachunk()
2238 if (asoc && sctp_outq_is_empty(&asoc->outqueue)) { in sctp_setsockopt_events()
4427 if (sctp_outq_is_empty(&asoc->outqueue)) { in sctp_assoc_ulpevent_type_set()
5227 list_for_each(pos, &asoc->outqueue.out_chunk_list) in sctp_get_sctp_info()
|
| /Linux-v5.4/drivers/isdn/capi/ |
| D | capi.c | 94 struct sk_buff_head outqueue; member
198 skb_queue_purge(&mp->outqueue); in capiminor_destroy()
225 skb_queue_head_init(&mp->outqueue); in capiminor_alloc()
507 skb = __skb_dequeue(&mp->outqueue); in handle_minor_send()
534 __skb_queue_head(&mp->outqueue, skb); in handle_minor_send()
552 __skb_queue_head(&mp->outqueue, skb); in handle_minor_send()
1058 __skb_queue_tail(&mp->outqueue, skb); in capinc_tty_write()
1072 __skb_queue_tail(&mp->outqueue, skb); in capinc_tty_write()
1098 __skb_queue_tail(&mp->outqueue, skb); in capinc_tty_put_char()
1133 __skb_queue_tail(&mp->outqueue, skb); in capinc_tty_flush_chars()
[all …]
|
| /Linux-v5.4/net/tipc/ |
| D | topsrv.c | 102 struct list_head outqueue; member
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()
249 struct list_head *queue = &con->outqueue; in tipc_conn_send_to_sock()
332 list_add_tail(&e->list, &con->outqueue); in tipc_topsrv_queue_evt()
|
| /Linux-v5.4/drivers/media/usb/usbvision/ |
| D | usbvision-video.c | 734 if (list_empty(&(usbvision->outqueue))) { in vidioc_dqbuf()
739 !list_empty(&(usbvision->outqueue))); in vidioc_dqbuf()
745 f = list_entry(usbvision->outqueue.next, in vidioc_dqbuf()
747 list_del(usbvision->outqueue.next); in vidioc_dqbuf()
929 if (list_empty(&(usbvision->outqueue))) { in usbvision_read()
935 !list_empty(&(usbvision->outqueue))); in usbvision_read()
941 frame = list_entry(usbvision->outqueue.next, in usbvision_read()
943 list_del(usbvision->outqueue.next); in usbvision_read()
|
| D | usbvision.h | 395 …struct list_head inqueue, outqueue; /* queued frame list and ready to … member
|
| D | usbvision-core.c | 1157 list_move_tail(&(frame->frame), &usbvision->outqueue); in usbvision_parse_data()
1815 INIT_LIST_HEAD(&(usbvision->outqueue)); in usbvision_empty_framequeues()
|
| /Linux-v5.4/drivers/media/usb/cx231xx/ |
| D | cx231xx.h | 648 struct list_head inqueue, outqueue; member
|
| /Linux-v5.4/include/net/sctp/ |
| D | structs.h | 1928 struct sctp_outq outqueue; member
|
