[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.58 and 1.60

version 1.58, 2010/09/01 08:01:09 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.57 2010/04/23 04:44:52 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 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,s;          int fd,n,i,index,mcind,s,maxfd,minfd;
         fd_set r,w,e;          fd_set r,w,e;
         NODE list,t,t1,t0;          NODE list,t,t1,t0;
         Q q;          Q q;
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);
           maxfd = minfd = -1;
         for ( t = list, t0 = 0; 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);
Line 1043  void Pox_select(NODE arg,LIST *rp)
Line 1097  void Pox_select(NODE arg,LIST *rp)
                         MKNODE(t1,(Q)BDY(t),t0); t0 = t1;                          MKNODE(t1,(Q)BDY(t),t0); t0 = t1;
                 } else {                  } else {
                         fd = get_fd(s); FD_SET((unsigned int)fd,&r);                          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 ) {          if ( t0 ) {
Line 1050  void Pox_select(NODE arg,LIST *rp)
Line 1106  void Pox_select(NODE arg,LIST *rp)
         }          }
   
         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);
Legend:
Removed from v.1.58  
changed lines
  Added in v.1.60
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>