src/robofsm/robot_orte.c

   1 /**
   2  * @file robot_orte.c
   3  * @date 2008-2010
   4  *
   5  * @brief Module providing communication through ORTE
   6  */
   7
   8 /*
   9  * robot_orte.c                 08/04/21
  10  *
  11  * Robot's orte stuffs.
  12  *
  13  * Copyright: (c) 2008-2010 CTU Dragons
  14  *            CTU FEE - Department of Control Engineering
  15  * License: GNU GPL v.2
  16  */
  17
  18 #include <orte.h>
  19 #include <roboorte_robottype.h>
  20 #include "robodata.h"
  21 #include <robot.h>
  22 #include <movehelper.h>
  23 #include <math.h>
  24 #include <robomath.h>
  25 #include "map_handling.h"
  26 #include "match-timing.h"
  27 #include <string.h>
  28 #include <can_msg_def.h>
  29 #include <actuators.h>
  30 #include <ul_log.h>
  31 #include <lidar_params.h>
  32
  33 UL_LOG_CUST(ulogd_robot_orte); /* Log domain name = ulogd + name of the file */
  34
  35 #ifdef ORTE_DEBUG
  36    #define DBG(format, ...) ul_logdeb(format, ##__VA_ARGS__)
  37 #else
  38    #define DBG(format, ...)
  39 #endif
  40
  41 /*****FIXME:*****/
  42 extern sem_t measurement_received;
  43
  44 /* ----------------------------------------------------------------------
  45  * PUBLISHER CALLBACKS - GENERIC
  46  * ---------------------------------------------------------------------- */
  47
  48 void send_ref_pos_cb(const ORTESendInfo *info, void *vinstance,
  49                         void *sendCallBackParam)
  50 {
  51         struct robot_pos_type *instance = (struct robot_pos_type *)vinstance;
  52
  53         ROBOT_LOCK(ref_pos);
  54         *instance = robot.ref_pos;
  55         ROBOT_UNLOCK(ref_pos);
  56 }
  57
  58 void send_est_pos_odo_cb(const ORTESendInfo *info, void *vinstance,
  59                         void *sendCallBackParam)
  60 {
  61         struct robot_pos_type *instance = (struct robot_pos_type *)vinstance;
  62
  63         ROBOT_LOCK(est_pos_odo);
  64         *instance = robot.est_pos_odo;
  65         ROBOT_UNLOCK(est_pos_odo);
  66 }
  67
  68 void send_est_pos_indep_odo_cb(const ORTESendInfo *info, void *vinstance,
  69                         void *sendCallBackParam)
  70 {
  71         struct robot_pos_type *instance = (struct robot_pos_type *)vinstance;
  72
  73         ROBOT_LOCK(est_pos_indep_odo);
  74         *instance = robot.est_pos_indep_odo;
  75         ROBOT_UNLOCK(est_pos_indep_odo);
  76 }
  77
  78 static void send_est_pos_best_cb(const ORTESendInfo *info, void *vinstance,
  79                         void *sendCallBackParam)
  80 {
  81         struct robot_pos_type *instance = (struct robot_pos_type *)vinstance;
  82
  83         robot_get_est_pos(&instance->x, &instance->y, &instance->phi);
  84 }
  85
  86 void send_dummy_cb(const ORTESendInfo *info, void *vinstance,
  87                         void *sendCallBackParam)
  88 {
  89 }
  90
  91 void send_match_time_cb(const ORTESendInfo *info, void *vinstance,
  92                         void *sendCallBackParam)
  93 {
  94         struct match_time_type *instance = (struct match_time_type *)vinstance;
  95
  96         if (robot.start_state == POWER_ON || robot.start_state == START_PLUGGED_IN) {
  97                 instance->time = 600;
  98         } else {
  99                 instance->time = 600 - robot_current_time();
 100         }
 101 }
 102 /* ----------------------------------------------------------------------
 103  * SUBSCRIBER CALLBACKS - GENERIC
 104  * ---------------------------------------------------------------------- */
 105 void rcv_odo_data_cb(const ORTERecvInfo *info, void *vinstance,
 106                         void *recvCallBackParam)
 107 {
 108         struct odo_data_type *instance = (struct odo_data_type *)vinstance;
 109         double dleft, dright, dtang, dphi;
 110         static bool first_run = true;
 111         /* spocitat prevodovy pomer */
 112         const double n = (double)(1.0 / 1.0);
 113
 114         /* vzdalenost na pulz IRC */
 115         const double c = (M_PI*2*ODOMETRY_WHEEL_RADIUS_M) / (n * 4*4096.0);
 116
 117         switch (info->status) {
 118                 case NEW_DATA:
 119                         if (first_run) {
 120                                 ROBOT_LOCK(odo_data);
 121                                 robot.odo_data = *instance;
 122                                 ROBOT_UNLOCK(odo_data);
 123                                 first_run = false;
 124                                 break;
 125                         }
 126
 127                         dleft = ((robot.odo_data.left - instance->left) >> 8) * c * robot.odo_cal_a;    // TODO >> 8 ?
 128                         dright = ((instance->right - robot.odo_data.right) >> 8) * c * robot.odo_cal_b;
 129
 130                         dtang = (dleft + dright) / 2.0;
 131                         dphi = (dright - dleft) / (2.0*ODOMETRY_ROTATION_RADIUS_M);
 132
 133                         ROBOT_LOCK(est_pos_indep_odo);
 134                         robot.odo_distance_a +=dleft;
 135                         robot.odo_distance_b +=dright;
 136                         double a = robot.est_pos_indep_odo.phi;
 137                         robot.est_pos_indep_odo.x += dtang*cos(a);
 138                         robot.est_pos_indep_odo.y += dtang*sin(a);
 139                         robot.est_pos_indep_odo.phi += dphi;
 140                         ROBOT_UNLOCK(est_pos_indep_odo);
 141
 142                         ROBOT_LOCK(odo_data);
 143                         robot.odo_data = *instance;
 144                         ROBOT_UNLOCK(odo_data);
 145
 146                         robot.indep_odometry_works = true;
 147
 148                         /* wake up motion-control/thread_trajectory_follower */
 149                         sem_post(&measurement_received);
 150
 151                         //robot.hw_status[COMPONENT_ODO] = STATUS_OK;
 152                         break;
 153                 case DEADLINE:
 154                         robot.indep_odometry_works = false;
 155                         //robot.hw_status[COMPONENT_ODO] = STATUS_FAILED;
 156                         DBG("ORTE deadline occurred - odo_data receive\n");
 157                         break;
 158         }
 159 }
 160
 161 void rcv_motion_irc_cb(const ORTERecvInfo *info, void *vinstance,
 162                         void *recvCallBackParam)
 163 {
 164         struct motion_irc_type *instance = (struct motion_irc_type *)vinstance;
 165         double dleft, dright, dtang, dphi;
 166         static bool first_run = true;
 167         /* spocitat prevodovy pomer */
 168         const double n = (double)(ROBOT_MOTOR_GEARBOX_RATIO / 1.0);
 169
 170         /* vzdalenost na pulz IRC */
 171         const double c = (M_PI*2*ROBOT_WHEEL_RADIUS_M) / (n * 4*ROBOT_MOTOR_IRC_RESOLUTION);
 172         switch (info->status) {
 173                 case NEW_DATA:
 174                         if (first_run) {
 175                                 ROBOT_LOCK(motion_irc);
 176                                 robot.motion_irc = *instance;
 177                                 ROBOT_UNLOCK(motion_irc);
 178                                 first_run = false;
 179                                 break;
 180                         }
 181
 182
 183                         /* FIXME maybe it is not correct to do this nasty hack here (switch dleft and dright),
 184                         what is the right solution?
 185                         This was neccessary to view motor odometry correctly in robomon. */
 186                         dright = ((robot.motion_irc.left - instance->left) >> 8) * c;
 187                         dleft = ((instance->right - robot.motion_irc.right) >> 8) * c;
 188
 189                         dtang = (dleft + dright) / 2.0;
 190                         dphi = (dright - dleft) / (2.0*ROBOT_ROTATION_RADIUS_M);
 191
 192                         ROBOT_LOCK(est_pos_odo);
 193                         double a = robot.est_pos_odo.phi;
 194                         robot.est_pos_odo.x += dtang*cos(a);
 195                         robot.est_pos_odo.y += dtang*sin(a);
 196                         robot.est_pos_odo.phi += dphi;
 197                         ROBOT_UNLOCK(est_pos_odo);
 198
 199                         /* locking should not be needed, but... */
 200                         ROBOT_LOCK(motion_irc);
 201                         robot.motion_irc = *instance;
 202                         robot.motion_irc_received = 1;
 203                         ROBOT_UNLOCK(motion_irc);
 204
 205                         robot.odometry_works = true;
 206
 207                         robot.status[COMPONENT_MOTOR] = STATUS_OK;
 208                         break;
 209                 case DEADLINE:
 210                         robot.odometry_works = false;
 211                         robot.status[COMPONENT_MOTOR] = STATUS_FAILED;
 212                         DBG("ORTE deadline occurred - motion_irc receive\n");
 213                         break;
 214         }
 215 }
 216
 217 void rcv_motion_speed_cb(const ORTERecvInfo *info, void *vinstance,
 218                         void *recvCallBackParam)
 219 {
 220         switch (info->status) {
 221                 case NEW_DATA:
 222                         break;
 223                 case DEADLINE:
 224                         DBG("ORTE deadline occurred - motion_speed receive\n");
 225                         break;
 226         }
 227 }
 228
 229 void rcv_motion_status_cb(const ORTERecvInfo *info, void *vinstance,
 230                         void *recvCallBackParam)
 231 {
 232         switch (info->status) {
 233                 case NEW_DATA:
 234                         break;
 235                 case DEADLINE:
 236                         DBG("ORTE deadline occurred - motion_status receive\n");
 237                         break;
 238         }
 239 }
 240
 241 void rcv_pwr_voltage_cb(const ORTERecvInfo *info, void *vinstance,
 242                         void *recvCallBackParam)
 243 {
 244         switch (info->status) {
 245                 case NEW_DATA:
 246                         robot.status[COMPONENT_POWER]=STATUS_OK;
 247                         break;
 248                 case DEADLINE:
 249                         robot.status[COMPONENT_POWER]=STATUS_FAILED;
 250                         DBG("ORTE deadline occurred - pwr_voltage receive\n");
 251                         break;
 252         }
 253 }
 254
 255 void rcv_pwr_ctrl_cb(const ORTERecvInfo *info, void *vinstance,
 256                         void *recvCallBackParam)
 257 {
 258         switch (info->status) {
 259                 case NEW_DATA:
 260                         break;
 261                 case DEADLINE:
 262                         DBG("ORTE deadline occurred - pwr_ctrl receive\n");
 263                         break;
 264         }
 265 }
 266
 267 void rcv_robot_cmd_cb(const ORTERecvInfo *info, void *vinstance,
 268                         void *recvCallBackParam)
 269 {
 270         struct robot_cmd_type *instance = (struct robot_cmd_type *)vinstance;
 271         static struct robot_cmd_type last_instance;
 272
 273         switch (info->status) {
 274                 case NEW_DATA:
 275                         /* Stupid way of controlling the robot by
 276                          * pluggin in and out start connector. */
 277                         switch (robot.start_state) {
 278                                 case POWER_ON:
 279                                         if (!instance->start_condition) {
 280                                                 robot.status[COMPONENT_START] = STATUS_WARNING;
 281                                                 robot.start_state = START_PLUGGED_IN;
 282                                                 ul_logmsg("START_PLUGGED_IN\n");
 283                                         }
 284                                         break;
 285
 286                                 case START_PLUGGED_IN:
 287                                         robot.status[COMPONENT_START] = STATUS_OK;
 288                                         /* Competition starts when plugged out */
 289                                         if (instance->start_condition) {
 290                                                 FSM_SIGNAL(MAIN, EV_START, NULL);
 291                                                 robot.start_state = COMPETITION_STARTED;
 292                                                 ul_logmsg("STARTED\n");
 293                                         }
 294                                         break;
 295
 296                                 case COMPETITION_STARTED: {
 297                                         /* Subsequent plug-in stops the robot */
 298                                         static int num = 0;
 299                                         if (!instance->start_condition) {
 300                                                 robot.status[COMPONENT_START] = STATUS_WARNING;
 301                                                 if (++num == 10)
 302                                                         robot_exit();
 303                                         }
 304                                         break;
 305                                 }
 306                         }
 307                         last_instance = *instance;
 308                         break;
 309                 case DEADLINE:
 310                         robot.status[COMPONENT_START] = STATUS_FAILED;
 311                         DBG("ORTE deadline occurred - robot_cmd receive\n");
 312                         break;
 313         }
 314 }
 315
 316 void rcv_hokuyo_scan_cb(const ORTERecvInfo *info, void *vinstance,
 317                         void *recvCallBackParam)
 318 {
 319         struct lidar_scan_type *instance = (struct lidar_scan_type *)vinstance;
 320
 321         switch (info->status) {
 322                 case NEW_DATA: {
 323                         ROBOT_LOCK(hokuyo);
 324                         robot.hokuyo = *instance;
 325                         robot.status[COMPONENT_HOKUYO] = STATUS_OK;
 326                         ROBOT_UNLOCK(hokuyo);
 327                         if(!robot.ignore_hokuyo)
 328                         {
 329                                 //update_map_lidar(&hokuyo_params, instance);
 330                         }
 331                         break;
 332                 }
 333                 case DEADLINE:
 334                         robot.status[COMPONENT_HOKUYO] = STATUS_FAILED;
 335                         //system("killall -9 hokuyo");
 336                         DBG("%s: ORTE deadline occurred\n", __FUNCTION__);
 337                         break;
 338         }
 339 }
 340
 341 void rcv_sick_scan_cb(const ORTERecvInfo *info, void *vinstance,
 342                         void *recvCallBackParam)
 343 {
 344         struct lidar_scan_type *instance = (struct lidar_scan_type *)vinstance;
 345
 346         switch (info->status) {
 347                 case NEW_DATA: {
 348                         ROBOT_LOCK(sick);
 349                         robot.sick = *instance;
 350                         robot.status[COMPONENT_SICK] = STATUS_OK;
 351                         ROBOT_UNLOCK(sick);
 352                         if(!robot.ignore_sick)
 353                         {
 354                                 update_map_lidar(&sick_params, instance);
 355                         }
 356                         break;
 357                 }
 358                 case DEADLINE:
 359                         robot.status[COMPONENT_SICK] = STATUS_FAILED;
 360                         DBG("%s: ORTE deadline occurred\n", __FUNCTION__);
 361                         break;
 362         }
 363 }
 364
 365 void rcv_camera_result_cb(const ORTERecvInfo *info, void *vinstance,
 366                         void *recvCallBackParam)
 367 {
 368         struct camera_result_type *instance = (struct camera_result_type *)vinstance;
 369         static bool last_response = false;
 370
 371         switch (info->status) {
 372                 case NEW_DATA: {
 373                         if (instance->data_valid && instance->data_valid != last_response) {
 374                                 ROBOT_LOCK(camera_result);
 375                                 robot.target_valid = instance->target_valid;
 376                                 robot.target_ang = instance->angle_deg;
 377                                 ROBOT_UNLOCK(camera_result);
 378                                 FSM_SIGNAL(MAIN, EV_CAMERA_DONE, NULL);
 379                         }
 380                         last_response = instance->data_valid;
 381                         break;
 382                 }
 383                 case DEADLINE:
 384                         if (robot.orte.camera_control.on) {
 385                                 robot.status[COMPONENT_CAMERA] = STATUS_FAILED;
 386                         }
 387
 388                         DBG("%s: ORTE deadline occurred\n", __FUNCTION__);
 389                         break;
 390         }
 391 }
 392 /* ----------------------------------------------------------------------
 393  * SUBSCRIBER CALLBACKS - EB2008
 394  * ---------------------------------------------------------------------- */
 395
 396 void rcv_jaws_status_cb(const ORTERecvInfo *info, void *vinstance,
 397                             void *recvCallBackParam)
 398 {
 399         struct jaws_status_type *instance = (struct jaws_status_type *)vinstance;
 400         static int last_response_left = 0;
 401         static int last_response_right = 0;
 402         switch (info->status) {
 403                 case NEW_DATA:
 404                         // new data arrived and requested position equals actual position
 405                         if (instance->flags.left == 0 &&
 406                             instance->flags.right == 0)
 407                                 robot.status[COMPONENT_JAWS] = STATUS_OK;
 408                         else
 409                                 robot.status[COMPONENT_JAWS] = STATUS_WARNING;
 410
 411                         if (instance->response.left != last_response_left &&
 412                             instance->response.right != last_response_right &&
 413                             instance->response.left == act_jaw_left_get_last_reqest() &&
 414                             instance->response.left == act_jaw_right_get_last_reqest())
 415                                 FSM_SIGNAL(MAIN, EV_JAWS_DONE, NULL);
 416
 417                         last_response_left = instance->response.left;
 418                         last_response_right = instance->response.right;
 419                         break;
 420                 case DEADLINE:
 421                         robot.status[COMPONENT_JAWS] = STATUS_FAILED;
 422                         DBG("ORTE deadline occurred - actuator_status receive\n");
 423                         break;
 424         }
 425 }
 426
 427 void rcv_lift_status_cb(const ORTERecvInfo *info, void *vinstance,
 428                             void *recvCallBackParam)
 429 {
 430         struct lift_status_type *instance = (struct lift_status_type *)vinstance;
 431         static int last_response = 0;
 432         switch (info->status) {
 433                 case NEW_DATA:
 434                         // new data arrived and requested position equals actual position
 435                         if (instance->flags == 0)
 436                                 robot.status[COMPONENT_LIFT] = STATUS_OK;
 437                         else
 438                                 robot.status[COMPONENT_LIFT] = STATUS_WARNING;
 439
 440                         if (instance->response != last_response &&
 441                             instance->response == act_lift_get_last_reqest())
 442                                 FSM_SIGNAL(MAIN, EV_LIFT_DONE, NULL);
 443                         last_response = instance->response;
 444                         break;
 445                 case DEADLINE:
 446                         robot.status[COMPONENT_LIFT] = STATUS_FAILED;
 447                         DBG("ORTE deadline occurred - actuator_status receive\n");
 448                         break;
 449         }
 450 }
 451
 452 void rcv_robot_switches_cb(const ORTERecvInfo *info, void *vinstance,
 453                            void *recvCallBackParam)
 454 {
 455         struct robot_switches_type *instance = (struct robot_switches_type *)vinstance;
 456         static bool last_strategy;
 457         switch (info->status) {
 458                 case NEW_DATA:
 459                         robot.team_color = instance->team_color;
 460
 461                         if (!last_strategy && instance->strategy) {
 462                                         /* strategy switching */
 463                                         FSM_SIGNAL(MAIN, EV_SWITCH_STRATEGY, NULL);
 464                         }
 465                         last_strategy = instance->strategy;
 466                         break;
 467                 case DEADLINE:
 468                         break;
 469         }
 470 }
 471
 472 void rcv_robot_bumpers_cb(const ORTERecvInfo *info, void *vinstance,
 473                            void *recvCallBackParam)
 474 {
 475         struct robot_bumpers_type *instance = (struct robot_bumpers_type *)vinstance;
 476         static bool last_left, last_right;
 477         switch (info->status) {
 478                 case NEW_DATA:
 479                         if (instance->bumper_right_across || instance->bumper_left_across || instance->bumper_rear_left || instance->bumper_rear_right)
 480                                 FSM_SIGNAL(MOTION, EV_OBSTACLE_BEHIND, NULL);
 481
 482                         if (instance->bumper_left || instance->bumper_right) {
 483                                 FSM_SIGNAL(MOTION, EV_OBSTACLE_SIDE, NULL);
 484                         }
 485                         break;
 486                 case DEADLINE:
 487                         break;
 488         }
 489 }
 490
 491 void rcv_cl_sensor_status_cb(const ORTERecvInfo *info, void *vinstance,
 492                            void *recvCallBackParam)
 493 {
 494         struct cl_sensor_status_type *instance = (struct cl_sensor_status_type *)vinstance;
 495         static bool last_pattern_match = 0;
 496         switch (info->status) {
 497                 case NEW_DATA:
 498                         if ((last_pattern_match != instance->pattern_match) && instance->pattern_match)
 499                                 FSM_SIGNAL(MAIN, EV_OMRON_DONE, NULL);
 500
 501                         last_pattern_match = instance->pattern_match;
 502                         break;
 503                 case DEADLINE:
 504                         break;
 505         }
 506 }
 507
 508 #define HIST_CNT 5
 509 #if 0
 510 static int cmp_double(const void *v1, const void *v2)
 511 {
 512         const double *d1 = v1, *const d2 = v2;
 513         if (d1 < d2)
 514                 return -1;
 515         else if (d1 > d2)
 516                 return +1;
 517         else
 518                 return 0;
 519 }
 520 #endif
 521
 522 int robot_init_orte()
 523 {
 524         int rv = 0;
 525
 526         robot.orte.strength = 20;
 527
 528         rv = robottype_roboorte_init(&robot.orte);
 529         if (rv)
 530                 return rv;
 531
 532         /* creating publishers */
 533         robottype_publisher_motion_speed_create(&robot.orte, NULL, &robot.orte);
 534         robottype_publisher_ref_pos_create(&robot.orte, send_ref_pos_cb, &robot.orte);
 535         robottype_publisher_est_pos_odo_create(&robot.orte, send_est_pos_odo_cb, &robot.orte);
 536         robottype_publisher_est_pos_indep_odo_create(&robot.orte, send_est_pos_indep_odo_cb, &robot.orte);
 537         robottype_publisher_est_pos_best_create(&robot.orte, send_est_pos_best_cb, &robot.orte);
 538         robottype_publisher_match_time_create(&robot.orte, send_match_time_cb, &robot.orte);
 539         //???robottype_publisher_pwr_ctrl_create(&robot.orte, NULL, &robot.orte);
 540
 541         // I didn't know what was the difference between the callback function pointer
 542         // being NULL and being set to pointer to empty send_dummy_cb function. The DIFFERENCE
 543         // IS CRUCIAL!
 544         //   - NULL: message is published only when OrtePublicationSend called
 545         //   - pointer to empty function: message is published periodically
 546         robottype_publisher_fsm_main_create(&robot.orte, send_dummy_cb, &robot.orte);
 547         robottype_publisher_fsm_act_create(&robot.orte, send_dummy_cb, &robot.orte);
 548         robottype_publisher_fsm_motion_create(&robot.orte, send_dummy_cb, &robot.orte);
 549         robottype_publisher_camera_control_create(&robot.orte, send_dummy_cb, &robot.orte);
 550         robottype_publisher_jaws_cmd_create(&robot.orte, send_dummy_cb, &robot.orte);
 551         robottype_publisher_lift_cmd_create(&robot.orte, send_dummy_cb, &robot.orte);
 552
 553         /* create generic subscribers */
 554         robottype_subscriber_odo_data_create(&robot.orte, rcv_odo_data_cb, &robot.orte);
 555         robottype_subscriber_motion_irc_create(&robot.orte, rcv_motion_irc_cb, &robot.orte);
 556         robottype_subscriber_motion_speed_create(&robot.orte, rcv_motion_speed_cb, &robot.orte);
 557         robottype_subscriber_motion_status_create(&robot.orte, rcv_motion_status_cb, &robot.orte);
 558         robottype_subscriber_pwr_voltage_create(&robot.orte, rcv_pwr_voltage_cb, &robot.orte);
 559         //robottype_subscriber_pwr_ctrl_create(&robot.orte, rcv_pwr_ctrl_cb, &robot.orte);
 560         robottype_subscriber_robot_cmd_create(&robot.orte, rcv_robot_cmd_cb, &robot.orte);
 561         robottype_subscriber_sick_scan_create(&robot.orte, rcv_sick_scan_cb, &robot.orte);
 562         robottype_subscriber_jaws_status_create(&robot.orte, rcv_jaws_status_cb, &robot.orte);
 563         robottype_subscriber_lift_status_create(&robot.orte, rcv_lift_status_cb, &robot.orte);
 564         robottype_subscriber_robot_switches_create(&robot.orte, rcv_robot_switches_cb, &robot.orte);
 565         robottype_subscriber_robot_bumpers_create(&robot.orte, rcv_robot_bumpers_cb, &robot.orte);
 566         robottype_subscriber_camera_result_create(&robot.orte, rcv_camera_result_cb, &robot.orte);
 567         robottype_subscriber_cl_sensor_status_create(&robot.orte, rcv_cl_sensor_status_cb, &robot.orte);
 568
 569         return rv;
 570 }
 571