Package org.apache.zookeeper.server.persistence

Examples of org.apache.zookeeper.server.persistence.FileTxnSnapLog

66
67
68
69
70
71
72
73
74
75
76
            public NIOServerCnxn.Factory createConnectionFactory()throws IOException {
                return new ObservableNIOServerCnxn.Factory(getClientPort());
            }
            public ZooKeeperServer createServer() throws IOException {
                ManagedZooKeeperServer zks = new ManagedZooKeeperServer(
                        new FileTxnSnapLog(new File(ServerConfig.getDataDir()),
                        new File(ServerConfig.getDataLogDir())),
                new ZooKeeperServer.BasicDataTreeBuilder());
                return zks;
            }
        });
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
            runPeer(new QuorumPeer.Factory() {
                public QuorumPeer create(NIOServerCnxn.Factory cnxnFactory)
                throws IOException {
                    ManagedQuorumPeer peer = new ManagedQuorumPeer();
                    peer.setClientPort(ServerConfig.getClientPort());
                    FileTxnSnapLog factory = new FileTxnSnapLog(new
                            File(ServerConfig.getDataLogDir()), new 
                                    File(ServerConfig.getDataDir()));
                    peer.setTxnFactory(factory);
                    peer.setQuorumPeers(QuorumPeerConfig.getServers());
                    peer.setElectionType(QuorumPeerConfig.getElectionAlg());
View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
            public ZooKeeperServer createServer() throws IOException {
                // create a file logger url from the command line args
                ZooKeeperServer zks = new ZooKeeperServer();

               FileTxnSnapLog ftxn = new FileTxnSnapLog(new
                       File(ServerConfig.getDataLogDir()),
                        new File(ServerConfig.getDataDir()));
               zks.setTxnLogFactory(ftxn);
               return zks;
            }
View Full Code Here
165
166
167
168
169
170
171
172
     * test code.
     * It defaults to FileLogProvider persistence provider.
     */
    public ZooKeeperServer(File snapDir, File logDir, int tickTime)
            throws IOException {
        this(new FileTxnSnapLog(snapDir,logDir),
                tickTime,new BasicDataTreeBuilder());
    }
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
        FileSupport.toRichFile(data_dir()).recursiveDelete();

        System.out.println("Starting ZooKeeper");
        ZooKeeperServer zk_server = new ZooKeeperServer();
        zk_server.setTickTime(500);
        zk_server.setTxnLogFactory(new FileTxnSnapLog(new File(data_dir(), "zk-log"), new File(data_dir(), "zk-data")));
        connector = new NIOServerCnxnFactory();
        connector.configure(new InetSocketAddress(0), 100);
        connector.startup(zk_server);
        System.out.println("ZooKeeper started");
    }
View Full Code Here
127
128
129
130
131
132
133
134
135
136
137
                }
            }
            zkServer = new ZooKeeperServer();
            File dataDir = new File("./target/zookeeper/log");
            File snapDir = new File("./target/zookeeper/data");
            FileTxnSnapLog ftxn = new FileTxnSnapLog(dataDir, snapDir);
            zkServer.setTxnLogFactory(ftxn);
            zkServer.setTickTime(1000);
            connectionFactory = new NIOServerCnxn.Factory(new InetSocketAddress("localhost", clientPort), 0);
            connectionFactory.startup(zkServer);
        }
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
                cleanZookeeperDir();
            }
            zkServer = new ZooKeeperServer();
            File dataDir = new File(zookeeperBaseDir, "log");
            File snapDir = new File(zookeeperBaseDir, "data");
            FileTxnSnapLog ftxn = new FileTxnSnapLog(dataDir, snapDir);
            zkServer.setTxnLogFactory(ftxn);
            zkServer.setTickTime(1000);
            connectionFactory = new NIOServerCnxn.Factory(new InetSocketAddress("localhost", clientPort), 0);
            connectionFactory.startup(zkServer);
        }
View Full Code Here
141
142
143
144
145
146
147
148
149
150
151
                }
            }
            zkServer = new ZooKeeperServer();
            File dataDir = new File("./target/zookeeper/log");
            File snapDir = new File("./target/zookeeper/data");
            FileTxnSnapLog ftxn = new FileTxnSnapLog(dataDir, snapDir);
            zkServer.setTxnLogFactory(ftxn);
            zkServer.setTickTime(1000);
            connectionFactory = new NIOServerCnxn.Factory(new InetSocketAddress("localhost", clientPort), 0);
            connectionFactory.startup(zkServer);
        }
View Full Code Here
122
123
124
125
126
127
128
129
130
131
132
              new NIOServerCnxn.Factory(config.getClientPortAddress(),
                      config.getMaxClientCnxns());
 
          quorumPeer = new QuorumPeer();
          quorumPeer.setClientPortAddress(config.getClientPortAddress());
          quorumPeer.setTxnFactory(new FileTxnSnapLog(
                      new File(config.getDataLogDir()),
                      new File(config.getDataDir())));
          quorumPeer.setQuorumPeers(config.getServers());
          quorumPeer.setElectionType(config.getElectionAlg());
          quorumPeer.setMyid(config.getServerId());
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
     */
    @Test
    public void testTxnFailure() throws Exception {
        long count = 1;
        File tmpDir = ClientBase.createTmpDir();
        FileTxnSnapLog logFile = new FileTxnSnapLog(tmpDir, tmpDir);
        DataTree dt = new DataTree();
        dt.createNode("/test", new byte[0], null, 0, 1, 1);
        for (count = 1; count <= 3; count++) {
            dt.createNode("/test/" + count, new byte[0], null, 0, count,
                    System.currentTimeMillis());
View Full Code Here
TOP

Related Classes of org.apache.zookeeper.server.persistence.FileTxnSnapLog

  • co.paralleluniverse.galaxy.test.GalaxyTestingUtils
  • co.paralleluniverse.galaxy.testing.GalaxyTestingUtils
  • com.cloudera.oryx.zk.LocalZKServer
  • com.facebook.presto.kafka.util.EmbeddedZookeeper
  • com.greplin.zookeeper.EmbeddedZookeeperServer
  • com.linkedin.d2.quorum.ZKPeer
  • com.senseidb.federated.broker.TestZkServer
  • com.senseidb.gateway.test.TestZkServer
  • com.senseidb.test.TestZkServer
  • io.fabric8.groups.GroupTest
    • 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.