X-Git-Url: http://jsfdemo.indexdata.com/?a=blobdiff_plain;f=src%2Fsession.c;h=54b82daa1210b6ea64f4dcd7f820536b28e78bc3;hb=96707c992b975c2c9b500bd6a5075b5631e32e26;hp=36be0616c55b6e99ca86d6056d33797f2031a803;hpb=eca44e3cf91bcb32e816f99736f81286312f51d7;p=pazpar2-moved-to-github.git diff --git a/src/session.c b/src/session.c index 36be061..54b82da 100644 --- a/src/session.c +++ b/src/session.c @@ -821,8 +821,7 @@ void session_init_databases(struct session *se) static struct session_database *load_session_database(struct session *se, char *id) { - struct database *db = new_database(id, se->session_nmem); - + struct database *db = new_database_inherit_settings(id, se->session_nmem, se->service->settings); session_init_databases_fun((void*) se, db); // New sdb is head of se->databases list @@ -1015,6 +1014,14 @@ static int cmp_ht(const void *p1, const void *p2) return h2->hits - h1->hits; } +// Compares two hitsbytarget nodes by hitcount +static int cmp_ht_approx(const void *p1, const void *p2) +{ + const struct hitsbytarget *h1 = p1; + const struct hitsbytarget *h2 = p2; + return h2->approximation - h1->approximation; +} + static int targets_termlist_nb(WRBUF wrbuf, struct session *se, int num, NMEM nmem, int version) { @@ -1022,7 +1029,10 @@ static int targets_termlist_nb(WRBUF wrbuf, struct session *se, int num, int count, i; ht = hitsbytarget_nb(se, &count, nmem); - qsort(ht, count, sizeof(struct hitsbytarget), cmp_ht); + if (version >= 2) + qsort(ht, count, sizeof(struct hitsbytarget), cmp_ht_approx); + else + qsort(ht, count, sizeof(struct hitsbytarget), cmp_ht); for (i = 0; i < count && i < num && ht[i].hits > 0; i++) { @@ -1576,6 +1586,7 @@ int ingest_record(struct client *cl, const char *rec, return ret; } +// Skip record on non-zero static int check_limit_local(struct client *cl, struct record *record, int record_no) @@ -1594,9 +1605,7 @@ static int check_limit_local(struct client *cl, char **values = 0; int i, num_v = 0; - const char *name = - client_get_facet_limit_local(cl, sdb, &l, nmem_tmp, &num_v, - &values); + const char *name = client_get_facet_limit_local(cl, sdb, &l, nmem_tmp, &num_v, &values); if (!name) break; @@ -1623,10 +1632,10 @@ static int check_limit_local(struct client *cl, } else { - yaz_log(YLOG_LOG, "cmp: '%s' '%s'", - rec_md->data.text.disp, values[i]); + yaz_log(YLOG_LOG, "cmp: '%s' '%s'", rec_md->data.text.disp, values[i]); if (!strcmp(rec_md->data.text.disp, values[i])) { + // Value equals, should not be filtered. break; } } @@ -1638,6 +1647,7 @@ static int check_limit_local(struct client *cl, i++; } } + // At end , not match if (i == num_v) { skip_record = 1; @@ -1776,6 +1786,8 @@ static int ingest_to_cluster(struct client *cl, struct record_metadata *rec_md = 0; int md_field_id = -1; int sk_field_id = -1; + int rank = 0; + xmlChar *rank_str = 0; type = xmlGetProp(n, (xmlChar *) "type"); value = xmlNodeListGetString(xdoc, n->children, 1); @@ -1789,6 +1801,15 @@ static int ingest_to_cluster(struct client *cl, continue; ser_md = &service->metadata[md_field_id]; + + rank_str = xmlGetProp(n, (xmlChar *) "rank"); + if (rank_str) + { + rank = atoi((const char *) rank_str); + xmlFree(rank_str); + } + else + rank = ser_md->rank; if (ser_md->sortkey_offset >= 0) { @@ -1888,10 +1909,11 @@ static int ingest_to_cluster(struct client *cl, // ranking of _all_ fields enabled ... - if (ser_md->rank) + if (rank) + { relevance_countwords(se->relevance, cluster, - (char *) value, ser_md->rank, - ser_md->name); + (char *) value, rank, ser_md->name); + } // construct facets ... unless the client already has reported them if (ser_md->termlist && !client_has_facet(cl, (char *) type))