Method sendPeriodicMessage

src/examples/simpleMessageSender.cpp:226–271

}

void cSimpleMessageSender::sendPeriodicMessage(FLOAT_DMEM *v, int firstElementIndex, int Nv, long vi, double tm)
{
  if (!useJsonFormat) {
    cComponentMessage msg;
    memset(&msg, 0, sizeof(msg));
    strncpy(msg.msgtype, messageType, CMSG_typenameLen);
    strncpy(msg.msgname, messageName, CMSG_typenameLen);
    if (v != NULL) {
      for (int i = 0; i < Nv && i < CMSG_nUserData; i++) {
        msg.floatData[i] = v[firstElementIndex + i];
      }
    }
    msg.intData[0] = 0;
    msg.readerTime = tm;
    msg.userTime1 = (double)vi;
    sendMessage(&msg);
  } else {
    rapidjson::Document doc;
    doc.SetObject();
    rapidjson::Document::AllocatorType& allocator = doc.GetAllocator();
    doc.AddMember("msgtype", rapidjson::Value(messageType, allocator), allocator);
    doc.AddMember("msgname", rapidjson::Value(messageName, allocator), allocator);
    rapidjson::Value fields(rapidjson::kObjectType);
    const FrameMetaInfo *fmeta = reader_->getFrameMetaInfo();
    for (int i = 0; i < Nv; i++) {
      long arrIdx;
      long el = fmeta->elementToFieldIdx(i, &arrIdx);
      FieldMetaInfo &field = fmeta->field[el];
      if (field.N <= 1) {
        // non-array field
        fields.AddMember(rapidjson::Value(field.name, allocator), rapidjson::Value(v[firstElementIndex + i]), allocator);      
      } else {
        // array field
        rapidjson::Value arrayField(rapidjson::kArrayType);
        for (int j = arrIdx; j < field.N && i < Nv; j++, i++) {
          arrayField.PushBack(v[firstElementIndex + i], allocator);
        }
        fields.AddMember(rapidjson::Value(field.name, allocator), arrayField, allocator);
      }
    }
    doc.AddMember("fields", fields, allocator);
    doc.AddMember("time", tm, allocator);
    doc.AddMember("vIdx", int(vi), allocator);    
    sendJsonMessage(doc);
  }
}

void cSimpleMessageSender::sendEventMessage(FLOAT_DMEM *v, int Nv, const char * text, FLOAT_DMEM ref, long vi, double tm)
{