| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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/quic/chromium/quic_chromium_client_stream.h" | 5 #include "net/quic/chromium/quic_chromium_client_stream.h" |
| 6 | 6 |
| 7 #include <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "base/bind_helpers.h" | 9 #include "base/bind_helpers.h" |
| 10 #include "base/callback_helpers.h" | 10 #include "base/callback_helpers.h" |
| (...skipping 127 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 138 } | 138 } |
| 139 | 139 |
| 140 SpdyPriority QuicChromiumClientStream::priority() const { | 140 SpdyPriority QuicChromiumClientStream::priority() const { |
| 141 if (delegate_ && delegate_->HasSendHeadersComplete()) { | 141 if (delegate_ && delegate_->HasSendHeadersComplete()) { |
| 142 return QuicSpdyStream::priority(); | 142 return QuicSpdyStream::priority(); |
| 143 } | 143 } |
| 144 return net::kV3HighestPriority; | 144 return net::kV3HighestPriority; |
| 145 } | 145 } |
| 146 | 146 |
| 147 int QuicChromiumClientStream::WriteStreamData( | 147 int QuicChromiumClientStream::WriteStreamData( |
| 148 base::StringPiece data, | 148 QuicStringPiece data, |
| 149 bool fin, | 149 bool fin, |
| 150 const CompletionCallback& callback) { | 150 const CompletionCallback& callback) { |
| 151 // We should not have data buffered. | 151 // We should not have data buffered. |
| 152 DCHECK(!HasBufferedData()); | 152 DCHECK(!HasBufferedData()); |
| 153 // Writes the data, or buffers it. | 153 // Writes the data, or buffers it. |
| 154 WriteOrBufferData(data, fin, nullptr); | 154 WriteOrBufferData(data, fin, nullptr); |
| 155 if (!HasBufferedData()) { | 155 if (!HasBufferedData()) { |
| 156 return OK; | 156 return OK; |
| 157 } | 157 } |
| 158 | 158 |
| 159 callback_ = callback; | 159 callback_ = callback; |
| 160 return ERR_IO_PENDING; | 160 return ERR_IO_PENDING; |
| 161 } | 161 } |
| 162 | 162 |
| 163 int QuicChromiumClientStream::WritevStreamData( | 163 int QuicChromiumClientStream::WritevStreamData( |
| 164 const std::vector<scoped_refptr<IOBuffer>>& buffers, | 164 const std::vector<scoped_refptr<IOBuffer>>& buffers, |
| 165 const std::vector<int>& lengths, | 165 const std::vector<int>& lengths, |
| 166 bool fin, | 166 bool fin, |
| 167 const CompletionCallback& callback) { | 167 const CompletionCallback& callback) { |
| 168 // Must not be called when data is buffered. | 168 // Must not be called when data is buffered. |
| 169 DCHECK(!HasBufferedData()); | 169 DCHECK(!HasBufferedData()); |
| 170 // Writes the data, or buffers it. | 170 // Writes the data, or buffers it. |
| 171 for (size_t i = 0; i < buffers.size(); ++i) { | 171 for (size_t i = 0; i < buffers.size(); ++i) { |
| 172 bool is_fin = fin && (i == buffers.size() - 1); | 172 bool is_fin = fin && (i == buffers.size() - 1); |
| 173 base::StringPiece string_data(buffers[i]->data(), lengths[i]); | 173 QuicStringPiece string_data(buffers[i]->data(), lengths[i]); |
| 174 WriteOrBufferData(string_data, is_fin, nullptr); | 174 WriteOrBufferData(string_data, is_fin, nullptr); |
| 175 } | 175 } |
| 176 if (!HasBufferedData()) { | 176 if (!HasBufferedData()) { |
| 177 return OK; | 177 return OK; |
| 178 } | 178 } |
| 179 | 179 |
| 180 callback_ = callback; | 180 callback_ = callback; |
| 181 return ERR_IO_PENDING; | 181 return ERR_IO_PENDING; |
| 182 } | 182 } |
| 183 | 183 |
| (...skipping 101 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 285 | 285 |
| 286 void QuicChromiumClientStream::DisableConnectionMigration() { | 286 void QuicChromiumClientStream::DisableConnectionMigration() { |
| 287 can_migrate_ = false; | 287 can_migrate_ = false; |
| 288 } | 288 } |
| 289 | 289 |
| 290 bool QuicChromiumClientStream::IsFirstStream() { | 290 bool QuicChromiumClientStream::IsFirstStream() { |
| 291 return id() == kHeadersStreamId + 2; | 291 return id() == kHeadersStreamId + 2; |
| 292 } | 292 } |
| 293 | 293 |
| 294 } // namespace net | 294 } // namespace net |
| OLD | NEW |