Aufgrund von Umarbeiten des s3 Storage wird es in GitLab, in nächster Zeit, mögliche Performance-Einbußen geben. Näheres dazu unter: https://maintenance.itc.rwth-aachen.de/ticket/status/messages/43/show_ticket/6670

Commit be7c8197 authored by Markus Georg Bendel's avatar Markus Georg Bendel

Update Adapter, use bind-function

parent f4f835f7
Pipeline #152110 passed with stage
in 2 minutes and 30 seconds
...@@ -23,8 +23,8 @@ void SomeipAdapter_tests_a_compA::init(tests_a_compA *comp) ...@@ -23,8 +23,8 @@ void SomeipAdapter_tests_a_compA::init(tests_a_compA *comp)
//_clockSubscriber->register_availability_handler(SAMPLE_SERVICE_ID, SAMPLE_INSTANCE_ID, on_availability); //_clockSubscriber->register_availability_handler(SAMPLE_SERVICE_ID, SAMPLE_INSTANCE_ID, on_availability);
_clockSubscriber->request_service(SAMPLE_SERVICE_ID, SAMPLE_INSTANCE_ID); _clockSubscriber->request_service(SAMPLE_SERVICE_ID, SAMPLE_INSTANCE_ID);
_clockSubscriber->register_message_handler(SAMPLE_SERVICE_ID, SAMPLE_INSTANCE_ID, SAMPLE_METHOD_ID, on_message); _clockSubscriber->register_message_handler(SAMPLE_SERVICE_ID, SAMPLE_INSTANCE_ID, SAMPLE_METHOD_ID, std::bind(&SomeipAdapter_tests_a_compA::on_message, this, std::placeholders::_1));
//_clockSubscriber->register_message_handler(vsomeip::ANY_SERVICE, vsomeip::ANY_INSTANCE, vsomeip::ANY_METHOD, on_message); //_clockSubscriber->register_message_handler(vsomeip::ANY_SERVICE, vsomeip::ANY_INSTANCE, vsomeip::ANY_METHOD, std::bind(&SomeipAdapter_tests_a_compA::on_message, this, std::placeholders::_1));
std::set<vsomeip::eventgroup_t> its_groups; std::set<vsomeip::eventgroup_t> its_groups;
its_groups.insert(SAMPLE_EVENTGROUP_ID); its_groups.insert(SAMPLE_EVENTGROUP_ID);
...@@ -53,14 +53,23 @@ void SomeipAdapter_tests_a_compA::on_message(const std::shared_ptr<vsomeip::mess ...@@ -53,14 +53,23 @@ void SomeipAdapter_tests_a_compA::on_message(const std::shared_ptr<vsomeip::mess
std::cout << "SERVICE: Received message from [" std::cout << "SERVICE: Received message from ["
<< std::setw(4) << std::setfill('0') << std::hex << _request->get_client() << "/" << std::setw(4) << std::setfill('0') << std::hex << _request->get_client() << "/"
<< std::setw(4) << std::setfill('0') << std::hex << _request->get_session() << "]: " << std::setw(4) << std::setfill('0') << std::hex << _request->get_session() << "]: "
<< final << std::endl; << dataFromMessage << std::endl;
} }
void SomeipAdapter_tests_a_compA::publish_echoPublisher() void SomeipAdapter_tests_a_compA::publish_echoPublisher()
{ {
const vsomeip::byte_t its_data[] = { 0x10 }; //component->rosOut double d = component->rosOut;
payload = vsomeip::runtime::get()->create_payload(); uint8_t *byteArray = (uint8_t*)&d;
payload->set_data(its_data, sizeof(its_data));
vsomeip::byte_t *p;
p = byteArray;
std::shared_ptr< vsomeip::payload > payload = vsomeip::runtime::get()->create_payload(p,8);
//const vsomeip::byte_t its_data[] = component->rosOut; //component->rosOut
//std::shared_ptr< vsomeip::payload > payload = vsomeip::runtime::get()->create_payload();
//payload->set_data(its_data, sizeof(its_data));
std::set<vsomeip::eventgroup_t> its_groups; std::set<vsomeip::eventgroup_t> its_groups;
its_groups.insert(SAMPLE_EVENTGROUP_ID); its_groups.insert(SAMPLE_EVENTGROUP_ID);
......
...@@ -23,9 +23,7 @@ public: ...@@ -23,9 +23,7 @@ public:
void tick(); void tick();
static void on_message(const std::shared_ptr<vsomeip::message> &_response); void on_message(const std::shared_ptr<vsomeip::message> &_response);
static void on_availability(vsomeip::service_t _service, vsomeip::instance_t _instance, bool _is_available);
private: private:
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment