Package org.apache.zookeeper.server.NIOServerCnxn

Examples of org.apache.zookeeper.server.NIOServerCnxn.Factory

116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
                zks.addCommittedProposal(request);
            }
        }

        if (request.hdr != null && request.hdr.getType() == OpCode.closeSession) {
            Factory scxn = zks.getServerCnxnFactory();
            // this might be possible since
            // we might just be playing diffs from the leader
            if (scxn != null) {
                scxn.closeSession(request.sessionId);
            }
        }

        if (request.cnxn == null) {
            return;
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
                zks.getZKDatabase().addCommittedProposal(request);
            }
        }

        if (request.hdr != null && request.hdr.getType() == OpCode.closeSession) {
            Factory scxn = zks.getServerCnxnFactory();
            // this might be possible since
            // we might just be playing diffs from the leader
            if (scxn != null && request.cnxn == null) {
                // calling this if we have the cnxn results in the client's
                // close session response being lost - we've already closed
                // the session/socket here before we can send the closeSession
                // in the switch block below
                scxn.closeSession(request.sessionId);
                return;
            }
        }

        if (request.cnxn == null) {
View Full Code Here
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
                zks.getZKDatabase().addCommittedProposal(request);
            }
        }

        if (request.hdr != null && request.hdr.getType() == OpCode.closeSession) {
            Factory scxn = zks.getServerCnxnFactory();
            // this might be possible since
            // we might just be playing diffs from the leader
            if (scxn != null && request.cnxn == null) {
                // calling this if we have the cnxn results in the client's
                // close session response being lost - we've already closed
                // the session/socket here before we can send the closeSession
                // in the switch block below
                scxn.closeSession(request.sessionId);
                return;
            }
        }

        if (request.cnxn == null) {
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
                zks.addCommittedProposal(request);
            }
        }

        if (request.hdr != null && request.hdr.getType() == OpCode.closeSession) {
            Factory scxn = zks.getServerCnxnFactory();
            // this might be possible since
            // we might just be playing diffs from the leader
            if (scxn != null) {
                scxn.closeSession(request.sessionId);
            }
        }

        if (request.cnxn == null) {
            return;
View Full Code Here
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
                zks.addCommittedProposal(request);
            }
        }

        if (request.hdr != null && request.hdr.getType() == OpCode.closeSession) {
            Factory scxn = zks.getServerCnxnFactory();
            // this might be possible since
            // we might just be playing diffs from the leader
            if (scxn != null) {
                scxn.closeSession(request.sessionId);
            }
        }

        if (request.cnxn == null) {
            return;
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
        File localfile = new File("./target/zookeeper.data");
        ZooKeeperServer zkServer;
        zkServer = new ZooKeeperServer(localfile, localfile, 2000);
        for (zkport = 60000; true; zkport++)
            try {
                zkFactory = new Factory(new InetSocketAddress(zkport));
                break;
            } catch (BindException e) {
                if (zkport == 65535) throw new IOException("Fail to find a port for Zookeeper server to bind");
            }
        LOG.info("Zookeeper port allocated:"+zkport);
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
                zks.addCommittedProposal(request);
            }
        }

        if (request.hdr != null && request.hdr.getType() == OpCode.closeSession) {
            Factory scxn = zks.getServerCnxnFactory();
            // this might be possible since
            // we might just be playing diffs from the leader
            if (scxn != null) {
                scxn.closeSession(request.sessionId);
            }
        }

        if (request.cnxn == null) {
            return;
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
                zks.addCommittedProposal(request);
            }
        }

        if (request.hdr != null && request.hdr.getType() == OpCode.closeSession) {
            Factory scxn = zks.getServerCnxnFactory();
            // this might be possible since
            // we might just be playing diffs from the leader
            if (scxn != null) {
                scxn.closeSession(request.sessionId);
            }
        }

        if (request.cnxn == null) {
            return;
View Full Code Here
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
                zks.getZKDatabase().addCommittedProposal(request);
            }
        }

        if (request.hdr != null && request.hdr.getType() == OpCode.closeSession) {
            Factory scxn = zks.getServerCnxnFactory();
            // this might be possible since
            // we might just be playing diffs from the leader
            if (scxn != null && request.cnxn == null) {
                // calling this if we have the cnxn results in the client's
                // close session response being lost - we've already closed
                // the session/socket here before we can send the closeSession
                // in the switch block below
                scxn.closeSession(request.sessionId);
                return;
            }
        }

        if (request.cnxn == null) {
View Full Code Here
93
94
95
96
97
98
99
100
101
102
103
   * @return fresh {@link ZooKeeperServerRunnable} instance.
   */
  public static final ZooKeeperServerRunnable newInstance(
      ServerConfig zkServerConfig, boolean addShutdownHook) {
    final ZooKeeperServer zkServer = initZKServer(zkServerConfig);
    final Factory zkCnxnFactory = initZKCxnFactory(zkServerConfig);
    final ZooKeeperServerRunnable runnable = new ZooKeeperServerRunnable(
        zkServer, zkCnxnFactory);
    if (addShutdownHook) {
      addShutdownHooks(runnable);
    }
View Full Code Here
TOP

Related Classes of org.apache.zookeeper.server.NIOServerCnxn.Factory

  • com.yahoo.storm.yarn.EmbeddedZKServer
  • net.scharrenbach.zookeeper.test.ZooKeeperServerRunnable
  • org.apache.zookeeper.server.FinalRequestProcessor
  • org.eclipse.ecf.provider.zookeeper.core.ZooDiscoveryContainer
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.