147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org/* 247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * Copyright 2004 The WebRTC Project Authors. All rights reserved. 347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * 447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * Use of this source code is governed by a BSD-style license 547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * that can be found in the LICENSE file in the root of the source 647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * tree. An additional intellectual property rights grant can be found 747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * in the file PATENTS. All contributing project authors may 847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * be found in the AUTHORS file in the root of the source tree. 947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org */ 1047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 1147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 1247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#if defined(WEBRTC_WIN) 1347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#include "webrtc/base/win32.h" 1447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#else // !WEBRTC_WIN 1547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#define SEC_E_CERT_EXPIRED (-2146893016) 1647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#endif // !WEBRTC_WIN 1747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 1847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#include "webrtc/base/common.h" 1947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#include "webrtc/base/httpbase.h" 2047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#include "webrtc/base/logging.h" 2147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#include "webrtc/base/socket.h" 2247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#include "webrtc/base/stringutils.h" 2347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#include "webrtc/base/thread.h" 2447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 2547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgnamespace rtc { 2647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 2747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org////////////////////////////////////////////////////////////////////// 2847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org// Helpers 2947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org////////////////////////////////////////////////////////////////////// 3047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 3147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgbool MatchHeader(const char* str, size_t len, HttpHeader header) { 3247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org const char* const header_str = ToString(header); 3347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org const size_t header_len = strlen(header_str); 3447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return (len == header_len) && (_strnicmp(str, header_str, header_len) == 0); 3547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 3647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 3747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgenum { 3847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org MSG_READ 3947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org}; 4047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 4147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org////////////////////////////////////////////////////////////////////// 4247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org// HttpParser 4347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org////////////////////////////////////////////////////////////////////// 4447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 4547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpParser::HttpParser() { 4647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org reset(); 4747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 4847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 4947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpParser::~HttpParser() { 5047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 5147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 5247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgvoid 5347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpParser::reset() { 5447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org state_ = ST_LEADER; 5547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org chunked_ = false; 5647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org data_size_ = SIZE_UNKNOWN; 5747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 5847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 5947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpParser::ProcessResult 6047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpParser::Process(const char* buffer, size_t len, size_t* processed, 6147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org HttpError* error) { 6247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org *processed = 0; 6347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org *error = HE_NONE; 6447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 6547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (state_ >= ST_COMPLETE) { 6647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(false); 6747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_COMPLETE; 6847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 6947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 7047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org while (true) { 7147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (state_ < ST_DATA) { 7247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org size_t pos = *processed; 7347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org while ((pos < len) && (buffer[pos] != '\n')) { 7447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org pos += 1; 7547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 7647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (pos >= len) { 7747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org break; // don't have a full header 7847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 7947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org const char* line = buffer + *processed; 8047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org size_t len = (pos - *processed); 8147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org *processed = pos + 1; 8247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org while ((len > 0) && isspace(static_cast<unsigned char>(line[len-1]))) { 8347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org len -= 1; 8447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 8547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ProcessResult result = ProcessLine(line, len, error); 8647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG(LS_VERBOSE) << "Processed line, result=" << result; 8747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 8847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (PR_CONTINUE != result) { 8947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return result; 9047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 9147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else if (data_size_ == 0) { 9247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (chunked_) { 9347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org state_ = ST_CHUNKTERM; 9447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else { 9547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_COMPLETE; 9647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 9747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else { 9847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org size_t available = len - *processed; 9947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (available <= 0) { 10047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org break; // no more data 10147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 10247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if ((data_size_ != SIZE_UNKNOWN) && (available > data_size_)) { 10347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org available = data_size_; 10447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 10547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org size_t read = 0; 10647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ProcessResult result = ProcessData(buffer + *processed, available, read, 10747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org error); 10847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG(LS_VERBOSE) << "Processed data, result: " << result << " read: " 10947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org << read << " err: " << error; 11047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 11147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (PR_CONTINUE != result) { 11247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return result; 11347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 11447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org *processed += read; 11547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (data_size_ != SIZE_UNKNOWN) { 11647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org data_size_ -= read; 11747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 11847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 11947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 12047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 12147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_CONTINUE; 12247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 12347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 12447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpParser::ProcessResult 12547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpParser::ProcessLine(const char* line, size_t len, HttpError* error) { 12647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG_F(LS_VERBOSE) << " state: " << state_ << " line: " 12747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org << std::string(line, len) << " len: " << len << " err: " 12847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org << error; 12947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 13047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org switch (state_) { 13147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case ST_LEADER: 13247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org state_ = ST_HEADERS; 13347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return ProcessLeader(line, len, error); 13447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 13547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case ST_HEADERS: 13647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (len > 0) { 13747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org const char* value = strchrn(line, len, ':'); 13847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (!value) { 13947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org *error = HE_PROTOCOL; 14047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_COMPLETE; 14147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 14247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org size_t nlen = (value - line); 14347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org const char* eol = line + len; 14447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org do { 14547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org value += 1; 14647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } while ((value < eol) && isspace(static_cast<unsigned char>(*value))); 14747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org size_t vlen = eol - value; 14847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (MatchHeader(line, nlen, HH_CONTENT_LENGTH)) { 14947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // sscanf isn't safe with strings that aren't null-terminated, and there 15047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // is no guarantee that |value| is. 15147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Create a local copy that is null-terminated. 15247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org std::string value_str(value, vlen); 15347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org unsigned int temp_size; 15447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (sscanf(value_str.c_str(), "%u", &temp_size) != 1) { 15547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org *error = HE_PROTOCOL; 15647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_COMPLETE; 15747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 15847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org data_size_ = static_cast<size_t>(temp_size); 15947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else if (MatchHeader(line, nlen, HH_TRANSFER_ENCODING)) { 16047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if ((vlen == 7) && (_strnicmp(value, "chunked", 7) == 0)) { 16147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org chunked_ = true; 16247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else if ((vlen == 8) && (_strnicmp(value, "identity", 8) == 0)) { 16347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org chunked_ = false; 16447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else { 16547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org *error = HE_PROTOCOL; 16647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_COMPLETE; 16747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 16847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 16947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return ProcessHeader(line, nlen, value, vlen, error); 17047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else { 17147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org state_ = chunked_ ? ST_CHUNKSIZE : ST_DATA; 17247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return ProcessHeaderComplete(chunked_, data_size_, error); 17347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 17447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org break; 17547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 17647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case ST_CHUNKSIZE: 17747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (len > 0) { 17847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org char* ptr = NULL; 17947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org data_size_ = strtoul(line, &ptr, 16); 18047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (ptr != line + len) { 18147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org *error = HE_PROTOCOL; 18247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_COMPLETE; 18347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 18447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org state_ = (data_size_ == 0) ? ST_TRAILERS : ST_DATA; 18547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else { 18647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org *error = HE_PROTOCOL; 18747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_COMPLETE; 18847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 18947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org break; 19047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 19147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case ST_CHUNKTERM: 19247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (len > 0) { 19347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org *error = HE_PROTOCOL; 19447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_COMPLETE; 19547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else { 19647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org state_ = chunked_ ? ST_CHUNKSIZE : ST_DATA; 19747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 19847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org break; 19947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 20047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case ST_TRAILERS: 20147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (len == 0) { 20247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_COMPLETE; 20347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 20447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // *error = onHttpRecvTrailer(); 20547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org break; 20647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 20747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org default: 20847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(false); 20947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org break; 21047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 21147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 21247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_CONTINUE; 21347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 21447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 21547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgbool 21647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpParser::is_valid_end_of_input() const { 21747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return (state_ == ST_DATA) && (data_size_ == SIZE_UNKNOWN); 21847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 21947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 22047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgvoid 22147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpParser::complete(HttpError error) { 22247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (state_ < ST_COMPLETE) { 22347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org state_ = ST_COMPLETE; 22447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org OnComplete(error); 22547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 22647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 22747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 22847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org////////////////////////////////////////////////////////////////////// 22947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org// HttpBase::DocumentStream 23047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org////////////////////////////////////////////////////////////////////// 23147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 23247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgclass BlockingMemoryStream : public ExternalMemoryStream { 23347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgpublic: 23447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org BlockingMemoryStream(char* buffer, size_t size) 23547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org : ExternalMemoryStream(buffer, size) { } 23647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 23747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org virtual StreamResult DoReserve(size_t size, int* error) { 23847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return (buffer_length_ >= size) ? SR_SUCCESS : SR_BLOCK; 23947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 24047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org}; 24147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 24247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgclass HttpBase::DocumentStream : public StreamInterface { 24347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgpublic: 24447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org DocumentStream(HttpBase* base) : base_(base), error_(HE_DEFAULT) { } 24547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 24647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org virtual StreamState GetState() const { 24747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (NULL == base_) 24847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return SS_CLOSED; 24947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (HM_RECV == base_->mode_) 25047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return SS_OPEN; 25147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return SS_OPENING; 25247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 25347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 25447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org virtual StreamResult Read(void* buffer, size_t buffer_len, 25547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org size_t* read, int* error) { 25647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (!base_) { 25747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (error) *error = error_; 25847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return (HE_NONE == error_) ? SR_EOS : SR_ERROR; 25947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 26047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 26147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (HM_RECV != base_->mode_) { 26247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return SR_BLOCK; 26347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 26447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 26547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // DoReceiveLoop writes http document data to the StreamInterface* document 26647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // member of HttpData. In this case, we want this data to be written 26747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // directly to our buffer. To accomplish this, we wrap our buffer with a 26847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // StreamInterface, and replace the existing document with our wrapper. 26947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // When the method returns, we restore the old document. Ideally, we would 27047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // pass our StreamInterface* to DoReceiveLoop, but due to the callbacks 27147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // of HttpParser, we would still need to store the pointer temporarily. 27247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org scoped_ptr<StreamInterface> 27347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org stream(new BlockingMemoryStream(reinterpret_cast<char*>(buffer), 27447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org buffer_len)); 27547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 27647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Replace the existing document with our wrapped buffer. 27747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org base_->data_->document.swap(stream); 27847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 27947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Pump the I/O loop. DoReceiveLoop is guaranteed not to attempt to 28047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // complete the I/O process, which means that our wrapper is not in danger 28147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // of being deleted. To ensure this, DoReceiveLoop returns true when it 28247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // wants complete to be called. We make sure to uninstall our wrapper 28347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // before calling complete(). 28447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org HttpError http_error; 28547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org bool complete = base_->DoReceiveLoop(&http_error); 28647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 28747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Reinstall the original output document. 28847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org base_->data_->document.swap(stream); 28947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 29047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // If we reach the end of the receive stream, we disconnect our stream 29147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // adapter from the HttpBase, and further calls to read will either return 29247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // EOS or ERROR, appropriately. Finally, we call complete(). 29347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org StreamResult result = SR_BLOCK; 29447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (complete) { 29547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org HttpBase* base = Disconnect(http_error); 29647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (error) *error = error_; 29747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org result = (HE_NONE == error_) ? SR_EOS : SR_ERROR; 29847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org base->complete(http_error); 29947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 30047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 30147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Even if we are complete, if some data was read we must return SUCCESS. 30247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Future Reads will return EOS or ERROR based on the error_ variable. 30347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org size_t position; 30447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org stream->GetPosition(&position); 30547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (position > 0) { 30647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (read) *read = position; 30747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org result = SR_SUCCESS; 30847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 30947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return result; 31047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 31147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 31247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org virtual StreamResult Write(const void* data, size_t data_len, 31347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org size_t* written, int* error) { 31447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (error) *error = -1; 31547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return SR_ERROR; 31647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 31747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 31847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org virtual void Close() { 31947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (base_) { 32047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org HttpBase* base = Disconnect(HE_NONE); 32147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (HM_RECV == base->mode_ && base->http_stream_) { 32247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Read I/O could have been stalled on the user of this DocumentStream, 32347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // so restart the I/O process now that we've removed ourselves. 32447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org base->http_stream_->PostEvent(SE_READ, 0); 32547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 32647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 32747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 32847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 32947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org virtual bool GetAvailable(size_t* size) const { 33047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (!base_ || HM_RECV != base_->mode_) 33147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return false; 33247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org size_t data_size = base_->GetDataRemaining(); 33347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (SIZE_UNKNOWN == data_size) 33447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return false; 33547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (size) 33647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org *size = data_size; 33747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return true; 33847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 33947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 34047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org HttpBase* Disconnect(HttpError error) { 34147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(NULL != base_); 34247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(NULL != base_->doc_stream_); 34347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org HttpBase* base = base_; 34447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org base_->doc_stream_ = NULL; 34547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org base_ = NULL; 34647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org error_ = error; 34747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return base; 34847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 34947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 35047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgprivate: 35147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org HttpBase* base_; 35247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org HttpError error_; 35347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org}; 35447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 35547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org////////////////////////////////////////////////////////////////////// 35647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org// HttpBase 35747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org////////////////////////////////////////////////////////////////////// 35847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 35947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpBase::HttpBase() : mode_(HM_NONE), data_(NULL), notify_(NULL), 36047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org http_stream_(NULL), doc_stream_(NULL) { 36147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 36247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 36347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpBase::~HttpBase() { 36447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(HM_NONE == mode_); 36547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 36647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 36747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgbool 36847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpBase::isConnected() const { 36947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return (http_stream_ != NULL) && (http_stream_->GetState() == SS_OPEN); 37047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 37147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 37247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgbool 37347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpBase::attach(StreamInterface* stream) { 37447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if ((mode_ != HM_NONE) || (http_stream_ != NULL) || (stream == NULL)) { 37547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(false); 37647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return false; 37747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 37847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org http_stream_ = stream; 37947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org http_stream_->SignalEvent.connect(this, &HttpBase::OnHttpStreamEvent); 38047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org mode_ = (http_stream_->GetState() == SS_OPENING) ? HM_CONNECT : HM_NONE; 38147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return true; 38247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 38347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 38447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgStreamInterface* 38547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpBase::detach() { 38647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(HM_NONE == mode_); 38747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (mode_ != HM_NONE) { 38847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return NULL; 38947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 39047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org StreamInterface* stream = http_stream_; 39147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org http_stream_ = NULL; 39247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (stream) { 39347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org stream->SignalEvent.disconnect(this); 39447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 39547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return stream; 39647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 39747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 39847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgvoid 39947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpBase::send(HttpData* data) { 40047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(HM_NONE == mode_); 40147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (mode_ != HM_NONE) { 40247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 40347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else if (!isConnected()) { 40447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org OnHttpStreamEvent(http_stream_, SE_CLOSE, HE_DISCONNECTED); 40547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 40647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 40747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 40847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org mode_ = HM_SEND; 40947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org data_ = data; 41047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org len_ = 0; 41147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ignore_data_ = chunk_data_ = false; 41247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 41347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (data_->document) { 41447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org data_->document->SignalEvent.connect(this, &HttpBase::OnDocumentEvent); 41547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 41647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 41747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org std::string encoding; 41847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (data_->hasHeader(HH_TRANSFER_ENCODING, &encoding) 41947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org && (encoding == "chunked")) { 42047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org chunk_data_ = true; 42147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 42247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 42347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org len_ = data_->formatLeader(buffer_, sizeof(buffer_)); 42447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org len_ += strcpyn(buffer_ + len_, sizeof(buffer_) - len_, "\r\n"); 42547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 42647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org header_ = data_->begin(); 42747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (header_ == data_->end()) { 42847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // We must call this at least once, in the case where there are no headers. 42947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org queue_headers(); 43047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 43147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 43247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org flush_data(); 43347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 43447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 43547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgvoid 43647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpBase::recv(HttpData* data) { 43747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(HM_NONE == mode_); 43847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (mode_ != HM_NONE) { 43947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 44047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else if (!isConnected()) { 44147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org OnHttpStreamEvent(http_stream_, SE_CLOSE, HE_DISCONNECTED); 44247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 44347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 44447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 44547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org mode_ = HM_RECV; 44647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org data_ = data; 44747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org len_ = 0; 44847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ignore_data_ = chunk_data_ = false; 44947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 45047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org reset(); 45147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (doc_stream_) { 45247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org doc_stream_->SignalEvent(doc_stream_, SE_OPEN | SE_READ, 0); 45347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else { 45447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org read_and_process_data(); 45547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 45647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 45747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 45847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgvoid 45947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpBase::abort(HttpError err) { 46047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (mode_ != HM_NONE) { 46147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (http_stream_ != NULL) { 46247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org http_stream_->Close(); 46347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 46447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org do_complete(err); 46547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 46647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 46747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 46847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgStreamInterface* HttpBase::GetDocumentStream() { 46947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (doc_stream_) 47047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return NULL; 47147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org doc_stream_ = new DocumentStream(this); 47247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return doc_stream_; 47347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 47447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 47547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpError HttpBase::HandleStreamClose(int error) { 47647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (http_stream_ != NULL) { 47747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org http_stream_->Close(); 47847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 47947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (error == 0) { 48047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if ((mode_ == HM_RECV) && is_valid_end_of_input()) { 48147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return HE_NONE; 48247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else { 48347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return HE_DISCONNECTED; 48447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 48547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else if (error == SOCKET_EACCES) { 48647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return HE_AUTH; 48747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else if (error == SEC_E_CERT_EXPIRED) { 48847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return HE_CERTIFICATE_EXPIRED; 48947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 49047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG_F(LS_ERROR) << "(" << error << ")"; 49147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return (HM_CONNECT == mode_) ? HE_CONNECT_FAILED : HE_SOCKET_ERROR; 49247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 49347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 49447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgbool HttpBase::DoReceiveLoop(HttpError* error) { 49547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(HM_RECV == mode_); 49647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(NULL != error); 49747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 49847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Do to the latency between receiving read notifications from 49947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // pseudotcpchannel, we rely on repeated calls to read in order to acheive 50047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // ideal throughput. The number of reads is limited to prevent starving 50147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // the caller. 50247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 50347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org size_t loop_count = 0; 50447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org const size_t kMaxReadCount = 20; 50547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org bool process_requires_more_data = false; 50647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org do { 50747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // The most frequent use of this function is response to new data available 50847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // on http_stream_. Therefore, we optimize by attempting to read from the 50947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // network first (as opposed to processing existing data first). 51047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 51147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (len_ < sizeof(buffer_)) { 51247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Attempt to buffer more data. 51347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org size_t read; 51447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org int read_error; 51547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org StreamResult read_result = http_stream_->Read(buffer_ + len_, 51647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org sizeof(buffer_) - len_, 51747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org &read, &read_error); 51847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org switch (read_result) { 51947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case SR_SUCCESS: 52047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(len_ + read <= sizeof(buffer_)); 52147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org len_ += read; 52247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org break; 52347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case SR_BLOCK: 52447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (process_requires_more_data) { 52547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // We're can't make progress until more data is available. 52647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return false; 52747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 52847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Attempt to process the data already in our buffer. 52947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org break; 53047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case SR_EOS: 53147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Clean close, with no error. Fall through to HandleStreamClose. 53247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org read_error = 0; 53347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case SR_ERROR: 53447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org *error = HandleStreamClose(read_error); 53547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return true; 53647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 53747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else if (process_requires_more_data) { 53847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // We have too much unprocessed data in our buffer. This should only 53947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // occur when a single HTTP header is longer than the buffer size (32K). 54047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Anything longer than that is almost certainly an error. 54147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org *error = HE_OVERFLOW; 54247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return true; 54347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 54447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 54547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Process data in our buffer. Process is not guaranteed to process all 54647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // the buffered data. In particular, it will wait until a complete 54747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // protocol element (such as http header, or chunk size) is available, 54847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // before processing it in its entirety. Also, it is valid and sometimes 54947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // necessary to call Process with an empty buffer, since the state machine 55047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // may have interrupted state transitions to complete. 55147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org size_t processed; 55247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ProcessResult process_result = Process(buffer_, len_, &processed, 55347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org error); 55447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(processed <= len_); 55547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org len_ -= processed; 55647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org memmove(buffer_, buffer_ + processed, len_); 55747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org switch (process_result) { 55847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case PR_CONTINUE: 55947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // We need more data to make progress. 56047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org process_requires_more_data = true; 56147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org break; 56247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case PR_BLOCK: 56347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // We're stalled on writing the processed data. 56447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return false; 56547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case PR_COMPLETE: 56647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // *error already contains the correct code. 56747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return true; 56847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 56947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } while (++loop_count <= kMaxReadCount); 57047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 57147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG_F(LS_WARNING) << "danger of starvation"; 57247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return false; 57347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 57447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 57547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgvoid 57647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpBase::read_and_process_data() { 57747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org HttpError error; 57847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (DoReceiveLoop(&error)) { 57947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org complete(error); 58047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 58147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 58247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 58347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgvoid 58447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpBase::flush_data() { 58547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(HM_SEND == mode_); 58647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 58747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // When send_required is true, no more buffering can occur without a network 58847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // write. 58947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org bool send_required = (len_ >= sizeof(buffer_)); 59047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 59147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org while (true) { 59247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(len_ <= sizeof(buffer_)); 59347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 59447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // HTTP is inherently sensitive to round trip latency, since a frequent use 59547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // case is for small requests and responses to be sent back and forth, and 59647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // the lack of pipelining forces a single request to take a minimum of the 59747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // round trip time. As a result, it is to our benefit to pack as much data 59847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // into each packet as possible. Thus, we defer network writes until we've 59947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // buffered as much data as possible. 60047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 60147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (!send_required && (header_ != data_->end())) { 60247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // First, attempt to queue more header data. 60347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org send_required = queue_headers(); 60447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 60547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 60647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (!send_required && data_->document) { 60747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Next, attempt to queue document data. 60847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 60947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org const size_t kChunkDigits = 8; 61047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org size_t offset, reserve; 61147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (chunk_data_) { 61247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Reserve characters at the start for X-byte hex value and \r\n 61347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org offset = len_ + kChunkDigits + 2; 61447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // ... and 2 characters at the end for \r\n 61547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org reserve = offset + 2; 61647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else { 61747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org offset = len_; 61847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org reserve = offset; 61947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 62047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 62147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (reserve >= sizeof(buffer_)) { 62247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org send_required = true; 62347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else { 62447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org size_t read; 62547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org int error; 62647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org StreamResult result = data_->document->Read(buffer_ + offset, 62747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org sizeof(buffer_) - reserve, 62847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org &read, &error); 62947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (result == SR_SUCCESS) { 63047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(reserve + read <= sizeof(buffer_)); 63147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (chunk_data_) { 63247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Prepend the chunk length in hex. 63347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Note: sprintfn appends a null terminator, which is why we can't 63447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // combine it with the line terminator. 63547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org sprintfn(buffer_ + len_, kChunkDigits + 1, "%.*x", 63647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org kChunkDigits, read); 63747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Add line terminator to the chunk length. 63847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org memcpy(buffer_ + len_ + kChunkDigits, "\r\n", 2); 63947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Add line terminator to the end of the chunk. 64047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org memcpy(buffer_ + offset + read, "\r\n", 2); 64147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 64247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org len_ = reserve + read; 64347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else if (result == SR_BLOCK) { 64447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Nothing to do but flush data to the network. 64547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org send_required = true; 64647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else if (result == SR_EOS) { 64747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (chunk_data_) { 64847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Append the empty chunk and empty trailers, then turn off 64947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // chunking. 65047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(len_ + 5 <= sizeof(buffer_)); 65147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org memcpy(buffer_ + len_, "0\r\n\r\n", 5); 65247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org len_ += 5; 65347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org chunk_data_ = false; 65447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else if (0 == len_) { 65547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // No more data to read, and no more data to write. 65647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org do_complete(); 65747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 65847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 65947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Although we are done reading data, there is still data which needs 66047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // to be flushed to the network. 66147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org send_required = true; 66247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else { 66347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG_F(LS_ERROR) << "Read error: " << error; 66447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org do_complete(HE_STREAM); 66547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 66647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 66747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 66847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 66947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 67047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (0 == len_) { 67147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // No data currently available to send. 67247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (!data_->document) { 67347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // If there is no source document, that means we're done. 67447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org do_complete(); 67547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 67647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 67747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 67847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 67947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org size_t written; 68047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org int error; 68147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org StreamResult result = http_stream_->Write(buffer_, len_, &written, &error); 68247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (result == SR_SUCCESS) { 68347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(written <= len_); 68447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org len_ -= written; 68547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org memmove(buffer_, buffer_ + written, len_); 68647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org send_required = false; 68747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else if (result == SR_BLOCK) { 68847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (send_required) { 68947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Nothing more we can do until network is writeable. 69047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 69147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 69247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else { 69347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(result == SR_ERROR); 69447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG_F(LS_ERROR) << "error"; 69547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org OnHttpStreamEvent(http_stream_, SE_CLOSE, error); 69647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 69747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 69847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 69947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 70047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(false); 70147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 70247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 70347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgbool 70447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpBase::queue_headers() { 70547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(HM_SEND == mode_); 70647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org while (header_ != data_->end()) { 70747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org size_t len = sprintfn(buffer_ + len_, sizeof(buffer_) - len_, 70847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org "%.*s: %.*s\r\n", 70947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org header_->first.size(), header_->first.data(), 71047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org header_->second.size(), header_->second.data()); 71147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (len_ + len < sizeof(buffer_) - 3) { 71247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org len_ += len; 71347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ++header_; 71447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else if (len_ == 0) { 71547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG(WARNING) << "discarding header that is too long: " << header_->first; 71647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ++header_; 71747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else { 71847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Not enough room for the next header, write to network first. 71947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return true; 72047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 72147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 72247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // End of headers 72347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org len_ += strcpyn(buffer_ + len_, sizeof(buffer_) - len_, "\r\n"); 72447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return false; 72547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 72647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 72747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgvoid 72847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpBase::do_complete(HttpError err) { 72947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(mode_ != HM_NONE); 73047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org HttpMode mode = mode_; 73147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org mode_ = HM_NONE; 73247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (data_ && data_->document) { 73347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org data_->document->SignalEvent.disconnect(this); 73447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 73547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org data_ = NULL; 73647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if ((HM_RECV == mode) && doc_stream_) { 73747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(HE_NONE != err); // We should have Disconnected doc_stream_ already. 73847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org DocumentStream* ds = doc_stream_; 73947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ds->Disconnect(err); 74047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ds->SignalEvent(ds, SE_CLOSE, err); 74147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 74247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (notify_) { 74347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org notify_->onHttpComplete(mode, err); 74447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 74547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 74647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 74747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org// 74847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org// Stream Signals 74947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org// 75047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 75147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgvoid 75247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpBase::OnHttpStreamEvent(StreamInterface* stream, int events, int error) { 75347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(stream == http_stream_); 75447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if ((events & SE_OPEN) && (mode_ == HM_CONNECT)) { 75547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org do_complete(); 75647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 75747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 75847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 75947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if ((events & SE_WRITE) && (mode_ == HM_SEND)) { 76047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org flush_data(); 76147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 76247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 76347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 76447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if ((events & SE_READ) && (mode_ == HM_RECV)) { 76547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (doc_stream_) { 76647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org doc_stream_->SignalEvent(doc_stream_, SE_READ, 0); 76747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else { 76847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org read_and_process_data(); 76947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 77047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 77147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 77247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 77347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if ((events & SE_CLOSE) == 0) 77447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 77547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 77647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org HttpError http_error = HandleStreamClose(error); 77747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (mode_ == HM_RECV) { 77847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org complete(http_error); 77947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else if (mode_ != HM_NONE) { 78047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org do_complete(http_error); 78147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else if (notify_) { 78247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org notify_->onHttpClosed(http_error); 78347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 78447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 78547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 78647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgvoid 78747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpBase::OnDocumentEvent(StreamInterface* stream, int events, int error) { 78847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(stream == data_->document.get()); 78947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if ((events & SE_WRITE) && (mode_ == HM_RECV)) { 79047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org read_and_process_data(); 79147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 79247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 79347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 79447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if ((events & SE_READ) && (mode_ == HM_SEND)) { 79547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org flush_data(); 79647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 79747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 79847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 79947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (events & SE_CLOSE) { 80047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG_F(LS_ERROR) << "Read error: " << error; 80147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org do_complete(HE_STREAM); 80247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 80347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 80447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 80547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 80647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org// 80747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org// HttpParser Implementation 80847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org// 80947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 81047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpParser::ProcessResult 81147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpBase::ProcessLeader(const char* line, size_t len, HttpError* error) { 81247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org *error = data_->parseLeader(line, len); 81347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return (HE_NONE == *error) ? PR_CONTINUE : PR_COMPLETE; 81447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 81547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 81647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpParser::ProcessResult 81747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpBase::ProcessHeader(const char* name, size_t nlen, const char* value, 81847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org size_t vlen, HttpError* error) { 81947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org std::string sname(name, nlen), svalue(value, vlen); 82047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org data_->addHeader(sname, svalue); 82147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_CONTINUE; 82247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 82347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 82447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpParser::ProcessResult 82547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpBase::ProcessHeaderComplete(bool chunked, size_t& data_size, 82647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org HttpError* error) { 82747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org StreamInterface* old_docstream = doc_stream_; 82847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (notify_) { 82947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org *error = notify_->onHttpHeaderComplete(chunked, data_size); 83047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // The request must not be aborted as a result of this callback. 83147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(NULL != data_); 83247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 83347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if ((HE_NONE == *error) && data_->document) { 83447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org data_->document->SignalEvent.connect(this, &HttpBase::OnDocumentEvent); 83547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 83647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (HE_NONE != *error) { 83747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_COMPLETE; 83847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 83947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (old_docstream != doc_stream_) { 84047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Break out of Process loop, since our I/O model just changed. 84147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_BLOCK; 84247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 84347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_CONTINUE; 84447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 84547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 84647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpParser::ProcessResult 84747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpBase::ProcessData(const char* data, size_t len, size_t& read, 84847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org HttpError* error) { 84947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (ignore_data_ || !data_->document) { 85047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org read = len; 85147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_CONTINUE; 85247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 85347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org int write_error = 0; 85447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org switch (data_->document->Write(data, len, &read, &write_error)) { 85547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case SR_SUCCESS: 85647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_CONTINUE; 85747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case SR_BLOCK: 85847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_BLOCK; 85947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case SR_EOS: 86047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG_F(LS_ERROR) << "Unexpected EOS"; 86147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org *error = HE_STREAM; 86247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_COMPLETE; 86347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case SR_ERROR: 86447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org default: 86547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG_F(LS_ERROR) << "Write error: " << write_error; 86647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org *error = HE_STREAM; 86747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return PR_COMPLETE; 86847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 86947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 87047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 87147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgvoid 87247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgHttpBase::OnComplete(HttpError err) { 87347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG_F(LS_VERBOSE); 87447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org do_complete(err); 87547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 87647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 87747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} // namespace rtc 878