cache_dir = $phpbb_root_path . 'cache/'; } /** * Load global cache */ function load() { global $phpEx; if (file_exists($this->cache_dir . 'data_global.' . $phpEx)) { include($this->cache_dir . 'data_global.' . $phpEx); } else { return false; } return true; } /** * Unload cache object */ function unload() { $this->save(); unset($this->vars); unset($this->var_expires); unset($this->sql_rowset); unset($this->sql_row_pointer); } /** * Save modified objects */ function save() { if (!$this->is_modified) { return; } global $phpEx; $file = "vars = " . $this->format_array($this->vars) . ";\n\n\$this->var_expires = " . $this->format_array($this->var_expires) . "\n?>"; if ($fp = @fopen($this->cache_dir . 'data_global.' . $phpEx, 'wb')) { @flock($fp, LOCK_EX); fwrite($fp, $file); @flock($fp, LOCK_UN); fclose($fp); } $this->is_modified = false; } /** * Tidy cache */ function tidy() { global $phpEx; $dir = opendir($this->cache_dir); while (($entry = readdir($dir)) !== false) { if (!preg_match('/^(sql_|data_(?!global))/', $entry)) { continue; } $expired = true; include($this->cache_dir . $entry); if ($expired) { @unlink($this->cache_dir . $entry); } } @closedir($dir); if (file_exists($this->cache_dir . 'data_global.' . $phpEx)) { if (!sizeof($this->vars)) { $this->load(); } foreach ($this->var_expires as $var_name => $expires) { if (time() > $expires) { $this->destroy($var_name); } } } set_config('cache_last_gc', time(), true); } /** * Get saved cache object */ function get($var_name) { if ($var_name{0} == '_') { global $phpEx; if (!$this->_exists($var_name)) { return false; } include($this->cache_dir . 'data' . $var_name . ".$phpEx"); return (isset($data)) ? $data : false; } else { return ($this->_exists($var_name)) ? $this->vars[$var_name] : false; } } /** * Put data into cache */ function put($var_name, $var, $ttl = 31536000) { if ($var_name{0} == '_') { global $phpEx; if ($fp = @fopen($this->cache_dir . 'data' . $var_name . ".$phpEx", 'wb')) { @flock($fp, LOCK_EX); fwrite($fp, " " . (time() + $ttl) . ") ? true : false;\nif (\$expired) { return; }\n\n\$data = unserialize('" . str_replace("'", "\\'", str_replace('\\', '\\\\', serialize($var))) . "');\n?>"); @flock($fp, LOCK_UN); fclose($fp); } } else { $this->vars[$var_name] = $var; $this->var_expires[$var_name] = time() + $ttl; $this->is_modified = true; } } /** * Purge cache data */ function purge() { // Purge sql data $dir = opendir($this->cache_dir); while (($entry = readdir($dir)) !== false) { if (strpos($entry, 'sql_') !== 0 && strpos($entry, 'data_') !== 0 && strpos($entry, 'ctpl_') !== 0 && strpos($entry, 'tpl_') !== 0) { continue; } @unlink($this->cache_dir . $entry); } @closedir($dir); unset($this->vars); unset($this->var_expires); unset($this->sql_rowset); unset($this->sql_row_pointer); $this->is_modified = false; } /** * Destroy cache data */ function destroy($var_name, $table = '') { global $phpEx; if ($var_name == 'sql' && !empty($table)) { $regex = '(' . ((is_array($table)) ? implode('|', $table) : $table) . ')'; $dir = opendir($this->cache_dir); while (($entry = readdir($dir)) !== false) { if (strpos($entry, 'sql_') !== 0) { continue; } $fp = fopen($this->cache_dir . $entry, 'rb'); $file = fread($fp, filesize($this->cache_dir . $entry)); @fclose($fp); if (preg_match('#/\*.*?\W' . $regex . '\W.*?\*/#s', $file, $m)) { @unlink($this->cache_dir . $entry); } } @closedir($dir); return; } if (!$this->_exists($var_name)) { return; } if ($var_name{0} == '_') { @unlink($this->cache_dir . 'data' . $var_name . ".$phpEx"); } else if (isset($this->vars[$var_name])) { $this->is_modified = true; unset($this->vars[$var_name]); unset($this->var_expires[$var_name]); // We save here to let the following cache hits succeed $this->save(); } } /** * Check if a given cache entry exist */ function _exists($var_name) { if ($var_name{0} == '_') { global $phpEx; return file_exists($this->cache_dir . 'data' . $var_name . ".$phpEx"); } else { if (!sizeof($this->vars)) { $this->load(); } if (!isset($this->var_expires[$var_name])) { return false; } return (time() > $this->var_expires[$var_name]) ? false : isset($this->vars[$var_name]); } } /** * Format an array to be stored on filesystem */ function format_array($array, $tab = '') { $tab .= "\t"; $lines = array(); foreach ($array as $k => $v) { if (is_array($v)) { $lines[] = "\n{$tab}'$k' => " . $this->format_array($v, $tab); } else if (is_int($v)) { $lines[] = "\n{$tab}'$k' => $v"; } else if (is_bool($v)) { $lines[] = "\n{$tab}'$k' => " . (($v) ? 'true' : 'false'); } else { $lines[] = "\n{$tab}'$k' => '" . str_replace("'", "\\'", str_replace('\\', '\\\\', $v)) . "'"; } } return 'array(' . implode(',', $lines) . ')'; } /** * Load cached sql query */ function sql_load($query) { global $phpEx; // Remove extra spaces and tabs $query = preg_replace('/[\n\r\s\t]+/', ' ', $query); $query_id = sizeof($this->sql_rowset); if (!file_exists($this->cache_dir . 'sql_' . md5($query) . ".$phpEx")) { return false; } @include($this->cache_dir . 'sql_' . md5($query) . ".$phpEx"); if (!isset($expired)) { return false; } else if ($expired) { @unlink($this->cache_dir . 'sql_' . md5($query) . ".$phpEx"); return false; } $this->sql_row_pointer[$query_id] = 0; return $query_id; } /** * Save sql query */ function sql_save($query, &$query_result, $ttl) { global $db, $phpEx; // Remove extra spaces and tabs $query = preg_replace('/[\n\r\s\t]+/', ' ', $query); if ($fp = @fopen($this->cache_dir . 'sql_' . md5($query) . '.' . $phpEx, 'wb')) { @flock($fp, LOCK_EX); $lines = array(); $query_id = sizeof($this->sql_rowset); $this->sql_rowset[$query_id] = array(); $this->sql_row_pointer[$query_id] = 0; while ($row = $db->sql_fetchrow($query_result)) { $this->sql_rowset[$query_id][] = $row; $lines[] = "unserialize('" . str_replace("'", "\\'", str_replace('\\', '\\\\', serialize($row))) . "')"; } $db->sql_freeresult($query_result); fwrite($fp, " " . (time() + $ttl) . ") ? true : false;\nif (\$expired) { return; }\n\n\$this->sql_rowset[\$query_id] = array(" . implode(',', $lines) . ') ?>'); @flock($fp, LOCK_UN); fclose($fp); $query_result = $query_id; } } /** * Ceck if a given sql query exist in cache */ function sql_exists($query_id) { return isset($this->sql_rowset[$query_id]); } /** * Fetch row from cache (database) */ function sql_fetchrow($query_id) { if ($this->sql_row_pointer[$query_id] < sizeof($this->sql_rowset[$query_id])) { return $this->sql_rowset[$query_id][$this->sql_row_pointer[$query_id]++]; } return false; } /** * Fetch the number of rows from cache (database) */ function sql_numrows($query_id) { return sizeof($this->sql_rowset[$query_id]); } /** * Fetch a field from the current row of a cached database result (database) */ function sql_fetchfield($query_id, $field) { if ($this->sql_row_pointer[$query_id] < sizeof($this->sql_rowset[$query_id])) { return (isset($this->sql_rowset[$query_id][$this->sql_row_pointer[$query_id]][$field])) ? $this->sql_rowset[$query_id][$this->sql_row_pointer[$query_id]][$field] : false; } return false; } /** * Seek a specific row in an a cached database result (database) */ function sql_rowseek($query_id, $rownum) { if ($rownum >= sizeof($this->sql_rowset[$query_id])) { return false; } $this->sql_row_pointer[$query_id] = $rownum; return true; } /** * Free memory used for a cached database result (database) */ function sql_freeresult($query_id) { if (!isset($this->sql_rowset[$query_id])) { return false; } unset($this->sql_rowset[$query_id]); unset($this->sql_row_pointer[$query_id]); return true; } } ?>