The MediatorThread worker thread needs to have a CertVerifier...

chrome/browser/sync/tools/sync_listen_notifications.cc

 // Copyright (c) 2010 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 <string>
 #include <vector>
 
 #include "base/at_exit.h"
 #include "base/base64.h"
 #include "base/command_line.h"
 #include "base/logging.h"
 #include "base/message_loop.h"
 #include "base/observer_list.h"
 #include "base/string_util.h"
 #include "base/task.h"
 #include "base/weak_ptr.h"
 #include "chrome/browser/sync/notifier/cache_invalidation_packet_handler.h"
 #include "chrome/browser/sync/notifier/chrome_invalidation_client.h"
 #include "chrome/browser/sync/notifier/chrome_system_resources.h"
 #include "chrome/browser/sync/sync_constants.h"
 #include "jingle/notifier/base/xmpp_connection.h"
 #include "jingle/notifier/listener/listen_task.h"
 #include "jingle/notifier/listener/notification_constants.h"
 #include "jingle/notifier/listener/notification_defines.h"
 #include "jingle/notifier/listener/send_update_task.h"
 #include "jingle/notifier/listener/subscribe_task.h"
 #include "jingle/notifier/listener/xml_element_util.h"
+#include "net/base/cert_verifier.h"
 #include "net/base/ssl_config_service.h"
 #include "net/socket/client_socket_factory.h"
 #include "talk/base/cryptstring.h"
 #include "talk/base/logging.h"
 #include "talk/base/sigslot.h"
 #include "talk/base/task.h"
 #include "talk/xmpp/jid.h"
 #include "talk/xmpp/xmppclientsettings.h"
 #include "talk/xmpp/constants.h"
 #include "talk/xmpp/xmppengine.h"
@@ skipping 21 matching lines @@
 
   template <class T> XmppNotificationClient(T begin, T end) {
     for (T it = begin; it != end; ++it) {
       observer_list_.AddObserver(*it);
     }
   }
 
   virtual ~XmppNotificationClient() {}
 
   // Connect with the given XMPP settings and run until disconnected.
-  void Run(const buzz::XmppClientSettings& xmpp_client_settings) {
+  void Run(const buzz::XmppClientSettings& xmpp_client_settings,
+           net::CertVerifier* cert_verifier) {
     DCHECK(!xmpp_connection_.get());
     xmpp_connection_.reset(
-        new notifier::XmppConnection(xmpp_client_settings, this, NULL));
+        new notifier::XmppConnection(xmpp_client_settings, cert_verifier,
+                                     this, NULL));
     MessageLoop::current()->Run();
     DCHECK(!xmpp_connection_.get());
   }
 
   virtual void OnConnect(base::WeakPtr<talk_base::Task> base_task) {
     FOR_EACH_OBSERVER(Observer, observer_list_, OnConnect(base_task));
   }
 
   virtual void OnError(buzz::XmppEngine::Error error, int subcode,
                        const buzz::XmlElement* stream_error) {
@@ skipping 205 matching lines @@
   insecure_crypt_string.password() = password;
   xmpp_client_settings.set_pass(
       talk_base::CryptString(insecure_crypt_string));
   talk_base::SocketAddress addr(server, port);
   if (!addr.ResolveIP()) {
     LOG(ERROR) << "Could not resolve " << addr.ToString();
     return -1;
   }
   xmpp_client_settings.set_server(addr);
 
+  net::CertVerifier cert_verifier;
+

[agl, 2010/12/17 16:22:01]

(very minor): I would remove this blank line.

   MessageLoopForIO message_loop;
 
   // Connect and listen.
   ServerNotifierDelegate server_notifier_delegate(
       server_notifier_state);
   LegacyNotifierDelegate legacy_notifier_delegate(
       legacy_notifier_send_initial_update);
   std::vector<XmppNotificationClient::Observer*> observers;
   if (use_legacy_notifier) {
     observers.push_back(&legacy_notifier_delegate);
   } else {
     observers.push_back(&server_notifier_delegate);
   }
   XmppNotificationClient xmpp_notification_client(
       observers.begin(), observers.end());
-  xmpp_notification_client.Run(xmpp_client_settings);
+  xmpp_notification_client.Run(xmpp_client_settings, &cert_verifier);
 
   return 0;
 }