Home
last modified time | relevance | path

Searched refs:outqueue (Results 1 – 22 of 22) sorted by relevance

/Linux-v4.19/net/sctp/
Dstream_sched.c148 struct sctp_sched_ops *old = asoc->outqueue.sched; in sctp_sched_set_sched()
175 asoc->outqueue.sched = n; in sctp_sched_set_sched()
187 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) { in sctp_sched_set_sched()
191 n->enqueue(&asoc->outqueue, msg); in sctp_sched_set_sched()
198 asoc->outqueue.sched = &sctp_sched_fcfs; /* Always safe */ in sctp_sched_set_sched()
208 if (asoc->outqueue.sched == sctp_sched_ops[i]) in sctp_sched_get_sched()
228 return asoc->outqueue.sched->set(&asoc->stream, sid, value, gfp); in sctp_sched_set_value()
240 return asoc->outqueue.sched->get(&asoc->stream, sid, value); in sctp_sched_get_value()
287 return asoc->outqueue.sched; in sctp_sched_ops_from_stream()
Dsm_sideeffect.c619 asoc->outqueue.error = error; in sctp_cmd_init_failed()
660 asoc->outqueue.error = error; in sctp_cmd_assoc_failed()
810 if (sctp_outq_sack(&asoc->outqueue, chunk)) { in sctp_cmd_process_sack()
921 !sctp_outq_is_empty(&asoc->outqueue)) in sctp_cmd_new_state()
922 sctp_outq_uncork(&asoc->outqueue, GFP_ATOMIC); in sctp_cmd_new_state()
1109 sctp_outq_tail(&asoc->outqueue, chunk, gfp); in sctp_cmd_send_msg()
1111 asoc->outqueue.sched->enqueue(&asoc->outqueue, msg); in sctp_cmd_send_msg()
1329 sctp_outq_uncork(&asoc->outqueue, gfp); in sctp_cmd_interpreter()
1344 sctp_outq_teardown(&asoc->outqueue); in sctp_cmd_interpreter()
1349 sctp_outq_uncork(&asoc->outqueue, gfp); in sctp_cmd_interpreter()
[all …]
Dchunk.c109 error = asoc->outqueue.error; in sctp_datamsg_destroy()
228 asoc->outqueue.out_qlen == 0 && in sctp_datamsg_from_user()
229 list_empty(&asoc->outqueue.retransmit) && in sctp_datamsg_from_user()
Dstream.c100 outq = &asoc->outqueue; in sctp_stream_outq_migrate()
311 if (!asoc->outqueue.out_qlen) in sctp_stream_outq_is_empty()
456 if (!sctp_outq_is_empty(&asoc->outqueue)) in sctp_send_reset_assoc()
782 if (!sctp_outq_is_empty(&asoc->outqueue)) { in sctp_process_strreset_tsnreq()
818 sctp_outq_free(&asoc->outqueue); in sctp_process_strreset_tsnreq()
1091 list_splice_init(&asoc->outqueue.out_chunk_list, &temp); in sctp_process_strreset_resp()
1092 sctp_outq_free(&asoc->outqueue); in sctp_process_strreset_resp()
1093 list_splice_init(&temp, &asoc->outqueue.out_chunk_list); in sctp_process_strreset_resp()
DMakefile12 inqueue.o outqueue.o ulpqueue.o \
Dstream_sched_rr.c172 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) { in sctp_sched_rr_sched_all()
Dassociola.c246 sctp_outq_init(asoc, &asoc->outqueue); in sctp_association_init()
359 sctp_outq_free(&asoc->outqueue); in sctp_association_free()
481 if (!asoc->outqueue.outstanding_bytes && !asoc->outqueue.out_qlen) in sctp_assoc_set_primary()
1535 sctp_outq_tail(&asoc->outqueue, sack, GFP_ATOMIC); in sctp_assoc_rwnd_increase()
Doutqueue.c372 sctp_insert_list(&asoc->outqueue.abandoned, in sctp_prsctp_prune_sent()
380 if (queue != &asoc->outqueue.retransmit && in sctp_prsctp_prune_sent()
385 asoc->outqueue.outstanding_bytes -= sctp_data_size(chk); in sctp_prsctp_prune_sent()
401 struct sctp_outq *q = &asoc->outqueue; in sctp_prsctp_prune_unsent()
447 &asoc->outqueue.retransmit, in sctp_prsctp_prune()
Doutput.c681 struct sctp_outq *q = &asoc->outqueue; in sctp_packet_can_append_data()
771 asoc->outqueue.outstanding_bytes += datasize; in sctp_packet_append_data()
Dstream_sched_prio.c316 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) { in sctp_sched_prio_sched_all()
Dtransport.c691 sctp_retransmit(&t->asoc->outqueue, t, SCTP_RTXR_T3_RTX); in sctp_transport_immediate_rtx()
Dauth.c429 list_for_each_entry(chunk, &asoc->outqueue.out_chunk_list, list) { in sctp_auth_asoc_init_active_key()
Dinput.c422 sctp_retransmit(&asoc->outqueue, t, SCTP_RTXR_PMTUD); in sctp_icmp_frag_needed()
Dsm_statefuns.c2816 if (sctp_outq_is_empty(&asoc->outqueue)) { in sctp_sf_do_9_2_shutdown()
4969 if (sctp_outq_is_empty(&asoc->outqueue)) { in sctp_sf_do_9_2_prm_shutdown()
6050 if (sctp_outq_is_empty(&asoc->outqueue)) { in sctp_sf_autoclose_timer_expire()
Dsocket.c187 struct sctp_outq *q = &asoc->outqueue; in sctp_for_each_tx_datachunk()
2341 if (asoc && sctp_outq_is_empty(&asoc->outqueue)) { in sctp_setsockopt_events()
4932 list_for_each(pos, &asoc->outqueue.out_chunk_list) in sctp_get_sctp_info()
/Linux-v4.19/drivers/isdn/capi/
Dcapi.c94 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()
1050 __skb_queue_tail(&mp->outqueue, skb); in capinc_tty_write()
1064 __skb_queue_tail(&mp->outqueue, skb); in capinc_tty_write()
1090 __skb_queue_tail(&mp->outqueue, skb); in capinc_tty_put_char()
1125 __skb_queue_tail(&mp->outqueue, skb); in capinc_tty_flush_chars()
[all …]
/Linux-v4.19/net/tipc/
Dtopsrv.c109 struct list_head outqueue; member
145 list_for_each_entry_safe(e, safe, &con->outqueue, list) { in tipc_conn_kref_release()
197 INIT_LIST_HEAD(&con->outqueue); in tipc_conn_alloc()
256 struct list_head *queue = &con->outqueue; in tipc_conn_send_to_sock()
339 list_add_tail(&e->list, &con->outqueue); in tipc_topsrv_queue_evt()
/Linux-v4.19/drivers/media/usb/usbvision/
Dusbvision-video.c752 if (list_empty(&(usbvision->outqueue))) { in vidioc_dqbuf()
757 !list_empty(&(usbvision->outqueue))); in vidioc_dqbuf()
763 f = list_entry(usbvision->outqueue.next, in vidioc_dqbuf()
765 list_del(usbvision->outqueue.next); in vidioc_dqbuf()
948 if (list_empty(&(usbvision->outqueue))) { in usbvision_read()
954 !list_empty(&(usbvision->outqueue))); in usbvision_read()
960 frame = list_entry(usbvision->outqueue.next, in usbvision_read()
962 list_del(usbvision->outqueue.next); in usbvision_read()
Dusbvision.h406 …struct list_head inqueue, outqueue; /* queued frame list and ready to … member
Dusbvision-core.c1167 list_move_tail(&(frame->frame), &usbvision->outqueue); in usbvision_parse_data()
1828 INIT_LIST_HEAD(&(usbvision->outqueue)); in usbvision_empty_framequeues()
/Linux-v4.19/drivers/media/usb/cx231xx/
Dcx231xx.h661 struct list_head inqueue, outqueue; member
/Linux-v4.19/include/net/sctp/
Dstructs.h1930 struct sctp_outq outqueue; member