| 27 | |
| 28 | |
| 29 | void |
| 30 | SimpleDataReader::init(const OpenDDS::DCPS::AssociationData& publication, |
| 31 | int num_msgs) |
| 32 | { |
| 33 | DBG_ENTRY("SimpleDataReader","init"); |
| 34 | this->num_messages_expected_ = num_msgs; |
| 35 | this->num_messages_received_ = 0; |
| 36 | |
| 37 | // Add the association between the local sub_id and the remote pub_id |
| 38 | // to the transport via the TransportInterface. |
| 39 | bool result = this->associate(publication, false /* active */); |
| 40 | |
| 41 | if (!result) { |
| 42 | ACE_ERROR((LM_ERROR, |
| 43 | "(%P|%t) SimpleDataReader::init() Failed to associate.\n")); |
| 44 | throw TestException(); |
| 45 | } |
| 46 | } |
| 47 | |
| 48 | |
| 49 | void |
nothing calls this directly
no test coverage detected