Lines Matching refs:tcp_probe

84 } tcp_probe;  variable
88 return (tcp_probe.head - tcp_probe.tail) & (bufsize - 1); in tcp_probe_used()
118 (full || tp->snd_cwnd != tcp_probe.lastcwnd)) { in jtcp_rcv_established()
120 spin_lock(&tcp_probe.lock); in jtcp_rcv_established()
123 struct tcp_log *p = tcp_probe.log + tcp_probe.head; in jtcp_rcv_established()
157 tcp_probe.head = (tcp_probe.head + 1) & (bufsize - 1); in jtcp_rcv_established()
159 tcp_probe.lastcwnd = tp->snd_cwnd; in jtcp_rcv_established()
160 spin_unlock(&tcp_probe.lock); in jtcp_rcv_established()
162 wake_up(&tcp_probe.wait); in jtcp_rcv_established()
178 spin_lock_bh(&tcp_probe.lock); in tcpprobe_open()
179 tcp_probe.head = tcp_probe.tail = 0; in tcpprobe_open()
180 tcp_probe.start = ktime_get(); in tcpprobe_open()
181 spin_unlock_bh(&tcp_probe.lock); in tcpprobe_open()
189 = tcp_probe.log + tcp_probe.tail; in tcpprobe_sprint()
191 = ktime_to_timespec(ktime_sub(p->tstamp, tcp_probe.start)); in tcpprobe_sprint()
215 error = wait_event_interruptible(tcp_probe.wait, in tcpprobe_read()
220 spin_lock_bh(&tcp_probe.lock); in tcpprobe_read()
221 if (tcp_probe.head == tcp_probe.tail) { in tcpprobe_read()
223 spin_unlock_bh(&tcp_probe.lock); in tcpprobe_read()
230 tcp_probe.tail = (tcp_probe.tail + 1) & (bufsize - 1); in tcpprobe_read()
232 spin_unlock_bh(&tcp_probe.lock); in tcpprobe_read()
265 init_waitqueue_head(&tcp_probe.wait); in tcpprobe_init()
266 spin_lock_init(&tcp_probe.lock); in tcpprobe_init()
272 tcp_probe.log = kcalloc(bufsize, sizeof(struct tcp_log), GFP_KERNEL); in tcpprobe_init()
273 if (!tcp_probe.log) in tcpprobe_init()
289 kfree(tcp_probe.log); in tcpprobe_init()
298 kfree(tcp_probe.log); in tcpprobe_exit()