Examples of java.io.DataInputStream.readShort()

java.io.DataInputStream.readShort()
See the general contract of the readShort method of DataInput.
Bytes for this operation are read from the contained input stream. @return the next two bytes of this input stream, interpreted as asigned 16-bit number. @exception EOFException if this input stream reaches the end beforereading two bytes. @exception IOException the stream has been closed and the containedinput stream does not support reading after close, or another I/O error occurs. @see java.io.FilterInputStream#in


        short crc = 0;
        
        if(hasCRC) {
          totalCRCs++;
          crc = in.readShort();
          Logger.normal(this, "Found a CRC");
          // FIXME calculate the CRC. It applies to a large number of frames, dependant on the format.
        }
        //Write out the frame
        byte[] frame = null;

View Full Code Here

         DataInputStream is = new DataInputStream(v.getInputStream());


         // Read in the Values
         values = new Value[ph.getValueCount()];
         for ( int i = 0; i < values.length; i++ ) {
            short valSize = is.readShort();
            byte[] b = new byte[valSize];


            is.read(b);
            values[i] = new Value(b);
         }

View Full Code Here

      for (int i = 0; i < numFiles; i++) {
        UTF8 name = new UTF8();
        name.readFields(in);
        // version 0 does not support per file replication
        if (!(imgVersion >= 0)) {
          replication = in.readShort(); // other versions do
          replication = FSEditLog.adjustReplication(replication);
        }
        int numBlocks = in.readInt();
        Block blocks[] = null;
        if (numBlocks > 0) {

View Full Code Here


            try {
                in_stream=new ExposedByteArrayInputStream(buf, offset, length);
                dis=new DataInputStream(in_stream);
                try {
                    version=dis.readShort();
                }
                catch(IOException ex) {
                    if(discard_incompatible_packets)
                        return;
                    throw ex;

View Full Code Here

                return null;


            DataInputStream in=new DataInputStream(new ByteArrayInputStream(buf));
            byte type=in.readByte();
            if(type == METHOD_CALL) {
                short id=in.readShort();
                short length=in.readShort();
                Object[] args=length > 0? new Object[length] : null;
                if(args != null) {
                    for(int i=0; i < args.length; i++)
                        args[i]=Util.objectFromStream(in);

View Full Code Here


            DataInputStream in=new DataInputStream(new ByteArrayInputStream(buf));
            byte type=in.readByte();
            if(type == METHOD_CALL) {
                short id=in.readShort();
                short length=in.readShort();
                Object[] args=length > 0? new Object[length] : null;
                if(args != null) {
                    for(int i=0; i < args.length; i++)
                        args[i]=Util.objectFromStream(in);
                }

View Full Code Here

        try {
            str = new DataInputStream(new GZIPInputStream(new FileInputStream(file)));
            if ((str.readByte() & 0xFF) != NBTConstants.TYPE_COMPOUND) {
                return false;
            }
            byte[] nameBytes = new byte[str.readShort() & 0xFFFF];
            str.readFully(nameBytes);
            String name = new String(nameBytes, NBTConstants.CHARSET);
            return name.equals("Schematic");
        } catch (IOException e) {
            return false;

View Full Code Here


    @Override
    public void processMessage(ChannelAssociation channelAssociation, MessageInputStream messageInputStream) throws IOException {
        final DataInputStream input = new DataInputStream(messageInputStream);
        // read the id of the invocation which needs to be cancelled
        final short invocationToCancel = input.readShort();
        // get the cancellation flag (if any) for the invocation id
        final CancellationFlag cancellationFlag = this.remoteAsyncInvocationCancelStatus.getCancelStatus(invocationToCancel);
        if (cancellationFlag == null) {
            return;
        }

View Full Code Here

    @Override
    public void processMessage(final ChannelAssociation channelAssociation, final MessageInputStream messageInputStream) throws IOException {


        final DataInputStream input = new DataInputStream(messageInputStream);
        // read the invocation id
        final short invocationId = input.readShort();


        // read the method name
        final String methodName = input.readUTF();
        // method signature
        String[] methodParamTypes = null;

View Full Code Here

        if (messageInputStream == null) {
            throw EjbMessages.MESSAGES.messageInputStreamCannotBeNull();
        }
        final DataInputStream dataInputStream = new DataInputStream(messageInputStream);
        // read invocation id
        final short invocationId = dataInputStream.readShort();
        final String appName = dataInputStream.readUTF();
        final String moduleName = dataInputStream.readUTF();
        final String distinctName = dataInputStream.readUTF();
        final String beanName = dataInputStream.readUTF();

View Full Code Here

0 1 2 3 4 5 6 7 8 9

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.