![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to initiator.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 / others / callback|
Return to initiator.c CVS log | Up to [CSRG BSD Unix] / 43BSDReno / contrib / isode-beta / others / callback |
1.1 root 1: /* initiator.c -- initiator for callback demo */
2:
3: #ifndef lint
4: static char *rcsid = "$Header: /f/osi/others/callback/RCS/initiator.c,v 7.0 89/11/23 21:58:11 mrose Rel $";
5: #endif
6:
7: /*
8: * $Header: /f/osi/others/callback/RCS/initiator.c,v 7.0 89/11/23 21:58:11 mrose Rel $
9: *
10: *
11: * $Log: initiator.c,v $
12: * Revision 7.0 89/11/23 21:58:11 mrose
13: * Release 6.0
14: *
15: */
16:
17: /*
18: * NOTICE
19: *
20: * Acquisition, use, and distribution of this module and related
21: * materials are subject to the restrictions of a license agreement.
22: * Consult the Preface in the User's Manual for the full terms of
23: * this agreement.
24: *
25: */
26:
27:
28: #include <stdio.h>
29: #include "callback.h"
30:
31: /* */
32:
33: static char *mycontext = "isode callback demo";
34:
35: /* */
36:
37: /* ARGSUSED */
38:
39: main (argc, argv, envp)
40: int argc;
41: char **argv,
42: **envp;
43: {
44: int vecp;
45: char *taddr,
46: *vec[4];
47: struct TSAPaddr *ta;
48: struct TSAPdisconnect tds;
49: struct TSAPdisconnect *td = &tds;
50: register struct SSAPaddr *sz;
51: struct SSAPconnect scs;
52: register struct SSAPconnect *sc = &scs;
53: struct SSAPstart sss;
54: register struct SSAPstart *ss = &sss;
55: struct SSAPdata sxs;
56: register struct SSAPdata *sx = &sxs;
57: struct SSAPrelease srs;
58: register struct SSAPrelease *sr = &srs;
59: struct SSAPindication sis;
60: register struct SSAPindication *si = &sis;
61: register struct SSAPabort *sa = &si -> si_abort;
62: AEI aei;
63: struct PSAPaddr *pa;
64: struct sblk incoming,
65: outgoing;
66: SB sbi = &incoming,
67: sbo = &outgoing;
68:
69: reportailor (argv[0]);
70:
71: if (argc != 2)
72: adios (NULLCP, "usage: %s \"host\"", argv[0]);
73:
74: /* really should postpone this until after the session connect so we
75: can bind to the same network address (in the case of a multi-homed ES) */
76: if ((aei = str2aei (PLocalHostName (), mycontext)) == NULLAEI)
77: adios (NULLCP, "%s-%s: unknown application-entity",
78: PLocalHostName (), mycontext);
79: if ((pa = aei2addr (aei)) == NULLPA)
80: adios (NULLCP, "address translation failed");
81: ta = &pa -> pa_addr.sa_addr;
82: if (TNetUnique (ta, td) == NOTOK) {
83: if (td -> td_cc > 0)
84: adios (NULLCP, "TNetUnique: [%s] %*.*s", TErrString (td -> td_reason),
85: td -> td_cc, td -> td_cc, td -> td_data);
86: else
87: adios (NULLCP, "TNetUnique: [%s]", TErrString (td -> td_reason));
88: }
89: if ((taddr = taddr2str (ta)) == NULLCP)
90: adios (NULLCP, "taddr2str failed");
91:
92: if ((aei = str2aei (argv[1], mycontext)) == NULLAEI)
93: adios (NULLCP, "%s-%s: unknown application-entity",
94: argv[1], mycontext);
95: if ((pa = aei2addr (aei)) == NULLPA)
96: adios (NULLCP, "address translation failed");
97: sz = &pa -> pa_addr;
98:
99: bzero ((char *) sbo, sizeof *sbo);
100: sbo -> sb_requirements = SR_BASUBSET;
101: sbo -> sb_settings = 0;
102: #define dotoken(requires,shift,bit,type) \
103: { \
104: if (sbo -> sb_requirements & requires) \
105: sbo -> sb_settings |= ST_INIT_VALUE << shift; \
106: }
107: dotokens ();
108: #undef dotoken
109: sbo -> sb_isn = SERIAL_NONE;
110:
111: /* we pass the transport address we are listening on in the initial
112: user data */
113: if (SConnRequest (&sbo -> sb_connect, NULLSA, sz, sbo -> sb_requirements,
114: sbo -> sb_settings, sbo -> sb_isn, taddr, strlen (taddr),
115: NULLQOS, sc, si) == NOTOK)
116: adios (NULLCP, "S-CONNECT.REQUEST: %s", SErrString (sa -> sa_reason));
117: if (sc -> sc_result != SC_ACCEPT)
118: adios (NULLCP, "connection rejected by peer: %s",
119: SErrString (sc -> sc_result));
120: advise (LLOG_NOTICE, NULLCP,
121: "S-CONNECT.RESPONSE: <%d, %s, %s, %s, %ld, %d>",
122: sc -> sc_sd, sprintref (&sc -> sc_connect),
123: saddr2str (&sc -> sc_responding),
124: sprintb (sc -> sc_requirements, RMASK), sc -> sc_isn,
125: sc -> sc_ssdusize);
126:
127: sbo -> sb_sd = sc -> sc_sd;
128: sbo -> sb_requirements = sc -> sc_requirements;
129: sbo -> sb_settings = sc -> sc_settings;
130: #define dotoken(requires,shift,bit,type) \
131: { \
132: if (sbo -> sb_requirements & requires) \
133: if ((sbo -> sb_settings & (ST_MASK << shift)) == ST_INIT_VALUE) \
134: sbo -> sb_owned |= bit; \
135: }
136: dotokens ();
137: #undef dotoken
138: sbo -> sb_ssn = sbo -> sb_isn = sc -> sc_isn;
139:
140: SCFREE (sc);
141:
142: /* now wait for the other end to call us back */
143: for (;;) {
144: if (TNetAccept (&vecp, vec, 0, NULLFD, NULLFD, NULLFD, NOTOK, td)
145: == NOTOK) {
146: if (td -> td_cc > 0)
147: adios (NULLCP, "TNetAccept: [%s] %*.*s", TErrString (td -> td_reason),
148: td -> td_cc, td -> td_cc, td -> td_data);
149: else
150: adios (NULLCP, "TNetAccept: [%s]", TErrString (td -> td_reason));
151: }
152:
153: if (vecp > 0)
154: break;
155: }
156:
157: if (SInit (vecp, vec, ss, si) == NOTOK)
158: adios (NULLCP, "S-CONNECT.INDICATION: %s",
159: SErrString (sa -> sa_reason));
160: advise (LLOG_NOTICE, NULLCP,
161: "S-CONNECT.INDICATION: <%d, %s, %s, %s, %s, %ld, %d>",
162: ss -> ss_sd, sprintref (&ss -> ss_connect),
163: saddr2str (&ss -> ss_calling), saddr2str (&ss -> ss_called),
164: sprintb (ss -> ss_requirements, RMASK), ss -> ss_isn,
165: ss -> ss_ssdusize);
166:
167: /* stop listening, we have what we want */
168: (void) TNetClose (NULLTA, td);
169:
170: bzero ((char *) sbi, sizeof *sbi);
171: sbi -> sb_sd = ss -> ss_sd;
172: sbi -> sb_connect = ss -> ss_connect; /* struct copy */
173: sbi -> sb_requirements = ss -> ss_requirements & SR_BASUBSET;
174: sbi -> sb_settings = ss -> ss_settings;
175: #define dotoken(requires,shift,bit,type) \
176: { \
177: if (sbi -> sb_requirements & requires) \
178: switch (sbi -> sb_settings & (ST_MASK << shift)) { \
179: case ST_CALL_VALUE << shift: \
180: sbi -> sb_settings &= ~(ST_MASK << shift); \
181: sbi -> sb_settings |= ST_INIT_VALUE << shift; \
182: break; \
183: \
184: case ST_INIT_VALUE: \
185: break; \
186: \
187: case ST_RESP_VALUE: \
188: sbi -> sb_owned |= bit; \
189: break; \
190: \
191: default: \
192: adios (NULLCP, "%s token: reserved", type); \
193: break; \
194: } \
195: }
196: dotokens ();
197: #undef dotoken
198: sbi -> sb_ssn = sbi -> sb_isn = ss -> ss_isn;
199:
200: SSFREE (ss);
201:
202: if (SConnResponse (sbi -> sb_sd, &sbi -> sb_connect, NULLSA, SC_ACCEPT,
203: sbi -> sb_requirements, sbi -> sb_settings, sbi -> sb_isn,
204: NULLCP, 0, si) == NOTOK)
205: adios (NULLCP, "S-CONNECT.RESPONSE: %s", SErrString (sa -> sa_reason));
206:
207: /* do work here */
208:
209: if (SRelRequest (sbo -> sb_sd, NULLCP, 0, NOTOK, sr, si) == NOTOK)
210: adios (NULLCP, "S-RELEASE.REQUEST: %s", SErrString (sa -> sa_reason));
211: if (!sr -> sr_affirmative)
212: adios (NULLCP, "release rejected by peer");
213:
214: switch (SReadRequest (sbi -> sb_sd, sx, NOTOK, si)) {
215: case NOTOK:
216: adios (NULLCP, "S-READ.REQUEST: %s", SErrString (sa -> sa_reason));
217:
218: case OK:
219: adios (NULLCP, "not expecting DATA indication 0x%x", sx -> sx_type);
220:
221: case DONE:
222: if (si -> si_type != SI_FINISH)
223: adios (NULLCP, "not expecting indication 0x%x", si -> si_type);
224: if (SRelResponse (sbi -> sb_sd, SC_ACCEPT, NULLCP, 0, si) == NOTOK)
225: adios (NULLCP, "S-RELEASE.RESPONSE: %s", SErrString (sa -> sa_reason));
226: break;
227: }
228:
229: exit (0);
230: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.