blob: 735c098c5b9525f352728e0407c6ade49d34bf91 (
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
|
// **********************************************************************
//
// Copyright (c) 2003-2015 ZeroC, Inc. All rights reserved.
//
// This copy of Ice is licensed to you under the terms described in the
// ICE_LICENSE file included in this distribution.
//
// **********************************************************************
#include <Ice/Ice.h>
#include <IceSSL/IceSSL.h>
#include <TestCommon.h>
#include <TestI.h>
using namespace std;
using namespace Ice;
using namespace Test;
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 = ICE_DYNAMIC_CAST(Ice::IPEndpointInfo, info);
test(info);
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"] = 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 = ICE_DYNAMIC_CAST(Ice::IPConnectionInfo, 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;
}
}
IceSSL::WSSConnectionInfoPtr wssinfo = ICE_DYNAMIC_CAST(IceSSL::WSSConnectionInfo, info);
if(wssinfo)
{
for(Ice::HeaderDict::const_iterator p = wssinfo->headers.begin(); p != wssinfo->headers.end(); ++p)
{
ctx["ws." + p->first] = p->second;
}
}
return ctx;
}
|
