Method write_w_timestamp

dds/DCPS/DataWriterImpl.cpp:3190–3236

}

DDS::ReturnCode_t DataWriterImpl::write_w_timestamp(
  const Sample& sample,
  DDS::InstanceHandle_t handle,
  const DDS::Time_t& source_timestamp)
{
  // This operation assumes the provided handle is valid. The handle provided
  // will not be verified.

  if (handle == DDS::HANDLE_NIL) {
    DDS::InstanceHandle_t registered_handle = DDS::HANDLE_NIL;
    const DDS::ReturnCode_t ret =
      get_or_create_instance_handle(registered_handle, sample, source_timestamp);
    if (ret != DDS::RETCODE_OK) {
      if (log_level >= LogLevel::Notice) {
        ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: %CDataWriterImpl::write_w_timestamp: "
                   "register failed: %C\n",
                   get_type_support()->name(),
                   retcode_to_string(ret)));
      }
      return ret;
    }

    handle = registered_handle;
  }

  // list of reader GUID_ts that should not get data
  GUIDSeq_var filter_out;
#ifndef OPENDDS_NO_CONTENT_FILTERED_TOPIC
  if (publisher_content_filter_) {
    ACE_GUARD_RETURN(ACE_Thread_Mutex, reader_info_guard, reader_info_lock_, DDS::RETCODE_ERROR);
    for (RepoIdToReaderInfoMap::iterator iter = reader_info_.begin(),
         end = reader_info_.end(); iter != end; ++iter) {
      const ReaderInfo& ri = iter->second;
      if (!ri.eval_.is_nil()) {
        if (!filter_out.ptr()) {
          filter_out = new OpenDDS::DCPS::GUIDSeq;
        }
        if (!sample.eval(*ri.eval_, ri.expression_params_)) {
          push_back(filter_out.inout(), iter->first);
        }
      }
    }
  }
#endif

  return write_sample(sample, handle, source_timestamp, filter_out._retn());
}

DDS::ReturnCode_t DataWriterImpl::write_sample(
  const Sample& sample,