Thanks for the response Vishal. I agree that it should be used for both FLE
and normal communication (both server ports). I believe the diff I sent
incorporates that thinking, although I may not have been clear. I
considered that it be optional, but cases where you would want it to bind on
all interfaces seem rare to me, since it would require specializing the
config files for each server so that two different servers communicated with
a third server on different ports. Users who would want this to be optional
could achieve the same effect by specifying their own
"server.#=address[:port][:[port]" entry as "server.#:0.0.0.0[:port][:port]".
I guess my proposal is that the address specified in the server.# should be
used. Advanced configurations can specify 0:0:0:0 to get the current
behavior. This way there wouldn't need to be another option to say that
(which would need customized anyway in such configurations).
~Jared
On Fri, Aug 27, 2010 at 9:45 AM, Vishal K <vishalm...@gmail.com> wrote:
> Hi Jared,
>
> I like the idea of allowing communication with ZK on only the IP addresses
> specified in the config file. This is useful when you are having a host
> with
> multiple IP address and/or when you want to have traffic isolation. In our
> setup, we will use this feature for traffic isolation. We have multiple
> interfaces on the server, and we want to route certain type of traffic
> through certain interfaces.
>
> Why not have this feature for both FLE and leader-follower communication? I
> would suggest to keep this optional (add a property) since most users would
> prefer to have the ability to reach the servers from all interfaces.
>
> -Vishal
>
> On Thu, Aug 26, 2010 at 1:34 PM, Jared Cantwell <jared.cantw...@gmail.com
> >wrote:
>
> > Hello,
> >
> > My project currently has the need to specify the local address that is
> used
> > for leader communication (and not use the default of listening on all
> > interfaces). This is similar to the clientPortAddress parameter that was
> > recently added. After reviewing the code, we can't think of a reason why
> > only the port would be used with the wildcard interface, when servers are
> > already connecting specifically to that interface anyway. Is binding to
> > the
> > wildcard interface for leader communication intentional?
> >
> > I believe the change would be straightforward-- one change for each
> leader
> > port used. Note: this doesn't account for all leader election
> algorithms,
> > only the default.
> >
> > Index:
> > src/java/main/org/apache/zookeeper/server/quorum/QuorumCnxManager.java
> > ===================================================================
> > ---
> > src/java/main/org/apache/zookeeper/server/quorum/QuorumCnxManager.java
> > (revision 989805)
> > +++
> > src/java/main/org/apache/zookeeper/server/quorum/QuorumCnxManager.java
> > (working copy)
> > @@ -434,7 +434,7 @@
> > ss = ServerSocketChannel.open();
> > int port =
> > self.quorumPeers.get(self.getId()).electionAddr.getPort();
> > ss.socket().setReuseAddress(true);
> > - InetSocketAddress addr = new
> InetSocketAddress(port);
> > + InetSocketAddress addr =
> > self.quorumPeers.get(self.getId()).electionAddr;
> > LOG.info("My election bind port: " +
> addr.toString());
> > setName(addr.toString());
> > ss.socket().bind(addr);
> > Index: src/java/main/org/apache/zookeeper/server/quorum/Leader.java
> > ===================================================================
> > --- src/java/main/org/apache/zookeeper/server/quorum/Leader.java
> > (revision 989805)
> > +++ src/java/main/org/apache/zookeeper/server/quorum/Leader.java
> > (working
> > copy)
> > @@ -128,10 +128,11 @@
> > Leader(QuorumPeer self,LeaderZooKeeperServer zk) throws IOException {
> > this.self = self;
> > try {
> > - ss = new ServerSocket(self.getQuorumAddress().getPort());
> > + ss = new ServerSocket();
> > + ss.bind(self.getQuorumAddress());
> > } catch (BindException e) {
> > - LOG.error("Couldn't bind to port "
> > - + self.getQuorumAddress().getPort(), e);
> > + LOG.error("Couldn't bind to address "
> > + + self.getQuorumAddress().getAddress() + ":" +
> > self.getQuorumAddress().getPort(), e);
> > throw e;
> > }
> > this.zk=zk;
> >
> >
> > Does this seem like a reasonable change? Thoughts?
> >
> > ~Jared
> >
>
