[BACK]Return to tcpf.c CVS log [TXT][DIR] Up to [local] / OpenXM_contrib2 / asir2000 / io

Diff for /OpenXM_contrib2/asir2000/io/tcpf.c between version 1.56 and 1.60

version 1.56, 2004/08/18 01:10:59 version 1.60, 2011/01/18 09:09:22
Line 44 
Line 44 
  * 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.59 2010/12/12 03:20:53 ohara Exp $
 */  */
 #include "ca.h"  #include "ca.h"
 #include "parse.h"  #include "parse.h"
Line 64 
Line 64 
 #include <process.h>  #include <process.h>
 #endif  #endif
   
   #define INIT_TAB_SIZ 64
 #define OX_XTERM "ox_xterm"  #define OX_XTERM "ox_xterm"
   
 #if !defined(_PA_RISC1_1)  #if !defined(_PA_RISC1_1)
Line 471  void Pregister_server(NODE arg,Q *rp)
Line 472  void Pregister_server(NODE arg,Q *rp)
         }          }
   
         /* register server to the server list */          /* register server to the server list */
         ind = register_server(use_unix,cn,sn);          ind = register_server(use_unix,cn,sn,-1);
   
         if ( ox_exchange_mathcap ) {          if ( ox_exchange_mathcap ) {
                 /* request remote mathcap */                  /* request remote mathcap */
Line 613  void ox_launch_generic(char *host,char *launcher,char 
Line 614  void ox_launch_generic(char *host,char *launcher,char 
         char server_port_str[BUFSIZ];          char server_port_str[BUFSIZ];
         Obj obj;          Obj obj;
         MATHCAP server_mathcap;          MATHCAP server_mathcap;
       Q value;
       char *key;
       int fd=-1;
       NODE opt,n0;
   
       if ( current_option ) {
           for ( opt = current_option; opt; opt = NEXT(opt) ) {
               n0 = BDY((LIST)BDY(opt));
               key = BDY((STRING)BDY(n0));
               value = (Q)BDY(NEXT(n0));
               if ( !strcmp(key,"fd") && value ) {
                   fd = QTOS(value);
                   break;
               }
           }
       }
       if (!available_mcindex(fd)) {
           STOQ(-1,*rp);
           return;
       }
 #if !defined(VISUAL)  #if !defined(VISUAL)
         if ( use_unix && !find_executable("xterm") ) use_x = 0;          if ( use_unix && !find_executable("xterm") ) use_x = 0;
 #endif  #endif
Line 656  void ox_launch_generic(char *host,char *launcher,char 
Line 676  void ox_launch_generic(char *host,char *launcher,char 
         }          }
   
         /* register server to the server list */          /* register server to the server list */
         ind = register_server(use_unix,cn,sn);          ind = register_server(use_unix,cn,sn,fd);
   
         if ( ox_exchange_mathcap ) {          if ( ox_exchange_mathcap ) {
                 /* request remote mathcap */                  /* request remote mathcap */
Line 826  void spawn_server(char *host,char *launcher,char *serv
Line 846  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 857  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 866  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 959  void ox_launch_main(int with_x,NODE arg,Obj *p)
Line 979  void ox_launch_main(int with_x,NODE arg,Obj *p)
         *p = (Obj)ret;          *p = (Obj)ret;
 }  }
   
 int register_server(int af_unix,int m,int c)  void extend_mctab(int bound)
 {  {
         int s,i;          int s,i,n;
         struct m_c *t;          struct m_c *t;
 #define INIT_TAB_SIZ 64      if ( !m_c_tab ) {
           n = (bound/INIT_TAB_SIZ + 1)*INIT_TAB_SIZ;
           t = (struct m_c *)MALLOC_ATOMIC(n*sizeof(struct m_c));
           for ( i = m_c_s; i < n; i++ ) {
               t[i].af_unix = 0;
               t[i].m = t[i].c = -1;
           }
           m_c_s = n; m_c_tab = t;
       }else if (bound >= m_c_s) {
           n = (bound/INIT_TAB_SIZ + 1)*INIT_TAB_SIZ;
           t = (struct m_c *)MALLOC_ATOMIC(n*sizeof(struct m_c));
           bzero((void *)t,s);
           bcopy((void *)m_c_tab,(void *)t,m_c_s*sizeof(struct m_c));
           for ( i = m_c_s; i < n; i++ ) {
               t[i].af_unix = 0;
               t[i].m = t[i].c = -1;
           }
           m_c_s = n; m_c_tab = t;
       }else {
           return;
       }
   }
   
   int available_mcindex(int ind)
   {
           if (ind < 0) return 1;
           extend_mctab(ind);
           return m_c_tab[ind].m<0 && m_c_tab[ind].c<0;
   }
   
   int register_server(int af_unix,int m,int c,int ind)
   {
           int s,i;
           struct m_c *t;
         if ( c < 0 )          if ( c < 0 )
                 return -1;                  return -1;
         if ( !m_c_tab ) {          extend_mctab( (ind<0)? 0: ind );
                 s = INIT_TAB_SIZ*sizeof(struct m_c);          if(ind >= 0) {
                 m_c_tab = (struct m_c *)MALLOC_ATOMIC(s);                  if (m_c_tab[ind].m<0 && m_c_tab[ind].c<0) {
                 for ( i = 0; i < INIT_TAB_SIZ; i++ ) {                          m_c_tab[ind].m = m; m_c_tab[ind].c = c;
                         m_c_tab[i].af_unix = 0;                          m_c_tab[ind].af_unix = af_unix;
                         m_c_tab[i].m = m_c_tab[i].c = -1;                          if (ind>=m_c_i) m_c_i = ind+1;
                           return ind;
                 }                  }
                 m_c_s = INIT_TAB_SIZ;                  return -1;
         }          }
 #if !defined(MPI)  #if !defined(MPI)
         for ( i = 0; i < m_c_i; i++ )          for ( i = 0; i < m_c_i; i++ )
Line 1017  int get_mcindex(int i)
Line 1070  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,maxfd,minfd;
         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 1088  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) ) {          maxfd = minfd = -1;
           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);
                           maxfd = maxfd<0 ? fd : MAX(fd,maxfd);
                           minfd = minfd<0 ? fd : MIN(fd,minfd);
                   }
         }          }
           if ( t0 ) {
                   MKLIST(*rp,t0); return;
           }
   
         n = select(FD_SETSIZE,&r,&w,&e,tvp);          n = select(FD_SETSIZE,&r,&w,&e,tvp);
   #if defined(VISUAL)
           for ( i = minfd, t = 0; n && i <= maxfd; i++ )
   #else
         for ( i = 0, t = 0; n && i < FD_SETSIZE; i++ )          for ( i = 0, t = 0; n && i < FD_SETSIZE; i++ )
   #endif
                 if ( FD_ISSET(i,&r) ) {                  if ( FD_ISSET(i,&r) ) {
                         /* index : index to iofp array */                          /* index : index to iofp array */
                         index = get_index(i);                          index = get_index(i);
Line 1364  void Pox_cmo_rpc(NODE arg,Obj *rp)
Line 1433  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 1451  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;
 }  }
   
Legend:
Removed from v.1.56  
changed lines
  Added in v.1.60
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>