1 /* ------------------------------------------------------------------------ */
3 /* lhadd.c -- LHarc Add Command */
5 /* Copyright (C) MCMLXXXIX Yooichi.Tagawa */
6 /* Modified Nobutaka Watazaki */
8 /* Ver. 1.14 Source All chagned 1995.01.14 N.Watazaki */
9 /* ------------------------------------------------------------------------ */
11 /* ------------------------------------------------------------------------ */
12 static void remove_files();
14 static char new_archive_name_buffer[FILENAME_LENGTH];
15 static char *new_archive_name;
16 /* ------------------------------------------------------------------------ */
18 add_one(fp, nafp, hdr)
22 long header_pos, next_pos, org_pos, data_pos;
23 long v_original_size, v_packed_size;
26 reading_filename = hdr->name;
27 writting_filename = temporary_name;
29 if (!fp && generic_format) /* [generic] doesn't need directory
32 header_pos = ftell(nafp);
33 write_header(nafp, hdr);/* DUMMY */
35 if ((hdr->unix_mode & UNIX_FILE_SYMLINK) == UNIX_FILE_SYMLINK) {
36 char buf[256], *b1, *b2;
38 strcpy(buf, hdr->name);
39 b1 = strtok(buf, "|");
40 b2 = strtok(NULL, "|");
41 printf("%s -> %s\t- Symbolic Link\n", b1, b2);
45 if (hdr->original_size == 0) /* empty file or directory */
46 return; /* previous write_header is not DUMMY. (^_^) */
49 data_pos = ftell(nafp);
51 hdr->crc = encode_lzhuf(fp, nafp, hdr->original_size,
52 &v_original_size, &v_packed_size, hdr->name, hdr->method);
54 if (v_packed_size < v_original_size) {
55 next_pos = ftell(nafp);
57 else { /* retry by stored method */
58 fseek(fp, org_pos, SEEK_SET);
59 fseek(nafp, data_pos, SEEK_SET);
60 hdr->crc = encode_stored_crc(fp, nafp, hdr->original_size,
61 &v_original_size, &v_packed_size);
63 next_pos = ftell(nafp);
65 ftruncate(fileno(nafp), next_pos);
67 bcopy(LZHUFF0_METHOD, hdr->method, METHOD_TYPE_STRAGE);
69 hdr->original_size = v_original_size;
70 hdr->packed_size = v_packed_size;
71 fseek(nafp, header_pos, SEEK_SET);
72 write_header(nafp, hdr);
73 fseek(nafp, next_pos, SEEK_SET);
77 /* ------------------------------------------------------------------------ */
79 append_it(name, oafp, nafp)
90 struct stat stbuf /*, lstbuf*/;
92 boolean directory, symlink;
94 if (GETSTAT(name, &stbuf) < 0) {
95 error("Cannot access", name); /* See cleaning_files, Why? */
99 directory = is_directory(&stbuf);
101 symlink = is_symlink(&stbuf);
105 init_header(name, &stbuf, &hdr);
107 if (!directory && !noexec)
111 fp = xfopen(name, READ_BINARY);
117 old_header = ftell(oafp);
118 if (!get_header(oafp, &ahdr)) {
124 cmp = STRING_COMPARE(ahdr.name, hdr.name);
126 /* for symbolic link. t.okamoto */
127 cmp = strcmp_filename(ahdr.name, hdr.name);
128 if (cmp < 0) { /* SKIP */
129 /* copy old to new */
131 fseek(oafp, old_header, SEEK_SET);
132 copy_old_one(oafp, nafp, &ahdr);
135 fseek(oafp, ahdr.packed_size, SEEK_CUR);
136 } else if (cmp == 0) { /* REPLACE */
137 /* drop old archive's */
138 fseek(oafp, ahdr.packed_size, SEEK_CUR);
140 } else { /* cmp > 0, INSERT */
141 fseek(oafp, old_header, SEEK_SET);
147 if (update_if_newer) {
148 if (!oafp || /* not in archive */
150 ahdr.unix_last_modified_stamp < /* newer than archive's */
151 hdr.unix_last_modified_stamp) {
153 printf("ADD %s\n", name);
155 add_one(fp, nafp, &hdr);
156 } else { /* cmp == 0 *//* copy old to new */
158 fseek(oafp, old_header, SEEK_SET);
159 copy_old_one(oafp, nafp, &ahdr);
163 if (!oafp || cmp > 0) { /* not in archive or dropped */
165 printf("ADD %s\n", name);
167 add_one(fp, nafp, &hdr);
169 else { /* cmp == 0 */
174 add_one(fp, nafp, &hdr);
183 else { /* recurcive call */
184 if (find_files(name, &filec, &filev)) {
185 for (i = 0; i < filec; i++)
186 oafp = append_it(filev[i], oafp, nafp);
187 free_files(filec, filev);
193 /* ------------------------------------------------------------------------ */
195 find_update_files(oafp)
196 FILE *oafp; /* old archive */
198 char name[FILENAME_LENGTH];
199 struct string_pool sp;
208 while (get_header(oafp, &hdr)) {
209 if ((hdr.unix_mode & UNIX_FILE_TYPEMASK) == UNIX_FILE_REGULAR) {
210 if (stat(hdr.name, &stbuf) >= 0) /* exist ? */
211 add_sp(&sp, hdr.name, strlen(hdr.name) + 1);
213 else if ((hdr.unix_mode & UNIX_FILE_TYPEMASK) == UNIX_FILE_DIRECTORY) {
214 strcpy(name, hdr.name);
216 if (len > 0 && name[len - 1] == '/')
217 name[--len] = '\0'; /* strip tail '/' */
218 if (stat(name, &stbuf) >= 0) /* exist ? */
219 add_sp(&sp, name, len + 1);
221 fseek(oafp, hdr.packed_size, SEEK_CUR);
224 fseek(oafp, pos, SEEK_SET);
226 finish_sp(&sp, &cmd_filec, &cmd_filev);
229 /* ------------------------------------------------------------------------ */
236 char lpath[256], *b1, *b2;
238 old_header_pos = ftell(oafp);
239 while (get_header(oafp, &ahdr)) {
240 strcpy(lpath, ahdr.name);
241 b1 = strtok(lpath, "|");
242 b2 = strtok(NULL, "|");
243 if (need_file(b1)) { /* skip */
244 fseek(oafp, ahdr.packed_size, SEEK_CUR);
245 if (noexec || !quiet)
247 printf("delete %s -> %s\n", b1, b2);
249 printf("delete %s\n", b1);
253 fseek(oafp, ahdr.packed_size, SEEK_CUR);
256 fseek(oafp, old_header_pos, SEEK_SET);
257 copy_old_one(oafp, nafp, &ahdr);
260 old_header_pos = ftell(oafp);
265 /* ------------------------------------------------------------------------ */
267 /* ------------------------------------------------------------------------ */
269 build_temporary_file()
274 build_temporary_name();
275 signal(SIGINT, interrupt);
276 signal(SIGHUP, interrupt);
278 old_umask = umask(077);
279 afp = xfopen(temporary_name, WRITE_BINARY);
280 remove_temporary_at_error = TRUE;
287 /* ------------------------------------------------------------------------ */
292 build_backup_name(backup_archive_name, archive_name);
294 signal(SIGINT, SIG_IGN);
295 signal(SIGHUP, SIG_IGN);
296 if (rename(archive_name, backup_archive_name) < 0)
297 fatal_error(archive_name);
298 recover_archive_when_interrupt = TRUE;
299 signal(SIGINT, interrupt);
300 signal(SIGHUP, interrupt);
304 /* ------------------------------------------------------------------------ */
306 report_archive_name_if_different()
308 if (!quiet && new_archive_name == new_archive_name_buffer) {
309 /* warning at old archive is SFX */
310 printf("New archive file is \"%s\"\n", new_archive_name);
314 /* ------------------------------------------------------------------------ */
315 #ifdef TMP_FILENAME_TEMPLATE
317 temporary_to_new_archive_file(new_archive_size)
318 long new_archive_size;
322 oafp = xfopen(temporary_name, READ_BINARY);
323 if (!strcmp(new_archive_name, "-")) {
325 writting_filename = "starndard output";
328 nafp = xfopen(new_archive_name, WRITE_BINARY);
329 writting_filename = archive_name;
331 reading_filename = temporary_name;
332 copyfile(oafp, nafp, new_archive_size, 0);
337 recover_archive_when_interrupt = FALSE;
338 unlink(temporary_name);
340 remove_temporary_at_error = FALSE;
343 temporary_to_new_archive_file(new_archive_size)
344 long new_archive_size;
347 p = (char *) strrchr(new_archive_name, '/');
348 p = p ? p + 1 : new_archive_name;
349 unlink(new_archive_name);
350 if (rename(temporary_name, p) < 0) {
351 fprintf(stderr, "Can't rename temporary_name '%s'\n", new_archive_name);
357 /* ------------------------------------------------------------------------ */
359 set_archive_file_mode()
364 if (archive_file_gid < 0) {
365 umask(umask_value = umask(0));
366 archive_file_mode = (~umask_value) & 0666; /* rw-rw-rw- */
367 if (stat(".", &stbuf) >= 0)
368 archive_file_gid = stbuf.st_gid;
370 if (archive_file_gid >= 0)
371 chown(new_archive_name, getuid(), archive_file_gid);
373 chmod(new_archive_name, archive_file_mode);
376 /* ------------------------------------------------------------------------ */
377 /* REMOVE FILE/DIRECTORY */
378 /* ------------------------------------------------------------------------ */
387 if (GETSTAT(name, &stbuf) < 0) {
388 warning("Cannot access", name);
390 else if (is_directory(&stbuf)) {
391 if (find_files(name, &filec, &filev)) {
392 remove_files(filec, filev);
393 free_files(filec, filev);
396 warning("Cannot open directory", name);
399 printf("REMOVE DIRECTORY %s\n", name);
400 else if (rmdir(name) < 0)
401 warning("Cannot remove directory", name);
403 printf("Removed %s.\n", name);
405 else if (is_regularfile(&stbuf)) {
407 printf("REMOVE FILE %s.\n", name);
408 else if (unlink(name) < 0)
409 warning("Cannot remove", name);
411 printf("Removed %s.\n", name);
414 else if (is_symlink(&stbuf)) {
416 printf("REMOVE SYMBOLIC LINK %s.\n", name);
417 else if (unlink(name) < 0)
418 warning("Cannot remove", name);
420 printf("Removed %s.\n", name);
424 error("Cannot remove (not a file or directory)", name);
429 remove_files(filec, filev)
435 for (i = 0; i < filec; i++)
436 remove_one(filev[i]);
439 /* ------------------------------------------------------------------------ */
441 /* ------------------------------------------------------------------------ */
449 boolean old_archive_exist;
450 long new_archive_size;
452 /* exit if no operation */
453 if (!update_if_newer && cmd_filec == 0) {
454 error("No files given in argument, do nothing.", "");
458 /* open old archive if exist */
459 if ((oafp = open_old_archive()) == NULL)
460 old_archive_exist = FALSE;
462 old_archive_exist = TRUE;
464 if (update_if_newer && cmd_filec == 0 && !oafp)
465 fatal_error(archive_name); /* exit if cannot execute
466 * automatic update */
469 if (new_archive && old_archive_exist) {
474 if (oafp && archive_is_msdos_sfx1(archive_name)) {
475 skip_msdos_sfx1_code(oafp);
476 build_standard_archive_name(new_archive_name_buffer, archive_name);
477 new_archive_name = new_archive_name_buffer;
480 new_archive_name = archive_name;
483 /* build temporary file */
485 nafp = build_temporary_file();
487 /* find needed files when automatic update */
488 if (update_if_newer && cmd_filec == 0)
489 find_update_files(oafp);
491 /* build new archive file */
492 /* cleaning arguments */
493 cleaning_files(&cmd_filec, &cmd_filev);
494 if (cmd_filec == 0) {
502 for (i = 0; i < cmd_filec; i++)
503 oafp = append_it(cmd_filev[i], oafp, nafp);
505 old_header = ftell(oafp);
506 while (get_header(oafp, &ahdr)) {
508 fseek(oafp, ahdr.packed_size, SEEK_CUR);
510 fseek(oafp, old_header, SEEK_SET);
511 copy_old_one(oafp, nafp, &ahdr);
513 old_header = ftell(oafp);
518 write_archive_tail(nafp);
519 new_archive_size = ftell(nafp);
523 /* build backup archive file */
524 if (old_archive_exist)
527 report_archive_name_if_different();
529 /* copy temporary file to new archive file */
530 if (!noexec && (!strcmp(new_archive_name, "-") ||
531 rename(temporary_name, new_archive_name) < 0))
532 temporary_to_new_archive_file(new_archive_size);
534 /* set new archive file mode/group */
535 set_archive_file_mode();
537 /* remove archived files */
538 if (delete_after_append)
539 remove_files(cmd_filec, cmd_filev);
544 /* ------------------------------------------------------------------------ */
549 long new_archive_size;
551 /* open old archive if exist */
552 if ((oafp = open_old_archive()) == NULL)
553 fatal_error(archive_name);
556 /* exit if no operation */
557 if (cmd_filec == 0) {
559 warning("No files given in argument, do nothing.", "");
563 if (archive_is_msdos_sfx1(archive_name)) {
564 skip_msdos_sfx1_code(oafp);
565 build_standard_archive_name(new_archive_name_buffer, archive_name);
566 new_archive_name = new_archive_name_buffer;
569 new_archive_name = archive_name;
572 /* build temporary file */
574 nafp = build_temporary_file();
576 /* build new archive file */
581 write_archive_tail(nafp);
582 new_archive_size = ftell(nafp);
586 /* build backup archive file */
589 /* 1999.5.24 t.oka */
590 if(!noexec && new_archive_size <= 1){
591 unlink(temporary_name);
592 printf("New archive file \"%s\" is not created because it would be empty.\n", new_archive_name);
596 report_archive_name_if_different();
598 /* copy temporary file to new archive file */
599 if (!noexec && rename(temporary_name, new_archive_name) < 0)
600 temporary_to_new_archive_file(new_archive_size);
602 /* set new archive file mode/group */
603 set_archive_file_mode();
608 /* for symbolic link name. t.okamoto 96/2/20 */
609 int strcmp_filename( str1, str2 )
616 while (*p != 0 && *q != 0) {
618 if (*q == 0) return 0;
619 else if (*q != '|') return -1;
620 } else if (*q == '|') {
621 if (*p == 0) return 0;
622 else if (*q != '|') return 1;
623 } else if (*p != *q) break;
626 return (int)*p-(int)*q;
630 /* Local Variables: */
633 /* compile-command:"gcc -c lhadd.c" */