List of transferToFully() Examples

Examples of transferToFully()

org.apache.hadoop.net.SocketOutputStream.transferToFully()
Transfers data from FileChannel using {@link FileChannel#transferTo(long,long,WritableByteChannel)}. Similar to readFully(), this waits till requested amount of data is transfered. @param fileCh FileChannel to transfer data from. @param position position within the channel where the transfer begins @param count number of bytes to transfer. @throws EOFException If end of input file is reached before requested number of bytes are transfered. @throws SocketTimeoutException If this channel blocks transfer longer than timeout for this stream. @throws IOException Includes any exception thrown by {@link FileChannel#transferTo(long,long,WritableByteChannel)}.

Examples of org.apache.hadoop.net.SocketOutputStream.transferToFully()

        SocketOutputStream sockOut = (SocketOutputStream)out;
        //first write the packet
        sockOut.write(buf, 0, dataOff);
        // no need to flush. since we know out is not a buffered stream. 


        sockOut.transferToFully(((FileInputStream)blockIn).getChannel(), 
                                blockInPosition, len);


        blockInPosition += len;
      } else {
        // normal transfer

View Full Code Here

Examples of org.apache.hadoop.net.SocketOutputStream.transferToFully()

          sockOut.write(buf, 0, dataOff + len);
        } else {
          //first write the packet
          sockOut.write(buf, 0, dataOff);
          // no need to flush. since we know out is not a buffered stream.
          sockOut.transferToFully(fileChannel, blockInPosition, len);
        }


        blockInPosition += len;


      } catch (IOException e) {

View Full Code Here

Examples of org.apache.hadoop.net.SocketOutputStream.transferToFully()

        
        // no need to flush since we know out is not a buffered stream
        FileChannel fileCh = ((FileInputStream)blockIn).getChannel();
        LongWritable waitTime = new LongWritable();
        LongWritable transferTime = new LongWritable();
        sockOut.transferToFully(fileCh, blockInPosition, dataLen, 
            waitTime, transferTime);
        datanode.metrics.addSendDataPacketBlockedOnNetworkNanos(waitTime.get());
        datanode.metrics.addSendDataPacketTransferNanos(transferTime.get());
        blockInPosition += dataLen;
      } else {

View Full Code Here

Examples of org.apache.hadoop.net.SocketOutputStream.transferToFully()

        SocketOutputStream sockOut = (SocketOutputStream)out;
        //first write the packet
        sockOut.write(buf, 0, dataOff);
        // no need to flush. since we know out is not a buffered stream. 


        sockOut.transferToFully(((FileInputStream)blockIn).getChannel(), 
                                blockInPosition, len);


        blockInPosition += len;
      } else {
        // normal transfer

View Full Code Here

Examples of org.apache.hadoop.net.SocketOutputStream.transferToFully()

        
        // no need to flush since we know out is not a buffered stream
        FileChannel fileCh = ((FileInputStream)blockIn).getChannel();
        LongWritable waitTime = new LongWritable();
        LongWritable transferTime = new LongWritable();
        sockOut.transferToFully(fileCh, blockInPosition, dataLen, 
            waitTime, transferTime);
        datanode.metrics.addSendDataPacketBlockedOnNetworkNanos(waitTime.get());
        datanode.metrics.addSendDataPacketTransferNanos(transferTime.get());
        blockInPosition += dataLen;
      } else {

View Full Code Here

Examples of org.apache.hadoop.net.SocketOutputStream.transferToFully()

          SocketOutputStream sockOut = (SocketOutputStream)out;
          //first write the packet
          sockOut.write(buf, 0, dataOff);
          // no need to flush. since we know out is not a buffered stream. 


          sockOut.transferToFully(((FileInputStream)blockIn).getChannel(), 
                                  blockInPosition, len);


          blockInPosition += len;
        } else {
          // normal transfer

View Full Code Here

Examples of org.apache.hadoop.net.SocketOutputStream.transferToFully()

        SocketOutputStream sockOut = (SocketOutputStream)out;
        //first write the packet
        sockOut.write(buf, 0, dataOff);
        // no need to flush. since we know out is not a buffered stream. 


        sockOut.transferToFully(((FileInputStream)blockIn).getChannel(), 
                                blockInPosition, len);


        blockInPosition += len;
      } else {
        // normal transfer

View Full Code Here

Examples of org.apache.hadoop.net.SocketOutputStream.transferToFully()

        
        // no need to flush since we know out is not a buffered stream
        FileChannel fileCh = ((FileInputStream)blockIn).getChannel();
        LongWritable waitTime = new LongWritable();
        LongWritable transferTime = new LongWritable();
        sockOut.transferToFully(fileCh, blockInPosition, dataLen, 
            waitTime, transferTime);
        datanode.metrics.addSendDataPacketBlockedOnNetworkNanos(waitTime.get());
        datanode.metrics.addSendDataPacketTransferNanos(transferTime.get());
        blockInPosition += dataLen;
      } else {

View Full Code Here

Examples of org.apache.hadoop.net.SocketOutputStream.transferToFully()

        SocketOutputStream sockOut = (SocketOutputStream)out;
        //first write the packet
        sockOut.write(buf, 0, dataOff);
        // no need to flush. since we know out is not a buffered stream. 


        sockOut.transferToFully(((FileInputStream)blockIn).getChannel(), 
                                blockInPosition, len);


        blockInPosition += len;
      } else {
        // normal transfer

View Full Code Here

Examples of org.apache.hadoop.net.SocketOutputStream.transferToFully()

        SocketOutputStream sockOut = (SocketOutputStream)out;
        //first write the packet
        sockOut.write(buf, 0, dataOff);
        // no need to flush. since we know out is not a buffered stream. 


        sockOut.transferToFully(((FileInputStream)blockIn).getChannel(), 
                                blockInPosition, len);


        blockInPosition += len;
      } else {
        // normal transfer

View Full Code Here

0 1 2

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.