원형큐를 생성하면서 공유메모리를 설정해주는 라이브러리를 만들고 싶은데 질문좀 드릴게요..
글쓴이: kangmaee / 작성시간: 화, 2014/02/25 - 1:58오후
#define SHARED_MEMORY_KEY 1234
int shmid;
void *shm_addr = (void *)0;
void CreateQueue(CircularQueue** queue, int capacity)
{
*queue = (CircularQueue*)malloc(sizeof(CircularQueue));
(*queue)->nodes = (Node*)malloc(sizeof(Node)* (capacity + 1));
(*queue)->capacity = capacity;
(*queue)->front = 0;
(*queue)->rear = 0;
shmid = shmget((key_t)SHARED_MEMORY_KEY, sizeof(Node), 0666|IPC_CREAT);
if(shmid == -1)
{
perror("shmget failed : ");
exit(0);
}
}
void DestroyQueue(CircularQueue* queue)
{
free(queue->nodes);
free(queue);
}
void Enqueue(CircularQueue* queue, char data[1400])
{
int position = 0;
if (queue->rear == queue->capacity + 1)
{
queue->rear = 0;
position = 0;
}
else
position = queue->rear++;
shm_addr = shmat(shmid, (void *)0, 0);
if(shm_addr == (void *)-1)
{
perror("shmat failed : ");
exit(0);
}
data = (char *)shm_addr;
queue->nodes[position].data = data;
}
ElementType Dequeue(CircularQueue* queue)
{
int position = queue->front;
if (position == queue->capacity)
queue->front = 0;
else
queue->front++;
shm_addr = shmat(shmid, (void *)0, 0);
if(shm_addr == (void *)-1)
{
perror("shmat failed : ");
exit(0);
}
queue = (CircularQueue *)shm_addr;
return queue->nodes[position].data;
}
int GetSize(CircularQueue* queue)
{
if (queue->front <= queue->rear)
return queue->rear - queue->front;
else
return (queue->capacity + 1 - queue->front) + queue->rear;
}
int IsEmpty(CircularQueue* queue)
{
return (queue->front == queue->rear);
}
int IsFull(CircularQueue* queue)
{
if (queue->front < queue->rear)
return (queue->rear - queue->front) == queue->capacity;
else
return (queue->rear + 1) == queue->front;
}이렇게 큐를 만들고 생성하는곳에 shmget 함수를 써주고, Enqueue와 Dequeue할때마다 shmat함수를 써주면...이걸 라이브러리로만들고 가져다 쓸때 공유메모리가 생성될거라 생각했는데...ipcs를 보면 아무 변화도 없고...Dequeue를 하면 shmget :Invalid argument 에러가 뜨네요.참고로 Enqueue하는 main 따로 Dequeue하는 main따로입니다. 몇날몇일 붙잡고있는데 영 안되네요
Forums:


댓글 달기