Cache/ApcStore.php at master · SugiPHP/Cache · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
<?php
/**
 * APC store.
 *
 * @package SugiPHP.Cache
 * @author  Plamen Popov <tzappa@gmail.com>
 * @license http://opensource.org/licenses/mit-license.php (MIT License)
 */

namespace SugiPHP\Cache;

class ApcStore implements StoreInterface, IncrementorInterface
{
    // for some optimization reasons in APC it does not invalidate
    // data on same request. @see https://bugs.php.net/bug.php?id=58084
    // To fix this behavior we'll use cache to store items along with timestamps
    public $ttlFix = false;

    protected $ttls = array();

    public function __construct(array $config = array())
    {
        // do we need a TTL fix
        // usually need to be set to true only for unit testing
        if (!empty($config["ttl_fix"])) {
            $this->ttlFix = true;
        }
    }

    /**
     * {@inheritdoc}
     */
    public function add($key, $value, $ttl = 0)
    {
        $res = apc_add($key, $value, $ttl);
        if ($this->ttlFix) {
            unset($this->ttls[$key]);
            // fixing ttl only if it is set
            if ($res && $ttl) {
                $this->ttls[$key] = microtime(true) + $ttl;
            }
        }
        return $res;
    }

    /**
     * {@inheritdoc}
     */
    public function set($key, $value, $ttl = 0)
    {
        $res = apc_store($key, $value, $ttl);
        if ($this->ttlFix) {
            unset($this->ttls[$key]);
            // fixing ttl only if it is set
            if ($res && $ttl) {
                $this->ttls[$key] = microtime(true) + $ttl;
            }
        }

        return $res;
    }

    /**
     * {@inheritdoc}
     */
    public function get($key)
    {
        $success = null;
        $result = apc_fetch($key, $success);

        if (!$success) {
            return null;
        }

        if ($this->ttlFix) {
            if (isset($this->ttls[$key]) && ($this->ttls[$key] < microtime(true))) {
                unset($this->ttls[$key]);
                return null;
            }
        }

        return $result;
    }

    /**
     * {@inheritdoc}
     */
    public function has($key)
    {
        if (!apc_exists($key)) {
            return false;
        }

        if ($this->ttlFix) {
            if (isset($this->ttls[$key]) && ($this->ttls[$key] < microtime(true))) {
                unset($this->ttls[$key]);
                return false;
            }
        }

        return true;
    }

    /**
     * {@inheritdoc}
     */
    public function delete($key)
    {
        if (apc_delete($key)) {
            if ($this->ttlFix) {
                unset($this->ttls[$key]);
            }
        }
    }

    /**
     * {@inheritdoc}
     */
    public function flush()
    {
        if (extension_loaded("apcu")) {
            apc_clear_cache();
        } else {
            apc_clear_cache("user");
        }
        if ($this->ttlFix) {
            unset($this->ttls);
        }
    }

    /**
     * {@inheritdoc}
     */
    public function inc($key, $step = 1)
    {
        return apc_inc($key, $step);
    }

    /**
     * {@inheritdoc}
     */
    public function dec($key, $step = 1)
    {
        return apc_dec($key, $step);
    }

    /**
     * Checks APC is running
     *
     * @return boolean
     */
    public function checkRunning()
    {
        return (function_exists("apc_store") && ini_get("apc.enabled")
                && ((PHP_SAPI != "cli") || ini_get("apc.enable_cli")));
    }
}