[Android WebView] Implement initial settings and callback support for Service Workers.

android_webview/native/aw_contents_io_thread_client_impl.cc

 // Copyright (c) 2012 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.
 
 #include "android_webview/native/aw_contents_io_thread_client_impl.h"
 
 #include <map>
 #include <utility>
 
 #include "android_webview/common/devtools_instrumentation.h"
@@ skipping 67 matching lines @@
   static LazyInstance<RfhToIoThreadClientMap> g_instance_;
   base::Lock map_lock_;
   RenderFrameHostToIoThreadClientType rfh_to_io_thread_client_;
 };
 
 // static
 LazyInstance<RfhToIoThreadClientMap> RfhToIoThreadClientMap::g_instance_ =
     LAZY_INSTANCE_INITIALIZER;
 
 // static
+LazyInstance<JavaObjectWeakGlobalRef> g_sw_instance_ =
+    LAZY_INSTANCE_INITIALIZER;
+
+// static
 RfhToIoThreadClientMap* RfhToIoThreadClientMap::GetInstance() {
   return g_instance_.Pointer();
 }
 
 void RfhToIoThreadClientMap::Set(pair<int, int> rfh_id,
                                  const IoThreadClientData& client) {
   base::AutoLock lock(map_lock_);
   rfh_to_io_thread_client_[rfh_id] = client;
 }
 
@@ skipping 149 matching lines @@
 
 // static
 void AwContentsIoThreadClientImpl::Associate(
     WebContents* web_contents,
     const JavaRef<jobject>& jclient) {
   JNIEnv* env = AttachCurrentThread();
   // The ClientMapEntryUpdater lifespan is tied to the WebContents.
   new ClientMapEntryUpdater(env, web_contents, jclient.obj());
 }
 
+// static
+void AwContentsIoThreadClientImpl::SetServiceWorkerIoThreadClient(
+    const base::android::JavaRef<jobject>& jclient) {
+  JavaObjectWeakGlobalRef temp(AttachCurrentThread(), jclient.obj());
+  g_sw_instance_.Get() = temp;
+}
+
+// static
+scoped_ptr<AwContentsIoThreadClient>
+AwContentsIoThreadClient::GetServiceWorkerIoThreadClient() {
+  if (g_sw_instance_.Get().is_empty())
+    return scoped_ptr<AwContentsIoThreadClient>();
+
+  JNIEnv* env = AttachCurrentThread();
+  ScopedJavaLocalRef<jobject> java_delegate = g_sw_instance_.Get().get(env);
+
+  DCHECK(!java_delegate.is_null());
+  return scoped_ptr<AwContentsIoThreadClient>(new AwContentsIoThreadClientImpl(
+      false, java_delegate));
+}
+
 AwContentsIoThreadClientImpl::AwContentsIoThreadClientImpl(
     bool pending_association,
     const JavaRef<jobject>& obj)
   : pending_association_(pending_association),
     java_object_(obj) {
 }
 
 AwContentsIoThreadClientImpl::~AwContentsIoThreadClientImpl() {
   // explict, out-of-line destructor.
 }
@@ skipping 237 matching lines @@
       jstring_reason.obj(),
       jstringArray_response_header_names.obj(),
       jstringArray_response_header_values.obj());
 }
 
 bool RegisterAwContentsIoThreadClientImpl(JNIEnv* env) {
   return RegisterNativesImpl(env);
 }
 
 } // namespace android_webview