1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
|
// **********************************************************************
//
// Copyright (c) 2001
// MutableRealms, Inc.
// Huntsville, AL, USA
//
// All Rights Reserved
//
// **********************************************************************
package IceInternal;
final class TraceUtil
{
static void
traceHeader(String heading, Ice.Stream stream, Ice.Logger logger,
TraceLevels tl)
{
if (tl.protocol >= 1)
{
// TODO: stream stuff
java.io.StringWriter s = new java.io.StringWriter();
s.write(heading);
printHeader(s, stream);
logger.trace(tl.protocolCat, s.toString());
}
}
static void
traceRequest(String heading, Ice.Stream stream, Ice.Logger logger,
TraceLevels tl)
{
if (tl.protocol >= 1)
{
// TODO: stream stuff
java.io.StringWriter s = new java.io.StringWriter();
s.write(heading);
printHeader(s, stream);
int requestId = stream.readInt();
s.write("\nrequest id = " + requestId);
if (requestId == 0)
{
s.write(" (oneway)");
}
String identity = stream.readString();
s.write("\nidentity = " + identity);
String facet = stream.readString();
s.write("\nfacet = " + facet);
String operation = stream.readString();
s.write("\noperation name = " + operation);
logger.trace(tl.protocolCat, s.toString());
}
}
static void
traceBatchRequest(String heading, Ice.Stream stream, Ice.Logger logger,
TraceLevels tl)
{
if (tl.protocol >= 1)
{
// TODO: stream stuff
java.io.StringWriter s = new java.io.StringWriter();
s.write(heading);
printHeader(s, stream);
int cnt = 0;
while (true /* stream.i != stream.b.end() */ )
{
s.write("\nrequest #" + cnt + ':');
cnt++;
// TODO
stream.startReadEncaps();
String identity = stream.readString();
s.write("\nidentity = " + identity);
String facet = stream.readString();
s.write("\nfacet = " + facet);
String operation = stream.readString();
s.write("\noperation name = " + operation);
// TODO
stream.skipEncaps();
}
logger.trace(tl.protocolCat, s.toString());
}
}
static void
traceReply(String heading, Ice.Stream stream, Ice.Logger logger,
TraceLevels tl)
{
if (tl.protocol >= 1)
{
// TODO: stream stuff
java.io.StringWriter s = new java.io.StringWriter();
s.write(heading);
printHeader(s, stream);
int requestId = stream.readInt();
s.write("\nrequest id = " + requestId);
byte status = stream.readByte();
s.write("\nreply status = " + (int)status + ' ');
switch (status)
{
case DispatchStatus._DispatchOK:
{
s.write("(ok)");
break;
}
case DispatchStatus._DispatchUserException:
{
s.write("(user exception)");
break;
}
case DispatchStatus._DispatchLocationForward:
{
s.write("(location forward)");
break;
}
case DispatchStatus._DispatchObjectNotExist:
{
s.write("(object not exist)");
break;
}
case DispatchStatus._DispatchOperationNotExist:
{
s.write("(operation not exist)");
break;
}
case DispatchStatus._DispatchUnknownLocalException:
{
s.write("(unknown local exception)");
break;
}
case DispatchStatus._DispatchUnknownException:
{
s.write("(unknown exception)");
break;
}
default:
{
s.write("(unknown)");
break;
}
}
logger.trace(tl.protocolCat, s.toString());
}
}
}
|
