| version 1.44, 2003/12/09 03:07:45 |
version 1.45, 2003/12/10 02:16:08 |
|
|
| * 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.43 2003/12/03 09:32:36 noro Exp $ |
* $OpenXM: OpenXM_contrib2/asir2000/io/tcpf.c,v 1.44 2003/12/09 03:07:45 noro Exp $ |
| */ |
*/ |
| #include "ca.h" |
#include "ca.h" |
| #include "parse.h" |
#include "parse.h" |
| Line 143 struct ftab tcp_tab[] = { |
|
| Line 143 struct ftab tcp_tab[] = { |
|
| {"ox_get_serverinfo",Pox_get_serverinfo,-1}, |
{"ox_get_serverinfo",Pox_get_serverinfo,-1}, |
| {"generate_port",Pgenerate_port,-1}, |
{"generate_port",Pgenerate_port,-1}, |
| |
|
| |
/* from master to client */ |
| {"ox_set_rank_102",Pox_set_rank_102,3}, |
{"ox_set_rank_102",Pox_set_rank_102,3}, |
| |
{"ox_tcp_accept_102",Pox_tcp_accept_102,3}, |
| |
{"ox_tcp_connect_102",Pox_tcp_connect_102,4}, |
| |
{"ox_reset_102",Pox_reset_102,1}, |
| |
|
| {"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_tcp_accept_102",Pox_tcp_accept_102,2}, |
|
| {"ox_tcp_connect_102",Pox_tcp_connect_102,3}, |
|
| {"ox_reset_102",Pox_reset_102,1}, |
|
| |
|
| {"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 313 void Pox_set_rank_102(NODE arg,Q *rp) |
|
| Line 314 void Pox_set_rank_102(NODE arg,Q *rp) |
|
| *rp = 0; |
*rp = 0; |
| } |
} |
| |
|
| /* ox_tcp_accept_102(port,rank) */ |
/* ox_tcp_accept_102(server,port,rank) */ |
| |
|
| void Pox_tcp_accept_102(NODE arg,Q *rp) |
void Pox_tcp_accept_102(NODE arg,Q *rp) |
| { |
{ |
| char port_str[BUFSIZ]; |
int s; |
| int port,s,use_unix,rank; |
int index = QTOS((Q)ARG0(arg)); |
| |
|
| if ( IS_CYGWIN || !ARG0(arg) || NUM(ARG0(arg)) ) { |
valid_mctab_index(index); |
| port = QTOS((Q)ARG0(arg)); |
s = m_c_tab[index].c; |
| sprintf(port_str,"%d",port); |
|
| use_unix = 0; |
ox_send_data(s,ARG1(arg)); |
| } else { |
ox_send_data(s,ARG2(arg)); |
| strcpy(port_str,BDY((STRING)ARG0(arg))); |
ox_send_cmd(s,SM_tcp_accept_102); |
| use_unix = 1; |
ox_flush_stream_force(s); |
| } |
*rp = 0; |
| s = try_bind_listen(use_unix,port_str); |
|
| s = try_accept(use_unix,s); |
|
| rank = QTOS((Q)ARG1(arg)); |
|
| if ( register_102(s,rank,1) < 0 ) |
|
| STOQ(-1,*rp); |
|
| else |
|
| *rp = 0; |
|
| } |
} |
| |
|
| /* |
/* |
| ox_tcp_connect_102(host,port,rank) |
ox_tcp_connect_102(server,host,port,rank) |
| */ |
*/ |
| |
|
| void Pox_tcp_connect_102(NODE arg,Q *rp) |
void Pox_tcp_connect_102(NODE arg,Q *rp) |
| { |
{ |
| char port_str[BUFSIZ]; |
int s; |
| char *host; |
int index = QTOS((Q)ARG0(arg)); |
| int port,s,use_unix,rank; |
|
| |
|
| if ( IS_CYGWIN || !ARG1(arg) || NUM(ARG1(arg)) ) { |
valid_mctab_index(index); |
| port = QTOS((Q)ARG1(arg)); |
s = m_c_tab[index].c; |
| sprintf(port_str,"%d",port); |
|
| use_unix = 0; |
ox_send_data(s,ARG1(arg)); |
| } else { |
ox_send_data(s,ARG2(arg)); |
| strcpy(port_str,BDY((STRING)ARG1(arg))); |
ox_send_data(s,ARG3(arg)); |
| use_unix = 1; |
ox_send_cmd(s,SM_tcp_connect_102); |
| } |
ox_flush_stream_force(s); |
| host = BDY((STRING)ARG0(arg)); |
*rp = 0; |
| s = try_connect(use_unix,host,port_str); |
|
| rank = QTOS((Q)ARG2(arg)); |
|
| if ( register_102(s,rank,0) < 0 ) |
|
| STOQ(-1,*rp); |
|
| else |
|
| *rp = 0; |
|
| } |
} |
| |
|
| /* |
/* |
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to tcpf.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [local] / OpenXM_contrib2 / asir2000 / io