Commit e9e8b0bc authored by unknown's avatar unknown
Browse files

ndb - replication 

  Make sure that SUB_GCP_COMPLETE_ACK is sent uncond, failure to do so can lead to problems...


storage/ndb/src/kernel/blocks/ndbfs/AsyncFile.cpp:
  retry on O_DIRECT
storage/ndb/src/ndbapi/TransporterFacade.cpp:
  Make sure that SUB_GCP_COMPLETE_ACK is sent uncond
parent 32b71c76

storage/ndb/src/kernel/blocks/ndbfs/AsyncFile.cpp

+9 −2
Original line number Diff line number Diff line
@@ -395,6 +395,13 @@ void AsyncFile::openReq(Request* request) 
      createDirectories();

      if (-1 == (theFd = ::open(theFileName.c_str(), new_flags, mode))) 

      {

#ifdef O_DIRECT

	if (new_flags & O_DIRECT)

	{

	  new_flags &= ~O_DIRECT;

	  goto no_odirect;

	}

#endif

        PRINT_ERRORANDFLAGS(new_flags);

        request->error = errno;

	return;

storage/ndb/src/ndbapi/TransporterFacade.cpp

+1 −1
Original line number Diff line number Diff line
@@ -343,7 +343,7 @@ execute(void * callbackObj, SignalHeader * const header, 
	 Uint32 aNodeId= refToNode(ref);

	 tSignal.theReceiversBlockNumber= refToBlock(ref);

	 tSignal.theVerId_signalNumber= GSN_SUB_GCP_COMPLETE_ACK;

	 theFacade->sendSignal(&tSignal, aNodeId);

	 theFacade->sendSignalUnCond(&tSignal, aNodeId);

       }

       break;

     }