| 273 | } |
| 274 | |
| 275 | DDS::ReturnCode_t |
| 276 | WriteDataContainer::enqueue_control(DataSampleElement* control_sample) |
| 277 | { |
| 278 | // Enqueue to the next_send_sample_ thread of unsent_data_ |
| 279 | // will link samples with the next_sample/previous_sample and |
| 280 | // also next_send_sample_. |
| 281 | // This would save time when we actually send the data. |
| 282 | |
| 283 | if (shutdown_) { |
| 284 | return DDS::RETCODE_ERROR; |
| 285 | } |
| 286 | |
| 287 | unsent_data_.enqueue_tail(control_sample); |
| 288 | |
| 289 | return DDS::RETCODE_OK; |
| 290 | } |
| 291 | |
| 292 | // This method assumes that instance list has space for this sample. |
| 293 | DDS::ReturnCode_t |
no test coverage detected