Method BroadcastProcessRMIs

Parallel/Core/vtkMultiProcessController.cxx:479–535

------------------------------------------------------------------------------

//------------------------------------------------------------------------------
int vtkMultiProcessController::BroadcastProcessRMIs(int vtkNotUsed(reportErrors), int dont_loop)
{
  int triggerMessage[128];
  int rmiTag;
  int argLength;
  unsigned char* arg = nullptr;
  int error = RMI_NO_ERROR;

  this->InvokeEvent(vtkCommand::StartEvent);

  do
  {
    this->RMICommunicator->Broadcast(triggerMessage, 128, 0);

#ifdef VTK_WORDS_BIGENDIAN
    // Header is sent in little-endian form. We need to convert it to big
    // endian.
    vtkByteSwap::SwapLERange(triggerMessage, 2);
#endif

    rmiTag = triggerMessage[0];
    argLength = triggerMessage[1];

    if (argLength > 0)
    {
      arg = new unsigned char[argLength];
      int buffer_size = sizeof(int) * (126 /*128-2*/);

      if (argLength < buffer_size)
      {
        memcpy(arg, &triggerMessage[2], argLength);
      } // END if message is inline
      else
      {
        this->RMICommunicator->Broadcast(arg, argLength, 0);
      } // END else message was not inline

    } // END if non-null arguments

    this->ProcessRMI(0 /*we broadcast from rank 0*/, arg, argLength, rmiTag);

    delete[] arg;
    arg = nullptr;

    // check for break
    if (this->BreakFlag)
    {
      this->BreakFlag = 0;
      this->InvokeEvent(vtkCommand::EndEvent);
      return error;
    }

  } while (!dont_loop);

  this->InvokeEvent(vtkCommand::EndEvent);
  return error;
}