Lines Matching refs:rcvvar
82 if (stream->rcvvar != NULL && in GetFragInfo()
83 stream->rcvvar->rcvbuf != NULL) { in GetFragInfo()
84 tcprb_t *rcvbuf = stream->rcvvar->rcvbuf; in GetFragInfo()
141 stream->rcvvar != NULL && in GetBufInfo()
142 stream->rcvvar->rcvbuf != NULL) { in GetBufInfo()
143 tcprb_t *rcvbuf = stream->rcvvar->rcvbuf; in GetBufInfo()
145 tbi->tcpbi_init_seq = stream->rcvvar->irs + 1; in GetBufInfo()
239 struct tcp_recv_vars *rcvvar; in RaiseReadEvent() local
241 rcvvar = stream->rcvvar; in RaiseReadEvent()
246 } else if (rcvvar->rcvbuf && tcprb_cflen(rcvvar->rcvbuf) > 0) { in RaiseReadEvent()
451 stream->rcvvar = (struct tcp_recv_vars *)MPAllocateChunk(mtcp->rv_pool);
452 if (!stream->rcvvar) {
458 memset(stream->rcvvar, 0, sizeof(struct tcp_recv_vars));
463 MPFreeChunk(mtcp->rv_pool, stream->rcvvar);
535 pthread_spin_destroy(&stream->rcvvar->read_lock);
539 pthread_mutex_destroy(&stream->rcvvar->read_lock);
544 stream->rcvvar->irs = 0;
547 stream->rcvvar->rcv_wnd = TCP_INITIAL_WINDOW;
549 stream->rcvvar->snd_wl1 = stream->rcvvar->irs - 1;
557 if (pthread_spin_init(&stream->rcvvar->read_lock, PTHREAD_PROCESS_PRIVATE)) {
559 if (pthread_mutex_init(&stream->rcvvar->read_lock, NULL)) {
735 if (stream->rcvvar->rcvbuf) {
738 stream->rcvvar->rcvbuf->cum_len,
739 stream->rcvvar->rcvbuf->merged_len,
740 stream->rcvvar->rcvbuf->last_len);
805 SBUF_LOCK_DESTROY(&stream->rcvvar->read_lock);
823 if (stream->rcvvar->rcvbuf) {
824 tcprb_del(stream->rcvvar->rcvbuf);
825 stream->rcvvar->rcvbuf = NULL;
850 MPFreeChunk(mtcp->rv_pool, stream->rcvvar);
900 struct tcp_recv_vars *rcvvar = stream->rcvvar; local
979 stream->rcv_nxt, rcvvar->irs,
980 rcvvar->rcv_wnd, rcvvar->snd_wl1, rcvvar->snd_wl2);
981 if (!rcvvar->rcvbuf) {
985 rcvvar->last_ack_seq, rcvvar->dup_acks);
988 "ts_tw_expire: %u\n", rcvvar->ts_recent, rcvvar->ts_lastack_rcvd,
989 rcvvar->ts_last_ts_upd, rcvvar->ts_tw_expire);
992 rcvvar->srtt, rcvvar->mdev, rcvvar->mdev_max,
993 rcvvar->rttvar, rcvvar->rtt_seq);