.. _program_listing_file__tmp_ws_src_SMACC2_smacc2_client_library_move_group_interface_client_include_move_group_interface_client_components_cp_tf_listener.hpp: Program Listing for File cp_tf_listener.hpp =========================================== |exhale_lsh| :ref:`Return to documentation for file ` (``/tmp/ws/src/SMACC2/smacc2_client_library/move_group_interface_client/include/move_group_interface_client/components/cp_tf_listener.hpp``) .. |exhale_lsh| unicode:: U+021B0 .. UPWARDS ARROW WITH TIP LEFTWARDS .. code-block:: cpp // Copyright 2021 RobosoftAI Inc. // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. /***************************************************************************************************************** * * Authors: Pablo Inigo Blasco, Brett Aldrich * *****************************************************************************************************************/ #pragma once #include #include #include #include #include #include #include namespace cl_move_base_z { struct TfPoseTrack { std::mutex mutex_; geometry_msgs::msg::PoseStamped pose_; std::string targetPoseFrame_; std::string referenceBaseFrame_; bool once = true; bool isInitialized = false; }; class CpTFListener : public smacc2::ISmaccComponent, public smacc2::ISmaccUpdatable { public: CpTFListener(); virtual void update() override { for (auto & poseTrack : poseTracks_) { tf2::Stamped transform; try { { std::lock_guard lock(listenerMutex_); tfListener_->lookupTransform( poseTrack->referenceBaseFrame_, poseTrack->targetPoseFrame_, rclcpp::Time(0), transform); } { std::lock_guard guard(m_mutex_); poseTrack->pose_.pose = tf2::toMsg(transform); poseTrack->pose_.header.stamp = transform.stamp_; poseTrack->pose_.header.frame_id = poseTrack->referenceBaseFrame_; poseTrack->isInitialized = true; } } catch (tf2::TransformException ex) { RCLCPP_ERROR_STREAM_THROTTLE( 1, "[Component pose] (getLogger(), " << poseFrameName_ << "/[" << referenceFrame_ << "] ) is failing on pose update : " << ex.what()); } } } void getLastTransform( std::string & targetPoseFrameName, std::string & referenceBaseFrame, geometry_msgs::msg::Pose & out) { } std::future waitForNextTransform( std::string & targetName, std::string & referenceBaseFrame) { tracks_ } private: static std::shared_ptr tfListener_; static std::mutex listenerMutex_; std::mutex m_mutex_; std::list> poseTracks_; }; } // namespace cl_move_base_z