Apache
/
jclouds
mirror of https://github.com/apache/jclouds.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Issue 214: default http executor tried to convert all blobs to a byte array

This commit is contained in:
Adrian Cole 2010-03-22 10:53:42 -07:00
parent 574af762f6
commit 9ea446ac9f
1 changed files with 19 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
core/src/main/java/org/jclouds/http/internal/JavaUrlHttpCommandExecutorService.java
View File

@ -157,7 +157,17 @@ public class JavaUrlHttpCommandExecutorService extends
protected HttpURLConnection convert(HttpRequest request) throws IOException,
InterruptedException {
URL url = request.getEndpoint().toURL();
boolean chunked = false;
for (String header : request.getHeaders().keySet()) {
for (String value : request.getHeaders().get(header)) {
if ("Transfer-Encoding".equals(header) && "chunked".equals(value)) {
chunked = true;
}
}
}
HttpURLConnection connection;
if (utils.useSystemProxies()) {
System.setProperty("java.net.useSystemProxies", "true");
Iterable<Proxy> proxies = ProxySelector.getDefault().select(request.getEndpoint());
@ -191,20 +201,24 @@ public class JavaUrlHttpCommandExecutorService extends
for (String header : request.getHeaders().keySet()) {
for (String value : request.getHeaders().get(header)) {
connection.setRequestProperty(header, value);
if ("Transfer-Encoding".equals(header) && "chunked".equals(value)) {
connection.setChunkedStreamingMode(8192);
}
}
}
connection.setRequestProperty(HttpHeaders.HOST, request.getEndpoint().getHost());
connection.setRequestProperty(HttpHeaders.USER_AGENT, USER_AGENT);
if (request.getPayload() != null) {
OutputStream out = connection.getOutputStream();
OutputStream out = null;
try {
if (chunked) {
connection.setChunkedStreamingMode(8192);
} else {
connection.setFixedLengthStreamingMode(Integer.parseInt(request
.getFirstHeaderOrNull(HttpHeaders.CONTENT_LENGTH)));
}
out = connection.getOutputStream();
request.getPayload().writeTo(out);
} finally {
out.flush();
} finally {
Closeables.closeQuietly(out);
}
} else {