![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to tp_pcb.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Net/2] / Net2 / netiso|
Return to tp_pcb.c CVS log | Up to [Net/2] / Net2 / netiso |
1.1 ! root 1: /*- ! 2: * Copyright (c) 1991 The Regents of the University of California. ! 3: * All rights reserved. ! 4: * ! 5: * Redistribution and use in source and binary forms, with or without ! 6: * modification, are permitted provided that the following conditions ! 7: * are met: ! 8: * 1. Redistributions of source code must retain the above copyright ! 9: * notice, this list of conditions and the following disclaimer. ! 10: * 2. Redistributions in binary form must reproduce the above copyright ! 11: * notice, this list of conditions and the following disclaimer in the ! 12: * documentation and/or other materials provided with the distribution. ! 13: * 3. All advertising materials mentioning features or use of this software ! 14: * must display the following acknowledgement: ! 15: * This product includes software developed by the University of ! 16: * California, Berkeley and its contributors. ! 17: * 4. Neither the name of the University nor the names of its contributors ! 18: * may be used to endorse or promote products derived from this software ! 19: * without specific prior written permission. ! 20: * ! 21: * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND ! 22: * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE ! 23: * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ! 24: * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE ! 25: * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL ! 26: * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS ! 27: * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) ! 28: * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT ! 29: * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY ! 30: * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF ! 31: * SUCH DAMAGE. ! 32: * ! 33: * @(#)tp_pcb.c 7.11 (Berkeley) 5/6/91 ! 34: */ ! 35: ! 36: /*********************************************************** ! 37: Copyright IBM Corporation 1987 ! 38: ! 39: All Rights Reserved ! 40: ! 41: Permission to use, copy, modify, and distribute this software and its ! 42: documentation for any purpose and without fee is hereby granted, ! 43: provided that the above copyright notice appear in all copies and that ! 44: both that copyright notice and this permission notice appear in ! 45: supporting documentation, and that the name of IBM not be ! 46: used in advertising or publicity pertaining to distribution of the ! 47: software without specific, written prior permission. ! 48: ! 49: IBM DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE, INCLUDING ! 50: ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS, IN NO EVENT SHALL ! 51: IBM BE LIABLE FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR ! 52: ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, ! 53: WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ! 54: ARISING OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS ! 55: SOFTWARE. ! 56: ! 57: ******************************************************************/ ! 58: ! 59: /* ! 60: * ARGO Project, Computer Sciences Dept., University of Wisconsin - Madison ! 61: */ ! 62: /* ! 63: * ARGO TP ! 64: * ! 65: * $Header: tp_pcb.c,v 5.4 88/11/18 17:28:24 nhall Exp $ ! 66: * $Source: /usr/argo/sys/netiso/RCS/tp_pcb.c,v $ ! 67: * ! 68: * ! 69: * This is the initialization and cleanup stuff - ! 70: * for the tp machine in general as well as for the individual pcbs. ! 71: * tp_init() is called at system startup. tp_attach() and tp_getref() are ! 72: * called when a socket is created. tp_detach() and tp_freeref() ! 73: * are called during the closing stage and/or when the reference timer ! 74: * goes off. ! 75: * tp_soisdisconnecting() and tp_soisdisconnected() are tp-specific ! 76: * versions of soisconnect* ! 77: * and are called (obviously) during the closing phase. ! 78: * ! 79: */ ! 80: ! 81: #include "types.h" ! 82: #include "param.h" ! 83: #include "mbuf.h" ! 84: #include "socket.h" ! 85: #include "socketvar.h" ! 86: #include "protosw.h" ! 87: #include "errno.h" ! 88: #include "time.h" ! 89: #include "argo_debug.h" ! 90: #include "tp_param.h" ! 91: #include "tp_timer.h" ! 92: #include "tp_ip.h" ! 93: #include "tp_stat.h" ! 94: #include "tp_pcb.h" ! 95: #include "tp_tpdu.h" ! 96: #include "tp_trace.h" ! 97: #include "tp_meas.h" ! 98: #include "tp_seq.h" ! 99: #include "tp_clnp.h" ! 100: ! 101: struct tp_param tp_param = { ! 102: 1, /* configured */ ! 103: }; ! 104: ! 105: /* ticks are in units of: ! 106: * 500 nano-fortnights ;-) or ! 107: * 500 ms or ! 108: * 1/2 second ! 109: */ ! 110: ! 111: struct tp_conn_param tp_conn_param[] = { ! 112: /* ISO_CLNS: TP4 CONNECTION LESS */ ! 113: { ! 114: TP_NRETRANS, /* short p_Nretrans; */ ! 115: 20, /* 10 sec */ /* short p_dr_ticks; */ ! 116: ! 117: 20, /* 10 sec */ /* short p_cc_ticks; */ ! 118: 20, /* 10 sec */ /* short p_dt_ticks; */ ! 119: ! 120: 40, /* 20 sec */ /* short p_x_ticks; */ ! 121: 80, /* 40 sec */ /* short p_cr_ticks;*/ ! 122: ! 123: 240, /* 2 min */ /* short p_keepalive_ticks;*/ ! 124: 10, /* 5 sec */ /* short p_sendack_ticks; */ ! 125: ! 126: 600, /* 5 min */ /* short p_ref_ticks; */ ! 127: 360, /* 3 min */ /* short p_inact_ticks; */ ! 128: ! 129: (short) 100, /* short p_lcdtfract */ ! 130: (short) TP_SOCKBUFSIZE, /* short p_winsize */ ! 131: TP_TPDUSIZE, /* u_char p_tpdusize */ ! 132: ! 133: TPACK_WINDOW, /* 4 bits p_ack_strat */ ! 134: TPRX_USE_CW | TPRX_FASTSTART, ! 135: /* 4 bits p_rx_strat*/ ! 136: TP_CLASS_4 | TP_CLASS_0,/* 5 bits p_class */ ! 137: 1, /* 1 bit xtd format */ ! 138: 1, /* 1 bit xpd service */ ! 139: 1, /* 1 bit use_checksum */ ! 140: 0, /* 1 bit use net xpd */ ! 141: 0, /* 1 bit use rcc */ ! 142: 0, /* 1 bit use efc */ ! 143: 1, /* no disc indications */ ! 144: 0, /* don't change params */ ! 145: ISO_CLNS, /* p_netservice */ ! 146: }, ! 147: /* IN_CLNS: TP4 CONNECTION LESS */ ! 148: { ! 149: TP_NRETRANS, /* short p_Nretrans; */ ! 150: 20, /* 10 sec */ /* short p_dr_ticks; */ ! 151: ! 152: 20, /* 10 sec */ /* short p_cc_ticks; */ ! 153: 20, /* 10 sec */ /* short p_dt_ticks; */ ! 154: ! 155: 40, /* 20 sec */ /* short p_x_ticks; */ ! 156: 80, /* 40 sec */ /* short p_cr_ticks;*/ ! 157: ! 158: 240, /* 2 min */ /* short p_keepalive_ticks;*/ ! 159: 10, /* 5 sec */ /* short p_sendack_ticks; */ ! 160: ! 161: 600, /* 5 min */ /* short p_ref_ticks; */ ! 162: 360, /* 3 min */ /* short p_inact_ticks; */ ! 163: ! 164: (short) 100, /* short p_lcdtfract */ ! 165: (short) TP_SOCKBUFSIZE, /* short p_winsize */ ! 166: TP_TPDUSIZE, /* u_char p_tpdusize */ ! 167: ! 168: TPACK_WINDOW, /* 4 bits p_ack_strat */ ! 169: TPRX_USE_CW | TPRX_FASTSTART, ! 170: /* 4 bits p_rx_strat*/ ! 171: TP_CLASS_4, /* 5 bits p_class */ ! 172: 1, /* 1 bit xtd format */ ! 173: 1, /* 1 bit xpd service */ ! 174: 1, /* 1 bit use_checksum */ ! 175: 0, /* 1 bit use net xpd */ ! 176: 0, /* 1 bit use rcc */ ! 177: 0, /* 1 bit use efc */ ! 178: 1, /* no disc indications */ ! 179: 0, /* don't change params */ ! 180: IN_CLNS, /* p_netservice */ ! 181: }, ! 182: /* ISO_CONS: TP0 CONNECTION MODE */ ! 183: { ! 184: TP_NRETRANS, /* short p_Nretrans; */ ! 185: 0, /* n/a */ /* short p_dr_ticks; */ ! 186: ! 187: 40, /* 20 sec */ /* short p_cc_ticks; */ ! 188: 0, /* n/a */ /* short p_dt_ticks; */ ! 189: ! 190: 0, /* n/a */ /* short p_x_ticks; */ ! 191: 360, /* 3 min */ /* short p_cr_ticks;*/ ! 192: ! 193: 0, /* n/a */ /* short p_keepalive_ticks;*/ ! 194: 0, /* n/a */ /* short p_sendack_ticks; */ ! 195: ! 196: 600, /* for cr/cc to clear *//* short p_ref_ticks; */ ! 197: 0, /* n/a */ /* short p_inact_ticks; */ ! 198: ! 199: /* Use tp4 defaults just in case the user changes ONLY ! 200: * the class ! 201: */ ! 202: (short) 100, /* short p_lcdtfract */ ! 203: (short) TP0_SOCKBUFSIZE, /* short p_winsize */ ! 204: TP0_TPDUSIZE, /* 8 bits p_tpdusize */ ! 205: ! 206: 0, /* 4 bits p_ack_strat */ ! 207: 0, /* 4 bits p_rx_strat*/ ! 208: TP_CLASS_0, /* 5 bits p_class */ ! 209: 0, /* 1 bit xtd format */ ! 210: 0, /* 1 bit xpd service */ ! 211: 0, /* 1 bit use_checksum */ ! 212: 0, /* 1 bit use net xpd */ ! 213: 0, /* 1 bit use rcc */ ! 214: 0, /* 1 bit use efc */ ! 215: 0, /* no disc indications */ ! 216: 0, /* don't change params */ ! 217: ISO_CONS, /* p_netservice */ ! 218: }, ! 219: /* ISO_COSNS: TP4 CONNECTION LESS SERVICE over CONSNS */ ! 220: { ! 221: TP_NRETRANS, /* short p_Nretrans; */ ! 222: 40, /* 20 sec */ /* short p_dr_ticks; */ ! 223: ! 224: 40, /* 20 sec */ /* short p_cc_ticks; */ ! 225: 80, /* 40 sec */ /* short p_dt_ticks; */ ! 226: ! 227: 120, /* 1 min */ /* short p_x_ticks; */ ! 228: 360, /* 3 min */ /* short p_cr_ticks;*/ ! 229: ! 230: 360, /* 3 min */ /* short p_keepalive_ticks;*/ ! 231: 20, /* 10 sec */ /* short p_sendack_ticks; */ ! 232: ! 233: 600, /* 5 min */ /* short p_ref_ticks; */ ! 234: 480, /* 4 min */ /* short p_inact_ticks; */ ! 235: ! 236: (short) 100, /* short p_lcdtfract */ ! 237: (short) TP0_SOCKBUFSIZE, /* short p_winsize */ ! 238: TP0_TPDUSIZE, /* u_char p_tpdusize */ ! 239: ! 240: TPACK_WINDOW, /* 4 bits p_ack_strat */ ! 241: TPRX_USE_CW , /* No fast start */ ! 242: /* 4 bits p_rx_strat*/ ! 243: TP_CLASS_4 | TP_CLASS_0,/* 5 bits p_class */ ! 244: 0, /* 1 bit xtd format */ ! 245: 1, /* 1 bit xpd service */ ! 246: 1, /* 1 bit use_checksum */ ! 247: 0, /* 1 bit use net xpd */ ! 248: 0, /* 1 bit use rcc */ ! 249: 0, /* 1 bit use efc */ ! 250: 0, /* no disc indications */ ! 251: 0, /* don't change params */ ! 252: ISO_COSNS, /* p_netservice */ ! 253: }, ! 254: }; ! 255: ! 256: #ifdef INET ! 257: int in_putnetaddr(); ! 258: int in_getnetaddr(); ! 259: int in_cmpnetaddr(); ! 260: int in_putsufx(); ! 261: int in_getsufx(); ! 262: int in_recycle_tsuffix(); ! 263: int tpip_mtu(); ! 264: int in_pcbbind(); ! 265: int in_pcbconnect(); ! 266: int in_pcbdisconnect(); ! 267: int in_pcbdetach(); ! 268: int in_pcballoc(); ! 269: int tpip_output(); ! 270: int tpip_output_dg(); ! 271: struct inpcb tp_inpcb; ! 272: #endif INET ! 273: #ifdef ISO ! 274: int iso_putnetaddr(); ! 275: int iso_getnetaddr(); ! 276: int iso_cmpnetaddr(); ! 277: int iso_putsufx(); ! 278: int iso_getsufx(); ! 279: int iso_recycle_tsuffix(); ! 280: int tpclnp_mtu(); ! 281: int iso_pcbbind(); ! 282: int iso_pcbconnect(); ! 283: int iso_pcbdisconnect(); ! 284: int iso_pcbdetach(); ! 285: int iso_pcballoc(); ! 286: int tpclnp_output(); ! 287: int tpclnp_output_dg(); ! 288: int iso_nlctloutput(); ! 289: struct isopcb tp_isopcb; ! 290: #endif ISO ! 291: #ifdef TPCONS ! 292: int iso_putnetaddr(); ! 293: int iso_getnetaddr(); ! 294: int iso_cmpnetaddr(); ! 295: int iso_putsufx(); ! 296: int iso_getsufx(); ! 297: int iso_recycle_tsuffix(); ! 298: int iso_pcbbind(); ! 299: int tpcons_pcbconnect(); ! 300: int tpclnp_mtu(); ! 301: int iso_pcbdisconnect(); ! 302: int iso_pcbdetach(); ! 303: int iso_pcballoc(); ! 304: int tpcons_output(); ! 305: struct isopcb tp_isopcb; ! 306: #endif TPCONS ! 307: ! 308: ! 309: struct nl_protosw nl_protosw[] = { ! 310: /* ISO_CLNS */ ! 311: #ifdef ISO ! 312: { AF_ISO, iso_putnetaddr, iso_getnetaddr, iso_cmpnetaddr, ! 313: iso_putsufx, iso_getsufx, ! 314: iso_recycle_tsuffix, ! 315: tpclnp_mtu, iso_pcbbind, iso_pcbconnect, ! 316: iso_pcbdisconnect, iso_pcbdetach, ! 317: iso_pcballoc, ! 318: tpclnp_output, tpclnp_output_dg, iso_nlctloutput, ! 319: (caddr_t) &tp_isopcb, ! 320: }, ! 321: #else ! 322: { 0 }, ! 323: #endif ISO ! 324: /* IN_CLNS */ ! 325: #ifdef INET ! 326: { AF_INET, in_putnetaddr, in_getnetaddr, in_cmpnetaddr, ! 327: in_putsufx, in_getsufx, ! 328: in_recycle_tsuffix, ! 329: tpip_mtu, in_pcbbind, in_pcbconnect, ! 330: in_pcbdisconnect, in_pcbdetach, ! 331: in_pcballoc, ! 332: tpip_output, tpip_output_dg, /* nl_ctloutput */ NULL, ! 333: (caddr_t) &tp_inpcb, ! 334: }, ! 335: #else ! 336: { 0 }, ! 337: #endif INET ! 338: /* ISO_CONS */ ! 339: #if defined(ISO) && defined(TPCONS) ! 340: { AF_ISO, iso_putnetaddr, iso_getnetaddr, iso_cmpnetaddr, ! 341: iso_putsufx, iso_getsufx, ! 342: iso_recycle_tsuffix, ! 343: tpclnp_mtu, iso_pcbbind, tpcons_pcbconnect, ! 344: iso_pcbdisconnect, iso_pcbdetach, ! 345: iso_pcballoc, ! 346: tpcons_output, tpcons_output, iso_nlctloutput, ! 347: (caddr_t) &tp_isopcb, ! 348: }, ! 349: #else ! 350: { 0 }, ! 351: #endif ISO_CONS ! 352: /* End of protosw marker */ ! 353: { 0 } ! 354: }; ! 355: ! 356: /* ! 357: * NAME: tp_init() ! 358: * ! 359: * CALLED FROM: ! 360: * autoconf through the protosw structure ! 361: * ! 362: * FUNCTION: ! 363: * initialize tp machine ! 364: * ! 365: * RETURNS: Nada ! 366: * ! 367: * SIDE EFFECTS: ! 368: * ! 369: * NOTES: ! 370: */ ! 371: int ! 372: tp_init() ! 373: { ! 374: static int init_done=0; ! 375: void tp_timerinit(); ! 376: ! 377: if (init_done++) ! 378: return 0; ! 379: ! 380: ! 381: /* FOR INET */ ! 382: tp_inpcb.inp_next = tp_inpcb.inp_prev = &tp_inpcb; ! 383: /* FOR ISO */ ! 384: tp_isopcb.isop_next = tp_isopcb.isop_prev = &tp_isopcb; ! 385: ! 386: tp_start_win = 2; ! 387: ! 388: tp_timerinit(); ! 389: bzero((caddr_t)&tp_stat, sizeof(struct tp_stat)); ! 390: return 0; ! 391: } ! 392: ! 393: /* ! 394: * NAME: tp_soisdisconnecting() ! 395: * ! 396: * CALLED FROM: ! 397: * tp.trans ! 398: * ! 399: * FUNCTION and ARGUMENTS: ! 400: * Set state of the socket (so) to reflect that fact that we're disconnectING ! 401: * ! 402: * RETURNS: Nada ! 403: * ! 404: * SIDE EFFECTS: ! 405: * ! 406: * NOTES: ! 407: * This differs from the regular soisdisconnecting() in that the latter ! 408: * also sets the SS_CANTRECVMORE and SS_CANTSENDMORE flags. ! 409: * We don't want to set those flags because those flags will cause ! 410: * a SIGPIPE to be delivered in sosend() and we don't like that. ! 411: * If anyone else is sleeping on this socket, wake 'em up. ! 412: */ ! 413: void ! 414: tp_soisdisconnecting(so) ! 415: register struct socket *so; ! 416: { ! 417: soisdisconnecting(so); ! 418: so->so_state &= ~SS_CANTSENDMORE; ! 419: IFPERF(sototpcb(so)) ! 420: register struct tp_pcb *tpcb = sototpcb(so); ! 421: u_int fsufx, lsufx; ! 422: ! 423: bcopy ((caddr_t)tpcb->tp_fsuffix, (caddr_t)&fsufx, sizeof(u_int) ); ! 424: bcopy ((caddr_t)tpcb->tp_lsuffix, (caddr_t)&lsufx, sizeof(u_int) ); ! 425: ! 426: tpmeas(tpcb->tp_lref, TPtime_close, &time, fsufx, lsufx, tpcb->tp_fref); ! 427: tpcb->tp_perf_on = 0; /* turn perf off */ ! 428: ENDPERF ! 429: } ! 430: ! 431: ! 432: /* ! 433: * NAME: tp_soisdisconnected() ! 434: * ! 435: * CALLED FROM: ! 436: * tp.trans ! 437: * ! 438: * FUNCTION and ARGUMENTS: ! 439: * Set state of the socket (so) to reflect that fact that we're disconnectED ! 440: * Set the state of the reference structure to closed, and ! 441: * recycle the suffix. ! 442: * Start a reference timer. ! 443: * ! 444: * RETURNS: Nada ! 445: * ! 446: * SIDE EFFECTS: ! 447: * ! 448: * NOTES: ! 449: * This differs from the regular soisdisconnected() in that the latter ! 450: * also sets the SS_CANTRECVMORE and SS_CANTSENDMORE flags. ! 451: * We don't want to set those flags because those flags will cause ! 452: * a SIGPIPE to be delivered in sosend() and we don't like that. ! 453: * If anyone else is sleeping on this socket, wake 'em up. ! 454: */ ! 455: void ! 456: tp_soisdisconnected(tpcb) ! 457: register struct tp_pcb *tpcb; ! 458: { ! 459: register struct socket *so = tpcb->tp_sock; ! 460: ! 461: soisdisconnecting(so); ! 462: so->so_state &= ~SS_CANTSENDMORE; ! 463: IFPERF(sototpcb(so)) ! 464: register struct tp_pcb *ttpcb = sototpcb(so); ! 465: u_int fsufx, lsufx; ! 466: ! 467: /* CHOKE */ ! 468: bcopy ((caddr_t)ttpcb->tp_fsuffix, (caddr_t)&fsufx, sizeof(u_int) ); ! 469: bcopy ((caddr_t)ttpcb->tp_lsuffix, (caddr_t)&lsufx, sizeof(u_int) ); ! 470: ! 471: tpmeas(ttpcb->tp_lref, TPtime_close, ! 472: &time, &lsufx, &fsufx, ttpcb->tp_fref); ! 473: tpcb->tp_perf_on = 0; /* turn perf off */ ! 474: ENDPERF ! 475: ! 476: tpcb->tp_refp->tpr_state = REF_FROZEN; ! 477: tp_recycle_tsuffix( tpcb ); ! 478: tp_etimeout(tpcb->tp_refp, TM_reference, 0,0,0, (int)tpcb->tp_refer_ticks); ! 479: } ! 480: ! 481: int tp_maxrefopen; /* highest reference # of the set of open tp connections */ ! 482: ! 483: /* ! 484: * NAME: tp_freeref() ! 485: * ! 486: * CALLED FROM: ! 487: * tp.trans when the reference timer goes off, and ! 488: * from tp_attach() and tp_detach() when a tpcb is partially set up but not ! 489: * set up enough to have a ref timer set for it, and it's discarded ! 490: * due to some sort of error or an early close() ! 491: * ! 492: * FUNCTION and ARGUMENTS: ! 493: * Frees the reference represented by (r) for re-use. ! 494: * ! 495: * RETURNS: Nothing ! 496: * ! 497: * SIDE EFFECTS: ! 498: * ! 499: * NOTES: better be called at clock priority !!!!! ! 500: */ ! 501: void ! 502: tp_freeref(r) ! 503: register struct tp_ref *r; ! 504: { ! 505: IFDEBUG(D_TIMER) ! 506: printf("tp_freeref called for ref %d maxrefopen %d\n", ! 507: r - tp_ref, tp_maxrefopen); ! 508: ENDDEBUG ! 509: IFTRACE(D_TIMER) ! 510: tptrace(TPPTmisc, "tp_freeref ref tp_maxrefopen", ! 511: r - tp_ref, tp_maxrefopen, 0, 0); ! 512: ENDTRACE ! 513: r->tpr_state = REF_FREE; ! 514: IFDEBUG(D_CONN) ! 515: printf("tp_freeref: CLEARING tpr_pcb 0x%x\n", r->tpr_pcb); ! 516: ENDDEBUG ! 517: r->tpr_pcb = (struct tp_pcb *)0; ! 518: ! 519: r = &tp_ref[tp_maxrefopen]; ! 520: ! 521: while( tp_maxrefopen > 0 ) { ! 522: if(r->tpr_state ) ! 523: break; ! 524: tp_maxrefopen--; ! 525: r--; ! 526: } ! 527: IFDEBUG(D_TIMER) ! 528: printf("tp_freeref ends w/ maxrefopen %d\n", tp_maxrefopen); ! 529: ENDDEBUG ! 530: } ! 531: ! 532: /* ! 533: * NAME: tp_getref() ! 534: * ! 535: * CALLED FROM: ! 536: * tp_attach() ! 537: * ! 538: * FUNCTION and ARGUMENTS: ! 539: * obtains the next free reference and allocates the appropriate ! 540: * ref structure, links that structure to (tpcb) ! 541: * ! 542: * RETURN VALUE: ! 543: * a reference number ! 544: * or TP_ENOREF ! 545: * ! 546: * SIDE EFFECTS: ! 547: * ! 548: * NOTES: ! 549: */ ! 550: static RefNum ! 551: tp_getref(tpcb) ! 552: register struct tp_pcb *tpcb; ! 553: { ! 554: register struct tp_ref *r = tp_ref; /* tp_ref[0] is never used */ ! 555: register int i=1; ! 556: ! 557: ! 558: while ((++r)->tpr_state != REF_FREE) { ! 559: if (++i == N_TPREF) ! 560: return TP_ENOREF; ! 561: } ! 562: r->tpr_state = REF_OPENING; ! 563: if (tp_maxrefopen < i) ! 564: tp_maxrefopen = i; ! 565: r->tpr_pcb = tpcb; ! 566: tpcb->tp_refp = r; ! 567: ! 568: return i; ! 569: } ! 570: ! 571: /* ! 572: * NAME: tp_attach() ! 573: * ! 574: * CALLED FROM: ! 575: * tp_usrreq, PRU_ATTACH ! 576: * ! 577: * FUNCTION and ARGUMENTS: ! 578: * given a socket (so) and a protocol family (dom), allocate a tpcb ! 579: * and ref structure, initialize everything in the structures that ! 580: * needs to be initialized. ! 581: * ! 582: * RETURN VALUE: ! 583: * 0 ok ! 584: * EINVAL if DEBUG(X) in is on and a disaster has occurred ! 585: * ENOPROTOOPT if TP hasn't been configured or if the ! 586: * socket wasn't created with tp as its protocol ! 587: * EISCONN if this socket is already part of a connection ! 588: * ETOOMANYREFS if ran out of tp reference numbers. ! 589: * E* whatever error is returned from soreserve() ! 590: * for from the network-layer pcb allocation routine ! 591: * ! 592: * SIDE EFFECTS: ! 593: * ! 594: * NOTES: ! 595: */ ! 596: tp_attach(so, dom) ! 597: struct socket *so; ! 598: int dom; ! 599: { ! 600: register struct tp_pcb *tpcb; ! 601: int error; ! 602: int protocol = so->so_proto->pr_protocol; ! 603: extern struct tp_conn_param tp_conn_param[]; ! 604: ! 605: IFDEBUG(D_CONN) ! 606: printf("tp_attach:dom 0x%x so 0x%x ", dom, so); ! 607: ENDDEBUG ! 608: IFTRACE(D_CONN) ! 609: tptrace(TPPTmisc, "tp_attach:dom so", dom, so, 0, 0); ! 610: ENDTRACE ! 611: if ( ! tp_param.tpp_configed ) { ! 612: error = ENOPROTOOPT; /* protocol not available */ ! 613: goto bad2; ! 614: } ! 615: ! 616: if (so->so_pcb != NULL) { ! 617: return EISCONN; /* socket already part of a connection*/ ! 618: } ! 619: ! 620: error = soreserve(so, TP_SOCKBUFSIZE, TP_SOCKBUFSIZE); ! 621: /* later an ioctl will allow reallocation IF still in closed state */ ! 622: ! 623: if (error) ! 624: goto bad2; ! 625: ! 626: MALLOC(tpcb, struct tp_pcb *, sizeof(*tpcb), M_PCB, M_NOWAIT); ! 627: if (tpcb == NULL) { ! 628: error = ENOBUFS; ! 629: goto bad2; ! 630: } ! 631: bzero( (caddr_t)tpcb, sizeof (struct tp_pcb) ); ! 632: ! 633: if ( ((tpcb->tp_lref = tp_getref(tpcb)) & TP_ENOREF) != 0 ) { ! 634: error = ETOOMANYREFS; ! 635: goto bad3; ! 636: } ! 637: tpcb->tp_sock = so; ! 638: tpcb->tp_domain = dom; ! 639: if (protocol<ISOPROTO_TP4) { ! 640: tpcb->tp_netservice = ISO_CONS; ! 641: tpcb->tp_snduna = (SeqNum) -1;/* kludge so the pseudo-ack from the CR/CC ! 642: * will generate correct fake-ack values ! 643: */ ! 644: } else { ! 645: tpcb->tp_netservice = (dom== AF_INET)?IN_CLNS:ISO_CLNS; ! 646: /* the default */ ! 647: } ! 648: tpcb->_tp_param = tp_conn_param[tpcb->tp_netservice]; ! 649: ! 650: tpcb->tp_cong_win = 1; ! 651: tpcb->tp_state = TP_CLOSED; ! 652: tpcb->tp_vers = TP_VERSION; ! 653: ! 654: /* Spec says default is 128 octets, ! 655: * that is, if the tpdusize argument never appears, use 128. ! 656: * As the initiator, we will always "propose" the 2048 ! 657: * size, that is, we will put this argument in the CR ! 658: * always, but accept what the other side sends on the CC. ! 659: * If the initiator sends us something larger on a CR, ! 660: * we'll respond w/ this. ! 661: * Our maximum is 4096. See tp_chksum.c comments. ! 662: */ ! 663: tpcb->tp_l_tpdusize = 1 << tpcb->tp_tpdusize; ! 664: ! 665: tpcb->tp_seqmask = TP_NML_FMT_MASK; ! 666: tpcb->tp_seqbit = TP_NML_FMT_BIT; ! 667: tpcb->tp_seqhalf = tpcb->tp_seqbit >> 1; ! 668: tpcb->tp_sndhiwat = (SeqNum) - 1; /* a kludge but it works */ ! 669: tpcb->tp_s_subseq = 0; ! 670: ! 671: /* attach to a network-layer protoswitch */ ! 672: /* new way */ ! 673: tpcb->tp_nlproto = & nl_protosw[tpcb->tp_netservice]; ! 674: ASSERT( tpcb->tp_nlproto->nlp_afamily == tpcb->tp_domain); ! 675: #ifdef notdef ! 676: /* OLD WAY */ ! 677: /* TODO: properly, this search would be on the basis of ! 678: * domain,netservice or just netservice only (if you have ! 679: * IN_CLNS, ISO_CLNS, and ISO_CONS) ! 680: */ ! 681: tpcb->tp_nlproto = nl_protosw; ! 682: while(tpcb->tp_nlproto->nlp_afamily != tpcb->tp_domain ) { ! 683: if( tpcb->tp_nlproto->nlp_afamily == 0 ) { ! 684: error = EAFNOSUPPORT; ! 685: goto bad4; ! 686: } ! 687: tpcb->tp_nlproto ++; ! 688: } ! 689: #endif notdef ! 690: ! 691: /* xx_pcballoc sets so_pcb */ ! 692: if ( error = (tpcb->tp_nlproto->nlp_pcballoc) ( ! 693: so, tpcb->tp_nlproto->nlp_pcblist ) ) { ! 694: goto bad4; ! 695: } ! 696: ! 697: if( dom == AF_INET ) ! 698: sotoinpcb(so)->inp_ppcb = (caddr_t) tpcb; ! 699: /* nothing to do for iso case */ ! 700: ! 701: tpcb->tp_npcb = (caddr_t) so->so_pcb; ! 702: so->so_tpcb = (caddr_t) tpcb; ! 703: ! 704: return 0; ! 705: ! 706: bad4: ! 707: IFDEBUG(D_CONN) ! 708: printf("BAD4 in tp_attach, so 0x%x\n", so); ! 709: ENDDEBUG ! 710: tp_freeref(tpcb->tp_refp); ! 711: ! 712: bad3: ! 713: IFDEBUG(D_CONN) ! 714: printf("BAD3 in tp_attach, so 0x%x\n", so); ! 715: ENDDEBUG ! 716: ! 717: free((caddr_t)tpcb, M_PCB); /* never a cluster */ ! 718: ! 719: bad2: ! 720: IFDEBUG(D_CONN) ! 721: printf("BAD2 in tp_attach, so 0x%x\n", so); ! 722: ENDDEBUG ! 723: so->so_pcb = 0; ! 724: so->so_tpcb = 0; ! 725: ! 726: /*bad:*/ ! 727: IFDEBUG(D_CONN) ! 728: printf("BAD in tp_attach, so 0x%x\n", so); ! 729: ENDDEBUG ! 730: return error; ! 731: } ! 732: ! 733: /* ! 734: * NAME: tp_detach() ! 735: * ! 736: * CALLED FROM: ! 737: * tp.trans, on behalf of a user close request ! 738: * and when the reference timer goes off ! 739: * (if the disconnect was initiated by the protocol entity ! 740: * rather than by the user) ! 741: * ! 742: * FUNCTION and ARGUMENTS: ! 743: * remove the tpcb structure from the list of active or ! 744: * partially active connections, recycle all the mbufs ! 745: * associated with the pcb, ref structure, sockbufs, etc. ! 746: * Only free the ref structure if you know that a ref timer ! 747: * wasn't set for this tpcb. ! 748: * ! 749: * RETURNS: Nada ! 750: * ! 751: * SIDE EFFECTS: ! 752: * ! 753: * NOTES: ! 754: * tp_soisdisconnected() was already when this is called ! 755: */ ! 756: void ! 757: tp_detach(tpcb) ! 758: register struct tp_pcb *tpcb; ! 759: { ! 760: void tp_freeref(); ! 761: register struct socket *so = tpcb->tp_sock; ! 762: ! 763: IFDEBUG(D_CONN) ! 764: printf("tp_detach(tpcb 0x%x, so 0x%x)\n", ! 765: tpcb,so); ! 766: ENDDEBUG ! 767: IFTRACE(D_CONN) ! 768: tptraceTPCB(TPPTmisc, "tp_detach tpcb so lsufx", ! 769: tpcb, so, *(u_short *)(tpcb->tp_lsuffix), 0); ! 770: ENDTRACE ! 771: ! 772: if (so->so_head) { ! 773: if (!soqremque(so, 0) && !soqremque(so, 1)) ! 774: panic("sofree dq"); ! 775: so->so_head = 0; ! 776: } ! 777: ! 778: IFDEBUG(D_CONN) ! 779: printf("tp_detach(freeing RTC list snduna 0x%x rcvnxt 0x%x)\n", ! 780: tpcb->tp_snduna_rtc, ! 781: tpcb->tp_rcvnxt_rtc); ! 782: ENDDEBUG ! 783: ! 784: #define FREE_RTC_LIST(XXX)\ ! 785: { register struct tp_rtc *xxr = XXX, *xxs; while (xxr) {\ ! 786: xxs = xxr->tprt_next;\ ! 787: m_freem( xxr->tprt_data );\ ! 788: m_free( dtom(xxr) ); xxr = xxs; }\ ! 789: XXX = (struct tp_rtc *)0;\ ! 790: } ! 791: ! 792: FREE_RTC_LIST( tpcb->tp_snduna_rtc ); ! 793: tpcb->tp_sndhiwat_rtc = (struct tp_rtc *)0; ! 794: ! 795: FREE_RTC_LIST( tpcb->tp_rcvnxt_rtc ); ! 796: ! 797: #undef FREE_RTC_LIST ! 798: ! 799: IFDEBUG(D_CONN) ! 800: printf("so_snd at 0x%x so_rcv at 0x%x\n", &so->so_snd, &so->so_rcv); ! 801: dump_mbuf(so->so_snd.sb_mb, "so_snd at detach "); ! 802: printf("about to call LL detach, nlproto 0x%x, nl_detach 0x%x\n", ! 803: tpcb->tp_nlproto, tpcb->tp_nlproto->nlp_pcbdetach); ! 804: ENDDEBUG ! 805: ! 806: if (so->so_snd.sb_cc != 0) ! 807: sbflush(&so->so_snd); ! 808: if (tpcb->tp_Xrcv.sb_cc != 0) ! 809: sbdrop(&tpcb->tp_Xrcv, (int)tpcb->tp_Xrcv.sb_cc); ! 810: if (tpcb->tp_ucddata) ! 811: m_freem(tpcb->tp_ucddata); ! 812: ! 813: IFDEBUG(D_CONN) ! 814: printf("calling (...nlproto->...)(0x%x, so 0x%x)\n", ! 815: so->so_pcb, so); ! 816: printf("so 0x%x so_head 0x%x, qlen %d q0len %d qlimit %d\n", ! 817: so, so->so_head, ! 818: so->so_q0len, so->so_qlen, so->so_qlimit); ! 819: ENDDEBUG ! 820: ! 821: ! 822: (tpcb->tp_nlproto->nlp_pcbdetach)(so->so_pcb); ! 823: /* does an sofree(so) */ ! 824: ! 825: IFDEBUG(D_CONN) ! 826: printf("after xxx_pcbdetach\n"); ! 827: ENDDEBUG ! 828: ! 829: if( tpcb->tp_refp->tpr_state == REF_OPENING ) { ! 830: /* no connection existed here so no reference timer will be called */ ! 831: IFDEBUG(D_CONN) ! 832: printf("SETTING ref %d, 0x%x to REF_FREE\n", tpcb->tp_lref, ! 833: tpcb->tp_refp - &tp_ref[0]); ! 834: ENDDEBUG ! 835: ! 836: tp_freeref(tpcb->tp_refp); ! 837: } ! 838: ! 839: if (tpcb->tp_Xsnd.sb_mb) { ! 840: printf("Unsent Xdata on detach; would panic"); ! 841: sbflush(&tpcb->tp_Xsnd); ! 842: } ! 843: so->so_tpcb = (caddr_t)0; ! 844: ! 845: /* ! 846: * Get rid of the cluster mbuf allocated for performance measurements, if ! 847: * there is one. Note that tpcb->tp_perf_on says nothing about whether or ! 848: * not a cluster mbuf was allocated, so you have to check for a pointer ! 849: * to one (that is, we need the TP_PERF_MEASs around the following section ! 850: * of code, not the IFPERFs) ! 851: */ ! 852: #ifdef TP_PERF_MEAS ! 853: if (tpcb->tp_p_mbuf) { ! 854: register struct mbuf *m = tpcb->tp_p_mbuf; ! 855: struct mbuf *n; ! 856: IFDEBUG(D_PERF_MEAS) ! 857: printf("freeing tp_p_meas 0x%x ", tpcb->tp_p_meas); ! 858: ENDDEBUG ! 859: do { ! 860: MFREE(m, n); ! 861: m = n; ! 862: } while (n); ! 863: tpcb->tp_p_meas = 0; ! 864: tpcb->tp_p_mbuf = 0; ! 865: } ! 866: #endif TP_PERF_MEAS ! 867: ! 868: IFDEBUG(D_CONN) ! 869: printf( "end of detach, NOT single, tpcb 0x%x\n", tpcb); ! 870: ENDDEBUG ! 871: /* free((caddr_t)tpcb, M_PCB); WHere to put this ? */ ! 872: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.