Annotation of OpenXM/src/kxx/oxmain.c, Revision 1.1.1.1
1.1 maekawa 1: /* nullserver01 */
2: #include <stdio.h>
3: #include <sys/types.h>
4: #include <sys/socket.h>
5: #include <sys/time.h>
6: #include <netinet/in.h>
7: #include <netdb.h>
8: #include <signal.h>
9: #include <setjmp.h>
10: /* -lnsl -lsocket /usr/ucblib/libucb.a */
11: #include "ox_kan.h"
12: #include "serversm.h"
13:
14: #define SERVERNAME "/home/nobuki/kxx/ox_sm1"
15: /*
16: #define SERVERNAME "/home/nobuki/kxx/stdserver00"
17: #define SERVERNAME "/home/ftp/pub/OHP/ox_asir"
18: */
19:
20: int OxCritical = 0;
21: int OxInterruptFlag = 0;
22:
23: int SerialCurrentControl;
24:
25: int MyServerPid;
26: char ServerName[1024];
27: int PacketMonitor = 0;
28: int Quiet = 0;
29:
30: int LocalMode = 1;
31: int NotifyPortnumber = 0;
32:
33:
34: main(int argc, char *argv[]) {
35: int fd;
36: int size;
37: char sname[1024];
38: int tmp[1];
39: char *buf;
40: int i;
41: int fdControl = -1; int portControl = 1200;
42: int fdStream = -1; int portStream = 1300;
43: int reverse = 0;
44: extern int OpenedSocket;
45: char portfile[1024];
46: char *pass;
47:
48: strcpy(sname,"localhost");
49: strcpy(ServerName,SERVERNAME);
50: i = 1;
51: while (i<argc) {
52: if (strcmp(argv[i],"-host") == 0) {
53: i++;
54: if (i<argc) strcpy(sname,argv[i]);
55: }else if (strcmp(argv[i],"-data")==0) {
56: i++;
57: if (i<argc) sscanf(argv[i],"%d",&portStream);
58: }else if (strcmp(argv[i],"-control")==0) {
59: i++;
60: if (i<argc) sscanf(argv[i],"%d",&portControl);
61: }else if (strcmp(argv[i],"-ox") == 0) {
62: i++;
63: if (i<argc) strcpy(ServerName,argv[i]);
64: }else if (strcmp(argv[i],"-monitor") == 0) {
65: PacketMonitor = 1;
66: }else if (strcmp(argv[i],"-insecure") == 0) {
67: LocalMode = 0;
68: }else if (strcmp(argv[i],"-reverse") == 0) {
69: reverse = 1;
70: }else if (strcmp(argv[i],"-portfile") == 0) {
71: i++;
72: if (i<argc) {
73: sscanf(argv[i],"%s",portfile);
74: portControl = 0;
75: portStream = 0;
76: NotifyPortnumber = 1;
77: }
78: }else if (strcmp(argv[i],"-pass") == 0) {
79: i++;
80: if (i<argc) {
81: pass = argv[i];
82: }
83: }else {
84: fprintf(stderr,"Unknown option %s.\n",argv[i]);
85: oxmainUsage(); exit(10);
86: }
87: i++;
88: }
89:
90: if (reverse) {
91: /* The order is very important. */
92: fdControl = socketConnectWithPass(sname,portControl,pass);
93: fdStream = socketConnectWithPass(sname,portStream,pass);
94:
95: fprintf(stderr,"Connected: control = %d, data = %d.\n",fdControl,fdStream);
96: if (portControl != -1) {
97: MyServerPid = fork();
98: if (MyServerPid > 0 ) parentServerMain(fdControl,fdStream);
99: else childServerMain(fdControl,fdStream);
100: }else{
101: childServerMain(fdControl,fdStream);
102: }
103: /* This line will be never executed. */
104: }
105:
106: /* non-reverse case. */
107: fprintf(stderr,"Hostname is %s \n",sname);
108: fprintf(stderr,"Port for data (-data) = %d \n",portStream);
109: fprintf(stderr,"Port for control message (-control) = %d \n",portControl);
110: fflush(NULL);
111:
112:
113: if (LocalMode) {
114: if (portControl != -1) {
115: fdControl = socketOpen(sname,portControl);
116: portControl = OpenedSocket;
117: if (NotifyPortnumber) {
118: oxWritePortFile(0,portControl,portfile);
119: }
120: fdControl = socketAcceptLocal(fdControl);
121: fprintf(stderr,"\n control port %d : Connected.\n",portControl);
122: }
123: if (portStream != -1) {
124: fdStream = socketOpen(sname,portStream);
125: portStream = OpenedSocket;
126: if (NotifyPortnumber) {
127: oxWritePortFile(1,portStream,portfile);
128: }
129: fdStream = socketAcceptLocal(fdStream);
130: fprintf(stderr,"\n stream port %d : Connected.\n",portStream);
131: }
132: }else{
133: if (portControl != -1) {
134: fdControl = socketOpen(sname,portControl);
135: portControl = OpenedSocket;
136: if (NotifyPortnumber) {
137: oxWritePortFile(0,portControl,portfile);
138: }
139: fdControl = socketAccept(fdControl);
140: fprintf(stderr,"\n control port %d : Connected.\n",portControl);
141: }
142: if (portStream != -1) {
143: fdStream = socketOpen(sname,portStream);
144: portStream = OpenedSocket;
145: if (NotifyPortnumber) {
146: oxWritePortFile(1,portStream,portfile);
147: }
148: fdStream = socketAccept(fdStream);
149: fprintf(stderr,"\n stream port %d : Connected.\n",portStream);
150: }
151: }
152:
153:
154:
155: if (portControl != -1) {
156: MyServerPid = fork();
157: if (MyServerPid > 0 ) parentServerMain(fdControl,fdStream);
158: else childServerMain(fdControl,fdStream);
159: }else{
160: childServerMain(fdControl,fdStream);
161: }
162:
163: }
164:
165: oxmainUsage() {
166: fprintf(stderr,"Usage: \n");
167: fprintf(stderr," ox [-ox serverprogram -host name -data portnum -control portnum -monitor]\n");
168: fprintf(stderr," [-insecure -portfile fname -reverse -pass xxxyyyzzz]");
169: fprintf(stderr,"\n");
170: fprintf(stderr,"Example 1: dc1% ./ox -ox ox_sm1 -host dc1.math.kobe-u.ac.jp -insecure -control 1300 -data 1200\n");
171: fprintf(stderr," sm1>[(dc1.math.kobe-u.ac.jp) 1300 1200] oxconnect /ox.ccc set\n");
172: fprintf(stderr,"\n");
173: }
174:
175: parentServerMain(int fdControl, int fdStream) {
176: int id;
177: int mtag;
178: int size;
179: int n;
180: int r;
181: int message = 1;
182: int controlByteOrder;
183:
184: extern void myServerExit();
185:
186: controlByteOrder = oxTellMyByteOrder(fdControl);
187: /* Set the network byte order. */
188: fprintf(stderr,"controlByteOrder=%x\n",controlByteOrder);
189:
190:
191: signal(SIGINT,myServerExit);
192: while(1) {
193: mtag = oxfdGetOXheader(fdControl,&SerialCurrentControl);
194: /* get the message_tag */
195: /* message_body */
196: id = oxfdGetInt32(fdControl); /* get the function_id */
197: if (message) {printf("\n[control] control function_id is %d\n",id);}
198: switch( id ) {
199: case SM_control_kill:
200: if (message) printf("[control] control_kill\n");
201: oxSendResultOfControl(fdControl);
202: sleep(2);
203: myServerExit();
204: break;
205: case SM_control_reset_connection:
206: if (message) printf("[control] control_reset_connection.\n");
207: if (message) printf("Sending the SIGUSR1 signal to %d: ",MyServerPid);
208: r=kill(MyServerPid,SIGUSR1);
209: if (message) printf("Result = %d\n",r);
210: fflush(NULL);
211: oxSendResultOfControlInt32(fdControl,0);
212: break;
213: default:
214: fprintf(stderr,"[control] Unknown control message.\n");
215: fprintf(stderr,"Shutdown the server.");
216: myServerExit();
217: break;
218: }
219: }
220: }
221:
222: void myServerExit() {
223: printf("Sending the kill signal to the child.\n");
224: kill(MyServerPid,SIGKILL);
225: exit();
226: }
227:
228: childServerMain(int fdControl, int fdStream) {
229: int i;
230: close(fdControl); /* close(0); dup(fdStream); */
231: dup2(fdStream,3);
232: dup2(fdStream,4);
233: /*close(0);
234: #include <sys/param.h>
235: for (i=5; i<NOFILE; i++) close(i);
236: */
237: if (PacketMonitor) {
238: if (execl(ServerName,ServerName,"-monitor",NULL)) {
239: fprintf(stderr,"%s cannot be executed with -monitor.\n",ServerName);
240: }
241: }else {
242: if (execl(ServerName,ServerName,NULL)) {
243: fprintf(stderr,"%s cannot be executed.\n",ServerName);
244: }
245: }
246: }
247:
248:
249: /* These are dummy. It is defined in stackmachine.c */
250: unlockCtrlCForOx() { ; }
251: restoreLockCtrlCForOx() { ; }
252:
253:
254:
255:
256:
257:
258:
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to oxmain.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [local] / OpenXM / src / kxx