L:/channel/channel/examples/hier_id_text_recv/send.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 <iostream>
#include <string>

#include <Channel.h>

using namespace std;
using namespace channel;

//---------------------------------------------------------------
// Channel specialization
//
typedef StringPathId<'/'> IdType;

typedef Channel<IdType, IdTrait<IdType>, ACE_MT_SYNCH, TrieRouter<IdType, IdTrait<IdType>, ACE_MT_SYNCH> > Chan;
typedef Chan::Msg ChanMsg;

//------------------------------------------------------------------
// Message definitions :
//
//app msgs ids 
const char * PING_MSG = "/APP/PING";
const char * PONG_MSG = "/APP/PONG";
const char * TEST_STRING_MSG = "/APP/TEST";
const char * APP_WILDCARD_MSG = "/APP/*";

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

//----------------------------------------------------------------
// Implementation
//

int main (int argc, char **argv) {
  if (argc < 2) {
    std::cout << "Usage: hsend peer_host:port\n";
    return -1;
  } 
   
  //step1. create channel
  Chan * my_chan = new Chan(); 
  
  //step2. connect channels
  char *peer_addr = argv[1];
  Chan::TcpSockConnector *tcp_conn = new Chan::TcpSockConnector(my_chan, true);
  tcp_conn->open ();
  ConnInfo ci(peer_addr);
  if (tcp_conn->connect (ci) == FAILURE) { 
    cout << "failed to connect peer tcp socket at " << peer_addr << endl;
    return -1;
  }

  //step3. create src attached to channels
  Chan::Source my_src(my_chan); 
 
  //step4. pub msgs thru ports/callbacks
  my_src.publish_msg(APP_WILDCARD_MSG/*TEST_STRING_MSG*/);

  cout << "hier_sender coming up ...\n";

  //step5. send msgs
  for(;;) {
    cout << "--- Please enter one line msg [type(ping,pong,test)|data]  ";
      Test_String_Msg *tm =  new Test_String_Msg();
      if (!gets (tm->data))
        break;
      tm->len = strlen(tm->data)+1;
      string str(tm->data);
      size_t pos = str.find('|');
      const char *id;
      if (pos == string::npos) 
        id = TEST_STRING_MSG;
      else if (str.substr(0,pos) == "ping")
        id = PING_MSG;
      else if (str.substr(0,pos) == "pong")
        id = PONG_MSG;
      else
        id = TEST_STRING_MSG;
      
      my_src.send_msg (id, tm);
  }

  cout << "hier_sender  exits...\n";

  return 0;
}

---