Examples of readInt()

Examples of com.mobixess.jodb.core.io.IRandomAccessDataBuffer.readInt()

346
347
348
349
350
351
352
353
354
355
356
        int directlyAddressedFieldsTotal = in.readShort()&0xffff;
        for (int i = 0; i < directlyAddressedFieldsTotal; i++) {
            int id = in.readShort()&0xffff;
            long offset;
            if(isRelativeAddr){
                offset = in.readInt()+ in.getCursorOffset();
            }else{
                offset = in.readLong();
            }
            int index = ArrayUtils.indexOf(fieldsIDs, id);
            if(index == -1){
View Full Code Here

Examples of com.orientechnologies.orient.core.storage.fs.OFile.readInt()

183
184
185
186
187
188
189
190
191
192
193
      long p = pos[1];

      iPPosition.dataSegment = file.readShort(p);
      iPPosition.dataPosition = file.readLong(p += OConstants.SIZE_SHORT);
      iPPosition.type = file.readByte(p += OConstants.SIZE_LONG);
      iPPosition.version = file.readInt(p += OConstants.SIZE_BYTE);
      return iPPosition;

    } finally {
      releaseSharedLock();
    }
View Full Code Here

Examples of com.orientechnologies.orient.enterprise.channel.binary.OChannelBinaryAsynchClient.readInt()

688
689
690
691
692
693
694
695
696
697
698
          endRequest(network);
        }

        try {
          beginResponse(network);
          final int positionsCount = network.readInt();

          if (positionsCount == 0) {
            return new OPhysicalPosition[0];
          } else {
            return readPhysicalPositions(network, positionsCount);
View Full Code Here

Examples of com.orientechnologies.orient.enterprise.channel.binary.OChannelBinaryClient.readInt()

86
87
88
89
90
91
92
93
94
95
96
        storage.endRequest(network);
      }

      try {
        storage.beginResponse(network);
        sessionId = network.readInt();
        storage.setSessionId(sessionId);
      } finally {
        storage.endResponse(network);
      }
View Full Code Here

Examples of com.peterhi.obsolete.Stream.readInt()

1327
1328
1329
1330
1331
1332
1333
1334
1335
1336
1337
     
      stream.readBit();

      for (NumWithInfo nwi : genNumWithInfos(Integer.SIZE)) {
        if (nwi.isNormal()) {
          assertEquals(nwi.getNumber().intValue(), stream.readInt(nwi.getBits()));
        } else {
          BigInteger flow = BigInteger.valueOf(2).pow(nwi.getBits());
          BigInteger left = nwi.getNumber();
          BigInteger right = BigInteger.valueOf(stream.readInt(nwi.getBits()));
         
View Full Code Here

Examples of com.sleepycat.bind.tuple.TupleInput.readInt()

333
334
335
336
337
338
339
340
341
342
343
                          to.getBufferBytes(), to.getBufferOffset(),
                          to.getBufferLength());
        data = new Data();
        setters[0].invoke(data, new Object[] {ti.readString()});
        setters[1].invoke(data, new Object[] {ti.readString()});
        setters[2].invoke(data, new Object[] {new Integer(ti.readInt())});
        setters[3].invoke(data, new Object[] {new Integer(ti.readInt())});
        setters[4].invoke(data, new Object[] {ti.readString()});

        return to.getBufferLength();
    }
View Full Code Here

Examples of com.sshtools.j2ssh.io.ByteArrayReader.readInt()

609
610
611
612
613
614
615
616
617
618
619
            }

            try {
                ByteArrayReader bar = new ByteArrayReader(requestData);
                String originatingHost = bar.readString();
                int originatingPort = (int) bar.readInt();
                log.debug("Creating socket to " +
                    x11ForwardingConfiguration.getHostToConnect() + "/" +
                    x11ForwardingConfiguration.getPortToConnect());

                Socket socket = new Socket(x11ForwardingConfiguration.getHostToConnect(),
View Full Code Here

Examples of com.sun.enterprise.naming.util.ObjectInputStreamWithLoader.readInt()

201
202
203
204
205
206
207
208
209
210
211
            version = ois.readLong();
            lastAccess = ois.readLong();
            maxIdleTime = ois.readLong();
            isNew = ois.readBoolean();
           
            int len = ois.readInt();
            state = new byte[len];
            int index = 0;

            for (int remaining = len; remaining > 0;) {
                int count = ois.read(state, index, remaining);
View Full Code Here

Examples of com.sun.messaging.jmq.io.VRecordRAF.readInt()

588
589
590
591
592
593
594
595
596
597
598
    } else {

        try {
      msgCount++;
      byteCount += record.readInt();
        } catch (Throwable t) {
      logger.log(logger.ERROR, br.X_READ_FROM_VRECORD_FAILED,
          vrfile.getFile(), t);
      throw new BrokerException(br.getString(
          br.X_READ_FROM_VRECORD_FAILED,
View Full Code Here

Examples of com.vividsolutions.jts.io.ByteOrderDataInStream.readInt()

92
93
94
95
96
97
98
99
100
101
102
    public Geometry read(InStream is) throws IOException {
        ByteOrderDataInStream dis = new ByteOrderDataInStream(is);
        dis.setOrder(ByteOrderValues.LITTLE_ENDIAN);

        srid = dis.readInt();
        version = dis.readByte();
        serializationProps = dis.readByte();
        hasZ = (serializationProps & 1) == 1;
        hasM = (serializationProps & 2) == 2;
        singlePoint = (serializationProps & 8) == 8;
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.