分割文件, 计算总行数不对

mjus

1. 
   
2. #include <fcntl.h>
   
3. #include <unistd.h>
   
4. #include <sys/stat.h>
   
5. #include <stdlib.h>
   
6. #include <stdio.h>
   
7. #include <string.h>
   
8. 
   
9. #define SIZE 4096
   
10. #define dbg(...) fprintf(stderr,__VA_ARGS__)
    
11. typedef struct{
    
12.         unsigned long offset;
    
13.         unsigned long size;
    
14. } PART;
    
15. 
    
16. char filein[24];   
    
17. char fileout1[24];
    
18. char fileout2[24];
    
19. char fileout3[24];
    
20. 
    
21. 
    
22. int main(int argc, char *argv[]){
    
23.         char                   data[SIZE];
    
24.         struct stat   f_stat;
    
25.         int fin, fout1, fout2, fout3, sz, i=0;
    
26.         PART         part1, part2, part3;
    
27. 
    
28.         if(argc != 5){
    
29.                 puts("Not enough arguments.");
    
30.                 puts("a.out in o1 o2 o3");
    
31.                 return -1;
    
32.         }
    
33.         strcpy(filein, argv[1]);
    
34.         strcpy(fileout1, argv[2]);
    
35.         strcpy(fileout2, argv[3]);
    
36.         strcpy(fileout3, argv[4]);
    
37. 
    
38.         stat(filein, &f_stat);         // getting the info of file
    
39.         printf("Size of file is %lu \n", f_stat.st_size);
    
40. 
    
41.         // breaking the size of file in 3 parts
    
42.         part1.offset = 0;
    
43.         part1.size = f_stat.st_size / 3;
    
44. 
    
45.         part2.offset = part1.size;
    
46.         part2.size = part1.size;
    
47. 
    
48.         part3.offset = part2.offset + part2.size;
    
49.         part3.size = f_stat.st_size - part3.offset;
    
50. 
    
51.         fin = open(filein, O_RDONLY);
    
52.         fout1 = open(fileout1, O_WRONLY|O_CREAT, 0666);
    
53.         fout2 = open(fileout2, O_WRONLY|O_CREAT, 0666);
    
54.         fout3 = open(fileout3, O_WRONLY|O_CREAT, 0666);
    
55. 
    
56.         lseek(fin,part1.offset, SEEK_SET);
    
57.         while(i < part1.size){
    
58.                 sz = read(fin, data, SIZE);
    
59.                 if(write(fout1, data, sz) <0)
    
60.                      exit(1);
    
61.                 i += sz;
    
62.         }
    
63.         close(fout1);
    
64.         printf("f1 \n");
    
65. 
    
66.    i=0;
    
67.    lseek(fin,part2.offset, SEEK_SET);
    
68.    while(i < part2.size){
    
69.                 sz = read(fin, data, SIZE);
    
70.                 if(write(fout2, data, sz)<0)
    
71.                      exit(2);
    
72.                 i += sz;
    
73.    }
    
74.    close(fout2);
    
75.    printf("f2 \n");
    
76. 
    
77.    i=0;
    
78.    lseek(fin,part3.offset, SEEK_SET);
    
79.    while(i < part3.size){
    
80.                 sz = read(fin, data, SIZE);
    
81.                 if(write(fout3, data, sz) <0)
    
82.                      exit(3);
    
83.                 i += sz;
    
84.    }
    
85.    printf("f3 \n");
    
86.    close(fout3);
    
87. 
    
88.    close(fin);
    
89.    printf("file breaking done\n");
    
90.    fflush(stdout);
    
91.    return 0;
    
92. }
    

复制代码

我用 seq 10000000 > test.dat ( 在 Linux ) 作为 input 文件.
打入 $> a.out test.dat f1 f2 f3
$> wc -l f1 f2 f3
3425928 f1
3287040 f2
3287038 f3
10000006 total

$> wc -l test.dat
10000000 test.dat

为何分割后三个文件总行数大于单个文件总行数 ? 我错在哪里 ? 多谢 !!!

hellioncu

每行不等宽，怎么能直接 /3

mjus

那怎样做才对呢 ? 谢谢 !

hellioncu

mjus 发表于 2014-12-03 11:39
那怎样做才对呢 ? 谢谢 !

若你的需求是按行均分，那你只能先计算总行数，再根据行数分割（逐行读或者自行判断换行符）

cobras

1. #include <stdio.h>
   
2. 
   
3. #define MAX_LINE 32
   
4. 
   
5. int nstr_lmt(const char *s, int lmt)
   
6. {
   
7.         int off;
   
8. 
   
9.         for (off = 0; off < lmt && s[off] != '\0'; ++off) {
   
10.         }
    
11.         return off;
    
12. }
    
13. 
    
14. int read_line(char *buf, int buf_len, FILE *fp)
    
15. {
    
16.         if (fgets(buf, buf_len, fp) == NULL) {
    
17.                 return 0;
    
18.         }
    
19.         return nstr_lmt(buf, buf_len);
    
20. }
    
21. 
    
22. int main(void)
    
23. {
    
24.         char line_buf[MAX_LINE];
    
25.         FILE *fp;
    
26.         int line_count;
    
27.         int line_start;
    
28.         int line_end;
    
29.         int line_len;
    
30. 
    
31.         printf("Please Input Filename: ");
    
32.         fgets(line_buf, MAX_LINE, stdin);
    
33.         line_len = nstr_lmt(line_buf, MAX_LINE);
    
34.         if (line_len > 0 && line_buf[line_len - 1] == '\n') {
    
35.                 line_buf[line_len - 1] = '\0';
    
36.         }
    
37.         printf("Please Input Start Line: ");
    
38.         scanf("%d", &line_start);
    
39.         printf("Please Input End Line: ");
    
40.         scanf("%d", &line_end);
    
41.         fp = fopen(line_buf, "r");
    
42.         if (fp != NULL) {
    
43.                 line_count = 1;
    
44.                 while ((line_len = read_line(line_buf, MAX_LINE, fp)) > 0) {
    
45.                         if (line_buf[line_len - 1] == '\n') {
    
46.                                 if (line_count >= line_start && line_count <= line_end) {
    
47.                                         printf("%d %.*s", line_count, line_len, line_buf);
    
48.                                 }
    
49.                         }else {
    
50.                                 if (line_count >= line_start && line_count <= line_end) {
    
51.                                         printf("%d ", line_count);
    
52.                                 }
    
53.                                 do {
    
54.                                         if (line_count >= line_start && line_count <= line_end) {
    
55.                                                 printf("%.*s", line_len, line_buf);
    
56.                                         }
    
57.                                 }while ((line_len = read_line(line_buf, MAX_LINE, fp)) > 0 && line_buf[line_len - 1] != '\n');
    
58.                                 if (line_count >= line_start && line_count <= line_end) {
    
59.                                         printf("%.*s", line_len, line_buf);
    
60.                                 }
    
61.                         }
    
62.                         ++line_count;
    
63.                 }
    
64.                 printf("Total Lines: %d\n", line_count);
    
65.                 fclose(fp);
    
66.                 return 0;
    
67.         }
    
68.         return -1;
    
69. }
    

复制代码