summaryrefslogtreecommitdiff
path: root/DAnCE/tools/Logger_Backend/ndds/Log_Backend.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'DAnCE/tools/Logger_Backend/ndds/Log_Backend.cpp')
-rw-r--r--DAnCE/tools/Logger_Backend/ndds/Log_Backend.cpp20
1 files changed, 18 insertions, 2 deletions
diff --git a/DAnCE/tools/Logger_Backend/ndds/Log_Backend.cpp b/DAnCE/tools/Logger_Backend/ndds/Log_Backend.cpp
index 4f116a4393a..98bbc66e4fe 100644
--- a/DAnCE/tools/Logger_Backend/ndds/Log_Backend.cpp
+++ b/DAnCE/tools/Logger_Backend/ndds/Log_Backend.cpp
@@ -6,6 +6,8 @@
#include "ace/Log_Record.h"
#include "ace/Get_Opt.h"
+#include <iostream>
+
namespace DAnCE
{
NDDS_Log_Backend::NDDS_Log_Backend (void)
@@ -26,6 +28,7 @@ namespace DAnCE
int
NDDS_Log_Backend::init (int argc, ACE_TCHAR **argv)
{
+ std::cerr << "init\n";
ACE_Get_Opt opts (argc, argv, ACE_TEXT ("t:d:"), 1, 0,
ACE_Get_Opt::RETURN_IN_ORDER);
opts.long_option (ACE_TEXT ("topic"), 't', ACE_Get_Opt::ARG_REQUIRED);
@@ -51,8 +54,8 @@ namespace DAnCE
return -1;
}
- return 0;
}
+ return 0;
}
int
@@ -88,6 +91,8 @@ namespace DAnCE
int
NDDS_Log_Backend::configure_dds (void)
{
+ std::cerr << "configuring dds\n";
+
this->participant_ = DDSDomainParticipantFactory::get_instance ()->
create_participant (this->domain_,
DDS_PARTICIPANT_QOS_DEFAULT,
@@ -101,7 +106,8 @@ namespace DAnCE
}
DDS_ReturnCode_t retval;
-
+
+ std::cerr << "participant\n";
retval = Log_RecordTypeSupport::register_type (this->participant_,
Log_RecordTypeSupport::get_type_name ());
@@ -111,6 +117,7 @@ namespace DAnCE
(void) this->close ();
return -1;
}
+ std::cerr << "type\n";
this->topic_ = this->participant_->create_topic (this->topic_name_.c_str (),
Log_RecordTypeSupport::get_type_name (),
@@ -125,6 +132,8 @@ namespace DAnCE
return -1;
}
+ std::cerr << "topic\n";
+
this->publisher_ = this->participant_->create_publisher (DDS_PUBLISHER_QOS_DEFAULT,
0,
DDS_STATUS_MASK_NONE);
@@ -135,6 +144,7 @@ namespace DAnCE
this->close ();
return -1;
}
+ std::cerr << "publisher\n";
this->datawriter_ = this->publisher_->create_datawriter (this->topic_,
DDS_DATAWRITER_QOS_DEFAULT,
@@ -147,6 +157,7 @@ namespace DAnCE
return -1;
}
+ std::cerr << "datawriter\n";
log_record_writer_ = Log_RecordDataWriter::narrow (this->datawriter_);
return 0;
@@ -160,6 +171,7 @@ namespace DAnCE
ACE_ERROR ((LM_ERROR, ACE_TEXT ("NDDS_Log_Backend::open - unable to get configuration\n")));
return -1;
}
+ std::cerr << "got configuration\n";
if (this->configure_dds () != 0)
{
@@ -167,6 +179,8 @@ namespace DAnCE
return -1;
}
+ std::cerr << "configured dds\n";
+
return 0;
}
@@ -179,6 +193,7 @@ namespace DAnCE
int
NDDS_Log_Backend::close (void)
{
+ std::cerr << "closing\n";
if (this->participant_ != 0)
{
DDS_ReturnCode_t retval =
@@ -209,6 +224,7 @@ namespace DAnCE
ssize_t
NDDS_Log_Backend::log (ACE_Log_Record &log_record)
{
+ std::cerr << "logging\n";
Log_Record *instance (0);
instance = Log_RecordTypeSupport::create_data_ex (DDS_BOOLEAN_FALSE);