Examples of readFully()


Examples of ae.javax.imageio.stream.ImageInputStream.readFully()

        }

        ImageInputStream stream = (ImageInputStream)source;
        byte[] b = new byte[2];
        stream.mark();
        stream.readFully(b);
        stream.reset();

        return (b[0] == 0x42) && (b[1] == 0x4d);
    }
View Full Code Here

Examples of at.jku.sii.sqlitereader.io.ArrayDataInput.readFully()

      int nextPage = block.readInt();
      block.annotateLastInt("nextPage", nextPage);

      int size = block.size() - 4;
      byte[] content = new byte[size];
      block.readFully(content);
      block.annotateLast(content.length, "Payload");
      ArrayDataInput in = new ArrayDataInput(content, block.createLastSubAnnotator(content.length));
      PayloadOverflowPage p = new PayloadOverflowPage(page, nextPage, in);
      list.add(p);
      db.resolvePage(page, p);
View Full Code Here

Examples of at.jku.sii.sqlitereader.io.FileDataInput.readFully()

      this.userVersion = file.readInt("userVersion");
      this.incrementalVacuumMode = file.readInt() > 0;
      file.annotateLastInt("incrementalVacuumMode", this.incrementalVacuumMode);
      // reserved
      byte[] reserved = new byte[24];
      file.readFully(reserved);
      file.annotateLast(reserved.length, "reserved");

      this.versionValid4Number = file.readInt("versionValid4Number");
      this.versionSqlite = file.readInt("versionSqlite");
      // end of header
View Full Code Here

Examples of com.aerospike.client.cluster.Connection.readFully()

    int timeout = (policy == null) ? 1000 : policy.timeout;
    Connection conn = node.getConnection(timeout);

    try {
      conn.write(dataBuffer, dataOffset);
      conn.readFully(dataBuffer, HEADER_SIZE);
      node.putConnection(conn);
    }
    catch (Exception e) {
      // All IO exceptions are considered fatal.  Do not retry.
      // Close socket to flush out possible garbage.  Do not put back in pool.
View Full Code Here

Examples of com.ardor3d.util.LittleEndianRandomAccessDataInput.readFully()

            for (int i = 0; i < header.numFrames; i++) {
                scale.set(bis.readFloat(), bis.readFloat(), bis.readFloat());
                translate.set(bis.readFloat(), bis.readFloat(), bis.readFloat());
                final String name = bis.readString(16);
                final byte[] vertData = new byte[header.numVertices * 4];
                bis.readFully(vertData);
                frames[i] = new Md2Frame(vertData, name, scale, translate);
            }

            // make index modes/counts to be used throughout meshes
            int vertexCount = 0;
View Full Code Here

Examples of com.baulsupp.kolja.log.util.SystemInCharSequence.readFully()

    final SystemInCharSequence charSequence = new SystemInCharSequence(System.in);

    Thread t = new Thread("InputProcessor") {
      public void run() {
        try {
          charSequence.readFully();
        } catch (IOException e) {
          log.error("error", e);
        }
      }
    };
View Full Code Here

Examples of com.google.common.io.ByteArrayDataInput.readFully()

        {
            inputChecksum = input.readInt();
        }
        int patchLength = input.readInt();
        byte[] patchBytes = new byte[patchLength];
        input.readFully(patchBytes);

        return new ClassPatch(name, sourceClassName, targetClassName, exists, inputChecksum, patchBytes);
    }

    private void log(String format, Object... args)
View Full Code Here

Examples of com.ibm.mq.MQMessage.readFully()

            else {
                /* anything other is binary data */
                msg.setMsgType(BridgeMsg.TYPE_BYTES);
                int len = mqMsg.getDataLength();
                byte[] data = new byte[len];
                mqMsg.readFully(data);
                msg.setByteData(data);
            }
            /* message headers */
            msg.setMessageId(createBridgeMessageId(mqMsg.messageId));
            msg.setPersistence(createBridgePersistence(mqMsg.persistence));
View Full Code Here

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

  public void pReadFully_byteArray() throws Exception {
    try {
      Stream stream = new Stream(sampleBytes());
      byte[] sample = new byte[0];
     
      stream.readFully(sample);
      assertEquals(sampleBytes().length, stream.available());
     
      sample = new byte[2];
      stream.readFully(sample);
     
View Full Code Here

Examples of com.spotify.docker.client.LogStream.readFully()

    deployJob(jobId, testHost());

    final TaskStatus taskStatus = awaitTaskState(jobId, testHost(), EXITED);
    try (final DockerClient dockerClient = getNewDockerClient()) {
      final LogStream logs = dockerClient.logs(taskStatus.getContainerId(), STDOUT, STDERR);
      final String log = logs.readFully();

      assertThat(log, containsString(server1));
      assertThat(log, containsString(server2));
    }
  }
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.