blob: 9f5dcd8cadd1611d712eb3eb5d095fa103325931 (
plain)
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
|
// **********************************************************************
//
// Copyright (c) 2003-present ZeroC, Inc. All rights reserved.
//
// **********************************************************************
#include <Ice/Ice.h>
#include <IceSSL/IceSSL.h>
#include <TestHelper.h>
#include <TestI.h>
using namespace std;
using namespace Ice;
using namespace Test;
namespace
{
Ice::IPEndpointInfoPtr
getIPEndpointInfo(const Ice::EndpointInfoPtr& info)
{
for(Ice::EndpointInfoPtr p = info; p; p = p->underlying)
{
Ice::IPEndpointInfoPtr ipInfo = ICE_DYNAMIC_CAST(Ice::IPEndpointInfo, p);
if(ipInfo)
{
return ipInfo;
}
}
return ICE_NULLPTR;
}
Ice::IPConnectionInfoPtr
getIPConnectionInfo(const Ice::ConnectionInfoPtr& info)
{
for(Ice::ConnectionInfoPtr p = info; p; p = p->underlying)
{
Ice::IPConnectionInfoPtr ipInfo = ICE_DYNAMIC_CAST(Ice::IPConnectionInfo, p);
if(ipInfo)
{
return ipInfo;
}
}
return ICE_NULLPTR;
}
}
void
TestI::shutdown(const Ice::Current& current)
{
current.adapter->getCommunicator()->shutdown();
}
Ice::Context
TestI::getEndpointInfoAsContext(const Ice::Current& c)
{
ostringstream os;
Ice::Context ctx;
Ice::EndpointInfoPtr info = c.con->getEndpoint()->getInfo();
os << info->timeout;
ctx["timeout"] = os.str();
ctx["compress"] = info->compress ? "true" : "false";
ctx["datagram"] = info->datagram() ? "true" : "false";
ctx["secure"] = info->datagram() ? "true" : "false";
os.str("");
os << info->type();
ctx["type"] = os.str();
Ice::IPEndpointInfoPtr ipinfo = getIPEndpointInfo(info);
test(ipinfo);
ctx["host"] = ipinfo->host;
os.str("");
os << ipinfo->port;
ctx["port"] = os.str();
if(ICE_DYNAMIC_CAST(Ice::UDPEndpointInfo, ipinfo))
{
Ice::UDPEndpointInfoPtr udp = ICE_DYNAMIC_CAST(Ice::UDPEndpointInfo, ipinfo);
ctx["mcastInterface"] = udp->mcastInterface;
ctx["mcastTtl"] = static_cast<char>(udp->mcastTtl);
}
return ctx;
}
Ice::Context
TestI::getConnectionInfoAsContext(const Ice::Current& c)
{
Ice::Context ctx;
Ice::ConnectionInfoPtr info = c.con->getInfo();
ctx["adapterName"] = info->adapterName;
ctx["incoming"] = info->incoming ? "true" : "false";
ostringstream os;
Ice::IPConnectionInfoPtr ipinfo = getIPConnectionInfo(info);
test(ipinfo);
ctx["localAddress"] = ipinfo->localAddress;
os.str("");
os << ipinfo->localPort;
ctx["localPort"] = os.str();
ctx["remoteAddress"] = ipinfo->remoteAddress;
os.str("");
os << ipinfo->remotePort;
ctx["remotePort"] = os.str();
Ice::WSConnectionInfoPtr wsinfo = ICE_DYNAMIC_CAST(Ice::WSConnectionInfo, info);
if(wsinfo)
{
for(Ice::HeaderDict::const_iterator p = wsinfo->headers.begin(); p != wsinfo->headers.end(); ++p)
{
ctx["ws." + p->first] = p->second;
}
}
return ctx;
}
|
