Index: GossipClient.java =================================================================== RCS file: /cvsroot/javagroups/JGroups/src/org/jgroups/stack/GossipClient.java,v retrieving revision 1.16 diff -r1.16 GossipClient.java 4a5,21 > import java.io.ByteArrayOutputStream; > import java.io.DataInputStream; > import java.io.DataOutputStream; > import java.io.IOException; > import java.net.InetAddress; > import java.net.InetSocketAddress; > import java.net.Socket; > import java.net.SocketAddress; > import java.util.Enumeration; > import java.util.Hashtable; > import java.util.Iterator; > import java.util.LinkedList; > import java.util.List; > import java.util.Timer; > import java.util.TimerTask; > import java.util.Vector; > 7a25 > import org.jgroups.Version; 10,16d27 < import java.io.*; < import java.net.InetAddress; < import java.net.Socket; < import java.net.SocketAddress; < import java.net.InetSocketAddress; < import java.util.*; < 34c45 < boolean refresher_enabled=true; --- > boolean refresher_enabled=false; 40d50 < 198c208 < gossip_req.writeTo(out); --- > writeGossipData(out, gossip_req); 202c212 < if(log.isErrorEnabled()) log.error("exception connecting to host " + entry); --- > if(log.isErrorEnabled()) log.error("exception connecting to host " + entry, ex); 234c244,245 < gossip_req.writeTo(out); --- > //gossip_req.writeTo(out); > writeGossipData(out, gossip_req); 271d281 < // sock=new Socket(entry.getIpAddress(), entry.getPort()); 276d285 < 295c304 < if(log.isErrorEnabled()) log.error("exception connecting to host " + entry); --- > if(log.isErrorEnabled()) log.error("exception connecting to host " + entry, ex); 308a318,333 > private void writeGossipData(DataOutputStream out, GossipData gossip) throws IOException { > out.write(new byte[]{'b', 'e', 'l', 'a'}); // cookie. not sure this approach of writing here in the client is correct check it again > out.writeShort(Version.version); > out.writeByte(4); > IpAddress clientAddr = (IpAddress)gossip.getAddress(); > out.write(clientAddr.getIpAddress().getAddress()); > out.writeInt(clientAddr.getPort()); > out.writeBoolean(false);// no additional data after IpAddress > > ByteArrayOutputStream bout = new ByteArrayOutputStream(); > DataOutputStream dout = new DataOutputStream(bout); > gossip.writeTo(dout); > > out.writeInt(bout.size()); > out.write(bout.toByteArray()); > }