| // Copyright 2015 The Chromium OS 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 BUFFET_SOCKET_STREAM_H_ |
| #define BUFFET_SOCKET_STREAM_H_ |
| |
| #include <string> |
| |
| #include <base/callback.h> |
| #include <base/macros.h> |
| #include <chromeos/streams/stream.h> |
| #include <weave/stream.h> |
| |
| namespace buffet { |
| |
| class SocketStream : public weave::Stream { |
| public: |
| explicit SocketStream(chromeos::StreamPtr ptr) : ptr_{std::move(ptr)} {} |
| |
| ~SocketStream() override = default; |
| |
| void Read(void* buffer, |
| size_t size_to_read, |
| const ReadSuccessCallback& success_callback, |
| const weave::ErrorCallback& error_callback) override; |
| |
| void Write(const void* buffer, |
| size_t size_to_write, |
| const weave::SuccessCallback& success_callback, |
| const weave::ErrorCallback& error_callback) override; |
| |
| void CancelPendingOperations() override; |
| |
| static std::unique_ptr<weave::Stream> ConnectBlocking(const std::string& host, |
| uint16_t port); |
| |
| static void TlsConnect(std::unique_ptr<weave::Stream> socket, |
| const std::string& host, |
| const base::Callback<void( |
| std::unique_ptr<weave::Stream>)>& success_callback, |
| const weave::ErrorCallback& error_callback); |
| |
| private: |
| chromeos::StreamPtr ptr_; |
| DISALLOW_COPY_AND_ASSIGN(SocketStream); |
| }; |
| |
| } // namespace buffet |
| |
| #endif // BUFFET_SOCKET_STREAM_H_ |