| | |
| | | */ |
| | | public function __construct($db, $config) |
| | | { |
| | | $this->db = $db; |
| | | $this->start = microtime(true); |
| | | $this->ip = $_SERVER['REMOTE_ADDR']; |
| | | $this->db = $db; |
| | | $this->start = microtime(true); |
| | | $this->ip = $_SERVER['REMOTE_ADDR']; |
| | | $this->logging = $config->get('log_session', false); |
| | | |
| | | $lifetime = $config->get('session_lifetime', 1) * 60; |
| | |
| | | public function db_read($key) |
| | | { |
| | | $sql_result = $this->db->query( |
| | | "SELECT vars, ip, changed FROM ".get_table_name('session')." WHERE sess_id = ?", |
| | | $key); |
| | | "SELECT vars, ip, changed FROM ".get_table_name('session') |
| | | ." WHERE sess_id = ?", $key); |
| | | |
| | | if ($sql_arr = $this->db->fetch_assoc($sql_result)) { |
| | | if ($sql_result && ($sql_arr = $this->db->fetch_assoc($sql_result))) { |
| | | $this->changed = strtotime($sql_arr['changed']); |
| | | $this->ip = $sql_arr['ip']; |
| | | $this->vars = base64_decode($sql_arr['vars']); |
| | |
| | | $ts = microtime(true); |
| | | $now = $this->db->fromunixtime((int)$ts); |
| | | |
| | | // no session row in DB (db_read() returns false) |
| | | if (!$this->key) { |
| | | $oldvars = false; |
| | | } |
| | | // use internal data from read() for fast requests (up to 0.5 sec.) |
| | | if ($key == $this->key && (!$this->vars || $ts - $this->start < 0.5)) { |
| | | else if ($key == $this->key && (!$this->vars || $ts - $this->start < 0.5)) { |
| | | $oldvars = $this->vars; |
| | | } else { // else read data again from DB |
| | | } |
| | | else { // else read data again from DB |
| | | $oldvars = $this->db_read($key); |
| | | } |
| | | |
| | |
| | | { |
| | | $ts = microtime(true); |
| | | |
| | | // no session data in cache (mc_read() returns false) |
| | | if (!$this->key) |
| | | $oldvars = false; |
| | | // use internal data for fast requests (up to 0.5 sec.) |
| | | if ($key == $this->key && (!$this->vars || $ts - $this->start < 0.5)) |
| | | else if ($key == $this->key && (!$this->vars || $ts - $this->start < 0.5)) |
| | | $oldvars = $this->vars; |
| | | else // else read data again |
| | | $oldvars = $this->mc_read($key); |
| | |
| | | { |
| | | foreach ($this->gc_handlers as $fct) |
| | | call_user_func($fct); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * Cleanup session data before saving |
| | | */ |
| | | public function cleanup() |
| | | { |
| | | // current compose information is stored in $_SESSION['compose'], move it to $_SESSION['compose_data'] |
| | | if ($_SESSION['compose']) { |
| | | $_SESSION['compose_data'][$_SESSION['compose']['id']] = $_SESSION['compose']; |
| | | $this->remove('compose'); |
| | | } |
| | | } |
| | | |
| | | |
| | |
| | | |
| | | |
| | | /** |
| | | * Re-read session data from storage backend |
| | | */ |
| | | public function reload() |
| | | { |
| | | if ($this->key && $this->memcache) |
| | | $data = $this->mc_read($this->key); |
| | | else if ($this->key) |
| | | $data = $this->db_read($this->key); |
| | | |
| | | if ($data) |
| | | session_decode($data); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * Serialize session data |
| | | */ |
| | | private function serialize($vars) |