[richfaces-svn-commits] JBoss Rich Faces SVN: r6101 - trunk/sandbox/samples/fileUploadDemo/src/main/java/org/richfaces.

[richfaces-svn-commits at lists.jboss.org]

Author: nbelaevski
Date: 2008-02-14 19:59:43 -0500 (Thu, 14 Feb 2008)
New Revision: 6101

Added:
   trunk/sandbox/samples/fileUploadDemo/src/main/java/org/richfaces/SleepDemoFilter.java
Log:
latest changes for file upload

Added: trunk/sandbox/samples/fileUploadDemo/src/main/java/org/richfaces/SleepDemoFilter.java
===================================================================
--- trunk/sandbox/samples/fileUploadDemo/src/main/java/org/richfaces/SleepDemoFilter.java	                        (rev 0)
+++ trunk/sandbox/samples/fileUploadDemo/src/main/java/org/richfaces/SleepDemoFilter.java	2008-02-15 00:59:43 UTC (rev 6101)
@@ -0,0 +1,95 @@
+package org.richfaces;
+
+import java.io.IOException;
+
+import javax.servlet.Filter;
+import javax.servlet.FilterChain;
+import javax.servlet.FilterConfig;
+import javax.servlet.ServletException;
+import javax.servlet.ServletInputStream;
+import javax.servlet.ServletRequest;
+import javax.servlet.ServletResponse;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletRequestWrapper;
+
+public class SleepDemoFilter implements Filter {
+
+	public void destroy() {
+		// TODO Auto-generated method stub
+
+	}
+
+	public void doFilter(ServletRequest servletRequest, final ServletResponse response,
+			FilterChain chain) throws IOException, ServletException {
+
+		if (servletRequest.getContentType() != null && servletRequest.getContentType().startsWith("multipart/")) {
+			chain.doFilter(new HttpServletRequestWrapper((HttpServletRequest) servletRequest) {
+				@Override
+				public ServletInputStream getInputStream() throws IOException {
+					final ServletInputStream is = super.getInputStream();
+					final int sleepTime = 10;
+					return new ServletInputStream() {
+
+						@Override
+						public int read() throws IOException {
+							try {
+								Thread.sleep(sleepTime);
+							} catch (InterruptedException e) {
+								// TODO Auto-generated catch block
+								e.printStackTrace();
+							}
+							return is.read();
+						}
+						
+						@Override
+						public int read(byte[] b) throws IOException {
+							try {
+								Thread.sleep(sleepTime);
+							} catch (InterruptedException e) {
+								// TODO Auto-generated catch block
+								e.printStackTrace();
+							}
+							// TODO Auto-generated method stub
+							return is.read(b);
+						}
+						
+						@Override
+						public int read(byte[] b, int off, int len)
+								throws IOException {
+							try {
+								Thread.sleep(sleepTime);
+							} catch (InterruptedException e) {
+								// TODO Auto-generated catch block
+								e.printStackTrace();
+							}
+							// TODO Auto-generated method stub
+							return is.read(b, off, len);
+						}
+						
+						@Override
+						public int readLine(byte[] b, int off, int len)
+								throws IOException {
+							try {
+								Thread.sleep(sleepTime);
+							} catch (InterruptedException e) {
+								// TODO Auto-generated catch block
+								e.printStackTrace();
+							}
+							// TODO Auto-generated method stub
+							return is.readLine(b, off, len);
+						}
+					
+					};
+				}
+			}, response);
+		} else {
+			chain.doFilter(servletRequest, response);
+		}
+	}
+
+	public void init(FilterConfig filterConfig) throws ServletException {
+		// TODO Auto-generated method stub
+
+	}
+
+}