chemistry-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From f...@apache.org
Subject svn commit: r1001636 - in /incubator/chemistry/opencmis/trunk: chemistry-opencmis-client/chemistry-opencmis-client-bindings/src/main/java/org/apache/chemistry/opencmis/client/bindings/spi/atompub/ chemistry-opencmis-test/chemistry-opencmis-test-fit/src...
Date Mon, 27 Sep 2010 09:17:15 GMT
Author: fmui
Date: Mon Sep 27 09:17:15 2010
New Revision: 1001636

URL: http://svn.apache.org/viewvc?rev=1001636&view=rev
Log:
CMIS-254: fixed AtomPub client

Modified:
    incubator/chemistry/opencmis/trunk/chemistry-opencmis-client/chemistry-opencmis-client-bindings/src/main/java/org/apache/chemistry/opencmis/client/bindings/spi/atompub/HttpUtils.java
    incubator/chemistry/opencmis/trunk/chemistry-opencmis-test/chemistry-opencmis-test-fit/src/test/java/org/apache/chemistry/opencmis/fit/runtime/AbstractWriteObjectIT.java

Modified: incubator/chemistry/opencmis/trunk/chemistry-opencmis-client/chemistry-opencmis-client-bindings/src/main/java/org/apache/chemistry/opencmis/client/bindings/spi/atompub/HttpUtils.java
URL: http://svn.apache.org/viewvc/incubator/chemistry/opencmis/trunk/chemistry-opencmis-client/chemistry-opencmis-client-bindings/src/main/java/org/apache/chemistry/opencmis/client/bindings/spi/atompub/HttpUtils.java?rev=1001636&r1=1001635&r2=1001636&view=diff
==============================================================================
--- incubator/chemistry/opencmis/trunk/chemistry-opencmis-client/chemistry-opencmis-client-bindings/src/main/java/org/apache/chemistry/opencmis/client/bindings/spi/atompub/HttpUtils.java
(original)
+++ incubator/chemistry/opencmis/trunk/chemistry-opencmis-client/chemistry-opencmis-client-bindings/src/main/java/org/apache/chemistry/opencmis/client/bindings/spi/atompub/HttpUtils.java
Mon Sep 27 09:17:15 2010
@@ -41,15 +41,12 @@ import org.apache.commons.logging.LogFac
 
 /**
  * HTTP helper methods.
- * 
- * @author <a href="mailto:fmueller@opentext.com">Florian M&uuml;ller</a>
- * 
  */
 public class HttpUtils {
 
     private static final Log log = LogFactory.getLog(HttpUtils.class);
 
-    private static final int BUFFER_SIZE = 4096;
+    private static final int BUFFER_SIZE = 2 * 1024 * 1024;
 
     private HttpUtils() {
     }
@@ -128,6 +125,7 @@ public class HttpUtils {
 
             // send data
             if (writer != null) {
+                conn.setChunkedStreamingMode(BUFFER_SIZE);
                 OutputStream out = new BufferedOutputStream(conn.getOutputStream(), BUFFER_SIZE);
                 writer.write(out);
                 out.flush();
@@ -144,16 +142,15 @@ public class HttpUtils {
             }
 
             // get the response
-            return new Response(respCode, conn.getResponseMessage(), conn.getHeaderFields(),
inputStream, conn
-                    .getErrorStream());
+            return new Response(respCode, conn.getResponseMessage(), conn.getHeaderFields(),
inputStream,
+                    conn.getErrorStream());
         } catch (Exception e) {
             throw new CmisConnectionException("Cannot access " + url + ": " + e.getMessage(),
e);
         }
     }
 
     /**
-     * @author <a href="mailto:fmueller@opentext.com">Florian M&uuml;ller</a>
-     * 
+     * HTTP Response.
      */
     public static class Response {
         private int fResponseCode;

Modified: incubator/chemistry/opencmis/trunk/chemistry-opencmis-test/chemistry-opencmis-test-fit/src/test/java/org/apache/chemistry/opencmis/fit/runtime/AbstractWriteObjectIT.java
URL: http://svn.apache.org/viewvc/incubator/chemistry/opencmis/trunk/chemistry-opencmis-test/chemistry-opencmis-test-fit/src/test/java/org/apache/chemistry/opencmis/fit/runtime/AbstractWriteObjectIT.java?rev=1001636&r1=1001635&r2=1001636&view=diff
==============================================================================
--- incubator/chemistry/opencmis/trunk/chemistry-opencmis-test/chemistry-opencmis-test-fit/src/test/java/org/apache/chemistry/opencmis/fit/runtime/AbstractWriteObjectIT.java
(original)
+++ incubator/chemistry/opencmis/trunk/chemistry-opencmis-test/chemistry-opencmis-test-fit/src/test/java/org/apache/chemistry/opencmis/fit/runtime/AbstractWriteObjectIT.java
Mon Sep 27 09:17:15 2010
@@ -89,6 +89,50 @@ public abstract class AbstractWriteObjec
     }
 
     @Test
+    @Ignore
+    public void createHugeDocument() throws IOException {
+        ObjectId parentId = this.session.createObjectId(this.fixture.getTestRootId());
+        String folderName = UUID.randomUUID().toString();
+        String typeId = FixtureData.DOCUMENT_TYPE_ID.value();
+
+        Map<String, Object> properties = new HashMap<String, Object>();
+        properties.put(PropertyIds.NAME, folderName);
+        properties.put(PropertyIds.OBJECT_TYPE_ID, typeId);
+
+        String filename = UUID.randomUUID().toString();
+        String mimetype = "application/octet-stream";
+
+        ObjectId id = this.session.createDocument(properties, parentId, null, VersioningState.NONE);
+        assertNotNull(id);
+
+        // verify content
+        Document doc = (Document) this.session.getObject(id);
+        assertNotNull(doc);
+
+        final int size = 1 * 1024 * 1024 * 1024; // 2GB
+
+        InputStream in = new InputStream() {
+
+            private int counter = -1;
+
+            @Override
+            public int read() throws IOException {
+                counter++;
+                if (counter >= size) {
+                    return -1;
+                }
+
+                return '0' + (counter / 10);
+            }
+        };
+
+        ContentStream contentStream = this.session.getObjectFactory().createContentStream(filename,
size, mimetype, in);
+        assertNotNull(contentStream);
+
+        doc.setContentStream(contentStream, true);
+    }
+
+    @Test
     public void createDocumentFromSource() throws IOException {
         try {
             // verify content
@@ -166,7 +210,7 @@ public abstract class AbstractWriteObjec
         document.updateProperties();
         assertEquals("Neuer Name", document.getName());
     }
-    
+
     @Test
     public void updateSinglePropertyAndCheckName() {
         // verify content
@@ -184,10 +228,10 @@ public abstract class AbstractWriteObjec
         // update single property
         ObjectId newId = document.updateProperties(properties);
         assertNotNull(newId);
-        assertEquals(id, newId.getId());  // should not be a new version
-   
+        assertEquals(id, newId.getId()); // should not be a new version
+
         session.clear();
-        
+
         // verify
         String s1 = FixtureData.DOCUMENT1_NAME.toString();
         String s2 = document.getName();
@@ -196,7 +240,7 @@ public abstract class AbstractWriteObjec
         Property<String> p = document.getProperty(PropertyIds.NAME);
         String s3 = p.getFirstValue();
         assertEquals(s1, s3);
-        
+
         Document document2 = (Document) this.session.getObjectByPath(path);
         assertNotNull("Document not found: " + path, document2);
     }



Mime
View raw message