Lines Matching refs:conn_id
45 laddr[self->conn_id], lport[self->conn_id], \
46 faddr[self->conn_id], fport[self->conn_id], \
47 iss[self->conn_id], irs[self->conn_id], \
48 send_count[self->conn_id], recv_count[self->conn_id]))
56 probe_name[self->conn_id, i], \
57 conn_time[self->conn_id, i], \
58 send_recv[self->conn_id, i], \
59 seqno[self->conn_id, i], \
60 ack[self->conn_id, i], \
61 datalen[self->conn_id, i], \
62 wnd[self->conn_id, i], \
63 flags[self->conn_id, i]))
96 self->conn_id = (uint64_t)self->tcpp->tcp_connp;
100 /first[self->conn_id] == 0/
103 pcount[self->conn_id] = -1;
104 rollover[self->conn_id] = 0;
105 end_ptr[self->conn_id] = 0;
106 num[self->conn_id] = 0;
108 first[self->conn_id] = 1;
111 laddr[self->conn_id] = self->i_laddr;
112 faddr[self->conn_id] = self->i_faddr;
113 lport[self->conn_id] = self->i_lport;
114 fport[self->conn_id] = self->i_fport;
115 iss[self->conn_id] = self->tcpp->tcp_iss;
116 irs[self->conn_id] = self->tcpp->tcp_irs;
123 pcount[self->conn_id]++;
124 rollover[self->conn_id] |= pcount[self->conn_id]/MAX_RECORDS;
125 pcount[self->conn_id] = pcount[self->conn_id]%MAX_RECORDS;
126 self->pcount = pcount[self->conn_id];
127 end_ptr[self->conn_id] = self->pcount;
128 num[self->conn_id] = (rollover[self->conn_id]?
129 MAX_RECORDS : pcount[self->conn_id] + 1);
130 conn_time[self->conn_id, self->pcount] = walltimestamp;
133 seqno[self->conn_id, self->pcount] = ntohl(self->tcph->tha_seq);
134 ack[self->conn_id, self->pcount] = ntohl(self->tcph->tha_ack);
135 datalen[self->conn_id, self->pcount] = ntohs(self->iph->ipha_length);
136 wnd[self->conn_id, self->pcount] = ntohs(self->tcph->tha_win);
137 probe_name[self->conn_id, self->pcount] = probename;
140 flags[self->conn_id, self->pcount] = self->tcph->tha_flags;
146 send_count[self->conn_id]++;
147 send_recv[self->conn_id, self->pcount] = "S";
152 recv_count[self->conn_id]++;
153 send_recv[self->conn_id, self->pcount] = "R";
161 self->i = (end_ptr[self->conn_id] + MAX_RECORDS - num[self->conn_id]
166 /(self->flags & TH_RST) && (num[self->conn_id] >= 10)/
171 num[self->conn_id]--;
175 /(self->flags & TH_RST) && (num[self->conn_id] >= 9)/
180 num[self->conn_id]--;
184 /(self->flags & TH_RST) && (num[self->conn_id] >= 8)/
189 num[self->conn_id]--;
193 /(self->flags & TH_RST) && (num[self->conn_id] >= 7)/
198 num[self->conn_id]--;
202 /(self->flags & TH_RST) && (num[self->conn_id] >= 6)/
207 num[self->conn_id]--;
211 /(self->flags & TH_RST) && (num[self->conn_id] >= 5)/
216 num[self->conn_id]--;
220 /(self->flags & TH_RST) && (num[self->conn_id] >= 4)/
225 num[self->conn_id]--;
229 /(self->flags & TH_RST) && (num[self->conn_id] >= 3)/
234 num[self->conn_id]--;
238 /(self->flags & TH_RST) && (num[self->conn_id] >= 2)/
243 num[self->conn_id]--;
247 /(self->flags & TH_RST) && (num[self->conn_id] >= 1)/
252 num[self->conn_id]--;
253 self->reset = self->conn_id;
270 this->conn_id = (uint64_t)arg0;
272 pcount[this->conn_id] = -1;
273 rollover[this->conn_id] = 0;
274 end_ptr[this->conn_id] = 0;
275 num[this->conn_id] = 0;
276 first[this->conn_id] = 0;
278 laddr[this->conn_id] = 0;
279 faddr[this->conn_id] = 0;
280 lport[this->conn_id] = 0;
281 fport[this->conn_id] = 0;
282 iss[this->conn_id] = 0;
283 irs[this->conn_id] = 0;