linux下共享内存的问题

parrot18

最近遇到一个很奇怪的问题，尝试父子进程之间共享内存进行进程间通信，使用的是SYSTEM V API，shmget系列
部分源代码如下：

1. //下面是顺序存储队列和队列一些操作的定义，准备使用这个队列来进行进程间的信息存取
   
2. typedef struct queue
   
3. {
   
4.         unsigned char buffer[64][128];
   
5.         int front, rear;
   
6.         int buf_size;
   
7. }QUEUE;
   
8. 
   
9. //初始化队列
   
10. void initQueue(QUEUE* cache)
    
11. {
    
12.         cache->front = 0;
    
13.         cache->rear = 0;
    
14.         cache->buf_size = 64;
    
15.         int i;
    
16.         for(i=0;i<cache->buf_size;i++)
    
17.         {
    
18.                 memset(cache->buffer[i], 0, cache->buf_size);
    
19.         }
    
20. }
    
21. //返回队首元素不改变队列状态
    
22. int outQueue(QUEUE* cache, unsigned char* buf)
    
23. {
    
24.         sem_wait(sem_cache);
    
25.         if(cache->front == cache->rear)
    
26.                 {
    
27.                         printf("the queue is empty!\n");
    
28.                         return -1;
    
29.                 }       
    
30.         memcpy(buf, cache->buffer[(cache->front + 1) % cache->buf_size], cache->buf_size);
    
31.         sem_post(sem_cache);
    
32.         return 0;
    
33. }
    
34. //删除队首元素
    
35. int delFront(QUEUE* cache)
    
36. {
    
37.         sem_wait(sem_cache);
    
38.         if(cache->front == cache->rear)
    
39.                 {
    
40.                         printf("the queue is empty!\n");
    
41.                         return -1;
    
42.                 }
    
43.         cache->front = (cache->front + 1) % cache->buf_size ;
    
44.         memset(cache->buffer[cache->front], 0, cache->buf_size);
    
45.         sem_post(sem_cache);
    
46.         return 0;
    
47. }
    
48. //插入元素
    
49. int enQueue(QUEUE* cache, unsigned char* buf)
    
50. {
    
51.         sem_wait(sem_cache);
    
52.         if(((cache->rear + 1) % cache->buf_size) == cache->front)
    
53.                 {
    
54.                         printf("the queue is full!\ndelete first node\n");
    
55.                         cache->front = (cache->front + 1) % cache->buf_size ;
    
56.                         memset(cache->buffer[cache->front], 0, cache->buf_size);
    
57.                 }
    
58.         cache->rear = (cache->rear + 1) % cache->buf_size;
    
59.         memcpy(cache->buffer[cache->rear], buf, cache->buf_size);
    
60.         sem_post(sem_cache);
    
61.         return 0;
    
62. }
    
63. //主程序利用信号灯进行共享内存读写的同步
    
64. int main()
    
65. {
    
66.        
    
67. /*创建信号灯*/
    
68.         sem_cache=sem_open(SEM_NAME,O_CREAT,0666,1);
    
69.         sem_close(sem_cache);
    
70.         sem_unlink(SEM_NAME);
    
71.         sem_cache=sem_open(SEM_NAME,O_CREAT,0666,1);//信号灯初始值为1
    
72.        
    
73.         int flag = 0;
    
74.         sem_getvalue(sem_cache, &flag);//问题1：如果不执行这步操作，信号灯初值居然为0...这段信号灯代码用了N年了，就今天这次出问题，不知是为什么。。。
    
75.         printf("sem:%d\n", flag);
    
76.         unsigned char send_buf[128], read_buf[128];
    
77.         memset(send_buf, 0, 128);
    
78.         memset(read_buf, 0, 128);
    
79.         QUEUE* app_cache;
    
80.         int shmid;
    
81.         shmid = shmget((key_t)118, 8192, IPC_CREAT|0666);
    
82.         if(shmid == -1)
    
83.                 {
    
84.                         perror("shmget");
    
85.                         return -1;
    
86.                 }
    
87.         app_cache = (QUEUE* )shmat(shmid, NULL, 0);
    
88.         if(app_cache == NULL)
    
89.                 {
    
90.                         perror("shmat");
    
91.                         return -1;
    
92.                 }
    
93.         initQueue(app_cache);
    
94.         send_buf[0] = 252;
    
95.         send_buf[1] = 51;
    
96.         send_buf[2] = 53;
    
97.         send_buf[3] = 49;
    
98.         send_buf[4] = 54;
    
99.         send_buf[5] = 57;
    
100.         send_buf[6] = 51;
     
101.         send_buf[7] = 48;
     
102.         send_buf[8] = 51;
     
103.         send_buf[9] = 49;
     
104.         send_buf[10] = 49;
     
105.         send_buf[11] = 49;
     
106.         send_buf[12] = 48;
     
107.         send_buf[13] = 55;
     
108.         send_buf[14] = 51;
     
109.         send_buf[15] = 52;
     
110.         send_buf[16] = 0;
     
111.         send_buf[17] = 21;
     
112.         send_buf[18] = 6;
     
113.         send_buf[19] = 0;
     
114.         send_buf[20] = 214;
     
115.         send_buf[21] = 13;
     
116.         send_buf[22] = 0;
     
117.         send_buf[23] = 158;
     
118.         send_buf[24] = 52;
     
119.         send_buf[25] = 7;
     
120.         send_buf[26] = 0;
     
121.         send_buf[27] = 160;
     
122.        
     
123.         enQueue(app_cache, send_buf);//插入信息       
     
124.         enQueue(app_cache, send_buf);//插入信息
     
125.         outQueue(app_cache, read_buf);//读取信息但是队列状态不变
     
126.         delFront(app_cache);//删除头结点
     
127.         printf("%d\n",app_cache->rear - app_cache->front);//打印队首队尾信息，不论这句话出现在哪儿..只要一访问app_cache->front，它的值就变了！！...正常此处应该是2-1 = 1  访问完之后 front 应该是1  rear是2 但是...gdb调试打印出来的front是2069..有时候甚至是几万几千...然后之后的enQueue操作就有可能溢出、段错误...很郁闷，不论在哪里，只要一访问完front，front的值立马就变了...哪怕只是打印一下...
     
128.         shmctl(shmid, IPC_RMID, 0);
     
129. }
     
130. 
     

复制代码

请大家帮忙指点指点这是为什么。。。谢谢。。