home *** CD-ROM | disk | FTP | other *** search
- /* Copyright (c) 1994 Burra Gopal, Udi Manber. All Rights Reserved. */
- #include "glimpse.h"
- #include "defs.h"
-
- #if BG_DEBUG
- extern FILE *debug;
- #endif /*BG_DEBUG*/
- extern char *INDEX_DIR;
- extern int Only_first;
- extern int OneFilePerBlock;
- extern int StructuredIndex;
- extern int WHOLEFILESCOPE;
- extern unsigned int dest_index_set[REAL_PARTITION];
- extern unsigned char dest_index_buf[REAL_INDEX_BUF];
- extern int mask_int[32];
- extern int errno;
- extern int ByteLevelIndex;
- extern int NOBYTELEVEL;
- extern int OPTIMIZEBYTELEVEL;
- extern int RegionLimit;
- extern struct offsets **src_offset_table;
- extern unsigned int multi_dest_index_set[MAXNUM_PAT][REAL_PARTITION];
- extern struct offsets **multi_dest_offset_table[MAXNUM_PAT];
- extern char *index_argv[MAX_ARGS];
- extern int index_argc;
- extern CHAR GProgname[MAXNAME];
-
- free_list(p1)
- struct offsets **p1;
- {
- struct offsets *tp1;
-
- while (*p1 != NULL) {
- tp1 = *p1;
- *p1 = (*p1)->next;
- my_free(tp1, sizeof(struct offsets));
- }
- }
-
- /* Unions offset lists list2 with list1 sorted in increasing order (deletes elements from list2) => changes both list1 and list2: f += #elems added */
- sorted_union(list1, list2, f, pf, cf)
- struct offsets **list1, **list2;
- int *f, pf, cf;
- {
- register struct offsets **p1 = list1, *p2;
- register int count = *f; /* don't update *f if setting NOBYTELEVEL */
-
- if (NOBYTELEVEL) { /* cannot come here! */
- free_list(list1);
- free_list(list2);
- return;
- }
- if ( ((pf > MIN_OCCURRENCES) && (count > MAX_UNION * pf)) || (count > MAX_ABSOLUTE*OneFilePerBlock) ||
- ((count > MIN_OCCURRENCES) && (pf > MAX_UNION * count)) || (pf > MAX_ABSOLUTE*OneFilePerBlock) ) {
- /* enough if we check the second condition at the beginning since it won't surely be satisfied after this when count ++ */
- NOBYTELEVEL = 1;
- return;
- }
- while (*list2 != NULL) {
- /* extract 1st element, update list2 */
- p2 = *list2;
- *list2 = (*list2)->next;
- p2->next = NULL;
-
- /* find position to insert p2, and do so */
- p1 = list1;
- while (((*p1) != NULL) && ((*p1)->offset < p2->offset)) p1 = &(*p1)->next;
- if (*p1 == NULL) { /* end of list1: append list2 to it and return */
- *p1 = p2;
- p2->next = *list2;
- *list2 = NULL;
- if (cf > 0) count = *f + cf;
- if ( ((pf > MIN_OCCURRENCES) && (count > MAX_UNION * pf)) || (count > MAX_ABSOLUTE*OneFilePerBlock)) {
- NOBYTELEVEL = 1;
- return;
- }
- *f = count;
- return;
- }
- else if (p2->offset == (*p1)->offset) my_free(p2, sizeof(struct offsets));
- else {
- p2->next = *p1;
- *p1 = p2;
- count ++;
- if ( ((pf > MIN_OCCURRENCES) && (count > MAX_UNION * pf)) || (count > MAX_ABSOLUTE*OneFilePerBlock) ) {
- NOBYTELEVEL = 1;
- return;
- }
- /* update list1 */
- list1 = &(*p1)->next;
- }
- }
- *f = count;
- }
-
- /* Intersects offset lists list2 with list1 sorted in increasing order (deletes elements from list2) => changes both list1 and list2 */
- sorted_intersection(filenum, list1, list2, f)
- struct offsets **list1, **list2;
- int *f;
- {
- register struct offsets **p1 = list1, *p2, *tp1;
- register int diff;
-
- if (NOBYTELEVEL) { /* cannot come here! */
- free_list(list1);
- free_list(list2);
- return;
- }
-
- /* find position to intersect list2, and do so: REMEBER: list1 is in increasing order, and so is list2 !!! */
- p1 = list1;
- while ( ((*p1) != NULL) && (*list2 != NULL) ) {
- diff = (*list2)->offset - (*p1)->offset;
- if ( (diff >= -RegionLimit) && (diff <= RegionLimit) ) {
- (*p1)->done = 1; /* p1 is in */
- p1 = &(*p1)->next;
- /* Can't increment p2 here since it might keep others after p1 also in */
- }
- else {
- if (diff < 0) {
- p2 = *list2;
- *list2 = (*list2)->next;
- my_free(p2, sizeof(struct offsets));
- /* p1 can intersect with list2's next */
- }
- else {
- if((*p1)->done) p1 = &(*p1)->next; /* imposs */
- else {
- tp1 = *p1;
- *p1 = (*p1)->next;
- my_free(tp1, sizeof(struct offsets));
- (*f) --;
- }
- /* list2 can intersect with p1's next */
- }
- }
- }
-
- while (*list2 != NULL) {
- p2 = *list2;
- *list2 = (*list2)->next;
- my_free(p2, sizeof(struct offsets));
- }
-
- p1 = list1;
- while (*p1 != NULL) {
- if ((*p1)->done == 0) {
- tp1 = *p1;
- *p1 = (*p1)->next;
- my_free(tp1, sizeof(struct offsets));
- (*f) --;
- }
- else {
- (*p1)->done = 0; /* for the next round! */
- p1 = &(*p1)->next;
- }
- }
- }
-
- purge_offsets(p1)
- struct offsets **p1;
- {
- struct offsets *tp1;
-
- while (*p1 != NULL) {
- if ((*p1)->sign == 0) {
- tp1 = *p1;
- (*p1) = (*p1)->next;
- my_free(tp1, sizeof(struct offsets));
- }
- else p1 = &(*p1)->next;
- }
- }
-
- /* Returns 1 if it is a Universal set, 0 otherwise. Constraint: WORD_END_MARK/ALL_INDEX_MARK must occur at or after buffer[0] */
- get_set(buffer, set, offset_table, patlen, pattern, patattr, outfile, partfp, frequency, prevfreq)
- unsigned char *buffer;
- unsigned int *set;
- struct offsets **offset_table;
- int patlen;
- char *pattern;
- int patattr;
- FILE *outfile;
- FILE *partfp;
- int *frequency, prevfreq;
- {
- int bdx2, j;
- int ret;
- int x=0, y=0, diff, even_words=1, prevy;
- int indexattr = 0;
- struct offsets *o, *tailo, *heado;
- int delim = encode8b(0);
- int curfreq = 0;
-
- /* buffer[0] is '\n', search must start from buffer[1] */
- if (StructuredIndex) {
- if (StructuredIndex < MaxNum8bPartition - 1) {
- indexattr = decode8b(buffer[1]);
- bdx2 = 2;
- }
- else if (StructuredIndex < MaxNum16bPartition - 1) {
- indexattr = decode16b((buffer[1] << 8) | buffer[2]);
- bdx2 = 3;
- }
- else {
- indexattr = decode32b((buffer[1] << 24) | (buffer[2] << 16) | (buffer[3] << 8) | (buffer[4]));
- bdx2 = 5;
- }
- /* printf("i=%d p=%d\n", indexattr, patattr); */
-
- if ((patattr > 0) && (indexattr != patattr)) {
- #if BG_DEBUG
- fprintf(debug, "indexattr=%d DOES NOT MATCH patattr=%d\n", indexattr, patattr);
- #endif /*BG_DEBUG*/
- return 0;
- }
- /* else, pat_attr is 0 => everything, OR, attribute matches */
- }
- else bdx2 = 1;
-
- if (OneFilePerBlock)
- while((bdx2<REAL_INDEX_BUF+1) && (buffer[bdx2] != WORD_END_MARK) && (buffer[bdx2] != ALL_INDEX_MARK)) bdx2++;
- else while((bdx2<REAL_INDEX_BUF+1) && (buffer[bdx2] != WORD_END_MARK)) bdx2++;
- if (bdx2 >= REAL_INDEX_BUF+1) return 0;
- if (OneFilePerBlock && (buffer[bdx2] == ALL_INDEX_MARK)) {
- /* A intersection Univ-set = A: so src_index_set won't change; A union Univ-set = Univ-set: so src_index_set = all 1s */
- #if BG_DEBUG
- buffer[bdx2] = '\0';
- fprintf(debug, "All indices search for %s\n", buffer + 1);
- buffer[bdx2] = ALL_INDEX_MARK;
- #endif /*BG_DEBUG*/
- set[REAL_PARTITION - 1] = 1;
- for(bdx2=0; bdx2<round(OneFilePerBlock, 8*sizeof(int)) - 1; bdx2++) {
- set[bdx2] = 0xffffffff;
- }
- set[bdx2] = 0;
- for (j=0; j<8*sizeof(int); j++) {
- if (bdx2*8*sizeof(int) + j >= OneFilePerBlock) break;
- set[bdx2] |= mask_int[j];
- }
- if (ByteLevelIndex) NOBYTELEVEL = 1;
- return 1;
- }
- else if (!OneFilePerBlock) { /* check only if index+partitions are NOT split */
- #if BG_DEBUG
- buffer[bdx2] = '\0';
- fprintf(debug, "memagrep-line: %s\t\tpattern: %s\n", buffer, pattern);
- #endif /*BG_DEBUG*/
- /* ignore if pattern with all its options matches block number sequence: bg+udi: Feb/16/93 */
- buffer[bdx2] = '\n'; /* memagrep needs buffer to end with '\n' */
- if ((ret = memagrep_search(patlen, pattern, bdx2+1, buffer, 0, outfile)) <= 0) return 0;
- else buffer[bdx2] = WORD_END_MARK;
- }
- bdx2++; /* bdx2 now points to the first byte of the offset */
-
- even_words = 1;
- /* Code identical to that in merge_in() in glimpseindex */
- if (OneFilePerBlock) {
- get_block_numbers(&buffer[bdx2], &buffer[bdx2], partfp);
- while((bdx2<REAL_INDEX_BUF) && (buffer[bdx2] != '\n') && (buffer[bdx2] != '\0')) {
- /* First get the file name */
- x = 0;
- if (ByteLevelIndex) {
- if (OneFilePerBlock <= MaxNum8bPartition) {
- x = decode8b(buffer[bdx2]);
- bdx2 ++;
- }
- else {
- x = (buffer[bdx2] << 8) | buffer[bdx2+1];
- x = decode16b(x);
- bdx2 += 2;
- }
- }
- else if (OneFilePerBlock <= MaxNum8bPartition) {
- x = decode8b(buffer[bdx2]);
- bdx2 ++;
- }
- else if (OneFilePerBlock <= MaxNum12bPartition) {
- if (even_words) {
- x = ((buffer[bdx2+1] & 0x0000000f) << 8) | buffer[bdx2];
- x = decode12b(x);
- bdx2 += 2;
- even_words = 0;
- }
- else { /* odd number of words so far */
- x = ((buffer[bdx2-1] & 0x000000f0) << 4) | buffer[bdx2];
- x = decode12b(x);
- bdx2 ++;
- even_words = 1;
- }
- }
- else if (OneFilePerBlock <= MaxNum16bPartition) {
- x = (buffer[bdx2] << 8) | buffer[bdx2+1];
- x = decode16b(x);
- bdx2 += 2;
- }
- set[block2index(x)] |= block2mask(x);
-
- prevy = 0;
- if (ByteLevelIndex) {
- heado = tailo = NULL;
- curfreq = 0;
- while ((bdx2<REAL_INDEX_BUF) && (buffer[bdx2] != '\n') && (buffer[bdx2] != '\0')) {
- y = decode8b(buffer[bdx2]);
- if ((y & 0x000000c0) == 0) { /* one byte offset */
- diff = y&0x0000003f;
- y = prevy + diff;
- bdx2 ++;
- }
- else if ((y & 0x000000c0) == 0x40) { /* two byte offset */
- diff = decode8b(buffer[bdx2+1]);
- y = prevy + (((y & 0x0000003f) * MaxNum8bPartition) + diff);
- bdx2 += 2;
- }
- else if ((y & 0x000000c0) == 0x80) { /* three byte offset */
- diff = decode16b((buffer[bdx2+1] << 8) | buffer[bdx2+2]);
- y = prevy + (((y & 0x0000003f) * MaxNum16bPartition) + diff);
- bdx2 += 3;
- }
- else { /* four byte offset */
- diff = decode24b((buffer[bdx2+1] << 16) | (buffer[bdx2+2] << 8) | buffer[bdx2+3]);
- y = prevy + (((y & 0x0000003f) * MaxNum24bPartition) + diff);
- bdx2 += 4;
- }
- prevy = y;
-
- curfreq ++;
-
- if (!Only_first && !NOBYTELEVEL && /* below borrowed from sorted_union */
- !(((prevfreq>MIN_OCCURRENCES)&&(curfreq+*frequency>MAX_UNION*prevfreq)) || (curfreq+*frequency>MAX_ABSOLUTE*OneFilePerBlock))) {
- /* These o's will be in sorted order. Just collect all of them and merge with &offset_table[x]. */
- o = (struct offsets *)my_malloc(sizeof(struct offsets));
- o->offset = y;
- o->next = NULL;
- o->sign = o->done = 0;
- if (heado == NULL) {
- heado = o;
- tailo = o;
- }
- else {
- tailo->next = o;
- tailo = o;
- }
- }
- else {
- if (heado != NULL) free_list(&heado);
- /* printf("1 "); */
- NOBYTELEVEL = 1; /* can't return since have to or the bitmasks */
- }
- if ((bdx2<REAL_INDEX_BUF) && (buffer[bdx2] == delim)) { /* look at offsets corr. to a new file now */
- bdx2 ++;
- break;
- }
- }
-
- if (heado == NULL) *frequency += curfreq;
- else if (!Only_first && !NOBYTELEVEL) {
- sorted_union(&offset_table[x], &heado, frequency, prevfreq, curfreq); /* this will free heado's elements and ++ *frequency */
- if (NOBYTELEVEL) *frequency += curfreq; /* can't return since have to or the bitmasks */
- if (heado != NULL) free_list(&heado);
- }
- }
- }
- }
- else {
- while((bdx2<MAX_INDEX_BUF) && (buffer[bdx2] != '\n') && (buffer[bdx2] != '\0') && (buffer[bdx2] < MAX_PARTITION)) {
- set[buffer[bdx2]] = 1;
- bdx2++;
- }
- }
-
- return 0;
- }
-
- /*
- * This is a very simple function: it gets the list of matched lines from the index,
- * and sets the block numbers corr. to files that need to be searched in "index_tab".
- * It also sets the file-offsets that have to be searched in "offset_tab" (byte-level).
- */
- get_index(infile, index_tab, offset_tab, pattern, patlen, patattr, index_argv, index_argc, outfile, partfp, parse, first_time)
- char *infile;
- unsigned int *index_tab;
- struct offsets **offset_tab;
- char *pattern;
- int patlen;
- int patattr;
- char *index_argv;
- int index_argc;
- FILE *outfile;
- FILE *partfp;
- int parse;
- int first_time;
- {
- int i=0, j, iii;
- FILE *f_in;
- struct offsets **offsetptr = multi_dest_offset_table[0];
- int ret=0;
-
- if (OneFilePerBlock && (parse & OR_EXP) && (index_tab[REAL_PARTITION - 1] == 1)) return 0;
- if((f_in = fopen(infile, "r")) == NULL) {
- fprintf(stderr, "%s: can't open for reading: %s/%s\n", GProgname, INDEX_DIR, infile);
- return -1;
- }
- if (OneFilePerBlock)
- for(i=0; i<round(OneFilePerBlock, 8*sizeof(int)); i++) {
- dest_index_set[i] = 0;
- }
- else for(i=0; i<MAX_PARTITION; i++) {
- dest_index_set[i] = 0;
- }
- dest_index_buf[0] = '\n'; /* memagrep needs buffer to begin with '\n' */
-
- dest_index_set[REAL_PARTITION - 2] = 0;
- while(fgets(dest_index_buf+1, REAL_INDEX_BUF, f_in)) {
- #if BG_DEBUG
- fprintf(debug, "index-line: %s", dest_index_buf+1);
- #endif /*BG_DEBUG*/
- if ((ret = get_set(&dest_index_buf[0], dest_index_set, offsetptr, patlen, pattern, patattr, outfile, partfp, &dest_index_set[REAL_PARTITION - 2], index_tab[REAL_PARTITION - 2])) != 0)
- break; /* all index mark touched */
- }
- if (NOBYTELEVEL) {
- for (iii=0; iii<OneFilePerBlock; iii++) {
- free_list(&offset_tab[iii]);
- free_list(&offsetptr[iii]);
- }
- }
-
- /* Take intersection if parse=ANDPAT or 0 (one terminal pattern), union if OR_EXP; Take care of universal sets in offset_tab[REAL_PARTITION - 1] */
- if (OneFilePerBlock) {
- if (parse & OR_EXP) {
- if (ret) {
- ret_is_1:
- index_tab[REAL_PARTITION - 1] = 1;
- for(i=0; i<round(OneFilePerBlock, 8*sizeof(int)) - 1; i++) {
- index_tab[i] = 0xffffffff;
- }
- index_tab[i] = 0;
- for (j=0; j<8*sizeof(int); j++) {
- if (i*8*sizeof(int) + j >= OneFilePerBlock) break;
- index_tab[i] |= mask_int[j];
- }
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) for (i=0; i<OneFilePerBlock; i++) {
- free_list(&offsetptr[i]);
- free_list(&offset_tab[i]);
- }
- if (ByteLevelIndex) NOBYTELEVEL = 1;
- fclose(f_in);
- return 0;
- }
- index_tab[REAL_PARTITION - 1] = 0;
- for (i=0; i<round(OneFilePerBlock, 8*sizeof(int)); i++) index_tab[i] |= dest_index_set[i];
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) {
- for (i=0; i<OneFilePerBlock; i++) {
- sorted_union(&offset_tab[i], &offsetptr[i], &index_tab[REAL_PARTITION - 2], dest_index_set[REAL_PARTITION - 2], 0);
- if (NOBYTELEVEL) {
- for (iii=0; iii<OneFilePerBlock; iii++) {
- free_list(&offset_tab[iii]);
- free_list(&offsetptr[iii]);
- }
- break;
- }
- }
- }
- }
- else {
- if (((index_tab[REAL_PARTITION - 1] == 1) || first_time) && (ret)) {
- both_are_1:
- if (first_time) {
- index_tab[REAL_PARTITION - 1] = 1;
- for(i=0; i<round(OneFilePerBlock, 8*sizeof(int)) - 1; i++) {
- index_tab[i] = 0xffffffff;
- }
- index_tab[i] = 0;
- for (j=0; j<8*sizeof(int); j++) {
- if (i*8*sizeof(int) + j >= OneFilePerBlock) break;
- index_tab[i] |= mask_int[j];
- }
- }
- first_time = 0;
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) for (i=0; i<OneFilePerBlock; i++) {
- free_list(&offsetptr[i]);
- free_list(&offset_tab[i]);
- }
- if (ByteLevelIndex) NOBYTELEVEL = 1;
- /*
- fclose(f_in);
- return 0;
- */
- }
- else if ((index_tab[REAL_PARTITION - 1] == 1) || first_time) {
- first_time = 0;
- index_tab[REAL_PARTITION - 1] = 0;
- for (i=0; i<round(OneFilePerBlock, 8*sizeof(int)); i++) index_tab[i] = dest_index_set[i];
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) {
- for (i=0; i<OneFilePerBlock; i++) {
- free_list(&offset_tab[i]);
- offset_tab[i] = offsetptr[i];
- offsetptr[i] = NULL;
- }
- }
- }
- else if (ret) {
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) for (i=0; i<OneFilePerBlock; i++) free_list(&offsetptr[i]);
- }
- else {
- for (i=0; i<round(OneFilePerBlock, 8*sizeof(int)); i++) index_tab[i] &= dest_index_set[i];
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) {
- if (first_time || WHOLEFILESCOPE) {
- first_time = 0;
- for (i=0; i<OneFilePerBlock; i++) {
- sorted_union(&offset_tab[i], &offsetptr[i], &index_tab[REAL_PARTITION - 2], dest_index_set[REAL_PARTITION - 2], 0);
- if (NOBYTELEVEL) {
- for (iii=0; iii<OneFilePerBlock; iii++) {
- free_list(&offset_tab[iii]);
- free_list(&offsetptr[iii]);
- }
- break;
- }
- }
- }
- else {
- for (i=0; i<OneFilePerBlock; i++) {
- if ((index_tab[block2index(i)] & mask_int[i % (8*sizeof(int))]))
- sorted_intersection(i, &offset_tab[i], &offsetptr[i], &index_tab[REAL_PARTITION - 2]);
- else free_list(&offsetptr[i]);
- /*
- if (index_tab[REAL_PARTITION - 2] < MIN_OCCURRENCES) {
- if (!NOBYTELEVEL) {
- for (iii=0; iii<OneFilePerBlock; iii++) {
- free_list(&offset_tab[iii]);
- free_list(&offsetptr[iii]);
- }
- }
- NOBYTELEVEL = 1;
- OPTIMIZEBYTELEVEL = 1;
- break;
- }
- */
- }
- }
- }
- }
- }
- }
- else {
- if (parse & OR_EXP)
- for(i=0; i<MAX_PARTITION; i++) index_tab[i] |= dest_index_set[i];
- else
- for(i=0; i<MAX_PARTITION; i++) index_tab[i] &= dest_index_set[i];
- }
-
- #if BG_DEBUG
- fprintf(debug, "get_index(): the following partitions are ON\n");
- for(i=0; i<((OneFilePerBlock > 0) ? round(OneFilePerBlock, 8*sizeof(int)) : MAX_PARTITION); i++) {
- if(index_tab[i]) fprintf(debug, "%d,%x\n", i, index_tab[i]);
- }
- #endif /*BG_DEBUG*/
-
- fclose(f_in);
- return 0;
- }
-
- /*
- * Same as above, but uses mgrep to search the index for many patterns at one go,
- * and interprets the output obtained from the -M and -P options (set in main.c).
- */
- mgrep_get_index(infile, index_tab, offset_tab, pat_list, pat_lens, pat_attr, mgrep_pat_index, num_mgrep_pat, patbufpos, index_argv, index_argc, outfile, partfp, parse, first_time)
- char *infile;
- int *index_tab;
- struct offsets **offset_tab;
- char *pat_list[];
- int pat_lens[];
- int pat_attr[];
- int mgrep_pat_index[];
- int num_mgrep_pat;
- int patbufpos;
- char *index_argv[];
- int index_argc;
- FILE *outfile;
- FILE *partfp;
- int parse;
- int first_time;
- {
- int i=0, j, temp, iii, jjj;
- FILE *f_in;
- int ret;
- int x=0, y=0, even_words=1;
- int patnum;
- unsigned int *setptr;
- struct offsets **offsetptr;
- CHAR dummypat[MAX_PAT];
- int dummylen=0;
- char allindexmark[MAXNUM_PAT];
- int k;
- int sorted[MAXNUM_PAT], min, max;
-
- if (OneFilePerBlock && (parse & OR_EXP) && (index_tab[REAL_PARTITION - 1] == 1)) return 0;
- /* Do the mgrep() */
- if ((f_in = fopen(infile, "w")) == NULL) {
- fprintf(stderr, "%s: run out of file descriptors!\n", GProgname);
- return -1;
- }
- errno = 0;
- if ((ret = fileagrep(index_argc, index_argv, 0, f_in)) < 0) {
- fprintf(stderr, "%s: error in searching index\n", GProgname);
- fclose(f_in);
- return -1;
- }
- fflush(f_in);
- fclose(f_in);
- f_in = NULL;
-
- index_argv[patbufpos] = NULL;
- /* For index-search with memgrep and get-filenames */
- dummypat[0] = '\0';
- if ((dummylen = memagrep_init(index_argc, index_argv, MAX_PAT, dummypat)) <= 0) {
- fclose(f_in);
- return -1;
- }
-
- /* Interpret the result */
- if((f_in = fopen(infile, "r")) == NULL) {
- fprintf(stderr, "%s: can't open for reading: %s/%s\n", GProgname, INDEX_DIR, infile);
- return -1;
- }
- if (OneFilePerBlock) {
- for (patnum=0; patnum<num_mgrep_pat; patnum ++) {
- for(i=0; i<round(OneFilePerBlock, 8*sizeof(int)); i++) {
- multi_dest_index_set[patnum][i] = 0;
- }
- if (ByteLevelIndex) for(i=0; i<OneFilePerBlock; i++) {
- multi_dest_offset_table[patnum][i] = NULL;
- }
- multi_dest_index_set[patnum][REAL_PARTITION - 1] = 0;
- multi_dest_index_set[patnum][REAL_PARTITION - 2] = 0;
- }
- }
- else {
- for (patnum=0; patnum<num_mgrep_pat; patnum ++)
- for(i=0; i<MAX_PARTITION; i++) {
- multi_dest_index_set[patnum][i] = 0;
- }
- }
- dest_index_buf[0] = '\n'; /* memagrep needs buffer to begin with '\n' */
-
- memset(allindexmark, '\0', num_mgrep_pat);
- min = (index_tab[REAL_PARTITION - 1] == 1) ? 0 : index_tab[REAL_PARTITION - 2];
- while(fgets(dest_index_buf+1, REAL_INDEX_BUF, f_in)) {
- patnum=0;
- sscanf(&dest_index_buf[1], "%d-", &patnum);
- #if BG_DEBUG
- fprintf(debug, "patnum=%d len=%d pat=%s attr=%d index-line: %s\n", patnum, pat_lens[mgrep_pat_index[patnum-1]], pat_list[mgrep_pat_index[patnum-1]], pat_attr[mgrep_pat_index[patnum-1]], dest_index_buf+1);
- #endif /*BG_DEBUG*/
- if ((patnum < 1) || (patnum > num_mgrep_pat)) continue; /* error! */
- setptr = multi_dest_index_set[patnum - 1];
- offsetptr = multi_dest_offset_table[patnum - 1];
- for(k=0; dest_index_buf[k] != ' '; k++);
- dest_index_buf[k] = '\n';
- if (!allindexmark[patnum - 1])
- allindexmark[patnum - 1] = (char)get_set(&dest_index_buf[k], setptr, offsetptr, pat_lens[mgrep_pat_index[patnum-1]],
- pat_list[mgrep_pat_index[patnum-1]], pat_attr[mgrep_pat_index[patnum-1]], outfile, partfp,
- &setptr[REAL_PARTITION - 2], min);
- /* To test the maximum disparity to stop unions within above */
- if (!allindexmark[patnum-1]) min = setptr[REAL_PARTITION - 2];
- for (patnum=0; patnum<num_mgrep_pat; patnum ++) {
- if ((multi_dest_index_set[patnum][REAL_PARTITION - 2] < min) && (multi_dest_index_set[patnum][REAL_PARTITION - 1] != 1))
- min = multi_dest_index_set[patnum][REAL_PARTITION - 2];
- }
- min += (index_tab[REAL_PARTITION - 1] == 1) ? 0 : index_tab[REAL_PARTITION - 2];
- }
- #if 0
- for (patnum=0; patnum<num_mgrep_pat; patnum++)
- printf("%d=%d,%d\n", patnum, multi_dest_index_set[patnum][REAL_PARTITION - 1], multi_dest_index_set[patnum][REAL_PARTITION - 2]);
- #endif /*0*/
-
- for (patnum=0; patnum<num_mgrep_pat; patnum++)
- sorted[patnum] = patnum;
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) {
- max = 0;
- for (patnum=1; patnum<num_mgrep_pat; patnum++) {
- if (multi_dest_index_set[patnum][REAL_PARTITION - 2] > multi_dest_index_set[max][REAL_PARTITION - 2])
- max = patnum;
- }
- /* Sort them according to the lengths of the lists in increasing order: min first */
- for (patnum=0; patnum<num_mgrep_pat; patnum++) {
- min = patnum;
- for (j=patnum+1; j<num_mgrep_pat; j++)
- if (multi_dest_index_set[sorted[j]][REAL_PARTITION - 2] < multi_dest_index_set[sorted[min]][REAL_PARTITION - 2])
- min = j;
- if (min != patnum) {
- temp = sorted[patnum];
- sorted[patnum] = sorted[min];
- sorted[min] = temp;
- }
- }
- if (multi_dest_index_set[sorted[max]][REAL_PARTITION - 2] > MAX_DISPARITY * multi_dest_index_set[sorted[0]][REAL_PARTITION - 2]) {
- NOBYTELEVEL = 1;
- /* printf("4 "); */
- for (iii=0; iii<OneFilePerBlock; iii++) {
- for (jjj=0; jjj<num_mgrep_pat; jjj++)
- free_list(&multi_dest_offset_table[jjj][iii]);
- free_list(&offset_tab[iii]);
- }
- }
- }
- else if (NOBYTELEVEL) {
- for (iii=0; iii<OneFilePerBlock; iii++) {
- for (jjj=0; jjj<num_mgrep_pat; jjj++)
- free_list(&multi_dest_offset_table[jjj][iii]);
- free_list(&offset_tab[iii]);
- }
- }
-
- /* Take intersection if parse=ANDPAT or 0 (one terminal pattern), union if OR_EXP; Take care of universal sets in offset_tab[REAL_PARTITION - 1] */
- for (patnum=0; patnum<num_mgrep_pat; patnum++) {
- if (OneFilePerBlock) {
- if (parse & OR_EXP) {
- if (allindexmark[sorted[patnum]]) {
- ret_is_1:
- index_tab[REAL_PARTITION - 1] = 1;
- for(i=0; i<round(OneFilePerBlock, 8*sizeof(int)) - 1; i++) {
- index_tab[i] = 0xffffffff;
- }
- index_tab[i] = 0;
- for (j=0; j<8*sizeof(int); j++) {
- if (i*8*sizeof(int) + j >= OneFilePerBlock) break;
- index_tab[i] |= mask_int[j];
- }
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) for (patnum=0;patnum<num_mgrep_pat;patnum++) for (i=0; i<OneFilePerBlock; i++) {
- free_list(&multi_dest_offset_table[sorted[patnum]][i]);
- free_list(&offset_tab[i]);
- }
- if (ByteLevelIndex) NOBYTELEVEL = 1;
- fclose(f_in);
- return 0;
- }
- index_tab[REAL_PARTITION - 1] = 0;
- for (i=0; i<round(OneFilePerBlock, 8*sizeof(int)); i++) index_tab[i] |= multi_dest_index_set[sorted[patnum]][i];
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) {
- for (i=0; i<OneFilePerBlock; i++) {
- sorted_union(&offset_tab[i], &multi_dest_offset_table[sorted[patnum]][i], &index_tab[REAL_PARTITION - 2], multi_dest_index_set[sorted[patnum]][REAL_PARTITION - 2], 0);
-
- if (NOBYTELEVEL) {
- for (iii=0; iii<OneFilePerBlock; iii++) {
- for (jjj=0; jjj<num_mgrep_pat; jjj++)
- free_list(&multi_dest_offset_table[jjj][iii]);
- free_list(&offset_tab[iii]);
- }
- break;
- }
- }
- }
- }
- else {
- if (((index_tab[REAL_PARTITION - 1] == 1) || first_time) && (allindexmark[sorted[patnum]])) {
- both_are_1:
- if (first_time) {
- index_tab[REAL_PARTITION - 1] = 1;
- for(i=0; i<round(OneFilePerBlock, 8*sizeof(int)) - 1; i++) {
- index_tab[i] = 0xffffffff;
- }
- index_tab[i] = 0;
- for (j=0; j<8*sizeof(int); j++) {
- if (i*8*sizeof(int) + j >= OneFilePerBlock) break;
- index_tab[i] |= mask_int[j];
- }
- }
- first_time = 0;
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) for (patnum=0;patnum<num_mgrep_pat;patnum++) for (i=0; i<OneFilePerBlock; i++) {
- free_list(&multi_dest_offset_table[sorted[patnum]][i]);
- free_list(&offset_tab[i]);
- }
- if (ByteLevelIndex) NOBYTELEVEL = 1;
- /*
- fclose(f_in);
- return 0;
- */
- }
- else if ((index_tab[REAL_PARTITION - 1] == 1) || first_time) {
- first_time = 0;
- index_tab[REAL_PARTITION - 1] = 0;
- for (i=0; i<round(OneFilePerBlock, 8*sizeof(int)); i++) index_tab[i] = multi_dest_index_set[sorted[patnum]][i];
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) {
- for (i=0; i<OneFilePerBlock; i++) {
- free_list(&offset_tab[i]);
- offset_tab[i] = multi_dest_offset_table[sorted[patnum]][i];
- multi_dest_offset_table[sorted[patnum]][i] = NULL;
- }
- }
- }
- else if (allindexmark[sorted[patnum]]) {
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) for (i=0; i<OneFilePerBlock; i++) free_list(&multi_dest_offset_table[sorted[patnum]][i]);
- }
- else {
- for (i=0; i<round(OneFilePerBlock, 8*sizeof(int)); i++) index_tab[i] &= multi_dest_index_set[sorted[patnum]][i];
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) {
- if (first_time || WHOLEFILESCOPE) {
- first_time = 0;
- for (i=0; i<OneFilePerBlock; i++) {
- sorted_union(&offset_tab[i], &multi_dest_offset_table[sorted[patnum]][i], &index_tab[REAL_PARTITION - 2], multi_dest_index_set[sorted[patnum]][REAL_PARTITION - 2], 0);
- if (NOBYTELEVEL) {
- for (iii=0; iii<OneFilePerBlock; iii++) {
- for (jjj=0; jjj<num_mgrep_pat; jjj++)
- free_list(&multi_dest_offset_table[jjj][iii]);
- free_list(&offset_tab[iii]);
- }
- break;
- }
- }
- }
- else {
- for (i=0; i<OneFilePerBlock; i++) {
- if ((index_tab[block2index(i)] & mask_int[i % (8*sizeof(int))]))
- sorted_intersection(i, &offset_tab[i], &multi_dest_offset_table[sorted[patnum]][i], &index_tab[REAL_PARTITION - 2]);
- else free_list(&multi_dest_offset_table[sorted[patnum]][i]);
- /*
- if (index_tab[REAL_PARTITION - 2] < MIN_OCCURRENCES) {
- if (!NOBYTELEVEL) {
- for (iii=0; iii<OneFilePerBlock; iii++) {
- for (jjj=0; jjj<num_mgrep_pat; jjj++)
- free_list(&multi_dest_offset_table[jjj][iii]);
- free_list(&offset_tab[iii]);
- }
- }
- NOBYTELEVEL = 1;
- OPTIMIZEBYTELEVEL = 1;
- break;
- }
- */
- }
- }
- }
- }
- }
- }
- else {
- if (parse & OR_EXP) {
- for (patnum=0; patnum<num_mgrep_pat; patnum++)
- for(i=0; i<MAX_PARTITION; i++) index_tab[i] |= multi_dest_index_set[patnum][i];
- }
- else {
- for (patnum=0; patnum<num_mgrep_pat; patnum++)
- for(i=0; i<MAX_PARTITION; i++) index_tab[i] &= multi_dest_index_set[patnum][i];
- }
- }
- }
-
- #if BG_DEBUG
- fprintf(debug, "get_index(): the following partitions are ON\n");
- for(i=0; i<((OneFilePerBlock > 0) ? round(OneFilePerBlock, 8*sizeof(int)) : MAX_PARTITION); i++) {
- if(index_tab[i]) fprintf(debug, "%d,%x\n", i, index_tab[i]);
- }
- #endif /*BG_DEBUG*/
-
- fclose(f_in);
- return 0;
- }
-
- /* All borrowed from main.c and are needed for searching the index */
- extern CHAR *pat_list[MAXNUM_PAT]; /* complete words within global pattern */
- extern int pat_lens[MAXNUM_PAT]; /* their lengths */
- extern int pat_attr[MAXNUM_PAT]; /* set of attributes */
- extern int num_pat;
- extern CHAR pat_buf[(MAXNUM_PAT + 2)*MAXPAT];
- extern int pat_ptr;
- extern int is_mgrep_pat[MAXNUM_PAT];
- extern int mgrep_pat_index[MAXNUM_PAT];
- extern int num_mgrep_pat;
- extern unsigned int src_index_set[REAL_PARTITION];
- extern struct offsets **src_offset_table;
- extern struct offsets **curr_offset_table;
- extern char tempfile[];
- extern int patindex;
- extern int patbufpos;
- extern ParseTree terminals[MAXNUM_PAT];
- extern int INVERSE; /* agrep's global: need here to implement ~ in index-search */
- extern int GBESTMATCH; /* Should I change -B to -# where # = no. of errors? */
- extern int bestmatcherrors; /* set during index search, used later on */
- extern FILE *partfp; /* glimpse partitions */
- extern FILE *nullfp; /* to discard output: agrep -s doesn't work properly */
- extern int ComplexBoolean;
- extern int num_terminals;
-
- /* Returns the number of times a successful search was conducted: unused info at present. */
- fillup_target(result_index_set, result_offset_table, parse)
- unsigned int result_index_set[REAL_PARTITION];
- struct offsets **result_offset_table;
- int parse;
- {
- int i=0;
- FILE *tmpfp;
- int dummylen = 0;
- char dummypat[MAX_PAT];
- int successes = 0, ret;
- int first_time = 1;
-
- while (i < num_pat) {
- if (is_mgrep_pat[i] && (num_mgrep_pat > 1)) { /* do later */
- i++;
- continue;
- }
- strcpy(index_argv[patindex], pat_list[i]); /* i-th pattern in its right position */
- /* printf("pat_list[%d] = %s\n", i, pat_list[i]); */
-
- if ((tmpfp = fopen(tempfile, "w")) == NULL) {
- fprintf(stderr, "%s: cannot open for writing: %s, errno=%d\n", GProgname, tempfile, errno);
- return(-1);
- }
- errno = 0;
-
- /* If this is the glimpse server, since the process doesn't die, most of its data pages might still remain in memory */
- if ((ret = fileagrep(index_argc, index_argv, 0, tmpfp)) < 0) {
- /* reinitialization here takes care of agrep_argv changes AFTER split_pattern */
- fprintf(stderr, "%s: error in searching index\n", GProgname);
- fclose(tmpfp);
- return(-1);
- }
- /* Now, the output of index search is in tempfile: need to use files here since index is too large */
- fflush(tmpfp);
- fclose(tmpfp);
- tmpfp = NULL;
-
- /* Keep track of the maximum number of errors */
- if (GBESTMATCH) {
- if (errno > bestmatcherrors)
- bestmatcherrors = errno;
- }
-
- /* At this point, all index-search options are properly set due to the above fileagrep */
- if (-1 == get_index(tempfile, result_index_set, result_offset_table, pat_list[i], pat_lens[i], pat_attr[i], index_argv, index_argc, nullfp, partfp, parse, first_time))
- return(-1);
- successes ++;
- first_time = 0;
- i++;
- }
- fflush(stderr);
-
- /* For index-search with memgrep in mgrep_get_index, and get-filenames */
- dummypat[0] = '\0';
- if ((dummylen = memagrep_init(index_argc, index_argv, MAX_PAT, dummypat)) <= 0) return(-1);
- if (num_mgrep_pat > 1) {
- CHAR *old_buf = (CHAR *)index_argv[patbufpos]; /* avoid my_free and re-my_malloc */
- index_argv[patbufpos] = (char*)pat_buf; /* this contains all the patterns with the right -m and -M options */
- #if BG_DEBUG
- fprintf(debug, "pat_buf = %s\n", pat_buf);
- #endif /*BG_DEBUG*/
- strcpy(index_argv[patindex], "-z"); /* no-op: patterns are in patbufpos; also avoid shift-left of index_argv */
- if (-1 == mgrep_get_index(tempfile, result_index_set, result_offset_table,
- pat_list, pat_lens, pat_attr, mgrep_pat_index, num_mgrep_pat, patbufpos,
- index_argv, index_argc, nullfp, partfp, parse, first_time)) {
- index_argv[patbufpos] = (char *)old_buf; /* else will my_free array! */
- fprintf(stderr, "%s: error in searching index\n", GProgname);
- return(-1);
- }
- successes ++;
- first_time = 0;
- index_argv[patbufpos] = (char *)old_buf;
- }
-
- return successes;
- }
-
- /*
- * Now, I search the index by doing an in-order traversal of the boolean parse tree starting at GParse.
- * The results at each node are stored in src_offset_table and src_index_set. Before the right child is
- * evaluated, results of the left child are stored in curr_offset_table and curr_index_set (accumulators)
- * and are unioned/intersected/noted with the right child's results (which get stored in src_...) and
- * passed on above. The accumulators are allocated at each internal node and freed after evaluation.
- * Left to right evaluation is good since number of curr_offset_tables that exist simultaneously depends
- * entirely on the maximum depth of a right branch (REAL_PARTITION is small so it won't make a difference).
- */
- int
- search_index(tree)
- ParseTree *tree;
- {
- int prev_INVERSE;
- int i, j, iii;
- int first_time = 0; /* since it is used AFTER left child has been computed */
- unsigned int curr_index_set[REAL_PARTITION];
- struct offsets **curr_offset_table = NULL;
-
- if (ComplexBoolean) { /* recursive */
- if (tree == NULL) return -1;
- if (tree->type == LEAF) {
- /* always AND pat of individual words at each term: initialize accordingly */
- if (OneFilePerBlock) {
- for(i=0; i<round(OneFilePerBlock, 8*sizeof(int)); i++) src_index_set[i] = 0xffffffff;
- }
- else for(i=0; i<MAX_PARTITION; i++) src_index_set[i] = 1;
- src_index_set[REAL_PARTITION - 1] = 0;
- src_index_set[REAL_PARTITION - 2] = 0;
-
- if (split_terminal(tree->terminalindex, tree->terminalindex+1) <= 0) return -1;
- prev_INVERSE = INVERSE; /* agrep's global to implement NOT */
- if (tree->op & NOTPAT) INVERSE = 1;
- if (fillup_target(src_index_set, src_offset_table, AND_EXP) <= 0) return -1;
- INVERSE = prev_INVERSE;
- return 1;
- }
- else if (tree->type == INTERNAL) {
- /* Search the left node and see if the right node can be searched */
- if (search_index(tree->data.internal.left) <= 0) return -1;
- if (OneFilePerBlock && ((tree->op & OPMASK) == ORPAT) && (src_index_set[REAL_PARTITION - 1] == 1)) goto quit; /* nothing to do */
- if ((tree->data.internal.right == NULL) || (tree->data.internal.right->type == 0)) return -1; /* uninitialized: see main.c */
-
- /* Save previous src_index_set and src_offset_table in fresh accumulators */
- if (OneFilePerBlock) {
- memcpy(curr_index_set, src_index_set, round(OneFilePerBlock,8));
- curr_index_set[REAL_PARTITION - 1] = src_index_set[REAL_PARTITION - 1];
- src_index_set[REAL_PARTITION - 1] = 0;
- curr_index_set[REAL_PARTITION - 2] = src_index_set[REAL_PARTITION - 2];
- src_index_set[REAL_PARTITION - 2] = 0;
- }
- else memcpy(curr_index_set, src_index_set, MAX_PARTITION * sizeof(int));
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) {
- if ((curr_offset_table = (struct offsets **)malloc(sizeof(struct offsets *) * OneFilePerBlock)) == NULL) {
- fprintf(stderr, "%s: malloc failure at: %s:%d\n", GProgname, __FILE__, __LINE__);
- return -1;
- }
- memcpy(curr_offset_table, src_offset_table, OneFilePerBlock * sizeof(struct offsets *));
- memset(src_offset_table, '\0', sizeof(struct offsets *) * OneFilePerBlock);
- }
-
- /* Now evaluate the right node which automatically put the results in src_index_set/src_offset_table */
- if (search_index(tree->data.internal.right) <= 0) {
- if (curr_offset_table != NULL) free(curr_offset_table);
- return -1;
- }
-
- /*
- * Alpha substitution of the code in get_index():
- * index_tab <- src_index_set
- * dest_index_table <- curr_index_set
- * offset_tab <- src_offset_table
- * dest_offset_table <- curr_offset_table
- * ret <- src_index_set[REAL_PARTITION - 1] for ORPAT, curr_index_set for ANDPAT
- * frequency = src_index_set[REAL_PARTITION - 2] in both ORPAT and ANDPAT
- * first_time <- 0
- * return 0 <- goto quit
- * Slight difference since we want the results to go to src rather than curr.
- */
- if (OneFilePerBlock) {
- if ((tree->op & OPMASK) == ORPAT) {
- if (src_index_set[REAL_PARTITION - 1] == 1) { /* curr..[..] can never be 1 since we would have quit above itself */
- ret_is_1:
- src_index_set[REAL_PARTITION - 1] = 1;
- for(i=0; i<round(OneFilePerBlock, 8*sizeof(int)) - 1; i++) {
- src_index_set[i] = 0xffffffff;
- }
- src_index_set[i] = 0;
- for (j=0; j<8*sizeof(int); j++) {
- if (i*8*sizeof(int) + j >= OneFilePerBlock) break;
- src_index_set[i] |= mask_int[j];
- }
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) for (i=0; i<OneFilePerBlock; i++) {
- free_list(&curr_offset_table[i]);
- free_list(&src_offset_table[i]);
- }
- if (ByteLevelIndex) NOBYTELEVEL = 1;
- goto quit;
- }
- src_index_set[REAL_PARTITION - 1] = 0;
- for (i=0; i<round(OneFilePerBlock, 8*sizeof(int)); i++) src_index_set[i] |= curr_index_set[i];
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) {
- for (i=0; i<OneFilePerBlock; i++) {
- sorted_union(&src_offset_table[i], &curr_offset_table[i], &src_index_set[REAL_PARTITION - 2], curr_index_set[REAL_PARTITION - 2], 0);
- if (NOBYTELEVEL) {
- for (iii=0; iii<OneFilePerBlock; iii++) {
- free_list(&src_offset_table[iii]);
- free_list(&curr_offset_table[iii]);
- }
- break;
- }
- }
- }
- }
- else {
- if (((src_index_set[REAL_PARTITION - 1] == 1) || first_time) && (curr_index_set[REAL_PARTITION - 1] == 1)) {
- both_are_1:
- if (first_time) {
- src_index_set[REAL_PARTITION - 1] = 1;
- for(i=0; i<round(OneFilePerBlock, 8*sizeof(int)) - 1; i++) {
- src_index_set[i] = 0xffffffff;
- }
- src_index_set[i] = 0;
- for (j=0; j<8*sizeof(int); j++) {
- if (i*8*sizeof(int) + j >= OneFilePerBlock) break;
- src_index_set[i] |= mask_int[j];
- }
- }
- first_time = 0;
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) for (i=0; i<OneFilePerBlock; i++) {
- free_list(&curr_offset_table[i]);
- free_list(&src_offset_table[i]);
- }
- if (ByteLevelIndex) NOBYTELEVEL = 1;
- /*
- goto quit;
- */
- }
- else if ((src_index_set[REAL_PARTITION - 1] == 1) || first_time) {
- first_time = 0;
- src_index_set[REAL_PARTITION - 1] = 0;
- for (i=0; i<round(OneFilePerBlock, 8*sizeof(int)); i++) src_index_set[i] = curr_index_set[i];
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) {
- for (i=0; i<OneFilePerBlock; i++) {
- free_list(&src_offset_table[i]);
- src_offset_table[i] = curr_offset_table[i];
- curr_offset_table[i] = NULL;
- }
- }
- }
- else if (curr_index_set[REAL_PARTITION - 1] == 1) {
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) for (i=0; i<OneFilePerBlock; i++) free_list(&curr_offset_table[i]);
- }
- else {
- for (i=0; i<round(OneFilePerBlock, 8*sizeof(int)); i++) src_index_set[i] &= curr_index_set[i];
- if (ByteLevelIndex && !NOBYTELEVEL && !Only_first) {
- if (first_time || WHOLEFILESCOPE) {
- first_time = 0;
- for (i=0; i<OneFilePerBlock; i++) {
- sorted_union(&src_offset_table[i], &curr_offset_table[i], &src_index_set[REAL_PARTITION - 2], curr_index_set[REAL_PARTITION - 2], 0);
- if (NOBYTELEVEL) {
- for (iii=0; iii<OneFilePerBlock; iii++) {
- free_list(&src_offset_table[iii]);
- free_list(&curr_offset_table[iii]);
- }
- break;
- }
- }
- }
- else {
- for (i=0; i<OneFilePerBlock; i++) {
- if ((src_index_set[block2index(i)] & mask_int[i % (8*sizeof(int))]))
- sorted_intersection(i, &src_offset_table[i], &curr_offset_table[i], &src_index_set[REAL_PARTITION - 2]);
- else free_list(&curr_offset_table[i]);
- /*
- if (src_index_set[REAL_PARTITION - 2] < MIN_OCCURRENCES) {
- if (!NOBYTELEVEL) {
- for (iii=0; iii<OneFilePerBlock; iii++) {
- free_list(&src_offset_table[iii]);
- free_list(&curr_offset_table[iii]);
- }
- }
- NOBYTELEVEL = 1;
- OPTIMIZEBYTELEVEL = 1;
- break;
- }
- */
- }
- }
- }
- }
- }
- }
- else {
- if ((tree->op & OPMASK) == ORPAT)
- for(i=0; i<MAX_PARTITION; i++) src_index_set[i] |= curr_index_set[i];
- else
- for(i=0; i<MAX_PARTITION; i++) src_index_set[i] &= curr_index_set[i];
- }
-
- quit:
- if (curr_offset_table != NULL) free(curr_offset_table);
- /* Now if it is a NOT expression, complement the indices stuff knowing that it cannot be ByteLevelIndex */
- if (tree->op & NOTPAT) {
- if (ByteLevelIndex) {
- /* Can't recover the discarded offsets */
- fprintf(stderr, "%s: can't handle NOT of AND/OR terms with ByteLevelIndex: please simplify the query\n", GProgname);
- return -1;
- }
- if (OneFilePerBlock)
- for (i=0; i<round(OneFilePerBlock, 8*sizeof(int)); i++) src_index_set[i] = ~src_index_set[i];
- else
- for(i=0; i<MAX_PARTITION; i++) src_index_set[i] = (src_index_set[i] ? 0 : 1);
- }
- }
- else return -1;
- }
- else { /* iterative just as it is now: initialize */
- if ((int)tree & OR_EXP) memset(src_index_set, '\0', round(OneFilePerBlock,8));
- else {
- if (OneFilePerBlock) for(i=0; i<round(OneFilePerBlock, 8*sizeof(int)); i++) src_index_set[i] = 0xffffffff;
- else for(i=0; i<MAX_PARTITION; i++) src_index_set[i] = 1;
- }
- src_index_set[REAL_PARTITION - 1] = 0;
- src_index_set[REAL_PARTITION - 2] = 0;
-
- if (split_terminal(0, num_terminals) <= 0) return -1;
- if (fillup_target(src_index_set, src_offset_table, (int)tree) <= 0) return -1;
- }
-
- return 1;
- }
-
-