Lines Matching refs:sndvar

461 	stream->sndvar = (struct tcp_send_vars *)MPAllocateChunk(mtcp->sv_pool);
462 	if (!stream->sndvar) {
470 		memset(stream->sndvar, 0, sizeof(struct tcp_send_vars));
518 	stream->sndvar->mss = TCP_DEFAULT_MSS;
519 	stream->sndvar->wscale_mine = TCP_DEFAULT_WSCALE;
520 	stream->sndvar->wscale_peer = 0;
523 		stream->sndvar->ip_id = 0;
524 		stream->sndvar->nif_out = GetOutputInterface(stream->daddr);
526 		stream->sndvar->iss = posix_seq_rand() % TCP_MAX_SEQ;
528 		stream->snd_nxt = stream->sndvar->iss;
529 		stream->sndvar->snd_una = stream->sndvar->iss;
530 		stream->sndvar->snd_wnd = g_config.mos->wmem_size;
531 		stream->sndvar->rto = TCP_INITIAL_RTO;
533 		if (pthread_spin_init(&stream->sndvar->write_lock, PTHREAD_PROCESS_PRIVATE)) {
537 		if (pthread_mutex_init(&stream->sndvar->write_lock, NULL)) {
575 			stream->sndvar->iss);
729 	if (stream->sndvar->sndbuf) {
732 				stream->sndvar->sndbuf->cum_len, 
733 				stream->sndvar->sndbuf->len);
745 	if (stream->sndvar->rstat.tdp_ack_cnt) {
749 				stream->sndvar->rstat.tdp_ack_cnt, stream->sndvar->rstat.tdp_ack_bytes, 
750 				stream->sndvar->rstat.tdp_ack_bytes / stream->sndvar->rstat.tdp_ack_cnt);
754 	if (stream->sndvar->rstat.rto_cnt > 0) {
756 				stream->sndvar->rstat.rto_cnt, stream->sndvar->rstat.rto_bytes);
760 	if (stream->sndvar->rstat.ack_upd_cnt) {
764 				stream->sndvar->rstat.ack_upd_cnt, stream->sndvar->rstat.ack_upd_bytes, 
765 				stream->sndvar->rstat.ack_upd_bytes / stream->sndvar->rstat.ack_upd_cnt);
768 	if (stream->sndvar->rstat.sack_cnt) {
771 				stream->sndvar->rstat.sack_cnt, stream->sndvar->rstat.sack_bytes, 
772 				stream->sndvar->rstat.sack_bytes / stream->sndvar->rstat.sack_cnt);
775 				stream->sndvar->rstat.sack_cnt, stream->sndvar->rstat.sack_bytes);
777 	if (stream->sndvar->rstat.tdp_sack_cnt) {
780 				stream->sndvar->rstat.tdp_sack_cnt, stream->sndvar->rstat.tdp_sack_bytes, 
781 				stream->sndvar->rstat.tdp_sack_bytes / stream->sndvar->rstat.tdp_sack_cnt);
784 				stream->sndvar->rstat.tdp_sack_cnt, stream->sndvar->rstat.tdp_sack_bytes);
806 		SBUF_LOCK_DESTROY(&stream->sndvar->write_lock);
811 		if (stream->sndvar->sndbuf) {
812 			SBFree(mtcp->rbm_snd, stream->sndvar->sndbuf);
813 			stream->sndvar->sndbuf = NULL;
851 	MPFreeChunk(mtcp->sv_pool, stream->sndvar);
899 	struct tcp_send_vars *sndvar = stream->sndvar;  local
938 			sndvar->on_control_list, stream->control_list_waiting, sndvar->on_send_list, 
939 			sndvar->on_ack_list, sndvar->is_wack, sndvar->ack_cnt, 
942 			sndvar->on_sendq, sndvar->on_ackq, 
943 			stream->closed, sndvar->on_closeq, sndvar->on_closeq_int, 
944 			sndvar->on_resetq, sndvar->on_resetq_int, 
945 			stream->have_reset, sndvar->is_fin_sent, 
946 			sndvar->is_fin_ackd, stream->saw_timestamp, stream->sack_permit, 
952 		      sndvar->ip_id, sndvar->mss, sndvar->eff_mss, 
953 		      sndvar->wscale_mine, sndvar->wscale_peer, sndvar->nif_out);
957 			stream->snd_nxt, sndvar->snd_una, sndvar->iss, sndvar->fss, 
958 			sndvar->snd_wnd, sndvar->peer_wnd, sndvar->cwnd, sndvar->ssthresh);
960 	if (sndvar->sndbuf) {
964 				sndvar->sndbuf->init_seq, sndvar->sndbuf->head_seq, 
965 				sndvar->sndbuf->len, sndvar->sndbuf->cum_len, sndvar->sndbuf->size);
971 			"ts_lastack_sent: %u\n", sndvar->nrtx, sndvar->max_nrtx, 
972 			sndvar->rto, sndvar->ts_rto, sndvar->ts_lastack_sent);