#include "shm_queue_wrapper.h"

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


static void * remote_queues[100];
static int remote_queues_len = 0;

void *pub(void *) {
	msg_t send_msg;
	send_msg.key = 1;
	while(true) {
		for(int i = 0; i < remote_queues_len; i++ ) {
			sprintf(send_msg.buf, "今日头条××××");
	    	shmqueue_push(remote_queues[i], (void *)&send_msg, sizeof(send_msg));
		}
		sleep(2);
	}
}

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

	pthread_t tid;
 	pthread_create(&tid, NULL, pub, NULL);
	
	while(shmqueue_pop(local_queue, &msg, &msg_size) ) {
		void * remote_queue = shmqueue_attach(((msg_t *)msg)->key);
		remote_queues[remote_queues_len++] = remote_queue;
	    printf("收到订阅请求", ((msg_t *)msg)->buf);
	   
	   
	    // shmqueue_drop(remote_queue);
	   // cout <<  item.pic << endl;
	    // i++;
	}

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

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

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