Remove old queue mode from tree

1 files changed, 0 insertions, 294 deletions

diff --git a/src/squeue/squeue.c b/src/squeue/squeue.c
deleted file mode 100644
index 69bd595..0000000
--- a/src/squeue/squeue.c
+++ /dev/null
@@ -1,294 +0,0 @@
-#include "squeue.h"
-#define _XOPEN_SOURCE 500     /* Or: #define _BSD_SOURCE */
-#include <unistd.h>
-#include <errno.h>
-#include <stdlib.h>
-#include <sys/ipc.h>
-#include <signal.h>
-#include <sys/shm.h>
-#include <sys/types.h>
-#include <sys/stat.h>
-#include <sys/mman.h>
-#include <fcntl.h>
-#include <stdio.h>
-#include <unistd.h>
-#include <string.h>
-
-#define POOL_SIZE ITEM_MAX*ITEM_SIZE
-#define ITEM_SIZE 512
-#define ITEM_MAX 10
-
-int squeue_release(const char *file)
-{
-	int shmid;
-	key_t k = ftok(file, 0xa3);
-	
-	if (k == -1) {
-		perror("ftok");
-		return -1;
-	}
-	
-	shmid = shmget(k, POOL_SIZE, 0666);
-	if (shmid == -1)
-		return -1; // not released
-	return shmctl(shmid, IPC_RMID,NULL);
-}
-
-extern int errno;
-struct squeue_t *squeue_open(const char *file, int mode)
-{
-	struct squeue_t *q;
-	char *pool;
-	int shmid;
-	key_t k;
-
-	k = ftok(file, 0x34);
-	if (k == -1) {
-		perror("ftok");
-		squeue_release(file);
-		close(creat(file, 0666));
-		chmod(file, 0666);
-		k = ftok(file, 0xa3);
-		if (k == -1) {
-			perror("ftok");
-			return NULL;
-		}
-	}
-_retry:
-	shmid = shmget(k, POOL_SIZE, 0666|(mode==Q_CREAT)?IPC_CREAT:0);
-	if (shmid == -1) {
-		perror("shmget1");
-		shmid = shmget(k, POOL_SIZE, 0666|((mode==Q_CREAT)?IPC_CREAT:0));
-		if (shmid == -1) {
-			perror("shmget2");
-			if (errno == EEXIST)
-				shmid = shmget(k, POOL_SIZE, 0666 |IPC_CREAT);
-
-			if (shmid == -1) {
-				if (mode == Q_WAIT) {
-					usleep(100);
-					goto _retry;
-				}
-				perror("shmget");
-				return NULL;
-			}
-		}
-	}
-
-	if (mode == Q_WAIT)
-		mode = Q_OPEN;
-
-	/* fix perms */
-	if (mode == Q_CREAT) {
-		struct shmid_ds sd;
-		shmctl(shmid, IPC_STAT, &sd);
-		sd.shm_perm.uid = 1000;
-		sd.shm_perm.gid = 1000;
-		sd.shm_perm.mode = sd.shm_perm.mode|0666;
-		shmctl(shmid, IPC_SET, &sd);
-	}
-
-	pool = shmat(shmid, NULL, 0);
-	if (pool == (void *)-1) {
-		perror("shmat");
-		return NULL;
-	}
-
-	if (mode == Q_CREAT)
-		memset(pool, '\0', POOL_SIZE);
-
-	q = (struct squeue_t *)malloc(sizeof(struct squeue_t));
-	memset(q, '\0', sizeof(struct squeue_t));
-	q->shmid = shmid;
-	q->pool  = pool;
-	q->mode  = mode;
-
-	return q;
-}
-
-void squeue_free(struct squeue_t *q)
-{
-	free(q);
-}
-
-int squeue_close(struct squeue_t *q)
-{
-	char *pool;
-
-	if (q==NULL)
-		return -1;
-
-	pool = q->pool;
-	shmctl(q->shmid, IPC_RMID, NULL);
-	free(q);
-	return shmdt(pool);
-}
-
-int squeue_push(struct squeue_t *q, const char *str, int lock)
-{
-	int i;
-
-	if (q==NULL)
-		return -1;
-//	if (q->mode == Q_CREAT) {
-//		printf("squeue_push: cannot push from the creator\n");
-//		return -1;
-//	}
-
-	if (str==NULL||strlen(str)>ITEM_SIZE)
-		return -1;
-	do {
-		if (q->squeue_idx >= ITEM_MAX) {
-			while (q->pool[0]!='\0') {
-				q->squeue_locks++;
-				if (!lock) {
-					printf("buffer is full\n");
-					return -1;
-				}
-				usleep(100);
-			}
-			q->squeue_idx = 0;
-		}
-		
-		for(i=q->squeue_idx*ITEM_SIZE;i<POOL_SIZE;i+=ITEM_SIZE) {
-			if (q->pool[i]=='\0') {
-				strcpy(q->pool+i, str);
-				q->squeue_idx++;
-				return 1;
-			}
-		}
-		q->squeue_locks++;
-	} while (lock);
-	q->squeue_lost++;
-
-	return 0;
-}
-
-int squeue_push2(struct squeue_t *q, const char *head, const char *str, int lock)
-{
-	int ret;
-	char *buf = malloc(strlen(head) + strlen(str) + 2);
-	strcpy(buf, head);
-	strcat(buf, ":");
-	strcat(buf, str);
-	ret = squeue_push(q, buf, lock);
-	free(buf);
-	return ret;
-}
-
-int squeue_pop(struct squeue_t *q)
-{
-	int i;
-	int two = 1;
-
-	if (q==NULL)
-		return -1;
-//	if (q->mode == Q_OPEN) { // cannot pop when not owner of squeue
-//		fprintf(stderr, "squeue_pop: cannot pop when you are not owner.\n");
-//		return -1;
-//	}
-	for(two=1;two--;q->head_idx = 0)
-		for(i=q->head_idx*ITEM_SIZE;i<POOL_SIZE;i+=ITEM_SIZE) {
-			if (q->pool[i]!='\0') {
-				q->pool[i]='\0';
-				q->head_idx++;
-				q->squeue_pops++;
-				return 1;
-			}
-		}
-	q->squeue_oops++;
-	fprintf(stderr, "WARNING: race condition detected in squeue.\n");
-	return 0;
-}
-
-char *squeue_get(struct squeue_t *q, int lock)
-{
-	int i=0;
-	int two = 1;
-
-	if(q==NULL)
-		return NULL;
-//	if (q->mode == Q_OPEN) { // cannot pop when not owner of squeue
-//		fprintf(stderr, "squeue_get: cannot pop when you are not owner.\n");
-//		return NULL;
-//	}
-	do {
-		for(two=1;two--;q->head_idx = 0) {
-			for(i=q->head_idx*ITEM_SIZE;i<POOL_SIZE;i+=ITEM_SIZE)
-				if (q->pool[i]!='\0')
-					return q->pool+i;
-		}
-		if (lock)
-			usleep(100);
-	} while (lock);
-	return NULL;
-}
-
-void squeue_stats(struct squeue_t *q)
-{
-	if(q==NULL)
-		return;
-	printf("Queue locks: %d\n", q->squeue_locks);
-	printf("Queue lost: %d\n", q->squeue_lost);
-	printf("Queue oops: %d\n", q->squeue_oops);
-	printf("Queue pops: %d\n", q->squeue_pops);
-}
-
-#if _MAIN_
-struct squeue_t *q;
-
-int sigc()
-{
-	squeue_stats(q);
-	exit(1);
-}
-
-int main()
-{
-	char buf[102];
-	int i;
-	int pid;
-
-	signal(SIGINT, sigc);
-
-	squeue_release("/dev/null");
-
-	pid = fork();
-	if (pid) {
-		q = squeue_open("/dev/null", Q_CREAT);
-		if (q == NULL) {
-			perror("oops");
-			kill(pid, SIGINT);
-			return;
-		}
-		squeue_push(q, "Hello World", 0);
-		squeue_push(q, "jeje msg 2", 0);
-
-		while(1) {
-			char *uh = squeue_get(q,1);
-			if (uh) {
-				printf("get: (%s)\n", uh);
-				squeue_pop(q);
-			}
-			usleep(100);
-		}
-		squeue_close(q);
-	} else {
-		q = squeue_open("/dev/null", Q_WAIT);
-		if (q == NULL) {
-			perror("oops");
-			return;
-		}
-		for(i=0;i<128;i++) {
-			sprintf(buf, "puta%d", i);
-			squeue_push(q, buf, 1);
-			usleep(100);
-		}
-		squeue_stats(q);
-		printf("cya\n");
-		squeue_close(q);
-	}
-
-	return 0;
-}
-#endif