Lines Matching defs:chk
102 struct sctp_tmit_chunk *chk;
113 TAILQ_FOREACH(chk, &asoc->sent_queue, sctp_next) {
114 if (chk->sent == SCTP_DATAGRAM_RESEND) {
119 TAILQ_FOREACH(chk, &asoc->control_send_queue, sctp_next) {
120 if (chk->sent == SCTP_DATAGRAM_RESEND) {
356 struct sctp_tmit_chunk *chk, *tp2;
431 chk = TAILQ_FIRST(&stcb->asoc.sent_queue);
432 for (;chk != NULL; chk = tp2) {
433 tp2 = TAILQ_NEXT(chk, sctp_next);
435 chk->rec.data.TSN_seq,
437 (stcb->asoc.last_acked_seq == chk->rec.data.TSN_seq)) {
440 TAILQ_REMOVE(&stcb->asoc.sent_queue, chk, sctp_next);
441 if (chk->data) {
442 sctp_release_pr_sctp_chunk(stcb, chk, 0xffff,
444 if (chk->flags & SCTP_PR_SCTP_BUFFER) {
449 sctp_free_remote_addr(chk->whoTo);
454 SCTP_ZONE_FREE(sctppcbinfo.ipi_zone_chunk, chk);
458 if ((chk->whoTo == net) && (chk->sent < SCTP_DATAGRAM_ACKED)) {
468 sctp_log_fr(chk->rec.data.TSN_seq,
469 chk->sent_rcv_time.tv_sec,
470 chk->sent_rcv_time.tv_usec,
473 if (chk->sent_rcv_time.tv_sec > min_wait.tv_sec) {
480 chk->sent_rcv_time.tv_sec,
481 chk->sent_rcv_time.tv_usec,
485 } else if (chk->sent_rcv_time.tv_sec == min_wait.tv_sec) {
488 if (chk->sent_rcv_time.tv_usec >= min_wait.tv_usec) {
492 chk->sent_rcv_time.tv_sec,
493 chk->sent_rcv_time.tv_usec,
502 if ((chk->flags & (SCTP_PR_SCTP_ENABLED|SCTP_PR_SCTP_BUFFER)) == SCTP_PR_SCTP_ENABLED) {
504 if ((now.tv_sec > chk->rec.data.timetodrop.tv_sec) ||
505 ((chk->rec.data.timetodrop.tv_sec == now.tv_sec) &&
506 (now.tv_usec > chk->rec.data.timetodrop.tv_usec))) {
508 if (chk->data) {
510 chk,
517 if (chk->sent != SCTP_DATAGRAM_RESEND) {
525 chk->rec.data.TSN_seq);
529 tsnfirst = chk->rec.data.TSN_seq;
533 tsnlast = chk->rec.data.TSN_seq;
534 sctp_log_fr(chk->rec.data.TSN_seq, chk->snd_count,
539 chk->sent = SCTP_DATAGRAM_RESEND;
541 chk->rec.data.doing_fast_retransmit = 0;
544 printf("mark TSN:%x for retransmission\n", chk->rec.data.TSN_seq);
548 chk->do_rtt = 0;
550 if (compare_with_wrap(chk->rec.data.TSN_seq,
554 stcb->asoc.t3timeout_highest_marked = chk->rec.data.TSN_seq;
557 sctp_free_remote_addr(chk->whoTo);
558 chk->whoTo = alt;
561 if ((chk->rec.data.state_flags & SCTP_WINDOW_PROBE) !=
565 chk->rec.data.state_flags &= ~SCTP_WINDOW_PROBE;
569 if (chk->sent == SCTP_DATAGRAM_RESEND) {
613 TAILQ_FOREACH(chk, &stcb->asoc.control_send_queue, sctp_next) {
614 if ((chk->whoTo == net) &&
615 (chk->rec.chunk_id == SCTP_ECN_ECHO)) {
616 sctp_free_remote_addr(chk->whoTo);
617 chk->whoTo = alt;
618 if (chk->sent != SCTP_DATAGRAM_RESEND) {
619 chk->sent = SCTP_DATAGRAM_RESEND;
660 TAILQ_FOREACH(chk, &stcb->asoc.sent_queue, sctp_next) {
661 if (chk->sent < SCTP_DATAGRAM_RESEND) {
662 stcb->asoc.total_flight += chk->book_size;
663 chk->whoTo->flight_size += chk->book_size;
674 chk = TAILQ_FIRST(&stcb->asoc.send_queue);
675 if (chk == NULL) {
678 stcb->asoc.nonce_resync_tsn = chk->rec.data.TSN_seq;
696 struct sctp_tmit_chunk *chk;
710 TAILQ_FOREACH(chk, &outs->outqueue, sctp_next) {
711 if (chk->whoTo == net) {
712 sctp_free_remote_addr(chk->whoTo);
713 chk->whoTo = alt;
719 TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) {
720 if (chk->whoTo == net) {
721 sctp_free_remote_addr(chk->whoTo);
722 chk->whoTo = alt;
968 struct sctp_tmit_chunk *strrst, *chk;
1007 TAILQ_FOREACH(chk, &stcb->asoc.control_send_queue, sctp_next) {
1008 if ((chk->whoTo == net) &&
1009 (chk->rec.chunk_id == SCTP_ECN_ECHO)) {
1010 sctp_free_remote_addr(chk->whoTo);
1011 if (chk->sent != SCTP_DATAGRAM_RESEND) {
1012 chk->sent = SCTP_DATAGRAM_RESEND;
1015 chk->whoTo = alt;
1022 * to alternates for ALL chk's in queue
1040 struct sctp_tmit_chunk *asconf, *chk;
1101 TAILQ_FOREACH(chk, &stcb->asoc.control_send_queue, sctp_next) {
1102 if ((chk->whoTo == net) &&
1103 (chk->rec.chunk_id == SCTP_ECN_ECHO)) {
1104 sctp_free_remote_addr(chk->whoTo);
1105 chk->whoTo = alt;
1106 if (chk->sent != SCTP_DATAGRAM_RESEND) {
1107 chk->sent = SCTP_DATAGRAM_RESEND;
1117 * to alternates for ALL chk's in queue
1195 struct sctp_tmit_chunk *chk;
1214 TAILQ_FOREACH(chk, &outs->outqueue, sctp_next) {
Indexes created Thu Sep 25 08:09:54 GMT 2025