帮忙调试一下这个程序

andy007

我最近在看Alex Vrenios的《Linux集群体系结构》， 其中的客户程序如何也调 试不出来。希望高手帮忙. 谢谢！
环境：rh9 compiler:gcc
源代码如下：

1. 
   
2. #include <math.h>
   
3. #include <stdio.h>
   
4. #include <stdlib.h>
   
5. #include <unistd.h>
   
6. #include <string.h>
   
7. #include <sys/ipc.h>
   
8. #include <sys/shm.h>
   
9. #include <sys/time.h>
   
10. #include <sys/types.h>
    
11. #include <sys/wait.h>
    
12. #include <sys/socket.h>
    
13. #include <netinet/in.h>
    
14. #include <netdb.h>
    
15. #include "msi.h"
    
16. 
    
17. #define FALSE 0
    
18. #define TRUE 1
    
19. #define NUM 50
    
20. 
    
21. #define CATS 10                        /* # of response time categories */
    
22. #define cats [CATS] = {.1, .2, .3, .4, .5, .6, .7, .8, .9, .10};
    
23. 
    
24. int bars[CATS] = { 0 };                /* counters for bar chart */
    
25. 
    
26. int main(int argc, char *argv[])
    
27. {
    
28.     /*
    
29.      ** client.c: reports response time stats
    
30.      */
    
31.     struct timeval bef, aft;        /* timer value before/after */
    
32.     struct sockaddr_in sock;
    
33.     struct hostent *hp;
    
34.     int flag = (IPC_CREAT | IPC_EXCL | 0660);
    
35.     int size = NUM * sizeof(double);
    
36.     key_t key = 0x01234567;        /* example shared memory key */
    
37.     int shmid;                        /* shared memory area id */
    
38.     int Expon = FALSE;                /* boolean: exponential dist */
    
39.     int Pulse = FALSE;                /* boolean: pulse distribution */
    
40.     int Sweep = FALSE;                /* boolean: sweep distribution */
    
41.     double mean = 0.50;                /* mean value for exponential */
    
42.     double slow = 0.25;                /* slow value for pulse & sweep */
    
43.     double fast = 0.10;                /* fast value for pulse burst */
    
44.     double random;                /* random reals: 0.0 -> 1.0 */
    
45.     double delay;                /* calculated delay time */
    
46.     double *rt;                        /* response times from subtasks */
    
47.     long timeleft;                /* time remaining in IAT */
    
48.     long usec = 0L;                /* inter-arrival microseconds */
    
49.     long secs = 0L;                /* time remaining in seconds */
    
50.     int pids[NUM];                /* subtask process ids */
    
51.     int opt = 1;                /* setsockopt parameter */
    
52.     int fd;                        /* socket file descriptor */
    
53.     int ii, jj, kk = 0;
    
54.     char distribution[4];
    
55.     char buf[QUERYSIZE], *p;
    
56.     int status;
    
57. 
    
58.     srand((unsigned int) getpid());        /* seed rand() */
    
59. 
    
60.     /*
    
61.      ** Operands are remote HOST name and distribution code
    
62.      */
    
63.     if (argc != 3) {
    
64.         printf("\n\tUsage: %s <HOST> <DISTRIBUTION>\n\n", argv[0]);
    
65.         exit(-1);
    
66.     }
    
67.     hp = gethostbyname(argv[1]);
    
68. 
    
69.     if ((argv[2][0] == 'e') || (argv[2][0] == 'E')) {
    
70.         Expon = TRUE;
    
71.         strcpy(distribution, "EXP");
    
72.         srand((unsigned int) getpid());        /* rand() seed */
    
73.     } else if ((argv[2][0] == 'p') || (argv[2][0] == 'P')) {
    
74.         Pulse = TRUE;
    
75.         strcpy(distribution, "PLS");
    
76.     } else if ((argv[2][0] == 's') || (argv[2][0] == 'S')) {
    
77.         Sweep = TRUE;
    
78.         strcpy(distribution, "SMP");
    
79.     } else {
    
80.         printf("\n\tUsage: %s <HOST> <DISTRIBUTION>\n", argv[0]);
    
81.         printf("\t        DISTRIBUTION = { 'e' | 'p' | 's' }\n");
    
82.         printf("\t        for exponential, pulse and sweep\n\n");
    
83.         exit(-1);
    
84.     }
    
85. 
    
86.     /* attach shared memory array */
    
87.     shmid = shmget(key, size, flag);
    
88.     /* attach the shared memory area */
    
89.     rt = (double *) shmat(shmid, 0, 0);
    
90. 
    
91.     /*
    
92.      ** LOOP : send and receive NUM packets
    
93.      */
    
94.     for (ii = 0; ii < NUM; ii++) {
    
95.         rt[ii] = 0.0;                /* zero shared array values */
    
96. 
    
97.         if (Expon) {
    
98.             random = rand() / (double) RAND_MAX;
    
99.             delay = -mean * log(random);
    
100.             if (delay > 0.999999) {
     
101.                 delay = 0.999999;        /* limit maximum */
     
102.             }
     
103.         } else if (Pulse) {
     
104.             if ((ii > (NUM * 0.3)) && (ii < (NUM * 0.4))) {
     
105.                 delay = fast;
     
106.             } else {
     
107.                 delay = slow;
     
108.             }
     
109.         } else if (Sweep) {
     
110.             delay = slow - (ii * (slow / NUM));
     
111.         } else {
     
112.             printf("\n\tError in logic?\n\n");
     
113.             exit(-1);
     
114.         }
     
115.         secs = (long) delay;
     
116.         usec = (long) (1000000.0 * (delay - ((double) secs)));
     
117. 
     
118.         /* random line numbers: 1 thru 99 */
     
119.         random = rand() / (double) RAND_MAX;
     
120.         jj = (int) ((double) (99.0) * random) + 1;
     
121.         if (jj == 20) {
     
122.             jj = 99;
     
123.         }
     
124.         sprintf(buf, "/home/andy/src/cluster/main/sample.txt %d", jj);
     
125. 
     
126.         /* record sending time */
     
127.         gettimeofday(&bef, NULL);
     
128. 
     
129.         /*
     
130.          ** A subtask for each query/response
     
131.          */
     
132.         if ((pids[kk++] = fork()) == 0) {
     
133.             /* attach parent's shared memory */
     
134.             rt = (double *) shmat(shmid, 0, 0);
     
135.             /* shmid is still set correctly */
     
136. 
     
137.             /* Set up TCP socket to the server */
     
138.             fd = socket(AF_INET, SOCK_STREAM, 0);
     
139.             memset((char *) &sock, 0, sizeof(sock));
     
140.             memcpy(&sock.sin_addr, hp->h_addr, hp->h_length);
     
141.             sock.sin_family = hp->h_addrtype;
     
142.             sock.sin_port = htons(QUERYPORT);
     
143.             setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, (char *) &opt,
     
144.                        sizeof(opt));
     
145.             connect(fd, (struct sockaddr *) &sock, sizeof(sock));
     
146.             send(fd, buf, strlen(buf) + 1, 0);
     
147. 
     
148.             /* await result from server */
     
149.             buf[0] = 0;                /* clear buffer */
     
150.             if (recv(fd, buf, QUERYSIZE, 0) > 0) {
     
151.                 printf("\t%d. Line %2d: %s ", kk, jj, buf);
     
152.                 p = strrchr(buf, ' ') + 2;
     
153.                 if (jj != atoi(p)) {
     
154.                     printf("***");        /* incorrect result! */
     
155.                 }
     
156.                 printf("\n");
     
157.             }
     
158. 
     
159.             /* record response time */
     
160.             gettimeofday(&aft, NULL);
     
161.             aft.tv_sec -= bef.tv_sec;
     
162.             aft.tv_usec -= bef.tv_usec;
     
163.             if (aft.tv_usec < 0L) {
     
164.                 aft.tv_usec += 1000000L;
     
165.                 aft.tv_sec -= 1;
     
166.             }
     
167.             rt[ii] =
     
168.                 (double) aft.tv_sec + ((double) aft.tv_usec / 1000000.0);
     
169. 
     
170.             close(fd);
     
171.             exit(0);
     
172.         }
     
173. 
     
174.         /*
     
175.          ** Sleep for remainder of IAT
     
176.          */
     
177.         gettimeofday(&aft, NULL);
     
178.         aft.tv_sec -= bef.tv_sec;
     
179.         aft.tv_usec -= bef.tv_usec;
     
180.         if (aft.tv_usec < 0L) {
     
181.             aft.tv_usec += 1000000L;
     
182.             aft.tv_sec -= 1;
     
183.         }
     
184.         bef.tv_sec = secs;
     
185.         bef.tv_usec = usec;
     
186.         bef.tv_sec -= aft.tv_sec;
     
187.         bef.tv_usec -= aft.tv_usec;
     
188.         if (bef.tv_usec < 0L) {
     
189.             bef.tv_usec += 1000000L;
     
190.             bef.tv_sec -= 1;
     
191.         }
     
192.         timeleft = (bef.tv_sec * 1000000L) + bef.tv_usec;
     
193.         if (timeleft < 0) {
     
194.             printf("\tERROR: A higher IAT value is required - exiting.\n");
     
195.             break;
     
196.         }
     
197.         usleep(timeleft);
     
198.     }
     
199.     for (ii = 0; ii < kk; ii++) {
     
200.         waitpid(pids[ii], &status, 0);
     
201.     }
     
202. 
     
203.     /*
     
204.      ** Report the response time statistics
     
205.      */
     
206.     for (ii = 0; ii < NUM; ii++) {
     
207.         for (jj = 0; jj < CATS; jj++) {
     
208.             if (rt[ii] < cats[jj]) {
     
209.                 bars[jj]++;
     
210.                 break;
     
211.             }
     
212.         }
     
213.     }
     
214.     sleep(2);
     
215.     printf("RESPONSE    |           %3d QUERY PACKETS            %s\n",
     
216.            NUM, distribution);
     
217.     printf("TIME (msec) |      10       20       30       40      50\n");
     
218.     printf("------------+---+---+---+----+---+----+---+----+---+--+\n");
     
219.     ii = 0;                        /* total */
     
220.     for (jj = 0; jj < CATS; jj++) {
     
221.         ii += bars[jj];
     
222.         kk = (1000.0 * cats[jj]) + .5;
     
223.         printf(" %5d%5d |", kk - 9, kk);
     
224.         for (kk = 0; kk < bars[jj]; kk++) {
     
225.             printf("*");
     
226.         }
     
227.         printf("\n");
     
228.     }
     
229.     printf("  OVER%5d |", (int) (1000 * cats[CATS - 1]));
     
230.     jj = NUM - ii;
     
231.     for (kk = 0; kk < jj; kk++) {
     
232.         printf("*");
     
233.     }
     
234.     printf("\n");
     
235. 
     
236.     /* remove unused shared memory area and exit */
     
237.     shmctl(shmid, IPC_RMID, (struct shmid_ds *) 0);
     
238. 
     
239.     return 0;
     
240. }
     

复制代码

这里是msi.h头文件：

1. 
   
2. /*
   
3. ** msi.h - master-slave interface header
   
4. */
   
5. #define QUERYPORT 9000
   
6. #define BROADCAST 5000
   
7. #define REGISTERS 5001
   
8. #define SLAVEPORT 5002
   
9. #define QUERYSIZE 256
   
10. 
    
11. struct packet
    
12. {
    
13.         /*
    
14.         ** Information request packet
    
15.         */
    
16. #ifdef TIMING
    
17.         /* slave phase times */
    
18.         struct timeval remote;
    
19.         struct timeval phase4;
    
20.         struct timeval phase5;
    
21.         struct timeval phase6;
    
22. #endif
    
23.         char buffer[QUERYSIZE]; /* request */
    
24. } packet;
    

复制代码

kj501

这一句是什么意思？！！

1. 
   
2. #define cats [CATS] = {.1, .2, .3, .4, .5, .6, .7, .8, .9, .10};
   

复制代码

andy007

客户程序最后的一段代码用来输出一张图，这个数组是用来显示的。
这张图表示了服务器响应客户机的时间。

kj501

如果是数组，直接后再初始化就行啦，干吗用#define?
这样在预处理时根本发现不了你的错误！
建议你自己找本教科书看看C语言中数组是如何定义的。

Maitou

楼主是书上的源码吧？

andy007

yes, it's from <<Linux Cluster Architecture>>

kj501

如果书上就是这样子写的，那一定是搞错了。可以把它的源代码下载来看看。

andy007

谢谢斑竹了