producer.cpp

Go to the documentation of this file.

#include <string>
#include <iostream>
#include <sstream>

#include "shm_segment.h"
#include "shm_mmap.h"
#include "shm_ptr.h"
#include "scoped_lock.h"
#include "shm_allocator.h"
#include "shm_message.h"
#include "shm_queue.h"

void reportInitialization( shm_segment *seg_addr, shm_queue<shm_message> *q_addr );
 
int main(int argc, char*argv[]) {
  int segment_key = 30000; 
  int segment_size = 61440;
  int segment_perm = 01640;
  unsigned int queue_size = 3000;
  int message_count = 0;
  shm_segment seg( segment_key, segment_size, segment_perm );
  shm_allocator a( seg );
  shm_queue<shm_message> q( a, queue_size );
  reportInitialization( &seg, &q ) ;
 
  while ( true ) {
      std::cout 
    << "enter a message: " 
    << std::flush;
      std::string line;
      std::getline( std::cin, line );
      //      Message* m = new ( a ) Message( line, a );
      shm_message* m = new ( a ) shm_message;
      m->sequence_num = message_count++;
      m->message.reset( static_cast<char*>( a.alloc( line.size() + 1 ) ), seg );
      strcpy( m->message.get(seg), line.c_str() );
      q.push( shm_ptr<shm_message>( m, seg ) );
      std::cout 
    << "message id : " 
    << q.size()
    << ", message address : " 
    << m
    << std::endl;
    }
}

void reportInitialization( shm_segment *seg_addr, shm_queue<shm_message> *q_addr ) 
{
 std::cout 
    << "segment id : " 
    << seg_addr->get_id()
    << std::endl
    << std::flush;
  std::cout 
    << "segment address : " 
    << seg_addr
    << std::endl
    << std::flush;
  std::cout 
    << "queue address : " 
    << q_addr
    << std::endl
    << std::flush;
}

/*
 * $Log: producer.cpp,v $
 * Revision 1.1.1.1  2006/08/30 12:14:46  oommoo
 * Initial checkin of project library
 *
 *
 * SharedMemory notes from :
 *
 * http://home.earthlink.net/~joshwalker1/writing/SharedMemory.html
 *
 * main routine for producer
 *
 */

---