Function AssembleLinearMessage

source/src/enet_encap/cpf.c:651–758

}

int AssembleLinearMessage(
  const CipMessageRouterResponse *const message_router_response,
  const CipCommonPacketFormatData *const common_packet_format_data_item,
  ENIPMessage *const outgoing_message) {

  if (message_router_response) {
    /* add Interface Handle and Timeout = 0 -> only for SendRRData and SendUnitData necessary */
    outgoing_message->used_message_length += AddDintToMessage(0,
                                                              &outgoing_message->current_message_position);
    outgoing_message->used_message_length += AddIntToMessage(0,
                                                             &outgoing_message->current_message_position);
  }

  EncodeItemCount(common_packet_format_data_item, outgoing_message);

  /* process Address Item */
  switch (common_packet_format_data_item->address_item.type_id) {
    case kCipItemIdNullAddress: {
      EncodeNullAddressItem(outgoing_message);
      break;
    }
    case kCipItemIdConnectionAddress: {
      EncodeConnectedAddressItem(common_packet_format_data_item,
                                 outgoing_message);
      break;
    }
    case kCipItemIdSequencedAddressItem: {
      EncodeSequencedAddressItem(common_packet_format_data_item,
                                 outgoing_message);
      break;
    }
    default:
      OPENER_TRACE_INFO("Unknown CIP Item in AssembleLinearMessage");
      return kEipStatusError;
  }

  /* process Data Item */
  if ( (common_packet_format_data_item->data_item.type_id
        == kCipItemIdUnconnectedDataItem)
       || (common_packet_format_data_item->data_item.type_id
           == kCipItemIdConnectedDataItem) ) {

    if (message_router_response) {
      EncodeDataItemType(common_packet_format_data_item,
                         outgoing_message);

      if (common_packet_format_data_item->data_item.type_id
          == kCipItemIdConnectedDataItem) { /* Connected Item */
        EncodeConnectedDataItemLength(message_router_response,
                                      outgoing_message);
        EncodeSequenceNumber(&g_common_packet_format_data_item,
                             outgoing_message);

      } else { /* Unconnected Item */
        EncodeUnconnectedDataItemLength(message_router_response,
                                        outgoing_message);
      }