Simplified code + some CS fixes
| | |
| | | // to have data in consistent state. Keeping the index consistent |
| | | // is needed for keys delete operation when we delete all keys or by prefix. |
| | | } |
| | | else if ($this->type == 'memcache') { |
| | | else { |
| | | $ckey = $this->ckey($key); |
| | | |
| | | if ($this->type == 'memcache') { |
| | | $data = $this->db->get($ckey); |
| | | } |
| | | else if ($this->type == 'apc') { |
| | | $data = apc_fetch($ckey); |
| | | } |
| | | |
| | | if ($this->debug) { |
| | | $this->debug('get', $ckey, $data); |
| | | } |
| | | } |
| | | else if ($this->type == 'apc') { |
| | | $ckey = $this->ckey($key); |
| | | $data = apc_fetch($ckey); |
| | | |
| | | if ($this->debug) { |
| | | $this->debug('fetch', $ckey, $data); |
| | | } |
| | | } |
| | | |
| | |
| | | { |
| | | if ($this->type == 'memcache') { |
| | | $result = $this->db->replace($key, $data, MEMCACHE_COMPRESSED, $this->ttl); |
| | | if (!$result) |
| | | $result = $this->db->set($key, $data, MEMCACHE_COMPRESSED, $this->ttl); |
| | | |
| | | if ($this->debug) { |
| | | $this->debug('set', $key, $data, $result); |
| | | if (!$result) { |
| | | $result = $this->db->set($key, $data, MEMCACHE_COMPRESSED, $this->ttl); |
| | | } |
| | | } |
| | | else if ($this->type == 'apc') { |
| | | if (apc_exists($key)) |
| | | if (apc_exists($key)) { |
| | | apc_delete($key); |
| | | } |
| | | |
| | | $result = apc_store($key, $data, $this->ttl); |
| | | } |
| | | |
| | | if ($this->debug) { |
| | | $this->debug('store', $key, $data, $result); |
| | | } |
| | | $this->debug('set', $key, $data, $result); |
| | | } |
| | | |
| | | if ($result) { |
| | |
| | | */ |
| | | private function delete_record($key, $index=true) |
| | | { |
| | | if ($this->type == 'memcache') { |
| | | $ckey = $this->ckey($key); |
| | | |
| | | if ($this->type == 'memcache') { |
| | | // #1488592: use 2nd argument |
| | | $result = $this->db->delete($ckey, 0); |
| | | |
| | | if ($this->debug) { |
| | | $this->debug('delete', $ckey, null, $result); |
| | | } |
| | | } |
| | | else { |
| | | $ckey = $this->ckey($key); |
| | | $result = apc_delete($ckey); |
| | | } |
| | | |
| | | if ($this->debug) { |
| | | $this->debug('delete', $ckey, null, $result); |
| | | } |
| | | } |
| | | |
| | | if ($result) { |
| | |
| | | */ |
| | | private function write_index() |
| | | { |
| | | if (!$this->db) { |
| | | return; |
| | | } |
| | | |
| | | if ($this->type == 'db') { |
| | | if (!$this->db || $this->type == 'db') { |
| | | return; |
| | | } |
| | | |
| | |
| | | */ |
| | | private function load_index() |
| | | { |
| | | if (!$this->db) { |
| | | if (!$this->db || $this->type == 'db') { |
| | | return; |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | $index_key = $this->ikey(); |
| | | |
| | | if ($this->type == 'memcache') { |
| | | $data = $this->db->get($index_key); |
| | | |
| | | if ($this->debug) { |
| | | $this->debug('get', $index_key, $data); |
| | | } |
| | | } |
| | | else if ($this->type == 'apc') { |
| | | $data = apc_fetch($index_key); |
| | | } |
| | | |
| | | if ($this->debug) { |
| | | $this->debug('fetch', $index_key, $data); |
| | | } |
| | | $this->debug('get', $index_key, $data); |
| | | } |
| | | |
| | | $this->index = $data ? unserialize($data) : array(); |
| | |
| | | // to have data in consistent state. Keeping the index consistent |
| | | // is needed for keys delete operation when we delete all keys or by prefix. |
| | | } |
| | | else if ($this->type == 'memcache') { |
| | | else { |
| | | $ckey = $this->ckey($key); |
| | | |
| | | if ($this->type == 'memcache') { |
| | | $data = $this->db->get($ckey); |
| | | } |
| | | else if ($this->type == 'apc') { |
| | | $data = apc_fetch($ckey); |
| | | } |
| | | |
| | | if ($this->debug) { |
| | | $this->debug('get', $ckey, $data); |
| | | } |
| | | } |
| | | else if ($this->type == 'apc') { |
| | | $ckey = $this->ckey($key); |
| | | $data = apc_fetch($ckey); |
| | | |
| | | if ($this->debug) { |
| | | $this->debug('fetch', $ckey, $data); |
| | | } |
| | | } |
| | | |
| | |
| | | { |
| | | if ($this->type == 'memcache') { |
| | | $result = $this->db->replace($key, $data, MEMCACHE_COMPRESSED, $this->ttl); |
| | | |
| | | if (!$result) { |
| | | $result = $this->db->set($key, $data, MEMCACHE_COMPRESSED, $this->ttl); |
| | | } |
| | | if ($this->debug) { |
| | | $this->debug('set', $key, $data, $result); |
| | | } |
| | | } |
| | | else if ($this->type == 'apc') { |
| | | if (apc_exists($key)) { |
| | | apc_delete($key); |
| | | } |
| | | |
| | | $result = apc_store($key, $data, $this->ttl); |
| | | } |
| | | |
| | | if ($this->debug) { |
| | | $this->debug('store', $key, $data, $result); |
| | | } |
| | | $this->debug('set', $key, $data, $result); |
| | | } |
| | | |
| | | if ($result) { |
| | |
| | | */ |
| | | private function delete_record($key, $index=true) |
| | | { |
| | | if ($this->type == 'memcache') { |
| | | $ckey = $this->ckey($key); |
| | | |
| | | if ($this->type == 'memcache') { |
| | | // #1488592: use 2nd argument |
| | | $result = $this->db->delete($ckey, 0); |
| | | |
| | | if ($this->debug) { |
| | | $this->debug('delete', $ckey, null, $result); |
| | | } |
| | | } |
| | | else { |
| | | $ckey = $this->ckey($key); |
| | | $result = apc_delete($ckey); |
| | | } |
| | | |
| | | if ($this->debug) { |
| | | $this->debug('delete', $ckey, null, $result); |
| | | } |
| | | } |
| | | |
| | | if ($result) { |
| | |
| | | */ |
| | | private function write_index() |
| | | { |
| | | if (!$this->db) { |
| | | return; |
| | | } |
| | | |
| | | if ($this->type == 'db') { |
| | | if (!$this->db || $this->type == 'db') { |
| | | return; |
| | | } |
| | | |
| | |
| | | */ |
| | | private function load_index() |
| | | { |
| | | if (!$this->db) { |
| | | if (!$this->db || $this->type == 'db') { |
| | | return; |
| | | } |
| | | |
| | |
| | | |
| | | if ($this->type == 'memcache') { |
| | | $data = $this->db->get($index_key); |
| | | |
| | | if ($this->debug) { |
| | | $this->debug('get', $index_key, $data); |
| | | } |
| | | } |
| | | else if ($this->type == 'apc') { |
| | | $data = apc_fetch($index_key); |
| | | } |
| | | |
| | | if ($this->debug) { |
| | | $this->debug('fetch', $index_key, $data); |
| | | } |
| | | $this->debug('get', $index_key, $data); |
| | | } |
| | | |
| | | $this->index = $data ? unserialize($data) : array(); |