=================================================================== RCS file: /home/cvs/OpenXM/src/kxx/oxmain.c,v retrieving revision 1.1 retrieving revision 1.8 diff -u -p -r1.1 -r1.8 --- OpenXM/src/kxx/oxmain.c 1999/10/08 02:12:13 1.1 +++ OpenXM/src/kxx/oxmain.c 2001/05/06 08:11:48 1.8 @@ -1,5 +1,7 @@ +/* $OpenXM: OpenXM/src/kxx/oxmain.c,v 1.7 2001/05/06 07:53:01 takayama Exp $ */ /* nullserver01 */ #include +#include #include #include #include @@ -11,11 +13,7 @@ #include "ox_kan.h" #include "serversm.h" -#define SERVERNAME "/home/nobuki/kxx/ox_sm1" -/* -#define SERVERNAME "/home/nobuki/kxx/stdserver00" -#define SERVERNAME "/home/ftp/pub/OHP/ox_asir" -*/ +#define SERVERNAME "ox_sm1" int OxCritical = 0; int OxInterruptFlag = 0; @@ -23,14 +21,22 @@ int OxInterruptFlag = 0; int SerialCurrentControl; int MyServerPid; -char ServerName[1024]; +#define SERVERNAME_SIZE 4096 +char ServerName[SERVERNAME_SIZE]; int PacketMonitor = 0; int Quiet = 0; int LocalMode = 1; int NotifyPortnumber = 0; +int Do_not_use_control_stream_to_tell_no_server = 1; +static void errorToStartEngine(void); +static int findOxServer(char *server); +static void couldNotFind(char *s); +#if defined(__CYGWIN__) +int errno; +#endif +/* gcc -v -c hoge.c */ - main(int argc, char *argv[]) { int fd; int size; @@ -44,10 +50,15 @@ main(int argc, char *argv[]) { extern int OpenedSocket; char portfile[1024]; char *pass; + int result; strcpy(sname,"localhost"); strcpy(ServerName,SERVERNAME); i = 1; + if (argc == 1) { + oxmainUsage(); + exit(); + } while (i 0 ) parentServerMain(fdControl,fdStream); - else childServerMain(fdControl,fdStream); + else result=childServerMain(fdControl,fdStream); }else{ - childServerMain(fdControl,fdStream); + result=childServerMain(fdControl,fdStream); } - /* This line will be never executed. */ + /* This line will be never executed in case of success */ + if (result < 0 ) { + errorToStartEngine(); + } } /* non-reverse case. */ @@ -115,7 +140,7 @@ main(int argc, char *argv[]) { fdControl = socketOpen(sname,portControl); portControl = OpenedSocket; if (NotifyPortnumber) { - oxWritePortFile(0,portControl,portfile); + oxWritePortFile(0,portControl,portfile); } fdControl = socketAcceptLocal(fdControl); fprintf(stderr,"\n control port %d : Connected.\n",portControl); @@ -124,7 +149,7 @@ main(int argc, char *argv[]) { fdStream = socketOpen(sname,portStream); portStream = OpenedSocket; if (NotifyPortnumber) { - oxWritePortFile(1,portStream,portfile); + oxWritePortFile(1,portStream,portfile); } fdStream = socketAcceptLocal(fdStream); fprintf(stderr,"\n stream port %d : Connected.\n",portStream); @@ -134,7 +159,7 @@ main(int argc, char *argv[]) { fdControl = socketOpen(sname,portControl); portControl = OpenedSocket; if (NotifyPortnumber) { - oxWritePortFile(0,portControl,portfile); + oxWritePortFile(0,portControl,portfile); } fdControl = socketAccept(fdControl); fprintf(stderr,"\n control port %d : Connected.\n",portControl); @@ -143,7 +168,7 @@ main(int argc, char *argv[]) { fdStream = socketOpen(sname,portStream); portStream = OpenedSocket; if (NotifyPortnumber) { - oxWritePortFile(1,portStream,portfile); + oxWritePortFile(1,portStream,portfile); } fdStream = socketAccept(fdStream); fprintf(stderr,"\n stream port %d : Connected.\n",portStream); @@ -151,15 +176,28 @@ main(int argc, char *argv[]) { } - + result = 0; if (portControl != -1) { MyServerPid = fork(); if (MyServerPid > 0 ) parentServerMain(fdControl,fdStream); - else childServerMain(fdControl,fdStream); + else result = childServerMain(fdControl,fdStream); }else{ - childServerMain(fdControl,fdStream); + result = childServerMain(fdControl,fdStream); } + if (result < 0) errorToStartEngine(); +} +static void errorToStartEngine(void) { + fprintf(stderr,"Failed to start the engine. Childing process is terminating.\n"); + /* You have to tell to the control server that there is no engine. + And, the control server must tell the client that there is no + engine. + This part has not yet been implemented. + If you implement this, set Do_not_use_control_stream_to_tell_no_server to + zero. + */ + sleep(2); + exit(-1); } oxmainUsage() { @@ -167,8 +205,27 @@ oxmainUsage() { fprintf(stderr," ox [-ox serverprogram -host name -data portnum -control portnum -monitor]\n"); fprintf(stderr," [-insecure -portfile fname -reverse -pass xxxyyyzzz]"); fprintf(stderr,"\n"); - fprintf(stderr,"Example 1: dc1% ./ox -ox ox_sm1 -host dc1.math.kobe-u.ac.jp -insecure -control 1300 -data 1200\n"); + fprintf(stderr,"-reverse: ox server connects to the client.\n"); + fprintf(stderr," The client must give a one time password to ox server to connect to the client with -pass option.\n"); + fprintf(stderr," The one time password can be seen by ps command, so you must not use this one time password system on an untrustful host.\n"); + fprintf(stderr," The one time password should be sent by a safe communication line like ssh and the ox server should be started by ssh. Do not use rsh\n"); + fprintf(stderr," If -reverse is not given, the client connect to the ox server\n"); + fprintf(stderr," See OpenXM/src/SSkan/Doc/ox.sm1, /sm1connectr\n"); + fprintf(stderr,"-insecure : \n"); + fprintf(stderr," If you access to the server from a localhost, you do not need one time password. However, if you access outside of the localhost, a one time password is required. To turn off this restriction, -insecure option is used.\n"); + fprintf(stderr,"\n"); + fprintf(stderr,"If ox fails to find the serverprogram, it tries to look for it in /usr/local/OpenXM/bin and $OpenXM_HOME/bin.\n"); + fprintf(stderr,"\n"); + fprintf(stderr,"Example 1:\n"); + fprintf(stderr,"(Start the ox server): dc1%% ox -ox ~/OpenXM/bin/ox_sm1 -host dc1.math.kobe-u.ac.jp -insecure -control 1200 -data 1300\n"); + fprintf(stderr,"(client): sm1\n "); + fprintf(stderr," (ox.sm1) run ; \n"); fprintf(stderr," sm1>[(dc1.math.kobe-u.ac.jp) 1300 1200] oxconnect /ox.ccc set\n"); + fprintf(stderr,"Example 2:\n"); + fprintf(stderr,"(Start the ox server): dc1%% ox -ox ~/OpenXM/bin/ox_sm1\n"); + fprintf(stderr,"(client): dc1%% sm1\n "); + fprintf(stderr," (ox.sm1) run ; \n"); + fprintf(stderr," sm1>[(localhost) 1300 1200] oxconnect /ox.ccc set\n"); fprintf(stderr,"\n"); } @@ -208,7 +265,7 @@ parentServerMain(int fdControl, int fdStream) { r=kill(MyServerPid,SIGUSR1); if (message) printf("Result = %d\n",r); fflush(NULL); - oxSendResultOfControlInt32(fdControl,0); + /* oxSendResultOfControlInt32(fdControl,0); */ break; default: fprintf(stderr,"[control] Unknown control message.\n"); @@ -230,19 +287,30 @@ childServerMain(int fdControl, int fdStream) { close(fdControl); /* close(0); dup(fdStream); */ dup2(fdStream,3); dup2(fdStream,4); -/*close(0); - #include - for (i=5; i + for (i=5; i= 0) { + fprintf(stderr,"Starting OX server : %s\n",server); + close(fd); + return(0); + } + if (server[0] == '/') { + couldNotFind(server); + return(-1); + } + fprintf(stderr,"The server %s was not found. Trying to find it under OpenXM/bin\n",server); + p = getenv("OpenXM_HOME"); + if (p == NULL) { + p = "/usr/local/OpenXM"; + } + p2 = (char *) malloc(sizeof(char)*(strlen(p)+strlen("/bin/")+3+strlen(server))); + if (p2 == NULL) { fprintf(stderr,"No more memory.\n"); exit(10); } + strcpy(p2,p); strcat(p2,"/bin/"); strcat(p2,server); + fd = open(p2,O_RDONLY); + if (fd >= 0) { + fprintf(stderr,"Starting OX server : %s\n",p2); + if (strlen(p2) < SERVERNAME_SIZE) strcpy(server,p2); + else { + couldNotFind("Too long ox server name."); + return(-1); + } + close(fd); + return(0); + } + couldNotFind(p2); + return(-1); +} - +static void couldNotFind(char *s) { + fprintf(stderr,"OX server %s could not be found.\n",s); +}