L:/channel/cvm/examples/cvm_instance/tasks/pong/PongTask.cpp

Go to the documentation of this file.

// Copyright (c) 2005, 2006 Yigong Liu
// Permission to use, copy, modify, distribute and sell this software for any 
//     purpose is hereby granted without fee, provided that the above copyright 
//     notice appear in all copies and that both that copyright notice and this 
//     permission notice appear in supporting documentation.
// The author makes no representations about the 
//     suitability of this software for any purpose. It is provided "as is" 
//     without express or implied warranty.

#include <PongTask.h>
#include <PongTask_export.h>

//----------------------------------------------
// the following 3 methods should be overwritten
// to implement application logic
//----------------------------------------------

//app hooks for resource reservation & cleanup
Status Pong_Task::prepare(void)
{  
  my_port()->publish_msg(PING_MSG, SCOPE_GLOBAL);
  //subscribe msg
  my_port()->subscribe_msg(PONG_MSG);

  return SUCCESS;
}

Status Pong_Task::cleanup(void)
{
  ACE_DEBUG ((LM_DEBUG,
              "(%t) Pong_Task::cleanup(void)...\n"));
  my_port()->unpublish_msg(PING_MSG);
  //unsubscribe msg 
  my_port()->unsubscribe_msg(PONG_MSG);
  return SUCCESS;
}


int Pong_Task::work() {
  ACE_DEBUG ((LM_DEBUG,
              "(%t) %s pong_task coming up ...\n", my_name().c_str()));
  Msg *msg;
  Ping_Pong_Msg *sm, *rsp;
  int next_count = 1;

  //wait for sys ready
  ACE_OS::sleep(ACE_Time_Value(1));

 //start ping-pong
  rsp = new Ping_Pong_Msg();
  rsp->count = 0;
  strcpy(rsp->data,"Lets ping pong...");
  rsp->len = strlen("Lets ping pong...");
  Msg *m = new Msg(PING_MSG, rsp);
  my_port()->send_msg(m);
  ACE_DEBUG ((LM_DEBUG, "pong sends one msg..."));

  for(;;) {
    if(my_port()->recv_msg(msg) == SUCCESS) {
      //handle_msg(msg);
      if(msg->type == PONG_MSG) {
        sm = (Ping_Pong_Msg *)msg->data();
        sm->data[sm->len-1] = '\0';

        if (next_count != sm->count)
          {
            delete sm;
          }
        else 
          {
            ACE_DEBUG ((LM_DEBUG, "(%t) (%s) receive the Pong_Pong_Msg[%d]: \n%s\n",
                        my_name().c_str(),sm->count,sm->data));

            //reuse sm
            sm->len = sm->len;
            sm->count = sm->count+1;
            if(sm->count > 4096) rsp->count=0;
            next_count = sm->count + 1;

            ACE_OS::sleep(ACE_Time_Value(1));

            Msg *m = new Msg(PING_MSG, sm);
            my_port()->send_msg(m);
          }
      }
    } else {
      //handle_error();
      break;
    }
  }

  ACE_DEBUG ((LM_DEBUG,
              "(%t) %s pong_task exits...\n", my_name().c_str()));

  return 0;
}

ACE_FACTORY_DEFINE (PongTask, Pong_Task)

---