dccp/ccids/ccid2.c

27 	struct ccid2_seq *seqp;
36 	seqp = kmalloc_array(CCID2_SEQBUF_LEN, sizeof(struct ccid2_seq),
38 	if (seqp == NULL)
42 		seqp[i].ccid2s_next = &seqp[i + 1];
43 		seqp[i + 1].ccid2s_prev = &seqp[i];
45 	seqp[CCID2_SEQBUF_LEN - 1].ccid2s_next = seqp;
46 	seqp->ccid2s_prev = &seqp[CCID2_SEQBUF_LEN - 1];
50 		hc->tx_seqh = hc->tx_seqt = seqp;
53 		hc->tx_seqh->ccid2s_next = seqp;
54 		seqp->ccid2s_prev = hc->tx_seqh;
56 		hc->tx_seqt->ccid2s_prev = &seqp[CCID2_SEQBUF_LEN - 1];
57 		seqp[CCID2_SEQBUF_LEN - 1].ccid2s_next = hc->tx_seqt;
61 	hc->tx_seqbuf[hc->tx_seqbufc] = seqp;
340 		struct ccid2_seq *seqp = hc->tx_seqt;
342 		while (seqp != hc->tx_seqh) {
344 				       (unsigned long long)seqp->ccid2s_seq,
345 				       seqp->ccid2s_acked, seqp->ccid2s_sent);
346 			seqp = seqp->ccid2s_next;
434 static void ccid2_new_ack(struct sock *sk, struct ccid2_seq *seqp,
477 	ccid2_rtt_estimator(sk, ccid2_jiffies32 - seqp->ccid2s_sent);
480 static void ccid2_congestion_event(struct sock *sk, struct ccid2_seq *seqp)
484 	if ((s32)(seqp->ccid2s_sent - hc->tx_last_cong) < 0) {
518 	struct ccid2_seq *seqp;
571 	seqp = hc->tx_seqt;
572 	while (before48(seqp->ccid2s_seq, ackno)) {
573 		seqp = seqp->ccid2s_next;
574 		if (seqp == hc->tx_seqh) {
575 			seqp = hc->tx_seqh->ccid2s_prev;
603 			while (after48(seqp->ccid2s_seq, ackno)) {
604 				if (seqp == hc->tx_seqt) {
608 				seqp = seqp->ccid2s_prev;
616 			while (between48(seqp->ccid2s_seq,ackno_end_rl,ackno)) {
621 				    !seqp->ccid2s_acked) {
624 								       seqp);
626 						ccid2_new_ack(sk, seqp,
629 					seqp->ccid2s_acked = 1;
631 						       (unsigned long long)seqp->ccid2s_seq);
634 				if (seqp == hc->tx_seqt) {
638 				seqp = seqp->ccid2s_prev;
652 	seqp = hc->tx_seqt;
653 	while (before48(seqp->ccid2s_seq, hc->tx_high_ack)) {
654 		seqp = seqp->ccid2s_next;
655 		if (seqp == hc->tx_seqh) {
656 			seqp = hc->tx_seqh->ccid2s_prev;
662 		if (seqp->ccid2s_acked) {
667 		if (seqp == hc->tx_seqt)
669 		seqp = seqp->ccid2s_prev;
676 		struct ccid2_seq *last_acked = seqp;
680 			if (!seqp->ccid2s_acked) {
682 					       (unsigned long long)seqp->ccid2s_seq);
687 				ccid2_congestion_event(sk, seqp);
690 			if (seqp == hc->tx_seqt)
692 			seqp = seqp->ccid2s_prev;