X-Git-Url: http://lists.indexdata.com/cgi-bin?a=blobdiff_plain;f=src%2Fgduutil.cpp;h=7ef3f03dfb5427faa1a4153b16e4e867f351000a;hb=ef427d6fec231e98a5babda2436dad7968df7b46;hp=7dcd712472e4c92c7d09c645a1f31743716643a4;hpb=e207284fc2943aa6a933cf3405f60bcdc584280d;p=metaproxy-moved-to-github.git diff --git a/src/gduutil.cpp b/src/gduutil.cpp index 7dcd712..7ef3f03 100644 --- a/src/gduutil.cpp +++ b/src/gduutil.cpp @@ -1,15 +1,17 @@ -/* $Id: gduutil.cpp,v 1.2 2006-08-30 08:35:47 marc Exp $ +/* $Id: gduutil.cpp,v 1.9 2006-09-19 13:50:17 marc Exp $ Copyright (c) 2005-2006, Index Data. See the LICENSE file for details */ #include "gduutil.hpp" +#include "util.hpp" #include #include #include +#include namespace mp = metaproxy_1; @@ -19,13 +21,96 @@ namespace mp_gdu = metaproxy_1::gdu; std::ostream& std::operator<<(std::ostream& os, Z_GDU& zgdu) { if (zgdu.which == Z_GDU_Z3950) - os << "Z3950" << " " << *(zgdu.u.z3950) ; + { + os << "Z3950"; + if (zgdu.u.z3950) + os << *(zgdu.u.z3950); + } else if (zgdu.which == Z_GDU_HTTP_Request) - os << "HTTP_Request" << " "; + { + os << "HTTP_Request"; + if (zgdu.u.HTTP_Request) + os << " " << *(zgdu.u.HTTP_Request); + } else if (zgdu.which == Z_GDU_HTTP_Response) - os << "HTTP_Response" << " "; + { + os << "HTTP_Response"; + if (zgdu.u.HTTP_Response) + os << " " << *(zgdu.u.HTTP_Response); + } else - os << "Z_GDU" << " "; + os << "Z_GDU"; + return os; +} + +std::ostream& std::operator<<(std::ostream& os, Z_HTTP_Request& httpreq) +{ + os << httpreq.method << " "; + os << httpreq.path; + return os; +} + + +std::ostream& std::operator<<(std::ostream& os, Z_HTTP_Response& httpres) +{ + os << httpres.code << " "; + os << httpres.content_len; + return os; +} + +std::ostream& std::operator<<(std::ostream& os, Z_Records & rs) +{ + switch(rs.which) { + case Z_Records_DBOSD : + break; + case Z_Records_NSD: + if (rs.u.nonSurrogateDiagnostic) + os << *(rs.u.nonSurrogateDiagnostic); + break; + case Z_Records_multipleNSD: + os << "Z_Records_multipleNSD"; + //os << *(rs.u.multipleNonSurDiagnostics); + break; + default: + os << "Z_Records" ; + } + + return os; +} + +std::ostream& std::operator<<(std::ostream& os, Z_DiagRec& dr) +{ + switch(dr.which) { + case Z_DiagRec_defaultFormat: + if (dr.u.defaultFormat) + os << *(dr.u.defaultFormat); + break; + case Z_DiagRec_externallyDefined : + os << "Z_DiagRec_externallyDefined"; + break; + default: + os << "Z_DiagRec" ; + } + + return os; +} + +std::ostream& std::operator<<(std::ostream& os, Z_DefaultDiagFormat& ddf) +{ + if (ddf.condition) + os << *(ddf.condition) << " "; + + switch(ddf.which) { + case Z_DefaultDiagFormat_v2Addinfo: + os << ddf.u.v2Addinfo; + break; + case Z_DefaultDiagFormat_v3Addinfo: + os << ddf.u.v3Addinfo; + break; + default: + os << "Z_DefaultDiagFormat" ; + } + return os; } @@ -34,7 +119,7 @@ std::ostream& std::operator<<(std::ostream& os, Z_APDU& zapdu) switch(zapdu.which) { case Z_APDU_initRequest: - os << "initRequest" << " "; + os << " " << "initRequest" << " "; { Z_InitRequest *ir @@ -42,36 +127,43 @@ std::ostream& std::operator<<(std::ostream& os, Z_APDU& zapdu) Z_IdAuthentication *a = ir->idAuthentication; if (a && a->which == Z_IdAuthentication_idPass ) - os << a->u.idPass->userId - << ":" << a->u.idPass->groupId << " "; + os << a->u.idPass->userId << " "; + //<< ":" << a->u.idPass->groupId << " "; else - os << "-:-" << " "; + os << "-" << " "; + std::list vhosts; + mp::util::get_vhost_otherinfo(ir->otherInfo, vhosts); + if (vhosts.size()){ + copy(vhosts.begin(), vhosts.end(), + ostream_iterator(os, " ")); + } + else + os << "-" << " " ; os << (ir->implementationId) << " " //<< ir->referenceId << " " << (ir->implementationName) << " " - << (ir->implementationVersion) << " "; + << (ir->implementationVersion); } break; case Z_APDU_initResponse: - os << "initResponse" << " "; + os << " " << "initResponse" << " "; { Z_InitResponse *ir = zapdu.u.initResponse; - if (*(ir->result)) + if (ir->result && *(ir->result)) os << "OK" << " " << (ir->implementationId) << " " //<< ir->referenceId << " " << (ir->implementationName) << " " << (ir->implementationVersion) << " "; else - os << "DIAG" << " "; + os << "DIAG"; } break; case Z_APDU_searchRequest: - os << "searchRequest" << " " - << "--" << " "; + os << " " << "searchRequest" << " "; { Z_SearchRequest *sr = zapdu.u.searchRequest; @@ -87,218 +179,502 @@ std::ostream& std::operator<<(std::ostream& os, Z_APDU& zapdu) WRBUF wr = wrbuf_alloc(); yaz_query_to_wrbuf(wr, sr->query); - os << wrbuf_buf(wr) << " "; + os << wrbuf_buf(wr); wrbuf_free(wr, 1); } break; case Z_APDU_searchResponse: - os << "searchResponse" << " "; + os << " " << "searchResponse" << " "; { Z_SearchResponse *sr = zapdu.u.searchResponse; - if (*(sr->searchStatus)) - os << "OK" << " " - << *(sr->resultCount) << " " - //<< sr->referenceId << " " - << *(sr->numberOfRecordsReturned) << " " - << *(sr->nextResultSetPosition) << " "; - else - os << "DIAG" << " "; + if (sr->searchStatus && *(sr->searchStatus)) + { + os << "OK"; + if (sr->resultCount) + os << " " << *(sr->resultCount); + else + os << " -"; + //<< sr->referenceId << " " + if (sr->numberOfRecordsReturned) + os << " " << *(sr->numberOfRecordsReturned); + else + os << " -"; + if (sr->nextResultSetPosition) + os << " " << *(sr->nextResultSetPosition); + else + os << " -"; + } + else + if (sr->records) + os << "DIAG " << *(sr->records); + else + os << "ERROR"; } break; case Z_APDU_presentRequest: - os << "presentRequest" << " " - << "--" << " "; + os << " " << "presentRequest" << " "; { Z_PresentRequest *pr = zapdu.u.presentRequest; os << pr->resultSetId << " " //<< pr->referenceId << " " << *(pr->resultSetStartPoint) << " " - << *(pr->numberOfRecordsRequested) << " "; + << *(pr->numberOfRecordsRequested); } break; case Z_APDU_presentResponse: - os << "presentResponse" << " "; + os << " " << "presentResponse" << " "; { Z_PresentResponse *pr = zapdu.u.presentResponse; - if (!*(pr->presentStatus)) - os << "OK" << " " - << "-" << " " - //<< pr->referenceId << " " - << *(pr->numberOfRecordsReturned) << " " - << *(pr->nextResultSetPosition) << " "; + if ((pr->presentStatus) && !*(pr->presentStatus)) + { + os << "OK"; + //<< pr->referenceId << " " + if (pr->numberOfRecordsReturned) + os << " " << *(pr->numberOfRecordsReturned); + else + os << " -"; + if (pr->nextResultSetPosition) + os << " " << *(pr->nextResultSetPosition); + else + os << " -"; + } else - os << "DIAG" << " " - << "-" << " " - //<< pr->referenceId << " " - << *(pr->numberOfRecordsReturned) << " " - << *(pr->nextResultSetPosition) << " "; + if (pr->records) + os << "DIAG " << *(pr->records); + else + os << "ERROR"; + + //os << "DIAG" << " " + //<< "-" << " " + //<< pr->referenceId << " " + //<< *(pr->numberOfRecordsReturned) << " " + //<< *(pr->nextResultSetPosition); } break; case Z_APDU_deleteResultSetRequest: - os << "deleteResultSetRequest" << " "; + os << " " << "deleteResultSetRequest"; break; case Z_APDU_deleteResultSetResponse: - os << "deleteResultSetResponse" << " "; + os << " " << "deleteResultSetResponse"; break; case Z_APDU_accessControlRequest: - os << "accessControlRequest" << " "; + os << " " << "accessControlRequest"; break; case Z_APDU_accessControlResponse: - os << "accessControlResponse" << " "; + os << " " << "accessControlResponse"; break; case Z_APDU_resourceControlRequest: - os << "resourceControlRequest" << " "; + os << " " << "resourceControlRequest"; break; case Z_APDU_resourceControlResponse: - os << "resourceControlResponse" << " "; + os << " " << "resourceControlResponse"; break; case Z_APDU_triggerResourceControlRequest: - os << "triggerResourceControlRequest" << " "; + os << " " << "triggerResourceControlRequest"; break; case Z_APDU_resourceReportRequest: - os << "resourceReportRequest" << " "; + os << " " << "resourceReportRequest"; break; case Z_APDU_resourceReportResponse: - os << "resourceReportResponse" << " "; + os << " " << "resourceReportResponse"; break; case Z_APDU_scanRequest: - os << "scanRequest" << " " - << "--" << " "; + os << " " << "scanRequest" << " "; { Z_ScanRequest *sr = zapdu.u.scanRequest; - - for (int i = 0; i < sr->num_databaseNames; i++) + + if (sr) { - os << sr->databaseNames[i]; - if (i+1 == sr->num_databaseNames) - os << " "; - else + for (int i = 0; i < sr->num_databaseNames; i++) + { + os << sr->databaseNames[i]; + if (i+1 == sr->num_databaseNames) + os << " "; + else os << "+"; + } + if (sr->numberOfTermsRequested) + os << " " << *(sr->numberOfTermsRequested); + else + os << " -"; + if (sr->preferredPositionInResponse) + os << " " << *(sr->preferredPositionInResponse); + else + os << " -"; + if (sr->stepSize) + os << " " << *(sr->stepSize); + else + os << " -"; + + if (sr->termListAndStartPoint) + { + WRBUF wr = wrbuf_alloc(); + yaz_scan_to_wrbuf(wr, sr->termListAndStartPoint, VAL_NONE); + os << wrbuf_buf(wr); + wrbuf_free(wr, 1); + } + else + os << " -"; } - - os << *(sr->numberOfTermsRequested) << " " - << *(sr->preferredPositionInResponse) << " " - << *(sr->stepSize) << " "; - - WRBUF wr = wrbuf_alloc(); - yaz_scan_to_wrbuf(wr, sr->termListAndStartPoint, VAL_NONE); - os << wrbuf_buf(wr) << " "; - wrbuf_free(wr, 1); } break; case Z_APDU_scanResponse: - os << "scanResponse" << " "; + os << " " << "scanResponse" << " "; { Z_ScanResponse *sr = zapdu.u.scanResponse; - if (*(sr->scanStatus)) - os << "OK" << " " - << *(sr->scanStatus) << " " - << *(sr->numberOfEntriesReturned) << " " - //<< sr->referenceId << " " - << *(sr->positionOfTerm) << " " - << *(sr->stepSize) << " "; - else - os << "DIAG" << " " - << *(sr->scanStatus) << " " - << *(sr->numberOfEntriesReturned) << " " + if (sr) + { + if ((sr->scanStatus) && !*(sr->scanStatus)) + { + os << "OK"; + //<< *(sr->scanStatus) << " " + if (sr->numberOfEntriesReturned) + os << " " << *(sr->numberOfEntriesReturned); + else + os << " -"; //<< sr->referenceId << " " - << *(sr->positionOfTerm) << " " - << *(sr->stepSize) << " "; + if (sr->positionOfTerm) + os << " " << *(sr->positionOfTerm); + else + os << " -"; + if (sr->stepSize) + os << " " << *(sr->stepSize); + else + os << " -"; + } + else { + os << "ERROR"; + if (sr->scanStatus) + { + os << " " << *(sr->scanStatus) << " "; + + switch (*(sr->scanStatus)){ + case Z_Scan_success: + os << "success "; + break; + case Z_Scan_partial_1: + os << "partial_1"; + break; + case Z_Scan_partial_2: + os << "partial_2"; + break; + case Z_Scan_partial_3: + os << "partial_3"; + break; + case Z_Scan_partial_4: + os << "partial_4"; + break; + case Z_Scan_partial_5: + os << "partial_5"; + break; + case Z_Scan_failure: + os << "failure"; + break; + default: + os << "unknown"; + } + } + if (sr->numberOfEntriesReturned) + os << " " << *(sr->numberOfEntriesReturned); + else + os << " -"; + } + } } break; case Z_APDU_sortRequest: - os << "sortRequest" << " "; + os << " " << "sortRequest" << " "; break; case Z_APDU_sortResponse: - os << "sortResponse" << " "; + os << " " << "sortResponse" << " "; break; case Z_APDU_segmentRequest: - os << "segmentRequest" << " "; + os << " " << "segmentRequest" << " "; break; case Z_APDU_extendedServicesRequest: - os << "extendedServicesRequest" << " "; -// { -// Z_ExtendedServicesRequest *er -// = zapdu.u.extendedServicesRequest; - -// os << er->packageName << " " -// << er->userId << " " -// << er->description << " "; -// } + os << " " << "extendedServicesRequest"; + { + Z_ExtendedServicesRequest *er + = zapdu.u.extendedServicesRequest; + if (er) + { + if (er->function) + { + os << " "; + switch(*(er->function)) + { + case Z_ExtendedServicesRequest_create: + os << "create"; + break; + case Z_ExtendedServicesRequest_delete: + os << "delete"; + break; + case Z_ExtendedServicesRequest_modify: + os << "modify"; + break; + default: + os << "unknown"; + } + } + else + os << " -"; + + + if (er->userId) + os << " " << er->userId ; + else + os << " -"; + + if (er->packageName) + os << " " << er->packageName; + else + os << " -"; + + if (er->description) + os << " " << er->description; + else + os << " -"; + } + } break; case Z_APDU_extendedServicesResponse: - os << "extendedServicesResponse" << " "; -// { -// Z_ExtendedServicesResponse *er -// = zapdu.u.extendedServicesResponse; - -// os << *(er->operationStatus) << " " -// << er->num_diagnostics << " "; -// } + os << " " << "extendedServicesResponse"; + { + Z_ExtendedServicesResponse *er + = zapdu.u.extendedServicesResponse; + if (er) + { + if (er->operationStatus) + { + os << " "; + switch (*(er->operationStatus)){ + case Z_ExtendedServicesResponse_done: + os << "OK"; + break; + case Z_ExtendedServicesResponse_accepted: + os << "ACCEPT"; + break; + case Z_ExtendedServicesResponse_failure: + if (er->num_diagnostics) + os << "DIAG " << **(er->diagnostics); + else + os << "ERROR"; + break; + default: + os << "unknown"; + } + } + else + os << " -"; + } + } break; case Z_APDU_close: - os << "close" << " "; + os << " " << "close" << " "; { Z_Close *c = zapdu.u.close; + if (c) + { + if (c->closeReason) + { + os << *(c->closeReason) << " "; - os << *(c->closeReason) << " "; - switch (*(c->closeReason)) { - case Z_Close_finished: - os << "finished" << " "; - break; - case Z_Close_shutdown: - os << "shutdown" << " "; - break; - case Z_Close_systemProblem: - os << "systemProblem" << " "; - break; - case Z_Close_costLimit: - os << "costLimit" << " "; - break; - case Z_Close_resources: - os << "resources" << " "; - break; - case Z_Close_securityViolation: - os << "securityViolation" << " "; - break; - case Z_Close_protocolError: - os << "protocolError" << " "; - break; - case Z_Close_lackOfActivity: - os << "" << " "; - break; - case Z_Close_peerAbort: - os << "peerAbort" << " "; - break; - case Z_Close_unspecified: - os << "unspecified" << " "; - break; - default: - os << "unknown" << " "; - break; + switch (*(c->closeReason)) { + case Z_Close_finished: + os << "finished"; + break; + case Z_Close_shutdown: + os << "shutdown"; + break; + case Z_Close_systemProblem: + os << "systemProblem"; + break; + case Z_Close_costLimit: + os << "costLimit"; + break; + case Z_Close_resources: + os << "resources"; + break; + case Z_Close_securityViolation: + os << "securityViolation"; + break; + case Z_Close_protocolError: + os << "protocolError"; + break; + case Z_Close_lackOfActivity: + os << "lackOfActivity"; + break; + case Z_Close_peerAbort: + os << "peerAbort"; + break; + case Z_Close_unspecified: + os << "unspecified"; + break; + default: + os << "unknown"; + } + } + + if (c->diagnosticInformation) + os << " " << c->diagnosticInformation; } } break; case Z_APDU_duplicateDetectionRequest: - os << "duplicateDetectionRequest" << " "; + os << " " << "duplicateDetectionRequest"; break; case Z_APDU_duplicateDetectionResponse: - os << "duplicateDetectionResponse" << " "; + os << " " << "duplicateDetectionResponse"; break; default: - os << "Z_APDU " - << "UNKNOWN" << " "; + os << " " << "Z_APDU " << "UNKNOWN"; } return os; } +std::ostream& std::operator<<(std::ostream& os, Z_SRW_PDU& srw_pdu) +{ + os << "SRU"; + + switch(srw_pdu.which) { + case Z_SRW_searchRetrieve_request: + os << " " << "searchRetrieveRequest"; + { + Z_SRW_searchRetrieveRequest *sr = srw_pdu.u.request; + if (sr) + { + if (sr->database) + os << " " << (sr->database); + else + os << " -"; + if (sr->startRecord) + os << " " << *(sr->startRecord); + else + os << " -"; + if (sr->maximumRecords) + os << " " << *(sr->maximumRecords); + else + os << " -"; + if (sr->recordPacking) + os << " " << *(sr->recordPacking); + else + os << " -"; + + switch (sr->query_type){ + case Z_SRW_query_type_cql: + os << " CQL " << sr->query.cql; + break; + case Z_SRW_query_type_xcql: + os << " XCQL"; + break; + case Z_SRW_query_type_pqf: + os << " PQF " << sr->query.pqf; + break; + } + } + } + break; + case Z_SRW_searchRetrieve_response: + os << " " << "searchRetrieveResponse"; + break; + case Z_SRW_explain_request: + os << " " << "explainRequest"; + break; + case Z_SRW_explain_response: + os << " " << "explainResponse"; + break; + case Z_SRW_scan_request: + os << " " << "scanRequest"; + break; + case Z_SRW_scan_response: + os << " " << "scanResponse"; + break; + case Z_SRW_update_request: + os << " " << "updateRequest"; + break; + case Z_SRW_update_response: + os << " " << "updateResponse"; + break; + default: + os << " " << "UNKNOWN"; + } + + return os; +} + + +// { +// Z_InitRequest *ir +// = zapdu.u.initRequest; + +// Z_IdAuthentication *a = ir->idAuthentication; +// if (a && a->which == Z_IdAuthentication_idPass ) +// os << a->u.idPass->userId << " "; +// //<< ":" << a->u.idPass->groupId << " "; +// else +// os << "-" << " "; + +// std::list vhosts; +// mp::util::get_vhost_otherinfo(ir->otherInfo, vhosts); +// if (vhosts.size()){ +// copy(vhosts.begin(), vhosts.end(), +// ostream_iterator(os, " ")); +// } +// else +// os << "-" << " " ; + +// os << (ir->implementationId) << " " +// //<< ir->referenceId << " " +// << (ir->implementationName) << " " +// << (ir->implementationVersion); +// } +// break; +// case Z_APDU_initResponse: +// os << " " << "initResponse" << " "; +// { +// Z_InitResponse *ir +// = zapdu.u.initResponse; +// if (ir->result && *(ir->result)) +// os << "OK" << " " +// << (ir->implementationId) << " " +// //<< ir->referenceId << " " +// << (ir->implementationName) << " " +// << (ir->implementationVersion) << " "; +// else +// os << "DIAG"; +// } +// break; +// case Z_APDU_searchRequest: +// os << " " << "searchRequest" << " "; +// { +// Z_SearchRequest *sr +// = zapdu.u.searchRequest; + +// for (int i = 0; i < sr->num_databaseNames; i++) +// { +// os << sr->databaseNames[i]; +// if (i+1 == sr->num_databaseNames) +// os << " "; +// else +// os << "+"; +// } + +// WRBUF wr = wrbuf_alloc(); +// yaz_query_to_wrbuf(wr, sr->query); +// os << wrbuf_buf(wr); +// wrbuf_free(wr, 1); +// } +// break; + + + /* * Local variables: * c-basic-offset: 4