proxy_interface.h

Go to the documentation of this file.

/*
 * Copyright 2011 Google Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http:///www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */


#ifndef PAGESPEED_AUTOMATIC_PROXY_INTERFACE_H_
#define PAGESPEED_AUTOMATIC_PROXY_INTERFACE_H_

#include "net/instaweb/http/public/url_async_fetcher.h"
#include "pagespeed/kernel/base/basictypes.h"
#include "pagespeed/kernel/base/scoped_ptr.h"
#include "pagespeed/kernel/base/string.h"
#include "pagespeed/kernel/base/string_util.h"

namespace net_instaweb {

class AsyncFetch;
class GoogleUrl;
class MessageHandler;
class ProxyFetchPropertyCallbackCollector;
class ProxyFetchFactory;
class ServerContext;
class RewriteOptions;
class Statistics;
class TimedVariable;

class ProxyInterface : public UrlAsyncFetcher {
 public:
  ProxyInterface(StringPiece stats_prefix, StringPiece hostname, int port,
                 ServerContext* server_context, Statistics* stats);
  virtual ~ProxyInterface();

  static void InitStats(StringPiece stats_prefix, Statistics* statistics);

  virtual void Fetch(const GoogleString& requested_url,
                     MessageHandler* handler,
                     AsyncFetch* async_fetch);

  bool IsWellFormedUrl(const GoogleUrl& url);

  static const char kCacheHtmlRequestCount[];

  virtual ProxyFetchPropertyCallbackCollector* InitiatePropertyCacheLookup(
      bool is_resource_fetch,
      const GoogleUrl& request_url,
      RewriteOptions* options,
      AsyncFetch* async_fetch);

 protected:
  ServerContext* server_context_; 

 private:
  friend class ProxyInterfaceTest;

  void ProxyRequest(bool is_resource_fetch,
                    const GoogleUrl& requested_url,
                    AsyncFetch* async_fetch,
                    MessageHandler* handler);

  struct RequestData;
  void GetRewriteOptionsDone(RequestData* request_data,
                             RewriteOptions* query_options);

  bool UrlAndPortMatchThisServer(const GoogleUrl& url);

  const GoogleString hostname_;
  const int port_;

  TimedVariable* all_requests_;
  TimedVariable* pagespeed_requests_;
  TimedVariable* cache_html_flow_requests_;
  TimedVariable* rejected_requests_;
  TimedVariable* requests_without_domain_config_;
  TimedVariable* resource_requests_without_domain_config_;

  scoped_ptr<ProxyFetchFactory> proxy_fetch_factory_;

  
};

}  

#endif