L:/channel/channel/examples/local_chan_conn/local_chan_conn.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 "ace/OS_main.h"
#include "ace/ACE.h"
#include "ace/Auto_Ptr.h"
#include "ace/OS_NS_string.h"
#include "ace/OS_NS_stdio.h"
#include "ace/Get_Opt.h"

#include <iostream>
#include <string>
#include <Channel.h>

using namespace std;
using namespace channel;

//------------------------------------------------------------------
// Message definitions :
// if we use int as IdType, define IdType as int
//
typedef string IdType;

//ids for channel using int as msg id/type 
/*
int PING_MSG=2000;
int PONG_MSG=2001;
int TEST_STRING_MSG=2002;
*/
//ids for channel using string as msg id/type 
std::string PING_MSG = "_PING_";
std::string PONG_MSG = "_PONG_";
std::string TEST_STRING_MSG = "_TEST_";

struct Test_String_Msg {
  enum { MAX_STR_LEN = 1024 };
  int len;
  char data[MAX_STR_LEN];
  Test_String_Msg() {
  }
};

//---------------------------------------------------------------
// Channel specialization
//
typedef Channel<IdType> Chan;
typedef Channel<IdType>::Msg ChanMsg;

//----------------------------------------------------------------
// Implementation
//
class My_Callback: public Chan::Callback {
public:
  My_Callback(Chan *c) : Chan::Callback(c) {}
  Status process(Chan::Msg *msg) {
    Test_String_Msg *sm = (Test_String_Msg *)msg->data_holder_->data_;
    ACE_DEBUG ((LM_DEBUG, "(%t) text_recv/My_Callback recv the following: \n%s\n",
                sm->data));
    ACE_DEBUG ((LM_DEBUG, "(%t) Please notice callback borrow Channel internal thread\n"));
 
    delete msg;

    return SUCCESS;
  }
}; 

int ACE_TMAIN (int argc, ACE_TCHAR *argv[]) {
  ACE_UNUSED_ARG(argc);
  ACE_UNUSED_ARG(argv);

  ACE::debug('y');

  ACE_LOG_MSG->open
    (argv[0], ACE_Log_Msg::SYSLOG, ACE_TEXT (argv[0]));
  ACE_LOG_MSG->set_flags (ACE_Log_Msg::STDERR);

  Chan * chan1 = new Chan(); 
  Chan * chan2 = new Chan(); 
  
  if (Chan::LocalConnector::connect (chan1, chan2) != SUCCESS)
    ACE_DEBUG ((LM_DEBUG, "(%t) failed to connect 2 local channels ...\n"));

  My_Callback my_calbak(chan2);
  Chan::Source my_src(chan1);

  my_src.publish_msg(TEST_STRING_MSG);
  my_calbak.subscribe_msg(TEST_STRING_MSG);

  ACE_DEBUG ((LM_DEBUG, "(%t) local_chan_conn coming up ...\n"));


  for(;;) {
      ACE_DEBUG((LM_DEBUG,  "--- Please enter one line msg: "));
      Test_String_Msg *tm =  new Test_String_Msg();
      if (!gets (tm->data))
        break;
      tm->len = strlen(tm->data)+1;
      my_src.send_msg (TEST_STRING_MSG, tm);
  }

  return 0;
}

---