List of readNextEntry() Examples

Examples of readNextEntry()

com.fasterxml.util.membuf.ChunkyBytesMemBuffer.readNextEntry()
Method for reading and removing next available entry from buffer and return length of the entry in bytes, if succesful; or, if buffer does not have enough space, return negative number as error code. If no entry is available, will block to wait for more data. @param buffer Buffer in which entry is to be read: must have enough spacefor read to succeed @param offset Offset in buffer to use for storing results @return Length of the entry (non-negative) if read succeeds;or, negative number that indicates length of the entry in case of failures: for example, if buffer only had space for 4 bytes, and entry length was 6, would return -6.
com.sleepycat.je.log.CheckpointFileReader.readNextEntry()
com.sleepycat.je.log.CleanerFileReader.readNextEntry()
com.sleepycat.je.log.DumpFileReader.readNextEntry()
com.sleepycat.je.log.FileReader.readNextEntry()
Scans the log files until either it has reached the end of the log or has hit an invalid portion. @return true if an element has been read, false at end-of-log. @throws EnvironmentFailureException if a ChecksumException,FileNotFoundException, or another internal problem occurs.
com.sleepycat.je.log.INFileReader.readNextEntry()
com.sleepycat.je.log.LNFileReader.readNextEntry()
com.sleepycat.je.log.LastFileReader.readNextEntry()
readNextEntry will stop at a bad entry. @return true if an element has been read.
com.sleepycat.je.log.ScavengerFileReader.readNextEntry()
com.sleepycat.je.log.SearchFileReader.readNextEntry()
com.sleepycat.je.log.TestUtilLogReader.readNextEntry()
com.sleepycat.je.rep.stream.FeederReader.readNextEntry()

Examples of com.fasterxml.util.membuf.ChunkyBytesMemBuffer.readNextEntry()


       chunk = buffer.peekNextEntry();
       Assert.assertArrayEquals(buildBytesChunk(6), chunk);
       assertEquals(6, buffer.getNextEntryLength());
       byte[] buf = new byte[6];
       assertEquals(6, buffer.readNextEntry(buf, 0));
       Assert.assertArrayEquals(chunk, buf);


       // and when empty, nothing more:
       assertEquals(-1, buffer.skipNextEntry());
       assertTrue(buffer.isEmpty());

View Full Code Here

Examples of com.sleepycat.je.log.CheckpointFileReader.readNextEntry()

            CheckpointFileReader searcher =
                new CheckpointFileReader(envImpl, readBufferSize, false,
                                         info.lastUsedLsn, DbLsn.NULL_LSN,
                                         info.nextAvailableLsn);


            while (searcher.readNextEntry()) {
                counter.incNumRead();
                counter.incNumProcessed();


                /*
                 * Continue iterating until we find a checkpoint end entry.

View Full Code Here

Examples of com.sleepycat.je.log.CheckpointFileReader.readNextEntry()

            CheckpointFileReader searcher =
                new CheckpointFileReader(env, readBufferSize, false,
                                         info.lastUsedLsn, DbLsn.NULL_LSN,
                                         info.nextAvailableLsn);


            while (searcher.readNextEntry()) {


                /* 
                 * Continue iterating until we find a checkpoint end entry.
                 * While we're at it, remember the last root seen in case we
                 * don't find a checkpoint end entry.

View Full Code Here

Examples of com.sleepycat.je.log.CheckpointFileReader.readNextEntry()

            CheckpointFileReader searcher =
                new CheckpointFileReader(env, readBufferSize, false,
                                         info.lastUsedLsn, DbLsn.NULL_LSN,
                                         info.nextAvailableLsn);


            while (searcher.readNextEntry()) {


                /* 
                 * Continue iterating until we find a checkpoint end entry.
                 * While we're at it, remember the last root seen in case we
                 * don't find a checkpoint end entry.

View Full Code Here

Examples of com.sleepycat.je.log.CheckpointFileReader.readNextEntry()

            CheckpointFileReader searcher =
                new CheckpointFileReader(envImpl, readBufferSize, false,
                                         info.lastUsedLsn, DbLsn.NULL_LSN,
                                         info.nextAvailableLsn);


            while (searcher.readNextEntry()) {


                /*
                 * Continue iterating until we find a checkpoint end entry.
                 * While we're at it, remember the last root seen in case we
                 * don't find a checkpoint end entry.

View Full Code Here

Examples of com.sleepycat.je.log.CleanerFileReader.readNextEntry()

                (env, readBufferSize, DbLsn.NULL_LSN, fileNum);


            DbTree dbMapTree = env.getDbMapTree();
            TreeLocation location = new TreeLocation();


            while (reader.readNextEntry()) {


                nEntriesRead += 1;
                long lsn = reader.getLastLsn();
                long fileOffset = DbLsn.getFileOffset(lsn);
                boolean isObsolete = false;

View Full Code Here

Examples of com.sleepycat.je.log.CleanerFileReader.readNextEntry()


            DbTree dbMapTree = env.getDbMapTree();
            TreeLocation location = new TreeLocation();


            int nProcessedLNs = 0;
            while (reader.readNextEntry()) {
                cleaner.nEntriesRead += 1;
                long lsn = reader.getLastLsn();
                long fileOffset = DbLsn.getFileOffset(lsn);
                boolean isLN = reader.isLN();
                boolean isIN = reader.isIN();

View Full Code Here

Examples of com.sleepycat.je.log.DumpFileReader.readNextEntry()

            /* Enclose the output in a tag to keep proper XML syntax. */
            if (!csvFormat) {
                System.out.println("<DbPrintLog>");
            }


            while (reader.readNextEntry()) {
            }


            reader.summarize(csvFormat);
            if (!csvFormat) {
                System.out.println("</DbPrintLog>");

View Full Code Here

Examples of com.sleepycat.je.log.DumpFileReader.readNextEntry()

            endLsn, entryTypes, txnIds, verbose);
        }


        // Enclose the output in a tag to keep proper XML syntax.
        System.out.println("<DbPrintLog>");
        while (reader.readNextEntry()) {
        }
        reader.summarize();
        System.out.println("</DbPrintLog>");
        env.close();
    }

View Full Code Here

Examples of com.sleepycat.je.log.DumpFileReader.readNextEntry()

            endLsn, entryTypes, txnIds, verbose);
        }


        // Enclose the output in a tag to keep proper XML syntax.
        System.out.println("<DbPrintLog>");
        while (reader.readNextEntry()) {
        }
        reader.summarize();
        System.out.println("</DbPrintLog>");
        env.close();
    }

View Full Code Here

0 1 2 3 4 5

TOP

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.