| Index: webrtc/base/httpclient.h
|
| diff --git a/webrtc/base/httpclient.h b/webrtc/base/httpclient.h
|
| deleted file mode 100644
|
| index 0c19d2efb4353dedea37a674c51fff0bcd6df24b..0000000000000000000000000000000000000000
|
| --- a/webrtc/base/httpclient.h
|
| +++ /dev/null
|
| @@ -1,196 +0,0 @@
|
| -/*
|
| - * Copyright 2004 The WebRTC Project Authors. All rights reserved.
|
| - *
|
| - * Use of this source code is governed by a BSD-style license
|
| - * that can be found in the LICENSE file in the root of the source
|
| - * tree. An additional intellectual property rights grant can be found
|
| - * in the file PATENTS. All contributing project authors may
|
| - * be found in the AUTHORS file in the root of the source tree.
|
| - */
|
| -
|
| -#ifndef WEBRTC_BASE_HTTPCLIENT_H__
|
| -#define WEBRTC_BASE_HTTPCLIENT_H__
|
| -
|
| -#include <memory>
|
| -
|
| -#include "webrtc/base/common.h"
|
| -#include "webrtc/base/httpbase.h"
|
| -#include "webrtc/base/nethelpers.h"
|
| -#include "webrtc/base/proxyinfo.h"
|
| -#include "webrtc/base/sigslot.h"
|
| -#include "webrtc/base/socketaddress.h"
|
| -#include "webrtc/base/socketpool.h"
|
| -
|
| -namespace rtc {
|
| -
|
| -//////////////////////////////////////////////////////////////////////
|
| -// Client-specific http utilities
|
| -//////////////////////////////////////////////////////////////////////
|
| -
|
| -// Write cache-relevant response headers to output stream. If size is non-null,
|
| -// it contains the length of the output in bytes. output may be null if only
|
| -// the length is desired.
|
| -bool HttpWriteCacheHeaders(const HttpResponseData* response,
|
| - StreamInterface* output, size_t* size);
|
| -// Read cached headers from a stream, and them merge them into the response
|
| -// object using the specified combine operation.
|
| -bool HttpReadCacheHeaders(StreamInterface* input,
|
| - HttpResponseData* response,
|
| - HttpData::HeaderCombine combine);
|
| -
|
| -//////////////////////////////////////////////////////////////////////
|
| -// HttpClient
|
| -// Implements an HTTP 1.1 client.
|
| -//////////////////////////////////////////////////////////////////////
|
| -
|
| -class DiskCache;
|
| -class HttpClient;
|
| -class IPNetPool;
|
| -
|
| -class SignalThread;
|
| -// What to do: Define STRICT_HTTP_ERROR=1 in your makefile. Use HttpError in
|
| -// your code (HttpErrorType should only be used for code that is shared
|
| -// with groups which have not yet migrated).
|
| -#if STRICT_HTTP_ERROR
|
| -typedef HttpError HttpErrorType;
|
| -#else // !STRICT_HTTP_ERROR
|
| -typedef int HttpErrorType;
|
| -#endif // !STRICT_HTTP_ERROR
|
| -
|
| -class HttpClient : private IHttpNotify, public sigslot::has_slots<> {
|
| -public:
|
| - // If HttpRequestData and HttpResponseData objects are provided, they must
|
| - // be freed by the caller. Otherwise, an internal object is allocated.
|
| - HttpClient(const std::string& agent, StreamPool* pool,
|
| - HttpTransaction* transaction = NULL);
|
| - ~HttpClient() override;
|
| -
|
| - void set_pool(StreamPool* pool) { pool_ = pool; }
|
| -
|
| - void set_agent(const std::string& agent) { agent_ = agent; }
|
| - const std::string& agent() const { return agent_; }
|
| -
|
| - void set_proxy(const ProxyInfo& proxy) { proxy_ = proxy; }
|
| - const ProxyInfo& proxy() const { return proxy_; }
|
| -
|
| - // Request retries occur when the connection closes before the beginning of
|
| - // an http response is received. In these cases, the http server may have
|
| - // timed out the keepalive connection before it received our request. Note
|
| - // that if a request document cannot be rewound, no retry is made. The
|
| - // default is 1.
|
| - void set_request_retries(size_t retries) { retries_ = retries; }
|
| - size_t request_retries() const { return retries_; }
|
| -
|
| - enum RedirectAction { REDIRECT_DEFAULT, REDIRECT_ALWAYS, REDIRECT_NEVER };
|
| - void set_redirect_action(RedirectAction action) { redirect_action_ = action; }
|
| - RedirectAction redirect_action() const { return redirect_action_; }
|
| -
|
| - enum UriForm { URI_DEFAULT, URI_ABSOLUTE, URI_RELATIVE };
|
| - void set_uri_form(UriForm form) { uri_form_ = form; }
|
| - UriForm uri_form() const { return uri_form_; }
|
| -
|
| - void set_cache(DiskCache* cache) { ASSERT(!IsCacheActive()); cache_ = cache; }
|
| - bool cache_enabled() const { return (NULL != cache_); }
|
| -
|
| - // reset clears the server, request, and response structures. It will also
|
| - // abort an active request.
|
| - void reset();
|
| -
|
| - void set_server(const SocketAddress& address);
|
| - const SocketAddress& server() const { return server_; }
|
| -
|
| - // Note: in order for HttpClient to retry a POST in response to
|
| - // an authentication challenge, a redirect response, or socket disconnection,
|
| - // the request document must support 'replaying' by calling Rewind() on it.
|
| - HttpTransaction* transaction() { return transaction_; }
|
| - const HttpTransaction* transaction() const { return transaction_; }
|
| - HttpRequestData& request() { return transaction_->request; }
|
| - const HttpRequestData& request() const { return transaction_->request; }
|
| - HttpResponseData& response() { return transaction_->response; }
|
| - const HttpResponseData& response() const { return transaction_->response; }
|
| -
|
| - // convenience methods
|
| - void prepare_get(const std::string& url);
|
| - void prepare_post(const std::string& url, const std::string& content_type,
|
| - StreamInterface* request_doc);
|
| -
|
| - // Convert HttpClient to a pull-based I/O model.
|
| - StreamInterface* GetDocumentStream();
|
| -
|
| - // After you finish setting up your request, call start.
|
| - void start();
|
| -
|
| - // Signalled when the header has finished downloading, before the document
|
| - // content is processed. You may change the response document in response
|
| - // to this signal. The second parameter indicates whether this is an
|
| - // intermediate (false) or final (true) header. An intermediate header is
|
| - // one that generates another request, such as a redirect or authentication
|
| - // challenge. The third parameter indicates the length of the response
|
| - // document, or else SIZE_UNKNOWN. Note: Do NOT abort the request in response
|
| - // to this signal.
|
| - sigslot::signal3<HttpClient*,bool,size_t> SignalHeaderAvailable;
|
| - // Signalled when the current request finishes. On success, err is 0.
|
| - sigslot::signal2<HttpClient*,HttpErrorType> SignalHttpClientComplete;
|
| -
|
| -protected:
|
| - void connect();
|
| - void release();
|
| -
|
| - bool ShouldRedirect(std::string* location) const;
|
| -
|
| - bool BeginCacheFile();
|
| - HttpError WriteCacheHeaders(const std::string& id);
|
| - void CompleteCacheFile();
|
| -
|
| - bool CheckCache();
|
| - HttpError ReadCacheHeaders(const std::string& id, bool override);
|
| - HttpError ReadCacheBody(const std::string& id);
|
| -
|
| - bool PrepareValidate();
|
| - HttpError CompleteValidate();
|
| -
|
| - HttpError OnHeaderAvailable(bool ignore_data, bool chunked, size_t data_size);
|
| -
|
| - void StartDNSLookup();
|
| - void OnResolveResult(AsyncResolverInterface* resolver);
|
| -
|
| - // IHttpNotify Interface
|
| - HttpError onHttpHeaderComplete(bool chunked, size_t& data_size) override;
|
| - void onHttpComplete(HttpMode mode, HttpError err) override;
|
| - void onHttpClosed(HttpError err) override;
|
| -
|
| -private:
|
| - enum CacheState { CS_READY, CS_WRITING, CS_READING, CS_VALIDATING };
|
| - bool IsCacheActive() const { return (cache_state_ > CS_READY); }
|
| -
|
| - std::string agent_;
|
| - StreamPool* pool_;
|
| - HttpBase base_;
|
| - SocketAddress server_;
|
| - ProxyInfo proxy_;
|
| - HttpTransaction* transaction_;
|
| - bool free_transaction_;
|
| - size_t retries_, attempt_, redirects_;
|
| - RedirectAction redirect_action_;
|
| - UriForm uri_form_;
|
| - std::unique_ptr<HttpAuthContext> context_;
|
| - DiskCache* cache_;
|
| - CacheState cache_state_;
|
| - AsyncResolverInterface* resolver_;
|
| -};
|
| -
|
| -//////////////////////////////////////////////////////////////////////
|
| -// HttpClientDefault - Default implementation of HttpClient
|
| -//////////////////////////////////////////////////////////////////////
|
| -
|
| -class HttpClientDefault : public ReuseSocketPool, public HttpClient {
|
| -public:
|
| - HttpClientDefault(SocketFactory* factory, const std::string& agent,
|
| - HttpTransaction* transaction = NULL);
|
| -};
|
| -
|
| -//////////////////////////////////////////////////////////////////////
|
| -
|
| -} // namespace rtc
|
| -
|
| -#endif // WEBRTC_BASE_HTTPCLIENT_H__
|
|
|