Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /* ************************************************************************
  #
  #  DivConq
  #
  #  http://divconq.com/
  #
  #  Copyright:
  #    Copyright 2014 eTimeline, LLC. All rights reserved.
  #
 #  License:
 #    See the license.txt file in the project's top-level directory for details.
 #
 #  Authors:
 #    * Andy White
 #
 ************************************************************************ */
 package divconq.api.internal;
 
 
 import java.io.File;
 
 
 public class UploadStream extends AbstractHttpData implements FileUpload {
     public static final String CONTENT_DISPOSITION = "Content-Disposition";
     public static final String NAME = "name";
     public static final String FILENAME = "filename";
     public static final String FORM_DATA = "form-data";
     public static final String ATTACHMENT = "attachment";
 
     protected String filename = null;
     protected String contentType = null;
     protected String contentTransferEncoding = null;
     protected OperationResult ops = null;
     
     protected ReadableByteChannel in = null;
 
     public UploadStream(ReadableByteChannel inString nameString filenameString contentType,
             String contentTransferEncodingCharset charsetlong sizeOperationResult ops
     {    	
         super(namecharsetsize);
         
         this.setFilename(filename);
         this.setContentType(contentType);
         this.setContentTransferEncoding(contentTransferEncoding);
         
         this. = in;
         this. = ops;
     }
 
     @Override
     public HttpDataType getHttpDataType() {
         return .;
     }
 
     @Override
     public String getFilename() {
         return this.;
     }
 
     @Override
     public void setFilename(String filename) {
         if (filename == null
             throw new NullPointerException("filename");
         
         this. = filename;
     }
 
     @Override
     public void setContentType(String contentType) {
         if (contentType == null
             throw new NullPointerException("contentType");
         
         this. = contentType;
     }
 
     @Override
     public String getContentType() {
         return this.;
     }
 
     @Override
     public String getContentTransferEncoding() {
         return this.;
     }
 
     @Override
    public void setContentTransferEncoding(String contentTransferEncoding) {
        this. = contentTransferEncoding;
    }
    @Override
    public String toString() {
        return . + ": " +
        		. + "; " + . + "=\"" + getName() +
                "\"; " + . + "=\"" + this. + "\"\r\n" +
                .. + ": " + this. +
                (getCharset() != null"; " + .. + '=' + getCharset() + "\r\n" : "\r\n") +
                .. + ": " + length() + "\r\n" +
                "Completed: " + isCompleted();
    }
    @Override
    public FileUpload retain(int increment) {
        super.retain(increment);
        return this;
    }
    @Override
    public FileUpload retain() {
        super.retain();
        return this;
    }
	public void setContent(ByteBuf bufferthrows IOException {
	}
	public void addContent(ByteBuf bufferboolean lastthrows IOException {
	}
	public void setContent(File filethrows IOException {
	}
	public void setContent(InputStream inputStreamthrows IOException {
	}
	public void delete() {
	}
	public byte[] get() throws IOException {
		// only handle chunked
		return null;
	}
	public ByteBuf getByteBuf() throws IOException {
		// only handle chunked
		return null;
	}
	public ByteBuf getChunk(int lengththrows IOException {
        if (this. == null || length == 0) 
            return .;
        
        // indicate that we are keeping busy and not hung
        this..touch();
        
        //System.out.println("Get last activity after touch: " + this.ops.getLastActivity());
        
        int read = 0;
        
        ByteBuffer byteBuffer = ByteBuffer.allocate(length);
        
        while (read < length) {
            int readnow = this..read(byteBuffer);
            
            if (readnow == -1) {
            	this..close();
                this. = null;
                break;
            } 
            else {
                read += readnow;
            }
        }
        
        if (read == 0) 
            return .;
        
        byteBuffer.flip();
        ByteBuf buffer = Unpooled.wrappedBuffer(byteBuffer);
        buffer.readerIndex(0);
        buffer.writerIndex(read);
        return buffer;
	}
	public String getString() throws IOException {
        return this.getString(.);
	}
	public String getString(Charset encodingthrows IOException {
        return "N/A";
	}
	public boolean renameTo(File destthrows IOException {
		return false;
	}
	public boolean isInMemory() {
		return false;
	}
	public File getFile() throws IOException {
		return null;
	}
	public int compareTo(InterfaceHttpData arg0) {
		return 0;
	}
	public FileUpload copy() {
		return null;
	}
	public FileUpload duplicate() {
		return null;
	}
New to GrepCode? Check out our FAQ X