Added some random variations in the start position to prevent inverse kinematics from getting stuck in a local minimum

src/rrrobot_ws/src/rrrobot/src/arm_controller_node.cpp

@@ -33,12 +33,15 @@
 #include <kdl/chainfksolverpos_recursive.hpp>
 #include <kdl/chainidsolver_recursive_newton_euler.hpp>
 
+#include <stdlib.h> /* srand, rand */
+#include <time.h>   /* time */
+#include <sstream>
+
 #include <cstdlib>
 #include <math.h>
 
 using namespace std;
 
-
 class ArmController
 {
 public:
@@ -50,6 +53,9 @@ public:
 
         arm_current_joint_states_.resize(arm->getChain()->getNrOfJoints(), 0.0);
 
+        /* initialize random seed: */
+        srand(time(NULL));
+
         // arm = std::move(arm_);
         // ROS_INFO("Arm size (in constructor): %d", arm->getChain()->getNrOfJoints());
         // arm_current_joint_states_ = KDL::JntArray(arm->getChain()->getNrOfJoints());
@@ -97,8 +103,10 @@ public:
         vector<double> positions;
 
         // Turn on suction
-        while (!gripper_control(true)) {
+        while (!gripper_control(true))
-            if (attempts == retry_attempts) {
+        {
+            if (attempts == retry_attempts)
+            {
                 ROS_ERROR("STEP 1: Suction failed, not going to target");
                 return;
             }
@@ -111,17 +119,20 @@ public:
 
         // Move arm to pickup item from conveyor belt
         attempts = 1;
-        positions = calc_joint_positions(target_pose.grab_location, above_conveyor);
+        if (calc_joint_positions(target_pose.grab_location, above_conveyor, positions))
-        send_joint_trajectory(positions, arm_action_phase::bin_to_belt);
+            send_joint_trajectory(positions, arm_action_phase::bin_to_belt);
 
         // Check if target has been reached
-        while(!have_reached_target(frame_to_pose(calc_end_effector_pose()), target_pose.grab_location)) {
+        while (!have_reached_target(frame_to_pose(calc_end_effector_pose()), target_pose.grab_location))
-            if (attempts == retry_attempts) {
+        {
+            if (attempts == retry_attempts)
+            {
                 ROS_ERROR("STEP 2: Did not reach target in allotted time");
                 return;
             }
 
-            send_joint_trajectory(positions, arm_action_phase::bin_to_belt);
+            if (calc_joint_positions(target_pose.grab_location, get_randomized_start_state(above_conveyor) /*target_pose.grab_location.position.y)*/, positions))
+                send_joint_trajectory(positions, arm_action_phase::bin_to_belt);
             attempts++;
         }
 
@@ -133,15 +144,16 @@ public:
         // Wait until object is attached
         while (!item_attached_)
         {
-            if (attempts == retry_attempts) {
+            if (attempts == retry_attempts)
+            {
                 ROS_ERROR("STEP 3: Could not pick up item");
                 return;
             }
 
             // If item is not able to attach, adjust z and try again
             target_location.position.z -= item_attach_z_adjustment; // meters
-            positions = calc_joint_positions(target_location, arm_current_joint_states_);
+            if (calc_joint_positions(target_location, arm_current_joint_states_, positions))
-            send_joint_trajectory(positions, arm_action_phase::item_pickup_adjustment);
+                send_joint_trajectory(positions, arm_action_phase::item_pickup_adjustment);
             attempts++;
         }
 
@@ -149,16 +161,40 @@ public:
 
         // Move item to desired position
         attempts = 1;
-        positions = calc_joint_positions(target_pose.drop_location, above_bins);
+        // if (calc_joint_positions(target_pose.drop_location, above_bins, positions))
-        send_joint_trajectory(positions, arm_action_phase::belt_to_bin);
+        //     send_joint_trajectory(positions, arm_action_phase::belt_to_bin);
+        KDL::Frame end_effector_pose;
+        if (target_pose.drop_location.position.y > 1.0)
+        {
+            positions = bin1;
+            KDL::JntArray pos(positions.size());
+            for (size_t idx = 0; idx < positions.size(); ++idx)
+            {
+                pos(idx) = positions[idx];
+            }
+            arm->calculateForwardKinematics(pos, end_effector_pose);
+        }
+        else
+        {
+            positions = bin2;
+            KDL::JntArray pos(positions.size());
+            for (size_t idx = 0; idx < positions.size(); ++idx)
+            {
+                pos(idx) = positions[idx];
+            }
+            arm->calculateForwardKinematics(pos, end_effector_pose);
+        }
 
         // Check if target has been reached
-        while(!have_reached_target(frame_to_pose(calc_end_effector_pose()), target_pose.drop_location)) {
+        while (!have_reached_target(frame_to_pose(calc_end_effector_pose()), frame_to_pose(end_effector_pose))) //target_pose.drop_location))
-            if (attempts == retry_attempts) {
+        {
+            if (attempts == retry_attempts)
+            {
                 ROS_ERROR("STEP 4: Did not reach target in allotted time");
                 return;
             }
 
+            // if (calc_joint_positions(target_pose.grab_location, get_randomized_start_state(above_bins) /*target_pose.drop_location.position.y)*/, positions))
             send_joint_trajectory(positions, arm_action_phase::belt_to_bin);
             attempts++;
         }
@@ -167,8 +203,10 @@ public:
 
         // Turn off suction
         attempts = 0;
-        while (!gripper_control(false)) {
+        while (!gripper_control(false))
-            if (attempts == retry_attempts) {
+        {
+            if (attempts == retry_attempts)
+            {
                 ROS_ERROR("STEP 5: Suction not turning off... ¯\\_(ツ)_/¯");
                 return;
             }
@@ -183,7 +221,8 @@ public:
         attempts = 0;
         while (item_attached_)
         {
-            if (attempts == retry_attempts) {
+            if (attempts == retry_attempts)
+            {
                 ROS_ERROR("STEP 6: Item not detaching.. ¯\\_(ツ)_/¯");
             }
 
@@ -202,7 +241,8 @@ private:
     ros::ServiceClient gripper_;
     vector<double> arm_current_joint_states_;
     ArmRepresentation *arm;
-    enum arm_action_phase {
+    enum arm_action_phase
+    {
         belt_to_bin,
         bin_to_belt,
         item_pickup_adjustment
@@ -211,10 +251,42 @@ private:
     int retry_attempts;
     double item_attach_z_adjustment;
     // Define intermediate joint positions
-    const vector<double> above_conveyor = {0, 0, -M_PI/2, M_PI/2, -M_PI/2, -M_PI/2, 0};
+    const vector<double> above_conveyor = {0, 0, -M_PI / 2, M_PI / 2, -M_PI / 2, -M_PI / 2, 0};
-    const vector<double> above_bins = {0, M_PI, -M_PI/2, M_PI/2, -M_PI/2, -M_PI/2, 0};
+    const vector<double> above_bins = {0, M_PI, -M_PI / 2, M_PI / 2, -M_PI / 2, -M_PI / 2, 0};
+    const vector<double> bin1 = {0.05, 0.0, -2.2, -2.2, -0.25, 1.5708, 0.0};
+    const vector<double> bin2 = {-0.7, 0.0, -2.2, -2.2, -0.25, 1.5708, 0.0};
 
-    vector<double> calc_joint_positions(const geometry_msgs::Pose &pose, const vector<double> &start_state)
+    vector<double> get_randomized_start_state(const vector<double> &preferred_state)
+    {
+        //int state_to_return = rand() % 2;
+
+        // if (state == 0)
+        //     return preferred_state;
+
+        vector<double> cur;
+        std::stringstream location;
+        location << "Random location: ";
+        // cur.push_back(y);
+        for (size_t pos = 0; pos < arm->getChain()->getNrOfJoints(); ++pos)
+        {
+            int val = rand() % 2;
+            double diff = 0;
+            if (val == 1)
+                diff = -0.1;
+            else
+                diff = 0.1;
+            // double val = (rand() % 70) / 100.0;
+            cur.push_back(preferred_state[pos] + diff);
+            location << cur[pos] << " ";
+        }
+
+        location << '\n';
+        ROS_INFO(location.str().c_str());
+
+        return cur;
+    }
+
+    bool calc_joint_positions(const geometry_msgs::Pose &pose, const vector<double> &start_state, vector<double> &positions)
     {
         // KDL::JntArray cur_configuration(arm->getChain()->getNrOfJoints()); // = arm_current_joint_states_;
         // KDL::SetToZero(cur_configuration);
@@ -235,13 +307,20 @@ private:
         int nbr_joints = arm->getChain()->getNrOfJoints();
         Eigen::VectorXd mat = final_joint_configuration.data;
         // cout << mat << endl;
-        vector<double> positions;
+        positions.clear();
+        // vector<double> positions;
+        std::stringstream pos_str;
+        pos_str << "Calculated joint positions: ";
         for (size_t idx = 0; idx < arm->getChain()->getNrOfJoints(); ++idx)
         {
             positions.push_back(mat[idx]);
+            pos_str << mat[idx] << " ";
         }
+        pos_str << '\n';
 
-        return positions;
+        ROS_INFO(pos_str.str().c_str());
+
+        return (error_code == 0);
     }
 
     KDL::Frame calc_end_effector_pose()
@@ -252,7 +331,8 @@ private:
         KDL::JntArray joint_positions(num_joints);
 
         // Copy current joint states values into JntArray
-        for (int i = 0; i < num_joints; ++i) {
+        for (int i = 0; i < num_joints; ++i)
+        {
             joint_positions(i) = arm_current_joint_states_[i];
         }
 
@@ -319,15 +399,20 @@ private:
         // Create points in the trajectory
         msg.points.resize(num_points);
 
-        for (int i = 0; i < num_points; ++i) {
+        for (int i = 0; i < num_points; ++i)
-            if (i == 0) {
+        {
-                if (phase == arm_action_phase::belt_to_bin) {
+            if (i == 0)
+            {
+                if (phase == arm_action_phase::belt_to_bin)
+                {
                     msg.points[i].positions = above_conveyor;
                 }
-                else if (phase == arm_action_phase::bin_to_belt) {
+                else if (phase == arm_action_phase::bin_to_belt)
+                {
                     msg.points[i].positions = above_bins;
                 }
-                else if (phase == arm_action_phase::item_pickup_adjustment) {
+                else if (phase == arm_action_phase::item_pickup_adjustment)
+                {
                     num_points = 1;
                     msg.points.resize(num_points);
                     msg.points[i].positions = target;
@@ -335,28 +420,32 @@ private:
                     break;
                 }
 
-                msg.points[i].time_from_start = ros::Duration((i+1)*time_per_step);
+                msg.points[i].time_from_start = ros::Duration((i + 1) * time_per_step);
             }
-            else if (i == 1) {
+            else if (i == 1)
-                if (phase == arm_action_phase::belt_to_bin) {
+            {
+                if (phase == arm_action_phase::belt_to_bin)
+                {
                     msg.points[i].positions = above_bins;
                 }
-                else if (phase == arm_action_phase::bin_to_belt) {
+                else if (phase == arm_action_phase::bin_to_belt)
+                {
                     msg.points[i].positions = above_conveyor;
                 }
 
-                msg.points[i].time_from_start = ros::Duration((i+1)*time_per_step);
+                msg.points[i].time_from_start = ros::Duration((i + 1) * time_per_step);
             }
-            else if (i == (num_points - 1)) {
+            else if (i == (num_points - 1))
+            {
                 msg.points[i].positions = target;
-                msg.points[i].time_from_start = ros::Duration((i+1)*time_per_step);
+                msg.points[i].time_from_start = ros::Duration((i + 1) * time_per_step);
             }
         }
 
         arm_joint_trajectory_publisher_.publish(msg);
 
         // Wait to reach target
-        ros::Duration((num_points+1)*time_per_step).sleep();
+        ros::Duration((num_points + 1) * time_per_step).sleep();
     }
 
     bool gripper_control(bool state)
@@ -366,7 +455,8 @@ private:
 
         bool success = gripper_.call(srv);
 
-        if(!success) {
+        if (!success)
+        {
             ROS_ERROR("Could not enable gripper");
         }
 
@@ -415,7 +505,8 @@ private:
             return false;
         }
 
-        if (qw_err > rot_thresh) {
+        if (qw_err > rot_thresh)
+        {
             return false;
         }
 

src/rrrobot_ws/src/rrrobot/src/image_display.py

@@ -0,0 +1,21 @@
+#!/usr/bin/env python
+import rospy
+from std_msgs.msg import String
+import matplotlib.pyplot as plt
+import matplotlib.image as mpimg
+
+def callback(data):
+    print("IMAGE DISPLAY CALLBACK")
+    file = data.data
+
+    img = mpimg.imread(file)
+    imgplot = plt.imshow(img)
+    plt.show()
+
+def listener():
+    rospy.init_node('image_display', anonymous=False)
+    rospy.Subscriber("/current_image", String, callback)
+    rospy.spin()
+
+if __name__ == '__main__':
+    listener()

src/rrrobot_ws/src/rrrobot/src/rrrobot_node.cpp

@@ -85,7 +85,7 @@ public:
 		{
 			current_robot_state &= ~RobotState::WAITING_FOR_CLASSIFICATION;
 		}
-		else
+		else if ((current_robot_state & RobotState::MOVING_ARM) == 0x0)
 		{
 			current_robot_state = RobotState::MOVING_ARM;
 
@@ -133,7 +133,7 @@ public:
 		{
 			current_robot_state &= ~RobotState::WAITING_FOR_GRAB_LOCATION;
 		}
-		else
+		else if ((current_robot_state & RobotState::MOVING_ARM) == 0x0)
 		{
 			current_robot_state = RobotState::MOVING_ARM;
 
@@ -172,10 +172,12 @@ private:
 	{
 		Position pos;
 
-		if(type == "trash") {
+		if (type == "trash")
+		{
 			pos = trash_bin;
 		}
-		else {
+		else
+		{
 			pos = recycle_bin;
 		}