+ Z_GDU *gdu_req = package.request().get();
+ Z_PresentRequest *pr_req = 0;
+ Z_SearchRequest *sr_req = 0;
+
+ const char *input_schema = 0;
+ Odr_oid *input_syntax = 0;
+
+ if (gdu_req && gdu_req->which == Z_GDU_Z3950 &&
+ gdu_req->u.z3950->which == Z_APDU_presentRequest)
+ {
+ pr_req = gdu_req->u.z3950->u.presentRequest;
+
+ input_schema =
+ mp_util::record_composition_to_esn(pr_req->recordComposition);
+ input_syntax = pr_req->preferredRecordSyntax;
+ }
+ else if (gdu_req && gdu_req->which == Z_GDU_Z3950 &&
+ gdu_req->u.z3950->which == Z_APDU_searchRequest)
+ {
+ sr_req = gdu_req->u.z3950->u.searchRequest;
+
+ input_syntax = sr_req->preferredRecordSyntax;
+
+ // we don't know how many hits we're going to get and therefore
+ // the effective element set name.. Therefore we can only allow
+ // two cases.. Both equal or absent.. If not, we'll just have to
+ // disable the piggyback!
+ if (sr_req->smallSetElementSetNames
+ &&
+ sr_req->mediumSetElementSetNames
+ &&
+ sr_req->smallSetElementSetNames->which == Z_ElementSetNames_generic
+ &&
+ sr_req->mediumSetElementSetNames->which == Z_ElementSetNames_generic
+ &&
+ !strcmp(sr_req->smallSetElementSetNames->u.generic,
+ sr_req->mediumSetElementSetNames->u.generic))
+ {
+ input_schema = sr_req->smallSetElementSetNames->u.generic;
+ }
+ else if (!sr_req->smallSetElementSetNames &&
+ !sr_req->mediumSetElementSetNames)
+ ; // input_schema is 0 already
+ else
+ {
+ // disable piggyback (perhaps it was disabled already)
+ *sr_req->smallSetUpperBound = 0;
+ *sr_req->largeSetLowerBound = 0;
+ *sr_req->mediumSetPresentNumber = 0;
+ package.move();
+ return;
+ }
+ // we can handle it in record_transform.
+ }
+ else
+ {
+ package.move();
+ return;
+ }
+
+ mp::odr odr_en(ODR_ENCODE);
+
+ const char *backend_schema = 0;
+ const Odr_oid *backend_syntax = 0;
+
+ if (input_schema && !strcmp(input_schema, elementset_input.c_str()) &&
+ (!input_syntax || !oid_oidcmp(input_syntax, yaz_oid_recsyn_xml)))
+ {
+ backend_schema = elementset_output.c_str();
+ backend_syntax = yaz_oid_recsyn_xml;
+ }
+ else
+ {
+ package.move();
+ return;
+ }
+
+ if (sr_req)
+ {
+ if (backend_syntax)
+ sr_req->preferredRecordSyntax = odr_oiddup(odr_en, backend_syntax);
+ else
+ sr_req->preferredRecordSyntax = 0;
+ if (backend_schema)
+ {
+ sr_req->smallSetElementSetNames
+ = (Z_ElementSetNames *)
+ odr_malloc(odr_en, sizeof(Z_ElementSetNames));
+ sr_req->smallSetElementSetNames->which = Z_ElementSetNames_generic;
+ sr_req->smallSetElementSetNames->u.generic
+ = odr_strdup(odr_en, backend_schema);
+ sr_req->mediumSetElementSetNames = sr_req->smallSetElementSetNames;
+ }
+ else
+ {
+ sr_req->smallSetElementSetNames = 0;
+ sr_req->mediumSetElementSetNames = 0;
+ }
+ }
+ else if (pr_req)
+ {
+ if (backend_syntax)
+ pr_req->preferredRecordSyntax = odr_oiddup(odr_en, backend_syntax);
+ else
+ pr_req->preferredRecordSyntax = 0;
+
+ if (backend_schema)
+ {
+ pr_req->recordComposition
+ = (Z_RecordComposition *)
+ odr_malloc(odr_en, sizeof(Z_RecordComposition));
+ pr_req->recordComposition->which
+ = Z_RecordComp_simple;
+ pr_req->recordComposition->u.simple
+ = (Z_ElementSetNames *)
+ odr_malloc(odr_en, sizeof(Z_ElementSetNames));
+ pr_req->recordComposition->u.simple->which = Z_ElementSetNames_generic;
+ pr_req->recordComposition->u.simple->u.generic
+ = odr_strdup(odr_en, backend_schema);
+ }
+ else
+ pr_req->recordComposition = 0;
+ }