| 100 | } |
| 101 | |
| 102 | int |
| 103 | Writer::write (Messenger::MessageDataWriter_ptr message_dw, |
| 104 | Messenger::Message& message) |
| 105 | { |
| 106 | for (int i = 0; i < num_messages; ++i) |
| 107 | { |
| 108 | ++this->count_; |
| 109 | message.count = this->count_; |
| 110 | |
| 111 | ::DDS::ReturnCode_t const ret = message_dw->write (message, DDS::HANDLE_NIL); |
| 112 | |
| 113 | if (ret != ::DDS::RETCODE_OK) |
| 114 | { |
| 115 | ACE_ERROR ((LM_ERROR, |
| 116 | ACE_TEXT("(%P|%t) ERROR: Writer::svc, ") |
| 117 | ACE_TEXT ("%dth write() returned %d.\n"), |
| 118 | i, |
| 119 | -1)); |
| 120 | if (ret == ::DDS::RETCODE_TIMEOUT) |
| 121 | { |
| 122 | ++this->timeout_writes_; |
| 123 | } |
| 124 | } |
| 125 | |
| 126 | } |
| 127 | |
| 128 | return 0; |
| 129 | } |