home *** CD-ROM | disk | FTP | other *** search
/ Liren Large Software Subsidy 7 / 07.iso / c / c004 / 1.ddi / CTCMPC.C < prev    next >
Encoding:
C/C++ Source or Header  |  1989-04-18  |  8.4 KB  |  346 lines
  1. /*
  2.  *    compact file
  3.  *
  4.  *    This program is the CONFIDENTIAL and PROPRIETARY property 
  5.  *    of FairCom(R) Corporation. Any unauthorized use, reproduction or
  6.  *    transfer of this program is strictly prohibited.
  7.  *
  8.  *      Copyright (c) 1985, 1986, 1987, 1988, 1989 FairCom Corporation
  9.  *    (Subject to limited distribution and
  10.  *     restricted disclosure only.)
  11.  *    *** ALL RIGHTS RESERVED ***
  12.  *
  13.  *    4006 West Broadway
  14.  *    Columbia, MO 65203
  15.  *
  16.  *
  17.  *    c-tree(R)    Version 4.3
  18.  *            Release C 
  19.  *            February 7, 1989 17:30
  20.  *
  21.  */
  22.  
  23.  
  24. #include "ctstdr.h"        /* standard i/o header         */
  25. #include "ctoptn.h"        /* c-tree configuration options */
  26. #include "cterrc.h"        /* c-tree error codes        */
  27. #include "ctstrc.h"        /* c-tree data structures    */
  28. #include "ctgvar.h"        /* c-tree global variables    */
  29. #include "ctvrec.h"        /* variable length header    */
  30.  
  31. #define TMP_NAME "CTREE.TMP"
  32. #define OLDFIL     0
  33. #define NEWFIL     1
  34.  
  35. POINTER FRSKEY(),NXTKEY(),NEWREC();
  36. COUNT   REDREC(),WRTREC(),CREMEM(),LOADKEY();
  37. COUNT   INTREE(),OPNFIL(),CLSFIL(),CREDAT(),CREIDX(),mbclos(),wrthdr();
  38. TEXT   *mballc();
  39.  
  40. #ifdef VARLDATA
  41. POINTER NEWVREC();
  42. COUNT   getvhdr(),putvhdr(),RDVREC(),WRTVREC();
  43. #endif
  44.  
  45. main (argc,argv)
  46. int   argc;
  47. TEXT *argv[];
  48. {
  49.     TEXT fname[MAX_NAME];
  50.  
  51.     VOID compact();
  52.  
  53.     printf("\n\nc-tree file compaction utility\nVersion 4.3 Release C Beta\n");
  54.     printf("Copyright 1985, 1988, 1989 FairCom Corporation\n");
  55.     printf(
  56. "\nThe compacted file will be named %s. Any existing file with this\n",TMP_NAME);
  57.     printf("\tname will first be deleted!\n");
  58.     if (argc > 1)
  59.         strcpy(fname,*++argv);
  60.     else {
  61.         printf("\nEnter file name >> ");
  62.         gets(ct_buf);
  63.         cpybuf(fname,ct_buf,MAX_NAME);
  64.     }
  65.     printf("\n\n\t*** Please wait while %s is compacted ***\n",fname);
  66.     compact(fname);
  67.     printf("\n\nEnd of File Compaction");
  68.     if (uerr_cod)
  69.         printf(" - Error Code %d\n\n",uerr_cod);
  70.     else
  71.         printf(".\n\n");
  72.     exit(0);
  73. }
  74.  
  75. VOID compact(fname)
  76. TEXT *fname;
  77. {
  78.     VOID comdat(),comvat(),comidx();
  79.  
  80.     /* increse the last parameter of INTREE (4) for nodes larger than
  81.        512 bytes
  82.     */
  83.     if (INTREE(15,2 * (MAXMEMB + 1),4)) {
  84.         printf("\nNot enough memory space for INTREE\n");
  85.         return;
  86.     }
  87.  
  88.     if (OPNFIL(OLDFIL,fname,(EXCLUSIVE | PERMANENT))) {
  89.         printf("\nCould not properly open %s\n",fname);
  90.         return;
  91.     }
  92.  
  93.     remove(TMP_NAME);
  94.  
  95.     switch (ct_key->clstyp) {
  96. case DAT_CLOSE:
  97.         comdat();
  98.         break;
  99. case IDX_CLOSE:
  100.         comidx();
  101.         break;
  102. case VAT_CLOSE:
  103.         comvat();
  104.         break;
  105. default:
  106.         printf("\nUnknown file type (%d)\nCall FairCom\n",ct_key->clstyp);
  107.     }
  108. }
  109.  
  110. VOID comdat()
  111. {
  112.     COUNT   filemd,datlen;
  113.     LONG    delrec;
  114.     TEXT   *recbuf;
  115.     POINTER recbyt,newbyt;
  116.     CTFILE *ctnum;
  117.  
  118.     filemd = (ct_key->flmode & ~VLENGTH);
  119.     datlen = ct_key->reclen;
  120.     ctnum  = ct_key + NEWFIL;
  121.     delrec = 0L;
  122.  
  123.     if ((recbuf = mballc(1,datlen)) == NULL) {
  124.         printf("\nCould not allocate space for record buffer\n");
  125.         return;
  126.     }
  127.  
  128.     if (CREDAT(NEWFIL,TMP_NAME,datlen,ct_key->extsiz,filemd) ||
  129.         CLSFIL(NEWFIL,0) ||
  130.         OPNFIL(NEWFIL,TMP_NAME,filemd)) {
  131.         printf("\nCould not create data file %s\n",TMP_NAME);
  132.         return;
  133.     }
  134.  
  135.     recbyt = ((SECSIZ + datlen - 1) / datlen) * datlen;
  136.     while (REDREC(OLDFIL,recbyt,recbuf) == NO_ERROR) {
  137.         if (recbuf[0] != DELFLG) {
  138.             if ((newbyt = NEWREC(NEWFIL)) == DRNZERO) {
  139.                 printf("\nCould not get new record\n");
  140.                 return;
  141.             }
  142.             if (WRTREC(NEWFIL,newbyt,recbuf)) {
  143.                 printf("\nCould not write new record\n");
  144.                 return;
  145.             }
  146.             LOKREC(NEWFIL,FREE,newbyt);
  147.         } else
  148.             delrec++;
  149.         recbyt += datlen;
  150.     }
  151.  
  152.     if (delrec)
  153.         ctnum->updflg = COMPACT;
  154.     else
  155.         ctnum->updflg = NO;
  156.     uerr_cod = 0;
  157.     if (wrthdr(ctnum)) {
  158.         printf("\nCould not write new header record at close\n");
  159.         return;
  160.     }
  161.     if (mbclos(ctnum,COMPLETE)) {
  162.         printf("\nCould not close temporary file\n");
  163.         return;
  164.     }
  165.     if (delrec)
  166.         printf(
  167. "\n\n%ld deleted records were removed.\nBe sure to rebuild indices.\n",
  168.             delrec);
  169.     else
  170.         printf("\n\nNo deleted records were encountered.\n");
  171.         
  172. }
  173.  
  174.  
  175. VOID comvat()
  176. {
  177. #ifdef VARLDATA
  178.     COUNT   filemd,datlen;
  179.     LONG    delrec,savpos,chkpos;
  180.     TEXT   *recbuf;
  181.     POINTER recbyt,newbyt;
  182.     CTFILE *ctnum;
  183.     VRLEN   bufsiz;
  184.     VHDR    vrhdr;
  185.  
  186.     COUNT   tstrec();
  187.  
  188.     filemd = (ct_key->flmode | VLENGTH);
  189.     datlen = ct_key->reclen;
  190.     bufsiz = datlen;
  191.     ctnum  = ct_key + NEWFIL;
  192.     delrec = 0L;
  193.  
  194.  
  195.     if ((recbuf = mballc(1,datlen)) == NULL) {
  196.         printf("\nCould not allocate space for record buffer\n");
  197.         return;
  198.     }
  199.  
  200.     if (CREDAT(NEWFIL,TMP_NAME,datlen,ct_key->extsiz,filemd) ||
  201.         CLSFIL(NEWFIL,0) ||
  202.         OPNFIL(NEWFIL,TMP_NAME,filemd)) {
  203.         printf("\nCould not create variable length data file %s\n",
  204.             TMP_NAME);
  205.         return;
  206.     }
  207.  
  208.     recbyt   = ct_key->recsiz + SIZVHDR;
  209.     while (tstrec(ct_key,recbyt) == NO_ERROR && getvhdr(ct_key,recbyt,&vrhdr) ==
  210.         NO_ERROR) {
  211.         if (vrhdr.recmrk == VACT_FLAG) {
  212.             if (bufsiz < vrhdr.urclen) {
  213.                 mbfree(recbuf);
  214.                 bufsiz = vrhdr.urclen;
  215.                 if ((recbuf = mballc(1,bufsiz)) == NULL) {
  216.                     printf(
  217. "\nCould not allocate %u bytes for record buffer\n",bufsiz);
  218.                     return;
  219.                 }
  220.             }
  221.             if (RDVREC(OLDFIL,recbyt,recbuf,bufsiz)) {
  222.                 printf("\nCould not read existing record\n");
  223.                 return;
  224.             }
  225.             if ((newbyt = NEWVREC(NEWFIL,vrhdr.urclen)) ==
  226.                 DRNZERO) {
  227.                 printf("\nCould not get new record\n");
  228.                 return;
  229.             }
  230.             if (WRTVREC(NEWFIL,newbyt,recbuf,vrhdr.urclen)) {
  231.                 printf("\nCould not write new record\n");
  232.                 return;
  233.             }
  234.             LOKREC(NEWFIL,FREE,newbyt);
  235.         } else if (vrhdr.recmrk == VNOD_FLAG ||
  236.             vrhdr.recmrk == VDEL_FLAG)
  237.             delrec += (vrhdr.trclen + SIZVHDR);
  238.         else { /* bad recmrk. scan until good mark found */
  239.             savpos = recbyt - SIZVHDR;
  240.             printf("\nBAD recmrk <%4x> at offset %lx",
  241.                 vrhdr.recmrk,savpos);
  242.             while (tstrec(ct_key,++recbyt) == NO_ERROR &&
  243.               getvhdr(ct_key,recbyt,&vrhdr) == NO_ERROR) {
  244.                 if (vrhdr.recmrk == VACT_FLAG) {
  245.                 chkpos = recbyt + vrhdr.trclen + SIZVHDR;
  246.                 if (getvhdr(ct_key,chkpos,&vrhdr) == NO_ERROR &&
  247.                    (vrhdr.recmrk == VACT_FLAG ||
  248.                     vrhdr.recmrk == VNOD_FLAG ||
  249.                     vrhdr.recmrk == VDEL_FLAG)) {
  250.                     getvhdr(ct_key,recbyt,&vrhdr);
  251.                     printf(
  252. "\nGood recmrk acquired at offset %lx",recbyt - SIZVHDR);
  253.                     break;
  254.                 }
  255.                 }
  256.             }
  257.             recbyt -= SIZVHDR;
  258.             vrhdr.trclen = 0;
  259.             delrec += (recbyt - savpos);
  260.         }
  261.         recbyt += (vrhdr.trclen + SIZVHDR);
  262.     }
  263.  
  264.     if (delrec)
  265.         ctnum->updflg = COMPACT;
  266.     else
  267.         ctnum->updflg = NO;
  268.     uerr_cod = 0;
  269.     if (wrthdr(ctnum)) {
  270.         printf("\nCould not write new header record at close\n");
  271.         return;
  272.     }
  273.     if (mbclos(ctnum,COMPLETE)) {
  274.         printf("\nCould not close temporary file\n");
  275.         return;
  276.     }
  277.     if (delrec)
  278.         printf(
  279. "\n\n%ld deleted bytes were removed.\nBe sure to rebuild indices.\n",
  280.             delrec);
  281.     else
  282.         printf("\n\nNo deleted records were encountered.\n");
  283. #else
  284.     printf("\n\nAttempt to compact variable record length data file.");
  285.     printf("\nCTCMPC compiled with variable length data records disabled.");
  286.     printf("\nRecompile with VARLDATA defined in CTOPTN.H\n");
  287. #endif
  288. }
  289.  
  290.  
  291. VOID comidx()
  292. {
  293.     POINTER recbyt,keycnt;
  294.     COUNT   filemd,nomemb,oldidx,newidx,k;
  295.     TEXT    keybuf[MAXLEN];
  296.     CTFILE *knum;
  297.  
  298.     filemd = (ct_key->flmode & ~VLENGTH);
  299.     newidx = (oldidx = OLDFIL) + (nomemb = ct_key->nmem) + 1;
  300.     if (CREIDX(newidx,TMP_NAME,ct_key->length,ct_key->ktype,ct_key->autodup,
  301.         nomemb,ct_key->extsiz,filemd)) {
  302.         printf("\nCould not create index file %s\n",TMP_NAME);
  303.         return;
  304.     }
  305.     for (k = 1,knum = ct_key + 1; k <= nomemb; k++,knum++)
  306.         if (CREMEM(newidx,knum->length,knum->ktype,knum->autodup,
  307.             k)) {
  308.             printf("\nCould not initialize additional index #%d\n",
  309.                 k);
  310.             return;
  311.         }
  312.     if (CLSFIL(newidx,0) ||
  313.         OPNFIL(newidx,TMP_NAME,filemd)) {
  314.         printf("\nCould not reopen index file %s\n",TMP_NAME);
  315.         return;
  316.     }
  317.  
  318.     for (k = 0; k <= nomemb; k++,oldidx++,newidx++) {
  319.         keycnt = DRNZERO;
  320.         recbyt = FRSKEY(oldidx,keybuf);
  321.         while (recbyt) {
  322.         if (keycnt == DRNZERO)
  323.             filemd = INCADD;
  324.         else
  325.             filemd = REGADD;
  326.         if (LOADKEY(newidx,keybuf,recbyt,filemd)) {
  327.             printf("\nCould not add key to new index (%d)\n",k);
  328.             return;
  329.         } else {
  330.             keycnt++;
  331.             recbyt = NXTKEY(oldidx,keybuf);
  332.         }
  333.         }
  334.         printf("\n%ld key values in %s (%d).\n",keycnt,TMP_NAME,k);
  335.         LOADKEY(newidx,NULL,DRNZERO,DECADD);
  336.     }
  337.  
  338.  
  339.     if (CLSFIL(OLDFIL + nomemb + 1,COMPLETE)) {
  340.         printf("\nCould not close temporary file\n");
  341.         return;
  342.     }
  343. }
  344.  
  345. /* end of ctcmpc.c */
  346.