#include "shm_queue_wrapper.h"

 
typedef struct msg_t
{
	int key;
	char buf[100];
	
} msg_t;

void server() {
 	void * msg;
 	int msg_size;
 	msg_t send_msg;
 	int key = 1;
	size_t qsize = 16;
	void * local_queue = shmqueue_create( &key, qsize);

	struct timespec timeout = {1, 0};
	
	while(shmqueue_pop(local_queue, &msg, &msg_size) ) {
		void * remote_queue = shmqueue_attach(((msg_t *)msg)->key);
	    printf("received: %s\n", ((msg_t *)msg)->buf);
	    // send_msg.key = 1;
	    sprintf(send_msg.buf, "hello, I have received: %s!", ((msg_t *)msg)->buf);
	    shmqueue_push(remote_queue, (void *)&send_msg, sizeof(send_msg));
	    shmqueue_drop(remote_queue);
	   // cout <<  item.pic << endl;
	    // i++;
	}

	//销毁队列
	shmqueue_drop(local_queue);
}

 
int main () {
	shm_mm_wrapper_init(512);
	server();

	//整个进程退出时需要执行这个方法，该方法首先会检查是否还有其他进程在使用该共享内存，如果还有其他进程在使用就只是detach,如果没有其他进程在使用则销毁整块内存。
	shm_mm_wrapper_destroy();
	return 0;
}