1 /* $Id: gduutil.cpp,v 1.14 2006-10-04 11:21:47 marc Exp $
2 Copyright (c) 2005-2006, Index Data.
4 See the LICENSE file for details
10 #include <yaz/wrbuf.h>
11 #include <yaz/querytowrbuf.h>
16 namespace mp = metaproxy_1;
18 // Doxygen doesn't like mp::gdu, so we use this instead
19 namespace mp_gdu = metaproxy_1::gdu;
21 std::ostream& std::operator<<(std::ostream& os, Z_GDU& zgdu)
23 if (zgdu.which == Z_GDU_Z3950)
27 os << *(zgdu.u.z3950);
29 else if (zgdu.which == Z_GDU_HTTP_Request)
32 if (zgdu.u.HTTP_Request)
33 os << " " << *(zgdu.u.HTTP_Request);
35 else if (zgdu.which == Z_GDU_HTTP_Response)
37 os << "HTTP_Response";
38 if (zgdu.u.HTTP_Response)
39 os << " " << *(zgdu.u.HTTP_Response);
46 std::ostream& std::operator<<(std::ostream& os, Z_HTTP_Request& httpreq)
48 os << httpreq.method << " ";
54 std::ostream& std::operator<<(std::ostream& os, Z_HTTP_Response& httpres)
56 os << httpres.code << " ";
57 os << httpres.content_len;
61 std::ostream& std::operator<<(std::ostream& os, Z_Records & rs)
64 case Z_Records_DBOSD :
67 if (rs.u.nonSurrogateDiagnostic)
68 os << *(rs.u.nonSurrogateDiagnostic);
70 case Z_Records_multipleNSD:
71 os << "Z_Records_multipleNSD";
72 //os << *(rs.u.multipleNonSurDiagnostics);
81 std::ostream& std::operator<<(std::ostream& os, Z_DiagRec& dr)
84 case Z_DiagRec_defaultFormat:
85 if (dr.u.defaultFormat)
86 os << *(dr.u.defaultFormat);
88 case Z_DiagRec_externallyDefined :
89 os << "Z_DiagRec_externallyDefined";
98 std::ostream& std::operator<<(std::ostream& os, Z_DefaultDiagFormat& ddf)
101 os << *(ddf.condition) << " ";
104 case Z_DefaultDiagFormat_v2Addinfo:
105 os << ddf.u.v2Addinfo;
107 case Z_DefaultDiagFormat_v3Addinfo:
108 os << ddf.u.v3Addinfo;
111 os << "Z_DefaultDiagFormat" ;
117 std::ostream& std::operator<<(std::ostream& os, Z_APDU& zapdu)
119 switch(zapdu.which) {
121 case Z_APDU_initRequest:
122 os << " " << "initRequest" << " ";
126 = zapdu.u.initRequest;
128 Z_IdAuthentication *a = ir->idAuthentication;
129 if (a && a->which == Z_IdAuthentication_idPass )
130 os << a->u.idPass->userId << " ";
131 //<< ":" << a->u.idPass->groupId << " ";
135 std::list<std::string> vhosts;
136 mp::util::get_vhost_otherinfo(ir->otherInfo, vhosts);
138 copy(vhosts.begin(), vhosts.end(),
139 ostream_iterator<string>(os, " "));
144 os << (ir->implementationId) << " "
145 //<< ir->referenceId << " "
146 << (ir->implementationName) << " "
147 << (ir->implementationVersion);
150 case Z_APDU_initResponse:
151 os << " " << "initResponse" << " ";
154 = zapdu.u.initResponse;
155 if (ir->result && *(ir->result))
157 << (ir->implementationId) << " "
158 //<< ir->referenceId << " "
159 << (ir->implementationName) << " "
160 << (ir->implementationVersion) << " ";
165 case Z_APDU_searchRequest:
166 os << " " << "searchRequest" << " ";
169 = zapdu.u.searchRequest;
171 for (int i = 0; i < sr->num_databaseNames; i++)
173 os << sr->databaseNames[i];
174 if (i+1 == sr->num_databaseNames)
180 WRBUF wr = wrbuf_alloc();
181 yaz_query_to_wrbuf(wr, sr->query);
186 case Z_APDU_searchResponse:
187 os << " " << "searchResponse" << " ";
190 = zapdu.u.searchResponse;
191 if (sr->searchStatus && *(sr->searchStatus))
195 os << " " << *(sr->resultCount);
198 //<< sr->referenceId << " "
199 if (sr->numberOfRecordsReturned)
200 os << " " << *(sr->numberOfRecordsReturned);
203 if (sr->nextResultSetPosition)
204 os << " " << *(sr->nextResultSetPosition);
210 os << "DIAG " << *(sr->records);
215 case Z_APDU_presentRequest:
216 os << " " << "presentRequest";
218 Z_PresentRequest *pr = zapdu.u.presentRequest;
220 os << " " << (pr->resultSetId);
223 //<< pr->referenceId << " "
224 if (pr->resultSetStartPoint)
225 os << " " << *(pr->resultSetStartPoint);
228 if (pr->numberOfRecordsRequested)
229 os << " " << *(pr->numberOfRecordsRequested);
232 if (pr->preferredRecordSyntax)
233 //os << " " << pr->preferredRecordSyntax;
234 os << " " <<(oid_getentbyoid(pr->preferredRecordSyntax))->desc;
239 // os << " " << *(pr->);
244 case Z_APDU_presentResponse:
245 os << " " << "presentResponse" << " ";
247 Z_PresentResponse *pr
248 = zapdu.u.presentResponse;
249 if ((pr->presentStatus) && !*(pr->presentStatus))
252 //<< pr->referenceId << " "
253 if (pr->numberOfRecordsReturned)
254 os << " " << *(pr->numberOfRecordsReturned);
257 if (pr->nextResultSetPosition)
258 os << " " << *(pr->nextResultSetPosition);
264 os << "DIAG " << *(pr->records);
268 //os << "DIAG" << " "
270 //<< pr->referenceId << " "
271 //<< *(pr->numberOfRecordsReturned) << " "
272 //<< *(pr->nextResultSetPosition);
275 case Z_APDU_deleteResultSetRequest:
276 os << " " << "deleteResultSetRequest";
278 case Z_APDU_deleteResultSetResponse:
279 os << " " << "deleteResultSetResponse";
281 case Z_APDU_accessControlRequest:
282 os << " " << "accessControlRequest";
284 case Z_APDU_accessControlResponse:
285 os << " " << "accessControlResponse";
287 case Z_APDU_resourceControlRequest:
288 os << " " << "resourceControlRequest";
290 case Z_APDU_resourceControlResponse:
291 os << " " << "resourceControlResponse";
293 case Z_APDU_triggerResourceControlRequest:
294 os << " " << "triggerResourceControlRequest";
296 case Z_APDU_resourceReportRequest:
297 os << " " << "resourceReportRequest";
299 case Z_APDU_resourceReportResponse:
300 os << " " << "resourceReportResponse";
302 case Z_APDU_scanRequest:
303 os << " " << "scanRequest" << " ";
306 = zapdu.u.scanRequest;
310 for (int i = 0; i < sr->num_databaseNames; i++)
312 os << sr->databaseNames[i];
313 if (i+1 == sr->num_databaseNames)
318 if (sr->numberOfTermsRequested)
319 os << " " << *(sr->numberOfTermsRequested);
322 if (sr->preferredPositionInResponse)
323 os << " " << *(sr->preferredPositionInResponse);
327 os << " " << *(sr->stepSize);
331 if (sr->termListAndStartPoint)
333 WRBUF wr = wrbuf_alloc();
334 yaz_scan_to_wrbuf(wr, sr->termListAndStartPoint, VAL_NONE);
343 case Z_APDU_scanResponse:
344 os << " " << "scanResponse" << " ";
347 = zapdu.u.scanResponse;
350 if ((sr->scanStatus) && !*(sr->scanStatus))
353 //<< *(sr->scanStatus) << " "
354 if (sr->numberOfEntriesReturned)
355 os << " " << *(sr->numberOfEntriesReturned);
358 //<< sr->referenceId << " "
359 if (sr->positionOfTerm)
360 os << " " << *(sr->positionOfTerm);
364 os << " " << *(sr->stepSize);
372 os << " " << *(sr->scanStatus) << " ";
374 switch (*(sr->scanStatus)){
378 case Z_Scan_partial_1:
381 case Z_Scan_partial_2:
384 case Z_Scan_partial_3:
387 case Z_Scan_partial_4:
390 case Z_Scan_partial_5:
400 if (sr->numberOfEntriesReturned)
401 os << " " << *(sr->numberOfEntriesReturned);
408 case Z_APDU_sortRequest:
409 os << " " << "sortRequest" << " ";
411 case Z_APDU_sortResponse:
412 os << " " << "sortResponse" << " ";
414 case Z_APDU_segmentRequest:
415 os << " " << "segmentRequest" << " ";
417 case Z_APDU_extendedServicesRequest:
418 os << " " << "extendedServicesRequest";
420 Z_ExtendedServicesRequest *er
421 = zapdu.u.extendedServicesRequest;
427 switch(*(er->function))
429 case Z_ExtendedServicesRequest_create:
432 case Z_ExtendedServicesRequest_delete:
435 case Z_ExtendedServicesRequest_modify:
447 os << " " << er->userId ;
452 os << " " << er->packageName;
457 os << " " << er->description;
463 case Z_APDU_extendedServicesResponse:
464 os << " " << "extendedServicesResponse";
466 Z_ExtendedServicesResponse *er
467 = zapdu.u.extendedServicesResponse;
470 if (er->operationStatus)
473 switch (*(er->operationStatus)){
474 case Z_ExtendedServicesResponse_done:
477 case Z_ExtendedServicesResponse_accepted:
480 case Z_ExtendedServicesResponse_failure:
481 if (er->num_diagnostics)
482 os << "DIAG " << **(er->diagnostics);
496 os << " " << "close" << " ";
504 os << *(c->closeReason) << " ";
506 switch (*(c->closeReason)) {
507 case Z_Close_finished:
510 case Z_Close_shutdown:
513 case Z_Close_systemProblem:
514 os << "systemProblem";
516 case Z_Close_costLimit:
519 case Z_Close_resources:
522 case Z_Close_securityViolation:
523 os << "securityViolation";
525 case Z_Close_protocolError:
526 os << "protocolError";
528 case Z_Close_lackOfActivity:
529 os << "lackOfActivity";
531 case Z_Close_peerAbort:
534 case Z_Close_unspecified:
542 if (c->diagnosticInformation)
543 os << " " << c->diagnosticInformation;
547 case Z_APDU_duplicateDetectionRequest:
548 os << " " << "duplicateDetectionRequest";
550 case Z_APDU_duplicateDetectionResponse:
551 os << " " << "duplicateDetectionResponse";
554 os << " " << "Z_APDU " << "UNKNOWN";
566 * indent-tabs-mode: nil
567 * c-file-style: "stroustrup"
569 * vim: shiftwidth=4 tabstop=8 expandtab