| 587 | } |
| 588 | |
| 589 | void |
| 590 | Monitor::MonitorTask::createBuiltinSubscription( |
| 591 | const char* topicName, |
| 592 | int type |
| 593 | ) |
| 594 | { |
| 595 | DDS::Subscriber_var subscriber |
| 596 | = this->participant_->get_builtin_subscriber(); |
| 597 | DDS::DataReader_var reader |
| 598 | = subscriber->lookup_datareader( topicName); |
| 599 | |
| 600 | // Track the type by handle and process any initial data. |
| 601 | this->handleTypeMap_[ reader->get_instance_handle()] = type; |
| 602 | |
| 603 | DDS::StatusCondition_var status = reader->get_statuscondition(); |
| 604 | status->set_enabled_statuses( DDS::DATA_AVAILABLE_STATUS); |
| 605 | this->waiter_->attach_condition( status.in()); |
| 606 | |
| 607 | if( this->options_.verbose()) { |
| 608 | ACE_DEBUG((LM_DEBUG, |
| 609 | ACE_TEXT("(%P|%t) MonitorTask::createBuiltinSubscription() - ") |
| 610 | ACE_TEXT("topic %C installed and mapped instance %d to type %d.\n"), |
| 611 | topicName, |
| 612 | reader->get_instance_handle(), |
| 613 | type |
| 614 | )); |
| 615 | } |
| 616 | } |
| 617 | |
| 618 | void |
| 619 | Monitor::MonitorTask::dispatchReader( DDS::DataReader_ptr reader) |
no test coverage detected