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