1. 包列表
  2. 类列表
  3. org.apache.zookeeper.server.persistence.FileHeader

Java 类org.apache.zookeeper.server.persistence.FileHeader 实例源码

项目：fuck_zookeeper    文件：LoadFromLogTest.java    
/**
 * Simulates ZOOKEEPER-1069 and verifies that flush() before padLogFile
 * fixes it.
 */
@Test
public void testPad() throws Exception {
    File tmpDir = ClientBase.createTmpDir();
    FileTxnLog txnLog = new FileTxnLog(tmpDir);
    TxnHeader txnHeader = new TxnHeader(0xabcd, 0x123, 0x123,
          System.currentTimeMillis(), OpCode.create);
    Record txn = new CreateTxn("/Test", new byte[0], null, false, 1);
    txnLog.append(txnHeader, txn);
    FileInputStream in = new FileInputStream(tmpDir.getPath() + "/log." +
          Long.toHexString(txnHeader.getZxid()));
    BinaryInputArchive ia  = BinaryInputArchive.getArchive(in);
    FileHeader header = new FileHeader();
    header.deserialize(ia, "fileheader");
    LOG.info("Received magic : " + header.getMagic() +
          " Expected : " + FileTxnLog.TXNLOG_MAGIC);
    Assert.assertTrue("Missing magic number ",
          header.getMagic() == FileTxnLog.TXNLOG_MAGIC);
}
项目：https-github.com-apache-zookeeper    文件：LoadFromLogTest.java    
/**
 * Simulates ZOOKEEPER-1069 and verifies that flush() before padLogFile
 * fixes it.
 */
@Test
public void testPad() throws Exception {
    File tmpDir = ClientBase.createTmpDir();
    FileTxnLog txnLog = new FileTxnLog(tmpDir);
    TxnHeader txnHeader = new TxnHeader(0xabcd, 0x123, 0x123,
          Time.currentElapsedTime(), OpCode.create);
    Record txn = new CreateTxn("/Test", new byte[0], null, false, 1);
    txnLog.append(txnHeader, txn);
    FileInputStream in = new FileInputStream(tmpDir.getPath() + "/log." +
          Long.toHexString(txnHeader.getZxid()));
    BinaryInputArchive ia  = BinaryInputArchive.getArchive(in);
    FileHeader header = new FileHeader();
    header.deserialize(ia, "fileheader");
    LOG.info("Received magic : " + header.getMagic() +
          " Expected : " + FileTxnLog.TXNLOG_MAGIC);
    Assert.assertTrue("Missing magic number ",
          header.getMagic() == FileTxnLog.TXNLOG_MAGIC);
}
项目：ZooKeeper    文件：LoadFromLogTest.java    
/**
 * Simulates ZOOKEEPER-1069 and verifies that flush() before padLogFile
 * fixes it.
 */
@Test
public void testPad() throws Exception {
    File tmpDir = ClientBase.createTmpDir();
    FileTxnLog txnLog = new FileTxnLog(tmpDir);
    TxnHeader txnHeader = new TxnHeader(0xabcd, 0x123, 0x123,
          System.currentTimeMillis(), OpCode.create);
    Record txn = new CreateTxn("/Test", new byte[0], null, false, 1);
    txnLog.append(txnHeader, txn);
    FileInputStream in = new FileInputStream(tmpDir.getPath() + "/log." +
          Long.toHexString(txnHeader.getZxid()));
    BinaryInputArchive ia  = BinaryInputArchive.getArchive(in);
    FileHeader header = new FileHeader();
    header.deserialize(ia, "fileheader");
    LOG.info("Received magic : " + header.getMagic() +
          " Expected : " + FileTxnLog.TXNLOG_MAGIC);
    Assert.assertTrue("Missing magic number ",
          header.getMagic() == FileTxnLog.TXNLOG_MAGIC);
}
项目：StreamProcessingInfrastructure    文件：LoadFromLogTest.java    
/**
 * Simulates ZOOKEEPER-1069 and verifies that flush() before padLogFile
 * fixes it.
 */
@Test
public void testPad() throws Exception {
    File tmpDir = ClientBase.createTmpDir();
    FileTxnLog txnLog = new FileTxnLog(tmpDir);
    TxnHeader txnHeader = new TxnHeader(0xabcd, 0x123, 0x123,
          System.currentTimeMillis(), OpCode.create);
    Record txn = new CreateTxn("/Test", new byte[0], null, false, 1);
    txnLog.append(txnHeader, txn);
    FileInputStream in = new FileInputStream(tmpDir.getPath() + "/log." +
          Long.toHexString(txnHeader.getZxid()));
    BinaryInputArchive ia  = BinaryInputArchive.getArchive(in);
    FileHeader header = new FileHeader();
    header.deserialize(ia, "fileheader");
    LOG.info("Received magic : " + header.getMagic() +
          " Expected : " + FileTxnLog.TXNLOG_MAGIC);
    Assert.assertTrue("Missing magic number ",
          header.getMagic() == FileTxnLog.TXNLOG_MAGIC);
}
项目：bigstreams    文件：LoadFromLogTest.java    
/**
 * Simulates ZOOKEEPER-1069 and verifies that flush() before padLogFile
 * fixes it.
 */
@Test
public void testPad() throws Exception {
    File tmpDir = ClientBase.createTmpDir();
    FileTxnLog txnLog = new FileTxnLog(tmpDir);
    TxnHeader txnHeader = new TxnHeader(0xabcd, 0x123, 0x123,
          System.currentTimeMillis(), OpCode.create);
    Record txn = new CreateTxn("/Test", new byte[0], null, false, 1);
    txnLog.append(txnHeader, txn);
    FileInputStream in = new FileInputStream(tmpDir.getPath() + "/log." +
          Long.toHexString(txnHeader.getZxid()));
    BinaryInputArchive ia  = BinaryInputArchive.getArchive(in);
    FileHeader header = new FileHeader();
    header.deserialize(ia, "fileheader");
    LOG.info("Received magic : " + header.getMagic() +
          " Expected : " + FileTxnLog.TXNLOG_MAGIC);
    Assert.assertTrue("Missing magic number ",
          header.getMagic() == FileTxnLog.TXNLOG_MAGIC);
}
项目：bigstreams    文件：LoadFromLogTest.java    
/**
 * Simulates ZOOKEEPER-1069 and verifies that flush() before padLogFile
 * fixes it.
 */
@Test
public void testPad() throws Exception {
    File tmpDir = ClientBase.createTmpDir();
    FileTxnLog txnLog = new FileTxnLog(tmpDir);
    TxnHeader txnHeader = new TxnHeader(0xabcd, 0x123, 0x123,
          System.currentTimeMillis(), OpCode.create);
    Record txn = new CreateTxn("/Test", new byte[0], null, false, 1);
    txnLog.append(txnHeader, txn);
    FileInputStream in = new FileInputStream(tmpDir.getPath() + "/log." +
          Long.toHexString(txnHeader.getZxid()));
    BinaryInputArchive ia  = BinaryInputArchive.getArchive(in);
    FileHeader header = new FileHeader();
    header.deserialize(ia, "fileheader");
    LOG.info("Expected header :" + header.getMagic() +
          " Received : " + FileTxnLog.TXNLOG_MAGIC);
    Assert.assertTrue("Missing magic number ",
          header.getMagic() == FileTxnLog.TXNLOG_MAGIC);
}
项目：zookeeper    文件：LoadFromLogTest.java    
/**
 * Simulates ZOOKEEPER-1069 and verifies that flush() before padLogFile
 * fixes it.
 */
@Test
public void testPad() throws Exception {
    File tmpDir = ClientBase.createTmpDir();
    FileTxnLog txnLog = new FileTxnLog(tmpDir);
    TxnHeader txnHeader = new TxnHeader(0xabcd, 0x123, 0x123,
          System.currentTimeMillis(), OpCode.create);
    Record txn = new CreateTxn("/Test", new byte[0], null, false, 1);
    txnLog.append(txnHeader, txn);
    FileInputStream in = new FileInputStream(tmpDir.getPath() + "/log." +
          Long.toHexString(txnHeader.getZxid()));
    BinaryInputArchive ia  = BinaryInputArchive.getArchive(in);
    FileHeader header = new FileHeader();
    header.deserialize(ia, "fileheader");
    LOG.info("Received magic : " + header.getMagic() +
          " Expected : " + FileTxnLog.TXNLOG_MAGIC);
    Assert.assertTrue("Missing magic number ",
          header.getMagic() == FileTxnLog.TXNLOG_MAGIC);
}
项目：SecureKeeper    文件：LoadFromLogTest.java    
/**
 * Simulates ZOOKEEPER-1069 and verifies that flush() before padLogFile
 * fixes it.
 */
@Test
public void testPad() throws Exception {
    File tmpDir = ClientBase.createTmpDir();
    FileTxnLog txnLog = new FileTxnLog(tmpDir);
    TxnHeader txnHeader = new TxnHeader(0xabcd, 0x123, 0x123,
          Time.currentElapsedTime(), OpCode.create);
    Record txn = new CreateTxn("/Test", new byte[0], null, false, 1);
    txnLog.append(txnHeader, txn);
    FileInputStream in = new FileInputStream(tmpDir.getPath() + "/log." +
          Long.toHexString(txnHeader.getZxid()));
    BinaryInputArchive ia  = BinaryInputArchive.getArchive(in);
    FileHeader header = new FileHeader();
    header.deserialize(ia, "fileheader");
    LOG.info("Received magic : " + header.getMagic() +
          " Expected : " + FileTxnLog.TXNLOG_MAGIC);
    Assert.assertTrue("Missing magic number ",
          header.getMagic() == FileTxnLog.TXNLOG_MAGIC);
}
项目：SecureKeeper    文件：LoadFromLogTest.java    
/**
 * Simulates ZOOKEEPER-1069 and verifies that flush() before padLogFile
 * fixes it.
 */
@Test
public void testPad() throws Exception {
    File tmpDir = ClientBase.createTmpDir();
    FileTxnLog txnLog = new FileTxnLog(tmpDir);
    TxnHeader txnHeader = new TxnHeader(0xabcd, 0x123, 0x123,
          Time.currentElapsedTime(), OpCode.create);
    Record txn = new CreateTxn("/Test", new byte[0], null, false, 1);
    txnLog.append(txnHeader, txn);
    FileInputStream in = new FileInputStream(tmpDir.getPath() + "/log." +
          Long.toHexString(txnHeader.getZxid()));
    BinaryInputArchive ia  = BinaryInputArchive.getArchive(in);
    FileHeader header = new FileHeader();
    header.deserialize(ia, "fileheader");
    LOG.info("Received magic : " + header.getMagic() +
          " Expected : " + FileTxnLog.TXNLOG_MAGIC);
    Assert.assertTrue("Missing magic number ",
          header.getMagic() == FileTxnLog.TXNLOG_MAGIC);
}
项目：exhibitor    文件：ZooKeeperLogParser.java    
public ZooKeeperLogParser(InputStream log)
{
    logStream = BinaryInputArchive.getArchive(log);

    boolean         localValidHeader = false;
    try
    {
        FileHeader fhdr = new FileHeader();
        fhdr.deserialize(logStream, "fileheader");
        localValidHeader = (fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC);
    }
    catch ( IOException e )
    {
        // ignore
    }
    validHeader = localValidHeader;
}
项目：StreamBench    文件：LoadFromLogTest.java    
/**
 * Simulates ZOOKEEPER-1069 and verifies that flush() before padLogFile
 * fixes it.
 */
@Test
public void testPad() throws Exception {
    File tmpDir = ClientBase.createTmpDir();
    FileTxnLog txnLog = new FileTxnLog(tmpDir);
    TxnHeader txnHeader = new TxnHeader(0xabcd, 0x123, 0x123,
          System.currentTimeMillis(), OpCode.create);
    Record txn = new CreateTxn("/Test", new byte[0], null, false, 1);
    txnLog.append(txnHeader, txn);
    FileInputStream in = new FileInputStream(tmpDir.getPath() + "/log." +
          Long.toHexString(txnHeader.getZxid()));
    BinaryInputArchive ia  = BinaryInputArchive.getArchive(in);
    FileHeader header = new FileHeader();
    header.deserialize(ia, "fileheader");
    LOG.info("Received magic : " + header.getMagic() +
          " Expected : " + FileTxnLog.TXNLOG_MAGIC);
    Assert.assertTrue("Missing magic number ",
          header.getMagic() == FileTxnLog.TXNLOG_MAGIC);
}
项目：helix    文件：ZKLogFormatter.java    
private static void readSnapshotLog(String snapshotPath) throws Exception {
  FileInputStream fis = new FileInputStream(snapshotPath);
  BinaryInputArchive ia = BinaryInputArchive.getArchive(fis);
  Map<Long, Integer> sessions = new HashMap<Long, Integer>();
  DataTree dt = new DataTree();
  FileHeader header = new FileHeader();
  header.deserialize(ia, "fileheader");
  if (header.getMagic() != FileSnap.SNAP_MAGIC) {
    throw new IOException("mismatching magic headers " + header.getMagic() + " !=  "
        + FileSnap.SNAP_MAGIC);
  }
  SerializeUtils.deserializeSnapshot(dt, ia, sessions);

  if (bw != null) {
    bw.write(sessions.toString());
    bw.newLine();
  } else {
    System.out.println(sessions);
  }
  traverse(dt, 1, "/");

}
项目：LoadBalanced_zk    文件：LoadFromLogTest.java    
/**
 * Simulates ZOOKEEPER-1069 and verifies that flush() before padLogFile
 * fixes it.
 */
@Test
public void testPad() throws Exception {
    File tmpDir = ClientBase.createTmpDir();
    FileTxnLog txnLog = new FileTxnLog(tmpDir);
    TxnHeader txnHeader = new TxnHeader(0xabcd, 0x123, 0x123,
          System.currentTimeMillis(), OpCode.create);
    Record txn = new CreateTxn("/Test", new byte[0], null, false, 1);
    txnLog.append(txnHeader, txn);
    FileInputStream in = new FileInputStream(tmpDir.getPath() + "/log." +
          Long.toHexString(txnHeader.getZxid()));
    BinaryInputArchive ia  = BinaryInputArchive.getArchive(in);
    FileHeader header = new FileHeader();
    header.deserialize(ia, "fileheader");
    LOG.info("Received magic : " + header.getMagic() +
          " Expected : " + FileTxnLog.TXNLOG_MAGIC);
    Assert.assertTrue("Missing magic number ",
          header.getMagic() == FileTxnLog.TXNLOG_MAGIC);
}
项目：LoadBalanced_zk    文件：LoadFromLogTest.java    
/**
 * Simulates ZOOKEEPER-1069 and verifies that flush() before padLogFile
 * fixes it.
 */
@Test
public void testPad() throws Exception {
    File tmpDir = ClientBase.createTmpDir();
    FileTxnLog txnLog = new FileTxnLog(tmpDir);
    TxnHeader txnHeader = new TxnHeader(0xabcd, 0x123, 0x123,
          System.currentTimeMillis(), OpCode.create);
    Record txn = new CreateTxn("/Test", new byte[0], null, false, 1);
    txnLog.append(txnHeader, txn);
    FileInputStream in = new FileInputStream(tmpDir.getPath() + "/log." +
          Long.toHexString(txnHeader.getZxid()));
    BinaryInputArchive ia  = BinaryInputArchive.getArchive(in);
    FileHeader header = new FileHeader();
    header.deserialize(ia, "fileheader");
    LOG.info("Received magic : " + header.getMagic() +
          " Expected : " + FileTxnLog.TXNLOG_MAGIC);
    Assert.assertTrue("Missing magic number ",
          header.getMagic() == FileTxnLog.TXNLOG_MAGIC);
}
项目：zookeeper.dsc    文件：LoadFromLogTest.java    
/**
 * Simulates ZOOKEEPER-1069 and verifies that flush() before padLogFile
 * fixes it.
 */
@Test
public void testPad() throws Exception {
    File tmpDir = ClientBase.createTmpDir();
    FileTxnLog txnLog = new FileTxnLog(tmpDir);
    TxnHeader txnHeader = new TxnHeader(0xabcd, 0x123, 0x123,
          System.currentTimeMillis(), OpCode.create);
    Record txn = new CreateTxn("/Test", new byte[0], null, false);
    txnLog.append(txnHeader, txn);
    FileInputStream in = new FileInputStream(tmpDir.getPath() + "/log." +
          Long.toHexString(txnHeader.getZxid()));
    BinaryInputArchive ia  = BinaryInputArchive.getArchive(in);
    FileHeader header = new FileHeader();
    header.deserialize(ia, "fileheader");
    Assert.assertTrue("Missing magic number ",
          header.getMagic() == FileTxnLog.TXNLOG_MAGIC);
}
项目：zookeeper-pkg    文件：LoadFromLogTest.java    
/**
 * Simulates ZOOKEEPER-1069 and verifies that flush() before padLogFile
 * fixes it.
 */
@Test
public void testPad() throws Exception {
    File tmpDir = ClientBase.createTmpDir();
    FileTxnLog txnLog = new FileTxnLog(tmpDir);
    TxnHeader txnHeader = new TxnHeader(0xabcd, 0x123, 0x123,
          System.currentTimeMillis(), OpCode.create);
    Record txn = new CreateTxn("/Test", new byte[0], null, false, 1);
    txnLog.append(txnHeader, txn);
    FileInputStream in = new FileInputStream(tmpDir.getPath() + "/log." +
          Long.toHexString(txnHeader.getZxid()));
    BinaryInputArchive ia  = BinaryInputArchive.getArchive(in);
    FileHeader header = new FileHeader();
    header.deserialize(ia, "fileheader");
    LOG.info("Received magic : " + header.getMagic() +
          " Expected : " + FileTxnLog.TXNLOG_MAGIC);
    Assert.assertTrue("Missing magic number ",
          header.getMagic() == FileTxnLog.TXNLOG_MAGIC);
}
项目：fuck_zookeeper    文件：TxnLogSource.java    
public static boolean isTransactionFile(String file) throws IOException {
       RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
       BinaryInputArchive logStream = new BinaryInputArchive(reader);
       FileHeader fhdr = new FileHeader();
       fhdr.deserialize(logStream, "fileheader");
reader.close();

       return fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC;
   }
项目：https-github.com-apache-zookeeper    文件：TxnLogSource.java    
public static boolean isTransactionFile(String file) throws IOException {
       RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
       BinaryInputArchive logStream = new BinaryInputArchive(reader);
       FileHeader fhdr = new FileHeader();
       fhdr.deserialize(logStream, "fileheader");
reader.close();

       return fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC;
   }
项目：ZooKeeper    文件：TxnLogSource.java    
public static boolean isTransactionFile(String file) throws IOException {
       RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
       BinaryInputArchive logStream = new BinaryInputArchive(reader);
       FileHeader fhdr = new FileHeader();
       fhdr.deserialize(logStream, "fileheader");
reader.close();

       return fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC;
   }
项目：ZooKeeper    文件：TxnLogSource.java    
public static boolean isTransactionFile(String file) throws IOException {
       RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
       BinaryInputArchive logStream = new BinaryInputArchive(reader);
       FileHeader fhdr = new FileHeader();
       fhdr.deserialize(logStream, "fileheader");
reader.close();

       return fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC;
   }
项目：StreamProcessingInfrastructure    文件：TxnLogSource.java    
public static boolean isTransactionFile(String file) throws IOException {
       RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
       BinaryInputArchive logStream = new BinaryInputArchive(reader);
       FileHeader fhdr = new FileHeader();
       fhdr.deserialize(logStream, "fileheader");
reader.close();

       return fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC;
   }
项目：StreamProcessingInfrastructure    文件：TxnLogSource.java    
public static boolean isTransactionFile(String file) throws IOException {
       RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
       BinaryInputArchive logStream = new BinaryInputArchive(reader);
       FileHeader fhdr = new FileHeader();
       fhdr.deserialize(logStream, "fileheader");
reader.close();

       return fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC;
   }
项目：bigstreams    文件：TxnLogSource.java    
public static boolean isTransactionFile(String file) throws IOException {
       RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
       BinaryInputArchive logStream = new BinaryInputArchive(reader);
       FileHeader fhdr = new FileHeader();
       fhdr.deserialize(logStream, "fileheader");
reader.close();

       return fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC;
   }
项目：bigstreams    文件：TxnLogSource.java    
public static boolean isTransactionFile(String file) throws IOException {
       RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
       BinaryInputArchive logStream = new BinaryInputArchive(reader);
       FileHeader fhdr = new FileHeader();
       fhdr.deserialize(logStream, "fileheader");
reader.close();

       return fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC;
   }
项目：bigstreams    文件：TxnLogSource.java    
public static boolean isTransactionFile(String file) throws IOException {
       RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
       BinaryInputArchive logStream = new BinaryInputArchive(reader);
       FileHeader fhdr = new FileHeader();
       fhdr.deserialize(logStream, "fileheader");
reader.close();

       return fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC;
   }
项目：SecureKeeper    文件：TxnLogSource.java    
public static boolean isTransactionFile(String file) throws IOException {
       RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
       BinaryInputArchive logStream = new BinaryInputArchive(reader);
       FileHeader fhdr = new FileHeader();
       fhdr.deserialize(logStream, "fileheader");
reader.close();

       return fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC;
   }
项目：SecureKeeper    文件：TxnLogSource.java    
public static boolean isTransactionFile(String file) throws IOException {
       RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
       BinaryInputArchive logStream = new BinaryInputArchive(reader);
       FileHeader fhdr = new FileHeader();
       fhdr.deserialize(logStream, "fileheader");
reader.close();

       return fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC;
   }
项目：StreamBench    文件：TxnLogSource.java    
public static boolean isTransactionFile(String file) throws IOException {
       RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
       BinaryInputArchive logStream = new BinaryInputArchive(reader);
       FileHeader fhdr = new FileHeader();
       fhdr.deserialize(logStream, "fileheader");
reader.close();

       return fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC;
   }
项目：StreamBench    文件：TxnLogSource.java    
public static boolean isTransactionFile(String file) throws IOException {
       RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
       BinaryInputArchive logStream = new BinaryInputArchive(reader);
       FileHeader fhdr = new FileHeader();
       fhdr.deserialize(logStream, "fileheader");
reader.close();

       return fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC;
   }
项目：LoadBalanced_zk    文件：TxnLogSource.java    
public static boolean isTransactionFile(String file) throws IOException {
       RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
       BinaryInputArchive logStream = new BinaryInputArchive(reader);
       FileHeader fhdr = new FileHeader();
       fhdr.deserialize(logStream, "fileheader");
reader.close();

       return fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC;
   }
项目：LoadBalanced_zk    文件：TxnLogSource.java    
public static boolean isTransactionFile(String file) throws IOException {
       RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
       BinaryInputArchive logStream = new BinaryInputArchive(reader);
       FileHeader fhdr = new FileHeader();
       fhdr.deserialize(logStream, "fileheader");
reader.close();

       return fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC;
   }
项目：LoadBalanced_zk    文件：TxnLogSource.java    
public static boolean isTransactionFile(String file) throws IOException {
       RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
       BinaryInputArchive logStream = new BinaryInputArchive(reader);
       FileHeader fhdr = new FileHeader();
       fhdr.deserialize(logStream, "fileheader");
reader.close();

       return fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC;
   }
项目：LoadBalanced_zk    文件：TxnLogSource.java    
public static boolean isTransactionFile(String file) throws IOException {
       RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
       BinaryInputArchive logStream = new BinaryInputArchive(reader);
       FileHeader fhdr = new FileHeader();
       fhdr.deserialize(logStream, "fileheader");
reader.close();

       return fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC;
   }
项目：zookeeper-pkg    文件：TxnLogSource.java    
public static boolean isTransactionFile(String file) throws IOException {
       RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
       BinaryInputArchive logStream = new BinaryInputArchive(reader);
       FileHeader fhdr = new FileHeader();
       fhdr.deserialize(logStream, "fileheader");
reader.close();

       return fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC;
   }
项目：zookeeper-pkg    文件：TxnLogSource.java    
public static boolean isTransactionFile(String file) throws IOException {
       RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
       BinaryInputArchive logStream = new BinaryInputArchive(reader);
       FileHeader fhdr = new FileHeader();
       fhdr.deserialize(logStream, "fileheader");
reader.close();

       return fhdr.getMagic() == FileTxnLog.TXNLOG_MAGIC;
   }
项目：fuck_zookeeper    文件：LogFormatter.java    
/**
 * @param args
 */
public static void main(String[] args) throws Exception {
    if (args.length != 1) {
        System.err.println("USAGE: LogFormatter log_file");
        System.exit(2);
    }
    FileInputStream fis = new FileInputStream(args[0]);
    BinaryInputArchive logStream = BinaryInputArchive.getArchive(fis);
    FileHeader fhdr = new FileHeader();
    fhdr.deserialize(logStream, "fileheader");

    if (fhdr.getMagic() != FileTxnLog.TXNLOG_MAGIC) {
        System.err.println("Invalid magic number for " + args[0]);
        System.exit(2);
    }
    System.out.println("ZooKeeper Transactional Log File with dbid "
            + fhdr.getDbid() + " txnlog format version "
            + fhdr.getVersion());

    int count = 0;
    while (true) {
        long crcValue;
        byte[] bytes;
        try {
            crcValue = logStream.readLong("crcvalue");

            bytes = logStream.readBuffer("txnEntry");
        } catch (EOFException e) {
            System.out.println("EOF reached after " + count + " txns.");
            return;
        }
        if (bytes.length == 0) {
            // Since we preallocate, we define EOF to be an
            // empty transaction
            System.out.println("EOF reached after " + count + " txns.");
            return;
        }
        Checksum crc = new Adler32();
        crc.update(bytes, 0, bytes.length);
        if (crcValue != crc.getValue()) {
            throw new IOException("CRC doesn't match " + crcValue +
                    " vs " + crc.getValue());
        }
        TxnHeader hdr = new TxnHeader();
        Record txn = SerializeUtils.deserializeTxn(bytes, hdr);
        System.out.println(DateFormat.getDateTimeInstance(DateFormat.SHORT,
                DateFormat.LONG).format(new Date(hdr.getTime()))
                + " session 0x"
                + Long.toHexString(hdr.getClientId())
                + " cxid 0x"
                + Long.toHexString(hdr.getCxid())
                + " zxid 0x"
                + Long.toHexString(hdr.getZxid())
                + " " + TraceFormatter.op2String(hdr.getType()) + " " + txn);
        if (logStream.readByte("EOR") != 'B') {
            LOG.error("Last transaction was partial.");
            throw new EOFException("Last transaction was partial.");
        }
        count++;
    }
}
项目：fuck_zookeeper    文件：TxnLogSource.java    
public TxnLogSource(String file) throws IOException {
this.file = file;

skiplist = new LogSkipList();

RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
try {
    BinaryInputArchive logStream = new BinaryInputArchive(reader);
    FileHeader fhdr = new FileHeader();
    fhdr.deserialize(logStream, "fileheader");

    byte[] bytes = null;
    while (true) {
    long lastFp = reader.getPosition();

    long crcValue;

    try {
        crcValue = logStream.readLong("crcvalue");
        bytes = logStream.readBuffer("txnEntry");
    } catch (EOFException e) {
        break;
    }

    if (bytes.length == 0) {
        break;
    }
    Checksum crc = new Adler32();
    crc.update(bytes, 0, bytes.length);
    if (crcValue != crc.getValue()) {
        throw new IOException("CRC doesn't match " + crcValue +
                  " vs " + crc.getValue());
    }
    if (logStream.readByte("EOR") != 'B') {
        throw new EOFException("Last transaction was partial.");
    }
    TxnHeader hdr = new TxnHeader();
    Record r = SerializeUtils.deserializeTxn(bytes, hdr);

    if (starttime == 0) {
        starttime = hdr.getTime();
    }
    endtime = hdr.getTime();

    if (size % skipN == 0) {
        skiplist.addMark(hdr.getTime(), lastFp, size);
    }
    size++;
    }
    if (bytes == null) {
    throw new IOException("Nothing read from ("+file+")");
    }
} finally {
    reader.close();
}
   }
项目：https-github.com-apache-zookeeper    文件：LogFormatter.java    
/**
 * @param args
 */
public static void main(String[] args) throws Exception {
    if (args.length != 1) {
        System.err.println("USAGE: LogFormatter log_file");
        System.exit(2);
    }
    FileInputStream fis = new FileInputStream(args[0]);
    BinaryInputArchive logStream = BinaryInputArchive.getArchive(fis);
    FileHeader fhdr = new FileHeader();
    fhdr.deserialize(logStream, "fileheader");

    if (fhdr.getMagic() != FileTxnLog.TXNLOG_MAGIC) {
        System.err.println("Invalid magic number for " + args[0]);
        System.exit(2);
    }
    System.out.println("ZooKeeper Transactional Log File with dbid "
            + fhdr.getDbid() + " txnlog format version "
            + fhdr.getVersion());

    int count = 0;
    while (true) {
        long crcValue;
        byte[] bytes;
        try {
            crcValue = logStream.readLong("crcvalue");

            bytes = logStream.readBuffer("txnEntry");
        } catch (EOFException e) {
            System.out.println("EOF reached after " + count + " txns.");
            return;
        }
        if (bytes.length == 0) {
            // Since we preallocate, we define EOF to be an
            // empty transaction
            System.out.println("EOF reached after " + count + " txns.");
            return;
        }
        Checksum crc = new Adler32();
        crc.update(bytes, 0, bytes.length);
        if (crcValue != crc.getValue()) {
            throw new IOException("CRC doesn't match " + crcValue +
                    " vs " + crc.getValue());
        }
        TxnHeader hdr = new TxnHeader();
        Record txn = SerializeUtils.deserializeTxn(bytes, hdr);
        System.out.println(DateFormat.getDateTimeInstance(DateFormat.SHORT,
                DateFormat.LONG).format(new Date(hdr.getTime()))
                + " session 0x"
                + Long.toHexString(hdr.getClientId())
                + " cxid 0x"
                + Long.toHexString(hdr.getCxid())
                + " zxid 0x"
                + Long.toHexString(hdr.getZxid())
                + " " + TraceFormatter.op2String(hdr.getType()) + " " + txn);
        if (logStream.readByte("EOR") != 'B') {
            LOG.error("Last transaction was partial.");
            throw new EOFException("Last transaction was partial.");
        }
        count++;
    }
}
项目：https-github.com-apache-zookeeper    文件：TxnLogSource.java    
public TxnLogSource(String file) throws IOException {
this.file = file;

skiplist = new LogSkipList();

RandomAccessFileReader reader = new RandomAccessFileReader(new File(file));
try {
    BinaryInputArchive logStream = new BinaryInputArchive(reader);
    FileHeader fhdr = new FileHeader();
    fhdr.deserialize(logStream, "fileheader");

    byte[] bytes = null;
    while (true) {
    long lastFp = reader.getPosition();

    long crcValue;

    try {
        crcValue = logStream.readLong("crcvalue");
        bytes = logStream.readBuffer("txnEntry");
    } catch (EOFException e) {
        break;
    }

    if (bytes.length == 0) {
        break;
    }
    Checksum crc = new Adler32();
    crc.update(bytes, 0, bytes.length);
    if (crcValue != crc.getValue()) {
        throw new IOException("CRC doesn't match " + crcValue +
                  " vs " + crc.getValue());
    }
    if (logStream.readByte("EOR") != 'B') {
        throw new EOFException("Last transaction was partial.");
    }
    TxnHeader hdr = new TxnHeader();
    Record r = SerializeUtils.deserializeTxn(bytes, hdr);

    if (starttime == 0) {
        starttime = hdr.getTime();
    }
    endtime = hdr.getTime();

    if (size % skipN == 0) {
        skiplist.addMark(hdr.getTime(), lastFp, size);
    }
    size++;
    }
    if (bytes == null) {
    throw new IOException("Nothing read from ("+file+")");
    }
} finally {
    reader.close();
}
   }
项目：ZooKeeper    文件：LogFormatter.java    
/**
 * @param args
 */
public static void main(String[] args) throws Exception {
    if (args.length != 1) {
        System.err.println("USAGE: LogFormatter log_file");
        System.exit(2);
    }
    FileInputStream fis = new FileInputStream(args[0]);
    BinaryInputArchive logStream = BinaryInputArchive.getArchive(fis);
    FileHeader fhdr = new FileHeader();
    fhdr.deserialize(logStream, "fileheader");

    if (fhdr.getMagic() != FileTxnLog.TXNLOG_MAGIC) {
        System.err.println("Invalid magic number for " + args[0]);
        System.exit(2);
    }
    System.out.println("ZooKeeper Transactional Log File with dbid "
            + fhdr.getDbid() + " txnlog format version "
            + fhdr.getVersion());

    int count = 0;
    while (true) {
        long crcValue;
        byte[] bytes;
        try {
            crcValue = logStream.readLong("crcvalue");

            bytes = logStream.readBuffer("txnEntry");
        } catch (EOFException e) {
            System.out.println("EOF reached after " + count + " txns.");
            return;
        }
        if (bytes.length == 0) {
            // Since we preallocate, we define EOF to be an
            // empty transaction
            System.out.println("EOF reached after " + count + " txns.");
            return;
        }
        Checksum crc = new Adler32();
        crc.update(bytes, 0, bytes.length);
        if (crcValue != crc.getValue()) {
            throw new IOException("CRC doesn't match " + crcValue +
                    " vs " + crc.getValue());
        }
        TxnHeader hdr = new TxnHeader();
        Record txn = SerializeUtils.deserializeTxn(bytes, hdr);
        System.out.println(DateFormat.getDateTimeInstance(DateFormat.SHORT,
                DateFormat.LONG).format(new Date(hdr.getTime()))
                + " session 0x"
                + Long.toHexString(hdr.getClientId())
                + " cxid 0x"
                + Long.toHexString(hdr.getCxid())
                + " zxid 0x"
                + Long.toHexString(hdr.getZxid())
                + " " + TraceFormatter.op2String(hdr.getType()) + " " + txn);
        if (logStream.readByte("EOR") != 'B') {
            LOG.error("Last transaction was partial.");
            throw new EOFException("Last transaction was partial.");
        }
        count++;
    }
}