OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "net/socket/web_socket_server_socket.h" | 5 #include "net/socket/web_socket_server_socket.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <deque> | 8 #include <deque> |
9 #include <limits> | 9 #include <limits> |
10 #include <map> | 10 #include <map> |
(...skipping 708 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
719 memcpy(io_buf_->data() + bytes_written_, p, len); | 719 memcpy(io_buf_->data() + bytes_written_, p, len); |
720 bytes_written_ += len; | 720 bytes_written_ += len; |
721 return true; | 721 return true; |
722 } | 722 } |
723 | 723 |
724 bool WriteLine(const char* p) { | 724 bool WriteLine(const char* p) { |
725 return Write(p, strlen(p)) && Write(kCRLF, strlen(kCRLF)); | 725 return Write(p, strlen(p)) && Write(kCRLF, strlen(kCRLF)); |
726 } | 726 } |
727 | 727 |
728 operator net::DrainableIOBuffer*() { | 728 operator net::DrainableIOBuffer*() { |
729 return new net::DrainableIOBuffer(io_buf_.release(), bytes_written_); | 729 return new net::DrainableIOBuffer(io_buf_.get(), bytes_written_); |
730 } | 730 } |
731 | 731 |
732 bool is_ok() { return is_ok_; } | 732 bool is_ok() { return is_ok_; } |
733 | 733 |
734 private: | 734 private: |
735 scoped_refptr<net::IOBuffer> io_buf_; | 735 scoped_refptr<net::IOBuffer> io_buf_; |
736 size_t bytes_written_; | 736 size_t bytes_written_; |
737 bool is_ok_; | 737 bool is_ok_; |
738 } buffer; | 738 } buffer; |
739 | 739 |
(...skipping 147 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
887 | 887 |
888 WebSocketServerSocket* CreateWebSocketServerSocket( | 888 WebSocketServerSocket* CreateWebSocketServerSocket( |
889 Socket* transport_socket, WebSocketServerSocket::Delegate* delegate) { | 889 Socket* transport_socket, WebSocketServerSocket::Delegate* delegate) { |
890 return new WebSocketServerSocketImpl(transport_socket, delegate); | 890 return new WebSocketServerSocketImpl(transport_socket, delegate); |
891 } | 891 } |
892 | 892 |
893 WebSocketServerSocket::~WebSocketServerSocket() { | 893 WebSocketServerSocket::~WebSocketServerSocket() { |
894 } | 894 } |
895 | 895 |
896 } // namespace net; | 896 } // namespace net; |
OLD | NEW |