1 /* This file is part of Metaproxy.
2 Copyright (C) 2005-2008 Index Data
4 Metaproxy is free software; you can redistribute it and/or modify it under
5 the terms of the GNU General Public License as published by the Free
6 Software Foundation; either version 2, or (at your option) any later
9 Metaproxy is distributed in the hope that it will be useful, but WITHOUT ANY
10 WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
14 You should have received a copy of the GNU General Public License
15 along with this program; if not, write to the Free Software
16 Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
19 #include "gduutil.hpp"
22 #include <yaz/wrbuf.h>
23 #include <yaz/oid_db.h>
24 #include <yaz/querytowrbuf.h>
29 namespace mp = metaproxy_1;
31 // Doxygen doesn't like mp::gdu, so we use this instead
32 namespace mp_util = metaproxy_1::util;
37 std::ostream& std::operator<<(std::ostream& os, Z_GDU& zgdu)
39 if (zgdu.which == Z_GDU_Z3950)
43 os << *(zgdu.u.z3950);
45 else if (zgdu.which == Z_GDU_HTTP_Request)
48 if (zgdu.u.HTTP_Request)
49 os << " " << *(zgdu.u.HTTP_Request);
51 else if (zgdu.which == Z_GDU_HTTP_Response)
53 os << "HTTP_Response";
54 if (zgdu.u.HTTP_Response)
55 os << " " << *(zgdu.u.HTTP_Response);
62 std::ostream& std::operator<<(std::ostream& os, Z_HTTP_Request& httpreq)
64 os << httpreq.method << " ";
70 std::ostream& std::operator<<(std::ostream& os, Z_HTTP_Response& httpres)
72 os << httpres.code << " ";
73 os << httpres.content_len;
77 std::ostream& std::operator<<(std::ostream& os, Z_Records & rs)
80 case Z_Records_DBOSD :
83 if (rs.u.nonSurrogateDiagnostic)
84 os << *(rs.u.nonSurrogateDiagnostic);
86 case Z_Records_multipleNSD:
87 os << "Z_Records_multipleNSD";
88 //os << *(rs.u.multipleNonSurDiagnostics);
97 std::ostream& std::operator<<(std::ostream& os, Z_DiagRec& dr)
100 case Z_DiagRec_defaultFormat:
101 if (dr.u.defaultFormat)
102 os << *(dr.u.defaultFormat);
104 case Z_DiagRec_externallyDefined :
105 os << "Z_DiagRec_externallyDefined";
114 std::ostream& std::operator<<(std::ostream& os, Z_DefaultDiagFormat& ddf)
117 os << *(ddf.condition) << " ";
120 case Z_DefaultDiagFormat_v2Addinfo:
121 os << ddf.u.v2Addinfo;
123 case Z_DefaultDiagFormat_v3Addinfo:
124 os << ddf.u.v3Addinfo;
127 os << "Z_DefaultDiagFormat" ;
133 static void dump_opt_string(std::ostream& os, const char *s)
142 static void dump_opt_int(std::ostream& os, const int *i)
151 std::ostream& std::operator<<(std::ostream& os, Z_APDU& zapdu)
153 switch(zapdu.which) {
155 case Z_APDU_initRequest:
156 os << " " << "initRequest";
160 = zapdu.u.initRequest;
162 Z_IdAuthentication *a = ir->idAuthentication;
163 if (a && a->which == Z_IdAuthentication_idPass)
164 dump_opt_string(os, a->u.idPass->userId);
165 else if (a && a->which == Z_IdAuthentication_open)
166 dump_opt_string(os, a->u.open);
168 dump_opt_string(os, 0);
171 std::list<std::string> vhosts;
172 mp::util::get_vhost_otherinfo(ir->otherInfo, vhosts);
174 copy(vhosts.begin(), vhosts.end(),
175 ostream_iterator<string>(os, " "));
180 dump_opt_string(os, ir->implementationId);
181 dump_opt_string(os, ir->implementationName);
182 dump_opt_string(os, ir->implementationVersion);
185 case Z_APDU_initResponse:
186 os << " " << "initResponse ";
189 = zapdu.u.initResponse;
190 if (ir->result && *(ir->result))
198 dump_opt_string(os, ir->implementationId);
199 dump_opt_string(os, ir->implementationName);
200 dump_opt_string(os, ir->implementationVersion);
203 case Z_APDU_searchRequest:
204 os << " " << "searchRequest" << " ";
207 = zapdu.u.searchRequest;
209 for (int i = 0; i < sr->num_databaseNames; i++)
211 os << sr->databaseNames[i];
212 if (i+1 != sr->num_databaseNames)
216 dump_opt_string(os, sr->resultSetName);
219 if (sr->preferredRecordSyntax)
221 char oid_name_str[OID_STR_MAX];
222 const char *oid_name = yaz_oid_to_string_buf(
223 sr->preferredRecordSyntax, 0, oid_name_str);
231 WRBUF wr = wrbuf_alloc();
232 yaz_query_to_wrbuf(wr, sr->query);
233 os << wrbuf_cstr(wr);
237 case Z_APDU_searchResponse:
238 os << " " << "searchResponse ";
241 = zapdu.u.searchResponse;
242 if (sr->searchStatus && *(sr->searchStatus))
245 dump_opt_int(os, sr->resultCount);
246 dump_opt_int(os, sr->numberOfRecordsReturned);
247 dump_opt_int(os, sr->nextResultSetPosition);
251 os << "DIAG " << *(sr->records);
256 case Z_APDU_presentRequest:
257 os << " " << "presentRequest";
259 Z_PresentRequest *pr = zapdu.u.presentRequest;
260 dump_opt_string(os, pr->resultSetId);
261 dump_opt_int(os, pr->resultSetStartPoint);
262 dump_opt_int(os, pr->numberOfRecordsRequested);
263 if (pr->preferredRecordSyntax)
265 char oid_name_str[OID_STR_MAX];
266 const char *oid_name = yaz_oid_to_string_buf(
267 pr->preferredRecordSyntax, 0, oid_name_str);
269 os << " " << oid_name;
273 const char * msg = 0;
274 if (pr->recordComposition)
275 msg = mp_util::record_composition_to_esn(pr->recordComposition);
276 dump_opt_string(os, msg);
279 case Z_APDU_presentResponse:
280 os << " " << "presentResponse" << " ";
282 Z_PresentResponse *pr
283 = zapdu.u.presentResponse;
284 if ((pr->presentStatus) && !*(pr->presentStatus))
287 //<< pr->referenceId << " "
288 if (pr->numberOfRecordsReturned)
289 os << " " << *(pr->numberOfRecordsReturned);
292 if (pr->nextResultSetPosition)
293 os << " " << *(pr->nextResultSetPosition);
299 os << "DIAG " << *(pr->records);
303 //os << "DIAG" << " "
305 //<< pr->referenceId << " "
306 //<< *(pr->numberOfRecordsReturned) << " "
307 //<< *(pr->nextResultSetPosition);
310 case Z_APDU_deleteResultSetRequest:
311 os << " " << "deleteResultSetRequest";
313 case Z_APDU_deleteResultSetResponse:
314 os << " " << "deleteResultSetResponse";
316 case Z_APDU_accessControlRequest:
317 os << " " << "accessControlRequest";
319 case Z_APDU_accessControlResponse:
320 os << " " << "accessControlResponse";
322 case Z_APDU_resourceControlRequest:
323 os << " " << "resourceControlRequest";
325 case Z_APDU_resourceControlResponse:
326 os << " " << "resourceControlResponse";
328 case Z_APDU_triggerResourceControlRequest:
329 os << " " << "triggerResourceControlRequest";
331 case Z_APDU_resourceReportRequest:
332 os << " " << "resourceReportRequest";
334 case Z_APDU_resourceReportResponse:
335 os << " " << "resourceReportResponse";
337 case Z_APDU_scanRequest:
338 os << " " << "scanRequest" << " ";
341 = zapdu.u.scanRequest;
345 for (int i = 0; i < sr->num_databaseNames; i++)
347 os << sr->databaseNames[i];
348 if (i+1 != sr->num_databaseNames)
351 dump_opt_int(os, sr->numberOfTermsRequested);
352 dump_opt_int(os, sr->preferredPositionInResponse);
353 dump_opt_int(os, sr->stepSize);
356 if (sr->termListAndStartPoint)
358 WRBUF wr = wrbuf_alloc();
359 yaz_scan_to_wrbuf(wr, sr->termListAndStartPoint,
361 os << wrbuf_cstr(wr);
369 case Z_APDU_scanResponse:
370 os << " " << "scanResponse" << " ";
373 = zapdu.u.scanResponse;
382 switch (*(sr->scanStatus)){
386 case Z_Scan_partial_1:
389 case Z_Scan_partial_2:
392 case Z_Scan_partial_3:
395 case Z_Scan_partial_4:
398 case Z_Scan_partial_5:
408 dump_opt_int(os, sr->numberOfEntriesReturned);
409 dump_opt_int(os, sr->positionOfTerm);
410 dump_opt_int(os, sr->stepSize);
414 case Z_APDU_sortRequest:
415 os << " " << "sortRequest" << " ";
417 case Z_APDU_sortResponse:
418 os << " " << "sortResponse" << " ";
420 case Z_APDU_segmentRequest:
421 os << " " << "segmentRequest" << " ";
423 case Z_APDU_extendedServicesRequest:
424 os << " " << "extendedServicesRequest";
426 Z_ExtendedServicesRequest *er
427 = zapdu.u.extendedServicesRequest;
433 switch(*(er->function))
435 case Z_ExtendedServicesRequest_create:
438 case Z_ExtendedServicesRequest_delete:
441 case Z_ExtendedServicesRequest_modify:
453 os << " " << er->userId ;
458 os << " " << er->packageName;
463 os << " " << er->description;
469 case Z_APDU_extendedServicesResponse:
470 os << " " << "extendedServicesResponse";
472 Z_ExtendedServicesResponse *er
473 = zapdu.u.extendedServicesResponse;
476 if (er->operationStatus)
479 switch (*(er->operationStatus)){
480 case Z_ExtendedServicesResponse_done:
483 case Z_ExtendedServicesResponse_accepted:
486 case Z_ExtendedServicesResponse_failure:
487 if (er->num_diagnostics)
488 os << "DIAG " << **(er->diagnostics);
502 os << " " << "close" << " ";
510 os << *(c->closeReason) << " ";
512 switch (*(c->closeReason)) {
513 case Z_Close_finished:
516 case Z_Close_shutdown:
519 case Z_Close_systemProblem:
520 os << "systemProblem";
522 case Z_Close_costLimit:
525 case Z_Close_resources:
528 case Z_Close_securityViolation:
529 os << "securityViolation";
531 case Z_Close_protocolError:
532 os << "protocolError";
534 case Z_Close_lackOfActivity:
535 os << "lackOfActivity";
537 case Z_Close_peerAbort:
540 case Z_Close_unspecified:
548 if (c->diagnosticInformation)
549 os << " " << c->diagnosticInformation;
553 case Z_APDU_duplicateDetectionRequest:
554 os << " " << "duplicateDetectionRequest";
556 case Z_APDU_duplicateDetectionResponse:
557 os << " " << "duplicateDetectionResponse";
560 os << " " << "Z_APDU " << "UNKNOWN";
572 * indent-tabs-mode: nil
573 * c-file-style: "stroustrup"
575 * vim: shiftwidth=4 tabstop=8 expandtab