Changeset 19 for trunk/extremum_seeking/esc_ros/src
- Timestamp:
- 01/03/13 15:32:03 (12 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/extremum_seeking/esc_ros/src/esc_ros.cpp
r11 r19 23 23 n_ = new ros::NodeHandle(); 24 24 25 reset(); 26 enabled_ = true; 25 27 esc_ = esc; 28 26 29 27 30 if (!n_->getParam("period", period_)){ … … 52 55 } 53 56 54 initialized_ = true; 55 first_obj_val_received_ = false; 56 57 sub_enable_ = n_->subscribe("enable", 1, &ESCROS::enableCallback, this); 58 pub_stopped_ = n_->advertise<std_msgs::Empty>("stopping_conditions_met",1); 57 59 } 58 60 … … 65 67 if(!first_obj_val_received_) 66 68 first_obj_val_received_ = true; 67 68 69 } 69 70 … … 76 77 } 77 78 79 void ESCROS::reset(){ 80 81 initialized_ = true; 82 first_obj_val_received_ = false; 83 reference_zeroed_ = false; 84 opt_dim_ = 0; 85 } 86 87 void ESCROS::enableCallback(std_msgs::Bool msg) 88 { 89 if (msg.data){ 90 reset(); 91 esc_->reset(); 92 enabled_ = true; 93 ROS_INFO("[esc_ros]: ESC enabled."); 94 } 95 else 96 enabled_ = false; 97 } 98 78 99 void ESCROS::step() 79 100 { … … 81 102 if(initialized_){ 82 103 if(first_obj_val_received_){ 83 std::vector<double> out; 84 if(esc_->getInputType() == esc_->inputValue) 85 out = esc_->step(obj_val_); 86 else if (esc_->getInputType() == esc_->inputStateValue) 87 out = esc_->step(state_vec_,obj_val_); 88 else 89 ROS_WARN("Invalid input type for the extremum seeking controller. The step function will not be executed."); 104 if(enabled_){ 105 std::vector<double> out; 106 if(esc_->getInputType() == esc_->inputValue) 107 out = esc_->step(obj_val_); 108 else if (esc_->getInputType() == esc_->inputStateValue) 109 out = esc_->step(state_vec_,obj_val_); 110 else 111 ROS_WARN("Invalid input type for the extremum seeking controller. The step function will not be executed."); 90 112 91 if (out.empty()){ 92 return; 113 if (out.empty()){ 114 return; 115 } 116 if(opt_dim_ == 0){ 117 opt_dim_ = out.size(); 118 } 119 120 std_msgs::Float32MultiArray msg; 121 for(size_t i=0;i<out.size();i++) 122 msg.data.push_back(out[i]); 123 pub_ref_.publish(msg); 124 125 if(monitor_){ 126 esc_ros::Monitors msg_monitor; 127 std::vector<double> values = esc_->monitor(); 128 129 msg_monitor.values.resize(values.size()); 130 for (size_t ii=0; ii < values.size(); ++ii) 131 msg_monitor.values[ii] = values[ii]; 132 msg_monitor.names = esc_->monitorNames(); 133 pub_monitor_.publish(msg_monitor); 134 } 135 } 136 else if(!reference_zeroed_){ 137 138 std_msgs::Float32MultiArray msg; 139 140 if (opt_dim_ != 0){ 141 msg.data.resize(opt_dim_); 142 143 for(size_t i = 0; i<opt_dim_; i++) 144 msg.data[i] = 0; 145 146 pub_ref_.publish(msg); 147 opt_dim_ = 0; 148 } 149 reference_zeroed_ = true; 150 93 151 } 94 152 95 std_msgs::Float32MultiArray msg; 96 for(size_t i=0;i<out.size();i++) 97 msg.data.push_back(out[i]); 98 pub_ref_.publish(msg); 153 } 99 154 100 if(monitor_){101 esc_ros::Monitors msg_monitor;102 std::vector<double> values = esc_->monitor();103 104 msg_monitor.values.resize(values.size());105 for (size_t ii=0; ii < values.size(); ++ii)106 msg_monitor.values[ii] = values[ii];107 msg_monitor.names = esc_->monitorNames();108 pub_monitor_.publish(msg_monitor);109 }110 }111 155 } 112 156 else … … 119 163 120 164 while (n_->ok()) { 165 if(esc_->isStoppingConditionsMet()){ 166 std_msgs::Empty msg_stopped; 167 pub_stopped_.publish(msg_stopped); 168 enabled_ = false; 169 } 170 step(); 121 171 ros::spinOnce(); 122 step();123 172 loop_rate.sleep(); 124 173 }
Note: See TracChangeset
for help on using the changeset viewer.