You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@manifoldcf.apache.org by kw...@apache.org on 2017/05/10 12:29:22 UTC
svn commit: r1794715 - in
/manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter:
ContentLimiter.java ContentLimiterConfig.java Messages.java
Author: kwright
Date: Wed May 10 12:29:22 2017
New Revision: 1794715
URL: http://svn.apache.org/viewvc?rev=1794715&view=rev
Log:
Fix formatting
Modified:
manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/ContentLimiter.java (contents, props changed)
manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/ContentLimiterConfig.java (contents, props changed)
manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/Messages.java (contents, props changed)
Modified: manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/ContentLimiter.java
URL: http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/ContentLimiter.java?rev=1794715&r1=1794714&r2=1794715&view=diff
==============================================================================
--- manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/ContentLimiter.java (original)
+++ manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/ContentLimiter.java Wed May 10 12:29:22 2017
@@ -1,4 +1,4 @@
-/* $Id: DocumentFilter.java 1756230 2016-08-12 22:20:00Z kwright $ */
+/* $Id$ */
/**
* Licensed to the Apache Software Foundation (ASF) under one or more
@@ -91,7 +91,7 @@ public class ContentLimiter extends org.
@Override
public boolean checkLengthIndexable(VersionContext outputDescription, long length, IOutputCheckActivity activities)
throws ManifoldCFException, ServiceInterruption {
- // Always true;
+ // Always true;
return true;
}
@@ -110,62 +110,62 @@ public class ContentLimiter extends org.
public int addOrReplaceDocumentWithException(String documentURI, VersionContext outputDescription, RepositoryDocument document, String authorityNameString, IOutputAddActivity activities)
throws ManifoldCFException, ServiceInterruption, IOException
{
- InputStream is = null;
- DestinationStorage ds = null;
- try {
- RepositoryDocument finalDocument;
- long length;
- long startTime = System.currentTimeMillis();
- String resultCode = "OK";
- String description = null;
- SpecPacker sp = new SpecPacker(outputDescription.getSpecification());
-
- if(document.getBinaryLength() > sp.lengthCutoff) {
-
- if (document.getBinaryLength() <= inMemoryMaximumFile)
- {
- ds = new MemoryDestinationStorage((int)document.getBinaryLength());
- }
- else
- {
- ds = new FileDestinationStorage();
- }
-
- // Create a copy of Repository Document
- finalDocument = document.duplicate();
-
- InputStream docIs = document.getBinaryStream();
- try {
- IOUtils.copyLarge(docIs, ds.getOutputStream(), 0L, sp.lengthCutoff);
-
- // Get new stream length
- length = ds.getBinaryLength();
- is = ds.getInputStream();
- finalDocument.setBinary(is,length);
- resultCode = "TRUNCATEDOK";
- } catch(IOException e) {
- resultCode = "TRUNCATEDERROR";
- description = e.getMessage();
- return DOCUMENTSTATUS_REJECTED;
- } finally {
- docIs.close();
- }
- } else {
- finalDocument = document;
- length = document.getBinaryLength();
- }
-
- activities.recordActivity(new Long(startTime), ACTIVITY_LIMIT, length, documentURI,
- resultCode, description);
- return activities.sendDocument(documentURI, finalDocument);
- } finally {
- if(is != null) {
- is.close();
- }
- if(ds != null) {
- ds.close();
- }
- }
+ InputStream is = null;
+ DestinationStorage ds = null;
+ try {
+ RepositoryDocument finalDocument;
+ long length;
+ long startTime = System.currentTimeMillis();
+ String resultCode = "OK";
+ String description = null;
+ SpecPacker sp = new SpecPacker(outputDescription.getSpecification());
+
+ if(document.getBinaryLength() > sp.lengthCutoff) {
+
+ if (document.getBinaryLength() <= inMemoryMaximumFile)
+ {
+ ds = new MemoryDestinationStorage((int)document.getBinaryLength());
+ }
+ else
+ {
+ ds = new FileDestinationStorage();
+ }
+
+ // Create a copy of Repository Document
+ finalDocument = document.duplicate();
+
+ InputStream docIs = document.getBinaryStream();
+ try {
+ IOUtils.copyLarge(docIs, ds.getOutputStream(), 0L, sp.lengthCutoff);
+
+ // Get new stream length
+ length = ds.getBinaryLength();
+ is = ds.getInputStream();
+ finalDocument.setBinary(is,length);
+ resultCode = "TRUNCATEDOK";
+ } catch(IOException e) {
+ resultCode = "TRUNCATEDERROR";
+ description = e.getMessage();
+ return DOCUMENTSTATUS_REJECTED;
+ } finally {
+ docIs.close();
+ }
+ } else {
+ finalDocument = document;
+ length = document.getBinaryLength();
+ }
+
+ activities.recordActivity(new Long(startTime), ACTIVITY_LIMIT, length, documentURI,
+ resultCode, description);
+ return activities.sendDocument(documentURI, finalDocument);
+ } finally {
+ if(is != null) {
+ is.close();
+ }
+ if(ds != null) {
+ ds.close();
+ }
+ }
}
protected static void fillInContentSpecificationMap(Map<String,Object> paramMap, Specification os)
Propchange: manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/ContentLimiter.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/ContentLimiter.java
------------------------------------------------------------------------------
svn:keywords = Id
Modified: manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/ContentLimiterConfig.java
URL: http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/ContentLimiterConfig.java?rev=1794715&r1=1794714&r2=1794715&view=diff
==============================================================================
--- manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/ContentLimiterConfig.java (original)
+++ manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/ContentLimiterConfig.java Wed May 10 12:29:22 2017
@@ -1,4 +1,4 @@
-/* $Id: DocumentFilterConfig.java 1630623 2014-10-10 00:11:30Z kwright $ */
+/* $Id$ */
/**
* Licensed to the Apache Software Foundation (ASF) under one or more
Propchange: manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/ContentLimiterConfig.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/ContentLimiterConfig.java
------------------------------------------------------------------------------
svn:keywords = Id
Modified: manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/Messages.java
URL: http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/Messages.java?rev=1794715&r1=1794714&r2=1794715&view=diff
==============================================================================
--- manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/Messages.java (original)
+++ manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/Messages.java Wed May 10 12:29:22 2017
@@ -1,4 +1,4 @@
-/* $Id: Messages.java 1604371 2014-06-21 13:36:55Z kwright $ */
+/* $Id$ */
/**
* Licensed to the Apache Software Foundation (ASF) under one or more
Propchange: manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/Messages.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/Messages.java
------------------------------------------------------------------------------
svn:keywords = Id