386BSD 0.1 development

[unix-history] / usr / othersrc / contrib / isode / dsap / common / correlate.c

/* correlate.c - correlate search results */

#ifndef	lint
static char *rcsid = "$Header: /f/osi/dsap/common/RCS/correlate.c,v 7.2 91/02/22 09:18:51 mrose Interim $";
#endif

/* 
 * $Header: /f/osi/dsap/common/RCS/correlate.c,v 7.2 91/02/22 09:18:51 mrose Interim $
 *
 *
 * $Log:	correlate.c,v $
 * Revision 7.2  91/02/22  09:18:51  mrose
 * Interim 6.8
 * 
 * Revision 7.1  90/07/09  14:34:13  mrose
 * sync
 * 
 * Revision 7.0  89/11/23  21:41:58  mrose
 * Release 6.0
 * 
 */

/*
 *				  NOTICE
 *
 *    Acquisition, use, and distribution of this module and related
 *    materials are subject to the restrictions of a license agreement.
 *    Consult the Preface in the User's Manual for the full terms of
 *    this agreement.
 *
 */


/* LINTLIBRARY */

#include "quipu/util.h"
#include "quipu/list.h"      /* to get LSR # defs */
#include "quipu/ds_search.h"

extern LLog * log_dsap;
int	entryinfo_print();
int	dn_print();

correlate_search_results(sr_res)
struct ds_search_result	* sr_res;
{
    struct ds_search_result	* sr_tmp;
    struct ds_search_result	* sr_last;

    DLOG(log_dsap, LLOG_DEBUG, ("correlate_search_results() "));

    if(sr_res->srr_correlated)
    {
	DLOG(log_dsap, LLOG_DEBUG, ("Already correlated! "));
	return;
    }

    DLOG(log_dsap, LLOG_DEBUG, ("Not yet correlated! "));

    for(sr_tmp = sr_res->srr_un.srr_parts; sr_tmp != NULLSRR; sr_tmp = sr_tmp->srr_next)
    {
	DLOG(log_dsap, LLOG_DEBUG, ("correlate_search_results(A Result Part)"));
	correlate_search_results(sr_tmp);
    }

    sr_tmp = sr_res->srr_un.srr_parts;
    sr_res->srr_correlated = TRUE;
    sr_res->srr_un.srr_unit = (struct ds_search_unit *) malloc(sizeof(struct ds_search_unit));
    sr_res->CSR_object = NULLDN;
    sr_res->CSR_entries = NULLENTRYINFO;
    sr_res->CSR_limitproblem = LSR_NOLIMITPROBLEM;
    sr_res->CSR_cr = NULLCONTINUATIONREF;
    sr_res->CSR_common.cr_requestor = NULLDN;
    sr_res->CSR_common.cr_aliasdereferenced = FALSE;

    while(sr_tmp != NULLSRR)
    {
	merge_search_results(sr_res, sr_tmp);
	sr_last = sr_tmp;
	sr_tmp = sr_tmp->srr_next;
	sr_last->srr_next = NULLSRR;
	DLOG(log_dsap, LLOG_DEBUG, ("Before search_results_free"));
	search_result_free(sr_last);
	DLOG(log_dsap, LLOG_DEBUG, ("After search_results_free"));
    }
}

merge_search_results(sr_res, sr_tmp)
struct ds_search_result	* sr_res;
struct ds_search_result	* sr_tmp;
{
    ContinuationRef		cr_tmp;

    DLOG(log_dsap, LLOG_DEBUG, ("merge_search_results"));

    if(sr_tmp == NULLSRR)
	return;

    if (sr_res->CSR_entries == NULLENTRYINFO)
    {
	DLOG(log_dsap, LLOG_DEBUG, ("Before inserting entries"));
	sr_res->CSR_entries = sr_tmp->CSR_entries;
    }
    else
    {
#ifdef	HEAVYDEBUG
	pslog(log_dsap, LLOG_DEBUG, "Before merging entries", entryinfo_print, (caddr_t) sr_res->CSR_entries);
#endif
	entryinfo_merge (sr_res->CSR_entries,sr_tmp->CSR_entries);
    }
    sr_tmp->CSR_entries = NULLENTRYINFO;

    DLOG(log_dsap, LLOG_DEBUG, ("Before merging limitproblems"));

    if(sr_res->CSR_limitproblem == LSR_NOLIMITPROBLEM)
        sr_res->CSR_limitproblem = sr_tmp->CSR_limitproblem;

    DLOG(log_dsap, LLOG_DEBUG, ("Before merging ContinuationRefs"));

    if(sr_tmp->CSR_cr != NULLCONTINUATIONREF)
    {
	for(cr_tmp = sr_tmp->CSR_cr; cr_tmp->cr_next != NULLCONTINUATIONREF; cr_tmp = cr_tmp->cr_next)
	{
#ifdef	DEBUG
	    pslog(log_dsap, LLOG_DEBUG, "Another new ref:", dn_print, (caddr_t) cr_tmp->cr_name);
#endif
	}
#ifdef	DEBUG
	pslog(log_dsap, LLOG_DEBUG, "Another new ref:", dn_print, (caddr_t) cr_tmp->cr_name);
#endif
	cr_tmp->cr_next = sr_res->CSR_cr;
	sr_res->CSR_cr = sr_tmp->CSR_cr;
	sr_tmp->CSR_cr = NULLCONTINUATIONREF;
    }
    else
    {
	DLOG(log_dsap, LLOG_DEBUG, ("No new references to merge"));
    }

#ifdef DEBUG
    if(sr_res->CSR_cr != NULLCONTINUATIONREF)
    {
	for(cr_tmp = sr_res->CSR_cr; cr_tmp != NULLCONTINUATIONREF; cr_tmp = cr_tmp->cr_next)
	{
	    pslog(log_dsap, LLOG_DEBUG, "ref entry:", dn_print, (caddr_t) cr_tmp->cr_name);
	}
    }
    else
    {
	DLOG(log_dsap, LLOG_DEBUG, ("No references"));
    }
#endif
    DLOG(log_dsap, LLOG_DEBUG, ("After merging results:"));

}

search_result_free(arg)
struct ds_search_result	* arg;
{
    DLOG(log_dsap, LLOG_DEBUG, ("search_result_free"));

    if(arg == NULLSRR)
    {
	LLOG(log_dsap, LLOG_EXCEPTIONS, ("Lost part of search structure somewhere!"));
	return;
    }

    if(arg->srr_correlated)
    {
	DLOG(log_dsap, LLOG_DEBUG, ("search_result_free - correlated"));
/*
	dn_free (arg->CSR_common.cr_requestor);
*/
	dn_free (arg->CSR_object);
	entryinfo_free (arg->CSR_entries,0);
	crefs_free (arg->CSR_cr);
	free((char *)arg->srr_un.srr_unit);
    }
    else
    {
	DLOG(log_dsap, LLOG_DEBUG, ("search_result_free - uncorrelated"));
	search_result_free(arg->srr_un.srr_parts);
	free((char *)arg->srr_un.srr_parts);
    }

    DLOG(log_dsap, LLOG_DEBUG, ("After freeing parts"));

    if(arg->srr_next != NULLSRR)
    {
	search_result_free(arg->srr_next);
	free((char *)arg->srr_next);
    }

    DLOG(log_dsap, LLOG_DEBUG, ("After freeing next"));

    return;
}