RW PM selection

Author: mariadb-SergeyZefirov

dmlproc/batchinsertprocessor.cpp

@@ -230,14 +230,23 @@ void BatchInsertProc::buildLastPkg(messageqcpp::ByteStream& bs)
   bs << rt;
 }
 
+uint32_t BatchInsertProc::selectNextPM()
+{
+  uint32_t pm;
+  do
+  {
+    pm = fBatchLoader->selectNextPM();
+  } while (pm != 0 && fWEClient->isConnectionReadonly(pm));
+  return pm;
+}
 void BatchInsertProc::sendFirstBatch()
 {
   uint32_t firstPmId = 0;
   int rc = 0;
 
   try
   {
-    firstPmId = fBatchLoader->selectNextPM();
+    firstPmId = selectNextPM();
   }
   catch (std::exception& ex)
   {
@@ -268,7 +277,7 @@ void BatchInsertProc::sendNextBatch()
 
   try
   {
-    fCurrentPMid = fBatchLoader->selectNextPM();
+    fCurrentPMid = selectNextPM();
   }
   catch (std::exception& ex)
   {

dmlproc/batchinsertprocessor.h

@@ -68,6 +68,7 @@ class BatchInsertProc
   void setHwm();
   void receiveAllMsg();
   void receiveOutstandingMsg();
+  uint32_t selectNextPM();
 
  private:
   SP_PKG fInsertPkgQueue;