[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.1.1.1 and 1.5

version 1.1.1.1, 1999/12/03 07:39:11 version 1.5, 2000/01/11 06:43:36
Line 1 
Line 1 
 /* $OpenXM: OpenXM/src/asir99/io/tcpf.c,v 1.8 1999/11/19 10:41:08 noro Exp $ */  /* $OpenXM: OpenXM_contrib2/asir2000/io/tcpf.c,v 1.4 1999/12/24 06:57:22 noro Exp $ */
 #if INET  #if INET
 #include "ca.h"  #include "ca.h"
 #include "parse.h"  #include "parse.h"
Line 45  void Pox_launch(),Pox_launch_nox(),Pox_launch_main();
Line 45  void Pox_launch(),Pox_launch_nox(),Pox_launch_main();
 void Pox_launch_generic();  void Pox_launch_generic();
 void Pox_shutdown();  void Pox_shutdown();
   
 void Pox_rpc(),Pox_cmo_rpc(),Pox_reset(),Pox_sync(),Pox_select();  void Pox_rpc(),Pox_cmo_rpc(),Pox_reset(),Pox_intr(),Pox_sync(),Pox_select();
   
 void Pox_push_local(),Pox_push_cmo(),Pox_push_vl(),Pox_push_cmd();  void Pox_push_local(),Pox_push_cmo(),Pox_push_vl(),Pox_push_cmd();
   
Line 84  struct ftab tcp_tab[] = {
Line 84  struct ftab tcp_tab[] = {
         {"ox_sync",Pox_sync,1},          {"ox_sync",Pox_sync,1},
 #if !MPI  #if !MPI
         {"ox_reset",Pox_reset,-2},          {"ox_reset",Pox_reset,-2},
           {"ox_intr",Pox_intr,1},
         {"ox_select",Pox_select,-2},          {"ox_select",Pox_select,-2},
 #endif  #endif
   
Line 93  struct ftab tcp_tab[] = {
Line 94  struct ftab tcp_tab[] = {
         {"ox_pop0_local",Pox_pop0_local,1},          {"ox_pop0_local",Pox_pop0_local,1},
         {"ox_pop_cmo",Pox_pop_cmo,1},          {"ox_pop_cmo",Pox_pop_cmo,1},
         {"ox_pop0_cmo",Pox_pop0_cmo,1},          {"ox_pop0_cmo",Pox_pop0_cmo,1},
         {"ox_get",Pox_get,1},          {"ox_get",Pox_get,-1},
         {"ox_pops",Pox_pops,-2},          {"ox_pops",Pox_pops,-2},
   
         {"ox_push_vl",Pox_push_vl,1},          {"ox_push_vl",Pox_push_vl,1},
Line 401  char *control_port_str,*server_port_str;
Line 402  char *control_port_str,*server_port_str;
         conn_str = conn_to_serv ? "1" : "0";          conn_str = conn_to_serv ? "1" : "0";
         rsh = use_ssh ? "ssh" : RSH;          rsh = use_ssh ? "ssh" : RSH;
         gethostname(localhost,BUFSIZ);          gethostname(localhost,BUFSIZ);
   #if !defined(VISUAL)
         if ( use_unix ) {          if ( use_unix ) {
                 if ( !fork() ) {                  if ( !fork() ) {
                           setpgid(0,getpid());
                         if ( dname )                          if ( dname )
                                 execlp("xterm","xterm","-name",OX_XTERM,"-display",dname,                                  execlp("xterm","xterm","-name",OX_XTERM,"-display",dname,
                                         "-geometry","60x10","-e",launcher,".",conn_str,                                          "-geometry","60x10","-e",launcher,".",conn_str,
Line 425  char *control_port_str,*server_port_str;
Line 428  char *control_port_str,*server_port_str;
                 fprintf(stderr,"%s\n",cmd);                  fprintf(stderr,"%s\n",cmd);
                 sleep(20);                  sleep(20);
 /*              system(cmd); */  /*              system(cmd); */
         } else {          } else
   #endif /* VISUAL */
           {
                 if ( dname )                  if ( dname )
                         sprintf(cmd,                          sprintf(cmd,
                                 "%s -n %s \"xterm -name %s -display %s -geometry 60x10 -e %s %s %s %s %s %s %s>&/dev/null&\">/dev/null",                                  "%s -n %s \"xterm -name %s -display %s -geometry 60x10 -e %s %s %s %s %s %s %s>&/dev/null&\">/dev/null",
Line 735  void Pox_get(arg,rp)
Line 740  void Pox_get(arg,rp)
 NODE arg;  NODE arg;
 Obj *rp;  Obj *rp;
 {  {
         int index = QTOS((Q)ARG0(arg));          int index;
         int s;          int s;
   
         valid_mctab_index(index);          if ( !arg ) {
         s = m_c_tab[index].c;                  /* client->server */
         ox_flush_stream_force(s);                  ox_get_result(0,rp);
         ox_get_result(s,rp);          } else {
                   /* server->client */
                   index = QTOS((Q)ARG0(arg));
                   valid_mctab_index(index);
                   s = m_c_tab[index].c;
                   ox_flush_stream_force(s);
                   ox_get_result(s,rp);
           }
 }  }
   
 void Pox_pops(arg,rp)  void Pox_pops(arg,rp)
Line 909  Q *rp;
Line 921  Q *rp;
                                 break;                                  break;
                 }                  }
                 ox_send_sync(c);                  ox_send_sync(c);
           } else
                   *rp = 0;
   }
   
   void Pox_intr(arg,rp)
   NODE arg;
   Q *rp;
   {
           int m;
           Obj obj;
           int index = QTOS((Q)ARG0(arg));
   
           valid_mctab_index(index);
           m = m_c_tab[index].m;
           if ( m >= 0 ) {
                   if ( argc(arg) == 1 ) {
                           ox_send_cmd(m,SM_control_intr);
                           ox_flush_stream_force(m);
                   }
                   *rp = ONE;
         } else          } else
                 *rp = 0;                  *rp = 0;
 }  }
Legend:
Removed from v.1.1.1.1  
changed lines
  Added in v.1.5
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>