+static int break_handler(void *client_data)
+{
+ bend_association assoc =(bend_association) client_data;
+ if (!bend_assoc_is_alive(assoc))
+ return 1;
+ return 0;
+}
+
+static Z_RPNQuery *query_add_sortkeys(ODR o, Z_RPNQuery *query,
+ const char *sortKeys)
+{
+#if YAZ_VERSIONL >= 0x40200
+ /* sortkey layour: path,schema,ascending,caseSensitive,missingValue */
+ /* see cql_sortby_to_sortkeys of YAZ. */
+ char **sortspec;
+ int num_sortspec = 0;
+ int i;
+
+ if (sortKeys)
+ nmem_strsplit_blank(odr_getmem(o), sortKeys, &sortspec, &num_sortspec);
+ if (num_sortspec > 0)
+ {
+ Z_RPNQuery *nquery;
+ WRBUF w = wrbuf_alloc();
+
+ /* left operand 'd' will be replaced by original query */
+ wrbuf_puts(w, "@or d");
+ for (i = 0; i < num_sortspec; i++)
+ {
+ char **arg;
+ int num_arg;
+ int ascending = 1;
+ nmem_strsplitx(odr_getmem(o), ",", sortspec[i], &arg, &num_arg, 0);
+
+ if (num_arg > 5 || num_arg < 1)
+ {
+ yaz_log(YLOG_WARN, "Invalid sort spec '%s' num_arg=%d",
+ sortspec[i], num_arg);
+ break;
+ }
+ if (num_arg > 2 && arg[2][0])
+ ascending = atoi(arg[2]);
+
+ if (i < num_sortspec-1)
+ wrbuf_puts(w, " @or");
+ wrbuf_puts(w, " @attr 1=");
+ yaz_encode_pqf_term(w, arg[0], strlen(arg[0]));
+ wrbuf_printf(w, "@attr 7=%d %d", ascending ? 1 : 2, i);
+ }
+ nquery = p_query_rpn(o, wrbuf_cstr(w));
+ if (!nquery)
+ {
+ yaz_log(YLOG_WARN, "query_add_sortkeys: bad RPN: '%s'",
+ wrbuf_cstr(w));
+ }
+ else
+ {
+ Z_RPNStructure *s = nquery->RPNStructure;
+
+ if (s->which != Z_RPNStructure_complex)
+ {
+ yaz_log(YLOG_WARN, "query_add_sortkeys: not complex operand");
+ }
+ else
+ {
+ /* left operand 'd' is replaced by origial query */
+ s->u.complex->s1 = query->RPNStructure;
+ /* and original query points to our new or+sort things */
+ query->RPNStructure = s;
+ }
+ }
+ wrbuf_destroy(w);
+ }
+#else
+ if (sortKeys)
+ {
+ yaz_log(YLOG_WARN, "sortkeys ignored because YAZ version < 4.2.0");
+ }
+#endif
+ return query;
+}
+