Index: chrome/browser/sync/notifier/communicator/xmpp_socket_adapter.h |
=================================================================== |
--- chrome/browser/sync/notifier/communicator/xmpp_socket_adapter.h (revision 46353) |
+++ chrome/browser/sync/notifier/communicator/xmpp_socket_adapter.h (working copy) |
@@ -1,87 +0,0 @@ |
-// Copyright (c) 2009 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. |
- |
-#ifndef CHROME_BROWSER_SYNC_NOTIFIER_COMMUNICATOR_XMPP_SOCKET_ADAPTER_H_ |
-#define CHROME_BROWSER_SYNC_NOTIFIER_COMMUNICATOR_XMPP_SOCKET_ADAPTER_H_ |
- |
-#include <string> |
- |
-#include "talk/base/asyncsocket.h" |
-#include "talk/xmpp/asyncsocket.h" |
-#include "talk/xmpp/xmppclientsettings.h" |
-#include "talk/xmpp/xmppengine.h" |
- |
-#ifndef _WIN32 |
-// Additional errors used by us from Win32 headers. |
-#define SEC_E_CERT_EXPIRED static_cast<int>(0x80090328L) |
-#define WSA_NOT_ENOUGH_MEMORY ENOMEM |
-#endif |
- |
-namespace notifier { |
- |
-class XmppSocketAdapter : public buzz::AsyncSocket, |
- public sigslot::has_slots<> { |
- public: |
- XmppSocketAdapter(const buzz::XmppClientSettings& xcs, |
- bool allow_unverified_certs); |
- virtual ~XmppSocketAdapter(); |
- |
- virtual State state() { return state_; } |
- virtual Error error() { return error_; } |
- virtual int GetError() { return wsa_error_; } |
- |
- void set_firewall(bool firewall) { firewall_ = firewall; } |
- |
- virtual bool Connect(const talk_base::SocketAddress& addr); |
- virtual bool Read(char* data, size_t len, size_t* len_read); |
- virtual bool Write(const char* data, size_t len); |
- virtual bool Close(); |
- |
-#if defined(FEATURE_ENABLE_SSL) |
- bool StartTls(const std::string& domainname); |
- bool IsOpen() const { return state_ == STATE_OPEN |
- || state_ == STATE_TLS_OPEN; } |
-#else |
- bool IsOpen() const { return state_ == STATE_OPEN; } |
-#endif |
- |
- sigslot::signal0<> SignalAuthenticationError; |
- |
- private: |
- // Return false if the socket is closed. |
- bool HandleReadable(); |
- bool HandleWritable(); |
- |
- State state_; |
- Error error_; |
- int wsa_error_; |
- |
- talk_base::AsyncSocket* socket_; |
- cricket::ProtocolType protocol_; |
- talk_base::ProxyInfo proxy_; |
- bool firewall_; |
- char* write_buffer_; |
- size_t write_buffer_length_; |
- size_t write_buffer_capacity_; |
- bool allow_unverified_certs_; |
- |
- bool FreeState(); |
- void NotifyClose(); |
- |
- void OnReadEvent(talk_base::AsyncSocket* socket); |
- void OnWriteEvent(talk_base::AsyncSocket* socket); |
- void OnConnectEvent(talk_base::AsyncSocket* socket); |
- void OnCloseEvent(talk_base::AsyncSocket* socket, int error); |
- |
- void QueueWriteData(const char* data, size_t len); |
- void FlushWriteQueue(Error* error, int* wsa_error); |
- |
- void SetError(Error error); |
- void SetWSAError(int error); |
- DISALLOW_COPY_AND_ASSIGN(XmppSocketAdapter); |
-}; |
- |
-} // namespace notifier |
- |
-#endif // CHROME_BROWSER_SYNC_NOTIFIER_COMMUNICATOR_XMPP_SOCKET_ADAPTER_H_ |