| Index: net/socket/web_socket_server_socket.cc
|
| ===================================================================
|
| --- net/socket/web_socket_server_socket.cc (revision 113718)
|
| +++ net/socket/web_socket_server_socket.cc (working copy)
|
| @@ -397,54 +397,7 @@
|
| ConsiderTransportWrite();
|
| return net::ERR_IO_PENDING;
|
| }
|
| - virtual int Write(net::IOBuffer* buf, int buf_len,
|
| - const net::CompletionCallback& callback) OVERRIDE {
|
| - if (buf_len == 0)
|
| - return 0;
|
| - if (buf == NULL || buf_len < 0) {
|
| - NOTREACHED();
|
| - return net::ERR_INVALID_ARGUMENT;
|
| - }
|
| - DCHECK_EQ(std::find(buf->data(), buf->data() + buf_len, '\xff'),
|
| - buf->data() + buf_len);
|
| - switch (phase_) {
|
| - case PHASE_FRAME_OUTSIDE:
|
| - case PHASE_FRAME_INSIDE:
|
| - case PHASE_FRAME_LENGTH:
|
| - case PHASE_FRAME_SKIP: {
|
| - break;
|
| - }
|
| - case PHASE_SHUT: {
|
| - return net::ERR_SOCKET_NOT_CONNECTED;
|
| - }
|
| - case PHASE_NYMPH:
|
| - case PHASE_HANDSHAKE:
|
| - default: {
|
| - NOTREACHED();
|
| - return net::ERR_UNEXPECTED;
|
| - }
|
| - }
|
|
|
| - net::IOBuffer* frame_start = new net::IOBuffer(1);
|
| - frame_start->data()[0] = '\x00';
|
| - pending_reqs_.push_back(PendingReq(PendingReq::TYPE_WRITE_METADATA,
|
| - new net::DrainableIOBuffer(frame_start, 1),
|
| - NULL));
|
| -
|
| - pending_reqs_.push_back(PendingReq(PendingReq::TYPE_WRITE,
|
| - new net::DrainableIOBuffer(buf, buf_len),
|
| - callback));
|
| -
|
| - net::IOBuffer* frame_end = new net::IOBuffer(1);
|
| - frame_end->data()[0] = '\xff';
|
| - pending_reqs_.push_back(PendingReq(PendingReq::TYPE_WRITE_METADATA,
|
| - new net::DrainableIOBuffer(frame_end, 1),
|
| - NULL));
|
| -
|
| - ConsiderTransportWrite();
|
| - return net::ERR_IO_PENDING;
|
| - }
|
| -
|
| virtual bool SetReceiveBufferSize(int32 size) OVERRIDE {
|
| return transport_socket_->SetReceiveBufferSize(size);
|
| }
|
|
|