| 98 | } |
| 99 | |
| 100 | bool |
| 101 | assert_supported(const Options& opts, const DDS::Entity_ptr e) |
| 102 | { |
| 103 | TEST_ASSERT(e != 0); |
| 104 | OpenDDS::DCPS::TransportClient* tc = dynamic_cast<OpenDDS::DCPS::TransportClient*> (e); |
| 105 | TEST_ASSERT(tc != 0); |
| 106 | |
| 107 | const std::vector<OPENDDS_STRING>& transporti = opts.protocol_str; |
| 108 | |
| 109 | // Assert effective transport protocols |
| 110 | size_t left = transporti.size(); |
| 111 | for (std::vector < OPENDDS_STRING>::const_iterator proto = transporti.begin(); |
| 112 | proto < transporti.end(); proto++) |
| 113 | { |
| 114 | // ACE_DEBUG((LM_INFO, |
| 115 | // ACE_TEXT("(%P|%t) Entity '%C' supports protocol '%C'?\n"), |
| 116 | // opts.entity_str.c_str(), |
| 117 | // proto->c_str())); |
| 118 | |
| 119 | if (::DDS_TEST::supports(tc, *proto)) left--; |
| 120 | } |
| 121 | |
| 122 | return (0 == left); |
| 123 | } |
| 124 | |
| 125 | bool |
| 126 | assert_negotiated(const Options& opts, const DDS::Entity_ptr e) |