proc.c (d0fa49b78d1f40d84ec76c363cdc38cf128511dd) | proc.c (406d62731eff92f06723c04de94992d94a293145) |
---|---|
1/* 2 * CDDL HEADER START 3 * 4 * The contents of this file are subject to the terms of the 5 * Common Development and Distribution License (the "License"). 6 * You may not use this file except in compliance with the License. 7 * 8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE --- 9 unchanged lines hidden (view full) --- 18 * 19 * CDDL HEADER END 20 */ 21/* 22 * Copyright 2008 Sun Microsystems, Inc. All rights reserved. 23 * Use is subject to license terms. 24 */ 25 | 1/* 2 * CDDL HEADER START 3 * 4 * The contents of this file are subject to the terms of the 5 * Common Development and Distribution License (the "License"). 6 * You may not use this file except in compliance with the License. 7 * 8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE --- 9 unchanged lines hidden (view full) --- 18 * 19 * CDDL HEADER END 20 */ 21/* 22 * Copyright 2008 Sun Microsystems, Inc. All rights reserved. 23 * Use is subject to license terms. 24 */ 25 |
26 | |
27/* 28 * Main processor for auditreduce. 29 * Mproc() is the entry point for this module. It is the only visible 30 * function in this module. 31 */ 32 33#include <sys/types.h> 34#include <locale.h> --- 442 unchanged lines hidden (view full) --- 477 (void) fprintf(stderr, "get_recs: %d ret %d recno %d\n", 478 pcb->pcb_procno, ret, pcb->pcb_nrecs + 1); 479#endif 480 /* 481 * See if entire file is after the time window specified. 482 * Must be check here because the start time of the file name 483 * may be after the first record(s). 484 */ | 26/* 27 * Main processor for auditreduce. 28 * Mproc() is the entry point for this module. It is the only visible 29 * function in this module. 30 */ 31 32#include <sys/types.h> 33#include <locale.h> --- 442 unchanged lines hidden (view full) --- 476 (void) fprintf(stderr, "get_recs: %d ret %d recno %d\n", 477 pcb->pcb_procno, ret, pcb->pcb_nrecs + 1); 478#endif 479 /* 480 * See if entire file is after the time window specified. 481 * Must be check here because the start time of the file name 482 * may be after the first record(s). 483 */ |
485 if (pcb->pcb_nrecs == 0 && (pcb->pcb_flags & PF_FILE)) { | 484 if (pcb->pcb_nrecs == 0 && (pcb->pcb_flags & PF_USEFILE)) { |
486 /* 487 * If the first record read failed then use the time 488 * that was in the filename to judge. 489 */ 490 if (ret > 0) 491 (pcb->pcb_cur)->fcb_start = secs; 492 if (!f_all && (m_before <= (pcb->pcb_cur)->fcb_start)) { 493 (void) fclose(pcb->pcb_fpr); /* ignore file */ --- 10 unchanged lines hidden (view full) --- 504 } 505 } 506 /* Succesful acquisition of a record. */ 507 if (ret > 0) { 508 pcb->pcb_time = secs; /* time of record */ 509 pcb->pcb_nrecs++; /* # of read recs from stream */ 510 nrecs++; /* # of recs read this call */ 511 /* Only check record if at bottom of process tree. */ | 485 /* 486 * If the first record read failed then use the time 487 * that was in the filename to judge. 488 */ 489 if (ret > 0) 490 (pcb->pcb_cur)->fcb_start = secs; 491 if (!f_all && (m_before <= (pcb->pcb_cur)->fcb_start)) { 492 (void) fclose(pcb->pcb_fpr); /* ignore file */ --- 10 unchanged lines hidden (view full) --- 503 } 504 } 505 /* Succesful acquisition of a record. */ 506 if (ret > 0) { 507 pcb->pcb_time = secs; /* time of record */ 508 pcb->pcb_nrecs++; /* # of read recs from stream */ 509 nrecs++; /* # of recs read this call */ 510 /* Only check record if at bottom of process tree. */ |
512 if (pcb->pcb_flags & PF_FILE) { | 511 if (pcb->pcb_flags & PF_USEFILE) { |
513 check_order(pcb); /* check time sequence */ 514 if ((ret2 = check_rec(pcb)) == 0) { 515 pcb->pcb_nprecs++; 516 getrec = FALSE; 517 } else if (ret2 == -2) { 518 /* error */ 519 getrec = FALSE; /* get no more recs */ 520 alldone = TRUE; /* quit this file */ --- 15 unchanged lines hidden (view full) --- 536 if (alldone == TRUE) { 537#if AUDIT_FILE 538 get_trace(pcb); 539#endif 540 /* Error in record read. Display messages. */ 541 if (ret < 0 || ret2 == -2) { 542 pcb->pcb_nrecs++; /* # of read records */ 543 if (!f_quiet) { | 512 check_order(pcb); /* check time sequence */ 513 if ((ret2 = check_rec(pcb)) == 0) { 514 pcb->pcb_nprecs++; 515 getrec = FALSE; 516 } else if (ret2 == -2) { 517 /* error */ 518 getrec = FALSE; /* get no more recs */ 519 alldone = TRUE; /* quit this file */ --- 15 unchanged lines hidden (view full) --- 535 if (alldone == TRUE) { 536#if AUDIT_FILE 537 get_trace(pcb); 538#endif 539 /* Error in record read. Display messages. */ 540 if (ret < 0 || ret2 == -2) { 541 pcb->pcb_nrecs++; /* # of read records */ 542 if (!f_quiet) { |
544 if (pcb->pcb_flags & PF_FILE) { | 543 if (pcb->pcb_flags & PF_USEFILE) { |
545 /* Ignore if this is not_terminated. */ 546 if (!strstr((pcb->pcb_cur)->fcb_file, 547 "not_terminated")) { 548(void) fprintf(stderr, gettext("%s read error in %s at record %d.\n"), ar, 549 (pcb->pcb_cur)->fcb_file, pcb->pcb_nrecs); 550 } 551 } else { 552(void) fprintf(stderr, gettext("%s read error in pipe at record %d.\n"), ar, 553 pcb->pcb_nrecs); 554 } 555 } 556 } else { 557 /* 558 * Only mark infile for deleting if we have succesfully 559 * processed all of it. 560 */ | 544 /* Ignore if this is not_terminated. */ 545 if (!strstr((pcb->pcb_cur)->fcb_file, 546 "not_terminated")) { 547(void) fprintf(stderr, gettext("%s read error in %s at record %d.\n"), ar, 548 (pcb->pcb_cur)->fcb_file, pcb->pcb_nrecs); 549 } 550 } else { 551(void) fprintf(stderr, gettext("%s read error in pipe at record %d.\n"), ar, 552 pcb->pcb_nrecs); 553 } 554 } 555 } else { 556 /* 557 * Only mark infile for deleting if we have succesfully 558 * processed all of it. 559 */ |
561 if (pcb->pcb_flags & PF_FILE) | 560 if (pcb->pcb_flags & PF_USEFILE) |
562 (pcb->pcb_cur)->fcb_flags |= FF_DELETE; 563 } 564 if (fclose(pcb->pcb_fpr) == EOF) { 565 if (!f_quiet) { | 561 (pcb->pcb_cur)->fcb_flags |= FF_DELETE; 562 } 563 if (fclose(pcb->pcb_fpr) == EOF) { 564 if (!f_quiet) { |
566 if (pcb->pcb_flags & PF_FILE) { | 565 if (pcb->pcb_flags & PF_USEFILE) { |
567 str = (pcb->pcb_cur)->fcb_file; 568 } else { 569 str = "pipe"; 570 } 571 (void) fprintf(stderr, 572 gettext("%s couldn't close %s.\n"), 573 ar, str); 574 } --- 20 unchanged lines hidden (view full) --- 595 */ 596static void 597get_trace(pcb) 598audit_pcb_t *pcb; 599{ 600 /* 601 * For file give filename, too. 602 */ | 566 str = (pcb->pcb_cur)->fcb_file; 567 } else { 568 str = "pipe"; 569 } 570 (void) fprintf(stderr, 571 gettext("%s couldn't close %s.\n"), 572 ar, str); 573 } --- 20 unchanged lines hidden (view full) --- 594 */ 595static void 596get_trace(pcb) 597audit_pcb_t *pcb; 598{ 599 /* 600 * For file give filename, too. 601 */ |
603 if (pcb->pcb_flags & PF_FILE) { | 602 if (pcb->pcb_flags & PF_USEFILE) { |
604 (void) fprintf(stderr, "%s closed %s: %d records read recs: \ 605 %d record written.\n", ar, (pcb->pcb_cur)->fcb_file, 606 pcb->pcb_nrecs, pcb->pcb_nprecs); 607 } else { 608 (void) fprintf(stderr, "%s closed pipe: %d records read: \ 609 %d records written .\n", ar, pcb->pcb_nrecs, 610 pcb->pcb_nprecs); 611 } --- 437 unchanged lines hidden --- | 603 (void) fprintf(stderr, "%s closed %s: %d records read recs: \ 604 %d record written.\n", ar, (pcb->pcb_cur)->fcb_file, 605 pcb->pcb_nrecs, pcb->pcb_nprecs); 606 } else { 607 (void) fprintf(stderr, "%s closed pipe: %d records read: \ 608 %d records written .\n", ar, pcb->pcb_nrecs, 609 pcb->pcb_nprecs); 610 } --- 437 unchanged lines hidden --- |