[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.59

version 1.58, 2010/09/01 08:01:09 version 1.59, 2010/12/12 03:20:53
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.58 2010/09/01 08:01:09 noro 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++ )
Legend:
Removed from v.1.58  
changed lines
  Added in v.1.59
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>