Examples of java.io.DataOutput.writeLong()

java.io.DataOutput.writeLong()
Writes a long value, which is comprised of eight bytes, to the output stream. The byte values to be written, in the order shown, are:
```
 (byte)(0xff & (v >> 56)) (byte)(0xff & (v >> 48)) (byte)(0xff & (v >> 40)) (byte)(0xff & (v >> 32)) (byte)(0xff & (v >> 24)) (byte)(0xff & (v >> 16)) (byte)(0xff & (v >>  8)) (byte)(0xff & v) 
```
The bytes written by this method may be read by the readLong method of interface DataInput , which will then return a long equal to v. @param v the long value to be written. @throws IOException if an I/O error occurs.

                } else {
                    // Set count as a TaggedValuePointable.
                    try {
                        abvsCount.reset();
                        dOutCount.write(ValueTag.XS_INTEGER_TAG);
                        dOutCount.writeLong(count);
                        tvpCount.set(abvsCount);


                        FunctionHelper.arithmeticOperation(aOpDivide, dCtx, tvpSum, tvpCount, tvpSum, tp1, tp2);
                        result.set(tvpSum);
                    } catch (Exception e) {

View Full Code Here

                            seq.getEntry(j, p);
                            tvp.set(p.getByteArray(), p.getStartOffset(), p.getLength());
                            if (FunctionHelper.compareTaggedValues(aOp, tvp, tvp2, dCtx, tp1, tp2)) {
                                abvsInner.reset();
                                dOutInner.write(ValueTag.XS_INTEGER_TAG);
                                dOutInner.writeLong(j + 1);
                                sb.addItem(abvsInner);
                            }
                        }
                    } else {
                        if (FunctionHelper.compareTaggedValues(aOp, tvp1, tvp2, dCtx, tp1, tp2)) {

View Full Code Here

                        }
                    } else {
                        if (FunctionHelper.compareTaggedValues(aOp, tvp1, tvp2, dCtx, tp1, tp2)) {
                            abvsInner.reset();
                            dOutInner.write(ValueTag.XS_INTEGER_TAG);
                            dOutInner.writeLong(1);
                            sb.addItem(abvsInner);
                        }
                    }
                    sb.finish();
                    result.set(abvs);

View Full Code Here

        // 318


        {
            long v = rnd.nextLong();
            test.writeLong(v);
            canon.writeLong(v);
        }
        {
            int v = rnd.nextInt();
            test.writeInt(v);
            canon.writeInt(v);

View Full Code Here

                    if (file.exists() && server.getLogger().isWritten(nextLogId)) {
                        logId++;


                        output.writeByte(RECOVERY_LOG);
                        crc32.reset();
                        output.writeLong(logId);


                        LOG.info("sending recovery file: " + file.getName());
                        final BufferedInputStream fileInput = new BufferedInputStream(new FileInputStream(file));


                        final byte[] buffer = new byte[8092];

View Full Code Here

                            output.writeInt(read);
                            output.write(buffer, 0, read);
                        }
                        output.writeInt(0);


                        output.writeLong(crc32.getValue());
                    }
                    try {
                        Thread.sleep(300);
                    } catch (final InterruptedException ignore) {
                    }

View Full Code Here

                return;
            }


            final LogRange logFileRange = Util.logFileRange();
            final long lastId = logFileRange.noLogFile() ? -1 : logFileRange.getLast();
            output.writeLong(lastId);
            do {
                if (input.readByte() != RECOVERY_LOG) {
                    return;
                }
                crc32.reset();

View Full Code Here

                    if (file.exists() && server.getLogger().isWritten(nextLogId)) {
                        logId++;


                        output.writeByte(RECOVERY_LOG);
                        crc32.reset();
                        output.writeLong(logId);


                        LOG.info("sending recovery file: " + file.getName());
                        BufferedInputStream fileInput = new BufferedInputStream(new FileInputStream(file));


                        byte[] buffer = new byte[8092];

View Full Code Here

                            output.writeInt(read);
                            output.write(buffer, 0, read);
                        }
                        output.writeInt(0);


                        output.writeLong(crc32.getValue());
                    }
                    try {
                        Thread.sleep(300);
                    } catch (InterruptedException ignore) {}

View Full Code Here

                return;
            }


            LogRange logFileRange = Util.logFileRange();
            long lastId = logFileRange.noLogFile() ? -1 : logFileRange.getLast();
            output.writeLong(lastId);
            do {
                if (input.readByte() != RECOVERY_LOG) {
                    return;
                }
                crc32.reset();

View Full Code Here

0 1 2 3 4 5 6 7 8

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.