1 /* $Id: gduutil.cpp,v 1.15 2006-10-04 14:04:00 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_util = metaproxy_1::util;
24 std::ostream& std::operator<<(std::ostream& os, Z_GDU& zgdu)
26 if (zgdu.which == Z_GDU_Z3950)
30 os << *(zgdu.u.z3950);
32 else if (zgdu.which == Z_GDU_HTTP_Request)
35 if (zgdu.u.HTTP_Request)
36 os << " " << *(zgdu.u.HTTP_Request);
38 else if (zgdu.which == Z_GDU_HTTP_Response)
40 os << "HTTP_Response";
41 if (zgdu.u.HTTP_Response)
42 os << " " << *(zgdu.u.HTTP_Response);
49 std::ostream& std::operator<<(std::ostream& os, Z_HTTP_Request& httpreq)
51 os << httpreq.method << " ";
57 std::ostream& std::operator<<(std::ostream& os, Z_HTTP_Response& httpres)
59 os << httpres.code << " ";
60 os << httpres.content_len;
64 std::ostream& std::operator<<(std::ostream& os, Z_Records & rs)
67 case Z_Records_DBOSD :
70 if (rs.u.nonSurrogateDiagnostic)
71 os << *(rs.u.nonSurrogateDiagnostic);
73 case Z_Records_multipleNSD:
74 os << "Z_Records_multipleNSD";
75 //os << *(rs.u.multipleNonSurDiagnostics);
84 std::ostream& std::operator<<(std::ostream& os, Z_DiagRec& dr)
87 case Z_DiagRec_defaultFormat:
88 if (dr.u.defaultFormat)
89 os << *(dr.u.defaultFormat);
91 case Z_DiagRec_externallyDefined :
92 os << "Z_DiagRec_externallyDefined";
101 std::ostream& std::operator<<(std::ostream& os, Z_DefaultDiagFormat& ddf)
104 os << *(ddf.condition) << " ";
107 case Z_DefaultDiagFormat_v2Addinfo:
108 os << ddf.u.v2Addinfo;
110 case Z_DefaultDiagFormat_v3Addinfo:
111 os << ddf.u.v3Addinfo;
114 os << "Z_DefaultDiagFormat" ;
120 std::ostream& std::operator<<(std::ostream& os, Z_APDU& zapdu)
122 switch(zapdu.which) {
124 case Z_APDU_initRequest:
125 os << " " << "initRequest" << " ";
129 = zapdu.u.initRequest;
131 Z_IdAuthentication *a = ir->idAuthentication;
132 if (a && a->which == Z_IdAuthentication_idPass )
133 os << a->u.idPass->userId << " ";
134 //<< ":" << a->u.idPass->groupId << " ";
138 std::list<std::string> vhosts;
139 mp::util::get_vhost_otherinfo(ir->otherInfo, vhosts);
141 copy(vhosts.begin(), vhosts.end(),
142 ostream_iterator<string>(os, " "));
147 os << (ir->implementationId) << " "
148 //<< ir->referenceId << " "
149 << (ir->implementationName) << " "
150 << (ir->implementationVersion);
153 case Z_APDU_initResponse:
154 os << " " << "initResponse" << " ";
157 = zapdu.u.initResponse;
158 if (ir->result && *(ir->result))
160 << (ir->implementationId) << " "
161 //<< ir->referenceId << " "
162 << (ir->implementationName) << " "
163 << (ir->implementationVersion) << " ";
168 case Z_APDU_searchRequest:
169 os << " " << "searchRequest" << " ";
172 = zapdu.u.searchRequest;
174 for (int i = 0; i < sr->num_databaseNames; i++)
176 os << sr->databaseNames[i];
177 if (i+1 == sr->num_databaseNames)
183 WRBUF wr = wrbuf_alloc();
184 yaz_query_to_wrbuf(wr, sr->query);
189 case Z_APDU_searchResponse:
190 os << " " << "searchResponse" << " ";
193 = zapdu.u.searchResponse;
194 if (sr->searchStatus && *(sr->searchStatus))
198 os << " " << *(sr->resultCount);
201 //<< sr->referenceId << " "
202 if (sr->numberOfRecordsReturned)
203 os << " " << *(sr->numberOfRecordsReturned);
206 if (sr->nextResultSetPosition)
207 os << " " << *(sr->nextResultSetPosition);
213 os << "DIAG " << *(sr->records);
218 case Z_APDU_presentRequest:
219 os << " " << "presentRequest";
221 Z_PresentRequest *pr = zapdu.u.presentRequest;
223 os << " " << (pr->resultSetId);
226 //<< pr->referenceId << " "
227 if (pr->resultSetStartPoint)
228 os << " " << *(pr->resultSetStartPoint);
231 if (pr->numberOfRecordsRequested)
232 os << " " << *(pr->numberOfRecordsRequested);
235 if (pr->preferredRecordSyntax)
236 //os << " " << pr->preferredRecordSyntax;
237 os << " " <<(oid_getentbyoid(pr->preferredRecordSyntax))->desc;
240 if (pr->recordComposition)
241 os << " " << mp_util::record_composition_to_esn(pr->recordComposition);
246 case Z_APDU_presentResponse:
247 os << " " << "presentResponse" << " ";
249 Z_PresentResponse *pr
250 = zapdu.u.presentResponse;
251 if ((pr->presentStatus) && !*(pr->presentStatus))
254 //<< pr->referenceId << " "
255 if (pr->numberOfRecordsReturned)
256 os << " " << *(pr->numberOfRecordsReturned);
259 if (pr->nextResultSetPosition)
260 os << " " << *(pr->nextResultSetPosition);
266 os << "DIAG " << *(pr->records);
270 //os << "DIAG" << " "
272 //<< pr->referenceId << " "
273 //<< *(pr->numberOfRecordsReturned) << " "
274 //<< *(pr->nextResultSetPosition);
277 case Z_APDU_deleteResultSetRequest:
278 os << " " << "deleteResultSetRequest";
280 case Z_APDU_deleteResultSetResponse:
281 os << " " << "deleteResultSetResponse";
283 case Z_APDU_accessControlRequest:
284 os << " " << "accessControlRequest";
286 case Z_APDU_accessControlResponse:
287 os << " " << "accessControlResponse";
289 case Z_APDU_resourceControlRequest:
290 os << " " << "resourceControlRequest";
292 case Z_APDU_resourceControlResponse:
293 os << " " << "resourceControlResponse";
295 case Z_APDU_triggerResourceControlRequest:
296 os << " " << "triggerResourceControlRequest";
298 case Z_APDU_resourceReportRequest:
299 os << " " << "resourceReportRequest";
301 case Z_APDU_resourceReportResponse:
302 os << " " << "resourceReportResponse";
304 case Z_APDU_scanRequest:
305 os << " " << "scanRequest" << " ";
308 = zapdu.u.scanRequest;
312 for (int i = 0; i < sr->num_databaseNames; i++)
314 os << sr->databaseNames[i];
315 if (i+1 == sr->num_databaseNames)
320 if (sr->numberOfTermsRequested)
321 os << " " << *(sr->numberOfTermsRequested);
324 if (sr->preferredPositionInResponse)
325 os << " " << *(sr->preferredPositionInResponse);
329 os << " " << *(sr->stepSize);
333 if (sr->termListAndStartPoint)
335 WRBUF wr = wrbuf_alloc();
336 yaz_scan_to_wrbuf(wr, sr->termListAndStartPoint, VAL_NONE);
345 case Z_APDU_scanResponse:
346 os << " " << "scanResponse" << " ";
349 = zapdu.u.scanResponse;
352 if ((sr->scanStatus) && !*(sr->scanStatus))
355 //<< *(sr->scanStatus) << " "
356 if (sr->numberOfEntriesReturned)
357 os << " " << *(sr->numberOfEntriesReturned);
360 //<< sr->referenceId << " "
361 if (sr->positionOfTerm)
362 os << " " << *(sr->positionOfTerm);
366 os << " " << *(sr->stepSize);
374 os << " " << *(sr->scanStatus) << " ";
376 switch (*(sr->scanStatus)){
380 case Z_Scan_partial_1:
383 case Z_Scan_partial_2:
386 case Z_Scan_partial_3:
389 case Z_Scan_partial_4:
392 case Z_Scan_partial_5:
402 if (sr->numberOfEntriesReturned)
403 os << " " << *(sr->numberOfEntriesReturned);
410 case Z_APDU_sortRequest:
411 os << " " << "sortRequest" << " ";
413 case Z_APDU_sortResponse:
414 os << " " << "sortResponse" << " ";
416 case Z_APDU_segmentRequest:
417 os << " " << "segmentRequest" << " ";
419 case Z_APDU_extendedServicesRequest:
420 os << " " << "extendedServicesRequest";
422 Z_ExtendedServicesRequest *er
423 = zapdu.u.extendedServicesRequest;
429 switch(*(er->function))
431 case Z_ExtendedServicesRequest_create:
434 case Z_ExtendedServicesRequest_delete:
437 case Z_ExtendedServicesRequest_modify:
449 os << " " << er->userId ;
454 os << " " << er->packageName;
459 os << " " << er->description;
465 case Z_APDU_extendedServicesResponse:
466 os << " " << "extendedServicesResponse";
468 Z_ExtendedServicesResponse *er
469 = zapdu.u.extendedServicesResponse;
472 if (er->operationStatus)
475 switch (*(er->operationStatus)){
476 case Z_ExtendedServicesResponse_done:
479 case Z_ExtendedServicesResponse_accepted:
482 case Z_ExtendedServicesResponse_failure:
483 if (er->num_diagnostics)
484 os << "DIAG " << **(er->diagnostics);
498 os << " " << "close" << " ";
506 os << *(c->closeReason) << " ";
508 switch (*(c->closeReason)) {
509 case Z_Close_finished:
512 case Z_Close_shutdown:
515 case Z_Close_systemProblem:
516 os << "systemProblem";
518 case Z_Close_costLimit:
521 case Z_Close_resources:
524 case Z_Close_securityViolation:
525 os << "securityViolation";
527 case Z_Close_protocolError:
528 os << "protocolError";
530 case Z_Close_lackOfActivity:
531 os << "lackOfActivity";
533 case Z_Close_peerAbort:
536 case Z_Close_unspecified:
544 if (c->diagnosticInformation)
545 os << " " << c->diagnosticInformation;
549 case Z_APDU_duplicateDetectionRequest:
550 os << " " << "duplicateDetectionRequest";
552 case Z_APDU_duplicateDetectionResponse:
553 os << " " << "duplicateDetectionResponse";
556 os << " " << "Z_APDU " << "UNKNOWN";
568 * indent-tabs-mode: nil
569 * c-file-style: "stroustrup"
571 * vim: shiftwidth=4 tabstop=8 expandtab