Permalink
Browse files

More debug

  • Loading branch information...
gegao committed Nov 19, 2013
1 parent 92e3624 commit 42ddae8df772ec2c843202a6d499299e7e648c37
@@ -6,13 +6,15 @@
import java.util.concurrent.LinkedBlockingDeque;
import org.apache.log4j.Logger;
import org.jfree.util.Log;
import org.voltdb.ClientResponseImpl;
import org.voltdb.catalog.Site;
import org.voltdb.messaging.FastDeserializer;
import org.voltdb.messaging.FastSerializer;
import org.voltdb.utils.ProcessUtils;
import com.google.protobuf.ByteString;
import edu.brown.hstore.Hstoreservice.Status;
import edu.brown.hstore.txns.LocalTransaction;
import edu.brown.logging.LoggerUtil;
@@ -189,6 +191,9 @@ public void addTransactionRequest(LocalTransaction ts) {
// ----------------------------------------------------------------------------
public void sendResponseToParent(ClientResponseImpl response) {
if (debug.val) {
Log.debug("Send back client response to parent");
}
ByteString bs = ByteString.EMPTY;
try {
bs = ByteString.copyFrom(FastSerializer.serialize(response));
@@ -4,6 +4,7 @@
import java.util.List;
import org.apache.log4j.Logger;
import org.jfree.util.Log;
import org.voltdb.ClientResponseImpl;
import com.google.protobuf.RpcCallback;
@@ -68,6 +69,9 @@ protected void unblockCallback() {
// We want to do this first because the transaction state could get
// cleaned-up right away when we call HStoreCoordinator.transactionFinish()
ClientResponseImpl cresponse = this.ts.getClientResponse();
if (debug.val) {
Log.debug("Send back client response");
}
assert(cresponse.isInitialized()) :
"Trying to send back ClientResponse for " + ts + " before it was set!";
this.hstore_site.responseSend(this.ts, cresponse);

0 comments on commit 42ddae8

Please sign in to comment.