FW: [javagroups-users] TCP Communications Problems
Brought to you by:
belaban
Menu
▾
▴
FW: [javagroups-users] TCP Communications Problems
|
From: Elvio H. A. <eva...@ei...> - 2002-11-08 13:40:14
|
Hi,
Now i have some logs about what is happening.
This log refers to the situation when no GOSSIP server is used.
The host that starts first is the mmhs23, and the second one is the mmhs30.
here it goes the logs :
[08:58:54[548]] [INFO] ClassConfigurator.ClassConfigurator(): mapping is:
1: class org.javagroups.stack.IpAddress
2: class org.javagroups.protocols.CAUSAL$CausalHeader
3: class org.javagroups.protocols.FD$FdHeader
4: class org.javagroups.protocols.FD_PID$FdHeader
5: class org.javagroups.protocols.FD_PROB$FdHeader
6: class org.javagroups.protocols.FD_SOCK$FdHeader
7: class org.javagroups.protocols.FRAG$FragHeader
8: class org.javagroups.protocols.MERGE$MergeHeader
9: class org.javagroups.protocols.NakAckHeader
10: class org.javagroups.protocols.PARTITIONER$PartitionerHeader
11: class org.javagroups.protocols.PerfHeader
12: class org.javagroups.protocols.PIGGYBACK$PiggybackHeader
13: class org.javagroups.protocols.PingHeader
14: class org.javagroups.protocols.TcpHeader
15: class org.javagroups.protocols.TOTAL$Header
16: class org.javagroups.protocols.TOTAL_OLD$TotalHeader
17: class org.javagroups.protocols.TOTAL_TOKEN$TotalTokenHeader
18: class org.javagroups.protocols.TOTAL_TOKEN$RingTokenHeader
19: class org.javagroups.protocols.TunnelHeader
20: class org.javagroups.protocols.UdpHeader
21: class org.javagroups.protocols.UNICAST$UnicastHeader
22: class org.javagroups.protocols.VERIFY_SUSPECT$VerifyHeader
23: class org.javagroups.protocols.WANPIPE$WanPipeHeader
24: class org.javagroups.protocols.pbcast.GMS$GmsHeader
25: class org.javagroups.protocols.pbcast.NakAckHeader
26: class org.javagroups.protocols.pbcast.PbcastHeader
27: class org.javagroups.protocols.pbcast.STABLE$StableHeader
28: class org.javagroups.protocols.pbcast.STATE_TRANSFER$StateHeader
29: class org.javagroups.protocols.SMACK$SmackHeader
50: class org.javagroups.service.lease.LeaseRequestHeader
51: class org.javagroups.service.lease.LeaseResponseHeader
52: class org.javagroups.service.lease.DenyResponseHeader
[08:58:54[788]] [INFO] GMS.setImpl(): changed role to
org.javagroups.protocols.pbcast.ClientGmsImpl
[08:58:54[818]] [INFO] GMS.becomeClient: null became client
[08:58:55[349]] [INFO] ConnectionTable.start(): server socket created on
mmhs23:7800
[08:58:55[379]] [INFO] TCPPING.down(): [FIND_INITIAL_MBRS] sending PING
request to localhost:7800
[08:58:55[379]] [INFO] TCPPING.down(): [FIND_INITIAL_MBRS] sending PING
request to localhost:7801
[08:58:55[419]] [INFO] TCP.connectionOpened(): opened connection to
localhost:7800
[08:58:55[429]] [INFO] ConnectionTable.Connection.init(): connection was
created to localhost:7800
[08:58:55[429]] [INFO] ConnectionTable.getConnection(): created socket to
localhost:7800
[08:58:55[459]] [INFO] ConnectionTable.run(): accepted connection,
client_sock=Socket[addr=/127.0.0.1,port=1897,localport=7800]
[08:58:55[469]] [INFO] ConnectionTable.Connection.matchCookie():
input_cookie is bela
[08:58:56[391]] [INFO] ConnectionTable.send(): connection to localhost:7801
could not be established: java.net.ConnectException: Connection refused:
connect
[08:58:56[401]] [INFO] ConnectionTable.Reaper.run(): thread was started.
Number of connections=2, reaper_interval=0, conn_expire_time=0
[08:58:56[401]] [INFO] TCP.connectionOpened(): opened connection to
mmhs23:7800
[08:58:56[401]] [INFO] ConnectionTable.Connection.init(): connection was
created to mmhs23:7800
[08:58:56[401]] [INFO] ConnectionTable.Reaper.run(): connection is 0 seconds
old (curr-time=1036745936401, last_access=1036745935459)
[08:58:56[411]] [INFO] ConnectionTable.Reaper.run(): connection
<127.0.0.1:1897 --> 127.0.0.1:7800> (0 secs old) has been idle for too long
(conn_expire_time=0), will be removed
[08:58:56[411]] [INFO] ConnectionTable.Connection.run(): exception is
java.net.SocketException: socket closed
[08:58:56[411]] [INFO] TCP.connectionClosed(): closed connection to
localhost:7800
[08:58:56[411]] [INFO] ConnectionTable.Reaper.run(): connection is 0 seconds
old (curr-time=1036745936401, last_access=1036745935469)
[08:58:56[441]] [INFO] ConnectionTable.Reaper.run(): connection
<127.0.0.1:7800 --> 127.0.0.1:1897> (0 secs old) has been idle for too long
(conn_expire_time=0), will be removed
[08:58:56[441]] [INFO] ConnectionTable.remove(): addr=localhost:7800,
connections are connections (0):
[08:58:56[441]] [INFO] ConnectionTable.Reaper.run(): reaper terminated
[08:58:56[451]] [INFO] TCP.receive(): received msg [dst: 127.0.0.1:7800,
src: mmhs23:7800 (2 headers), size = 0 bytes]
[08:58:56[451]] [INFO] ConnectionTable.remove(): addr=mmhs23:7800,
connections are connections (0):
[08:59:00[376]] [INFO] TCPPING.down(): [FIND_INITIAL_MBRS] initial members
are []
[08:59:00[386]] [DEBUG] ClientGmsImpl.join(): initial_mbrs are []
[08:59:00[386]] [INFO] ClientGmsImpl.join(): no initial members discovered:
creating group as first member
[08:59:00[386]] [INFO] GMS.installView(): view is [mmhs23:7800|0]
[mmhs23:7800]
[08:59:00[396]] [INFO] GMS.setImpl(): changed role to
org.javagroups.protocols.pbcast.CoordGmsImpl
[08:59:00[396]] [INFO] GMS.becomeCoordinator(): mmhs23:7800 became
coordinator
[08:59:00[416]] [INFO] ClientGmsImpl.becomeSingletonMember(): created group
(first member). My view is [mmhs23:7800|0], impl is
org.javagroups.protocols.pbcast.CoordGmsImpl
[08:59:00[436]] [INFO] STABLE.startStableTask(): stable task started;
num_gossip_runs=3, max_gossip_runs=3
[08:59:09[359]] [INFO] ConnectionTable.run(): accepted connection,
client_sock=Socket[addr=/193.126.91.227,port=3951,localport=7800]
[08:59:09[389]] [INFO] ConnectionTable.Connection.matchCookie():
input_cookie is bela
[08:59:09[550]] [INFO] TCP.connectionOpened(): opened connection to
MMHS30:7800
[08:59:09[550]] [INFO] ConnectionTable.Connection.init(): connection was
created to MMHS30:7800
[08:59:09[570]] [INFO] TCP.receive(): received msg [dst: mmhs23:7800, src:
MMHS30:7800 (2 headers), size = 0 bytes]
[08:59:09[580]] [INFO] ConnectionTable.Reaper.run(): thread was started.
Number of connections=1, reaper_interval=0, conn_expire_time=0
[08:59:09[580]] [INFO] ConnectionTable.Reaper.run(): connection is 0 seconds
old (curr-time=1036745949580, last_access=1036745949580)
[08:59:09[580]] [INFO] ConnectionTable.Reaper.run(): connection is 0 seconds
old (curr-time=1036745949580, last_access=1036745949580)
[08:59:09[580]] [INFO] ConnectionTable.Reaper.run(): connection is 0 seconds
old (curr-time=1036745949580, last_access=1036745949580)
[08:59:09[580]] [INFO] ConnectionTable.Reaper.run(): connection is 0 seconds
old (curr-time=1036745949580, last_access=1036745949580)
[08:59:09[580]] [INFO] ConnectionTable.Reaper.run(): connection is 0 seconds
old (curr-time=1036745949580, last_access=1036745949580)
[08:59:09[580]] [INFO] ConnectionTable.Reaper.run(): connection is 0 seconds
old (curr-time=1036745949580, last_access=1036745949580)
[08:59:09[580]] [INFO] ConnectionTable.Reaper.run(): connection is 0 seconds
old (curr-time=1036745949580, last_access=1036745949580)
[08:59:09[580]] [INFO] ConnectionTable.Reaper.run(): connection is 0 seconds
old (curr-time=1036745949580, last_access=1036745949580)
[08:59:09[580]] [INFO] ConnectionTable.Reaper.run(): connection is 0 seconds
old (curr-time=1036745949580, last_access=1036745949580)
[08:59:09[580]] [INFO] ConnectionTable.Reaper.run(): connection is 0 seconds
old (curr-time=1036745949580, last_access=1036745949580)
[08:59:09[580]] [INFO] ConnectionTable.Reaper.run(): connection is 0 seconds
old (curr-time=1036745949580, last_access=1036745949580)
[08:59:09[580]] [INFO] ConnectionTable.Reaper.run(): connection is 0 seconds
old (curr-time=1036745949580, last_access=1036745949580)
[08:59:09[580]] [INFO] ConnectionTable.Reaper.run(): connection is 0 seconds
old (curr-time=1036745949580, last_access=1036745949580)
[08:59:09[580]] [INFO] ConnectionTable.Reaper.run(): connection is 0 seconds
old (curr-time=1036745949580, last_access=1036745949580)
[08:59:09[580]] [INFO] ConnectionTable.Reaper.run(): connection is 0 seconds
old (curr-time=1036745949580, last_access=1036745949580)
[08:59:09[590]] [INFO] ConnectionTable.Reaper.run(): connection is 0 seconds
old (curr-time=1036745949590, last_access=1036745949580)
[08:59:09[590]] [INFO] ConnectionTable.Reaper.run(): connection <mmhs23:7800
--> mmhs23:3951> (0 secs old) has been idle for too long
(conn_expire_time=0), will be removed
[08:59:09[590]] [INFO] ConnectionTable.Connection.run(): exception is
java.net.SocketException: socket closed
[08:59:09[590]] [INFO] TCP.connectionClosed(): closed connection to
MMHS30:7800
[08:59:09[590]] [INFO] ConnectionTable.remove(): addr=MMHS30:7800,
connections are connections (0):
[08:59:09[590]] [INFO] ConnectionTable.Reaper.run(): reaper terminated
[08:59:10[441]] [INFO] STABLE.sendStableMessage(): mcasting digest
[mmhs23:7800: [0 : 0]
[08:59:10[441]] [INFO] STABLE.handleStableGossip(): received digest
mmhs23:7800#0 (-1) from mmhs23:7800
[08:59:10[441]] [INFO] STABLE.handleStableGossip(): sending stability msg
mmhs23:7800#0 (-1)
[08:59:10[441]] [INFO] STABLE.sendStabilityMessage(): stability_task=null,
delay is 981
[08:59:11[432]] [INFO] STABLE.handleStabilityMessage(): stability vector is
[mmhs23:7800#0]
[08:59:11[432]] [INFO] STABLE.handleStabilityMessage(): cancelling stability
task (running=true)
[08:59:11[432]] [INFO] NAKACK.stable(): received digest [mmhs23:7800: [-1 :
0]
once again
thanks
Élvio
-----Original Message-----
From: Elvio Henrique Andrade [mailto:eva...@ei...]
Sent: sexta-feira, 8 de Novembro de 2002 11:46
To: jav...@li...
Subject: [javagroups-users] TCP Communications Problems
Hi,
I am trying to use your example ViewDemo in two different machines using TCP
and it doesn't seem to work. The two hosts can't communicate with each
other. In the HostA we have the following properties :
String props="TCP(start_port=7800):" +
"TCPPING(initial_hosts=localhost[7800];port_range=2;" +
"timeout=5000;num_initial_members=3;up_thread=true;down_thread=true):" +
"VERIFY_SUSPECT(timeout=1500):" +
"pbcast.STABLE(desired_avg_gossip=200000;down_thread=false;up_thread=false):
"+
"pbcast.NAKACK(down_thread=true;up_thread=true;gc_lag=100;retransmit_timeout
=3000):" +
"pbcast.GMS(join_timeout=5000;join_retry_timeout=2000;shun=false;" +
"print_local_addr=true;down_thread=true;up_thread=true)";
And on HostB we have :
String props="TCP(start_port=7800):" +
"TCPPING(initial_hosts=HostA[7800];port_range=2;" +
"timeout=5000;num_initial_members=3;up_thread=true;down_thread=true):" +
"VERIFY_SUSPECT(timeout=1500):" +
"pbcast.STABLE(desired_avg_gossip=200000;down_thread=false;up_thread=false):
"+
"pbcast.NAKACK(down_thread=true;up_thread=true;gc_lag=100;retransmit_timeout
=3000):" +
"pbcast.GMS(join_timeout=5000;join_retry_timeout=2000;shun=false;" +
"print_local_addr=true;down_thread=true;up_thread=true)";
We also tried to use a GOSSIP server, so we started one in HostA on the port
5555, then we changed the properties in HostA to :
String props="TCP(start_port=7800):" +
"TCPGOSSIP(initial_hosts=localhost[5555];gossip_refresh_rate=10000;" +
"num_initial_members=3;up_thread=true;down_thread=true):" +
"VERIFY_SUSPECT(timeout=1500):" +
"pbcast.STABLE(desired_avg_gossip=200000;down_thread=false;up_thread=false):
"+
"pbcast.NAKACK(down_thread=true;up_thread=true;gc_lag=100;retransmit_timeout
=3000):" +
"pbcast.GMS(join_timeout=5000;join_retry_timeout=2000;shun=false;" +
"print_local_addr=true;down_thread=true;up_thread=true)";
and in HostB to :
String props="TCP(start_port=7800):" +
"TCPGOSSIP(initial_hosts=HostA[5555];gossip_refresh_rate=10000;" +
"num_initial_members=3;up_thread=true;down_thread=true):" +
"VERIFY_SUSPECT(timeout=1500):" +
"pbcast.STABLE(desired_avg_gossip=200000;down_thread=false;up_thread=false):
"+
"pbcast.NAKACK(down_thread=true;up_thread=true;gc_lag=100;retransmit_timeout
=3000):" +
"pbcast.GMS(join_timeout=5000;join_retry_timeout=2000;shun=false;" +
"print_local_addr=true;down_thread=true;up_thread=true)";
No modifications in the behaviour of the demo seemed to occur. They both
start well but aren't able to find anyone else then themselves.
Can anyone help and show me how to put two entities communicating with each
other using TCP?
Thanks in advance
Élvio Andrade
|