Colony

#include "shmimgserve.h"

#include <stdio.h>

#include <string.h>

#include <stdlib.h>

#include <errno.h>

#include <sys/types.h>

#include <sys/shm.h>

#include "php_sysvsem.h"

#define DEBUG 0

#if DEBUG

#define dbg_printf(...)   printf(__VA_ARGS__)

#else

#define dbg_printf(...)

#endif

int write_JPEG_to_mem (unsigned char *storage, int length, IplImage *_img, int quality);

static sysvsem *sem;

static int shm_id;

int sendImage(IplImage *image)

{

  dbg_printf("Send image\n");

        if (sem->sem_acquire())

        {

                dbg_printf("Semaphore acquired\n");

                unsigned char *p = (unsigned char *)shmat(shm_id, NULL, 0);

                if (p!=(void *)-1)

                {

                        dbg_printf("Memory mapped at %p\n", p);

                        int len = write_JPEG_to_mem (p+4, 150000-4, image, JPEG_QUALITY);

                        int i;

                        int length = len;

                        dbg_printf("%d\n", length);

                        for(i=0; i < 4; i++)

                        {

                                char digit = (char)(length & 0xff);

                                length >>= 8;

                                memcpy(p+i, &digit, sizeof(char));

                        }

                        dbg_printf("Memory copied\n");

                        sem->sem_release();

                        dbg_printf("Semaphore released\n");

                        shmdt(p);

                  dbg_printf("Memory detached\n");

                }

        }

  if (errno!=0)

  {

    int errnum = errno;

    errno = 0;

    fprintf(stderr, "error %d %s\n", errnum, strerror(errnum));

    return errnum;

  }

  return 0;

}

int openShM()

{

        shm_id = shmget(0x40305163, 150000, IPC_CREAT | 0666);

        if (shm_id > 0)

                dbg_printf("Shared memory opened\n");

        else

        {

                fprintf(stderr, "Error opening shared memory\n");

                return -1;

        }

  sem = new (std::nothrow)sysvsem(0x40309999);

  if (sem)

                dbg_printf("Semaphore opened\n");

        else

        {

                fprintf(stderr, "Error opening semaphore\n");

                return -2;

        }

}

void releaseShM()

{

  sem->sem_remove();

        delete sem;

        dbg_printf("Semaphore deleted\n");

  shmctl(shm_id, IPC_RMID, NULL);

  dbg_printf("Memory marked for deletion\n");

}