Lines Matching defs:ccb
141 * args: ccbp - pointer to sender ccb block
161 * args: ccbp - pointer to sender ccb block
231 tfrc_time_send(void *ccb)
233 struct tfrc_send_ccb *cb = (struct tfrc_send_ccb *) ccb;
364 tfrc_time_no_feedback(void *ccb)
369 struct tfrc_send_ccb *cb = (struct tfrc_send_ccb *) ccb;
481 * Removes ccb from memory
482 * args: ccb - ccb of sender
485 tfrc_send_term(void *ccb)
487 struct tfrc_send_ccb *cb = (struct tfrc_send_ccb *) ccb;
489 if (ccb == 0)
490 panic("TFRC - Sender ccb is null! (free)");
511 struct tfrc_send_ccb *ccb;
513 ccb = malloc(sizeof(struct tfrc_send_ccb), M_PCB, M_NOWAIT | M_ZERO);
514 if (ccb == 0) {
520 mutex_init(&(ccb->mutex), MUTEX_DEFAULT, IPL_SOFTNET);
522 ccb->pcb = pcb;
523 if (ccb->pcb->avgpsize >= TFRC_MIN_PACKET_SIZE && ccb->pcb->avgpsize <= TFRC_MAX_PACKET_SIZE)
524 ccb->s = (u_int16_t) ccb->pcb->avgpsize;
526 ccb->s = TFRC_STD_PACKET_SIZE;
528 TFRC_DEBUG((LOG_INFO, "TFRC - Sender is using packet size %u\n", ccb->s));
530 ccb->x.num = ccb->s; /* set transmissionrate to 1 packet per second */
531 ccb->x.denom = 1;
533 ccb->t_ld.tv_sec = -1;
534 ccb->t_ld.tv_usec = 0;
537 ccb->t_last_win_count.tv_sec = -1;
539 callout_init(&ccb->ch_stimer, 0);
540 callout_init(&ccb->ch_nftimer, 0);
543 TAILQ_INIT(&(ccb->hist));
545 ccb->state = TFRC_SSTATE_NO_SENT;
549 return ccb;
554 * args: ccb - ccb of sender
558 tfrc_send_free(void *ccb)
561 struct tfrc_send_ccb *cb = (struct tfrc_send_ccb *) ccb;
565 if (ccb == 0)
589 /* schedule the removal of ccb */
595 * args: ccb - ccb block for current connection
599 tfrc_send_packet(void *ccb, long datasize)
606 struct tfrc_send_ccb *cb = (struct tfrc_send_ccb *) ccb;
714 * args: ccb - ccb block for current connection
719 tfrc_send_packet_sent(void *ccb, int moreToSend, long datasize)
723 struct tfrc_send_ccb *cb = (struct tfrc_send_ccb *) ccb;
821 * args: ccb - ccb block for current connection
824 tfrc_send_packet_recv(void *ccb, char *options, int optlen)
838 struct tfrc_send_ccb *cb = (struct tfrc_send_ccb *) ccb;
1040 * args: cb - ccb of receiver
1059 * args: cb - ccb of receiver
1076 * args: cb - ccb of receiver
1163 * args: cb - ccb for receiver
1245 * args: cb - ccb of the receiver
1336 * args: cb - ccb of receiver
1445 * args: cb - ccb of the receiver
1608 struct tfrc_recv_ccb *ccb;
1610 ccb = malloc(sizeof(struct tfrc_recv_ccb), M_PCB, M_NOWAIT | M_ZERO);
1611 if (ccb == 0) {
1617 mutex_init(&(ccb->mutex), MUTEX_DEFAULT, IPL_SOFTNET);
1619 ccb->pcb = pcb;
1621 if (ccb->pcb->avgpsize >= TFRC_MIN_PACKET_SIZE && ccb->pcb->avgpsize <= TFRC_MAX_PACKET_SIZE)
1622 ccb->s = (u_int16_t) ccb->pcb->avgpsize;
1624 ccb->s = TFRC_STD_PACKET_SIZE;
1626 TFRC_DEBUG((LOG_INFO, "TFRC - Receiver is using packet size %u\n", ccb->s));
1629 TAILQ_INIT(&(ccb->hist));
1632 TAILQ_INIT(&(ccb->li_hist));
1634 ccb->state = TFRC_RSTATE_NO_DATA;
1637 return ccb;
1640 * args: ccb - ccb of receiver
1644 tfrc_recv_free(void *ccb)
1648 struct tfrc_recv_ccb *cb = (struct tfrc_recv_ccb *) ccb;
1650 if (ccb == 0)
1651 panic("TFRC - Receiver ccb is null! (free)");
1680 free(ccb, M_PCB);
1688 * args: ccb - ccb block for current connection
1691 tfrc_recv_packet_recv(void *ccb, char *options, int optlen)
1697 struct tfrc_recv_ccb *cb = (struct tfrc_recv_ccb *) ccb;