Lines Matching refs:sender
573 struct mtcp_sender *sender, uint32_t cur_ts, int thresh) in WriteTCPControlList() argument
580 thresh = MIN(thresh, sender->control_list_cnt); in WriteTCPControlList()
584 cur_stream = TAILQ_FIRST(&sender->control_list); in WriteTCPControlList()
585 last = TAILQ_LAST(&sender->control_list, control_head); in WriteTCPControlList()
594 TAILQ_REMOVE(&sender->control_list, cur_stream, sndvar->control_link); in WriteTCPControlList()
595 sender->control_list_cnt--; in WriteTCPControlList()
602 TAILQ_INSERT_HEAD(&sender->control_list, in WriteTCPControlList()
605 sender->control_list_cnt++; in WriteTCPControlList()
623 struct mtcp_sender *sender, uint32_t cur_ts, int thresh) in WriteTCPDataList() argument
632 cur_stream = TAILQ_FIRST(&sender->send_list); in WriteTCPDataList()
633 last = TAILQ_LAST(&sender->send_list, send_head); in WriteTCPDataList()
642 TAILQ_REMOVE(&sender->send_list, cur_stream, sndvar->send_link); in WriteTCPDataList()
669 TAILQ_INSERT_TAIL(&sender->send_list, cur_stream, sndvar->send_link); in WriteTCPDataList()
675 sender->send_list_cnt--; in WriteTCPDataList()
713 struct mtcp_sender *sender, uint32_t cur_ts, int thresh) in WriteTCPACKList() argument
723 cur_stream = TAILQ_FIRST(&sender->ack_list); in WriteTCPACKList()
724 last = TAILQ_LAST(&sender->ack_list, ack_head); in WriteTCPACKList()
787 TAILQ_REMOVE(&sender->ack_list, cur_stream, sndvar->ack_link); in WriteTCPACKList()
788 sender->ack_list_cnt--; in WriteTCPACKList()
794 TAILQ_REMOVE(&sender->ack_list, cur_stream, sndvar->ack_link); in WriteTCPACKList()
795 sender->ack_list_cnt--; in WriteTCPACKList()
806 TAILQ_REMOVE(&sender->ack_list, cur_stream, sndvar->ack_link); in WriteTCPACKList()
807 sender->ack_list_cnt--; in WriteTCPACKList()
843 struct mtcp_sender *sender = GetSender(mtcp, cur_stream); in AddtoControlList() local
844 assert(sender != NULL); in AddtoControlList()
850 struct mtcp_sender *sender = GetSender(mtcp, cur_stream); in AddtoControlList() local
851 assert(sender != NULL); in AddtoControlList()
854 TAILQ_INSERT_TAIL(&sender->control_list, cur_stream, sndvar->control_link); in AddtoControlList()
855 sender->control_list_cnt++; in AddtoControlList()
863 TAILQ_REMOVE(&sender->control_list, cur_stream, sndvar->control_link); in AddtoControlList()
864 sender->control_list_cnt--; in AddtoControlList()
873 struct mtcp_sender *sender = GetSender(mtcp, cur_stream); in AddtoSendList() local
874 assert(sender != NULL); in AddtoSendList()
886 TAILQ_INSERT_TAIL(&sender->send_list, cur_stream, sndvar->send_link); in AddtoSendList()
887 sender->send_list_cnt++; in AddtoSendList()
894 struct mtcp_sender *sender = GetSender(mtcp, cur_stream); in AddtoACKList() local
895 assert(sender != NULL); in AddtoACKList()
899 TAILQ_INSERT_TAIL(&sender->ack_list, cur_stream, sndvar->ack_link); in AddtoACKList()
900 sender->ack_list_cnt++; in AddtoACKList()
907 struct mtcp_sender *sender = GetSender(mtcp, cur_stream); in RemoveFromControlList() local
908 assert(sender != NULL); in RemoveFromControlList()
912 TAILQ_REMOVE(&sender->control_list, cur_stream, sndvar->control_link); in RemoveFromControlList()
913 sender->control_list_cnt--; in RemoveFromControlList()
922 struct mtcp_sender *sender = GetSender(mtcp, cur_stream); in RemoveFromSendList() local
923 assert(sender != NULL); in RemoveFromSendList()
927 TAILQ_REMOVE(&sender->send_list, cur_stream, sndvar->send_link); in RemoveFromSendList()
928 sender->send_list_cnt--; in RemoveFromSendList()
935 struct mtcp_sender *sender = GetSender(mtcp, cur_stream); in RemoveFromACKList() local
936 assert(sender != NULL); in RemoveFromACKList()
940 TAILQ_REMOVE(&sender->ack_list, cur_stream, sndvar->ack_link); in RemoveFromACKList()
941 sender->ack_list_cnt--; in RemoveFromACKList()
972 DumpControlList(mtcp_manager_t mtcp, struct mtcp_sender *sender) in DumpControlList() argument
976 TRACE_DBG("Dumping control list (count: %d):\n", sender->control_list_cnt); in DumpControlList()
977 TAILQ_FOREACH(stream, &sender->control_list, sndvar->control_link) { in DumpControlList()