Added more logging
git-svn-id: https://hyracks.googlecode.com/svn/branches/hyracks_dev_next@1029 123451ca-8445-de46-9d55-352943316053
diff --git a/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/collectors/NonDeterministicPartitionCollector.java b/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/collectors/NonDeterministicPartitionCollector.java
index 2b37c7b..d5f4fd8 100644
--- a/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/collectors/NonDeterministicPartitionCollector.java
+++ b/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/collectors/NonDeterministicPartitionCollector.java
@@ -18,6 +18,8 @@
import java.util.ArrayList;
import java.util.BitSet;
import java.util.Collection;
+import java.util.logging.Level;
+import java.util.logging.Logger;
import edu.uci.ics.hyracks.api.channels.IInputChannel;
import edu.uci.ics.hyracks.api.channels.IInputChannelMonitor;
@@ -31,6 +33,8 @@
import edu.uci.ics.hyracks.dataflow.common.comm.util.FrameUtils;
public class NonDeterministicPartitionCollector extends AbstractPartitionCollector {
+ private static final Logger LOGGER = Logger.getLogger(NonDeterministicPartitionCollector.class.getName());
+
private final FrameReader reader;
private final BitSet expectedPartitions;
@@ -173,6 +177,10 @@
int senderIndex = pid.getSenderIndex();
failSenders.set(senderIndex);
eosSenders.set(senderIndex);
+ if (LOGGER.isLoggable(Level.FINE)) {
+ LOGGER.fine("Failure: " + connectorId + " sender: " + senderIndex + " receiver: "
+ + receiverIndex);
+ }
NonDeterministicPartitionCollector.this.notifyAll();
}
}
@@ -184,6 +192,10 @@
int senderIndex = pid.getSenderIndex();
availableFrameCounts[senderIndex] += nFrames;
frameAvailability.set(senderIndex);
+ if (LOGGER.isLoggable(Level.FINE)) {
+ LOGGER.fine("Data available: " + connectorId + " sender: " + senderIndex + " receiver: "
+ + receiverIndex);
+ }
NonDeterministicPartitionCollector.this.notifyAll();
}
}
@@ -194,6 +206,10 @@
PartitionId pid = (PartitionId) channel.getAttachment();
int senderIndex = pid.getSenderIndex();
eosSenders.set(senderIndex);
+ if (LOGGER.isLoggable(Level.FINE)) {
+ LOGGER.fine("EOS: " + connectorId + " sender: " + senderIndex + " receiver: "
+ + receiverIndex);
+ }
NonDeterministicPartitionCollector.this.notifyAll();
}
}
diff --git a/hyracks-ipc/src/main/java/edu/uci/ics/hyracks/ipc/impl/IPCConnectionManager.java b/hyracks-ipc/src/main/java/edu/uci/ics/hyracks/ipc/impl/IPCConnectionManager.java
index 3ce3475..eb9cbd3 100644
--- a/hyracks-ipc/src/main/java/edu/uci/ics/hyracks/ipc/impl/IPCConnectionManager.java
+++ b/hyracks-ipc/src/main/java/edu/uci/ics/hyracks/ipc/impl/IPCConnectionManager.java
@@ -104,7 +104,9 @@
}
synchronized void write(Message msg) {
- LOGGER.fine("Enqueued message: " + msg);
+ if (LOGGER.isLoggable(Level.FINE)) {
+ LOGGER.fine("Enqueued message: " + msg);
+ }
sendList.add(msg);
networkThread.selector.wakeup();
}
@@ -189,7 +191,9 @@
if (!workingSendList.isEmpty()) {
for (Iterator<Message> i = workingSendList.iterator(); i.hasNext();) {
Message msg = i.next();
- LOGGER.fine("Processing send of message: " + msg);
+ if (LOGGER.isLoggable(Level.FINE)) {
+ LOGGER.fine("Processing send of message: " + msg);
+ }
IPCHandle handle = msg.getIPCHandle();
if (handle.getState() == HandleState.CLOSED) {
i.remove();