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.cpp298
1 files changed, 143 insertions, 155 deletions
diff --git a/cppe/src/IceE/TraceUtil.cpp b/cppe/src/IceE/TraceUtil.cpp
index bd2aa5f493d..ed49424b2e5 100644
--- a/cppe/src/IceE/TraceUtil.cpp
+++ b/cppe/src/IceE/TraceUtil.cpp
@@ -203,46 +203,40 @@ void
IceInternal::traceHeader(const char* heading, const BasicStream& str, const LoggerPtr& logger,
const TraceLevelsPtr& tl)
{
- if(tl->protocol >= 1)
- {
- 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;
- }
+ 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)
{
- if(tl->protocol >= 1)
+ 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)
{
- 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;
+ s += " (oneway)";
}
+
+ printRequestHeader(s, stream);
+
+ logger->trace(tl->protocolCat, s);
+ stream.i = p;
}
#ifdef ICEE_HAS_BATCH
@@ -250,29 +244,26 @@ void
IceInternal::traceBatchRequest(const char* heading, const BasicStream& str, const LoggerPtr& logger,
const TraceLevelsPtr& tl)
{
- if(tl->protocol >= 1)
- {
- BasicStream& stream = const_cast<BasicStream&>(str);
- BasicStream::Container::iterator p = stream.i;
- stream.i = stream.b.begin();
+ BasicStream& stream = const_cast<BasicStream&>(str);
+ BasicStream::Container::iterator p = stream.i;
+ stream.i = stream.b.begin();
- string s(heading);
- printHeader(s, stream);
+ string s(heading);
+ printHeader(s, stream);
- int batchRequestNum;
- stream.read(batchRequestNum);
- s += Ice::printfToString("\nnumber of requests = %d", batchRequestNum);
+ 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;
+ 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
@@ -280,117 +271,114 @@ void
IceInternal::traceReply(const char* heading, const BasicStream& str, const LoggerPtr& logger,
const TraceLevelsPtr& tl)
{
- if(tl->protocol >= 1)
+ 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 status;
+ stream.read(status);
+ s += Ice::printfToString("\nreply status = %d ", static_cast<int>(status));
+ switch(static_cast<DispatchStatus>(status))
+ {
+ case DispatchOK:
{
- BasicStream& stream = const_cast<BasicStream&>(str);
- BasicStream::Container::iterator p = stream.i;
- stream.i = stream.b.begin();
+ s += "(ok)";
+ break;
+ }
+
+ case DispatchUserException:
+ {
+ s += "(user exception)";
+ break;
+ }
- string s(heading);
- printHeader(s, stream);
+ case DispatchObjectNotExist:
+ case DispatchFacetNotExist:
+ case DispatchOperationNotExist:
+ {
+ switch(static_cast<DispatchStatus>(status))
+ {
+ case DispatchObjectNotExist:
+ {
+ s += "(object not exist)";
+ break;
+ }
- Int requestId;
- stream.read(requestId);
- s += Ice::printfToString("\nrequest id = %d", requestId);
+ case DispatchFacetNotExist:
+ {
+ s += "(facet not exist)";
+ break;
+ }
- Byte status;
- stream.read(status);
- s += Ice::printfToString("\nreply status = %d ", static_cast<int>(status));
+ case DispatchOperationNotExist:
+ {
+ s += "(operation not exist)";
+ break;
+ }
+
+ default:
+ {
+ assert(false);
+ break;
+ }
+ }
+
+ printIdentityFacetOperation(s, stream);
+ break;
+ }
+
+ case DispatchUnknownException:
+ case DispatchUnknownLocalException:
+ case DispatchUnknownUserException:
+ {
switch(static_cast<DispatchStatus>(status))
{
- case DispatchOK:
- {
- s += "(ok)";
- break;
- }
-
- case DispatchUserException:
- {
- s += "(user exception)";
- break;
- }
-
- case DispatchObjectNotExist:
- case DispatchFacetNotExist:
- case DispatchOperationNotExist:
- {
- switch(static_cast<DispatchStatus>(status))
- {
- case DispatchObjectNotExist:
- {
- s += "(object not exist)";
- break;
- }
-
- case DispatchFacetNotExist:
- {
- s += "(facet not exist)";
- break;
- }
-
- case DispatchOperationNotExist:
- {
- s += "(operation not exist)";
- break;
- }
-
- default:
- {
- assert(false);
- break;
- }
- }
-
- printIdentityFacetOperation(s, stream);
- break;
- }
-
- case DispatchUnknownException:
- case DispatchUnknownLocalException:
- case DispatchUnknownUserException:
- {
- switch(static_cast<DispatchStatus>(status))
- {
- case DispatchUnknownException:
- {
- s += "(unknown exception)";
- break;
- }
-
- case DispatchUnknownLocalException:
- {
- s += "(unknown local exception)";
- break;
- }
-
- case DispatchUnknownUserException:
- {
- s += "(unknown user exception)";
- break;
- }
-
- default:
- {
- assert(false);
- break;
- }
- }
-
- string unknown;
- stream.read(unknown);
- s += "\nunknown = ";
- s += unknown;
- break;
- }
-
- default:
- {
- s += "(unknown)";
- break;
- }
+ case DispatchUnknownException:
+ {
+ s += "(unknown exception)";
+ break;
}
- logger->trace(tl->protocolCat, s);
- stream.i = p;
+ case DispatchUnknownLocalException:
+ {
+ s += "(unknown local exception)";
+ break;
+ }
+
+ case DispatchUnknownUserException:
+ {
+ 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;
}