Index: sky/services/oknet/src/org/domokit/oknet/NetworkServiceImpl.java |
diff --git a/sky/services/oknet/src/org/domokit/oknet/NetworkServiceImpl.java b/sky/services/oknet/src/org/domokit/oknet/NetworkServiceImpl.java |
new file mode 100644 |
index 0000000000000000000000000000000000000000..4dbbb646c7c0a96351751106f88cd15aff0b9154 |
--- /dev/null |
+++ b/sky/services/oknet/src/org/domokit/oknet/NetworkServiceImpl.java |
@@ -0,0 +1,76 @@ |
+// Copyright 2015 The Chromium Authors. All rights reserved. |
+// Use of this source code is governed by a BSD-style license that can be |
+// found in the LICENSE file. |
+ |
+package org.domokit.oknet; |
+ |
+import com.squareup.okhttp.OkHttpClient; |
+ |
+import org.chromium.mojo.bindings.InterfaceRequest; |
+import org.chromium.mojo.system.Core; |
+import org.chromium.mojo.system.DataPipe; |
+import org.chromium.mojo.system.MojoException; |
+import org.chromium.mojom.mojo.CookieStore; |
+import org.chromium.mojom.mojo.NetAddress; |
+import org.chromium.mojom.mojo.NetworkService; |
+import org.chromium.mojom.mojo.TcpBoundSocket; |
+import org.chromium.mojom.mojo.TcpConnectedSocket; |
+import org.chromium.mojom.mojo.UdpSocket; |
+import org.chromium.mojom.mojo.UrlLoader; |
+import org.chromium.mojom.mojo.WebSocket; |
+ |
+/** |
+ * OkHttp implementation of NetworkService. |
+ */ |
+public class NetworkServiceImpl implements NetworkService { |
+ private OkHttpClient mClient; |
+ private Core mCore; |
+ |
+ public NetworkServiceImpl(Core core) { |
+ assert core != null; |
+ mCore = core; |
+ mClient = new OkHttpClient(); |
+ } |
+ |
+ @Override |
+ public void close() {} |
+ |
+ @Override |
+ public void onConnectionError(MojoException e) {} |
+ |
+ @Override |
+ public void createUrlLoader(InterfaceRequest<UrlLoader> loader) { |
+ UrlLoader.MANAGER.bind(new UrlLoaderImpl(mCore, mClient), loader); |
+ } |
+ |
+ @Override |
+ public void getCookieStore(InterfaceRequest<CookieStore> cookieStore) { |
+ cookieStore.close(); |
+ } |
+ |
+ @Override |
+ public void createWebSocket(InterfaceRequest<WebSocket> socket) { |
+ socket.close(); |
+ } |
+ |
+ @Override |
+ public void createTcpBoundSocket(NetAddress localAddress, |
+ InterfaceRequest<TcpBoundSocket> boundSocket, CreateTcpBoundSocketResponse callback) { |
+ boundSocket.close(); |
+ } |
+ |
+ @Override |
+ public void createTcpConnectedSocket(NetAddress remoteAddress, |
+ DataPipe.ConsumerHandle sendStream, DataPipe.ProducerHandle receiveStream, |
+ InterfaceRequest<TcpConnectedSocket> clientSocket, |
+ CreateTcpConnectedSocketResponse callback) { |
+ sendStream.close(); |
+ receiveStream.close(); |
+ clientSocket.close(); |
+ } |
+ |
+ @Override |
+ public void createUdpSocket(InterfaceRequest<UdpSocket> socket) { |
+ socket.close(); |
+ } |
+} |