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
|
// **********************************************************************
//
// Copyright (c) 2003-2014 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.
//
// **********************************************************************
package IceInternal;
public final class HTTPNetworkProxy implements NetworkProxy
{
public HTTPNetworkProxy(String host, int port)
{
_host = host;
_port = port;
_protocolSupport = Network.EnableBoth;
}
private HTTPNetworkProxy(java.net.InetSocketAddress address, int protocolSupport)
{
_address = address;
_protocolSupport = protocolSupport;
}
@Override
public void beginWrite(java.net.InetSocketAddress endpoint, Buffer buf)
{
String addr = Network.addrToString(endpoint);
StringBuilder str = new StringBuilder();
str.append("CONNECT ");
str.append(addr);
str.append(" HTTP/1.1\r\nHost: ");
str.append(addr);
str.append("\r\n\r\n");
byte[] b = str.toString().getBytes(java.nio.charset.StandardCharsets.US_ASCII);
//
// HTTP connect request
//
buf.resize(b.length, false);
buf.b.position(0);
buf.b.put(b);
buf.b.position(0);
buf.b.limit(buf.size());
}
@Override
public int endWrite(Buffer buf)
{
// Once the request is sent, read the response
return buf.b.hasRemaining() ? SocketOperation.Write : SocketOperation.Read;
}
@Override
public void beginRead(Buffer buf)
{
//
// Read the HTTP response
//
buf.resize(7, true); // Enough space for reading at least HTTP1.1
buf.b.position(0);
}
@Override
public int endRead(Buffer buf)
{
//
// Check if we received the full HTTP response, if not, continue
// reading otherwise we're done.
//
int end = new HttpParser().isCompleteMessage(buf.b, 0, buf.b.position());
if(end < 0 && !buf.b.hasRemaining())
{
//
// Read one more byte, we can't easily read bytes in advance
// since the transport implenentation might be be able to read
// the data from the memory instead of the socket.
//
buf.resize(buf.size() + 1, true);
return SocketOperation.Read;
}
return SocketOperation.None;
}
@Override
public void finish(Buffer readBuffer, Buffer writeBuffer)
{
HttpParser parser = new HttpParser();
parser.parse(readBuffer.b, 0, readBuffer.b.position());
if(parser.status() != 200)
{
throw new Ice.ConnectFailedException();
}
}
@Override
public NetworkProxy resolveHost(int protocol)
{
assert(_host != null);
return new HTTPNetworkProxy(Network.getAddresses(_host,
_port,
protocol,
Ice.EndpointSelectionType.Random,
false,
true).get(0),
protocol);
}
@Override
public java.net.InetSocketAddress getAddress()
{
assert(_address != null); // Host must be resolved.
return _address;
}
@Override
public String getName()
{
return "HTTP";
}
@Override
public int getProtocolSupport()
{
return _protocolSupport;
}
private String _host;
private int _port;
private java.net.InetSocketAddress _address;
private int _protocolSupport;
}
|
