Commit e0218948 authored by unknown's avatar unknown
Browse files

ndb - 

  fix api_signal_log print of uncond signals


ndb/src/ndbapi/Ndbif.cpp:
  Send TC_COMMIT_ACK uncond
ndb/src/ndbapi/TransporterFacade.cpp:
  Fix printout of uncond signals
ndb/src/ndbapi/TransporterFacade.hpp:
  Fix printout of uncond signals
parent 61873599

ndb/src/ndbapi/Ndbif.cpp

+2 −2
Original line number Diff line number Diff line
@@ -1355,5 +1355,5 @@ NdbConnection::sendTC_COMMIT_ACK(NdbApiSignal * aSignal, 
  dataPtr[0] = transId1;

  dataPtr[1] = transId2;

  

  tp->sendSignal(aSignal, refToNode(aTCRef));

  tp->sendSignalUnCond(aSignal, refToNode(aTCRef));

}

ndb/src/ndbapi/TransporterFacade.cpp

+4 −3
Original line number Diff line number Diff line
@@ -817,7 +817,7 @@ TransporterFacade::sendSignal(NdbApiSignal * aSignal, NodeId aNode){ 
      LinearSectionPtr ptr[3];

      signalLogger.sendSignal(* aSignal,

			      1,

			      aSignal->getDataPtr(),

			      tDataPtr,

			      aNode, ptr, 0);

      signalLogger.flushSignalLog();

      aSignal->theSendersBlockRef = tmp;
@@ -844,6 +844,7 @@ TransporterFacade::sendSignal(NdbApiSignal * aSignal, NodeId aNode){ 


int

TransporterFacade::sendSignalUnCond(NdbApiSignal * aSignal, NodeId aNode){

  Uint32* tDataPtr = aSignal->getDataPtrSend();

#ifdef API_TRACE

  if(setSignalLog() && TRACE_GSN(aSignal->theVerId_signalNumber)){

    Uint32 tmp = aSignal->theSendersBlockRef;
@@ -851,7 +852,7 @@ TransporterFacade::sendSignalUnCond(NdbApiSignal * aSignal, NodeId aNode){ 
    LinearSectionPtr ptr[3];

    signalLogger.sendSignal(* aSignal,

			    0,

			    aSignal->getDataPtr(),

			    tDataPtr,

			    aNode, ptr, 0);

    signalLogger.flushSignalLog();

    aSignal->theSendersBlockRef = tmp;
@@ -862,7 +863,7 @@ TransporterFacade::sendSignalUnCond(NdbApiSignal * aSignal, NodeId aNode){ 
         (aSignal->theReceiversBlockNumber != 0));

  SendStatus ss = theTransporterRegistry->prepareSend(aSignal, 

						      0, 

						      aSignal->getDataPtr(), 

						      tDataPtr,

						      aNode, 

						      0);

ndb/src/ndbapi/TransporterFacade.hpp

+2 −1
Original line number Diff line number Diff line
@@ -128,6 +128,7 @@ private: 
  friend class GrepSS;

  friend class Ndb;

  friend class Ndb_cluster_connection_impl;

  friend class NdbConnection;

  

  int sendSignalUnCond(NdbApiSignal *, NodeId nodeId);