1 /* 2 * Copyright 2005 The WebRTC Project Authors. All rights reserved. 3 * 4 * Use of this source code is governed by a BSD-style license 5 * that can be found in the LICENSE file in the root of the source 6 * tree. An additional intellectual property rights grant can be found 7 * in the file PATENTS. All contributing project authors may 8 * be found in the AUTHORS file in the root of the source tree. 9 */ 10 11 #ifndef WEBRTC_BASE_SOCKETSTREAM_H_ 12 #define WEBRTC_BASE_SOCKETSTREAM_H_ 13 14 #include "webrtc/base/asyncsocket.h" 15 #include "webrtc/base/common.h" 16 #include "webrtc/base/stream.h" 17 18 namespace rtc { 19 20 /////////////////////////////////////////////////////////////////////////////// 21 22 class SocketStream : public StreamInterface, public sigslot::has_slots<> { 23 public: 24 explicit SocketStream(AsyncSocket* socket); 25 virtual ~SocketStream(); 26 27 void Attach(AsyncSocket* socket); 28 AsyncSocket* Detach(); 29 GetSocket()30 AsyncSocket* GetSocket() { return socket_; } 31 32 virtual StreamState GetState() const; 33 34 virtual StreamResult Read(void* buffer, size_t buffer_len, 35 size_t* read, int* error); 36 37 virtual StreamResult Write(const void* data, size_t data_len, 38 size_t* written, int* error); 39 40 virtual void Close(); 41 42 private: 43 void OnConnectEvent(AsyncSocket* socket); 44 void OnReadEvent(AsyncSocket* socket); 45 void OnWriteEvent(AsyncSocket* socket); 46 void OnCloseEvent(AsyncSocket* socket, int err); 47 48 AsyncSocket* socket_; 49 50 DISALLOW_EVIL_CONSTRUCTORS(SocketStream); 51 }; 52 53 /////////////////////////////////////////////////////////////////////////////// 54 55 } // namespace rtc 56 57 #endif // WEBRTC_BASE_SOCKETSTREAM_H_ 58