问一个关于fork后的文件操作的IO问题

zhangchuhu

每个进程都有自己的文件表项，因此每个进程都有自己对文件的偏移量。lseek和write不是一个原子操作。因此b进程可能替换了a进程写入的内容。要达到楼主想要的效果有两种方式：
1.不加记录锁，打开文件的时候用O_APPEND状态标记，这样内核在写的时候会把当前位移量移动到文件的末尾处。
if ((fd = open(fn, O_WRONLY | O_CREAT|O_APPEND, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH)) < 0) {
                perror("open:");
                exit(-1);
        }
2.把记录锁加到循环外面

1. #include <stdio.h>
   
2. #include <stdlib.h>
   
3. #include <unistd.h>
   
4. #include <sys/stat.h>
   
5. #include <fcntl.h>
   
6. #include <string.h>
   
7. #define CNT 100
   
8. 
   
9. void write_file(int fd, char data, size_t len);
   
10. 
    
11. int main(int argc, char *argv[])
    
12. {
    
13.         char fn[]="flock-demo";
    
14.         int fd;
    
15.         pid_t pid;
    
16. 
    
17.         if (argc > 1)
    
18.                 strcpy(fn,argv[1]);
    
19. 
    
20.         if ((fd = open(fn, O_WRONLY | O_CREAT, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH)) < 0) {
    
21.                 perror("open:");
    
22.                 exit(-1);
    
23.         }
    
24. 
    
25.         for (int i = 0; i < CNT; i++) {
    
26.                 if ((pid = fork()) < 0) {
    
27.                         perror("fork:");
    
28.                         exit(-1);
    
29.                 } else {
    
30.                         if (pid == 0) {
    
31.                                 /* child process */
    
32.                                 write_file(fd, i, sizeof(i));
    
33.                                 exit(0);
    
34.                         }
    
35.                 }
    
36.         }
    
37. 
    
38.         return 0;
    
39. }
    
40. 
    
41. void write_file(int fd, char data, size_t len)
    
42. {
    
43.         struct flock fl;
    
44. 
    
45.         fl.l_whence = SEEK_SET;
    
46.         fl.l_start  = 0;
    
47.         fl.l_len    = 0;
    
48.         fl.l_type = F_WRLCK;
    
49.         if (fcntl(fd, F_SETLKW, &fl) < 0) {
    
50.                 perror("fcntl:");
    
51.                 exit(-1);
    
52.         }*
    
53.         for (int i = 0; i < CNT; i++) {
    
54.        
    
55. 
    
56.                 ssize_t wlen = write(fd, &data, len);
    
57.                 if (wlen < 0) {
    
58.                         perror("write:");
    
59.                         exit(-1);
    
60.                 }
    
61.                 else {
    
62.                         if ((size_t)wlen < len) {
    
63.                                 fprintf(stderr, "Other write error in process %d\n", getpid());
    
64.                                 exit(-1);
    
65.                         }
    
66.                 }
    
67. 
    
68.                
    
69.                 }
    
70.         fl.l_type = F_UNLCK;
    
71.         if (fcntl(fd, F_SETLKW, &fl) < 0) {
    
72.                 perror("fcntl:");
    
73.                 exit(-1);
    
74.         }
    
75. }
    

复制代码

hejindan88

经测试  木有问题

rongpmcu

大概的看了下，首先你这个程序加父进程才是100个，而且循环也就999，不是1000， 而且你的记录锁只加锁了一次