system_server_context.h

Go to the documentation of this file.

// Copyright 2013 Google Inc.

#ifndef PAGESPEED_SYSTEM_SYSTEM_SERVER_CONTEXT_H_
#define PAGESPEED_SYSTEM_SYSTEM_SERVER_CONTEXT_H_

#include "net/instaweb/http/public/request_context.h"
#include "net/instaweb/rewriter/public/server_context.h"
#include "pagespeed/system/admin_site.h"
#include "pagespeed/kernel/base/abstract_mutex.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"
#include "pagespeed/kernel/base/writer.h"
#include "pagespeed/kernel/util/copy_on_write.h"

namespace net_instaweb {

class AsyncFetch;
class GoogleUrl;
class Histogram;
class QueryParams;
class PurgeSet;
class RewriteDriver;
class RewriteDriverFactory;
class RewriteOptions;
class RewriteStats;
class SharedMemStatistics;
class Statistics;
class SystemCachePath;
class SystemCaches;
class SystemRewriteDriverFactory;
class SystemRewriteOptions;
class UpDownCounter;
class UrlAsyncFetcherStats;
class Variable;

class SystemServerContext : public ServerContext {
 public:

  SystemServerContext(RewriteDriverFactory* factory,
                      StringPiece hostname, int port);
  virtual ~SystemServerContext();

  void SetCachePath(SystemCachePath* cache_path);

  void FlushCacheIfNecessary();

  SystemRewriteOptions* global_system_rewrite_options();
  GoogleString hostname_identifier() { return hostname_identifier_; }

  void UpdateCachePurgeSet(const CopyOnWrite<PurgeSet>& purge_set);

  virtual void PostInitHook();

  static void InitStats(Statistics* statistics);

  virtual void ChildInit(SystemRewriteDriverFactory* factory);

  void CreateLocalStatistics(Statistics* global_statistics,
                             SystemRewriteDriverFactory* factory);

  bool initialized() const { return initialized_; }

  virtual void ApplySessionFetchers(const RequestContextPtr& req,
                                    RewriteDriver* driver);

  void AddHtmlRewriteTimeUs(int64 rewrite_time_us);

  SystemCachePath* cache_path() { return cache_path_; }

  virtual void CollapseConfigOverlaysAndComputeSignatures();

  void ConsoleHandler(const SystemRewriteOptions& options,
                      AdminSite::AdminSource source,
                      const QueryParams& query_params, AsyncFetch* fetch);

  void MessageHistoryHandler(const RewriteOptions& options,
                             AdminSite::AdminSource source,
                             AsyncFetch* fetch);

  void StatisticsGraphsHandler(Writer* writer);

  void AdminPage(bool is_global, const GoogleUrl& stripped_gurl,
                 const QueryParams& query_params, const RewriteOptions* options,
                 AsyncFetch* fetch);

  void StatisticsPage(bool is_global, const QueryParams& query_params,
                      const RewriteOptions* options,
                      AsyncFetch* fetch);

  AdminSite* admin_site() { return admin_site_.get(); }

 protected:
  virtual bool UpdateCacheFlushTimestampMs(int64 timestamp_ms);

  void ConsoleJsonHandler(const QueryParams& params, AsyncFetch* fetch);

  void StatisticsHandler(const RewriteOptions& options, bool is_global_request,
                         AdminSite::AdminSource source, AsyncFetch* fetch);

  void PrintConfig(AdminSite::AdminSource source, AsyncFetch* fetch);

  void PrintCaches(bool is_global, AdminSite::AdminSource source,
                   const GoogleUrl& stripped_gurl,
                   const QueryParams& query_params,
                   const RewriteOptions* options,
                   AsyncFetch* fetch);

  void PrintHistograms(bool is_global_request,
                       AdminSite::AdminSource source,
                       AsyncFetch* fetch);

  Variable* statistics_404_count();

 private:
  void CheckLegacyGlobalCacheFlushFile();

  scoped_ptr<AdminSite> admin_site_;

  bool initialized_;
  bool use_per_vhost_statistics_;

  scoped_ptr<AbstractMutex> cache_flush_mutex_;
  int64 last_cache_flush_check_sec_; 

  Variable* cache_flush_count_;
  UpDownCounter* cache_flush_timestamp_ms_;

  Histogram* html_rewrite_time_us_histogram_;

  scoped_ptr<Statistics> split_statistics_;

  SharedMemStatistics* local_statistics_;

  scoped_ptr<RewriteStats> local_rewrite_stats_;
  scoped_ptr<UrlAsyncFetcherStats> stats_fetcher_;

  GoogleString hostname_identifier_;

  SystemCaches* system_caches_;

  SystemCachePath* cache_path_;

  
};

}  

#endif