Update ICE protocol to handle closed channel

remoting/protocol/fake_stream_socket.h

 // Copyright 2014 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 REMOTING_PROTOCOL_FAKE_STREAM_SOCKET_H_
 #define REMOTING_PROTOCOL_FAKE_STREAM_SOCKET_H_
 
 #include <map>
 #include <memory>
 #include <string>
 
 #include "base/macros.h"
 #include "base/memory/weak_ptr.h"
+#include "base/optional.h"
 #include "net/base/completion_callback.h"
 #include "remoting/protocol/p2p_stream_socket.h"
 #include "remoting/protocol/stream_channel_factory.h"
 
 namespace base {
 class SingleThreadTaskRunner;
 }
 
 namespace remoting {
 namespace protocol {
@@ skipping 24 matching lines @@
 
   // Set error codes for the next Write() call. Once returned the
   // value is automatically reset to net::OK .
   void set_next_write_error(int error) { next_write_error_ = error; }
 
   // Appends |data| to the read buffer.
   void AppendInputData(const std::string& data);
 
   // Causes Read() to fail with |error| once the read buffer is exhausted. If
   // there is a currently pending Read, it is interrupted.
-  void AppendReadError(int error);
+  void SetReadError(int error);
 
   // Pairs the socket with |peer_socket|. Deleting either of the paired sockets
   // unpairs them.
   void PairWith(FakeStreamSocket* peer_socket);
 
   // Current input position in bytes.
   int input_pos() const { return input_pos_; }
 
   // True if a Read() call is currently pending.
   bool read_pending() const { return !read_callback_.is_null(); }
 
   base::WeakPtr<FakeStreamSocket> GetWeakPtr();
 
   // P2PStreamSocket interface.
   int Read(const scoped_refptr<net::IOBuffer>& buf, int buf_len,
            const net::CompletionCallback& callback) override;
   int Write(const scoped_refptr<net::IOBuffer>& buf, int buf_len,
             const net::CompletionCallback& callback) override;
 
  private:
   void DoAsyncWrite(const scoped_refptr<net::IOBuffer>& buf, int buf_len,
                     const net::CompletionCallback& callback);
   void DoWrite(const scoped_refptr<net::IOBuffer>& buf, int buf_len);
 
   bool async_write_ = false;
   bool write_pending_ = false;
   int write_limit_ = 0;
   int next_write_error_ = 0;
 
-  int next_read_error_ = 0;
+  base::Optional<int> next_read_error_;
   scoped_refptr<net::IOBuffer> read_buffer_;
   int read_buffer_size_ = 0;
   net::CompletionCallback read_callback_;
   base::WeakPtr<FakeStreamSocket> peer_socket_;
 
   std::string written_data_;
   std::string input_data_;
   int input_pos_ = 0;
 
   scoped_refptr<base::SingleThreadTaskRunner> task_runner_;
@@ skipping 44 matching lines @@
   base::WeakPtr<FakeStreamChannelFactory> peer_factory_;
   base::WeakPtrFactory<FakeStreamChannelFactory> weak_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(FakeStreamChannelFactory);
 };
 
 }  // namespace protocol
 }  // namespace remoting
 
 #endif  // REMOTING_PROTOCOL_FAKE_STREAM_SOCKET_H_