summaryrefslogtreecommitdiff
path: root/cppe/src/IceE/TraceUtil.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cppe/src/IceE/TraceUtil.cpp')
-rw-r--r--cppe/src/IceE/TraceUtil.cpp385
1 files changed, 0 insertions, 385 deletions
diff --git a/cppe/src/IceE/TraceUtil.cpp b/cppe/src/IceE/TraceUtil.cpp
deleted file mode 100644
index faf4a068c9d..00000000000
--- a/cppe/src/IceE/TraceUtil.cpp
+++ /dev/null
@@ -1,385 +0,0 @@
-// **********************************************************************
-//
-// Copyright (c) 2003-2007 ZeroC, Inc. All rights reserved.
-//
-// This copy of Ice-E is licensed to you under the terms described in the
-// ICEE_LICENSE file included in this distribution.
-//
-// **********************************************************************
-
-#include <IceE/TraceUtil.h>
-#include <IceE/StringUtil.h>
-#include <IceE/ReplyStatus.h>
-#include <IceE/TraceLevels.h>
-#include <IceE/Logger.h>
-#include <IceE/BasicStream.h>
-#include <IceE/Protocol.h>
-#include <IceE/SafeStdio.h>
-#include <IceE/OperationMode.h>
-#include <IceE/Identity.h>
-#include <IceE/Instance.h>
-
-using namespace std;
-using namespace Ice;
-using namespace IceInternal;
-
-static void
-printIdentityFacetOperation(string& s, BasicStream& stream)
-{
- Identity identity;
- identity.__read(&stream);
- s += "\nidentity = ";
- s += stream.instance()->identityToString(identity);
-
- vector<string> facet;
- stream.read(facet);
- s += "\nfacet = ";
- if(!facet.empty())
- {
- s += IceUtil::escapeString(facet[0], "");
- }
-
- string operation;
- stream.read(operation);
- s += "\noperation = ";
- s += operation;
-}
-
-static void
-printRequestHeader(string& s, BasicStream& stream)
-{
- printIdentityFacetOperation(s, stream);
-
- Byte mode;
- stream.read(mode);
- s += Ice::printfToString("\nmode = %d ", static_cast<int>(mode));
- switch(mode)
- {
- case Normal:
- {
- s += "(normal)";
- break;
- }
-
- case Nonmutating:
- {
- s += "(nonmutating)";
- break;
- }
-
- case Idempotent:
- {
- s += "(idempotent)";
- break;
- }
-
- default:
- {
- s += "(unknown)";
- break;
- }
- }
-
- Int sz;
- stream.readSize(sz);
- s += "\ncontext = ";
- while(sz--)
- {
- pair<string, string> pair;
- stream.read(pair.first);
- stream.read(pair.second);
- s += pair.first;
- s += "/";
- s += pair.second;
- if(sz)
- {
- s += ", ";
- }
- }
-}
-
-static void
-printHeader(string& s, BasicStream& stream)
-{
- Byte magicNumber;
- stream.read(magicNumber); // Don't bother printing the magic number
- stream.read(magicNumber);
- stream.read(magicNumber);
- stream.read(magicNumber);
-
- Byte pMajor;
- Byte pMinor;
- stream.read(pMajor);
- stream.read(pMinor);
- //Ice::printfToString("\nprotocol version = %d.%d", static_cast<unsigned>(pMajor),
- //static_cast<unsigned>(pMinor);
-
- Byte eMajor;
- Byte eMinor;
- stream.read(eMajor);
- stream.read(eMinor);
- //Ice::printfToString("\nencoding version = %d.%d", static_cast<unsigned>(eMajor),
- //static_cast<unsigned>(eMinor);
-
- Byte type;
- stream.read(type);
- s += Ice::printfToString("\nmessage type = %d ", static_cast<int>(type));
-
- switch(type)
- {
- case requestMsg:
- {
- s += "(request)";
- break;
- }
-
- case requestBatchMsg:
- {
- s += "(batch request)";
- break;
- }
-
- case replyMsg:
- {
- s += "(reply)";
- break;
- }
-
- case closeConnectionMsg:
- {
- s += "(close connection)";
- break;
- }
-
- case validateConnectionMsg:
- {
- s += "(validate connection)";
- break;
- }
-
- default:
- {
- s += "(unknown)";
- break;
- }
- }
-
- Byte compress;
- stream.read(compress);
- s += Ice::printfToString("\ncompression status = %d ", static_cast<int>(compress));
-
- switch(compress)
- {
- case 0:
- {
- s += "(not compressed; do not compress response, if any)";
- break;
- }
-
- case 1:
- {
- s += "(not compressed; compress response, if any)";
- break;
- }
-
- case 2:
- {
- s += "(compressed; compress response, if any)";
- break;
- }
-
- default:
- {
- s += "(unknown)";
- break;
- }
- }
-
- Int size;
- stream.read(size);
- s += Ice::printfToString("\nmessage size = %d", size);
-}
-
-void
-IceInternal::traceHeader(const char* heading, const BasicStream& str, const LoggerPtr& logger,
- const TraceLevelsPtr& tl)
-{
- BasicStream& stream = const_cast<BasicStream&>(str);
- BasicStream::Container::iterator p = stream.i;
- stream.i = stream.b.begin();
-
- string s(heading);
- printHeader(s, stream);
-
- logger->trace(tl->protocolCat, s);
- stream.i = p;
-}
-
-void
-IceInternal::traceRequest(const char* heading, const BasicStream& str, const LoggerPtr& logger,
- const TraceLevelsPtr& tl)
-{
- BasicStream& stream = const_cast<BasicStream&>(str);
- BasicStream::Container::iterator p = stream.i;
- stream.i = stream.b.begin();
-
- string s(heading);
- printHeader(s, stream);
-
- Int requestId;
- stream.read(requestId);
- s += Ice::printfToString("\nrequest id = %d", requestId);
- if(requestId == 0)
- {
- s += " (oneway)";
- }
-
- printRequestHeader(s, stream);
-
- logger->trace(tl->protocolCat, s);
- stream.i = p;
-}
-
-#ifdef ICEE_HAS_BATCH
-void
-IceInternal::traceBatchRequest(const char* heading, const BasicStream& str, const LoggerPtr& logger,
- const TraceLevelsPtr& tl)
-{
- BasicStream& stream = const_cast<BasicStream&>(str);
- BasicStream::Container::iterator p = stream.i;
- stream.i = stream.b.begin();
-
- string s(heading);
- printHeader(s, stream);
-
- int batchRequestNum;
- stream.read(batchRequestNum);
- s += Ice::printfToString("\nnumber of requests = %d", batchRequestNum);
-
- for(int i = 0; i < batchRequestNum; ++i)
- {
- s += Ice::printfToString("\nrequest #%d:", i);
- printRequestHeader(s, stream);
- stream.skipEncaps();
- }
-
- logger->trace(tl->protocolCat, s);
- stream.i = p;
-}
-#endif
-
-void
-IceInternal::traceReply(const char* heading, const BasicStream& str, const LoggerPtr& logger,
- const TraceLevelsPtr& tl)
-{
- BasicStream& stream = const_cast<BasicStream&>(str);
- BasicStream::Container::iterator p = stream.i;
- stream.i = stream.b.begin();
-
- string s(heading);
- printHeader(s, stream);
-
- Int requestId;
- stream.read(requestId);
- s += Ice::printfToString("\nrequest id = %d", requestId);
-
- Byte replyStatus;
- stream.read(replyStatus);
- s += Ice::printfToString("\nreply status = %d ", static_cast<int>(replyStatus));
- switch(replyStatus)
- {
- case replyOK:
- {
- s += "(ok)";
- break;
- }
-
- case replyUserException:
- {
- s += "(user exception)";
- break;
- }
-
- case replyObjectNotExist:
- case replyFacetNotExist:
- case replyOperationNotExist:
- {
- switch(replyStatus)
- {
- case replyObjectNotExist:
- {
- s += "(object not exist)";
- break;
- }
-
- case replyFacetNotExist:
- {
- s += "(facet not exist)";
- break;
- }
-
- case replyOperationNotExist:
- {
- s += "(operation not exist)";
- break;
- }
-
- default:
- {
- assert(false);
- break;
- }
- }
-
- printIdentityFacetOperation(s, stream);
- break;
- }
-
- case replyUnknownException:
- case replyUnknownLocalException:
- case replyUnknownUserException:
- {
- switch(replyStatus)
- {
- case replyUnknownException:
- {
- s += "(unknown exception)";
- break;
- }
-
- case replyUnknownLocalException:
- {
- s += "(unknown local exception)";
- break;
- }
-
- case replyUnknownUserException:
- {
- s += "(unknown user exception)";
- break;
- }
-
- default:
- {
- assert(false);
- break;
- }
- }
-
- string unknown;
- stream.read(unknown);
- s += "\nunknown = ";
- s += unknown;
- break;
- }
-
- default:
- {
- s += "(unknown)";
- break;
- }
- }
-
- logger->trace(tl->protocolCat, s);
- stream.i = p;
-}
generated by cgit v1.2.3 (git 2.46.0) at 2025-08-03 22:45:24 +0000