List of readHeader() Examples

Examples of readHeader()

com.mobixess.jodb.core.io.ObjectDataContainer.readHeader()
@param ioTicket @return true if object deleted @throws IOException
de.netseeker.ejoe.io.DataChannel.readHeader()
Receives a EJOE specific header containing the size of the next ByteBuffer. @param timeout read timeout @return the length of the following data package @throws IOException
htsjdk.variant.bcf2.BCF2Codec.readHeader()
htsjdk.variant.vcf.VCFCodec.readHeader()
info.unipax.bina.analysis.data.csv.CsvReader.readHeader()
org.apache.maven.index.updater.IndexDataReader.readHeader()
org.jboss.marshalling.StreamHeader.readHeader()
Read the stream header from the stream. @param input the stream header @throws IOException if the header is invalid or an error occurs
org.jpos.iso.channel.ASCIIChannel.readHeader()
org.jpos.iso.channel.NACChannel.readHeader()

Examples of com.mobixess.jodb.core.io.ObjectDataContainer.readHeader()

            DataContainersCache dataContainersCache = TransactionUtils.getObjectDataContainerCache();
            ObjectDataContainer existingObjectHeaderData =  dataContainersCache.pullObjectDataContainer();// tContainer.getTempObjectDataContainer();


            //ioTicket.getRandomAccessBuffer().seek(tHandle.getHandle().getObjectEntryOffset());
            //JODBIOUtils.readObjectHeader(ioTicket, existingObjectHeaderData, false);
            existingObjectHeaderData.readHeader(ioTicket.getRandomAccessBuffer(),tHandle.getHandle().getObjectEntryOffset(), false);
            tHandle.setTransactionOffset(existingObjectHeaderData.getOffset());//JODBIOUtils.addAbsoluteOffsetIdentifierBit(existingObjectHeaderData.getOffset()));//if object already existed than alvays point to initial object position
            long redirectorOffset = existingObjectHeaderData.isRedirection()?existingObjectHeaderData.getOffset():-1;
            if(objectBodyLength > existingObjectHeaderData.getBodyLength() || fieldsWithRelativeAddr.size() > 0 ){
                if( existingObjectHeaderData.isRedirection() ){
                    //redirection entry space is too small, let see what is under redirection offset

View Full Code Here

Examples of com.mobixess.jodb.core.io.ObjectDataContainer.readHeader()

                if( existingObjectHeaderData.isRedirection() ){
                    //redirection entry space is too small, let see what is under redirection offset
                    //ioTicket.getRandomAccessBuffer().seek(existingObjectHeaderData.getRedirectionOffset());
                    long existingObjectRedirectionOffset = existingObjectHeaderData.getRedirectionOffset();
                    existingObjectHeaderData.reset();
                    existingObjectHeaderData.readHeader(ioTicket.getRandomAccessBuffer(), existingObjectRedirectionOffset, true);
                    //JODBIOUtils.readObjectHeader(ioTicket, existingObjectHeaderData, true);
                }
            }


            if(objectBodyLength <= existingObjectHeaderData.getBodyLength() && fieldsWithRelativeAddr.size() == 0){

View Full Code Here

Examples of com.mobixess.jodb.core.io.ObjectDataContainer.readHeader()

        //ioTicket.getRandomAccessBuffer().seek(persistentObjectOffset);
        IRandomAccessDataBuffer replacementsFile =  tContainer.getTransactionReplacementsDataFile();
        DataContainersCache dataContainersCache = TransactionUtils.getObjectDataContainerCache();
        ObjectDataContainer container = dataContainersCache.pullObjectDataContainer();
        //JODBIOUtils.readObjectHeader(ioTicket, container, false);
        container.readHeader(ioTicket.getRandomAccessBuffer(),persistentObjectOffset, false);
        replacementsFile.writeByte(TRANSACTION_REPLACEMENT_ENTRY_TYPE_STATIC);
        replacementsFile.writeLong(persistentObjectOffset);//write offset of object to replace
        replacementsFile.writeLong(0);//reserving space for entry's length
        long entryOffsetStart = replacementsFile.getCursorOffset();
        TransactionUtils.writeEmptyObjectEntry(replacementsFile , container.getBodyLength());

View Full Code Here

Examples of com.mobixess.jodb.core.io.ObjectDataContainer.readHeader()

                if(value == null){//if object under the persistent offset is delete than we continue itteration
                    if(fieldRecord._objectOffset != 0){
                        DataContainersCache dataContainersCache = TransactionUtils.getObjectDataContainerCache();
                        ObjectDataContainer referencedObjectDataContainer =  dataContainersCache.pullObjectDataContainer();
                        try {
                            referencedObjectDataContainer.readHeader(context.getIoTicket().getRandomAccessBuffer(), fieldRecord._objectOffset, true);
                            if(!referencedObjectDataContainer.isDeleted()){
                                return false;
                            }
                        } finally {
                            dataContainersCache.pushObjectDataContainer(referencedObjectDataContainer);

View Full Code Here

Examples of de.netseeker.ejoe.io.DataChannel.readHeader()


        try
        {
            if ( !this._senderInfo.hasWaitingBuffer() )
            {
                int length = dataChannel.readHeader( this._senderInfo, EJConstants.EJOE_CONNECTION_TIMEOUT );


                // maybe the DataChannel signals that it has already read
                // partial data
                if ( this._senderInfo.hasWaitingBuffer() )
                {

View Full Code Here

Examples of de.netseeker.ejoe.io.DataChannel.readHeader()


        try
        {
            if ( dataBuf == null )
            {
                int length = dataChannel.readHeader( _serverInfo, this._connectionTimeout );
                // server signals a null result?
                if ( length == 0 )
                {
                    return null;
                }

View Full Code Here

Examples of htsjdk.variant.bcf2.BCF2Codec.readHeader()

    public void rawTestFile() throws Exception {
        String path = "/path/to/myfile.bcf";
        PositionalBufferedStream ps = new PositionalBufferedStream(new FileInputStream(path));


        BCF2Codec codec = new BCF2Codec();
        codec.readHeader(ps);


    }




}

View Full Code Here

Examples of htsjdk.variant.vcf.VCFCodec.readHeader()


        // confirm that the call is the correct one
        final VCFCodec codec = new VCFCodec();
        final FileInputStream s = new FileInputStream(outputVCF);
        final LineIterator lineIterator = codec.makeSourceFromStream(new PositionalBufferedStream(s));
        codec.readHeader(lineIterator);
        final String line = lineIterator.next();
        Assert.assertFalse(line == null);
        final VariantContext vc = codec.decode(line);
        Assert.assertTrue(vc.isBiallelic());
        Assert.assertTrue(vc.getReference().basesMatch("ATGTATG"));

View Full Code Here

Examples of htsjdk.variant.vcf.VCFCodec.readHeader()

        final File outputVCF = executeTest("testMultiAllelics", spec).getFirst().get(0);


        final VCFCodec codec = new VCFCodec();
        final FileInputStream originalStream = new FileInputStream(MultiAllelicsTest);
        final LineIterator originalLineIterator = codec.makeSourceFromStream(new PositionalBufferedStream(originalStream));
        codec.readHeader(originalLineIterator);
        int numOriginalRecords = 0;
        while ( originalLineIterator.hasNext() ) {
            originalLineIterator.next();
            numOriginalRecords++;
        }

View Full Code Here

Examples of htsjdk.variant.vcf.VCFCodec.readHeader()

            numOriginalRecords++;
        }


        final FileInputStream newStream = new FileInputStream(outputVCF);
        final LineIterator newLineIterator = codec.makeSourceFromStream(new PositionalBufferedStream(newStream));
        codec.readHeader(newLineIterator);
        int numNewRecords = 0;
        while ( newLineIterator.hasNext() ) {
            newLineIterator.next();
            numNewRecords++;
        }

View Full Code Here

0 1

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.