smq_write.c

#include <unistd.h>    /* for usleep() */
#include <signal.h>    /* for signal() */
#include <shm_arena.h> /* for Shared Memory Arena Library */

static int running = 1;

static void catcher(int sig)
{
  printf("catch signal %d\n", sig);
  running = 0;
}

int main(void)
{
  smq_t q;
  int count = 0;
  int *ptr;

  signal(SIGINT, catcher);

  q = smq_get(NULL, sizeof(int), 10, "q_count", O_CREAT);
  if(!q)
    {
      printf("smq_get() failed\n");
      return 1;
    }

  while(running)
    {
      smq_wrlock(q, 0);
      /* get the next entry to write */
      ptr = smq_write(q);
      /* write */
      *ptr = count;
      smq_unlock(q);

      count++;
      usleep(100000); /* micro seconds */
    }

  return 0;
}