#include "shm_queue_wrapper.h"
|
#include "mm.h"
|
|
typedef struct msg_t
|
{
|
int key;
|
char buf[100];
|
|
} msg_t;
|
|
void server() {
|
msg_t msg;
|
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, (void *)&msg) ) {
|
void * remote_queue = shmqueue_attach(msg.key);
|
printf("received: %s\n", msg.buf);
|
// send_msg.key = 1;
|
sprintf(send_msg.buf, "hello, I have received: %s!", 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 () {
|
mm_init(512);
|
server();
|
|
//整个进程退出时需要执行这个方法，该方法首先会检查是否还有其他进程在使用该共享内存，如果还有其他进程在使用就只是detach,如果没有其他进程在使用则销毁整块内存。
|
mm_destroy();
|
return 0;
|
}
|
