![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to conn_request.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [CSRG BSD Unix] / 43BSDReno / contrib / isode-beta / quipu|
Return to conn_request.c CVS log | Up to [CSRG BSD Unix] / 43BSDReno / contrib / isode-beta / quipu |
1.1 root 1: /* conn_request.c - Generate DSP BIND from connection block */
2:
3: #ifndef lint
4: static char *rcsid = "$Header: /f/osi/quipu/RCS/conn_request.c,v 7.4 90/07/09 14:45:28 mrose Exp $";
5: #endif
6:
7: /*
8: * $Header: /f/osi/quipu/RCS/conn_request.c,v 7.4 90/07/09 14:45:28 mrose Exp $
9: *
10: *
11: * $Log: conn_request.c,v $
12: * Revision 7.4 90/07/09 14:45:28 mrose
13: * sync
14: *
15: * Revision 7.3 89/12/19 16:20:06 mrose
16: * sync
17: *
18: * Revision 7.2 89/11/27 10:30:09 mrose
19: * sync
20: *
21: * Revision 7.1 89/11/24 16:21:56 mrose
22: * sync
23: *
24: * Revision 7.0 89/11/23 22:16:55 mrose
25: * Release 6.0
26: *
27: */
28:
29: /*
30: * NOTICE
31: *
32: * Acquisition, use, and distribution of this module and related
33: * materials are subject to the restrictions of a license agreement.
34: * Consult the Preface in the User's Manual for the full terms of
35: * this agreement.
36: *
37: */
38:
39:
40: /* LINTLIBRARY */
41:
42: #include "quipu/dsap.h"
43: #include "tsap.h"
44: #include "quipu/util.h"
45: #include "quipu/connection.h"
46:
47: extern time_t timenow;
48:
49: struct connection * conn_alloc();
50: void conn_free();
51:
52: extern LLog * log_dsap;
53: #ifndef NO_STATS
54: extern LLog * log_stat;
55: extern int dn_print();
56: #endif
57:
58: extern PS opt;
59: extern unsigned watchdog_time;
60: extern unsigned watchdog_delta;
61:
62: /*
63: * conn_request uses the directory bind argument and context
64: * set up in the connection block to generate an asynchronous
65: * association request.
66: * If OK is returned the connection should be linked onto
67: * the global list.
68: * If NOTOK is returned the connection block should be freed,
69: * alerting all the operations requesting it.
70: */
71: conn_request(cn)
72: register struct connection * cn;
73: {
74: struct DSAPconnect dc_s;
75: struct DSAPconnect *dc = &dc_s;
76: struct DSAPindication di_s;
77: struct DSAPindication * di = &(di_s);
78: int inv_ret;
79:
80: DLOG(log_dsap, LLOG_TRACE, ("conn_request()"));
81: LLOG(log_dsap, LLOG_NOTICE, ("conn_request: Calling: %s", paddr2str(&(cn->cn_addr),NULLNA)));
82:
83: switch(cn->cn_ctx)
84: {
85: case DS_CTX_X500_DAP:
86: LLOG(log_dsap, LLOG_EXCEPTIONS, ("Making DAP connections illegal for DSA"));
87: return(NOTOK);
88:
89: case DS_CTX_X500_DSP:
90: LLOG(log_dsap, LLOG_TRACE, ("Making an X500 DSP connection"));
91: watch_dog ("DspAsynBindRequest");
92: inv_ret = DspAsynBindRequest (&(cn->cn_addr), &(cn->cn_connect.cc_req),
93: (int) (watchdog_time - watchdog_delta), dc, di, ROS_ASYNC);
94: watch_dog_reset ();
95: break;
96:
97: case DS_CTX_QUIPU_DSP:
98: LLOG(log_dsap, LLOG_TRACE, ("Making a QUIPU DSP connection"));
99: watch_dog ("QspAsynBindRequest");
100: inv_ret = QspAsynBindRequest (&(cn->cn_addr),
101: &(cn->cn_connect.cc_req),
102: (int) (watchdog_time - watchdog_delta), dc, di, ROS_ASYNC);
103: watch_dog_reset ();
104: break;
105:
106: default:
107: LLOG(log_dsap, LLOG_EXCEPTIONS, ("Unknown connection context"));
108: return(NOTOK);
109: }
110:
111: cn->cn_last_used = timenow;
112:
113: switch(inv_ret)
114: {
115: case NOTOK:
116: DLOG(log_dsap, LLOG_NOTICE, ("ASYN BIND REQUEST NOTOK!"));
117: #ifndef NO_STATS
118: pslog (log_stat, LLOG_NOTICE, "Failed (NOTOK)", dn_print, (caddr_t) cn->cn_dn);
119: #endif
120: dsa_reliable (cn,FALSE,timenow);
121: return(NOTOK);
122: case DONE:
123: DLOG(log_dsap, LLOG_NOTICE, ("ASYN BIND REQUEST DONE! (ad = %d)", dc->dc_sd));
124: cn->cn_ad = dc->dc_sd;
125: if (cn->cn_ad == NOTOK)
126: {
127: DCFREE(dc);
128: #ifndef NO_STATS
129: pslog(log_stat, LLOG_NOTICE, "Failed (DONE)", dn_print, (caddr_t) cn->cn_dn);
130: #endif
131: cn->cn_state = CN_FAILED;
132: dsa_reliable (cn,FALSE,timenow);
133: return(NOTOK);
134: }
135: if (conn_req_aux(cn, dc) == NOTOK) {
136: #ifndef NO_STATS
137: pslog(log_stat, LLOG_NOTICE, "Failed (DONE 2)", dn_print, (caddr_t) cn->cn_dn);
138: #endif
139: dsa_reliable (cn,FALSE,timenow);
140: return NOTOK;
141: }
142: return OK;
143: case CONNECTING_1:
144: DLOG (log_dsap,LLOG_NOTICE,("ASYN BIND REQUEST CONNECTING_1 (ad = %d)", dc->dc_sd));
145: cn->cn_ad = dc->dc_sd;
146: DCFREE(dc);
147: cn->cn_state = CN_CONNECTING1;
148: #ifndef NO_STATS
149: pslog (log_stat, LLOG_NOTICE, "Trying (CONN_1)", dn_print, (caddr_t) cn->cn_dn);
150: #endif
151: return(OK);
152:
153: case CONNECTING_2:
154: DLOG (log_dsap,LLOG_NOTICE,("ASYN BIND REQUEST CONNECTING_2 (ad = %d)", dc->dc_sd));
155: cn->cn_ad = dc->dc_sd;
156: DCFREE(dc);
157: cn->cn_state = CN_CONNECTING2;
158: #ifndef NO_STATS
159: pslog (log_stat, LLOG_NOTICE, "Trying (CONN_2)", dn_print, (caddr_t) cn->cn_dn);
160: #endif
161: return(OK);
162:
163: default:
164: LLOG(log_dsap, LLOG_EXCEPTIONS, ("Unknown return from DAsynBind : %d", inv_ret));
165: return(NOTOK);
166: } /* switch inv_ret */
167: /* NOTREACHED */
168: }
169:
170: /*
171: * conn_req_aux() is called to complete work started by conn_request().
172: * Current major complication is how to deal with an undecodable BindResult.
173: * If OK is returned, the connection is ready for action and any waiting
174: * operations should be sent.
175: * If NOTOK is returned the connection needs to be extracted, alerting any
176: * waiting operations in the process.
177: */
178: conn_req_aux(cn, dc)
179: register struct connection * cn;
180: register struct DSAPconnect * dc;
181: {
182:
183: switch(dc->dc_result)
184: {
185: case DS_RESULT:
186: DLOG(log_dsap, LLOG_NOTICE, ("D-BIND.RETRY(ASYNC) RESULT"));
187: cn->cn_state = CN_OPEN;
188: break;
189:
190: case DS_ERROR:
191: /*
192: * Get the DirectoryBindError
193: */
194: DLOG(log_dsap, LLOG_NOTICE, ("D-BIND.RETRY(ASYNC) ERROR"));
195: cn->cn_state = CN_FAILED;
196: cn->cn_ad = 0;
197: break;
198:
199: default:
200: DLOG(log_dsap, LLOG_NOTICE, ("D-BIND.RETRY(ASYNC) OTHER"));
201: cn->cn_state = CN_FAILED;
202: cn->cn_ad = 0;
203: LLOG (log_dsap,LLOG_EXCEPTIONS,( "Association rejected"));
204: /* ADT
205: LLOG (log_dsap,LLOG_EXCEPTIONS,( "Association rejected: [%s]",
206: DErrString(dc->dc_result)));
207: */
208: break;
209:
210: } /* switch acc->acc_result */
211:
212: if(cn->cn_state == CN_OPEN)
213: {
214: struct TSAPdisconnect td_s;
215: struct TSAPdisconnect *td = &td_s;
216:
217: if (TSetQueuesOK (cn->cn_ad, 1, td) == NOTOK)
218: td_log (td, "TSetQueuesOK (outgoing)");
219:
220: cn->cn_last_used = timenow;
221: dsa_reliable (cn,TRUE,cn->cn_last_used);
222: #ifndef NO_STATS
223: {
224: char buf [LINESIZE];
225: (void) sprintf (buf,"Bound using %s DSP context (%d)", cn->cn_ctx == DS_CTX_QUIPU_DSP ? "QUIPU" : "X500", cn->cn_ad);
226: pslog(log_stat, LLOG_NOTICE, buf, dn_print, (caddr_t) cn->cn_dn);
227: }
228: #endif
229: return(OK);
230: }
231:
232: return(NOTOK);
233: }
234:
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.