L:/channel/channel/examples/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 string IdType;

typedef Channel<IdType> Chan;
typedef Channel<IdType>::Msg ChanMsg;

//------------------------------------------------------------------
// Message definitions :
//
//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() {
  }
};

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

int main (int , char *argv[]) {
   
  //step1. create channel
  Chan * my_chan = new Chan(); 
  
  //step2. connect channels
  char *peer_addr = argv[1];
  Chan::UnixSockConnector *unix_conn = new Chan::UnixSockConnector(my_chan, true);
  unix_conn->open ();
  if (unix_conn->connect (peer_addr) == FAILURE) { 
    cout << "failed to connect peer unix domain 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(TEST_STRING_MSG);

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

  //step5. send msgs
  for(;;) {
    cout <<  "--- Please enter one line msg: " << endl;
      Test_String_Msg *tm =  new Test_String_Msg();
      if (!gets (tm->data)) {
        delete tm;
        break;
      }
      tm->len = strlen(tm->data)+1;
      my_src.send_msg (TEST_STRING_MSG, tm);
  }

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

  return 0;
}

---