simpleipc.h File Reference

#include <semaphore.h>

Go to the source code of this file.

Macros
#define	SIPC_MAX_SEMAPHORES   512
#define	USE_SEM_INIT   0

Typedefs
typedef sem_t	sipc_sem_t

Functions
int	sipc_semaphore_init (int id, int count)
int	sipc_semaphore_exists (int id)
int	sipc_semaphore_acquire (int id)
int	sipc_semaphore_try_acquire (int id)
int	sipc_semaphore_get_value (int id)
int	sipc_semaphore_release (int id)
int	simpleipc_cmd (char *cmd, int id, int v)

Variables
EXTERN_VAR sipc_sem_t *	semaphore [SIPC_MAX_SEMAPHORES]
EXTERN_VAR int	sem_acquired [SIPC_MAX_SEMAPHORES]

Macro Definition Documentation

SIPC_MAX_SEMAPHORES

#define SIPC_MAX_SEMAPHORES   512

Definition at line 10 of file simpleipc.h.

USE_SEM_INIT

#define USE_SEM_INIT   0

Definition at line 12 of file simpleipc.h.

Typedef Documentation

sipc_sem_t

typedef sem_t sipc_sem_t

Definition at line 27 of file simpleipc.h.

Function Documentation

simpleipc_cmd()

int simpleipc_cmd	(	char *	cmd,
		int	id,
		int	v
	)

Definition at line 167 of file semaphore.c.

{
  if (strcmp(cmd,"init")==0)
    return sipc_semaphore_init(id,v);
  else if (strcmp(cmd,"exists")==0)
    return sipc_semaphore_exists(id);
  else if (strcmp(cmd,"acquire")==0)
    return  sipc_semaphore_acquire(id);
  else if (strcmp(cmd,"try_acquire")==0)
    return sipc_semaphore_try_acquire(id);
  else if (strcmp(cmd,"release")==0)
    return sipc_semaphore_release(id);
  else if (strcmp(cmd,"get_value")==0)
    return sipc_semaphore_get_value(id);
  else printf("unknown\n");
    return  -2;
}

sipc_semaphore_acquire()

int sipc_semaphore_acquire

(

int

id

)

Definition at line 94 of file semaphore.c.

{
  if ((id<0) || (id >= SIPC_MAX_SEMAPHORES) || (semaphore[id]==NULL))  return -1;
  defer_shutdown++;
#if PORTABLE_SEMAPHORES
  si_sem_wait(semaphore[id]->sig);
  si_sem_wait(semaphore[id]->guard);
  semaphore[id]->count--;
  sem_post(semaphore[id]->guard);
#else
  si_sem_wait(semaphore[id]);
#endif
  sem_acquired[id]++;
  defer_shutdown--;
  if (!defer_shutdown && do_shutdown) m2_end(1);
  return 1;
}

sipc_semaphore_exists()

int sipc_semaphore_exists

(

int

id

)

Definition at line 88 of file semaphore.c.

{
  if ((id<0) || (id >= SIPC_MAX_SEMAPHORES))  return -1;
  return semaphore[id] != NULL;
}

sipc_semaphore_get_value()

int sipc_semaphore_get_value

(

int

id

)

Definition at line 153 of file semaphore.c.

{
  int val;
  if ((id<0) || (id >= SIPC_MAX_SEMAPHORES) || (semaphore[id]==NULL))  return -1;
#if PORTABLE_SEMAPHORES
  sem_wait(semaphore[id]->guard);
  val = semaphore[id]->count;
  sem_post(semaphore[id]->guard);
#else
  sem_getvalue(semaphore[id], &val);
#endif
  return val;
}

sipc_semaphore_init()

int sipc_semaphore_init	(	int	id,
		int	count
	)

Definition at line 31 of file semaphore.c.

{
  char buf[100];
  sipc_sem_t *sem;
  if ((id<0) || (id >= SIPC_MAX_SEMAPHORES))
    return -1;
  // Already initialized?
  if (semaphore[id])
    return 0;
  // to make it completely safe, we should generate a name
  // from /dev/urandom.
#if USE_SEM_INIT
  // TODO: This should really use mapped memory so that processes
  // can keep using the semaphore after fork + exec.
  sem = malloc(sizeof(sem_t));
  if (!sem)
    return -1;
  if (sem_init(sem, 1, count) < 0)
  {
    free(sem);
    return -1;
  }
#else
#if PORTABLE_SEMAPHORES
#ifndef MAP_ANONYMOUS
#define MAP_ANONYMOUS MAP_ANON
#endif
  sem = mmap(NULL, getpagesize(),
    PROT_READ|PROT_WRITE, MAP_ANONYMOUS|MAP_SHARED, -1, 0);
  if (sem == MAP_FAILED)
    return -1;
  sem->count = count;
  sprintf(buf, "/%d:sem%d:g", getpid(), id);
  sem_unlink(buf);
  sem->guard = sem_open(buf, O_CREAT, 0600, count);
  sem_unlink(buf);
  sprintf(buf, "/%d:sem%d:s", getpid(), id);
  sem_unlink(buf);
  sem->sig = sem_open(buf, O_CREAT, 0600, count);
  sem_unlink(buf);
#else
  sprintf(buf, "/%d:sem%d", getpid(), id);
  sem_unlink(buf);
  sem = sem_open(buf, O_CREAT, 0600, count);
#endif
#endif
#if !PORTABLE_SEMAPHORES
  if (sem == SEM_FAILED || !sem)
    return -1;
#endif
  semaphore[id] = sem;
#if !USE_SEM_INIT
  sem_unlink(buf);
#endif
  return 1;
}

sipc_semaphore_release()

int sipc_semaphore_release

(

int

id

)

Definition at line 135 of file semaphore.c.

{
  if ((id<0) || (id >= SIPC_MAX_SEMAPHORES) || (semaphore[id]==NULL))  return -1;
  defer_shutdown++;
#if PORTABLE_SEMAPHORES
  sem_wait(semaphore[id]->guard);
  semaphore[id]->count++;
  sem_post(semaphore[id]->sig);
  sem_post(semaphore[id]->guard);
#else
  sem_post(semaphore[id]);
#endif
  sem_acquired[id]--;
  defer_shutdown--;
  if (!defer_shutdown && do_shutdown) m2_end(1);
  return 1;
}

sipc_semaphore_try_acquire()

int sipc_semaphore_try_acquire

(

int

id

)

Definition at line 112 of file semaphore.c.

{
  if ((id<0) || (id >= SIPC_MAX_SEMAPHORES) || (semaphore[id]==NULL))  return -1;
  defer_shutdown++;
#if PORTABLE_SEMAPHORES
  int trywait = si_sem_trywait(semaphore[id]->sig);
#else
  int trywait = si_sem_trywait(semaphore[id]);
#endif
  if (!trywait)
  {
#if PORTABLE_SEMAPHORES
    si_sem_wait(semaphore[id]->guard);
    semaphore[id]->count--;
    sem_post(semaphore[id]->guard);
#endif
    sem_acquired[id]++;
  }
  defer_shutdown--;
  if (!defer_shutdown && do_shutdown) m2_end(1);
  return !trywait;
}

Variable Documentation

sem_acquired

EXTERN_VAR int sem_acquired[SIPC_MAX_SEMAPHORES]

Definition at line 32 of file simpleipc.h.

semaphore

EXTERN_VAR sipc_sem_t* semaphore[SIPC_MAX_SEMAPHORES]

Definition at line 31 of file simpleipc.h.