1 /* $Id: gduutil.cpp,v 1.17 2007-01-25 14:05:54 adam Exp $
2 Copyright (c) 2005-2007, 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 const char * msg = 0;
241 if (pr->recordComposition
242 && (msg = mp_util::record_composition_to_esn(pr->recordComposition)))
248 case Z_APDU_presentResponse:
249 os << " " << "presentResponse" << " ";
251 Z_PresentResponse *pr
252 = zapdu.u.presentResponse;
253 if ((pr->presentStatus) && !*(pr->presentStatus))
256 //<< pr->referenceId << " "
257 if (pr->numberOfRecordsReturned)
258 os << " " << *(pr->numberOfRecordsReturned);
261 if (pr->nextResultSetPosition)
262 os << " " << *(pr->nextResultSetPosition);
268 os << "DIAG " << *(pr->records);
272 //os << "DIAG" << " "
274 //<< pr->referenceId << " "
275 //<< *(pr->numberOfRecordsReturned) << " "
276 //<< *(pr->nextResultSetPosition);
279 case Z_APDU_deleteResultSetRequest:
280 os << " " << "deleteResultSetRequest";
282 case Z_APDU_deleteResultSetResponse:
283 os << " " << "deleteResultSetResponse";
285 case Z_APDU_accessControlRequest:
286 os << " " << "accessControlRequest";
288 case Z_APDU_accessControlResponse:
289 os << " " << "accessControlResponse";
291 case Z_APDU_resourceControlRequest:
292 os << " " << "resourceControlRequest";
294 case Z_APDU_resourceControlResponse:
295 os << " " << "resourceControlResponse";
297 case Z_APDU_triggerResourceControlRequest:
298 os << " " << "triggerResourceControlRequest";
300 case Z_APDU_resourceReportRequest:
301 os << " " << "resourceReportRequest";
303 case Z_APDU_resourceReportResponse:
304 os << " " << "resourceReportResponse";
306 case Z_APDU_scanRequest:
307 os << " " << "scanRequest" << " ";
310 = zapdu.u.scanRequest;
314 for (int i = 0; i < sr->num_databaseNames; i++)
316 os << sr->databaseNames[i];
317 if (i+1 == sr->num_databaseNames)
322 if (sr->numberOfTermsRequested)
323 os << " " << *(sr->numberOfTermsRequested);
326 if (sr->preferredPositionInResponse)
327 os << " " << *(sr->preferredPositionInResponse);
331 os << " " << *(sr->stepSize);
335 if (sr->termListAndStartPoint)
337 WRBUF wr = wrbuf_alloc();
338 yaz_scan_to_wrbuf(wr, sr->termListAndStartPoint, VAL_NONE);
347 case Z_APDU_scanResponse:
348 os << " " << "scanResponse" << " ";
351 = zapdu.u.scanResponse;
354 if ((sr->scanStatus) && !*(sr->scanStatus))
357 //<< *(sr->scanStatus) << " "
358 if (sr->numberOfEntriesReturned)
359 os << " " << *(sr->numberOfEntriesReturned);
362 //<< sr->referenceId << " "
363 if (sr->positionOfTerm)
364 os << " " << *(sr->positionOfTerm);
368 os << " " << *(sr->stepSize);
376 os << " " << *(sr->scanStatus) << " ";
378 switch (*(sr->scanStatus)){
382 case Z_Scan_partial_1:
385 case Z_Scan_partial_2:
388 case Z_Scan_partial_3:
391 case Z_Scan_partial_4:
394 case Z_Scan_partial_5:
404 if (sr->numberOfEntriesReturned)
405 os << " " << *(sr->numberOfEntriesReturned);
412 case Z_APDU_sortRequest:
413 os << " " << "sortRequest" << " ";
415 case Z_APDU_sortResponse:
416 os << " " << "sortResponse" << " ";
418 case Z_APDU_segmentRequest:
419 os << " " << "segmentRequest" << " ";
421 case Z_APDU_extendedServicesRequest:
422 os << " " << "extendedServicesRequest";
424 Z_ExtendedServicesRequest *er
425 = zapdu.u.extendedServicesRequest;
431 switch(*(er->function))
433 case Z_ExtendedServicesRequest_create:
436 case Z_ExtendedServicesRequest_delete:
439 case Z_ExtendedServicesRequest_modify:
451 os << " " << er->userId ;
456 os << " " << er->packageName;
461 os << " " << er->description;
467 case Z_APDU_extendedServicesResponse:
468 os << " " << "extendedServicesResponse";
470 Z_ExtendedServicesResponse *er
471 = zapdu.u.extendedServicesResponse;
474 if (er->operationStatus)
477 switch (*(er->operationStatus)){
478 case Z_ExtendedServicesResponse_done:
481 case Z_ExtendedServicesResponse_accepted:
484 case Z_ExtendedServicesResponse_failure:
485 if (er->num_diagnostics)
486 os << "DIAG " << **(er->diagnostics);
500 os << " " << "close" << " ";
508 os << *(c->closeReason) << " ";
510 switch (*(c->closeReason)) {
511 case Z_Close_finished:
514 case Z_Close_shutdown:
517 case Z_Close_systemProblem:
518 os << "systemProblem";
520 case Z_Close_costLimit:
523 case Z_Close_resources:
526 case Z_Close_securityViolation:
527 os << "securityViolation";
529 case Z_Close_protocolError:
530 os << "protocolError";
532 case Z_Close_lackOfActivity:
533 os << "lackOfActivity";
535 case Z_Close_peerAbort:
538 case Z_Close_unspecified:
546 if (c->diagnosticInformation)
547 os << " " << c->diagnosticInformation;
551 case Z_APDU_duplicateDetectionRequest:
552 os << " " << "duplicateDetectionRequest";
554 case Z_APDU_duplicateDetectionResponse:
555 os << " " << "duplicateDetectionResponse";
558 os << " " << "Z_APDU " << "UNKNOWN";
570 * indent-tabs-mode: nil
571 * c-file-style: "stroustrup"
573 * vim: shiftwidth=4 tabstop=8 expandtab