Author: solomax
Date: Wed Jul 13 06:59:35 2016
New Revision: 1752370

URL: http://svn.apache.org/viewvc?rev=1752370&view=rev
Log:
no jira: stream being sent by network tester is internally read to simulate 
some processing

Modified:
    
openmeetings/application/branches/3.1.x/openmeetings-webservice/src/main/java/org/apache/openmeetings/webservice/NetTestWebService.java
    
openmeetings/application/branches/3.2.x/openmeetings-webservice/src/main/java/org/apache/openmeetings/webservice/NetTestWebService.java
    
openmeetings/application/trunk/openmeetings-webservice/src/main/java/org/apache/openmeetings/webservice/NetTestWebService.java

Modified: 
openmeetings/application/branches/3.1.x/openmeetings-webservice/src/main/java/org/apache/openmeetings/webservice/NetTestWebService.java
URL: 
http://svn.apache.org/viewvc/openmeetings/application/branches/3.1.x/openmeetings-webservice/src/main/java/org/apache/openmeetings/webservice/NetTestWebService.java?rev=1752370&r1=1752369&r2=1752370&view=diff
==============================================================================
--- 
openmeetings/application/branches/3.1.x/openmeetings-webservice/src/main/java/org/apache/openmeetings/webservice/NetTestWebService.java
 (original)
+++ 
openmeetings/application/branches/3.1.x/openmeetings-webservice/src/main/java/org/apache/openmeetings/webservice/NetTestWebService.java
 Wed Jul 13 06:59:35 2016
@@ -21,6 +21,7 @@ package org.apache.openmeetings.webservi
 import static org.apache.openmeetings.util.OpenmeetingsVariables.webAppRootKey;
 
 import java.io.ByteArrayInputStream;
+import java.io.IOException;
 import java.io.InputStream;
 import java.util.Arrays;
 
@@ -102,7 +103,9 @@ public class NetTestWebService {
        @POST
        @Consumes(MediaType.MULTIPART_FORM_DATA)
        @Path("/")
-       public void upload(@Multipart(value = "stream", type = 
MediaType.APPLICATION_OCTET_STREAM) InputStream stream) {
+       public void upload(@Multipart(value = "stream", type = 
MediaType.APPLICATION_OCTET_STREAM) InputStream stream) throws IOException {
+               byte[] b = new byte[1024];
+               while (stream.read(b) >= 0 ) {};
     }
 
 

Modified: 
openmeetings/application/branches/3.2.x/openmeetings-webservice/src/main/java/org/apache/openmeetings/webservice/NetTestWebService.java
URL: 
http://svn.apache.org/viewvc/openmeetings/application/branches/3.2.x/openmeetings-webservice/src/main/java/org/apache/openmeetings/webservice/NetTestWebService.java?rev=1752370&r1=1752369&r2=1752370&view=diff
==============================================================================
--- 
openmeetings/application/branches/3.2.x/openmeetings-webservice/src/main/java/org/apache/openmeetings/webservice/NetTestWebService.java
 (original)
+++ 
openmeetings/application/branches/3.2.x/openmeetings-webservice/src/main/java/org/apache/openmeetings/webservice/NetTestWebService.java
 Wed Jul 13 06:59:35 2016
@@ -21,6 +21,7 @@ package org.apache.openmeetings.webservi
 import static org.apache.openmeetings.util.OpenmeetingsVariables.webAppRootKey;
 
 import java.io.ByteArrayInputStream;
+import java.io.IOException;
 import java.io.InputStream;
 import java.util.Arrays;
 
@@ -102,7 +103,9 @@ public class NetTestWebService {
        @POST
        @Consumes(MediaType.MULTIPART_FORM_DATA)
        @Path("/")
-       public void upload(@Multipart(value = "stream", type = 
MediaType.APPLICATION_OCTET_STREAM) InputStream stream) {
+       public void upload(@Multipart(value = "stream", type = 
MediaType.APPLICATION_OCTET_STREAM) InputStream stream) throws IOException {
+               byte[] b = new byte[1024];
+               while (stream.read(b) >= 0 ) {};
     }
 
 

Modified: 
openmeetings/application/trunk/openmeetings-webservice/src/main/java/org/apache/openmeetings/webservice/NetTestWebService.java
URL: 
http://svn.apache.org/viewvc/openmeetings/application/trunk/openmeetings-webservice/src/main/java/org/apache/openmeetings/webservice/NetTestWebService.java?rev=1752370&r1=1752369&r2=1752370&view=diff
==============================================================================
--- 
openmeetings/application/trunk/openmeetings-webservice/src/main/java/org/apache/openmeetings/webservice/NetTestWebService.java
 (original)
+++ 
openmeetings/application/trunk/openmeetings-webservice/src/main/java/org/apache/openmeetings/webservice/NetTestWebService.java
 Wed Jul 13 06:59:35 2016
@@ -21,6 +21,7 @@ package org.apache.openmeetings.webservi
 import static org.apache.openmeetings.util.OpenmeetingsVariables.webAppRootKey;
 
 import java.io.ByteArrayInputStream;
+import java.io.IOException;
 import java.io.InputStream;
 import java.util.Arrays;
 
@@ -102,7 +103,9 @@ public class NetTestWebService {
        @POST
        @Consumes(MediaType.MULTIPART_FORM_DATA)
        @Path("/")
-       public void upload(@Multipart(value = "stream", type = 
MediaType.APPLICATION_OCTET_STREAM) InputStream stream) {
+       public void upload(@Multipart(value = "stream", type = 
MediaType.APPLICATION_OCTET_STREAM) InputStream stream) throws IOException {
+               byte[] b = new byte[1024];
+               while (stream.read(b) >= 0 ) {};
     }
 
 


Reply via email to