| 3236 | } |
| 3237 | |
| 3238 | DDS::ReturnCode_t DataWriterImpl::write_sample( |
| 3239 | const Sample& sample, |
| 3240 | DDS::InstanceHandle_t handle, |
| 3241 | const DDS::Time_t& source_timestamp, |
| 3242 | GUIDSeq* filter_out) |
| 3243 | { |
| 3244 | Message_Block_Ptr serialized(serialize_sample(sample)); |
| 3245 | if (!serialized) { |
| 3246 | if (log_level >= LogLevel::Notice) { |
| 3247 | ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DataWriterImpl::write_sample: " |
| 3248 | "failed to serialize sample\n")); |
| 3249 | } |
| 3250 | return DDS::RETCODE_ERROR; |
| 3251 | } |
| 3252 | |
| 3253 | return write(OPENDDS_MOVE_NS::move(serialized), handle, source_timestamp, filter_out, sample.native_data()); |
| 3254 | } |
| 3255 | |
| 3256 | } // namespace DCPS |
| 3257 | } // namespace OpenDDS |
nothing calls this directly
no test coverage detected