diff options
Diffstat (limited to 'includes')
-rw-r--r-- | includes/bootstrap.inc | 10 | ||||
-rw-r--r-- | includes/cache.inc | 75 | ||||
-rw-r--r-- | includes/common.inc | 2 | ||||
-rw-r--r-- | includes/locale.inc | 5 | ||||
-rw-r--r-- | includes/menu.inc | 10 |
5 files changed, 74 insertions, 28 deletions
diff --git a/includes/bootstrap.inc b/includes/bootstrap.inc index e392c4f6e..49b7aa1f4 100644 --- a/includes/bootstrap.inc +++ b/includes/bootstrap.inc @@ -240,7 +240,7 @@ function drupal_get_filename($type, $name, $filename = NULL, $check_db = TRUE) { */ function variable_init($conf = array()) { // NOTE: caching the variables improves performance by 20% when serving cached pages. - if ($cached = cache_get('variables')) { + if ($cached = cache_get('variables', 'cache')) { $variables = unserialize($cached->data); } else { @@ -248,7 +248,7 @@ function variable_init($conf = array()) { while ($variable = db_fetch_object($result)) { $variables[$variable->name] = unserialize($variable->value); } - cache_set('variables', serialize($variables)); + cache_set('variables', 'cache', serialize($variables)); } foreach ($conf as $name => $value) { @@ -291,7 +291,7 @@ function variable_set($name, $value) { db_query("INSERT INTO {variable} (name, value) VALUES ('%s', '%s')", $name, serialize($value)); db_unlock_tables(); - cache_clear_all('variables'); + cache_clear_all('variables', 'cache'); $conf[$name] = $value; } @@ -306,7 +306,7 @@ function variable_del($name) { global $conf; db_query("DELETE FROM {variable} WHERE name = '%s'", $name); - cache_clear_all('variables'); + cache_clear_all('variables', 'cache'); unset($conf[$name]); } @@ -325,7 +325,7 @@ function page_get_cache() { $cache = NULL; if (!$user->uid && $_SERVER['REQUEST_METHOD'] == 'GET' && count(drupal_set_message()) == 0) { - $cache = cache_get($base_root . request_uri()); + $cache = cache_get($base_root . request_uri(), 'cache_page'); if (empty($cache)) { ob_start(); diff --git a/includes/cache.inc b/includes/cache.inc index 1559d3429..3b0b149ff 100644 --- a/includes/cache.inc +++ b/includes/cache.inc @@ -6,19 +6,22 @@ * * @param $key * The cache ID of the data to retrieve. + * @param $table + * The table $table to store the data in. Valid core values are 'cache_filter', + * 'cache_menu', 'cache_page', or 'cache' for the default cache. */ -function cache_get($key) { +function cache_get($key, $table = 'cache') { global $user; // Garbage collection necessary when enforcing a minimum cache lifetime $cache_flush = variable_get('cache_flush', 0); if ($cache_flush && ($cache_flush + variable_get('cache_lifetime', 0) <= time())) { // Time to flush old cache data - db_query("DELETE FROM {cache} WHERE expire != %d AND expire <= %d", CACHE_PERMANENT, $cache_flush); + db_query("DELETE FROM {%s} WHERE expire != %d AND expire <= %d", $table, CACHE_PERMANENT, $cache_flush); variable_set('cache_flush', 0); } - $cache = db_fetch_object(db_query("SELECT data, created, headers, expire FROM {cache} WHERE cid = '%s'", $key)); + $cache = db_fetch_object(db_query("SELECT data, created, headers, expire FROM {%s} WHERE cid = '%s'", $table, $key)); if (isset($cache->data)) { // If the data is permanent or we're not enforcing a minimum cache lifetime // always return the cached data. @@ -47,8 +50,33 @@ function cache_get($key) { /** * Store data in the persistent cache. * + * The persistent cache is split up into four database + * tables. Contributed modules can add additional tables. + * + * 'cache_page': This table stores generated pages for anonymous + * users. This is the only table affected by the page cache setting on + * the administrator panel. + * + * 'cache_menu': Stores the cachable part of the users' menus. + * + * 'cache_filter': Stores filtered pieces of content. This table is + * periodically cleared of stale entries by cron. + * + * 'cache': Generic cache storage table. + * + * The reasons for having several tables are as follows: + * + * - smaller tables allow for faster selects and inserts + * - we try to put fast changing cache items and rather static + * ones into different tables. The effect is that only the fast + * changing tables will need a lot of writes to disk. The more + * static tables will also be better cachable with MySQL's query cache + * * @param $cid * The cache ID of the data to store. + * @param $table + * The table $table to store the data in. Valid core values are 'cache_filter', + * 'cache_menu', 'cache_page', or 'cache'. * @param $data * The data to store in the cache. Complex data types must be serialized first. * @param $expire @@ -62,29 +90,41 @@ function cache_get($key) { * @param $headers * A string containing HTTP header information for cached pages. */ -function cache_set($cid, $data, $expire = CACHE_PERMANENT, $headers = NULL) { - db_lock_table('cache'); - db_query("UPDATE {cache} SET data = %b, created = %d, expire = %d, headers = '%s' WHERE cid = '%s'", $data, time(), $expire, $headers, $cid); +function cache_set($cid, $table = 'cache', $data, $expire = CACHE_PERMANENT, $headers = NULL) { + db_lock_table($table); + db_query("UPDATE {%s} SET data = '%s', created = %d, expire = %d, headers = '%s' WHERE cid = '%s'", $table, $data, time(), $expire, $headers, $cid); if (!db_affected_rows()) { - @db_query("INSERT INTO {cache} (cid, data, created, expire, headers) VALUES ('%s', %b, %d, %d, '%s')", $cid, $data, time(), $expire, $headers); + @db_query("INSERT INTO {%s} (cid, data, created, expire, headers) VALUES ('%s', '%s', %d, %d, '%s')", $table, $cid, $data, time(), $expire, $headers); } db_unlock_tables(); } /** - * Expire data from the cache. + * + * Expire data from the cache. If called without arguments, expirable + * entries will be cleared from the cache_page table. * * @param $cid * If set, the cache ID to delete. Otherwise, all cache entries that can * expire are deleted. * + * @param $table + * If set, the table $table to delete from. Mandatory + * argument if $cid is set. + * * @param $wildcard - * If set to TRUE, the $cid is treated as a substring to match rather than a - * complete ID. + * If set to TRUE, the $cid is treated as a substring + * to match rather than a complete ID. The match is a right hand + * match. If '*' is given as $cid, the table $table will be emptied. */ -function cache_clear_all($cid = NULL, $wildcard = FALSE) { +function cache_clear_all($cid = NULL, $table = NULL, $wildcard = FALSE) { global $user; + if (!isset($cid) && !isset($table)) { + cache_clear_all(NULL, 'cache_page'); + return; + } + if (empty($cid)) { if (variable_get('cache_lifetime', 0)) { // We store the time in the current user's $user->cache variable which @@ -101,21 +141,26 @@ function cache_clear_all($cid = NULL, $wildcard = FALSE) { else if (time() > ($cache_flush + variable_get('cache_lifetime', 0))) { // Clear the cache for everyone, cache_flush_delay seconds have // passed since the first request to clear the cache. - db_query("DELETE FROM {cache} WHERE expire != %d AND expire < %d", CACHE_PERMANENT, time()); + db_query("DELETE FROM {%s} WHERE expire != %d AND expire < %d", $table, CACHE_PERMANENT, time()); variable_set('cache_flush', 0); } } else { // No minimum cache lifetime, flush all temporary cache entries now. - db_query("DELETE FROM {cache} WHERE expire != %d AND expire < %d", CACHE_PERMANENT, time()); + db_query("DELETE FROM {%s} WHERE expire != %d AND expire < %d", $table, CACHE_PERMANENT, time()); } } else { if ($wildcard) { - db_query("DELETE FROM {cache} WHERE cid LIKE '%%%s%%'", $cid); + if ($cid == '*') { + db_query("TRUNCATE TABLE {%s}", $table); + } + else { + db_query("DELETE FROM {%s} WHERE cid LIKE '%s%%'", $table, $cid); + } } else { - db_query("DELETE FROM {cache} WHERE cid = '%s'", $cid); + db_query("DELETE FROM {%s} WHERE cid = '%s'", $table, $cid); } } } diff --git a/includes/common.inc b/includes/common.inc index 4ab0e2e57..90c620c63 100644 --- a/includes/common.inc +++ b/includes/common.inc @@ -1597,7 +1597,7 @@ function page_set_cache() { } ob_end_flush(); if ($cache && $data) { - cache_set($base_root . request_uri(), $data, CACHE_TEMPORARY, drupal_get_headers()); + cache_set($base_root . request_uri(), 'cache_page', $data, CACHE_TEMPORARY, drupal_get_headers()); } } } diff --git a/includes/locale.inc b/includes/locale.inc index 5c63c5443..0b2c5a333 100644 --- a/includes/locale.inc +++ b/includes/locale.inc @@ -119,7 +119,8 @@ function _locale_admin_manage_screen_submit($form_id, $form_values) { drupal_set_message(t('Configuration saved.')); // Changing the locale settings impacts the interface: - cache_clear_all(); + cache_clear_all('*', 'cache_menu', TRUE); + cache_clear_all('*', 'cache_page', TRUE); return 'admin/settings/locale/language/overview'; } @@ -486,7 +487,7 @@ function _locale_import_po($file, $lang, $mode) { } // rebuild locale cache - cache_clear_all("locale:$lang"); + cache_clear_all("locale:$lang", 'cache'); // rebuild the menu, strings may have changed menu_rebuild(); diff --git a/includes/menu.inc b/includes/menu.inc index e56698176..b7bf2930f 100644 --- a/includes/menu.inc +++ b/includes/menu.inc @@ -206,14 +206,14 @@ function menu_get_menu() { // _menu_build() may indirectly call this function, so prevent infinite loops. $_menu['items'] = array(); - $cid = "menu:$user->uid:$locale"; - if ($cached = cache_get($cid)) { + $cid = "$user->uid:$locale"; + if ($cached = cache_get($cid, 'cache_menu')) { $_menu = unserialize($cached->data); } else { _menu_build(); // Cache the menu structure for this user, to expire after one day. - cache_set($cid, serialize($_menu), time() + (60 * 60 * 24)); + cache_set($cid, 'cache_menu', serialize($_menu), time() + (60 * 60 * 24)); } // Make sure items that cannot be cached are added. @@ -585,9 +585,9 @@ function menu_in_active_trail_in_submenu($mid, $pid) { */ function menu_rebuild() { // Clear the page cache, so that changed menus are reflected for anonymous users. - cache_clear_all(); + cache_clear_all('*', 'cache_page', TRUE); // Also clear the menu cache. - cache_clear_all('menu:', TRUE); + cache_clear_all('*', 'cache_menu', TRUE); _menu_build(); |