version 1.23, 2004/09/17 08:46:10 |
version 1.30, 2016/03/31 03:22:55 |
|
|
/* $OpenXM: OpenXM/src/kan96xx/plugin/oxmisc.c,v 1.22 2004/09/17 07:27:28 takayama Exp $ */ |
/* $OpenXM: OpenXM/src/kan96xx/plugin/oxmisc.c,v 1.29 2015/10/08 11:49:37 takayama Exp $ */ |
#include <stdio.h> |
#include <stdio.h> |
|
#include <string.h> |
#include <sys/types.h> |
#include <sys/types.h> |
#include <sys/stat.h> |
#include <sys/stat.h> |
#include <sys/socket.h> |
#include <sys/socket.h> |
Line 22 FILE *MyErrorOut = NULL; |
|
Line 23 FILE *MyErrorOut = NULL; |
|
#include "../Kan/extern.h" |
#include "../Kan/extern.h" |
|
|
#include "ox_kan.h" |
#include "ox_kan.h" |
|
#include "mysig.h" |
|
|
|
|
#define READBUFSIZE 5000 |
#define READBUFSIZE 5000 |
|
|
int OxVersion = 200012030; |
int OxVersion = 200012030; |
Line 178 int oxWaitSyncBall(ox_stream ostream) |
|
Line 181 int oxWaitSyncBall(ox_stream ostream) |
|
fprintf(stderr,"Looking for the next message tag. mtag=%d\n",mtag); |
fprintf(stderr,"Looking for the next message tag. mtag=%d\n",mtag); |
/* or stdout */ |
/* or stdout */ |
fflush(NULL); |
fflush(NULL); |
|
if (mtag == -1) { |
|
fprintf(stderr,"Your peer seems to be dead.\n"); return 0; |
|
} |
} |
} |
} |
} |
|
|
Line 344 void oxSendResultOfControl(int fd) |
|
Line 350 void oxSendResultOfControl(int fd) |
|
void oxSendMathCap(ox_stream os,struct mathCap *mathcap) |
void oxSendMathCap(ox_stream os,struct mathCap *mathcap) |
{ |
{ |
int i,n,infosize,ncmo; |
int i,n,infosize,ncmo; |
struct object mathinfo; |
struct object mathinfo = OINIT; |
/* printf("ox sending mathcap\n"); fflush(stdout); */ |
/* printf("ox sending mathcap\n"); fflush(stdout); */ |
mathinfo = *((struct object *)(mathcap->infop)); |
mathinfo = *((struct object *)(mathcap->infop)); |
infosize = getoaSize(mathinfo); |
infosize = getoaSize(mathinfo); |
Line 917 static void cancelConnection() { |
|
Line 923 static void cancelConnection() { |
|
#else |
#else |
extern jmp_buf MyEnv_oxmisc; |
extern jmp_buf MyEnv_oxmisc; |
#endif |
#endif |
signal(SIGALRM,SIG_IGN); |
mysignal(SIGALRM,SIG_IGN); |
fprintf(stderr,"Time out in TCP/IP connection.\n"); |
fprintf(stderr,"Time out in TCP/IP connection.\n"); |
#if defined(__CYGWIN__) |
#if defined(__CYGWIN__) |
siglongjmp(MyEnv_oxmisc,1); |
MYSIGLONGJMP(MyEnv_oxmisc,1); |
#else |
#else |
longjmp(MyEnv_oxmisc,1); |
MYLONGJMP(MyEnv_oxmisc,1); |
#endif |
#endif |
} |
} |
|
|
Line 946 oxclientp oxCreateClient2(int fdstream,int portStream, |
|
Line 952 oxclientp oxCreateClient2(int fdstream,int portStream, |
|
|
|
v = !Quiet; |
v = !Quiet; |
#if defined(__CYGWIN__) |
#if defined(__CYGWIN__) |
if (sigsetjmp(MyEnv_oxmisc,1)) { |
if (MYSIGSETJMP(MyEnv_oxmisc,1)) { |
#else |
#else |
if (setjmp(MyEnv_oxmisc)) { |
if (MYSETJMP(MyEnv_oxmisc)) { |
#endif |
#endif |
return(NULL); |
return(NULL); |
}else{ |
}else{ |
} |
} |
alarm((unsigned int) 20); /* setup timeout. */ |
alarm((unsigned int) 20); /* setup timeout. */ |
signal(SIGALRM,cancelConnection); |
mysignal(SIGALRM,cancelConnection); |
|
|
switch(ipmask) { |
switch(ipmask) { |
case 0:/* only local */ |
case 0:/* only local */ |
Line 996 oxclientp oxCreateClient2(int fdstream,int portStream, |
|
Line 1002 oxclientp oxCreateClient2(int fdstream,int portStream, |
|
return(NULL); |
return(NULL); |
} |
} |
} |
} |
signal(SIGALRM,SIG_IGN); |
mysignal(SIGALRM,SIG_IGN); |
|
|
controlByteOrder = oxSetByteOrder(fdControl); |
controlByteOrder = oxSetByteOrder(fdControl); |
if (v) fprintf(stderr,"Byte order for control process is %s.\n", |
if (v) fprintf(stderr,"Byte order for control process is %s.\n", |