[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.47 and 1.48

version 1.47, 2003/12/10 07:37:40 version 1.48, 2003/12/11 05:48:04
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.46 2003/12/10 05:39:58 noro Exp $   * $OpenXM: OpenXM_contrib2/asir2000/io/tcpf.c,v 1.47 2003/12/10 07:37:40 noro Exp $
 */  */
 #include "ca.h"  #include "ca.h"
 #include "parse.h"  #include "parse.h"
Line 154  struct ftab tcp_tab[] = {
Line 154  struct ftab tcp_tab[] = {
         {"ox_send_102",Pox_send_102,2},          {"ox_send_102",Pox_send_102,2},
         {"ox_recv_102",Pox_recv_102,1},          {"ox_recv_102",Pox_recv_102,1},
         {"ox_bcast_102",Pox_bcast_102,-2},          {"ox_bcast_102",Pox_bcast_102,-2},
         {"ox_reduce_102",Pox_reduce_102,3},          {"ox_reduce_102",Pox_reduce_102,-3},
   
         {"try_bind_listen",Ptry_bind_listen,1},          {"try_bind_listen",Ptry_bind_listen,1},
         {"try_connect",Ptry_connect,2},          {"try_connect",Ptry_connect,2},
Line 1006  void Pox_bcast_102(NODE arg,Obj *rp)
Line 1006  void Pox_bcast_102(NODE arg,Obj *rp)
         int rank = QTOS((Q)ARG0(arg));          int rank = QTOS((Q)ARG0(arg));
         Obj data;          Obj data;
   
         if ( rank == myrank_102 ) {          if ( argc(arg) > 1 )
                 if ( argc(arg) == 1 )                  asir_push_one((Obj)ARG1(arg));
                         error("ox_bcast_102 : data should be given at the root");          ox_bcast_102(rank);
                 data = (Obj)ARG1(arg);          *rp = (Obj)asir_pop_one();
         }  
         ox_bcast_102(rank,&data);  
         *rp = data;  
 }  }
   
 void Pox_reduce_102(NODE arg,Obj *rp)  void Pox_reduce_102(NODE arg,Obj *rp)
 {  {
         int rank = QTOS((Q)ARG0(arg));          int root = QTOS((Q)ARG0(arg));
         STRING op;          STRING op;
         char *opname;          char *opname;
         void (*func)();          void (*func)();
Line 1032  void Pox_reduce_102(NODE arg,Obj *rp)
Line 1029  void Pox_reduce_102(NODE arg,Obj *rp)
         else {          else {
                 error("ox_reduce_102 : operation not supported");                  error("ox_reduce_102 : operation not supported");
         }          }
         ox_reduce_102(rank,func,(Obj)ARG2(arg),rp);          if ( argc(arg) > 2 )
                   asir_push_one((Obj)ARG2(arg));
           ox_reduce_102(root,func);
           *rp = (Obj)asir_pop_one();
 }  }
   
 void Pox_push_local(NODE arg,Obj *rp)  void Pox_push_local(NODE arg,Obj *rp)
Legend:
Removed from v.1.47  
changed lines
  Added in v.1.48
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>