consumer.cpp

Go to the documentation of this file.

#include <string>
#include <iostream>
#include <sstream>
#include <math.h>
 
#include "shm_segment.h"
#include "shm_ptr.h"
#include "scoped_lock.h"
#include "shm_allocator.h"
#include "shm_queue.h"
#include "shm_message.h"
 
using namespace std;
 
int main(int argc, char*argv[])
{
  std::cout 
    << "enter a shared memory id : " 
    << std::flush;
  std::string line;
  std::getline( std::cin, line );
  long shmid = atol( line.c_str() );
  shm_segment seg( (int)shmid, 01640 ) ; 
  shm_allocator a( seg );
  shm_queue<shm_message> q( a );

  while ( true ) {
      std::cout 
    << "Queue size : "
    << q.size()
    << endl;
      shm_ptr<shm_message> p = q.pop();
      shm_message* m = p.get(seg);
      std::cout 
    << "Message " 
    << m->sequence_num 
    << " " 
    << m->message.get(seg) 
    << "\n";
      //      a.free(m->message.get(seg));
      //      m->~Message();
      //      operator delete(m, a);
    }
}
 
/*
 * $Log: consumer.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
 *
 */

---