Author: jolee
Date: 2012-07-03 11:29:48 -0400 (Tue, 03 Jul 2012)
New Revision: 4220
Modified:
branches/7.7.x/client/src/main/java/org/teiid/net/socket/Message.java
branches/7.7.x/client/src/main/java/org/teiid/net/socket/ServiceInvocationStruct.java
branches/7.7.x/engine/src/main/java/org/teiid/query/processor/relational/SortUtility.java
branches/7.7.x/runtime/src/main/java/org/teiid/transport/SocketClientInstance.java
Log:
TEIID-2089 additional logging enhancements
Modified: branches/7.7.x/client/src/main/java/org/teiid/net/socket/Message.java
===================================================================
--- branches/7.7.x/client/src/main/java/org/teiid/net/socket/Message.java 2012-07-03
15:29:32 UTC (rev 4219)
+++ branches/7.7.x/client/src/main/java/org/teiid/net/socket/Message.java 2012-07-03
15:29:48 UTC (rev 4220)
@@ -35,7 +35,7 @@
private Serializable messageKey;
public String toString() {
- return "MessageHolder: contents=" + contents; //$NON-NLS-1$
+ return "MessageHolder: key=" + messageKey + " contents=" +
contents; //$NON-NLS-1$ //$NON-NLS-2$
}
public void setContents(Object contents) {
Modified:
branches/7.7.x/client/src/main/java/org/teiid/net/socket/ServiceInvocationStruct.java
===================================================================
---
branches/7.7.x/client/src/main/java/org/teiid/net/socket/ServiceInvocationStruct.java 2012-07-03
15:29:32 UTC (rev 4219)
+++
branches/7.7.x/client/src/main/java/org/teiid/net/socket/ServiceInvocationStruct.java 2012-07-03
15:29:48 UTC (rev 4220)
@@ -65,4 +65,9 @@
out.writeObject(methodName);
ExternalizeUtil.writeArray(out, args);
}
+
+ @Override
+ public String toString() {
+ return "Invoke " + targetClass + "." + methodName; //$NON-NLS-1$
//$NON-NLS-2$
+ }
}
\ No newline at end of file
Modified:
branches/7.7.x/engine/src/main/java/org/teiid/query/processor/relational/SortUtility.java
===================================================================
---
branches/7.7.x/engine/src/main/java/org/teiid/query/processor/relational/SortUtility.java 2012-07-03
15:29:32 UTC (rev 4219)
+++
branches/7.7.x/engine/src/main/java/org/teiid/query/processor/relational/SortUtility.java 2012-07-03
15:29:48 UTC (rev 4220)
@@ -40,6 +40,7 @@
import org.teiid.core.TeiidProcessingException;
import org.teiid.core.util.Assertion;
import org.teiid.language.SortSpecification.NullOrdering;
+import org.teiid.logging.LogConstants;
import org.teiid.logging.LogManager;
import org.teiid.logging.MessageLevel;
import org.teiid.query.sql.lang.OrderBy;
@@ -177,10 +178,6 @@
this(ts, new OrderBy(expressions, types).getOrderByItems(), mode, bufferManager,
connectionID, schema);
}
- public boolean isDone() {
- return this.doneReading && this.phase == DONE;
- }
-
public TupleBuffer sort()
throws TeiidComponentException, TeiidProcessingException {
@@ -204,11 +201,18 @@
initialSort();
}
+ for (TupleBuffer tb : activeTupleBuffers) {
+ tb.close();
+ }
+
return activeTupleBuffers;
}
private TupleBuffer createTupleBuffer() throws TeiidComponentException {
TupleBuffer tb = bufferManager.createTupleBuffer(this.schema, this.groupName,
TupleSourceType.PROCESSOR);
+ if (LogManager.isMessageToBeRecorded(LogConstants.CTX_DQP, MessageLevel.DETAIL)) {
+ LogManager.logDetail(LogConstants.CTX_DQP, "Created intermediate sort buffer
", tb.getId()); //$NON-NLS-1$
+ }
tb.setForwardOnly(true);
return tb;
}
Modified:
branches/7.7.x/runtime/src/main/java/org/teiid/transport/SocketClientInstance.java
===================================================================
---
branches/7.7.x/runtime/src/main/java/org/teiid/transport/SocketClientInstance.java 2012-07-03
15:29:32 UTC (rev 4219)
+++
branches/7.7.x/runtime/src/main/java/org/teiid/transport/SocketClientInstance.java 2012-07-03
15:29:48 UTC (rev 4220)
@@ -75,10 +75,10 @@
}
public void send(Message message, Serializable messageKey) {
+ message.setMessageKey(messageKey);
if (LogManager.isMessageToBeRecorded(LogConstants.CTX_TRANSPORT,
MessageLevel.DETAIL)) {
- LogManager.logDetail(LogConstants.CTX_TRANSPORT, " message: " +
message + " for message:" + messageKey); //$NON-NLS-1$ //$NON-NLS-2$
+ LogManager.logDetail(LogConstants.CTX_TRANSPORT, "send message: " +
message); //$NON-NLS-1$
}
- message.setMessageKey(messageKey);
objectSocket.write(message);
}
Show replies by thread