[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.62 and 1.66

version 1.62, 2012/12/17 07:20:45 version 1.66, 2013/11/22 00:43:41
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.61 2011/06/16 08:17:15 noro Exp $   * $OpenXM: OpenXM_contrib2/asir2000/io/tcpf.c,v 1.65 2013/11/21 23:15:37 ohara Exp $
 */  */
 #include "ca.h"  #include "ca.h"
 #include "parse.h"  #include "parse.h"
Line 58 
Line 58 
 #endif  #endif
 #include "ox.h"  #include "ox.h"
   
 #if defined(VISUAL)  
 #include <stdlib.h>  #include <stdlib.h>
   #if defined(VISUAL)
 #include <winsock2.h>  #include <winsock2.h>
 #include <process.h>  #include <process.h>
 #endif  #endif
Line 128  void Pgenerate_port(),Ptry_bind_listen(),Ptry_connect(
Line 128  void Pgenerate_port(),Ptry_bind_listen(),Ptry_connect(
 void Pregister_server();  void Pregister_server();
 void Pox_get_serverinfo();  void Pox_get_serverinfo();
 void Pox_mpi_myid(), Pox_mpi_nprocs();  void Pox_mpi_myid(), Pox_mpi_nprocs();
 void Pnd_exec_f4_red();  
 void Pox_tcp_accept_102(),Pox_tcp_connect_102();  void Pox_tcp_accept_102(),Pox_tcp_connect_102();
 void Pox_send_102(),Pox_recv_102();  void Pox_send_102(),Pox_recv_102();
 void Pox_set_rank_102();  void Pox_set_rank_102();
Line 203  struct ftab tcp_tab[] = {
Line 202  struct ftab tcp_tab[] = {
         {"ox_execute_string",Pox_execute_string,2},          {"ox_execute_string",Pox_execute_string,2},
         {"ox_execute_function",Pox_execute_function,3},          {"ox_execute_function",Pox_execute_function,3},
   
         {"nd_exec_f4_red",Pnd_exec_f4_red,0},  
   
   
         {0,0,0},          {0,0,0},
 };  };
   
Line 213  extern struct IOFP iofp[];
Line 209  extern struct IOFP iofp[];
 extern MATHCAP my_mathcap;  extern MATHCAP my_mathcap;
 extern int ox_exchange_mathcap;  extern int ox_exchange_mathcap;
   
 char *getenv();  Obj asir_pop_one();
   void asir_push_one(Obj);
   
 void Pnd_exec_f4_red(Q *rp)  
 {  
         nd_exec_f4_red_dist();  
         *rp = 0;  
 }  
   
 #if defined(MPI)  #if defined(MPI)
 extern int mpi_myid, mpi_nprocs;  extern int mpi_myid, mpi_nprocs;
   
Line 981  void ox_launch_main(int with_x,NODE arg,Obj *p)
Line 972  void ox_launch_main(int with_x,NODE arg,Obj *p)
   
 void extend_mctab(int bound)  void extend_mctab(int bound)
 {  {
         int s,i,n;          int i,n;
         struct m_c *t;          struct m_c *t;
     if ( !m_c_tab ) {      if ( !m_c_tab ) {
         n = (bound/INIT_TAB_SIZ + 1)*INIT_TAB_SIZ;          n = (bound/INIT_TAB_SIZ + 1)*INIT_TAB_SIZ;
Line 994  void extend_mctab(int bound)
Line 985  void extend_mctab(int bound)
     }else if (bound >= m_c_s) {      }else if (bound >= m_c_s) {
         n = (bound/INIT_TAB_SIZ + 1)*INIT_TAB_SIZ;          n = (bound/INIT_TAB_SIZ + 1)*INIT_TAB_SIZ;
         t = (struct m_c *)MALLOC_ATOMIC(n*sizeof(struct m_c));          t = (struct m_c *)MALLOC_ATOMIC(n*sizeof(struct m_c));
         bzero((void *)t,s);          bzero((void *)t,n*sizeof(struct m_c));
         bcopy((void *)m_c_tab,(void *)t,m_c_s*sizeof(struct m_c));          bcopy((void *)m_c_tab,(void *)t,m_c_s*sizeof(struct m_c));
         for ( i = m_c_s; i < n; i++ ) {          for ( i = m_c_s; i < n; i++ ) {
             t[i].af_unix = 0;              t[i].af_unix = 0;
Line 1041  int register_server(int af_unix,int m,int c,int ind)
Line 1032  int register_server(int af_unix,int m,int c,int ind)
 #endif  #endif
         if ( m_c_i == m_c_s ) {          if ( m_c_i == m_c_s ) {
                 s = (m_c_s+INIT_TAB_SIZ)*sizeof(struct m_c);                  s = (m_c_s+INIT_TAB_SIZ)*sizeof(struct m_c);
                 t = (struct m_c *)MALLOC_ATOMIC(s); bzero((void *)m_c_tab,s);                  t = (struct m_c *)MALLOC_ATOMIC(s);
                 bcopy((void *)m_c_tab,(void *)t,m_c_s*sizeof(struct m_c));                  bcopy((void *)m_c_tab,(void *)t,m_c_s*sizeof(struct m_c));
                 for ( i = 0; i < INIT_TAB_SIZ; i++ ) {                  for ( i = 0; i < INIT_TAB_SIZ; i++ ) {
                         m_c_tab[m_c_s+i].af_unix = 0;                          t[m_c_s+i].af_unix = 0;
                         m_c_tab[m_c_s+i].m = m_c_tab[m_c_s+i].c = -1;                          t[m_c_s+i].m = m_c_tab[m_c_s+i].c = -1;
                 }                  }
                 m_c_s += INIT_TAB_SIZ; m_c_tab = t;                  m_c_s += INIT_TAB_SIZ; m_c_tab = t;
         }          }
Legend:
Removed from v.1.62  
changed lines
  Added in v.1.66
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>