![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to tp_output.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_output.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_output.c 7.10 (Berkeley) 6/27/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: *
1.1.1.2 ! root 65: * $Header: /cvsroot/src/sys/netiso/tp_output.c,v 1.1 1993/04/09 12:01:41 cgd Exp $
! 66: * $Source: /cvsroot/src/sys/netiso/tp_output.c,v $
1.1 root 67: *
68: * In here is tp_ctloutput(), the guy called by [sg]etsockopt(),
69: */
70:
71: #include "param.h"
72: #include "mbuf.h"
73: #include "systm.h"
74: #include "socket.h"
75: #include "socketvar.h"
76: #include "protosw.h"
77: #include "errno.h"
78: #include "time.h"
79: #include "tp_param.h"
80: #include "tp_user.h"
81: #include "tp_stat.h"
82: #include "tp_ip.h"
83: #include "tp_clnp.h"
84: #include "tp_timer.h"
85: #include "argo_debug.h"
86: #include "tp_pcb.h"
87: #include "tp_trace.h"
88: #include "kernel.h"
89:
90: #define USERFLAGSMASK_G 0x0f00643b
91: #define USERFLAGSMASK_S 0x0f000432
92: #define TPDUSIZESHIFT 24
93: #define CLASSHIFT 16
94:
95: /*
96: * NAME: tp_consistency()
97: *
98: * CALLED FROM:
99: * tp_ctloutput(), tp_input()
100: *
101: * FUNCTION and ARGUMENTS:
102: * Checks the consistency of options and tpdusize with class,
103: * using the parameters passed in via (param).
104: * (cmd) may be TP_STRICT or TP_FORCE or both.
105: * Force means it will set all the values in (tpcb) to those in
106: * the input arguements iff no errors were encountered.
107: * Strict means that no inconsistency will be tolerated. If it's
108: * not used, checksum and tpdusize inconsistencies will be tolerated.
109: * The reason for this is that in some cases, when we're negotiating down
110: * from class 4, these options should be changed but should not
111: * cause negotiation to fail.
112: *
113: * RETURNS
114: * E* or EOK
115: * E* if the various parms aren't ok for a given class
116: * EOK if they are ok for a given class
117: */
118:
119: int
120: tp_consistency( tpcb, cmd, param )
121: u_int cmd;
122: struct tp_conn_param *param;
123: struct tp_pcb *tpcb;
124: {
125: register int error = EOK;
126: int class_to_use = tp_mask_to_num(param->p_class);
127:
128: IFTRACE(D_SETPARAMS)
129: tptrace(TPPTmisc,
130: "tp_consist enter class_to_use dontchange param.class cmd",
131: class_to_use, param->p_dont_change_params, param->p_class, cmd);
132: ENDTRACE
133: IFDEBUG(D_SETPARAMS)
134: printf("tp_consistency %s %s\n",
135: cmd& TP_FORCE? "TP_FORCE": "",
136: cmd& TP_STRICT? "TP_STRICT":"");
137: ENDDEBUG
138: if ((cmd & TP_FORCE) && (param->p_dont_change_params)) {
139: cmd &= ~TP_FORCE;
140: }
141: /* can switch net services within a domain, but
142: * cannot switch domains
143: */
144: switch( param->p_netservice) {
145: case ISO_CONS:
146: case ISO_CLNS:
147: case ISO_COSNS:
148: /* param->p_netservice in ISO DOMAIN */
149: if(tpcb->tp_domain != AF_ISO ) {
150: error = EINVAL; goto done;
151: }
152: break;
153: case IN_CLNS:
154: /* param->p_netservice in INET DOMAIN */
155: if( tpcb->tp_domain != AF_INET ) {
156: error = EINVAL; goto done;
157: }
158: break;
159: /* no others not possible-> netservice is a 2-bit field! */
160: }
161:
162: IFDEBUG(D_SETPARAMS)
163: printf("p_class 0x%x, class_to_use 0x%x\n", param->p_class,
164: class_to_use);
165: ENDDEBUG
166: if((param->p_netservice < 0) || (param->p_netservice > TP_MAX_NETSERVICES)){
167: error = EINVAL; goto done;
168: }
169: if( (param->p_class & TP_CLASSES_IMPLEMENTED) == 0 ) {
170: error = EINVAL; goto done;
171: }
172: IFDEBUG(D_SETPARAMS)
173: printf("Nretrans 0x%x\n", param->p_Nretrans );
174: ENDDEBUG
175: if( ( param->p_Nretrans < 1 ) ||
176: (param->p_cr_ticks < 1) || (param->p_cc_ticks < 1) ) {
177: /* bad for any class because negot has to be done a la class 4 */
178: error = EINVAL; goto done;
179: }
180: IFDEBUG(D_SETPARAMS)
181: printf("winsize 0x%x\n", param->p_winsize );
182: ENDDEBUG
183: if( (param->p_winsize < 128 ) ||
184: (param->p_winsize < param->p_tpdusize ) ||
185: (param->p_winsize > ((1+SB_MAX)>>2 /* 1/4 of the max */)) ) {
186: error = EINVAL; goto done;
187: } else {
188: if( tpcb->tp_state == TP_CLOSED )
189: soreserve(tpcb->tp_sock, (u_long)param->p_winsize,
190: (u_long)param->p_winsize);
191: }
192: IFDEBUG(D_SETPARAMS)
193: printf("use_csum 0x%x\n", param->p_use_checksum );
194: printf("xtd_format 0x%x\n", param->p_xtd_format );
195: printf("xpd_service 0x%x\n", param->p_xpd_service );
196: printf("tpdusize 0x%x\n", param->p_tpdusize );
197: printf("tpcb->flags 0x%x\n", tpcb->tp_flags );
198: ENDDEBUG
199: switch( class_to_use ) {
200:
201: case 0:
202: /* do not use checksums, xtd format, or XPD */
203:
204: if( param->p_use_checksum | param->p_xtd_format | param->p_xpd_service ) {
205: if(cmd & TP_STRICT) {
206: error = EINVAL;
207: } else {
208: param->p_use_checksum = 0;
209: param->p_xtd_format = 0;
210: param->p_xpd_service = 0;
211: }
212: break;
213: }
214:
215: if (param->p_tpdusize < TP_MIN_TPDUSIZE) {
216: if(cmd & TP_STRICT) {
217: error = EINVAL;
218: } else {
219: param->p_tpdusize = TP_MIN_TPDUSIZE;
220: }
221: break;
222: }
223: if (param->p_tpdusize > TP0_TPDUSIZE) {
224: if (cmd & TP_STRICT) {
225: error = EINVAL;
226: } else {
227: param->p_tpdusize = TP0_TPDUSIZE;
228: }
229: break;
230: }
231:
232: /* connect/disc data not allowed for class 0 */
233: if (tpcb->tp_ucddata) {
234: if(cmd & TP_STRICT) {
235: error = EINVAL;
236: } else if(cmd & TP_FORCE) {
237: m_freem(tpcb->tp_ucddata);
238: tpcb->tp_ucddata = 0;
239: }
240: }
241: break;
242:
243: case 4:
244: IFDEBUG(D_SETPARAMS)
245: printf("dt_ticks 0x%x\n", param->p_dt_ticks );
246: printf("x_ticks 0x%x\n", param->p_x_ticks );
247: printf("dr_ticks 0x%x\n", param->p_dr_ticks );
248: printf("keepalive 0x%x\n", param->p_keepalive_ticks );
249: printf("sendack 0x%x\n", param->p_sendack_ticks );
250: printf("inact 0x%x\n", param->p_inact_ticks );
251: printf("ref 0x%x\n", param->p_ref_ticks );
252: ENDDEBUG
253: if( (param->p_class & TP_CLASS_4 ) && (
254: (param->p_dt_ticks < 1) || (param->p_dr_ticks < 1) ||
255: (param->p_x_ticks < 1) || (param->p_keepalive_ticks < 1) ||
256: (param->p_sendack_ticks < 1) || (param->p_ref_ticks < 1) ||
257: (param->p_inact_ticks < 1) ) ) {
258: error = EINVAL;
259: break;
260: }
261: IFDEBUG(D_SETPARAMS)
262: printf("rx_strat 0x%x\n", param->p_rx_strat );
263: ENDDEBUG
264: if(param->p_rx_strat >
265: ( TPRX_USE_CW | TPRX_EACH | TPRX_FASTSTART) ) {
266: if(cmd & TP_STRICT) {
267: error = EINVAL;
268: } else {
269: param->p_rx_strat = TPRX_USE_CW;
270: }
271: break;
272: }
273: IFDEBUG(D_SETPARAMS)
274: printf("ack_strat 0x%x\n", param->p_ack_strat );
275: ENDDEBUG
276: if((param->p_ack_strat != 0) && (param->p_ack_strat != 1)) {
277: if(cmd & TP_STRICT) {
278: error = EINVAL;
279: } else {
280: param->p_ack_strat = TPACK_WINDOW;
281: }
282: break;
283: }
284: if (param->p_tpdusize < TP_MIN_TPDUSIZE) {
285: if(cmd & TP_STRICT) {
286: error = EINVAL;
287: } else {
288: param->p_tpdusize = TP_MIN_TPDUSIZE;
289: }
290: break;
291: }
292: if (param->p_tpdusize > TP_TPDUSIZE) {
293: if(cmd & TP_STRICT) {
294: error = EINVAL;
295: } else {
296: param->p_tpdusize = TP_TPDUSIZE;
297: }
298: break;
299: }
300: break;
301: }
302:
303: if ((error==0) && (cmd & TP_FORCE)) {
304: /* Enforce Negotation rules below */
305: if (tpcb->tp_tpdusize > param->p_tpdusize)
306: tpcb->tp_tpdusize = param->p_tpdusize;
307: tpcb->tp_class = param->p_class;
308: if (tpcb->tp_use_checksum || param->p_use_checksum)
309: tpcb->tp_use_checksum = 1;
310: if (!tpcb->tp_xpd_service || !param->p_xpd_service)
311: tpcb->tp_xpd_service = 0;
312: if (!tpcb->tp_xtd_format || !param->p_xtd_format)
313: tpcb->tp_xtd_format = 0;
314: }
315:
316: done:
317:
318: IFTRACE(D_CONN)
319: tptrace(TPPTmisc, "tp_consist returns class xtdfmt cmd",
320: error, tpcb->tp_class, tpcb->tp_xtd_format, cmd);
321: ENDTRACE
322: IFDEBUG(D_CONN)
323: printf(
324: "tp_consist rtns 0x%x class 0x%x xtd_fmt 0x%x cmd 0x%x\n",
325: error, tpcb->tp_class, tpcb->tp_xtd_format, cmd);
326: ENDDEBUG
327: return error;
328: }
329:
330: /*
331: * NAME: tp_ctloutput()
332: *
333: * CALLED FROM:
334: * [sg]etsockopt(), via so[sg]etopt().
335: *
336: * FUNCTION and ARGUMENTS:
337: * Implements the socket options at transport level.
338: * (cmd) is either PRCO_SETOPT or PRCO_GETOPT (see ../sys/protosw.h).
339: * (so) is the socket.
340: * (level) is SOL_TRANSPORT (see ../sys/socket.h)
341: * (optname) is the particular command or option to be set.
342: * (**mp) is an mbuf structure.
343: *
344: * RETURN VALUE:
345: * ENOTSOCK if the socket hasn't got an associated tpcb
346: * EINVAL if
347: * trying to set window too big
348: * trying to set illegal max tpdu size
349: * trying to set illegal credit fraction
350: * trying to use unknown or unimplemented class of TP
351: * structure passed to set timer values is wrong size
352: * illegal combination of command/GET-SET option,
353: * e.g., GET w/ TPOPT_CDDATA_CLEAR:
354: * EOPNOTSUPP if the level isn't transport, or command is neither GET nor SET
355: * or if the transport-specific command is not implemented
356: * EISCONN if trying a command that isn't allowed after a connection
357: * is established
358: * ENOTCONN if trying a command that is allowed only if a connection is
359: * established
360: * EMSGSIZE if trying to give too much data on connect/disconnect
361: *
362: * SIDE EFFECTS:
363: *
364: * NOTES:
365: */
366: ProtoHook
367: tp_ctloutput(cmd, so, level, optname, mp)
368: int cmd, level, optname;
369: struct socket *so;
370: struct mbuf **mp;
371: {
372: struct tp_pcb *tpcb = sototpcb(so);
373: int s = splnet();
374: caddr_t value;
375: unsigned val_len;
376: int error = 0;
377:
378: IFTRACE(D_REQUEST)
379: tptrace(TPPTmisc, "tp_ctloutput cmd so optname mp",
380: cmd, so, optname, mp);
381: ENDTRACE
382: IFDEBUG(D_REQUEST)
383: printf(
384: "tp_ctloutput so 0x%x cmd 0x%x optname 0x%x, mp 0x%x *mp 0x%x tpcb 0x%x\n",
385: so, cmd, optname, mp, mp?*mp:0, tpcb);
386: ENDDEBUG
387: if( tpcb == (struct tp_pcb *)0 ) {
388: error = ENOTSOCK; goto done;
389: }
390: if(*mp == MNULL) {
391: register struct mbuf *m;
392:
393: MGET(m, M_DONTWAIT, TPMT_SONAME); /* does off, type, next */
394: if (m == NULL) {
395: splx(s);
396: return ENOBUFS;
397: }
398: m->m_len = 0;
399: m->m_act = 0;
400: *mp = m;
401: }
402:
403: /*
404: * Hook so one can set network options via a tp socket.
405: */
406: if ( level == SOL_NETWORK ) {
407: if ((tpcb->tp_nlproto == NULL) || (tpcb->tp_npcb == NULL))
408: error = ENOTSOCK;
409: else if (tpcb->tp_nlproto->nlp_ctloutput == NULL)
410: error = EOPNOTSUPP;
411: else
412: error = (tpcb->tp_nlproto->nlp_ctloutput)(cmd, optname,
413: tpcb->tp_npcb, *mp);
414: goto done;
415: } else if ( level != SOL_TRANSPORT ) {
416: error = EOPNOTSUPP; goto done;
417: }
418: if (cmd != PRCO_GETOPT && cmd != PRCO_SETOPT) {
419: error = EOPNOTSUPP; goto done;
420: }
421: if ( so->so_error ) {
422: error = so->so_error; goto done;
423: }
424:
425: /* The only options allowed after connection is established
426: * are GET (anything) and SET DISC DATA and SET PERF MEAS
427: */
428: if ( ((so->so_state & SS_ISCONNECTING)||(so->so_state & SS_ISCONNECTED))
429: &&
430: (cmd == PRCO_SETOPT &&
431: optname != TPOPT_DISC_DATA &&
432: optname != TPOPT_CFRM_DATA &&
433: optname != TPOPT_PERF_MEAS &&
434: optname != TPOPT_CDDATA_CLEAR ) ) {
435: error = EISCONN; goto done;
436: }
437: /* The only options allowed after disconnection are GET DISC DATA,
438: * and TPOPT_PSTATISTICS
439: * and they're not allowed if the ref timer has gone off, because
440: * the tpcb is gone
441: */
442: if ((so->so_state & (SS_ISCONNECTED | SS_ISCONFIRMING)) == 0) {
443: if ( so->so_tpcb == (caddr_t)0 ) {
444: error = ENOTCONN; goto done;
445: }
446: if ( (tpcb->tp_state == TP_REFWAIT || tpcb->tp_state == TP_CLOSING) &&
447: (optname != TPOPT_DISC_DATA && optname != TPOPT_PSTATISTICS)) {
448: error = ENOTCONN; goto done;
449: }
450: }
451:
452: value = mtod(*mp, caddr_t); /* it's aligned, don't worry,
453: * but lint complains about it
454: */
455: val_len = (*mp)->m_len;
456:
457: switch (optname) {
458:
459: case TPOPT_INTERCEPT:
460: if ((so->so_state & SS_PRIV) == 0) {
461: error = EPERM;
462: break;
463: } else if (cmd != PRCO_SETOPT || tpcb->tp_state != TP_LISTENING)
464: error = EINVAL;
465: else {
466: register struct tp_pcb *t = 0;
467: struct mbuf *m = m_getclr(M_WAIT, MT_SONAME);
468: struct sockaddr *sa = mtod(m, struct sockaddr *);
469: (*tpcb->tp_nlproto->nlp_getnetaddr)(tpcb->tp_npcb, m, TP_LOCAL);
470: switch (sa->sa_family) {
471: case AF_ISO:
472: if (((struct sockaddr_iso *)sa)->siso_nlen == 0)
473: default: error = EINVAL;
474: break;
475: case AF_INET:
476: if (((struct sockaddr_in *)sa)->sin_addr.s_addr == 0)
477: error = EINVAL;
478: break;
479: }
480: for (t = tp_intercepts; t; t = t->tp_nextlisten) {
481: if (t->tp_nlproto->nlp_afamily != tpcb->tp_nlproto->nlp_afamily)
482: continue;
483: if ((*t->tp_nlproto->nlp_cmpnetaddr)(t->tp_npcb, sa, TP_LOCAL))
484: error = EADDRINUSE;
485: }
486: m_freem(m);
487: if (error)
488: break;
489: }
490: {
491: register struct tp_pcb **tt;
492: for (tt = &tp_listeners; *tt; tt = &((*tt)->tp_nextlisten))
493: if (*tt == tpcb)
494: break;
495: if (*tt)
496: *tt = tpcb->tp_nextlisten;
497: else
498: {error = EHOSTUNREACH; goto done; }
499: }
500: tpcb->tp_nextlisten = tp_intercepts;
501: tp_intercepts = tpcb;
502: break;
503:
504: case TPOPT_MY_TSEL:
505: if ( cmd == PRCO_GETOPT ) {
506: ASSERT( tpcb->tp_lsuffixlen <= MAX_TSAP_SEL_LEN );
507: bcopy((caddr_t)tpcb->tp_lsuffix, value, tpcb->tp_lsuffixlen);
508: (*mp)->m_len = tpcb->tp_lsuffixlen;
509: } else /* cmd == PRCO_SETOPT */ {
510: if( (val_len > MAX_TSAP_SEL_LEN) || (val_len <= 0 )) {
511: printf("val_len 0x%x (*mp)->m_len 0x%x\n", val_len, (*mp));
512: error = EINVAL;
513: } else {
514: bcopy(value, (caddr_t)tpcb->tp_lsuffix, val_len);
515: tpcb->tp_lsuffixlen = val_len;
516: }
517: }
518: break;
519:
520: case TPOPT_PEER_TSEL:
521: if ( cmd == PRCO_GETOPT ) {
522: ASSERT( tpcb->tp_fsuffixlen <= MAX_TSAP_SEL_LEN );
523: bcopy((caddr_t)tpcb->tp_fsuffix, value, tpcb->tp_fsuffixlen);
524: (*mp)->m_len = tpcb->tp_fsuffixlen;
525: } else /* cmd == PRCO_SETOPT */ {
526: if( (val_len > MAX_TSAP_SEL_LEN) || (val_len <= 0 )) {
527: printf("val_len 0x%x (*mp)->m_len 0x%x\n", val_len, (*mp));
528: error = EINVAL;
529: } else {
530: bcopy(value, (caddr_t)tpcb->tp_fsuffix, val_len);
531: tpcb->tp_fsuffixlen = val_len;
532: }
533: }
534: break;
535:
536: case TPOPT_FLAGS:
537: IFDEBUG(D_REQUEST)
538: printf("%s TPOPT_FLAGS value 0x%x *value 0x%x, flags 0x%x \n",
539: cmd==PRCO_GETOPT?"GET":"SET",
540: value,
541: *value,
542: tpcb->tp_flags);
543: ENDDEBUG
544:
545: if ( cmd == PRCO_GETOPT ) {
546: *(int *)value = (int)tpcb->tp_flags;
547: (*mp)->m_len = sizeof(u_int);
548: } else /* cmd == PRCO_SETOPT */ {
549: error = EINVAL; goto done;
550: }
551: break;
552:
553: case TPOPT_PARAMS:
554: /* This handles:
555: * timer values,
556: * class, use of transport expedited data,
557: * max tpdu size, checksum, xtd format and
558: * disconnect indications, and may get rid of connect/disc data
559: */
560: IFDEBUG(D_SETPARAMS)
561: printf("TPOPT_PARAMS value 0x%x, cmd %s \n", value,
562: cmd==PRCO_GETOPT?"GET":"SET");
563: ENDDEBUG
564: IFDEBUG(D_REQUEST)
565: printf("TPOPT_PARAMS value 0x%x, cmd %s \n", value,
566: cmd==PRCO_GETOPT?"GET":"SET");
567: ENDDEBUG
568:
569: if ( cmd == PRCO_GETOPT ) {
570: *(struct tp_conn_param *)value = tpcb->_tp_param;
571: (*mp)->m_len = sizeof(tpcb->_tp_param);
572: } else /* cmd == PRCO_SETOPT */ {
573: if( (error =
574: tp_consistency(tpcb, TP_STRICT | TP_FORCE,
575: (struct tp_conn_param *)value))==0) {
576: /*
577: * tp_consistency doesn't copy the whole set of params
578: */
579: tpcb->_tp_param = *(struct tp_conn_param *)value;
580: (*mp)->m_len = sizeof(tpcb->_tp_param);
581: }
582: }
583: break;
584:
585: case TPOPT_PSTATISTICS:
586: #ifdef TP_PERF_MEAS
587: if (cmd == PRCO_SETOPT) {
588: error = EINVAL; goto done;
589: }
590: IFPERF(tpcb)
591: if (*mp) {
592: struct mbuf * n;
593: do {
594: MFREE(*mp, n);
595: *mp = n;
596: } while (n);
597: }
598: *mp = m_copym(tpcb->tp_p_mbuf, (int)M_COPYALL, M_WAITOK);
599: ENDPERF
600: else {
601: error = EINVAL; goto done;
602: }
603: break;
604: #else
605: error = EOPNOTSUPP;
606: goto done;
607: #endif TP_PERF_MEAS
608:
609: case TPOPT_CDDATA_CLEAR:
610: if (cmd == PRCO_GETOPT) {
611: error = EINVAL;
612: } else {
613: if (tpcb->tp_ucddata) {
614: m_freem(tpcb->tp_ucddata);
615: tpcb->tp_ucddata = 0;
616: }
617: }
618: break;
619:
620: case TPOPT_CFRM_DATA:
621: case TPOPT_DISC_DATA:
622: case TPOPT_CONN_DATA:
623: if( tpcb->tp_class == TP_CLASS_0 ) {
624: error = EOPNOTSUPP;
625: break;
626: }
627: IFDEBUG(D_REQUEST)
628: printf("%s\n", optname==TPOPT_DISC_DATA?"DISC data":"CONN data");
629: printf("m_len 0x%x, vallen 0x%x so_snd.cc 0x%x\n",
630: (*mp)->m_len, val_len, so->so_snd.sb_cc);
631: dump_mbuf(so->so_snd.sb_mb, "tp_ctloutput: sosnd ");
632: ENDDEBUG
633: if (cmd == PRCO_SETOPT) {
634: int len = tpcb->tp_ucddata ? tpcb->tp_ucddata->m_len : 0;
635: /* can append connect data in several calls */
636: if (len + val_len >
637: (optname==TPOPT_CONN_DATA?TP_MAX_CR_DATA:TP_MAX_DR_DATA) ) {
638: error = EMSGSIZE; goto done;
639: }
640: (*mp)->m_next = MNULL;
641: (*mp)->m_act = 0;
642: if (tpcb->tp_ucddata)
643: m_cat(tpcb->tp_ucddata, *mp);
644: else
645: tpcb->tp_ucddata = *mp;
646: IFDEBUG(D_REQUEST)
647: dump_mbuf(tpcb->tp_ucddata, "tp_ctloutput after CONN_DATA");
648: ENDDEBUG
649: IFTRACE(D_REQUEST)
650: tptrace(TPPTmisc,"C/D DATA: flags snd.sbcc val_len",
651: tpcb->tp_flags, so->so_snd.sb_cc,val_len,0);
652: ENDTRACE
653: *mp = MNULL; /* prevent sosetopt from freeing it! */
654: if (optname == TPOPT_CFRM_DATA && (so->so_state & SS_ISCONFIRMING))
655: (void) tp_confirm(tpcb);
656: }
657: break;
658:
659: case TPOPT_PERF_MEAS:
660: #ifdef TP_PERF_MEAS
661: if (cmd == PRCO_GETOPT) {
662: *value = (u_int)tpcb->tp_perf_on;
663: (*mp)->m_len = sizeof(u_int);
664: } else if (cmd == PRCO_SETOPT) {
665: (*mp)->m_len = 0;
666: if ((*value) != 0 && (*value) != 1 )
667: error = EINVAL;
668: else tpcb->tp_perf_on = (*value);
669: }
670: if( tpcb->tp_perf_on )
671: error = tp_setup_perf(tpcb);
672: #else TP_PERF_MEAS
673: error = EOPNOTSUPP;
674: #endif TP_PERF_MEAS
675: break;
676:
677: default:
678: error = EOPNOTSUPP;
679: }
680:
681: done:
682: IFDEBUG(D_REQUEST)
683: dump_mbuf(so->so_snd.sb_mb, "tp_ctloutput sosnd at end");
684: dump_mbuf(*mp, "tp_ctloutput *mp");
685: ENDDEBUG
686: /*
687: * sigh: getsockopt looks only at m_len : all output data must
688: * reside in the first mbuf
689: */
690: if ( error && (*mp) != MNULL )
691: (*mp)->m_len = 0;
692: if( (*mp) != MNULL ) {
693: ASSERT ( m_compress(*mp, mp) <= MLEN );
694: IFDEBUG(D_REQUEST)
695: dump_mbuf(*mp, "tp_ctloutput *mp after compress");
696: ENDDEBUG
697: }
698:
699: splx(s);
700: return error;
701: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.