version 1.56, 2004/08/18 01:10:59 |
version 1.58, 2010/09/01 08:01:09 |
|
|
* OF THE SOFTWARE HAS BEEN DEVELOPED BY A THIRD PARTY, THE THIRD PARTY |
* OF THE SOFTWARE HAS BEEN DEVELOPED BY A THIRD PARTY, THE THIRD PARTY |
* DEVELOPER SHALL HAVE NO LIABILITY IN CONNECTION WITH THE USE, |
* DEVELOPER SHALL HAVE NO LIABILITY IN CONNECTION WITH THE USE, |
* PERFORMANCE OR NON-PERFORMANCE OF THE SOFTWARE. |
* PERFORMANCE OR NON-PERFORMANCE OF THE SOFTWARE. |
* $OpenXM: OpenXM_contrib2/asir2000/io/tcpf.c,v 1.55 2004/06/15 09:04:41 noro Exp $ |
* $OpenXM: OpenXM_contrib2/asir2000/io/tcpf.c,v 1.57 2010/04/23 04:44:52 noro Exp $ |
*/ |
*/ |
#include "ca.h" |
#include "ca.h" |
#include "parse.h" |
#include "parse.h" |
Line 826 void spawn_server(char *host,char *launcher,char *serv |
|
Line 826 void spawn_server(char *host,char *launcher,char *serv |
|
setpgid(0,getpid()); |
setpgid(0,getpid()); |
execlp("xterm","xterm","-name",OX_XTERM,"-T","ox_launch:local","-display",dname, |
execlp("xterm","xterm","-name",OX_XTERM,"-T","ox_launch:local","-display",dname, |
"-geometry","60x10","-xrm","XTerm*locale:false","-e",launcher,use_unix?".":"127.1",conn_str, |
"-geometry","60x10","-xrm","XTerm*locale:false","-e",launcher,use_unix?".":"127.1",conn_str, |
control_port_str,server_port_str,server,dname,0); |
control_port_str,server_port_str,server,dname,(char *)0); |
} |
} |
} else if ( dname && get_start_path(win_start) ) { |
} else if ( dname && get_start_path(win_start) ) { |
sprintf(cmd,"%s %s %s %s %s %s %s 1", |
sprintf(cmd,"%s %s %s %s %s %s %s 1", |
Line 837 void spawn_server(char *host,char *launcher,char *serv |
|
Line 837 void spawn_server(char *host,char *launcher,char *serv |
|
if ( !fork() ) { |
if ( !fork() ) { |
setpgid(0,getpid()); |
setpgid(0,getpid()); |
execlp(launcher,launcher,use_unix?".":"127.1",conn_str, |
execlp(launcher,launcher,use_unix?".":"127.1",conn_str, |
control_port_str,server_port_str,server,dname0,"-nolog",0); |
control_port_str,server_port_str,server,dname0,"-nolog",(char *)0); |
} |
} |
} |
} |
#else |
#else |
Line 846 void spawn_server(char *host,char *launcher,char *serv |
|
Line 846 void spawn_server(char *host,char *launcher,char *serv |
|
if ( dname ) |
if ( dname ) |
execlp("xterm","xterm","-name",OX_XTERM,"-T","ox_launch:local","-display",dname, |
execlp("xterm","xterm","-name",OX_XTERM,"-T","ox_launch:local","-display",dname, |
"-geometry","60x10","-xrm","XTerm*locale:false","-e",launcher,use_unix?".":"127.1",conn_str, |
"-geometry","60x10","-xrm","XTerm*locale:false","-e",launcher,use_unix?".":"127.1",conn_str, |
control_port_str,server_port_str,server,dname,0); |
control_port_str,server_port_str,server,dname,(char *)0); |
else |
else |
execlp(launcher,launcher,use_unix?".":"127.1",conn_str, |
execlp(launcher,launcher,use_unix?".":"127.1",conn_str, |
control_port_str,server_port_str,server,dname0,"-nolog",0); |
control_port_str,server_port_str,server,dname0,"-nolog",(char *)0); |
} |
} |
#endif |
#endif |
} else if ( conn_to_serv == 2 ) { |
} else if ( conn_to_serv == 2 ) { |
Line 1017 int get_mcindex(int i) |
|
Line 1017 int get_mcindex(int i) |
|
|
|
void Pox_select(NODE arg,LIST *rp) |
void Pox_select(NODE arg,LIST *rp) |
{ |
{ |
int fd,n,i,index,mcind; |
int fd,n,i,index,mcind,s; |
fd_set r,w,e; |
fd_set r,w,e; |
NODE list,t,t1; |
NODE list,t,t1,t0; |
Q q; |
Q q; |
double max; |
double max; |
struct timeval interval; |
struct timeval interval; |
Line 1035 void Pox_select(NODE arg,LIST *rp) |
|
Line 1035 void Pox_select(NODE arg,LIST *rp) |
|
tvp = 0; |
tvp = 0; |
|
|
FD_ZERO(&r); FD_ZERO(&w); FD_ZERO(&e); |
FD_ZERO(&r); FD_ZERO(&w); FD_ZERO(&e); |
for ( t = list; t; t = NEXT(t) ) { |
for ( t = list, t0 = 0; t; t = NEXT(t) ) { |
index = QTOS((Q)BDY(t)); |
index = QTOS((Q)BDY(t)); |
valid_mctab_index(index); |
valid_mctab_index(index); |
fd = get_fd(m_c_tab[index].c); FD_SET((unsigned int)fd,&r); |
s = m_c_tab[index].c; |
|
if ( ox_data_is_available(s) ) { |
|
MKNODE(t1,(Q)BDY(t),t0); t0 = t1; |
|
} else { |
|
fd = get_fd(s); FD_SET((unsigned int)fd,&r); |
|
} |
} |
} |
|
if ( t0 ) { |
|
MKLIST(*rp,t0); return; |
|
} |
|
|
n = select(FD_SETSIZE,&r,&w,&e,tvp); |
n = select(FD_SETSIZE,&r,&w,&e,tvp); |
for ( i = 0, t = 0; n && i < FD_SETSIZE; i++ ) |
for ( i = 0, t = 0; n && i < FD_SETSIZE; i++ ) |
if ( FD_ISSET(i,&r) ) { |
if ( FD_ISSET(i,&r) ) { |
Line 1364 void Pox_cmo_rpc(NODE arg,Obj *rp) |
|
Line 1373 void Pox_cmo_rpc(NODE arg,Obj *rp) |
|
STRING f; |
STRING f; |
USINT ui; |
USINT ui; |
NODE t; |
NODE t; |
|
Obj dmy; |
pointer *w; |
pointer *w; |
int index = QTOS((Q)ARG0(arg)); |
int index = QTOS((Q)ARG0(arg)); |
|
int sync,find; |
|
|
|
find = get_opt("sync",&sync); |
valid_mctab_index(index); |
valid_mctab_index(index); |
s = m_c_tab[index].c; arg = NEXT(arg); |
s = m_c_tab[index].c; arg = NEXT(arg); |
f = (STRING)BDY(arg); arg = NEXT(arg); |
f = (STRING)BDY(arg); arg = NEXT(arg); |
Line 1379 void Pox_cmo_rpc(NODE arg,Obj *rp) |
|
Line 1391 void Pox_cmo_rpc(NODE arg,Obj *rp) |
|
MKUSINT(ui,n); |
MKUSINT(ui,n); |
ox_send_data(s,ui); |
ox_send_data(s,ui); |
ox_send_data(s,f); |
ox_send_data(s,f); |
ox_send_cmd(s,SM_executeFunction); |
if ( find && sync ) { |
|
ox_send_cmd(s,SM_executeFunctionSync); |
|
ox_get_result(s,&dmy); |
|
} else |
|
ox_send_cmd(s,SM_executeFunction); |
*rp = 0; |
*rp = 0; |
} |
} |
|
|