tag | line | file | source code |
sk | 271 | net/tcp/arp.c | skb->sk = NULL; |
sk | 442 | net/tcp/arp.c | skb->sk = NULL; |
sk | 269 | net/tcp/dev.c | skb->sk = NULL; |
sk | 150 | net/tcp/icmp.c | skb->sk = NULL; |
sk | 185 | net/tcp/icmp.c | skb1->sk = NULL; |
sk | 201 | net/tcp/icmp.c | skb1->sk = NULL; |
sk | 241 | net/tcp/icmp.c | skb1->sk = NULL; |
sk | 264 | net/tcp/icmp.c | skb1->sk = NULL; |
sk | 277 | net/tcp/icmp.c | skb1->sk = NULL; |
sk | 281 | net/tcp/icmp.c | skb->sk = NULL; |
sk | 293 | net/tcp/icmp.c | skb1->sk = NULL; |
sk | 316 | net/tcp/icmp.c | skb1->sk = NULL; |
sk | 322 | net/tcp/icmp.c | skb1->sk = NULL; |
sk | 328 | net/tcp/icmp.c | skb1->sk = NULL; |
sk | 727 | net/tcp/ip.c | skb->sk = NULL; |
sk | 736 | net/tcp/ip.c | skb->sk = NULL; |
sk | 745 | net/tcp/ip.c | skb->sk = NULL; |
sk | 789 | net/tcp/ip.c | skb->sk = NULL; |
sk | 804 | net/tcp/ip.c | ip_queue_xmit (volatile struct sock *sk, struct device *dev, |
sk | 809 | net/tcp/ip.c | if (sk == NULL) free = 1; |
sk | 836 | net/tcp/ip.c | sk->packets_out++; |
sk | 838 | net/tcp/ip.c | if (sk->send_tail == NULL) |
sk | 840 | net/tcp/ip.c | sk->send_tail = skb; |
sk | 841 | net/tcp/ip.c | sk->send_head = skb; |
sk | 845 | net/tcp/ip.c | sk->send_tail->link3 = skb; |
sk | 846 | net/tcp/ip.c | sk->send_tail = skb; |
sk | 849 | net/tcp/ip.c | sk->time_wait.len = sk->rtt*2; |
sk | 850 | net/tcp/ip.c | sk->timeout=TIME_WRITE; |
sk | 851 | net/tcp/ip.c | reset_timer ((struct timer *)&sk->time_wait); |
sk | 855 | net/tcp/ip.c | skb->sk = sk; |
sk | 859 | net/tcp/ip.c | if (sk != NULL) |
sk | 861 | net/tcp/ip.c | dev->queue_xmit(skb, dev, sk->priority); |
sk | 876 | net/tcp/ip.c | ip_retransmit (volatile struct sock *sk, int all) |
sk | 882 | net/tcp/ip.c | prot = sk->prot; |
sk | 883 | net/tcp/ip.c | skb = sk->send_head; |
sk | 902 | net/tcp/ip.c | if (sk) |
sk | 903 | net/tcp/ip.c | dev->queue_xmit(skb, dev, sk->priority); |
sk | 907 | net/tcp/ip.c | sk->retransmits++; |
sk | 908 | net/tcp/ip.c | sk->prot->retransmits ++; |
sk | 913 | net/tcp/ip.c | if (sk->retransmits > sk->cong_window) break; |
sk | 922 | net/tcp/ip.c | sk->rtt *= 2; |
sk | 923 | net/tcp/ip.c | sk->time_wait.len = sk->rtt; |
sk | 924 | net/tcp/ip.c | sk->timeout = TIME_WRITE; |
sk | 925 | net/tcp/ip.c | reset_timer ((struct timer *)&sk->time_wait); |
sk | 942 | net/tcp/ip.c | ip_handoff (volatile struct sock *sk) |
sk | 946 | net/tcp/ip.c | p = get_protocol (sk->protocol); |
sk | 956 | net/tcp/ip.c | while (p->handler != sk->prot->rcv) |
sk | 968 | net/tcp/ip.c | sk->inuse = 1; |
sk | 972 | net/tcp/ip.c | if (sk->rqueue == NULL) return (0); |
sk | 973 | net/tcp/ip.c | skb = sk->rqueue; |
sk | 976 | net/tcp/ip.c | sk->rqueue = NULL; |
sk | 980 | net/tcp/ip.c | sk->rqueue = skb->next; |
sk | 990 | net/tcp/ip.c | release_sock (sk); |
sk | 165 | net/tcp/ip.h | void ip_queue_xmit (volatile struct sock *sk, struct device *dev, |
sk | 167 | net/tcp/ip.h | void ip_retransmit(volatile struct sock *sk, int all); |
sk | 171 | net/tcp/ip.h | int ip_handoff (volatile struct sock *sk); |
sk | 72 | net/tcp/packet.c | volatile struct sock *sk; |
sk | 74 | net/tcp/packet.c | sk = pt->data; |
sk | 80 | net/tcp/packet.c | if (sk->inuse) |
sk | 86 | net/tcp/packet.c | skb->sk = NULL; |
sk | 91 | net/tcp/packet.c | sk->inuse = 1; |
sk | 94 | net/tcp/packet.c | skb->sk = sk; |
sk | 97 | net/tcp/packet.c | if (sk->rmem_alloc + skb->mem_len >= SK_RMEM_MAX) |
sk | 99 | net/tcp/packet.c | skb->sk = NULL; |
sk | 104 | net/tcp/packet.c | sk->rmem_alloc += skb->mem_len; |
sk | 107 | net/tcp/packet.c | if (sk->rqueue == NULL) |
sk | 109 | net/tcp/packet.c | sk->rqueue = skb; |
sk | 115 | net/tcp/packet.c | skb->next = sk->rqueue; |
sk | 116 | net/tcp/packet.c | skb->prev = sk->rqueue->prev; |
sk | 120 | net/tcp/packet.c | wake_up (sk->sleep); |
sk | 121 | net/tcp/packet.c | release_sock (sk); |
sk | 127 | net/tcp/packet.c | packet_sendto (volatile struct sock *sk, unsigned char *from, int len, |
sk | 150 | net/tcp/packet.c | skb = sk->prot->wmalloc (sk, len+sizeof (*skb) + sk->prot->max_header, 0, |
sk | 156 | net/tcp/packet.c | print_sk (sk); |
sk | 161 | net/tcp/packet.c | skb->mem_len = len + sizeof (*skb) +sk->prot->max_header; |
sk | 162 | net/tcp/packet.c | skb->sk = sk; |
sk | 168 | net/tcp/packet.c | sk->prot->wfree (sk, skb->mem_addr, skb->mem_len); |
sk | 176 | net/tcp/packet.c | dev->queue_xmit (skb, dev, sk->priority); |
sk | 183 | net/tcp/packet.c | packet_write (volatile struct sock *sk, unsigned char *buff, |
sk | 186 | net/tcp/packet.c | return (packet_sendto (sk, buff, len, noblock, flags, NULL, 0)); |
sk | 190 | net/tcp/packet.c | packet_close (volatile struct sock *sk, int timeout) |
sk | 192 | net/tcp/packet.c | sk->inuse = 1; |
sk | 193 | net/tcp/packet.c | sk->state = TCP_CLOSE; |
sk | 194 | net/tcp/packet.c | dev_remove_pack ((struct packet_type *)sk->pair); |
sk | 195 | net/tcp/packet.c | kfree_s ((void *)sk->pair, sizeof (struct packet_type)); |
sk | 196 | net/tcp/packet.c | release_sock (sk); |
sk | 200 | net/tcp/packet.c | packet_init (volatile struct sock *sk) |
sk | 207 | net/tcp/packet.c | p->type = sk->num; |
sk | 208 | net/tcp/packet.c | p->data = (void *)sk; |
sk | 212 | net/tcp/packet.c | sk->pair = (volatile struct sock *)p; |
sk | 219 | net/tcp/packet.c | packet_recvfrom (volatile struct sock *sk, unsigned char *to, int len, |
sk | 233 | net/tcp/packet.c | if (sk->shutdown & RCV_SHUTDOWN) return (0); |
sk | 241 | net/tcp/packet.c | sk->inuse = 1; |
sk | 242 | net/tcp/packet.c | while (sk->rqueue == NULL) |
sk | 246 | net/tcp/packet.c | release_sock (sk); |
sk | 249 | net/tcp/packet.c | release_sock (sk); |
sk | 251 | net/tcp/packet.c | if (sk->rqueue == NULL) |
sk | 253 | net/tcp/packet.c | interruptible_sleep_on (sk->sleep); |
sk | 261 | net/tcp/packet.c | skb = sk->rqueue; |
sk | 267 | net/tcp/packet.c | sk->rqueue = NULL; |
sk | 271 | net/tcp/packet.c | sk->rqueue = sk->rqueue ->next; |
sk | 294 | net/tcp/packet.c | release_sock (sk); |
sk | 300 | net/tcp/packet.c | packet_read (volatile struct sock *sk, unsigned char *buff, |
sk | 303 | net/tcp/packet.c | return (packet_recvfrom (sk, buff, len, noblock, flags, NULL, NULL)); |
sk | 307 | net/tcp/packet.c | int udp_connect (volatile struct sock *sk, struct sockaddr_in *usin, |
sk | 310 | net/tcp/packet.c | int udp_select (volatile struct sock *sk, int sel_type, select_table *wait); |
sk | 96 | net/tcp/raw.c | volatile struct sock *sk; |
sk | 102 | net/tcp/raw.c | sk = protocol->data; |
sk | 104 | net/tcp/raw.c | if (sk == NULL) return; |
sk | 109 | net/tcp/raw.c | if (sk->cong_window > 1) |
sk | 110 | net/tcp/raw.c | sk->cong_window = sk->cong_window/2; |
sk | 114 | net/tcp/raw.c | sk->err = icmp_err_convert[err & 0xff].errno; |
sk | 133 | net/tcp/raw.c | volatile struct sock *sk; |
sk | 145 | net/tcp/raw.c | sk = protocol->data; |
sk | 146 | net/tcp/raw.c | if (sk == NULL) |
sk | 153 | net/tcp/raw.c | skb->sk = sk; |
sk | 163 | net/tcp/raw.c | if (sk->inuse) |
sk | 166 | net/tcp/raw.c | if (sk->back_log == NULL) |
sk | 168 | net/tcp/raw.c | sk->back_log = skb; |
sk | 174 | net/tcp/raw.c | skb->next = sk->back_log; |
sk | 175 | net/tcp/raw.c | skb->prev = sk->back_log->prev; |
sk | 182 | net/tcp/raw.c | sk->inuse = 1; |
sk | 187 | net/tcp/raw.c | if (sk->rmem_alloc + skb->mem_len >= SK_RMEM_MAX) |
sk | 189 | net/tcp/raw.c | skb->sk = NULL; |
sk | 194 | net/tcp/raw.c | sk->rmem_alloc += skb->mem_len; |
sk | 197 | net/tcp/raw.c | if (sk->rqueue == NULL) |
sk | 199 | net/tcp/raw.c | sk->rqueue = skb; |
sk | 205 | net/tcp/raw.c | skb->next = sk->rqueue; |
sk | 206 | net/tcp/raw.c | skb->prev = sk->rqueue->prev; |
sk | 210 | net/tcp/raw.c | wake_up (sk->sleep); |
sk | 211 | net/tcp/raw.c | release_sock (sk); |
sk | 217 | net/tcp/raw.c | raw_sendto (volatile struct sock *sk, unsigned char *from, int len, |
sk | 227 | net/tcp/raw.c | " usin=%X, addr_len = %d)\n", sk, from, len, noblock, |
sk | 247 | net/tcp/raw.c | if (sk->state != TCP_ESTABLISHED) |
sk | 250 | net/tcp/raw.c | sin.sin_port = sk->protocol; |
sk | 251 | net/tcp/raw.c | sin.sin_addr.s_addr = sk->daddr; |
sk | 253 | net/tcp/raw.c | if (sin.sin_port == 0) sin.sin_port = sk->protocol; |
sk | 255 | net/tcp/raw.c | sk->inuse = 1; |
sk | 259 | net/tcp/raw.c | skb = sk->prot->wmalloc (sk, len+sizeof (*skb) + sk->prot->max_header, |
sk | 267 | net/tcp/raw.c | print_sk (sk); |
sk | 269 | net/tcp/raw.c | tmp = sk->wmem_alloc; |
sk | 270 | net/tcp/raw.c | release_sock (sk); |
sk | 272 | net/tcp/raw.c | if (tmp <= sk->wmem_alloc) |
sk | 274 | net/tcp/raw.c | interruptible_sleep_on (sk->sleep); |
sk | 281 | net/tcp/raw.c | sk->inuse = 1; |
sk | 287 | net/tcp/raw.c | skb->mem_len = len + sizeof (*skb) +sk->prot->max_header; |
sk | 288 | net/tcp/raw.c | skb->sk = sk; |
sk | 293 | net/tcp/raw.c | tmp = sk->prot->build_header (skb, sk->saddr, |
sk | 295 | net/tcp/raw.c | sk->protocol, sk->opt, skb->mem_len); |
sk | 299 | net/tcp/raw.c | sk->prot->wfree (sk, skb->mem_addr, skb->mem_len); |
sk | 300 | net/tcp/raw.c | release_sock (sk); |
sk | 307 | net/tcp/raw.c | sk->prot->queue_xmit (sk, dev, skb, 1); |
sk | 308 | net/tcp/raw.c | release_sock (sk); |
sk | 313 | net/tcp/raw.c | raw_write (volatile struct sock *sk, unsigned char *buff, int len, int noblock, |
sk | 316 | net/tcp/raw.c | return (raw_sendto (sk, buff, len, noblock, flags, NULL, 0)); |
sk | 320 | net/tcp/raw.c | raw_close (volatile struct sock *sk, int timeout) |
sk | 322 | net/tcp/raw.c | sk->inuse = 1; |
sk | 323 | net/tcp/raw.c | sk->state = TCP_CLOSE; |
sk | 325 | net/tcp/raw.c | ((struct ip_protocol *)sk->pair)->protocol)); |
sk | 326 | net/tcp/raw.c | if (delete_ip_protocol ((struct ip_protocol *)sk->pair) < 0) |
sk | 328 | net/tcp/raw.c | kfree_s ((void *)sk->pair, sizeof (struct ip_protocol)); |
sk | 329 | net/tcp/raw.c | sk->pair = NULL; |
sk | 330 | net/tcp/raw.c | release_sock (sk); |
sk | 334 | net/tcp/raw.c | raw_init (volatile struct sock *sk) |
sk | 341 | net/tcp/raw.c | p->protocol = sk->protocol; |
sk | 342 | net/tcp/raw.c | p->data = (void *)sk; |
sk | 347 | net/tcp/raw.c | sk->pair = (volatile struct sock *)p; |
sk | 349 | net/tcp/raw.c | PRINTK (("raw init added protocol %d\n", sk->protocol)); |
sk | 356 | net/tcp/raw.c | raw_recvfrom (volatile struct sock *sk, unsigned char *to, int len, |
sk | 366 | net/tcp/raw.c | " sin=%X, addr_len=%X)\n", sk, to, len, noblock, |
sk | 372 | net/tcp/raw.c | if (sk->shutdown & RCV_SHUTDOWN) return (0); |
sk | 378 | net/tcp/raw.c | sk->inuse = 1; |
sk | 379 | net/tcp/raw.c | while (sk->rqueue == NULL) |
sk | 383 | net/tcp/raw.c | release_sock (sk); |
sk | 387 | net/tcp/raw.c | release_sock (sk); |
sk | 389 | net/tcp/raw.c | if (sk->rqueue == NULL) |
sk | 391 | net/tcp/raw.c | interruptible_sleep_on (sk->sleep); |
sk | 398 | net/tcp/raw.c | sk->inuse = 1; |
sk | 401 | net/tcp/raw.c | skb = sk->rqueue; |
sk | 407 | net/tcp/raw.c | sk->rqueue = NULL; |
sk | 411 | net/tcp/raw.c | sk->rqueue = sk->rqueue ->next; |
sk | 433 | net/tcp/raw.c | release_sock (sk); |
sk | 439 | net/tcp/raw.c | raw_read (volatile struct sock *sk, unsigned char *buff, int len, int noblock, |
sk | 442 | net/tcp/raw.c | return (raw_recvfrom (sk, buff, len, noblock, flags, NULL, NULL)); |
sk | 446 | net/tcp/raw.c | int udp_connect (volatile struct sock *sk, struct sockaddr_in *usin, |
sk | 449 | net/tcp/raw.c | int udp_select (volatile struct sock *sk, int sel_type, select_table *wait); |
sk | 183 | net/tcp/sock.c | print_sk (volatile struct sock *sk) |
sk | 185 | net/tcp/sock.c | if (!sk) { |
sk | 189 | net/tcp/sock.c | PRINTK ((" wmem_alloc = %d\n", sk->wmem_alloc)); |
sk | 190 | net/tcp/sock.c | PRINTK ((" rmem_alloc = %d\n", sk->rmem_alloc)); |
sk | 191 | net/tcp/sock.c | PRINTK ((" send_head = %X\n", sk->send_head)); |
sk | 192 | net/tcp/sock.c | PRINTK ((" state = %d\n",sk->state)); |
sk | 193 | net/tcp/sock.c | PRINTK ((" wback = %X, rqueue = %X\n", sk->wback, sk->rqueue)); |
sk | 194 | net/tcp/sock.c | PRINTK ((" wfront = %X\n", sk->wfront)); |
sk | 195 | net/tcp/sock.c | PRINTK ((" daddr = %X, saddr = %X\n", sk->daddr,sk->saddr)); |
sk | 196 | net/tcp/sock.c | PRINTK ((" num = %d", sk->num)); |
sk | 197 | net/tcp/sock.c | PRINTK ((" next = %X\n", sk->next)); |
sk | 199 | net/tcp/sock.c | sk->send_seq, sk->acked_seq, sk->copied_seq)); |
sk | 201 | net/tcp/sock.c | sk->rcv_ack_seq, sk->window_seq, sk->fin_seq)); |
sk | 202 | net/tcp/sock.c | PRINTK ((" prot = %X\n", sk->prot)); |
sk | 203 | net/tcp/sock.c | PRINTK ((" pair = %X, back_log = %X\n", sk->pair,sk->back_log)); |
sk | 204 | net/tcp/sock.c | PRINTK ((" inuse = %d , blog = %d\n", sk->inuse, sk->blog)); |
sk | 205 | net/tcp/sock.c | PRINTK ((" dead = %d delay_acks=%d\n", sk->dead, sk->delay_acks)); |
sk | 206 | net/tcp/sock.c | PRINTK ((" retransmits = %d, timeout = %d\n", sk->retransmits, sk->timeout)); |
sk | 207 | net/tcp/sock.c | PRINTK ((" cong_window = %d, packets_out = %d\n", sk->cong_window, |
sk | 208 | net/tcp/sock.c | sk->packets_out)); |
sk | 219 | net/tcp/sock.c | PRINTK ((" sk = %X link3 = %X\n", skb->sk, skb->link3)); |
sk | 257 | net/tcp/sock.c | if (skb->sk) |
sk | 261 | net/tcp/sock.c | skb->sk->prot->rfree (skb->sk, skb->mem_addr, skb->mem_len); |
sk | 265 | net/tcp/sock.c | skb->sk->prot->wfree (skb->sk, skb->mem_addr, skb->mem_len); |
sk | 289 | net/tcp/sock.c | volatile struct sock *sk; |
sk | 290 | net/tcp/sock.c | for (sk = prot->sock_array[num & (SOCK_ARRAY_SIZE -1 )]; |
sk | 291 | net/tcp/sock.c | sk != NULL; sk=sk->next) |
sk | 293 | net/tcp/sock.c | if (sk->dummy_th.source == num) return (1); |
sk | 308 | net/tcp/sock.c | volatile struct sock *sk; |
sk | 321 | net/tcp/sock.c | sk = prot->sock_array[(i+base+1) & (SOCK_ARRAY_SIZE -1)]; |
sk | 322 | net/tcp/sock.c | while (sk != NULL) |
sk | 324 | net/tcp/sock.c | sk = sk->next; |
sk | 351 | net/tcp/sock.c | put_sock(unsigned short num, volatile struct sock *sk) |
sk | 357 | net/tcp/sock.c | PRINTK (("put_sock (num = %d, sk = %X\n", num, sk)); |
sk | 358 | net/tcp/sock.c | sk->num = num; |
sk | 359 | net/tcp/sock.c | sk->next = NULL; |
sk | 364 | net/tcp/sock.c | if (sk->prot->sock_array[num] == NULL) |
sk | 366 | net/tcp/sock.c | sk->prot->sock_array[num] = sk; |
sk | 373 | net/tcp/sock.c | if (mask & sk->saddr) |
sk | 383 | net/tcp/sock.c | sk1 = sk->prot->sock_array[num]; |
sk | 390 | net/tcp/sock.c | sk->next = sk->prot->sock_array[num]; |
sk | 391 | net/tcp/sock.c | sk->prot->sock_array[num] = sk; |
sk | 395 | net/tcp/sock.c | sk->next = sk2; |
sk | 396 | net/tcp/sock.c | sk1->next= sk; |
sk | 403 | net/tcp/sock.c | sk->next = NULL; |
sk | 404 | net/tcp/sock.c | sk1->next = sk; |
sk | 453 | net/tcp/sock.c | destroy_sock(volatile struct sock *sk) |
sk | 457 | net/tcp/sock.c | PRINTK (("destroying socket %X\n",sk)); |
sk | 459 | net/tcp/sock.c | sk->inuse = 1; |
sk | 462 | net/tcp/sock.c | if (!sk->dead) wake_up (sk->sleep); |
sk | 464 | net/tcp/sock.c | remove_sock (sk); |
sk | 467 | net/tcp/sock.c | delete_timer((struct timer *)&sk->time_wait); |
sk | 469 | net/tcp/sock.c | if (sk->send_tmp != NULL) kfree_skb (sk->send_tmp, FREE_WRITE); |
sk | 472 | net/tcp/sock.c | for (skb = sk->wfront; skb != NULL; ) |
sk | 486 | net/tcp/sock.c | sk->wfront = NULL; |
sk | 487 | net/tcp/sock.c | sk->wback = NULL; |
sk | 489 | net/tcp/sock.c | if (sk->rqueue != NULL) |
sk | 491 | net/tcp/sock.c | skb = sk->rqueue; |
sk | 499 | net/tcp/sock.c | if (skb->sk != NULL && skb->sk != sk) |
sk | 501 | net/tcp/sock.c | skb->sk->dead = 1; |
sk | 502 | net/tcp/sock.c | skb->sk->prot->close (skb->sk, 0); |
sk | 506 | net/tcp/sock.c | } while (skb != sk->rqueue); |
sk | 509 | net/tcp/sock.c | sk->rqueue = NULL; |
sk | 512 | net/tcp/sock.c | for (skb = sk->send_head; skb != NULL; ) |
sk | 605 | net/tcp/sock.c | sk->send_head = NULL; |
sk | 609 | net/tcp/sock.c | if (sk->back_log != NULL) |
sk | 614 | net/tcp/sock.c | skb = sk->back_log; |
sk | 620 | net/tcp/sock.c | } while (skb != sk->back_log); |
sk | 624 | net/tcp/sock.c | sk->back_log = NULL; |
sk | 627 | net/tcp/sock.c | if (sk->pair) |
sk | 629 | net/tcp/sock.c | sk->pair->dead = 1; |
sk | 630 | net/tcp/sock.c | sk->pair->prot->close (sk->pair, 0); |
sk | 631 | net/tcp/sock.c | sk->pair = NULL; |
sk | 636 | net/tcp/sock.c | if (sk->rmem_alloc == 0 && sk->wmem_alloc == 0) |
sk | 638 | net/tcp/sock.c | kfree_s ((void *)sk,sizeof (*sk)); |
sk | 644 | net/tcp/sock.c | PRINTK (("possible memory leak in socket = %X\n", sk)); |
sk | 645 | net/tcp/sock.c | print_sk (sk); |
sk | 646 | net/tcp/sock.c | sk->destroy = 1; |
sk | 647 | net/tcp/sock.c | sk->ack_backlog = 0; |
sk | 648 | net/tcp/sock.c | sk->inuse = 0; |
sk | 649 | net/tcp/sock.c | sk->time_wait.len = SOCK_DESTROY_TIME; |
sk | 650 | net/tcp/sock.c | sk->timeout = TIME_DESTROY; |
sk | 651 | net/tcp/sock.c | reset_timer ((struct timer *)&sk->time_wait); |
sk | 662 | net/tcp/sock.c | volatile struct sock *sk; |
sk | 663 | net/tcp/sock.c | sk=sock->data; |
sk | 664 | net/tcp/sock.c | if (sk == NULL) |
sk | 673 | net/tcp/sock.c | sk->proc = arg; |
sk | 677 | net/tcp/sock.c | return (sk->proc); |
sk | 688 | net/tcp/sock.c | volatile struct sock *sk; |
sk | 692 | net/tcp/sock.c | sk = sock->data; |
sk | 693 | net/tcp/sock.c | if (sk == NULL) |
sk | 718 | net/tcp/sock.c | sk->reuse = 1; |
sk | 720 | net/tcp/sock.c | sk->reuse = 0; |
sk | 725 | net/tcp/sock.c | sk->keepopen = 1; |
sk | 727 | net/tcp/sock.c | sk->keepopen = 0; |
sk | 732 | net/tcp/sock.c | sk->urginline = 1; |
sk | 734 | net/tcp/sock.c | sk->urginline = 0; |
sk | 739 | net/tcp/sock.c | sk->no_check = 1; |
sk | 741 | net/tcp/sock.c | sk->no_check = 0; |
sk | 747 | net/tcp/sock.c | sk->priority = val; |
sk | 762 | net/tcp/sock.c | volatile struct sock *sk; |
sk | 766 | net/tcp/sock.c | sk = sock->data; |
sk | 767 | net/tcp/sock.c | if (sk == NULL) |
sk | 787 | net/tcp/sock.c | val = sk->reuse; |
sk | 791 | net/tcp/sock.c | val = sk->keepopen; |
sk | 795 | net/tcp/sock.c | if (sk->prot == &tcp_prot) |
sk | 802 | net/tcp/sock.c | val = sk->err; |
sk | 803 | net/tcp/sock.c | sk->err = 0; |
sk | 807 | net/tcp/sock.c | val = sk->urginline; |
sk | 811 | net/tcp/sock.c | val = sk->no_check; |
sk | 815 | net/tcp/sock.c | val = sk->priority; |
sk | 829 | net/tcp/sock.c | volatile struct sock *sk; |
sk | 830 | net/tcp/sock.c | sk = sock->data; |
sk | 831 | net/tcp/sock.c | if (sk == NULL) |
sk | 838 | net/tcp/sock.c | if (sk->num == 0) |
sk | 840 | net/tcp/sock.c | sk->num = get_new_socknum (sk->prot, 0); |
sk | 841 | net/tcp/sock.c | if (sk->num == 0) return (-EAGAIN); |
sk | 842 | net/tcp/sock.c | put_sock (sk->num, sk); |
sk | 843 | net/tcp/sock.c | sk->dummy_th.source = net16(sk->num); |
sk | 847 | net/tcp/sock.c | sk->max_ack_backlog = backlog; |
sk | 848 | net/tcp/sock.c | sk->ack_backlog = 0; |
sk | 849 | net/tcp/sock.c | sk->state = TCP_LISTEN; |
sk | 905 | net/tcp/sock.c | volatile struct sock *sk; |
sk | 909 | net/tcp/sock.c | sk = kmalloc (sizeof (*sk), GFP_KERNEL); |
sk | 910 | net/tcp/sock.c | if (sk == NULL) |
sk | 912 | net/tcp/sock.c | sk->num = 0; |
sk | 921 | net/tcp/sock.c | kfree_s ((void *)sk, sizeof (*sk)); |
sk | 924 | net/tcp/sock.c | sk->no_check = TCP_NO_CHECK; |
sk | 931 | net/tcp/sock.c | kfree_s ((void *)sk, sizeof (*sk)); |
sk | 934 | net/tcp/sock.c | sk->no_check = UDP_NO_CHECK; |
sk | 941 | net/tcp/sock.c | kfree_s ((void *)sk, sizeof (*sk)); |
sk | 947 | net/tcp/sock.c | kfree_s ((void *)sk, sizeof (*sk)); |
sk | 951 | net/tcp/sock.c | sk->reuse = 1; |
sk | 952 | net/tcp/sock.c | sk->no_check = 0; /* doesn't matter no checksum is preformed |
sk | 954 | net/tcp/sock.c | sk->num = protocol; |
sk | 960 | net/tcp/sock.c | kfree_s ((void *)sk, sizeof (*sk)); |
sk | 966 | net/tcp/sock.c | kfree_s ((void *)sk, sizeof (*sk)); |
sk | 970 | net/tcp/sock.c | sk->reuse = 1; |
sk | 971 | net/tcp/sock.c | sk->no_check = 0; /* doesn't matter no checksum is preformed |
sk | 973 | net/tcp/sock.c | sk->num = protocol; |
sk | 978 | net/tcp/sock.c | kfree_s ((void *)sk, sizeof (*sk)); |
sk | 982 | net/tcp/sock.c | sk->protocol = protocol; |
sk | 983 | net/tcp/sock.c | sk->wmem_alloc = 0; |
sk | 984 | net/tcp/sock.c | sk->rmem_alloc = 0; |
sk | 985 | net/tcp/sock.c | sk->pair = NULL; |
sk | 986 | net/tcp/sock.c | sk->opt = NULL; |
sk | 987 | net/tcp/sock.c | sk->send_seq = 0; |
sk | 988 | net/tcp/sock.c | sk->acked_seq = 0; |
sk | 989 | net/tcp/sock.c | sk->copied_seq = 0; |
sk | 990 | net/tcp/sock.c | sk->fin_seq = 0; |
sk | 991 | net/tcp/sock.c | sk->proc = 0; |
sk | 992 | net/tcp/sock.c | sk->rtt = TCP_WRITE_TIME; |
sk | 993 | net/tcp/sock.c | sk->packets_out = 0; |
sk | 994 | net/tcp/sock.c | sk->cong_window = 1; /* start with only sending one packet at a time. */ |
sk | 995 | net/tcp/sock.c | sk->exp_growth = 1; /* if set cong_window grow exponentially every time |
sk | 997 | net/tcp/sock.c | sk->urginline = 0; |
sk | 998 | net/tcp/sock.c | sk->intr = 0; |
sk | 999 | net/tcp/sock.c | sk->linger = 0; |
sk | 1000 | net/tcp/sock.c | sk->destroy = 0; |
sk | 1001 | net/tcp/sock.c | sk->reuse = 0; |
sk | 1002 | net/tcp/sock.c | sk->priority = 1; |
sk | 1003 | net/tcp/sock.c | sk->shutdown = 0; |
sk | 1004 | net/tcp/sock.c | sk->urg = 0; |
sk | 1005 | net/tcp/sock.c | sk->keepopen = 0; |
sk | 1006 | net/tcp/sock.c | sk->done = 0; |
sk | 1007 | net/tcp/sock.c | sk->ack_backlog = 0; |
sk | 1008 | net/tcp/sock.c | sk->window = 0; |
sk | 1009 | net/tcp/sock.c | sk->bytes_rcv = 0; |
sk | 1010 | net/tcp/sock.c | sk->state = TCP_CLOSE; |
sk | 1011 | net/tcp/sock.c | sk->dead = 0; |
sk | 1012 | net/tcp/sock.c | sk->ack_timed = 0; |
sk | 1013 | net/tcp/sock.c | sk->send_tmp = NULL; |
sk | 1014 | net/tcp/sock.c | sk->mss = 0; /* we will try not to send any packets smaller |
sk | 1020 | net/tcp/sock.c | sk->max_unacked = 2048; /* needs to be at most 2 full packets. */ |
sk | 1025 | net/tcp/sock.c | sk->max_ack_backlog = 0; |
sk | 1026 | net/tcp/sock.c | sk->inuse = 0; |
sk | 1027 | net/tcp/sock.c | sk->delay_acks = 0; |
sk | 1028 | net/tcp/sock.c | sk->wback = NULL; |
sk | 1029 | net/tcp/sock.c | sk->wfront = NULL; |
sk | 1030 | net/tcp/sock.c | sk->rqueue = NULL; |
sk | 1031 | net/tcp/sock.c | sk->mtu = 576; |
sk | 1032 | net/tcp/sock.c | sk->prot = prot; |
sk | 1033 | net/tcp/sock.c | sk->sleep = sock->wait; |
sk | 1034 | net/tcp/sock.c | sk->daddr = 0; |
sk | 1035 | net/tcp/sock.c | sk->saddr = MY_IP_ADDR; |
sk | 1036 | net/tcp/sock.c | sk->err = 0; |
sk | 1037 | net/tcp/sock.c | sk->next = NULL; |
sk | 1038 | net/tcp/sock.c | sk->pair = NULL; |
sk | 1039 | net/tcp/sock.c | sk->send_tail = NULL; |
sk | 1040 | net/tcp/sock.c | sk->send_head = NULL; |
sk | 1041 | net/tcp/sock.c | sk->time_wait.len = TCP_CONNECT_TIME; |
sk | 1042 | net/tcp/sock.c | sk->time_wait.when = 0; |
sk | 1043 | net/tcp/sock.c | sk->time_wait.sk = sk; |
sk | 1044 | net/tcp/sock.c | sk->time_wait.next = NULL; |
sk | 1045 | net/tcp/sock.c | sk->timeout = 0; |
sk | 1046 | net/tcp/sock.c | sk->back_log = NULL; |
sk | 1047 | net/tcp/sock.c | sk->blog = 0; |
sk | 1048 | net/tcp/sock.c | sock->data =(void *) sk; |
sk | 1049 | net/tcp/sock.c | sk->dummy_th.doff = sizeof (sk->dummy_th)/4; |
sk | 1050 | net/tcp/sock.c | sk->dummy_th.res1=0; |
sk | 1051 | net/tcp/sock.c | sk->dummy_th.res2=0; |
sk | 1052 | net/tcp/sock.c | sk->dummy_th.urg_ptr = 0; |
sk | 1053 | net/tcp/sock.c | sk->dummy_th.fin = 0; |
sk | 1054 | net/tcp/sock.c | sk->dummy_th.syn = 0; |
sk | 1055 | net/tcp/sock.c | sk->dummy_th.rst = 0; |
sk | 1056 | net/tcp/sock.c | sk->dummy_th.psh = 0; |
sk | 1057 | net/tcp/sock.c | sk->dummy_th.ack = 0; |
sk | 1058 | net/tcp/sock.c | sk->dummy_th.urg = 0; |
sk | 1059 | net/tcp/sock.c | sk->dummy_th.dest = 0; |
sk | 1061 | net/tcp/sock.c | if (sk->num) |
sk | 1067 | net/tcp/sock.c | put_sock (sk->num, sk); |
sk | 1068 | net/tcp/sock.c | sk->dummy_th.source = net16(sk->num); |
sk | 1071 | net/tcp/sock.c | if (sk->prot->init) |
sk | 1073 | net/tcp/sock.c | err = sk->prot->init(sk); |
sk | 1076 | net/tcp/sock.c | destroy_sock (sk); |
sk | 1094 | net/tcp/sock.c | volatile struct sock *sk; |
sk | 1095 | net/tcp/sock.c | sk = sock->data; |
sk | 1096 | net/tcp/sock.c | if (sk == NULL) return (0); |
sk | 1098 | net/tcp/sock.c | wake_up (sk->sleep); |
sk | 1103 | net/tcp/sock.c | if (sk->linger == 0) |
sk | 1105 | net/tcp/sock.c | sk->prot->close(sk,0); |
sk | 1106 | net/tcp/sock.c | sk->dead = 1; |
sk | 1111 | net/tcp/sock.c | sk->prot->close(sk, 0); |
sk | 1113 | net/tcp/sock.c | while (sk->state != TCP_CLOSE) |
sk | 1115 | net/tcp/sock.c | interruptible_sleep_on (sk->sleep); |
sk | 1123 | net/tcp/sock.c | sk->dead = 1; |
sk | 1126 | net/tcp/sock.c | sk->inuse = 1; |
sk | 1128 | net/tcp/sock.c | release_sock (sk); |
sk | 1144 | net/tcp/sock.c | volatile struct sock *sk, *sk2; |
sk | 1147 | net/tcp/sock.c | sk = sock->data; |
sk | 1148 | net/tcp/sock.c | if (sk == NULL) |
sk | 1154 | net/tcp/sock.c | if (sk->state != TCP_CLOSE) return (-EIO); |
sk | 1155 | net/tcp/sock.c | if (sk->num != 0) return (-EINVAL); |
sk | 1163 | net/tcp/sock.c | PRINTK (("bind sk =%X to port = %d\n", sk, snum)); |
sk | 1164 | net/tcp/sock.c | print_sk (sk); |
sk | 1165 | net/tcp/sock.c | sk = sock->data; |
sk | 1173 | net/tcp/sock.c | if ( sk->num > PROT_SOCK) return (0); |
sk | 1174 | net/tcp/sock.c | snum = get_new_socknum (sk->prot, 0); |
sk | 1181 | net/tcp/sock.c | sk->saddr = addr.sin_addr.s_addr; |
sk | 1184 | net/tcp/sock.c | sk->prot->sock_array[snum & (SOCK_ARRAY_SIZE -1)])); |
sk | 1185 | net/tcp/sock.c | print_sk (sk->prot->sock_array[snum & (SOCK_ARRAY_SIZE -1)]); |
sk | 1188 | net/tcp/sock.c | for (sk2 = sk->prot->sock_array[snum & (SOCK_ARRAY_SIZE -1)]; |
sk | 1193 | net/tcp/sock.c | if (sk2->saddr != sk->saddr) continue; |
sk | 1194 | net/tcp/sock.c | if (!sk->reuse) return (-EADDRINUSE); |
sk | 1197 | net/tcp/sock.c | remove_sock (sk); |
sk | 1198 | net/tcp/sock.c | put_sock(snum, sk); |
sk | 1199 | net/tcp/sock.c | sk->dummy_th.source = net16(sk->num); |
sk | 1200 | net/tcp/sock.c | sk->daddr = 0; |
sk | 1201 | net/tcp/sock.c | sk->dummy_th.dest = 0; |
sk | 1209 | net/tcp/sock.c | volatile struct sock *sk; |
sk | 1212 | net/tcp/sock.c | sk = sock->data; |
sk | 1213 | net/tcp/sock.c | if (sk == NULL) |
sk | 1219 | net/tcp/sock.c | if (sk->state == TCP_ESTABLISHED) |
sk | 1227 | net/tcp/sock.c | if (sk->state == TCP_SYN_SENT || sk->state == TCP_SYN_RECV) |
sk | 1230 | net/tcp/sock.c | if (sk->err) return (-sk->err); |
sk | 1237 | net/tcp/sock.c | if (sk->num == 0) |
sk | 1239 | net/tcp/sock.c | sk->num = get_new_socknum (sk->prot, 0); |
sk | 1240 | net/tcp/sock.c | if (sk->num == 0) return (-EAGAIN); |
sk | 1241 | net/tcp/sock.c | put_sock (sk->num, sk); |
sk | 1242 | net/tcp/sock.c | sk->dummy_th.source = net16(sk->num); |
sk | 1245 | net/tcp/sock.c | if (sk->prot->connect == NULL) |
sk | 1248 | net/tcp/sock.c | if (sk->intr == 0) |
sk | 1250 | net/tcp/sock.c | err = sk->prot->connect (sk, (struct sockaddr_in *)uaddr, addr_len); |
sk | 1255 | net/tcp/sock.c | if (sk->state != TCP_ESTABLISHED && (flags & O_NONBLOCK)) |
sk | 1260 | net/tcp/sock.c | while (sk->state == TCP_SYN_SENT || sk->state == TCP_SYN_RECV) |
sk | 1262 | net/tcp/sock.c | interruptible_sleep_on (sk->sleep); |
sk | 1266 | net/tcp/sock.c | sk->intr = 1; |
sk | 1273 | net/tcp/sock.c | sk->intr = 0; |
sk | 1274 | net/tcp/sock.c | if (sk->state != TCP_ESTABLISHED && sk->err) |
sk | 1277 | net/tcp/sock.c | return (-sk->err); |
sk | 1364 | net/tcp/sock.c | volatile struct sock *sk; |
sk | 1370 | net/tcp/sock.c | sk = sock->data; |
sk | 1371 | net/tcp/sock.c | if (sk == NULL) |
sk | 1378 | net/tcp/sock.c | if (!tcp_connected(sk->state)) |
sk | 1380 | net/tcp/sock.c | sin.sin_port = sk->dummy_th.dest; |
sk | 1381 | net/tcp/sock.c | sin.sin_addr.s_addr = sk->daddr; |
sk | 1385 | net/tcp/sock.c | sin.sin_port = sk->dummy_th.source; |
sk | 1386 | net/tcp/sock.c | sin.sin_addr.s_addr = sk->saddr; |
sk | 1399 | net/tcp/sock.c | volatile struct sock *sk; |
sk | 1400 | net/tcp/sock.c | sk = sock->data; |
sk | 1401 | net/tcp/sock.c | if (sk == NULL) |
sk | 1408 | net/tcp/sock.c | if (sk->num == 0) |
sk | 1410 | net/tcp/sock.c | sk->num = get_new_socknum (sk->prot, 0); |
sk | 1411 | net/tcp/sock.c | if (sk->num == 0) return (-EAGAIN); |
sk | 1412 | net/tcp/sock.c | put_sock (sk->num, sk); |
sk | 1413 | net/tcp/sock.c | sk->dummy_th.source = net16(sk->num); |
sk | 1416 | net/tcp/sock.c | return (sk->prot->read (sk, ubuf, size, noblock,0)); |
sk | 1423 | net/tcp/sock.c | volatile struct sock *sk; |
sk | 1424 | net/tcp/sock.c | sk = sock->data; |
sk | 1425 | net/tcp/sock.c | if (sk == NULL) |
sk | 1432 | net/tcp/sock.c | if (sk->num == 0) |
sk | 1434 | net/tcp/sock.c | sk->num = get_new_socknum (sk->prot, 0); |
sk | 1435 | net/tcp/sock.c | if (sk->num == 0) return (-EAGAIN); |
sk | 1436 | net/tcp/sock.c | put_sock (sk->num, sk); |
sk | 1437 | net/tcp/sock.c | sk->dummy_th.source = net16(sk->num); |
sk | 1440 | net/tcp/sock.c | return (sk->prot->read (sk, ubuf, size, noblock, flags)); |
sk | 1446 | net/tcp/sock.c | volatile struct sock *sk; |
sk | 1447 | net/tcp/sock.c | sk = sock->data; |
sk | 1448 | net/tcp/sock.c | if (sk == NULL) |
sk | 1453 | net/tcp/sock.c | if (sk->shutdown & SEND_SHUTDOWN) |
sk | 1460 | net/tcp/sock.c | if (sk->num == 0) |
sk | 1462 | net/tcp/sock.c | sk->num = get_new_socknum (sk->prot, 0); |
sk | 1463 | net/tcp/sock.c | if (sk->num == 0) return (-EAGAIN); |
sk | 1464 | net/tcp/sock.c | put_sock (sk->num, sk); |
sk | 1465 | net/tcp/sock.c | sk->dummy_th.source = net16(sk->num); |
sk | 1468 | net/tcp/sock.c | return (sk->prot->write (sk, ubuf, size, noblock, 0)); |
sk | 1476 | net/tcp/sock.c | volatile struct sock *sk; |
sk | 1477 | net/tcp/sock.c | sk = sock->data; |
sk | 1478 | net/tcp/sock.c | if (sk == NULL) |
sk | 1483 | net/tcp/sock.c | if (sk->shutdown & SEND_SHUTDOWN) |
sk | 1490 | net/tcp/sock.c | if (sk->num == 0) |
sk | 1492 | net/tcp/sock.c | sk->num = get_new_socknum (sk->prot, 0); |
sk | 1493 | net/tcp/sock.c | if (sk->num == 0) return (-EAGAIN); |
sk | 1494 | net/tcp/sock.c | put_sock (sk->num, sk); |
sk | 1495 | net/tcp/sock.c | sk->dummy_th.source = net16(sk->num); |
sk | 1498 | net/tcp/sock.c | return (sk->prot->write (sk, ubuf, size, noblock, flags)); |
sk | 1506 | net/tcp/sock.c | volatile struct sock *sk; |
sk | 1507 | net/tcp/sock.c | sk = sock->data; |
sk | 1508 | net/tcp/sock.c | if (sk == NULL) |
sk | 1513 | net/tcp/sock.c | if (sk->shutdown & SEND_SHUTDOWN) |
sk | 1519 | net/tcp/sock.c | if (sk->prot->sendto == NULL) return (-EOPNOTSUPP); |
sk | 1522 | net/tcp/sock.c | if (sk->num == 0) |
sk | 1524 | net/tcp/sock.c | sk->num = get_new_socknum (sk->prot, 0); |
sk | 1525 | net/tcp/sock.c | if (sk->num == 0) return (-EAGAIN); |
sk | 1526 | net/tcp/sock.c | put_sock (sk->num, sk); |
sk | 1527 | net/tcp/sock.c | sk->dummy_th.source = net16(sk->num); |
sk | 1530 | net/tcp/sock.c | return (sk->prot->sendto (sk, ubuf, size, noblock, flags, |
sk | 1538 | net/tcp/sock.c | volatile struct sock *sk; |
sk | 1539 | net/tcp/sock.c | sk = sock->data; |
sk | 1540 | net/tcp/sock.c | if (sk == NULL) |
sk | 1546 | net/tcp/sock.c | if (sk->prot->recvfrom == NULL) return (-EOPNOTSUPP); |
sk | 1549 | net/tcp/sock.c | if (sk->num == 0) |
sk | 1551 | net/tcp/sock.c | sk->num = get_new_socknum (sk->prot, 0); |
sk | 1552 | net/tcp/sock.c | if (sk->num == 0) return (-EAGAIN); |
sk | 1553 | net/tcp/sock.c | put_sock (sk->num, sk); |
sk | 1554 | net/tcp/sock.c | sk->dummy_th.source = net16(sk->num); |
sk | 1557 | net/tcp/sock.c | return (sk->prot->recvfrom (sk, ubuf, size, noblock, flags, |
sk | 1564 | net/tcp/sock.c | volatile struct sock *sk; |
sk | 1571 | net/tcp/sock.c | sk = sock->data; |
sk | 1572 | net/tcp/sock.c | if (sk == NULL) |
sk | 1577 | net/tcp/sock.c | if (sock->state == SS_CONNECTING && sk->state == TCP_ESTABLISHED) |
sk | 1580 | net/tcp/sock.c | if (!tcp_connected(sk->state)) return (-ENOTCONN); |
sk | 1581 | net/tcp/sock.c | sk->shutdown |= how; |
sk | 1582 | net/tcp/sock.c | if (sk->prot->shutdown) |
sk | 1583 | net/tcp/sock.c | sk->prot->shutdown (sk, how); |
sk | 1590 | net/tcp/sock.c | volatile struct sock *sk; |
sk | 1591 | net/tcp/sock.c | sk = sock->data; |
sk | 1592 | net/tcp/sock.c | if (sk == NULL) |
sk | 1598 | net/tcp/sock.c | if (sk->prot->select == NULL) |
sk | 1603 | net/tcp/sock.c | return (sk->prot->select(sk, sel_type, wait)); |
sk | 1611 | net/tcp/sock.c | volatile struct sock *sk; |
sk | 1612 | net/tcp/sock.c | sk = sock->data; |
sk | 1613 | net/tcp/sock.c | if (sk == NULL) |
sk | 1633 | net/tcp/sock.c | sk->proc = user; |
sk | 1641 | net/tcp/sock.c | put_fs_long (sk->proc, (void *)arg); |
sk | 1646 | net/tcp/sock.c | if (!sk->prot->ioctl) |
sk | 1648 | net/tcp/sock.c | return (sk->prot->ioctl (sk, cmd, arg)); |
sk | 1653 | net/tcp/sock.c | sock_wmalloc(volatile struct sock *sk, unsigned long size, int force, |
sk | 1656 | net/tcp/sock.c | if (sk) |
sk | 1658 | net/tcp/sock.c | if (sk->wmem_alloc + size < SK_WMEM_MAX || force) |
sk | 1661 | net/tcp/sock.c | sk->wmem_alloc+= size; |
sk | 1666 | net/tcp/sock.c | sk, size, force, priority)); |
sk | 1673 | net/tcp/sock.c | sock_rmalloc(volatile struct sock *sk, unsigned long size, int force, |
sk | 1676 | net/tcp/sock.c | if (sk ) |
sk | 1678 | net/tcp/sock.c | if (sk->rmem_alloc + size < SK_RMEM_MAX || force) |
sk | 1681 | net/tcp/sock.c | sk->rmem_alloc+= size; |
sk | 1686 | net/tcp/sock.c | sk,size,force, priority)); |
sk | 1694 | net/tcp/sock.c | sock_rspace (volatile struct sock *sk) |
sk | 1697 | net/tcp/sock.c | if (sk != NULL) |
sk | 1699 | net/tcp/sock.c | if (sk->rmem_alloc >= SK_RMEM_MAX-2*MIN_WINDOW) return (0); |
sk | 1700 | net/tcp/sock.c | amt = min ((SK_RMEM_MAX-sk->rmem_alloc)/2-MIN_WINDOW, MAX_WINDOW); |
sk | 1708 | net/tcp/sock.c | sock_wspace (volatile struct sock *sk) |
sk | 1710 | net/tcp/sock.c | if (sk != NULL) |
sk | 1712 | net/tcp/sock.c | if (sk->shutdown & SEND_SHUTDOWN) return (0); |
sk | 1713 | net/tcp/sock.c | if (sk->wmem_alloc >= SK_WMEM_MAX) return (0); |
sk | 1714 | net/tcp/sock.c | return (SK_WMEM_MAX-sk->wmem_alloc ); |
sk | 1721 | net/tcp/sock.c | sock_wfree (volatile struct sock *sk, void *mem, unsigned long size) |
sk | 1723 | net/tcp/sock.c | MPRINTK (("sock_wfree (sk=%X, mem=%X, size=%d)\n",sk, mem, size)); |
sk | 1725 | net/tcp/sock.c | if (sk) |
sk | 1727 | net/tcp/sock.c | sk->wmem_alloc -= size; |
sk | 1729 | net/tcp/sock.c | if (!sk->dead) wake_up(sk->sleep); |
sk | 1730 | net/tcp/sock.c | if (sk->destroy && sk->wmem_alloc == 0 && sk->rmem_alloc == 0) |
sk | 1732 | net/tcp/sock.c | MPRINTK (("recovered lost memory, destroying sock = %X\n",sk)); |
sk | 1733 | net/tcp/sock.c | delete_timer ((struct timer *)&sk->time_wait); |
sk | 1734 | net/tcp/sock.c | kfree_s ((void *)sk, sizeof (*sk)); |
sk | 1741 | net/tcp/sock.c | sock_rfree (volatile struct sock *sk, void *mem, unsigned long size) |
sk | 1743 | net/tcp/sock.c | MPRINTK (("sock_rfree (sk=%X, mem=%X, size=%d)\n",sk, mem, size)); |
sk | 1745 | net/tcp/sock.c | if (sk) |
sk | 1747 | net/tcp/sock.c | sk->rmem_alloc -= size; |
sk | 1748 | net/tcp/sock.c | if (sk->destroy && sk->wmem_alloc == 0 && sk->rmem_alloc == 0) |
sk | 1750 | net/tcp/sock.c | delete_timer ((struct timer *)&sk->time_wait); |
sk | 1751 | net/tcp/sock.c | kfree_s ((void *)sk, sizeof (*sk)); |
sk | 1792 | net/tcp/sock.c | void release_sock (volatile struct sock *sk) |
sk | 1794 | net/tcp/sock.c | if (!sk) |
sk | 1800 | net/tcp/sock.c | if (!sk->prot) |
sk | 1806 | net/tcp/sock.c | if (sk->blog) return; |
sk | 1810 | net/tcp/sock.c | sk->inuse = 1; |
sk | 1811 | net/tcp/sock.c | while (sk->back_log != NULL) |
sk | 1814 | net/tcp/sock.c | sk->blog = 1; |
sk | 1815 | net/tcp/sock.c | skb = sk->back_log; |
sk | 1820 | net/tcp/sock.c | sk->back_log = skb->next; |
sk | 1826 | net/tcp/sock.c | sk->back_log = NULL; |
sk | 1829 | net/tcp/sock.c | PRINTK (("sk->back_log = %X\n",sk->back_log)); |
sk | 1830 | net/tcp/sock.c | if (sk->prot->rcv) |
sk | 1831 | net/tcp/sock.c | sk->prot->rcv(skb, skb->dev, sk->opt, |
sk | 1834 | net/tcp/sock.c | (struct ip_protocol *)sk->pair); |
sk | 1837 | net/tcp/sock.c | sk->blog = 0; |
sk | 1838 | net/tcp/sock.c | sk->inuse = 0; |
sk | 1840 | net/tcp/sock.c | if (sk->dead && sk->state == TCP_CLOSE) |
sk | 1843 | net/tcp/sock.c | sk->time_wait.len = min (sk->rtt * 2, TCP_DONE_TIME); |
sk | 1844 | net/tcp/sock.c | sk->timeout = TIME_DONE; |
sk | 1845 | net/tcp/sock.c | reset_timer ((struct timer *)&sk->time_wait); |
sk | 102 | net/tcp/sock.h | void *(*wmalloc)(volatile struct sock *sk, unsigned long size, int force, |
sk | 104 | net/tcp/sock.h | void *(*rmalloc)(volatile struct sock *sk, unsigned long size, int force, |
sk | 106 | net/tcp/sock.h | void (*wfree)(volatile struct sock *sk, void *mem, unsigned long size); |
sk | 107 | net/tcp/sock.h | void (*rfree)(volatile struct sock *sk, void *mem, unsigned long size); |
sk | 108 | net/tcp/sock.h | unsigned long (*rspace)(volatile struct sock *sk); |
sk | 109 | net/tcp/sock.h | unsigned long (*wspace)(volatile struct sock *sk); |
sk | 110 | net/tcp/sock.h | void (*close)(volatile struct sock *sk, int timeout); |
sk | 111 | net/tcp/sock.h | int (*read)(volatile struct sock *sk, unsigned char *to, int len, |
sk | 113 | net/tcp/sock.h | int (*write)(volatile struct sock *sk, unsigned char *to, int len, |
sk | 115 | net/tcp/sock.h | int (*sendto) (volatile struct sock *sk, unsigned char *from, int len, |
sk | 118 | net/tcp/sock.h | int (*recvfrom) (volatile struct sock *sk, unsigned char *from, int len, |
sk | 124 | net/tcp/sock.h | int (*connect) (volatile struct sock *sk, struct sockaddr_in *usin, |
sk | 126 | net/tcp/sock.h | volatile struct sock *(*accept) (volatile struct sock *sk, int flags); |
sk | 127 | net/tcp/sock.h | void (*queue_xmit) (volatile struct sock *sk, struct device *dev, |
sk | 129 | net/tcp/sock.h | void (*retransmit) (volatile struct sock *sk, int all); |
sk | 130 | net/tcp/sock.h | void (*write_wakeup) (volatile struct sock *sk); |
sk | 131 | net/tcp/sock.h | void (*read_wakeup) (volatile struct sock *sk); |
sk | 135 | net/tcp/sock.h | int (*select)(volatile struct sock *sk, int which, select_table *wait); |
sk | 136 | net/tcp/sock.h | int (*ioctl) (volatile struct sock *sk, int cmd, unsigned long arg); |
sk | 137 | net/tcp/sock.h | int (*init) (volatile struct sock *sk); |
sk | 138 | net/tcp/sock.h | void (*shutdown) (volatile struct sock *sk, int how); |
sk | 160 | net/tcp/sock.h | volatile struct sock *sk; |
sk | 189 | net/tcp/sock.h | void destroy_sock (volatile struct sock *sk); |
sk | 192 | net/tcp/sock.h | void release_sock (volatile struct sock *sk); |
sk | 197 | net/tcp/sock.h | void *sock_wmalloc(volatile struct sock *sk, unsigned long size, int force, |
sk | 199 | net/tcp/sock.h | void *sock_rmalloc(volatile struct sock *sk, unsigned long size, int force, |
sk | 201 | net/tcp/sock.h | void sock_wfree(volatile struct sock *sk, void *mem, unsigned long size); |
sk | 202 | net/tcp/sock.h | void sock_rfree(volatile struct sock *sk, void *mem, unsigned long size); |
sk | 203 | net/tcp/sock.h | unsigned long sock_rspace(volatile struct sock *sk); |
sk | 204 | net/tcp/sock.h | unsigned long sock_wspace(volatile struct sock *sk); |
sk | 132 | net/tcp/tcp.c | get_firstr(volatile struct sock *sk) |
sk | 135 | net/tcp/tcp.c | skb = sk->rqueue; |
sk | 137 | net/tcp/tcp.c | sk->rqueue = skb->next; |
sk | 138 | net/tcp/tcp.c | if (sk->rqueue == skb) |
sk | 140 | net/tcp/tcp.c | sk->rqueue = NULL; |
sk | 144 | net/tcp/tcp.c | sk->rqueue->prev=skb->prev; |
sk | 145 | net/tcp/tcp.c | sk->rqueue->prev->next = sk->rqueue; |
sk | 162 | net/tcp/tcp.c | tcp_time_wait (volatile struct sock *sk) |
sk | 164 | net/tcp/tcp.c | sk->state = TCP_TIME_WAIT; |
sk | 165 | net/tcp/tcp.c | sk->shutdown = SHUTDOWN_MASK; |
sk | 166 | net/tcp/tcp.c | if (!sk->dead) wake_up (sk->sleep); |
sk | 167 | net/tcp/tcp.c | sk->time_wait.len = TCP_TIMEWAIT_LEN; |
sk | 168 | net/tcp/tcp.c | sk->timeout = TIME_CLOSE; |
sk | 169 | net/tcp/tcp.c | reset_timer ((struct timer *)&sk->time_wait); |
sk | 173 | net/tcp/tcp.c | tcp_retransmit (volatile struct sock *sk, int all) |
sk | 177 | net/tcp/tcp.c | ip_retransmit (sk, all); |
sk | 180 | net/tcp/tcp.c | sk->rtt *= 2; /* exponential back off. */ |
sk | 181 | net/tcp/tcp.c | if (sk->cong_window > 1) |
sk | 182 | net/tcp/tcp.c | sk->cong_window = sk->cong_window / 2; |
sk | 183 | net/tcp/tcp.c | sk->exp_growth = 0; |
sk | 186 | net/tcp/tcp.c | ip_retransmit (sk, all); |
sk | 202 | net/tcp/tcp.c | volatile struct sock *sk; |
sk | 208 | net/tcp/tcp.c | sk = get_sock (&tcp_prot, net16(th->dest), saddr, th->source, daddr); |
sk | 211 | net/tcp/tcp.c | if (sk == NULL) return; |
sk | 218 | net/tcp/tcp.c | if (sk->cong_window > 1) |
sk | 219 | net/tcp/tcp.c | sk->cong_window --; |
sk | 225 | net/tcp/tcp.c | sk->err = icmp_err_convert[err & 0xff].errno; |
sk | 228 | net/tcp/tcp.c | if (sk->state != TCP_ESTABLISHED) |
sk | 230 | net/tcp/tcp.c | sk->state = TCP_CLOSE; |
sk | 232 | net/tcp/tcp.c | sk->prot->close(sk, 0); |
sk | 240 | net/tcp/tcp.c | tcp_readable (volatile struct sock *sk) |
sk | 248 | net/tcp/tcp.c | if (sk == NULL || sk->rqueue == NULL) return (0); |
sk | 250 | net/tcp/tcp.c | counted = sk->copied_seq; |
sk | 252 | net/tcp/tcp.c | skb = sk->rqueue->next; |
sk | 274 | net/tcp/tcp.c | } while (skb != sk->rqueue->next); |
sk | 280 | net/tcp/tcp.c | tcp_select (volatile struct sock *sk, int sel_type, select_table *wait) |
sk | 282 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 286 | net/tcp/tcp.c | select_wait (sk->sleep, wait); |
sk | 287 | net/tcp/tcp.c | if (sk->rqueue != NULL) |
sk | 289 | net/tcp/tcp.c | if (sk->state == TCP_LISTEN || tcp_readable(sk)) |
sk | 291 | net/tcp/tcp.c | release_sock (sk); |
sk | 296 | net/tcp/tcp.c | if (sk->shutdown & RCV_SHUTDOWN) |
sk | 298 | net/tcp/tcp.c | release_sock (sk); |
sk | 303 | net/tcp/tcp.c | release_sock (sk); |
sk | 308 | net/tcp/tcp.c | select_wait (sk->sleep, wait); |
sk | 310 | net/tcp/tcp.c | if (sk->shutdown & SEND_SHUTDOWN) |
sk | 312 | net/tcp/tcp.c | release_sock (sk); |
sk | 317 | net/tcp/tcp.c | if (sk->prot->wspace(sk) >= MIN_WRITE_SPACE) |
sk | 319 | net/tcp/tcp.c | release_sock (sk); |
sk | 322 | net/tcp/tcp.c | release_sock (sk); |
sk | 327 | net/tcp/tcp.c | select_wait(sk->sleep,wait); |
sk | 328 | net/tcp/tcp.c | if (sk->err) |
sk | 330 | net/tcp/tcp.c | release_sock (sk); |
sk | 333 | net/tcp/tcp.c | release_sock (sk); |
sk | 337 | net/tcp/tcp.c | release_sock (sk); |
sk | 342 | net/tcp/tcp.c | tcp_ioctl (volatile struct sock *sk, int cmd, unsigned long arg) |
sk | 344 | net/tcp/tcp.c | PRINTK (("tcp_ioctl (sk=%X, cmd = %d, arg=%X)\n", sk, cmd, arg)); |
sk | 355 | net/tcp/tcp.c | if (sk->state == TCP_LISTEN) |
sk | 359 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 360 | net/tcp/tcp.c | if (sk->rqueue != NULL) |
sk | 362 | net/tcp/tcp.c | amount = tcp_readable(sk); |
sk | 364 | net/tcp/tcp.c | release_sock (sk); |
sk | 376 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 377 | net/tcp/tcp.c | if (sk->rqueue != NULL) |
sk | 379 | net/tcp/tcp.c | skb = sk->rqueue->next; |
sk | 380 | net/tcp/tcp.c | if (sk->copied_seq+1 == skb->h.th->seq && skb->h.th->urg) |
sk | 383 | net/tcp/tcp.c | release_sock (sk); |
sk | 392 | net/tcp/tcp.c | if (sk->state == TCP_LISTEN) |
sk | 394 | net/tcp/tcp.c | amount = sk->prot->wspace(sk)/2; |
sk | 475 | net/tcp/tcp.c | unsigned long daddr, int len, volatile struct sock *sk) |
sk | 479 | net/tcp/tcp.c | if (sk && sk->no_check) return; |
sk | 485 | net/tcp/tcp.c | tcp_send_partial(volatile struct sock *sk) |
sk | 489 | net/tcp/tcp.c | if (sk == NULL || sk->send_tmp == NULL) return; |
sk | 491 | net/tcp/tcp.c | skb = sk->send_tmp; |
sk | 493 | net/tcp/tcp.c | tcp_send_check (skb->h.th, sk->saddr, sk->daddr, |
sk | 495 | net/tcp/tcp.c | (unsigned long)(skb+1), sk); |
sk | 497 | net/tcp/tcp.c | skb->h.seq = sk->send_seq; |
sk | 498 | net/tcp/tcp.c | if (after (sk->send_seq , sk->window_seq) || |
sk | 499 | net/tcp/tcp.c | sk->packets_out >= sk->cong_window) |
sk | 502 | net/tcp/tcp.c | sk->cong_window, sk->packets_out)); |
sk | 504 | net/tcp/tcp.c | sk->send_seq, sk->window_seq)); |
sk | 507 | net/tcp/tcp.c | if (sk->wback == NULL) |
sk | 509 | net/tcp/tcp.c | sk->wfront=skb; |
sk | 513 | net/tcp/tcp.c | sk->wback->next = skb; |
sk | 515 | net/tcp/tcp.c | sk->wback = skb; |
sk | 519 | net/tcp/tcp.c | sk->prot->queue_xmit (sk, skb->dev, skb,0); |
sk | 521 | net/tcp/tcp.c | sk->send_tmp = NULL; |
sk | 529 | net/tcp/tcp.c | volatile struct sock *sk, |
sk | 540 | net/tcp/tcp.c | buff=sk->prot->wmalloc(sk,MAX_ACK_SIZE,1, GFP_ATOMIC); |
sk | 544 | net/tcp/tcp.c | sk->ack_backlog++; |
sk | 545 | net/tcp/tcp.c | if (sk->timeout != TIME_WRITE && tcp_connected (sk->state)) |
sk | 547 | net/tcp/tcp.c | sk->timeout = TIME_WRITE; |
sk | 548 | net/tcp/tcp.c | sk->time_wait.len = 10; /* got to do it quickly. */ |
sk | 549 | net/tcp/tcp.c | reset_timer ((struct timer *)&sk->time_wait); |
sk | 558 | net/tcp/tcp.c | buff->sk = sk; |
sk | 561 | net/tcp/tcp.c | tmp = sk->prot->build_header (buff, sk->saddr, daddr, &dev, |
sk | 562 | net/tcp/tcp.c | IPPROTO_TCP, sk->opt, MAX_ACK_SIZE); |
sk | 565 | net/tcp/tcp.c | sk->prot->wfree(sk, buff->mem_addr, buff->mem_len); |
sk | 578 | net/tcp/tcp.c | sk->window = sk->prot->rspace(sk); |
sk | 579 | net/tcp/tcp.c | t1->window = net16(sk->window); |
sk | 587 | net/tcp/tcp.c | if (ack == sk->acked_seq) |
sk | 589 | net/tcp/tcp.c | sk->ack_backlog = 0; |
sk | 590 | net/tcp/tcp.c | sk->bytes_rcv = 0; |
sk | 591 | net/tcp/tcp.c | sk->ack_timed = 0; |
sk | 592 | net/tcp/tcp.c | if (sk->send_head == NULL && |
sk | 593 | net/tcp/tcp.c | sk->wfront == NULL) |
sk | 595 | net/tcp/tcp.c | delete_timer((struct timer *)&sk->time_wait); |
sk | 596 | net/tcp/tcp.c | sk->timeout = 0; |
sk | 602 | net/tcp/tcp.c | tcp_send_check (t1, sk->saddr, daddr, sizeof (*t1), sk); |
sk | 603 | net/tcp/tcp.c | sk->prot->queue_xmit(sk, dev, buff, 1); |
sk | 608 | net/tcp/tcp.c | tcp_build_header(struct tcp_header *th, volatile struct sock *sk, int push) |
sk | 612 | net/tcp/tcp.c | memcpy (th,(void *) &(sk->dummy_th), sizeof (*th)); |
sk | 613 | net/tcp/tcp.c | th->seq = net32(sk->send_seq); |
sk | 618 | net/tcp/tcp.c | sk->ack_backlog = 0; |
sk | 619 | net/tcp/tcp.c | sk->bytes_rcv = 0; |
sk | 620 | net/tcp/tcp.c | sk->ack_timed = 0; |
sk | 621 | net/tcp/tcp.c | th->ack_seq = net32(sk->acked_seq); |
sk | 622 | net/tcp/tcp.c | sk->window = sk->prot->rspace(sk); |
sk | 623 | net/tcp/tcp.c | th->window = net16(sk->window); |
sk | 632 | net/tcp/tcp.c | tcp_write (volatile struct sock *sk, unsigned char *from, |
sk | 644 | net/tcp/tcp.c | sk, from, len, nonblock, flags)); |
sk | 646 | net/tcp/tcp.c | print_sk (sk); |
sk | 648 | net/tcp/tcp.c | prot = sk->prot; |
sk | 653 | net/tcp/tcp.c | sk->inuse = 1; /* no one else will use this socket. */ |
sk | 654 | net/tcp/tcp.c | while (sk->state != TCP_ESTABLISHED && sk->state != TCP_CLOSE_WAIT) |
sk | 656 | net/tcp/tcp.c | if (sk->state != TCP_SYN_SENT && |
sk | 657 | net/tcp/tcp.c | sk->state != TCP_SYN_RECV) |
sk | 659 | net/tcp/tcp.c | release_sock (sk); |
sk | 663 | net/tcp/tcp.c | if (sk->err) |
sk | 665 | net/tcp/tcp.c | tmp = -sk->err; |
sk | 666 | net/tcp/tcp.c | sk->err = 0; |
sk | 670 | net/tcp/tcp.c | if (sk->keepopen) |
sk | 679 | net/tcp/tcp.c | release_sock (sk); |
sk | 691 | net/tcp/tcp.c | release_sock (sk); |
sk | 693 | net/tcp/tcp.c | if (sk->state != TCP_ESTABLISHED && sk->state != TCP_CLOSE_WAIT && |
sk | 694 | net/tcp/tcp.c | sk->err == 0) |
sk | 696 | net/tcp/tcp.c | interruptible_sleep_on (sk->sleep); |
sk | 706 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 710 | net/tcp/tcp.c | if (sk->send_tmp != NULL) |
sk | 714 | net/tcp/tcp.c | skb = sk->send_tmp; |
sk | 717 | net/tcp/tcp.c | copy = min (sk->mss - skb->len + 128 + prot->max_header, len); |
sk | 728 | net/tcp/tcp.c | sk->send_seq += copy; |
sk | 732 | net/tcp/tcp.c | (unsigned long)(skb+1) >= sk->mss |
sk | 735 | net/tcp/tcp.c | tcp_send_partial (sk); |
sk | 744 | net/tcp/tcp.c | copy = min (sk->mtu, diff(sk->window_seq, sk->send_seq)); |
sk | 747 | net/tcp/tcp.c | if (copy < 200 || copy > sk->mtu) copy = sk->mtu; |
sk | 751 | net/tcp/tcp.c | if (sk->packets_out && copy < sk->mss && !(flags & MSG_OOB)) |
sk | 754 | net/tcp/tcp.c | release_sock (sk); |
sk | 755 | net/tcp/tcp.c | skb=prot->wmalloc (sk, |
sk | 756 | net/tcp/tcp.c | sk->mss + 128 + prot->max_header + sizeof (*skb), |
sk | 758 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 759 | net/tcp/tcp.c | sk->send_tmp = skb; |
sk | 761 | net/tcp/tcp.c | skb->mem_len = sk->mss + 128 + prot->max_header+sizeof (*skb); |
sk | 766 | net/tcp/tcp.c | release_sock (sk); |
sk | 767 | net/tcp/tcp.c | skb=prot->wmalloc (sk, copy + prot->max_header+sizeof (*skb),0, |
sk | 769 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 779 | net/tcp/tcp.c | release_sock (sk); |
sk | 786 | net/tcp/tcp.c | tmp = sk->wmem_alloc; |
sk | 787 | net/tcp/tcp.c | release_sock (sk); |
sk | 791 | net/tcp/tcp.c | if (tmp <= sk->wmem_alloc |
sk | 792 | net/tcp/tcp.c | && (sk->state == TCP_ESTABLISHED || sk->state == TCP_CLOSE_WAIT ) |
sk | 793 | net/tcp/tcp.c | && sk->err == 0) |
sk | 795 | net/tcp/tcp.c | interruptible_sleep_on (sk->sleep); |
sk | 804 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 811 | net/tcp/tcp.c | skb->sk = sk; |
sk | 819 | net/tcp/tcp.c | tmp = prot->build_header (skb, sk->saddr, sk->daddr, &dev, |
sk | 820 | net/tcp/tcp.c | IPPROTO_TCP, sk->opt, skb->mem_len); |
sk | 823 | net/tcp/tcp.c | prot->wfree (sk, skb->mem_addr, skb->mem_len); |
sk | 824 | net/tcp/tcp.c | release_sock (sk); |
sk | 833 | net/tcp/tcp.c | tmp = tcp_build_header((struct tcp_header *)buff, sk, len-copy); |
sk | 837 | net/tcp/tcp.c | prot->wfree (sk, skb->mem_addr, skb->mem_len); |
sk | 838 | net/tcp/tcp.c | release_sock (sk); |
sk | 857 | net/tcp/tcp.c | sk->send_seq += copy; |
sk | 859 | net/tcp/tcp.c | if (sk->send_tmp != NULL) |
sk | 864 | net/tcp/tcp.c | tcp_send_check ((struct tcp_header *)buff, sk->saddr, sk->daddr, |
sk | 865 | net/tcp/tcp.c | copy +sizeof (struct tcp_header), sk); |
sk | 868 | net/tcp/tcp.c | skb->h.seq = sk->send_seq; |
sk | 869 | net/tcp/tcp.c | if (after (sk->send_seq , sk->window_seq) || |
sk | 870 | net/tcp/tcp.c | sk->packets_out >= sk->cong_window) |
sk | 873 | net/tcp/tcp.c | sk->cong_window, sk->packets_out)); |
sk | 875 | net/tcp/tcp.c | sk->send_seq, sk->window_seq)); |
sk | 878 | net/tcp/tcp.c | if (sk->wback == NULL) |
sk | 880 | net/tcp/tcp.c | sk->wfront=skb; |
sk | 884 | net/tcp/tcp.c | sk->wback->next = skb; |
sk | 886 | net/tcp/tcp.c | sk->wback = skb; |
sk | 890 | net/tcp/tcp.c | prot->queue_xmit (sk, dev, skb,0); |
sk | 893 | net/tcp/tcp.c | sk->err = 0; |
sk | 894 | net/tcp/tcp.c | release_sock (sk); |
sk | 900 | net/tcp/tcp.c | tcp_sendto (volatile struct sock *sk, unsigned char *from, |
sk | 910 | net/tcp/tcp.c | if (sin.sin_port != sk->dummy_th.dest) |
sk | 912 | net/tcp/tcp.c | if (sin.sin_addr.s_addr != sk->daddr) |
sk | 914 | net/tcp/tcp.c | return (tcp_write (sk, from, len, nonblock, flags)); |
sk | 918 | net/tcp/tcp.c | tcp_read_wakeup(volatile struct sock *sk) |
sk | 925 | net/tcp/tcp.c | if (!sk->ack_backlog ) return; |
sk | 934 | net/tcp/tcp.c | buff=sk->prot->wmalloc(sk,MAX_ACK_SIZE,1, GFP_ATOMIC); |
sk | 938 | net/tcp/tcp.c | sk->timeout = TIME_WRITE; |
sk | 939 | net/tcp/tcp.c | sk->time_wait.len = 10; |
sk | 940 | net/tcp/tcp.c | reset_timer((struct timer *) &sk->time_wait); |
sk | 948 | net/tcp/tcp.c | buff->sk = sk; |
sk | 951 | net/tcp/tcp.c | tmp = sk->prot->build_header (buff, sk->saddr, sk->daddr, &dev, |
sk | 952 | net/tcp/tcp.c | IPPROTO_TCP, sk->opt, MAX_ACK_SIZE); |
sk | 955 | net/tcp/tcp.c | sk->prot->wfree(sk, buff->mem_addr, buff->mem_len); |
sk | 962 | net/tcp/tcp.c | memcpy (t1,(void *) &sk->dummy_th, sizeof (*t1)); |
sk | 963 | net/tcp/tcp.c | t1->seq = net32(sk->send_seq); |
sk | 971 | net/tcp/tcp.c | sk->ack_backlog = 0; |
sk | 972 | net/tcp/tcp.c | sk->bytes_rcv = 0; |
sk | 973 | net/tcp/tcp.c | sk->window = sk->prot->rspace(sk); |
sk | 974 | net/tcp/tcp.c | t1->window = net16(sk->window); |
sk | 975 | net/tcp/tcp.c | t1->ack_seq = net32(sk->acked_seq); |
sk | 977 | net/tcp/tcp.c | tcp_send_check (t1, sk->saddr, sk->daddr, sizeof (*t1), sk); |
sk | 978 | net/tcp/tcp.c | sk->prot->queue_xmit(sk, dev, buff, 1); |
sk | 987 | net/tcp/tcp.c | cleanup_rbuf (volatile struct sock *sk) |
sk | 992 | net/tcp/tcp.c | while (sk->rqueue != NULL ) |
sk | 995 | net/tcp/tcp.c | skb=sk->rqueue->next; |
sk | 997 | net/tcp/tcp.c | if (sk->rqueue == skb) |
sk | 999 | net/tcp/tcp.c | sk->rqueue = NULL; |
sk | 1006 | net/tcp/tcp.c | skb->sk = sk; |
sk | 1013 | net/tcp/tcp.c | sk->window - sk->bytes_rcv, sk->prot->rspace(sk))); |
sk | 1015 | net/tcp/tcp.c | if ((sk->prot->rspace(sk) > |
sk | 1016 | net/tcp/tcp.c | (sk->window - sk->bytes_rcv + TCP_WINDOW_DIFF))) |
sk | 1018 | net/tcp/tcp.c | sk->ack_backlog++; |
sk | 1019 | net/tcp/tcp.c | if (sk->ack_backlog > sk->max_ack_backlog) |
sk | 1021 | net/tcp/tcp.c | tcp_read_wakeup (sk); |
sk | 1026 | net/tcp/tcp.c | if ( before (jiffies + TCP_ACK_TIME, sk->time_wait.when)) |
sk | 1028 | net/tcp/tcp.c | sk->time_wait.len = TCP_ACK_TIME; |
sk | 1029 | net/tcp/tcp.c | sk->timeout = TIME_WRITE; |
sk | 1030 | net/tcp/tcp.c | reset_timer ((struct timer *)&sk->time_wait); |
sk | 1039 | net/tcp/tcp.c | tcp_read_urg(volatile struct sock * sk, int nonblock, |
sk | 1045 | net/tcp/tcp.c | sk, to, len, flags)); |
sk | 1046 | net/tcp/tcp.c | print_sk(sk); |
sk | 1049 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 1050 | net/tcp/tcp.c | while (sk->urg==0 || sk->rqueue == NULL) |
sk | 1052 | net/tcp/tcp.c | if (sk->err) |
sk | 1055 | net/tcp/tcp.c | release_sock (sk); |
sk | 1057 | net/tcp/tcp.c | tmp = -sk->err; |
sk | 1058 | net/tcp/tcp.c | sk->err = 0; |
sk | 1062 | net/tcp/tcp.c | if (sk->state == TCP_CLOSE) |
sk | 1064 | net/tcp/tcp.c | release_sock (sk); |
sk | 1066 | net/tcp/tcp.c | if (!sk->done) |
sk | 1068 | net/tcp/tcp.c | sk->done = 1; |
sk | 1074 | net/tcp/tcp.c | if (sk->shutdown & RCV_SHUTDOWN) |
sk | 1076 | net/tcp/tcp.c | release_sock(sk); |
sk | 1078 | net/tcp/tcp.c | sk->done = 1; |
sk | 1084 | net/tcp/tcp.c | release_sock (sk); |
sk | 1090 | net/tcp/tcp.c | release_sock (sk); |
sk | 1092 | net/tcp/tcp.c | if ((sk->urg == 0 || sk->rqueue == NULL) && sk->err == 0 |
sk | 1093 | net/tcp/tcp.c | && !(sk->shutdown & RCV_SHUTDOWN) ) |
sk | 1095 | net/tcp/tcp.c | interruptible_sleep_on (sk->sleep); |
sk | 1104 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 1107 | net/tcp/tcp.c | for (skb = sk->rqueue->next; skb->next != sk->rqueue; |
sk | 1123 | net/tcp/tcp.c | sk->urg --; |
sk | 1125 | net/tcp/tcp.c | release_sock (sk); |
sk | 1135 | net/tcp/tcp.c | tcp_read (volatile struct sock *sk, unsigned char *to, |
sk | 1150 | net/tcp/tcp.c | if (sk->state == TCP_LISTEN) return (-ENOTCONN); |
sk | 1154 | net/tcp/tcp.c | return (tcp_read_urg (sk, nonblock, to, len, flags)); |
sk | 1157 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 1158 | net/tcp/tcp.c | if (sk->rqueue != NULL) |
sk | 1159 | net/tcp/tcp.c | skb=sk->rqueue->next; |
sk | 1164 | net/tcp/tcp.c | sk, to, len, nonblock, flags)); |
sk | 1168 | net/tcp/tcp.c | while ( skb == NULL || before (sk->copied_seq+1, skb->h.th->seq) || |
sk | 1175 | net/tcp/tcp.c | print_sk (sk); |
sk | 1177 | net/tcp/tcp.c | cleanup_rbuf(sk); |
sk | 1179 | net/tcp/tcp.c | if (sk->err) |
sk | 1182 | net/tcp/tcp.c | release_sock (sk); |
sk | 1184 | net/tcp/tcp.c | tmp = -sk->err; |
sk | 1185 | net/tcp/tcp.c | sk->err = 0; |
sk | 1189 | net/tcp/tcp.c | if (sk->state == TCP_CLOSE) |
sk | 1191 | net/tcp/tcp.c | release_sock (sk); |
sk | 1193 | net/tcp/tcp.c | if (!sk->done) |
sk | 1195 | net/tcp/tcp.c | sk->done = 1; |
sk | 1201 | net/tcp/tcp.c | if (sk->shutdown & RCV_SHUTDOWN) |
sk | 1203 | net/tcp/tcp.c | release_sock (sk); |
sk | 1204 | net/tcp/tcp.c | if (copied == 0) sk->done = 1; |
sk | 1211 | net/tcp/tcp.c | release_sock (sk); |
sk | 1218 | net/tcp/tcp.c | release_sock (sk); |
sk | 1222 | net/tcp/tcp.c | PRINTK (("tcp_read about to sleep. state = %d\n",sk->state)); |
sk | 1224 | net/tcp/tcp.c | release_sock (sk); /* now we may have some data waiting. */ |
sk | 1227 | net/tcp/tcp.c | if ( sk->shutdown & RCV_SHUTDOWN || sk->err != 0) |
sk | 1229 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 1234 | net/tcp/tcp.c | if ( sk->rqueue == NULL || |
sk | 1235 | net/tcp/tcp.c | before (sk->copied_seq+1, sk->rqueue->next->h.th->seq) ) |
sk | 1237 | net/tcp/tcp.c | interruptible_sleep_on (sk->sleep); |
sk | 1248 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 1250 | net/tcp/tcp.c | if (sk->rqueue != NULL) |
sk | 1251 | net/tcp/tcp.c | skb=sk->rqueue->next; |
sk | 1260 | net/tcp/tcp.c | offset = sk->copied_seq+1 - skb->h.th->seq; |
sk | 1272 | net/tcp/tcp.c | sk->copied_seq += skb->h.th->urg_ptr; |
sk | 1297 | net/tcp/tcp.c | sk->copied_seq += used; |
sk | 1320 | net/tcp/tcp.c | cleanup_rbuf (sk); |
sk | 1321 | net/tcp/tcp.c | release_sock (sk); |
sk | 1332 | net/tcp/tcp.c | tcp_shutdown (volatile struct sock *sk, int how) |
sk | 1347 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 1350 | net/tcp/tcp.c | if (sk->send_tmp) |
sk | 1351 | net/tcp/tcp.c | tcp_send_partial(sk); |
sk | 1353 | net/tcp/tcp.c | prot = (struct proto *)sk->prot; |
sk | 1354 | net/tcp/tcp.c | th=(struct tcp_header *)&sk->dummy_th; |
sk | 1355 | net/tcp/tcp.c | release_sock (sk); /* incase the malloc sleeps. */ |
sk | 1356 | net/tcp/tcp.c | buff=prot->wmalloc(sk, MAX_RESET_SIZE,1 , GFP_KERNEL); |
sk | 1361 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 1368 | net/tcp/tcp.c | buff->sk = sk; |
sk | 1373 | net/tcp/tcp.c | tmp = prot->build_header (buff,sk->saddr, sk->daddr, &dev, |
sk | 1374 | net/tcp/tcp.c | IPPROTO_TCP, sk->opt, |
sk | 1378 | net/tcp/tcp.c | prot->wfree (sk,buff->mem_addr, buff->mem_len); |
sk | 1379 | net/tcp/tcp.c | release_sock(sk); |
sk | 1390 | net/tcp/tcp.c | t1->seq = net32(sk->send_seq); |
sk | 1392 | net/tcp/tcp.c | sk->send_seq++; |
sk | 1393 | net/tcp/tcp.c | buff->h.seq = sk->send_seq; |
sk | 1396 | net/tcp/tcp.c | t1->ack_seq = net32(sk->acked_seq); |
sk | 1397 | net/tcp/tcp.c | t1->window = net16(sk->prot->rspace(sk)); |
sk | 1402 | net/tcp/tcp.c | tcp_send_check (t1, sk->saddr, sk->daddr, sizeof (*t1), sk); |
sk | 1406 | net/tcp/tcp.c | if (sk->wback != NULL) |
sk | 1409 | net/tcp/tcp.c | sk->wback->next = buff; |
sk | 1410 | net/tcp/tcp.c | sk->wback = buff; |
sk | 1415 | net/tcp/tcp.c | sk->prot->queue_xmit (sk, dev, buff,0); |
sk | 1418 | net/tcp/tcp.c | if (sk->state == TCP_ESTABLISHED) |
sk | 1420 | net/tcp/tcp.c | sk->state = TCP_FIN_WAIT1; |
sk | 1424 | net/tcp/tcp.c | sk->state = TCP_FIN_WAIT2; |
sk | 1426 | net/tcp/tcp.c | release_sock(sk); |
sk | 1431 | net/tcp/tcp.c | tcp_recvfrom (volatile struct sock *sk, unsigned char *to, |
sk | 1435 | net/tcp/tcp.c | int result = tcp_read(sk, to, to_len, nonblock, flags); |
sk | 1444 | net/tcp/tcp.c | sin.sin_port = sk->dummy_th.dest; |
sk | 1445 | net/tcp/tcp.c | sin.sin_addr.s_addr = sk->daddr; |
sk | 1471 | net/tcp/tcp.c | buff->sk = NULL; |
sk | 1510 | net/tcp/tcp.c | tcp_conn_request(volatile struct sock *sk, struct sk_buff *skb, |
sk | 1524 | net/tcp/tcp.c | sk, skb, daddr, saddr, opt, dev)); |
sk | 1527 | net/tcp/tcp.c | if (!sk->dead) |
sk | 1529 | net/tcp/tcp.c | wake_up(sk->sleep); |
sk | 1534 | net/tcp/tcp.c | tcp_reset (daddr, saddr, th, sk->prot, opt, dev); |
sk | 1541 | net/tcp/tcp.c | if (sk->ack_backlog >= sk->max_ack_backlog) |
sk | 1563 | net/tcp/tcp.c | memcpy ((void *)newsk, (void *)sk, sizeof (*newsk)); |
sk | 1594 | net/tcp/tcp.c | newsk->time_wait.sk = newsk; |
sk | 1637 | net/tcp/tcp.c | sk->err = -ENOMEM; |
sk | 1648 | net/tcp/tcp.c | buff->sk = newsk; |
sk | 1653 | net/tcp/tcp.c | tmp = sk->prot->build_header (buff, newsk->saddr, newsk->daddr, &dev, |
sk | 1659 | net/tcp/tcp.c | sk->err = tmp; |
sk | 1660 | net/tcp/tcp.c | sk->prot->wfree(newsk, buff->mem_addr, buff->mem_len); |
sk | 1663 | net/tcp/tcp.c | skb->sk = sk; |
sk | 1699 | net/tcp/tcp.c | PRINTK (("newsk->time_wait.sk = %X\n", newsk->time_wait.sk)); |
sk | 1701 | net/tcp/tcp.c | skb->sk = newsk; |
sk | 1703 | net/tcp/tcp.c | sk->rmem_alloc -= skb->mem_len; |
sk | 1706 | net/tcp/tcp.c | if (sk->rqueue == NULL) |
sk | 1710 | net/tcp/tcp.c | sk->rqueue = skb; |
sk | 1714 | net/tcp/tcp.c | skb->next = sk->rqueue; |
sk | 1715 | net/tcp/tcp.c | skb->prev = sk->rqueue->prev; |
sk | 1716 | net/tcp/tcp.c | sk->rqueue->prev = skb; |
sk | 1719 | net/tcp/tcp.c | sk->ack_backlog++; |
sk | 1724 | net/tcp/tcp.c | tcp_close (volatile struct sock *sk, int timeout) |
sk | 1734 | net/tcp/tcp.c | PRINTK (("tcp_close ((struct sock *)%X, %d)\n",sk, timeout)); |
sk | 1735 | net/tcp/tcp.c | print_sk (sk); |
sk | 1736 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 1737 | net/tcp/tcp.c | sk->keepopen = 1; |
sk | 1738 | net/tcp/tcp.c | sk->shutdown = SHUTDOWN_MASK; |
sk | 1740 | net/tcp/tcp.c | if (!sk->dead) |
sk | 1741 | net/tcp/tcp.c | wake_up (sk->sleep); |
sk | 1746 | net/tcp/tcp.c | if (sk->rqueue != NULL) |
sk | 1750 | net/tcp/tcp.c | skb = sk->rqueue; |
sk | 1755 | net/tcp/tcp.c | after (skb->h.th->seq + skb->len + 1, sk->copied_seq)) |
sk | 1759 | net/tcp/tcp.c | } while (skb != sk->rqueue); |
sk | 1761 | net/tcp/tcp.c | sk->rqueue = NULL; |
sk | 1764 | net/tcp/tcp.c | if (sk->send_tmp) |
sk | 1766 | net/tcp/tcp.c | tcp_send_partial (sk); |
sk | 1769 | net/tcp/tcp.c | switch (sk->state) |
sk | 1776 | net/tcp/tcp.c | sk->time_wait.len = 4*sk->rtt;; |
sk | 1777 | net/tcp/tcp.c | sk->timeout = TIME_CLOSE; |
sk | 1778 | net/tcp/tcp.c | reset_timer ((struct timer *)&sk->time_wait); |
sk | 1780 | net/tcp/tcp.c | tcp_time_wait(sk); |
sk | 1781 | net/tcp/tcp.c | release_sock (sk); |
sk | 1786 | net/tcp/tcp.c | sk->state = TCP_CLOSE; |
sk | 1787 | net/tcp/tcp.c | release_sock (sk); |
sk | 1791 | net/tcp/tcp.c | sk->state = TCP_CLOSE; |
sk | 1792 | net/tcp/tcp.c | release_sock(sk); |
sk | 1797 | net/tcp/tcp.c | release_sock(sk); |
sk | 1806 | net/tcp/tcp.c | prot = (struct proto *)sk->prot; |
sk | 1807 | net/tcp/tcp.c | th=(struct tcp_header *)&sk->dummy_th; |
sk | 1809 | net/tcp/tcp.c | buff=prot->wmalloc(sk, MAX_FIN_SIZE,1, GFP_ATOMIC); |
sk | 1813 | net/tcp/tcp.c | if (sk->state != TCP_CLOSE_WAIT) |
sk | 1814 | net/tcp/tcp.c | sk->state = TCP_ESTABLISHED; |
sk | 1815 | net/tcp/tcp.c | sk->timeout = TIME_CLOSE; |
sk | 1816 | net/tcp/tcp.c | sk->time_wait.len = 100; /* wait a second. */ |
sk | 1817 | net/tcp/tcp.c | reset_timer ((struct timer *)&sk->time_wait); |
sk | 1824 | net/tcp/tcp.c | buff->sk = sk; |
sk | 1828 | net/tcp/tcp.c | tmp = prot->build_header (buff,sk->saddr, sk->daddr, &dev, |
sk | 1829 | net/tcp/tcp.c | IPPROTO_TCP, sk->opt, |
sk | 1833 | net/tcp/tcp.c | prot->wfree (sk,buff->mem_addr, buff->mem_len); |
sk | 1835 | net/tcp/tcp.c | release_sock(sk); |
sk | 1843 | net/tcp/tcp.c | t1->seq = net32(sk->send_seq); |
sk | 1844 | net/tcp/tcp.c | sk->send_seq++; |
sk | 1845 | net/tcp/tcp.c | buff->h.seq = sk->send_seq; |
sk | 1849 | net/tcp/tcp.c | sk->delay_acks = 0; |
sk | 1850 | net/tcp/tcp.c | t1->ack_seq = net32(sk->acked_seq); |
sk | 1851 | net/tcp/tcp.c | t1->window = net16(sk->prot->rspace(sk)); |
sk | 1855 | net/tcp/tcp.c | tcp_send_check (t1, sk->saddr, sk->daddr, sizeof (*t1), sk); |
sk | 1857 | net/tcp/tcp.c | if (sk->wfront == NULL) |
sk | 1859 | net/tcp/tcp.c | prot->queue_xmit(sk, dev, buff, 0); |
sk | 1863 | net/tcp/tcp.c | sk->time_wait.len = sk->rtt; |
sk | 1864 | net/tcp/tcp.c | sk->timeout = TIME_WRITE; |
sk | 1865 | net/tcp/tcp.c | reset_timer ((struct timer *)&sk->time_wait); |
sk | 1867 | net/tcp/tcp.c | if (sk->wback == NULL) |
sk | 1869 | net/tcp/tcp.c | sk->wfront=buff; |
sk | 1873 | net/tcp/tcp.c | sk->wback->next = buff; |
sk | 1875 | net/tcp/tcp.c | sk->wback = buff; |
sk | 1880 | net/tcp/tcp.c | if (sk->state == TCP_CLOSE_WAIT) |
sk | 1882 | net/tcp/tcp.c | sk->state = TCP_FIN_WAIT2; |
sk | 1886 | net/tcp/tcp.c | sk->state = TCP_FIN_WAIT1; |
sk | 1889 | net/tcp/tcp.c | release_sock (sk); |
sk | 1896 | net/tcp/tcp.c | tcp_write_xmit (volatile struct sock *sk) |
sk | 1899 | net/tcp/tcp.c | PRINTK (("tcp_write_xmit (sk=%X)\n",sk)); |
sk | 1900 | net/tcp/tcp.c | while (sk->wfront != NULL && before (sk->wfront->h.seq, sk->window_seq) && |
sk | 1901 | net/tcp/tcp.c | sk->packets_out < sk->cong_window) |
sk | 1903 | net/tcp/tcp.c | skb = sk->wfront; |
sk | 1904 | net/tcp/tcp.c | sk->wfront = skb->next; |
sk | 1905 | net/tcp/tcp.c | if (sk->wfront == NULL) |
sk | 1906 | net/tcp/tcp.c | sk->wback = NULL; |
sk | 1912 | net/tcp/tcp.c | sk->wfront = NULL; |
sk | 1913 | net/tcp/tcp.c | sk->wback = NULL; |
sk | 1918 | net/tcp/tcp.c | sk->prot->queue_xmit (sk, skb->dev, skb, skb->free); |
sk | 1927 | net/tcp/tcp.c | tcp_ack (volatile struct sock *sk, struct tcp_header *th, unsigned long saddr) |
sk | 1934 | net/tcp/tcp.c | ack, net16(th->window), sk->rcv_ack_seq, sk->window_seq)); |
sk | 1935 | net/tcp/tcp.c | if (after (ack, sk->send_seq+1) || before (ack, sk->rcv_ack_seq-1)) |
sk | 1937 | net/tcp/tcp.c | if (after (ack, sk->send_seq) || (sk->state != TCP_ESTABLISHED && |
sk | 1938 | net/tcp/tcp.c | sk->state != TCP_CLOSE_WAIT)) |
sk | 1942 | net/tcp/tcp.c | if (sk->keepopen) |
sk | 1943 | net/tcp/tcp.c | reset_timer ((struct timer *)&sk->time_wait); |
sk | 1944 | net/tcp/tcp.c | sk->retransmits = 0; |
sk | 1949 | net/tcp/tcp.c | if (after (sk->window_seq, ack+net16(th->window))) |
sk | 1961 | net/tcp/tcp.c | sk->window_seq = ack + net16(th->window); |
sk | 1963 | net/tcp/tcp.c | for (skb = sk->send_head; skb != NULL; skb=skb->link3) |
sk | 1965 | net/tcp/tcp.c | if (after( skb->h.seq, sk->window_seq)) |
sk | 1971 | net/tcp/tcp.c | sk->send_head = skb->link3; |
sk | 1977 | net/tcp/tcp.c | if (sk->send_tail == skb) |
sk | 1978 | net/tcp/tcp.c | sk->send_tail = skb2; |
sk | 2013 | net/tcp/tcp.c | skb->next = sk->wfront; |
sk | 2014 | net/tcp/tcp.c | sk->wfront = skb; |
sk | 2031 | net/tcp/tcp.c | sk->window_seq = ack + net16(th->window); |
sk | 2034 | net/tcp/tcp.c | if (sk->cong_window < 2048 && ack != sk->rcv_ack_seq) |
sk | 2036 | net/tcp/tcp.c | if (sk->exp_growth) |
sk | 2037 | net/tcp/tcp.c | sk->cong_window *= 2; |
sk | 2039 | net/tcp/tcp.c | sk->cong_window++; |
sk | 2043 | net/tcp/tcp.c | sk->rcv_ack_seq = ack; |
sk | 2046 | net/tcp/tcp.c | while (sk->send_head != NULL) |
sk | 2048 | net/tcp/tcp.c | if (before (sk->send_head->h.seq, ack+1)) |
sk | 2052 | net/tcp/tcp.c | sk->packets_out --; |
sk | 2053 | net/tcp/tcp.c | PRINTK (("skb=%X acked\n", sk->send_head)); |
sk | 2056 | net/tcp/tcp.c | if (!sk->dead) |
sk | 2057 | net/tcp/tcp.c | wake_up (sk->sleep); |
sk | 2061 | net/tcp/tcp.c | oskb = sk->send_head; |
sk | 2063 | net/tcp/tcp.c | sk->rtt += ((jiffies - oskb->when) - sk->rtt)/2; |
sk | 2064 | net/tcp/tcp.c | if (sk->rtt < 30) sk->rtt = 30; |
sk | 2065 | net/tcp/tcp.c | sk->send_head = oskb->link3; |
sk | 2066 | net/tcp/tcp.c | if (sk->send_head == NULL) |
sk | 2068 | net/tcp/tcp.c | sk->send_tail = NULL; |
sk | 2101 | net/tcp/tcp.c | if (!sk->dead) |
sk | 2102 | net/tcp/tcp.c | wake_up(sk->sleep); |
sk | 2117 | net/tcp/tcp.c | if (sk->retransmits && sk->send_head != NULL) |
sk | 2120 | net/tcp/tcp.c | sk->prot->retransmit (sk,1); |
sk | 2122 | net/tcp/tcp.c | sk->retransmits = 0; |
sk | 2126 | net/tcp/tcp.c | if (sk->wfront != NULL && sk->packets_out < sk->cong_window) |
sk | 2128 | net/tcp/tcp.c | if (after (sk->window_seq, sk->wfront->h.seq)) |
sk | 2130 | net/tcp/tcp.c | tcp_write_xmit (sk); |
sk | 2135 | net/tcp/tcp.c | if (sk->send_head == NULL && sk->ack_backlog == 0 && |
sk | 2136 | net/tcp/tcp.c | sk->state != TCP_TIME_WAIT && !sk->keepopen) |
sk | 2139 | net/tcp/tcp.c | if (!sk->dead) |
sk | 2140 | net/tcp/tcp.c | wake_up (sk->sleep); |
sk | 2143 | net/tcp/tcp.c | sk->time_wait.len = TCP_PROBEWAIT_LEN; |
sk | 2144 | net/tcp/tcp.c | sk->timeout = TIME_KEEPOPEN; |
sk | 2145 | net/tcp/tcp.c | reset_timer((struct timer *)&sk->time_wait); |
sk | 2146 | net/tcp/tcp.c | sk->timeout = 0; |
sk | 2150 | net/tcp/tcp.c | if (sk->state == TCP_TIME_WAIT) |
sk | 2152 | net/tcp/tcp.c | sk->time_wait.len = TCP_TIMEWAIT_LEN; |
sk | 2153 | net/tcp/tcp.c | sk->timeout = TIME_CLOSE; |
sk | 2155 | net/tcp/tcp.c | sk->timeout = TIME_WRITE; |
sk | 2156 | net/tcp/tcp.c | sk->time_wait.len = sk->rtt*2; |
sk | 2157 | net/tcp/tcp.c | reset_timer ((struct timer *)&sk->time_wait); |
sk | 2162 | net/tcp/tcp.c | if (sk->packets_out == 0 && sk->send_tmp != NULL && |
sk | 2163 | net/tcp/tcp.c | sk->wfront == NULL && sk->send_head == NULL) |
sk | 2165 | net/tcp/tcp.c | tcp_send_partial (sk); |
sk | 2169 | net/tcp/tcp.c | if ( sk->state == TCP_TIME_WAIT) |
sk | 2171 | net/tcp/tcp.c | if (!sk->dead) wake_up (sk->sleep); |
sk | 2172 | net/tcp/tcp.c | if (sk->rcv_ack_seq == sk->send_seq && |
sk | 2173 | net/tcp/tcp.c | sk->acked_seq == sk->fin_seq) |
sk | 2175 | net/tcp/tcp.c | sk->state = TCP_CLOSE; |
sk | 2176 | net/tcp/tcp.c | sk->shutdown = SHUTDOWN_MASK; |
sk | 2180 | net/tcp/tcp.c | if (sk->state == TCP_LAST_ACK || sk->state == TCP_FIN_WAIT2) |
sk | 2182 | net/tcp/tcp.c | if (!sk->dead) wake_up (sk->sleep); |
sk | 2183 | net/tcp/tcp.c | if (sk->rcv_ack_seq == sk->send_seq) |
sk | 2185 | net/tcp/tcp.c | if (sk->acked_seq != sk->fin_seq) |
sk | 2187 | net/tcp/tcp.c | tcp_time_wait(sk); |
sk | 2191 | net/tcp/tcp.c | PRINTK (("tcp_ack closing socket - %X\n", sk)); |
sk | 2192 | net/tcp/tcp.c | print_sk (sk); |
sk | 2193 | net/tcp/tcp.c | tcp_send_ack (sk->send_seq, sk->acked_seq, sk, th, sk->daddr); |
sk | 2194 | net/tcp/tcp.c | sk->shutdown = SHUTDOWN_MASK; |
sk | 2195 | net/tcp/tcp.c | sk->state = TCP_CLOSE; |
sk | 2210 | net/tcp/tcp.c | tcp_data (struct sk_buff *skb, volatile struct sock *sk, |
sk | 2220 | net/tcp/tcp.c | PRINTK(("tcp_data len = %d sk = %X:\n",skb->len, sk)); |
sk | 2221 | net/tcp/tcp.c | print_sk(sk); |
sk | 2223 | net/tcp/tcp.c | sk->bytes_rcv += skb->len; |
sk | 2229 | net/tcp/tcp.c | tcp_send_ack (sk->send_seq, sk->acked_seq,sk, th, saddr); |
sk | 2234 | net/tcp/tcp.c | if (sk->shutdown & RCV_SHUTDOWN) |
sk | 2236 | net/tcp/tcp.c | sk->acked_seq = th->seq + skb->len + th->syn + th->fin; |
sk | 2237 | net/tcp/tcp.c | tcp_reset (sk->saddr, sk->daddr, skb->h.th, |
sk | 2238 | net/tcp/tcp.c | sk->prot, NULL, skb->dev); |
sk | 2239 | net/tcp/tcp.c | sk->state = TCP_CLOSE; |
sk | 2240 | net/tcp/tcp.c | sk->err = EPIPE; |
sk | 2241 | net/tcp/tcp.c | sk->shutdown = SHUTDOWN_MASK; |
sk | 2242 | net/tcp/tcp.c | PRINTK (("tcp_data: closing socket - %X\n", sk)); |
sk | 2243 | net/tcp/tcp.c | print_sk (sk); |
sk | 2245 | net/tcp/tcp.c | if (!sk->dead) wake_up (sk->sleep); |
sk | 2255 | net/tcp/tcp.c | if (sk->rqueue == NULL) |
sk | 2260 | net/tcp/tcp.c | sk->rqueue = skb; |
sk | 2267 | net/tcp/tcp.c | PRINTK (("tcp_data adding to chain sk = %X:\n",sk)); |
sk | 2268 | net/tcp/tcp.c | print_sk (sk); |
sk | 2270 | net/tcp/tcp.c | for (skb1=sk->rqueue; ; skb1=skb1->prev) |
sk | 2281 | net/tcp/tcp.c | if (skb1 == sk->rqueue) |
sk | 2282 | net/tcp/tcp.c | sk->rqueue = skb; |
sk | 2285 | net/tcp/tcp.c | if ( skb1->prev == sk->rqueue) |
sk | 2299 | net/tcp/tcp.c | print_sk (sk); |
sk | 2307 | net/tcp/tcp.c | if (before (sk->acked_seq, sk->copied_seq)) |
sk | 2310 | net/tcp/tcp.c | sk->acked_seq = sk->copied_seq; |
sk | 2314 | net/tcp/tcp.c | if (skb1 == NULL || skb1->acked || before (th->seq, sk->acked_seq+1)) |
sk | 2316 | net/tcp/tcp.c | if (before (th->seq, sk->acked_seq+1)) |
sk | 2318 | net/tcp/tcp.c | if (after (th->ack_seq, sk->acked_seq)) |
sk | 2319 | net/tcp/tcp.c | sk->acked_seq = th->ack_seq; |
sk | 2325 | net/tcp/tcp.c | if (!sk->dead) wake_up (sk->sleep); |
sk | 2326 | net/tcp/tcp.c | sk->shutdown |= RCV_SHUTDOWN; |
sk | 2329 | net/tcp/tcp.c | for (skb2=skb->next; skb2 != sk->rqueue->next; skb2=skb2->next) |
sk | 2331 | net/tcp/tcp.c | if (before(skb2->h.th->seq, sk->acked_seq+1)) |
sk | 2333 | net/tcp/tcp.c | if (after (skb2->h.th->ack_seq, sk->acked_seq)) |
sk | 2334 | net/tcp/tcp.c | sk->acked_seq = skb2->h.th->ack_seq; |
sk | 2340 | net/tcp/tcp.c | sk->shutdown |= RCV_SHUTDOWN; |
sk | 2341 | net/tcp/tcp.c | if (!sk->dead) wake_up (sk->sleep); |
sk | 2345 | net/tcp/tcp.c | sk->ack_backlog = sk->max_ack_backlog; |
sk | 2356 | net/tcp/tcp.c | if (!sk->delay_acks || |
sk | 2357 | net/tcp/tcp.c | sk->ack_backlog >= sk->max_ack_backlog || |
sk | 2358 | net/tcp/tcp.c | sk->bytes_rcv > sk->max_unacked || |
sk | 2361 | net/tcp/tcp.c | tcp_send_ack (sk->send_seq, sk->acked_seq,sk,th, saddr); |
sk | 2365 | net/tcp/tcp.c | sk->ack_backlog++; |
sk | 2366 | net/tcp/tcp.c | sk->time_wait.len = TCP_ACK_TIME; |
sk | 2367 | net/tcp/tcp.c | sk->timeout = TIME_WRITE; |
sk | 2368 | net/tcp/tcp.c | reset_timer ((struct timer *)&sk->time_wait); |
sk | 2369 | net/tcp/tcp.c | sk->retransmits = 0; |
sk | 2376 | net/tcp/tcp.c | tcp_send_ack (sk->send_seq, sk->acked_seq, sk, th, saddr); |
sk | 2380 | net/tcp/tcp.c | if (!sk->dead) |
sk | 2382 | net/tcp/tcp.c | wake_up (sk->sleep); |
sk | 2389 | net/tcp/tcp.c | if (sk->state == TCP_FIN_WAIT2 && sk->acked_seq == sk->fin_seq |
sk | 2390 | net/tcp/tcp.c | && sk->rcv_ack_seq == sk->send_seq) |
sk | 2392 | net/tcp/tcp.c | PRINTK (("tcp_data: entering last_ack state sk = %X\n", sk)); |
sk | 2393 | net/tcp/tcp.c | print_sk (sk); |
sk | 2394 | net/tcp/tcp.c | tcp_send_ack (sk->send_seq, sk->acked_seq, sk, th, saddr); |
sk | 2395 | net/tcp/tcp.c | sk->shutdown = SHUTDOWN_MASK; |
sk | 2396 | net/tcp/tcp.c | sk->state = TCP_LAST_ACK; |
sk | 2397 | net/tcp/tcp.c | if (!sk->dead) wake_up (sk->sleep); |
sk | 2404 | net/tcp/tcp.c | tcp_urg (volatile struct sock *sk, struct tcp_header *th, unsigned long saddr) |
sk | 2409 | net/tcp/tcp.c | if (!sk->dead) |
sk | 2410 | net/tcp/tcp.c | wake_up(sk->sleep); |
sk | 2412 | net/tcp/tcp.c | if (sk->urginline) |
sk | 2419 | net/tcp/tcp.c | sk->urg++; |
sk | 2421 | net/tcp/tcp.c | if (!sk->urg) |
sk | 2425 | net/tcp/tcp.c | if (sk->proc == 0) return (0); |
sk | 2426 | net/tcp/tcp.c | if (sk->proc > 0) |
sk | 2428 | net/tcp/tcp.c | kill_proc (sk->proc, SIGURG, 1); |
sk | 2432 | net/tcp/tcp.c | kill_pg (-sk->proc, SIGURG, 1); |
sk | 2440 | net/tcp/tcp.c | tcp_fin (volatile struct sock *sk, struct tcp_header *th, |
sk | 2444 | net/tcp/tcp.c | sk, th, saddr, dev)); |
sk | 2446 | net/tcp/tcp.c | if (!sk->dead) |
sk | 2448 | net/tcp/tcp.c | wake_up (sk->sleep); |
sk | 2451 | net/tcp/tcp.c | switch (sk->state) |
sk | 2456 | net/tcp/tcp.c | sk->fin_seq = th->seq+1; /* Contains the one that needs to be acked */ |
sk | 2457 | net/tcp/tcp.c | sk->state = TCP_CLOSE_WAIT; |
sk | 2465 | net/tcp/tcp.c | sk->fin_seq = th->seq+1; /* Contains the one that needs to be acked */ |
sk | 2466 | net/tcp/tcp.c | sk->state = TCP_FIN_WAIT2; |
sk | 2471 | net/tcp/tcp.c | sk->state = TCP_LAST_ACK; |
sk | 2473 | net/tcp/tcp.c | sk->time_wait.len = TCP_TIMEWAIT_LEN; |
sk | 2474 | net/tcp/tcp.c | sk->timeout = TIME_CLOSE; |
sk | 2475 | net/tcp/tcp.c | reset_timer ((struct timer *)&sk->time_wait); |
sk | 2481 | net/tcp/tcp.c | sk->ack_backlog ++; |
sk | 2485 | net/tcp/tcp.c | buff=sk->prot->wmalloc(sk,MAX_ACK_SIZE,1, GFP_ATOMIC); |
sk | 2495 | net/tcp/tcp.c | buff->sk = sk; |
sk | 2499 | net/tcp/tcp.c | tmp = sk->prot->build_header (buff, sk->saddr, sk->daddr, &dev, |
sk | 2500 | net/tcp/tcp.c | IPPROTO_TCP, sk->opt, MAX_ACK_SIZE); |
sk | 2503 | net/tcp/tcp.c | sk->prot->wfree(sk, buff->mem_addr, buff->mem_len); |
sk | 2517 | net/tcp/tcp.c | t1->seq = net32(sk->send_seq); |
sk | 2522 | net/tcp/tcp.c | buff->h.seq = sk->send_seq; |
sk | 2523 | net/tcp/tcp.c | t1->window = net16(sk->prot->rspace(sk)); |
sk | 2533 | net/tcp/tcp.c | t1->ack_seq = net32(sk->acked_seq); |
sk | 2536 | net/tcp/tcp.c | tcp_send_check (t1, sk->saddr, sk->daddr, sizeof (*t1), sk); |
sk | 2540 | net/tcp/tcp.c | if (sk->wback != NULL) |
sk | 2543 | net/tcp/tcp.c | sk->wback->next = buff; |
sk | 2544 | net/tcp/tcp.c | sk->wback = buff; |
sk | 2549 | net/tcp/tcp.c | sk->prot->queue_xmit (sk, dev, buff,0); |
sk | 2559 | net/tcp/tcp.c | tcp_accept (volatile struct sock *sk, int flags) |
sk | 2564 | net/tcp/tcp.c | PRINTK (("tcp_accept(sk=%X, flags=%X)\n", sk, flags)); |
sk | 2565 | net/tcp/tcp.c | print_sk(sk); |
sk | 2569 | net/tcp/tcp.c | if (sk->state != TCP_LISTEN) |
sk | 2571 | net/tcp/tcp.c | sk->err = EINVAL; |
sk | 2576 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 2578 | net/tcp/tcp.c | while ( (skb = get_firstr(sk)) == NULL ) |
sk | 2583 | net/tcp/tcp.c | release_sock (sk); |
sk | 2584 | net/tcp/tcp.c | sk->err = EAGAIN; |
sk | 2588 | net/tcp/tcp.c | release_sock (sk); |
sk | 2589 | net/tcp/tcp.c | interruptible_sleep_on (sk->sleep); |
sk | 2593 | net/tcp/tcp.c | sk->err = ERESTARTSYS; |
sk | 2597 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 2602 | net/tcp/tcp.c | newsk = skb->sk; |
sk | 2605 | net/tcp/tcp.c | sk->ack_backlog--; |
sk | 2606 | net/tcp/tcp.c | release_sock (sk); |
sk | 2614 | net/tcp/tcp.c | tcp_connect (volatile struct sock *sk, struct sockaddr_in *usin, int addr_len) |
sk | 2622 | net/tcp/tcp.c | if (sk->state != TCP_CLOSE) return (-EISCONN); |
sk | 2629 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 2630 | net/tcp/tcp.c | sk->daddr = sin.sin_addr.s_addr; |
sk | 2631 | net/tcp/tcp.c | sk->send_seq = timer_seq*SEQ_TICK-seq_offset; |
sk | 2632 | net/tcp/tcp.c | sk->rcv_ack_seq = sk->send_seq -1; |
sk | 2633 | net/tcp/tcp.c | sk->err = 0; |
sk | 2634 | net/tcp/tcp.c | sk->dummy_th.dest = sin.sin_port; |
sk | 2635 | net/tcp/tcp.c | release_sock (sk); |
sk | 2637 | net/tcp/tcp.c | buff=sk->prot->wmalloc(sk,MAX_SYN_SIZE,0, GFP_KERNEL); |
sk | 2642 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 2647 | net/tcp/tcp.c | buff->sk = sk; |
sk | 2652 | net/tcp/tcp.c | tmp = sk->prot->build_header (buff, sk->saddr, sk->daddr, &dev, |
sk | 2656 | net/tcp/tcp.c | sk->prot->wfree(sk, buff->mem_addr, buff->mem_len); |
sk | 2657 | net/tcp/tcp.c | release_sock (sk); |
sk | 2663 | net/tcp/tcp.c | memcpy (t1, (void *)&(sk->dummy_th), sizeof (*t1)); |
sk | 2664 | net/tcp/tcp.c | t1->seq = net32(sk->send_seq++); |
sk | 2665 | net/tcp/tcp.c | buff->h.seq = sk->send_seq; |
sk | 2682 | net/tcp/tcp.c | sk->mtu = dev->mtu - HEADER_SIZE; |
sk | 2683 | net/tcp/tcp.c | tcp_send_check (t1, sk->saddr, sk->daddr, |
sk | 2684 | net/tcp/tcp.c | sizeof (struct tcp_header) + 4, sk); |
sk | 2687 | net/tcp/tcp.c | sk->state = TCP_SYN_SENT; |
sk | 2689 | net/tcp/tcp.c | sk->prot->queue_xmit(sk, dev, buff, 0); |
sk | 2691 | net/tcp/tcp.c | sk->time_wait.len = TCP_CONNECT_TIME; |
sk | 2692 | net/tcp/tcp.c | reset_timer ((struct timer *)&sk->time_wait); |
sk | 2693 | net/tcp/tcp.c | sk->retransmits = TCP_RETR2 - TCP_SYN_RETRIES; |
sk | 2694 | net/tcp/tcp.c | release_sock (sk); |
sk | 2703 | net/tcp/tcp.c | tcp_sequence (volatile struct sock *sk, struct tcp_header *th, short len, |
sk | 2712 | net/tcp/tcp.c | sk, th, len, opt, saddr)); |
sk | 2714 | net/tcp/tcp.c | if (between(th->seq, sk->acked_seq, sk->acked_seq + sk->window)|| |
sk | 2715 | net/tcp/tcp.c | between(th->seq + len-sizeof (*th), sk->acked_seq, |
sk | 2716 | net/tcp/tcp.c | sk->acked_seq + sk->window) || |
sk | 2717 | net/tcp/tcp.c | (before (th->seq, sk->acked_seq) && |
sk | 2718 | net/tcp/tcp.c | after (th->seq + len - sizeof (*th), sk->acked_seq + sk->window))) |
sk | 2727 | net/tcp/tcp.c | if (after (th->seq, sk->acked_seq + sk->window)) |
sk | 2729 | net/tcp/tcp.c | tcp_send_ack (sk->send_seq, sk->acked_seq, sk, th, saddr); |
sk | 2734 | net/tcp/tcp.c | if (th->ack && len == th->doff*4 && after (th->seq, sk->acked_seq - 32767) && |
sk | 2740 | net/tcp/tcp.c | tcp_send_ack (net32(th->ack_seq), sk->acked_seq, sk, th, saddr); |
sk | 2749 | net/tcp/tcp.c | tcp_options (volatile struct sock *sk, struct tcp_header *th) |
sk | 2755 | net/tcp/tcp.c | sk->mtu = min (sk->mtu, 576-HEADER_SIZE); |
sk | 2758 | net/tcp/tcp.c | sk->mtu = min (sk->mtu, ptr[2]*256 + ptr[3] - HEADER_SIZE); |
sk | 2767 | net/tcp/tcp.c | volatile struct sock *sk; |
sk | 2795 | net/tcp/tcp.c | sk=get_sock(&tcp_prot, net16(th->dest), saddr, th->source, daddr); |
sk | 2799 | net/tcp/tcp.c | if (sk) |
sk | 2801 | net/tcp/tcp.c | PRINTK (("sk = %X:\n",sk)); |
sk | 2802 | net/tcp/tcp.c | print_sk (sk); |
sk | 2809 | net/tcp/tcp.c | skb->sk = NULL; |
sk | 2818 | net/tcp/tcp.c | if (sk == NULL) |
sk | 2822 | net/tcp/tcp.c | skb->sk = NULL; |
sk | 2828 | net/tcp/tcp.c | skb->sk = sk; |
sk | 2841 | net/tcp/tcp.c | if (sk->inuse) |
sk | 2843 | net/tcp/tcp.c | if (sk->back_log == NULL) |
sk | 2845 | net/tcp/tcp.c | sk->back_log = skb; |
sk | 2851 | net/tcp/tcp.c | skb->next = sk->back_log; |
sk | 2852 | net/tcp/tcp.c | skb->prev = sk->back_log->prev; |
sk | 2859 | net/tcp/tcp.c | sk->inuse = 1; |
sk | 2864 | net/tcp/tcp.c | if (!sk) |
sk | 2871 | net/tcp/tcp.c | if (!sk->prot) |
sk | 2878 | net/tcp/tcp.c | if (sk->rmem_alloc + skb->mem_len >= SK_RMEM_MAX) |
sk | 2880 | net/tcp/tcp.c | skb->sk = NULL; |
sk | 2883 | net/tcp/tcp.c | release_sock (sk); |
sk | 2887 | net/tcp/tcp.c | sk->rmem_alloc += skb->mem_len; |
sk | 2893 | net/tcp/tcp.c | switch (sk->state) |
sk | 2900 | net/tcp/tcp.c | sk->err = ECONNRESET; |
sk | 2901 | net/tcp/tcp.c | sk->state = TCP_CLOSE; |
sk | 2902 | net/tcp/tcp.c | sk->shutdown = SHUTDOWN_MASK; |
sk | 2903 | net/tcp/tcp.c | if (!sk->dead) |
sk | 2905 | net/tcp/tcp.c | wake_up (sk->sleep); |
sk | 2908 | net/tcp/tcp.c | release_sock(sk); |
sk | 2918 | net/tcp/tcp.c | if (!tcp_sequence (sk, th, len, opt, saddr)) |
sk | 2921 | net/tcp/tcp.c | release_sock(sk); |
sk | 2928 | net/tcp/tcp.c | sk->err = ECONNRESET; |
sk | 2930 | net/tcp/tcp.c | if (sk->state == TCP_CLOSE_WAIT) |
sk | 2932 | net/tcp/tcp.c | sk->err = EPIPE; |
sk | 2939 | net/tcp/tcp.c | sk->state = TCP_CLOSE; |
sk | 2940 | net/tcp/tcp.c | sk->shutdown = SHUTDOWN_MASK; |
sk | 2941 | net/tcp/tcp.c | if (!sk->dead) |
sk | 2943 | net/tcp/tcp.c | wake_up (sk->sleep); |
sk | 2946 | net/tcp/tcp.c | release_sock(sk); |
sk | 2952 | net/tcp/tcp.c | sk->err = ECONNRESET; |
sk | 2953 | net/tcp/tcp.c | sk->state = TCP_CLOSE; |
sk | 2954 | net/tcp/tcp.c | sk->state = SHUTDOWN_MASK; |
sk | 2955 | net/tcp/tcp.c | tcp_reset (daddr, saddr, th, sk->prot, opt,dev); |
sk | 2956 | net/tcp/tcp.c | if (!sk->dead) |
sk | 2958 | net/tcp/tcp.c | wake_up (sk->sleep); |
sk | 2961 | net/tcp/tcp.c | release_sock(sk); |
sk | 2967 | net/tcp/tcp.c | if(!tcp_ack (sk, th, saddr)) |
sk | 2970 | net/tcp/tcp.c | release_sock(sk); |
sk | 2976 | net/tcp/tcp.c | if (tcp_urg (sk, th, saddr)) |
sk | 2979 | net/tcp/tcp.c | release_sock(sk); |
sk | 2984 | net/tcp/tcp.c | if (th->fin && tcp_fin (sk, th, saddr, dev)) |
sk | 2987 | net/tcp/tcp.c | release_sock(sk); |
sk | 2991 | net/tcp/tcp.c | if ( tcp_data (skb, sk, saddr, len)) |
sk | 2994 | net/tcp/tcp.c | release_sock(sk); |
sk | 2998 | net/tcp/tcp.c | release_sock(sk); |
sk | 3003 | net/tcp/tcp.c | if (sk->dead || sk->daddr) |
sk | 3007 | net/tcp/tcp.c | release_sock (sk); |
sk | 3015 | net/tcp/tcp.c | tcp_reset (daddr, saddr, th, sk->prot, opt,dev); |
sk | 3018 | net/tcp/tcp.c | release_sock(sk); |
sk | 3025 | net/tcp/tcp.c | release_sock(sk); |
sk | 3030 | net/tcp/tcp.c | tcp_reset (daddr, saddr, th, sk->prot, opt,dev ); |
sk | 3032 | net/tcp/tcp.c | release_sock(sk); |
sk | 3050 | net/tcp/tcp.c | tcp_conn_request (sk, skb, daddr, saddr, opt, dev); |
sk | 3052 | net/tcp/tcp.c | release_sock(sk); |
sk | 3057 | net/tcp/tcp.c | release_sock(sk); |
sk | 3061 | net/tcp/tcp.c | if (!tcp_sequence (sk, th, len, opt, saddr)) |
sk | 3064 | net/tcp/tcp.c | release_sock(sk); |
sk | 3071 | net/tcp/tcp.c | sk->err = ECONNREFUSED ; |
sk | 3072 | net/tcp/tcp.c | sk->state = TCP_CLOSE; |
sk | 3073 | net/tcp/tcp.c | sk->state = SHUTDOWN_MASK; |
sk | 3074 | net/tcp/tcp.c | if (!sk->dead) |
sk | 3076 | net/tcp/tcp.c | wake_up (sk->sleep); |
sk | 3079 | net/tcp/tcp.c | release_sock(sk); |
sk | 3100 | net/tcp/tcp.c | sk->state = TCP_SYN_RECV; |
sk | 3104 | net/tcp/tcp.c | release_sock(sk); |
sk | 3108 | net/tcp/tcp.c | switch (sk->state) |
sk | 3111 | net/tcp/tcp.c | if (!tcp_ack(sk, th, saddr)) |
sk | 3113 | net/tcp/tcp.c | tcp_reset(daddr, saddr, th, sk->prot, opt,dev); |
sk | 3115 | net/tcp/tcp.c | release_sock(sk); |
sk | 3125 | net/tcp/tcp.c | release_sock (sk); |
sk | 3130 | net/tcp/tcp.c | sk->acked_seq = th->seq+1; |
sk | 3131 | net/tcp/tcp.c | sk->fin_seq = th->seq; |
sk | 3132 | net/tcp/tcp.c | tcp_send_ack (sk->send_seq, th->seq+1, sk, |
sk | 3133 | net/tcp/tcp.c | th, sk->daddr); |
sk | 3136 | net/tcp/tcp.c | if (!tcp_ack(sk, th, saddr)) |
sk | 3138 | net/tcp/tcp.c | tcp_reset(daddr, saddr, th, sk->prot, opt, dev); |
sk | 3140 | net/tcp/tcp.c | release_sock(sk); |
sk | 3144 | net/tcp/tcp.c | sk->state = TCP_ESTABLISHED; |
sk | 3149 | net/tcp/tcp.c | tcp_options(sk, th); |
sk | 3150 | net/tcp/tcp.c | sk->dummy_th.dest = th->source; |
sk | 3151 | net/tcp/tcp.c | sk->copied_seq = sk->acked_seq-1; |
sk | 3152 | net/tcp/tcp.c | if (!sk->dead) |
sk | 3154 | net/tcp/tcp.c | wake_up (sk->sleep); |
sk | 3160 | net/tcp/tcp.c | if (tcp_urg (sk, th, saddr)) |
sk | 3163 | net/tcp/tcp.c | release_sock(sk); |
sk | 3166 | net/tcp/tcp.c | if (tcp_data (skb, sk, saddr, len)) |
sk | 3170 | net/tcp/tcp.c | tcp_fin(sk, th, saddr, dev); |
sk | 3172 | net/tcp/tcp.c | release_sock(sk); |
sk | 3178 | net/tcp/tcp.c | if (tcp_urg (sk, th, saddr)) |
sk | 3181 | net/tcp/tcp.c | release_sock (sk); |
sk | 3186 | net/tcp/tcp.c | if (tcp_data (skb, sk, saddr, len)) |
sk | 3189 | net/tcp/tcp.c | release_sock (sk); |
sk | 3195 | net/tcp/tcp.c | release_sock(sk); |
sk | 3198 | net/tcp/tcp.c | tcp_fin (sk, th, saddr, dev); |
sk | 3199 | net/tcp/tcp.c | release_sock(sk); |
sk | 3209 | net/tcp/tcp.c | tcp_write_wakeup(volatile struct sock *sk) |
sk | 3215 | net/tcp/tcp.c | if (sk -> state != TCP_ESTABLISHED && sk->state != TCP_CLOSE_WAIT) return; |
sk | 3217 | net/tcp/tcp.c | buff=sk->prot->wmalloc(sk,MAX_ACK_SIZE,1, GFP_ATOMIC); |
sk | 3226 | net/tcp/tcp.c | buff->sk = sk; |
sk | 3231 | net/tcp/tcp.c | tmp = sk->prot->build_header (buff, sk->saddr, sk->daddr, &dev, |
sk | 3232 | net/tcp/tcp.c | IPPROTO_TCP, sk->opt, MAX_ACK_SIZE); |
sk | 3235 | net/tcp/tcp.c | sk->prot->wfree(sk, buff->mem_addr, buff->mem_len); |
sk | 3242 | net/tcp/tcp.c | memcpy (t1,(void *) &sk->dummy_th, sizeof (*t1)); |
sk | 3246 | net/tcp/tcp.c | t1->seq = net32(sk->send_seq-1); |
sk | 3255 | net/tcp/tcp.c | t1->ack_seq = net32(sk->acked_seq); |
sk | 3256 | net/tcp/tcp.c | t1->window = net16(sk->prot->rspace(sk)); |
sk | 3258 | net/tcp/tcp.c | tcp_send_check (t1, sk->saddr, sk->daddr, sizeof (*t1), sk); |
sk | 3261 | net/tcp/tcp.c | sk->prot->queue_xmit(sk, dev, buff, 1); |
sk | 157 | net/tcp/timer.c | volatile struct sock *sk; |
sk | 165 | net/tcp/timer.c | sk = timer_base->sk; |
sk | 167 | net/tcp/timer.c | if (sk->inuse) |
sk | 172 | net/tcp/timer.c | sk->inuse = 1; |
sk | 174 | net/tcp/timer.c | why = sk->timeout; |
sk | 176 | net/tcp/timer.c | PRINTK (("net_timer: found sk=%X why = %d\n",sk, why)); |
sk | 178 | net/tcp/timer.c | if (sk->keepopen) |
sk | 180 | net/tcp/timer.c | sk->time_wait.len = TCP_TIMEOUT_LEN; |
sk | 181 | net/tcp/timer.c | sk->timeout = TIME_KEEPOPEN; |
sk | 186 | net/tcp/timer.c | sk->timeout = 0; |
sk | 191 | net/tcp/timer.c | if (sk->ack_backlog) |
sk | 193 | net/tcp/timer.c | sk->prot->read_wakeup(sk); |
sk | 194 | net/tcp/timer.c | if (!sk->dead) wake_up (sk->sleep); |
sk | 202 | net/tcp/timer.c | if (!sk->dead || sk->state != TCP_CLOSE) |
sk | 205 | net/tcp/timer.c | release_sock (sk); |
sk | 208 | net/tcp/timer.c | destroy_sock (sk); |
sk | 215 | net/tcp/timer.c | PRINTK (("possible memory leak. sk = %X\n", sk)); |
sk | 216 | net/tcp/timer.c | print_sk (sk); |
sk | 217 | net/tcp/timer.c | reset_timer ((struct timer *)&sk->time_wait); |
sk | 218 | net/tcp/timer.c | sk->inuse = 0; |
sk | 224 | net/tcp/timer.c | sk->state = TCP_CLOSE; |
sk | 225 | net/tcp/timer.c | delete_timer ((struct timer *)&sk->time_wait); |
sk | 228 | net/tcp/timer.c | arp_destroy (sk->daddr); |
sk | 229 | net/tcp/timer.c | if (!sk->dead) |
sk | 230 | net/tcp/timer.c | wake_up (sk->sleep); |
sk | 231 | net/tcp/timer.c | release_sock(sk); |
sk | 237 | net/tcp/timer.c | if (sk->send_head != NULL) |
sk | 239 | net/tcp/timer.c | if (before (jiffies, sk->send_head->when + 2*sk->rtt)) |
sk | 241 | net/tcp/timer.c | sk->time_wait.len = 2*sk->rtt; |
sk | 242 | net/tcp/timer.c | sk->timeout = TIME_WRITE; |
sk | 243 | net/tcp/timer.c | reset_timer ((struct timer *)&sk->time_wait); |
sk | 244 | net/tcp/timer.c | release_sock (sk); |
sk | 248 | net/tcp/timer.c | sk->prot->retransmit (sk, 0); |
sk | 250 | net/tcp/timer.c | if (sk->retransmits > TCP_RETR1) |
sk | 253 | net/tcp/timer.c | arp_destroy (sk->daddr); |
sk | 254 | net/tcp/timer.c | ip_route_check (sk->daddr); |
sk | 257 | net/tcp/timer.c | if (sk->retransmits > TCP_RETR2) |
sk | 260 | net/tcp/timer.c | sk->err = ETIMEDOUT; |
sk | 261 | net/tcp/timer.c | if (sk->state == TCP_FIN_WAIT1 || |
sk | 262 | net/tcp/timer.c | sk->state == TCP_FIN_WAIT2 || |
sk | 263 | net/tcp/timer.c | sk->state == TCP_LAST_ACK) |
sk | 265 | net/tcp/timer.c | sk->state = TCP_TIME_WAIT; |
sk | 266 | net/tcp/timer.c | sk->timeout = TIME_CLOSE; |
sk | 267 | net/tcp/timer.c | sk->time_wait.len = TCP_TIMEWAIT_LEN; |
sk | 268 | net/tcp/timer.c | reset_timer ((struct timer *)&sk->time_wait); |
sk | 269 | net/tcp/timer.c | release_sock(sk); |
sk | 274 | net/tcp/timer.c | sk->prot->close (sk,1); |
sk | 278 | net/tcp/timer.c | release_sock (sk); |
sk | 281 | net/tcp/timer.c | release_sock (sk); |
sk | 287 | net/tcp/timer.c | if (sk->prot->write_wakeup != NULL) |
sk | 288 | net/tcp/timer.c | sk->prot->write_wakeup(sk); |
sk | 289 | net/tcp/timer.c | sk->retransmits ++; |
sk | 290 | net/tcp/timer.c | if (sk->shutdown == SHUTDOWN_MASK) |
sk | 292 | net/tcp/timer.c | sk->prot->close (sk,1); |
sk | 293 | net/tcp/timer.c | sk->state = TCP_CLOSE; |
sk | 296 | net/tcp/timer.c | if (sk->retransmits > TCP_RETR1) |
sk | 299 | net/tcp/timer.c | arp_destroy (sk->daddr); |
sk | 300 | net/tcp/timer.c | ip_route_check (sk->daddr); |
sk | 301 | net/tcp/timer.c | release_sock (sk); |
sk | 304 | net/tcp/timer.c | if (sk->retransmits > TCP_RETR2) |
sk | 307 | net/tcp/timer.c | arp_destroy (sk->daddr); |
sk | 308 | net/tcp/timer.c | sk->err = ETIMEDOUT; |
sk | 309 | net/tcp/timer.c | if (sk->state == TCP_FIN_WAIT1 || |
sk | 310 | net/tcp/timer.c | sk->state == TCP_FIN_WAIT2) |
sk | 312 | net/tcp/timer.c | sk->state = TCP_TIME_WAIT; |
sk | 313 | net/tcp/timer.c | if (!sk->dead) |
sk | 314 | net/tcp/timer.c | wake_up (sk->sleep); |
sk | 315 | net/tcp/timer.c | release_sock(sk); |
sk | 319 | net/tcp/timer.c | sk->prot->close (sk, 1); |
sk | 323 | net/tcp/timer.c | release_sock (sk); |
sk | 327 | net/tcp/timer.c | release_sock(sk); |
sk | 40 | net/tcp/timer.h | volatile struct sock *sk; |
sk | 101 | net/tcp/udp.c | udp_select (volatile struct sock *sk, int sel_type, select_table *wait) |
sk | 103 | net/tcp/udp.c | select_wait(sk->sleep, wait); |
sk | 107 | net/tcp/udp.c | if (sk->rqueue != NULL) |
sk | 114 | net/tcp/udp.c | if (sk->prot->wspace(sk) >= MIN_WRITE_SPACE) |
sk | 121 | net/tcp/udp.c | if (sk->err) return (1); /* can this ever happen? */ |
sk | 139 | net/tcp/udp.c | volatile struct sock *sk; |
sk | 144 | net/tcp/udp.c | sk = get_sock (&udp_prot, net16(th->dest), saddr, th->source, daddr); |
sk | 146 | net/tcp/udp.c | if (sk == NULL) return; |
sk | 149 | net/tcp/udp.c | if (sk->cong_window > 1) |
sk | 150 | net/tcp/udp.c | sk->cong_window = sk->cong_window/2; |
sk | 154 | net/tcp/udp.c | sk->err = icmp_err_convert[err & 0xff].errno; |
sk | 156 | net/tcp/udp.c | if (icmp_err_convert[err & 0xff].fatal && sk->state == TCP_ESTABLISHED) |
sk | 158 | net/tcp/udp.c | sk->prot->close(sk, 0); |
sk | 236 | net/tcp/udp.c | unsigned long daddr, int len, volatile struct sock *sk) |
sk | 239 | net/tcp/udp.c | if (sk && sk->no_check) return; |
sk | 244 | net/tcp/udp.c | udp_loopback (volatile struct sock *sk, unsigned short port, |
sk | 251 | net/tcp/udp.c | sk->inuse = 1; |
sk | 255 | net/tcp/udp.c | pair = get_sock (sk->prot, net16(port), saddr, |
sk | 256 | net/tcp/udp.c | sk->dummy_th.source, daddr); |
sk | 277 | net/tcp/udp.c | uh -> source = sk->dummy_th.source; |
sk | 298 | net/tcp/udp.c | release_sock (sk); |
sk | 304 | net/tcp/udp.c | udp_sendto (volatile struct sock *sk, unsigned char *from, int len, |
sk | 340 | net/tcp/udp.c | if (sk->state != TCP_ESTABLISHED) |
sk | 343 | net/tcp/udp.c | sin.sin_port = sk->dummy_th.dest; |
sk | 344 | net/tcp/udp.c | sin.sin_addr.s_addr = sk->daddr; |
sk | 348 | net/tcp/udp.c | saddr = sk->saddr; |
sk | 358 | net/tcp/udp.c | err = udp_loopback (sk, sin.sin_port, from, len, |
sk | 364 | net/tcp/udp.c | sk->inuse = 1; |
sk | 369 | net/tcp/udp.c | skb = sk->prot->wmalloc (sk, len + sizeof (*skb) |
sk | 370 | net/tcp/udp.c | + sk->prot->max_header, 0, |
sk | 377 | net/tcp/udp.c | print_sk(sk); |
sk | 378 | net/tcp/udp.c | tmp = sk->wmem_alloc; |
sk | 379 | net/tcp/udp.c | release_sock (sk); |
sk | 383 | net/tcp/udp.c | if (tmp <= sk->wmem_alloc) |
sk | 385 | net/tcp/udp.c | interruptible_sleep_on (sk->sleep); |
sk | 393 | net/tcp/udp.c | sk->inuse = 1; |
sk | 400 | net/tcp/udp.c | skb->mem_len = len + sizeof (*skb) + sk->prot->max_header; |
sk | 401 | net/tcp/udp.c | skb->sk = sk; |
sk | 407 | net/tcp/udp.c | tmp = sk->prot->build_header (skb, saddr, |
sk | 409 | net/tcp/udp.c | IPPROTO_UDP, sk->opt, skb->mem_len); |
sk | 412 | net/tcp/udp.c | sk->prot->wfree (sk, skb->mem_addr, skb->mem_len); |
sk | 413 | net/tcp/udp.c | release_sock (sk); |
sk | 430 | net/tcp/udp.c | uh->source = sk->dummy_th.source; |
sk | 438 | net/tcp/udp.c | release_sock (sk); |
sk | 449 | net/tcp/udp.c | amt+sizeof (*uh), sk); |
sk | 451 | net/tcp/udp.c | sk->prot->queue_xmit (sk, dev, skb, 1); |
sk | 453 | net/tcp/udp.c | release_sock (sk); |
sk | 458 | net/tcp/udp.c | udp_write (volatile struct sock *sk, unsigned char *buff, int len, int noblock, |
sk | 461 | net/tcp/udp.c | return (udp_sendto (sk, buff, len, noblock, flags, NULL, 0)); |
sk | 466 | net/tcp/udp.c | udp_ioctl (volatile struct sock *sk, int cmd, unsigned long arg) |
sk | 476 | net/tcp/udp.c | if (sk->state == TCP_LISTEN) |
sk | 478 | net/tcp/udp.c | amount = sk->prot->wspace(sk)/2; |
sk | 490 | net/tcp/udp.c | if (sk->state == TCP_LISTEN) |
sk | 493 | net/tcp/udp.c | skb = sk->rqueue; |
sk | 509 | net/tcp/udp.c | udp_recvfrom (volatile struct sock *sk, unsigned char *to, int len, |
sk | 523 | net/tcp/udp.c | if (sk->err) |
sk | 526 | net/tcp/udp.c | err = -sk->err; |
sk | 527 | net/tcp/udp.c | sk->err = 0; |
sk | 535 | net/tcp/udp.c | sk->inuse = 1; |
sk | 536 | net/tcp/udp.c | while (sk->rqueue == NULL) |
sk | 538 | net/tcp/udp.c | if (sk->shutdown & RCV_SHUTDOWN) |
sk | 545 | net/tcp/udp.c | release_sock (sk); |
sk | 548 | net/tcp/udp.c | release_sock (sk); |
sk | 550 | net/tcp/udp.c | if (sk->rqueue == NULL) |
sk | 552 | net/tcp/udp.c | interruptible_sleep_on (sk->sleep); |
sk | 560 | net/tcp/udp.c | skb = sk->rqueue; |
sk | 566 | net/tcp/udp.c | sk->rqueue = NULL; |
sk | 570 | net/tcp/udp.c | sk->rqueue = sk->rqueue ->next; |
sk | 593 | net/tcp/udp.c | release_sock (sk); |
sk | 600 | net/tcp/udp.c | udp_read (volatile struct sock *sk, unsigned char *buff, int len, int noblock, |
sk | 603 | net/tcp/udp.c | return (udp_recvfrom (sk, buff, len, noblock, flags, NULL, NULL)); |
sk | 607 | net/tcp/udp.c | udp_connect (volatile struct sock *sk, struct sockaddr_in *usin, int addr_len) |
sk | 615 | net/tcp/udp.c | sk->daddr = sin.sin_addr.s_addr; |
sk | 616 | net/tcp/udp.c | sk->dummy_th.dest = sin.sin_port; |
sk | 617 | net/tcp/udp.c | sk->state = TCP_ESTABLISHED; |
sk | 622 | net/tcp/udp.c | udp_close(volatile struct sock *sk, int timeout) |
sk | 624 | net/tcp/udp.c | sk->inuse = 1; |
sk | 625 | net/tcp/udp.c | sk->state = TCP_CLOSE; |
sk | 626 | net/tcp/udp.c | if (sk->dead) |
sk | 627 | net/tcp/udp.c | destroy_sock (sk); |
sk | 629 | net/tcp/udp.c | release_sock (sk); |
sk | 639 | net/tcp/udp.c | volatile struct sock *sk; |
sk | 646 | net/tcp/udp.c | sk = get_sock (prot, net16(uh->dest), saddr, uh->source, daddr); |
sk | 649 | net/tcp/udp.c | if (sk == NULL) |
sk | 656 | net/tcp/udp.c | skb->sk = NULL; |
sk | 667 | net/tcp/udp.c | skb->sk = NULL; |
sk | 672 | net/tcp/udp.c | skb->sk = sk; |
sk | 682 | net/tcp/udp.c | if (sk->inuse) |
sk | 684 | net/tcp/udp.c | if (sk->back_log == NULL) |
sk | 686 | net/tcp/udp.c | sk->back_log = skb; |
sk | 692 | net/tcp/udp.c | skb->next = sk->back_log; |
sk | 693 | net/tcp/udp.c | skb->prev = sk->back_log->prev; |
sk | 700 | net/tcp/udp.c | sk->inuse = 1; |
sk | 705 | net/tcp/udp.c | if (sk->rmem_alloc + skb->mem_len >= SK_RMEM_MAX) |
sk | 707 | net/tcp/udp.c | skb->sk = NULL; |
sk | 709 | net/tcp/udp.c | release_sock (sk); |
sk | 713 | net/tcp/udp.c | sk->rmem_alloc += skb->mem_len; |
sk | 717 | net/tcp/udp.c | print_sk (sk); |
sk | 720 | net/tcp/udp.c | if (sk->rqueue == NULL) |
sk | 722 | net/tcp/udp.c | sk->rqueue = skb; |
sk | 728 | net/tcp/udp.c | skb->next = sk->rqueue; |
sk | 729 | net/tcp/udp.c | skb->prev = sk->rqueue->prev; |
sk | 736 | net/tcp/udp.c | if (!sk->dead) |
sk | 737 | net/tcp/udp.c | wake_up (sk->sleep); |
sk | 739 | net/tcp/udp.c | release_sock (sk); |