Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * JBoss, Home of Professional Open Source.
   * Copyright 2014 Red Hat, Inc., and individual contributors
   * as indicated by the @author tags.
   *
   * Licensed under the Apache License, Version 2.0 (the "License");
   * you may not use this file except in compliance with the License.
   * You may obtain a copy of the License at
   *
  *     http://www.apache.org/licenses/LICENSE-2.0
  *
  *  Unless required by applicable law or agreed to in writing, software
  *  distributed under the License is distributed on an "AS IS" BASIS,
  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  *  See the License for the specific language governing permissions and
  *  limitations under the License.
  */
 
 package io.undertow.conduits;
 
 
A stream source conduit which is always empty. Temporary copy from XNIO, see https://issues.jboss.org/browse/XNIO-199

Author(s):
David M. Lloyd
 
 public final class EmptyStreamSourceConduit implements StreamSourceConduit {
     private final XnioWorker worker;
     private final XnioIoThread readThread;
     private boolean shutdown;
     private boolean resumed;

    
Construct a new instance.

Parameters:
readThread the read thread for this conduit
 
     public EmptyStreamSourceConduit(final XnioIoThread readThread) {
         this. = readThread.getWorker();
         this. = readThread;
     }
 
     public void setReadReadyHandler(final ReadReadyHandler handler) {
          = handler;
     }
 
     public long transferTo(final long positionfinal long countfinal FileChannel targetthrows IOException {
         return 0;
     }
 
     public long transferTo(final long countfinal ByteBuffer throughBufferfinal StreamSinkChannel targetthrows IOException {
          = false;
         return -1L;
     }
 
     public int read(final ByteBuffer dstthrows IOException {
          = false;
         return -1;
     }
 
     public long read(final ByteBuffer[] dstsfinal int offsfinal int lenthrows IOException {
          = false;
         return -1L;
     }
 
     public boolean isReadShutdown() {
         return ;
     }
 
     public void resumeReads() {
          = true;
         .execute(new Runnable() {
             public void run() {
                 final ReadReadyHandler handler = ;
                 if (handler != null) {
                     handler.readReady();
                 }
             }
         });
     }
 
     public void suspendReads() {
          = false;
     }
 
     public void wakeupReads() {
        resumeReads();
    }
    public boolean isReadResumed() {
        return ;
    }
    public void awaitReadable() throws IOException {
        // always ready
    }
    public void awaitReadable(final long timefinal TimeUnit timeUnitthrows IOException {
        // always ready
    }
    public void terminateReads() throws IOException {
        if (! ) {
             = true;
            if( != null) {
                .terminated();
            }
        }
    }
    public XnioIoThread getReadThread() {
        return ;
    }
    public XnioWorker getWorker() {
        return ;
    }
New to GrepCode? Check out our FAQ X