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