You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2015/04/10 18:09:40 UTC

svn commit: r1672695 - in /uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp: DuccHttpClient.java HttpWorkerThread.java

Author: cwiklik
Date: Fri Apr 10 16:09:40 2015
New Revision: 1672695

URL: http://svn.apache.org/r1672695
Log:
UIMA-4066 added more logging for ACK msgs

Modified:
    uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/DuccHttpClient.java
    uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/HttpWorkerThread.java

Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/DuccHttpClient.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/DuccHttpClient.java?rev=1672695&r1=1672694&r2=1672695&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/DuccHttpClient.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/DuccHttpClient.java Fri Apr 10 16:09:40 2015
@@ -308,8 +308,10 @@ public class DuccHttpClient {
 	            addCommonHeaders(postMethod);
 	    
 	            postMethod.setRequestHeader("Content-Length", String.valueOf(body.length()));
+	            logger.debug("execute",null, "calling httpClient.executeMethod()");
 	            // wait for a reply
 	            httpClient.executeMethod(postMethod);
+	            logger.debug("execute",null, "httpClient.executeMethod() returned");
                 
                 String content = new String(postMethod.getResponseBody());
                 

Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/HttpWorkerThread.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/HttpWorkerThread.java?rev=1672695&r1=1672694&r2=1672695&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/HttpWorkerThread.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/HttpWorkerThread.java Fri Apr 10 16:09:40 2015
@@ -173,6 +173,7 @@ public class HttpWorkerThread implements
 					command = Type.Ack.name();
 					tid = new TransactionId(major, minor++);
 					transaction.setTransactionId(tid);
+					logger.debug("run", null,"Thread:"+Thread.currentThread().getId()+" Sending ACK request - WI:"+transaction.getMetaCas().getSystemKey());
 					httpClient.execute(transaction, postMethod); 
 					
                     logger.debug("run", null,"Thread:"+Thread.currentThread().getId()+" ACK reply recv'd");