Method decode_rtps_message

dds/DCPS/security/CryptoBuiltInImpl.cpp:1949–2092

}

bool CryptoBuiltInImpl::decode_rtps_message(
  DDS::OctetSeq& plain_buffer,
  const DDS::OctetSeq& encoded_buffer,
  ParticipantCryptoHandle receiving_participant_crypto,
  ParticipantCryptoHandle sending_participant_crypto,
  SecurityException& ex)
{
  if (DDS::HANDLE_NIL == receiving_participant_crypto) {
    return CommonUtilities::set_security_error(ex, -1, 0, "No Receiving Participant handle");
  }
  if (DDS::HANDLE_NIL == sending_participant_crypto) {
    return CommonUtilities::set_security_error(ex, -1, 1, "No Sending Participant handle");
  }

  RTPS::MessageParser parser(encoded_buffer);

  if (!parser.parseHeader()) {
    return CommonUtilities::set_security_error(ex, -2, 0, "Failed to deserialize Header");
  }

  CryptoHeader ch = CryptoHeader();
  CryptoFooter cf;
  bool haveCryptoHeader = false, haveCryptoFooter = false;
  const char* afterSrtpsPrefix = 0;
  unsigned int sizeOfAuthenticated = 0, sizeOfEncrypted = 0;
  const char* encrypted = 0;

  for (int i = 0; parser.remaining(); ++i) {
    if (parser.remaining() < RTPS::SMHDR_SZ || !parser.parseSubmessageHeader()) {
      return CommonUtilities::set_security_error(ex, -3, i, "Failed to deserialize SubmessageHeader");
    }

    parser.serializer().endianness(ENDIAN_BIG);
    const int type = parser.submessageHeader().submessageId;

    if (i == 0 && type == RTPS::SRTPS_PREFIX) {
      if (!(parser >> ch)) {
        return CommonUtilities::set_security_error(ex, -4, i, "Failed to deserialize CryptoHeader");
      }
      haveCryptoHeader = true;
      if (!parser.skipToNextSubmessage()) {
        return CommonUtilities::set_security_error(ex, -5, i, "Failed to find submessage after SRTPS_PREFIX");
      }
      afterSrtpsPrefix = parser.current();

    } else if (haveCryptoHeader && type == RTPS::SEC_BODY) {
      if (!(parser >> sizeOfEncrypted)) {
        return CommonUtilities::set_security_error(ex, -13, i, "Failed to deserialize CryptoContent length");
      }
      const unsigned short sz =
        static_cast<unsigned short>(DCPS::uint32_cdr_size);
      if (sizeOfEncrypted + sz > parser.submessageHeader().submessageLength) {
        return CommonUtilities::set_security_error(ex, -14, i, "CryptoContent length out of bounds");
      }
      encrypted = parser.current();
      if (!parser.skipToNextSubmessage()) {
        return CommonUtilities::set_security_error(ex, -15, i, "Failed to find submessage after SEC_BODY");
      }