|
MediaWiki REL1_39
|
memcached client class implemented using (p)fsockopen() More...


Public Member Functions | |
| __construct ( $args) | |
| Memcache initializer. | |
| _close_sock ( $sock) | |
| Close the specified socket. | |
| _connect_sock (&$sock, $host) | |
| Connects $sock to $host, timing out after $timeout. | |
| _dead_host ( $host) | |
| _dead_sock ( $sock) | |
| Marks a host as dead until 30-40 seconds in the future. | |
| _debugprint ( $text) | |
| _error_log ( $text) | |
| _fgets ( $sock) | |
| Read a line from a stream. | |
| _flush_read_buffer ( $f) | |
| Flush the read buffer of a stream. | |
| _fread ( $sock, $len) | |
| Read the specified number of bytes from a stream. | |
| _fwrite ( $sock, $buf) | |
| Write to a stream. | |
| _handle_error ( $sock, $msg) | |
| Handle an I/O error. | |
| _hashfunc ( $key) | |
| Creates a hash integer based on the $key. | |
| _incrdecr ( $cmd, $key, $amt=1) | |
| Perform increment/decrement on $key. | |
| _load_items ( $sock, &$ret, &$casToken=null) | |
| Load items into $ret from $sock. | |
| _set ( $cmd, $key, $val, $exp, $casToken=null) | |
| Performs the requested storage operation to the memcache server. | |
| add ( $key, $val, $exp=0) | |
| Adds a key/value to the memcache server if one isn't already set with that key. | |
| cas ( $casToken, $key, $value, $exp=0) | |
| Sets a key to a given value in the memcache if the current value still corresponds to a known, given value. | |
| decr ( $key, $amt=1) | |
| Decrease a value stored on the memcache server. | |
| delete ( $key, $time=0) | |
| Deletes a key from the server, optionally after $time. | |
| disconnect_all () | |
| Disconnects all connected sockets. | |
| enable_compress ( $enable) | |
| Enable / Disable compression. | |
| forget_dead_hosts () | |
| Forget about all of the dead hosts. | |
| get ( $key, &$casToken=null) | |
| Retrieves the value associated with the key from the memcache server. | |
| get_multi ( $keys) | |
| Get multiple keys from the server(s) | |
| get_sock ( $key) | |
| get_sock | |
| incr ( $key, $amt=1) | |
| Increments $key (optionally) by $amt. | |
| replace ( $key, $value, $exp=0) | |
| Overwrites an existing value for key; only works if key is already set. | |
| run_command ( $sock, $cmd) | |
| Passes through $cmd to the memcache server connected by $sock; returns output as an array (null array if no output) | |
| serialize ( $value) | |
| set ( $key, $value, $exp=0) | |
| Unconditionally sets a key to a given value in the memcache. | |
| set_compress_threshold ( $thresh) | |
| Set the compression threshold. | |
| set_debug ( $dbg) | |
| Set the debug flag. | |
| set_servers ( $list) | |
| Set the server list to distribute key gets and puts between. | |
| set_timeout ( $seconds, $microseconds) | |
| Sets the timeout for new connections. | |
| sock_to_host ( $host) | |
| Returns the socket for the host. | |
| touch ( $key, $time=0) | |
| Changes the TTL on a key from the server to $time. | |
| unserialize ( $value) | |
Public Attributes | |
| int | $_active |
| int | $_bucketcount |
| Total # of bit buckets we have. | |
| array | $_buckets |
| Our bit buckets. | |
| array | $_cache_sock |
| Cached Sockets that are connected. | |
| bool | $_compress_enable |
| Do we want to use compression? | |
| int | $_compress_threshold |
| At how many bytes should we compress? | |
| $_connect_attempts | |
| Number of connection attempts for each server. | |
| $_connect_timeout | |
| Connect timeout in seconds. | |
| bool | $_debug |
| Current debug status; 0 - none to 9 - profiling. | |
| bool | $_have_zlib |
| Is compression available? | |
| array | $_host_dead |
| Dead hosts, assoc array, 'host'=>'unixtime when ok to check again'. | |
| int | $_last_cmd_status = self::ERR_NONE |
| StorageAwareness:ERR_* constant of the last cache command. | |
| bool | $_persistent |
| Are we using persistent links? | |
| array | $_servers |
| Array containing ip:port or array(ip:port, weight) | |
| string | $_single_sock |
| If only using one server; contains ip:port to connect to. | |
| int | $_timeout_microseconds |
| Stream timeout in microseconds. | |
| int | $_timeout_seconds |
| Stream timeout in seconds. | |
| array | $stats |
| Command statistics. | |
| const | COMPRESSED = 2 |
| Flag: indicates data is compressed. | |
| const | COMPRESSION_SAVINGS = 0.20 |
| Minimum savings to store data compressed. | |
| const | INTVAL = 4 |
| Flag: indicates data is an integer. | |
| const | SERIALIZED = 1 |
| Flag: indicates data is serialized. | |
Public Attributes inherited from Wikimedia\LightweightObjectStore\StorageAwareness | |
| const | ATTR_DURABILITY = 2 |
| Durability of writes; see QOS_DURABILITY_* (higher means stronger) | |
| const | ATTR_EMULATION = 1 |
| Emulation/fallback mode; see QOS_EMULATION_*; higher is better. | |
| const | ERR_NO_RESPONSE = 1 |
| Storage medium failed to yield a complete response to an operation. | |
| const | ERR_NONE = 0 |
| No storage medium error. | |
| const | ERR_UNEXPECTED = 3 |
| Storage medium operation failed due to usage limitations or an I/O error. | |
| const | ERR_UNREACHABLE = 2 |
| Storage medium could not be reached to establish a connection. | |
| const | QOS_DURABILITY_DISK = 4 |
| Data is saved to disk and writes do not usually block on fsync() | |
| const | QOS_DURABILITY_NONE = 1 |
| Data is never saved to begin with (blackhole store) | |
| const | QOS_DURABILITY_RDBMS = 5 |
| Data is saved to disk and writes usually block on fsync(), like a standard RDBMS. | |
| const | QOS_DURABILITY_SCRIPT = 2 |
| Data is lost at the end of the current web request or CLI script. | |
| const | QOS_DURABILITY_SERVICE = 3 |
| Data is lost once the service storing the data restarts. | |
| const | QOS_EMULATION_SQL = 1 |
| Fallback disk-based SQL store. | |
| const | QOS_UNKNOWN = INF |
| Generic "unknown" value; useful for comparisons (always "good enough") | |
memcached client class implemented using (p)fsockopen()
Definition at line 82 of file MemcachedClient.php.
| MemcachedClient::__construct | ( | $args | ) |
Memcache initializer.
| array | $args | Associative array of settings |
Definition at line 266 of file MemcachedClient.php.
References $args, and set_servers().
| MemcachedClient::_close_sock | ( | $sock | ) |
Close the specified socket.
| string | $sock | Socket to close |
Definition at line 806 of file MemcachedClient.php.
| MemcachedClient::_connect_sock | ( | & | $sock, |
| $host ) |
Connects $sock to $host, timing out after $timeout.
| int | $sock | Socket to connect |
| string | $host | Host:IP to connect to |
Definition at line 824 of file MemcachedClient.php.
References $_connect_attempts, $_connect_timeout, _dead_host(), _error_log(), and _flush_read_buffer().
Referenced by sock_to_host().
| MemcachedClient::_dead_host | ( | $host | ) |
| string | $host |
Definition at line 882 of file MemcachedClient.php.
Referenced by _connect_sock(), and _dead_sock().
| MemcachedClient::_dead_sock | ( | $sock | ) |
Marks a host as dead until 30-40 seconds in the future.
| string | $sock | Socket to mark as dead |
Definition at line 874 of file MemcachedClient.php.
References _dead_host().
Referenced by _handle_error().
| MemcachedClient::_debugprint | ( | $text | ) |
| string | $text |
Definition at line 1245 of file MemcachedClient.php.
Referenced by _incrdecr(), _set(), delete(), get(), get_multi(), and touch().
| MemcachedClient::_error_log | ( | $text | ) |
| string | $text |
Definition at line 1252 of file MemcachedClient.php.
Referenced by _connect_sock(), and _handle_error().
| MemcachedClient::_fgets | ( | $sock | ) |
Read a line from a stream.
If there is an error, mark the socket dead. The \r\n line ending is stripped from the response.
| Resource | $sock | The socket |
Definition at line 1342 of file MemcachedClient.php.
References _handle_error().
Referenced by _incrdecr(), _load_items(), _set(), delete(), run_command(), and touch().
| MemcachedClient::_flush_read_buffer | ( | $f | ) |
Flush the read buffer of a stream.
| Resource | $f |
Definition at line 1371 of file MemcachedClient.php.
Referenced by _connect_sock().
| MemcachedClient::_fread | ( | $sock, | |
| $len ) |
Read the specified number of bytes from a stream.
If there is an error, mark the socket dead.
| Resource | $sock | The socket |
| int | $len | The number of bytes to read |
Definition at line 1311 of file MemcachedClient.php.
References _handle_error().
Referenced by _load_items().
| MemcachedClient::_fwrite | ( | $sock, | |
| $buf ) |
Write to a stream.
If there is an error, mark the socket dead.
| Resource | $sock | The socket |
| string | $buf | The string to write |
Definition at line 1263 of file MemcachedClient.php.
References _handle_error().
Referenced by _incrdecr(), _set(), delete(), get(), get_multi(), run_command(), and touch().
| MemcachedClient::_handle_error | ( | $sock, | |
| $msg ) |
Handle an I/O error.
Mark the socket dead and log an error.
| Resource | $sock | |
| string | $msg |
Definition at line 1290 of file MemcachedClient.php.
References _dead_sock(), and _error_log().
Referenced by _fgets(), _fread(), _fwrite(), and _load_items().
| MemcachedClient::_hashfunc | ( | $key | ) |
Creates a hash integer based on the $key.
| string | $key | Key to hash |
Definition at line 954 of file MemcachedClient.php.
Referenced by get_sock().
| MemcachedClient::_incrdecr | ( | $cmd, | |
| $key, | |||
| $amt = 1 ) |
Perform increment/decrement on $key.
| string | $cmd | Command to perform |
| string | array | $key | Key to perform it on |
| int | $amt | Amount to adjust |
Definition at line 974 of file MemcachedClient.php.
References $line, _debugprint(), _fgets(), _fwrite(), Wikimedia\LightweightObjectStore\StorageAwareness\ERR_NO_RESPONSE, Wikimedia\LightweightObjectStore\StorageAwareness\ERR_NONE, Wikimedia\LightweightObjectStore\StorageAwareness\ERR_UNEXPECTED, Wikimedia\LightweightObjectStore\StorageAwareness\ERR_UNREACHABLE, and get_sock().
| MemcachedClient::_load_items | ( | $sock, | |
| & | $ret, | ||
| & | $casToken = null ) |
Load items into $ret from $sock.
| Resource | $sock | Socket to read from |
| array | $ret | returned values |
| float | $casToken | [optional] |
Definition at line 1030 of file MemcachedClient.php.
References _fgets(), _fread(), _handle_error(), and unserialize().
Referenced by get(), and get_multi().
| MemcachedClient::_set | ( | $cmd, | |
| $key, | |||
| $val, | |||
| $exp, | |||
| $casToken = null ) |
Performs the requested storage operation to the memcache server.
| string | $cmd | Command to perform |
| string | $key | Key to act on |
| mixed | $val | What we need to store |
| int | $exp | (optional) Expiration time. This can be a number of seconds to cache for (up to 30 days inclusive). Any timespans of 30 days + 1 second or longer must be the timestamp of the time at which the mapping should expire. It is safe to use timestamps in all cases, regardless of expiration eg: strtotime("+3 hour") |
| float | $casToken | [optional] |
Definition at line 1118 of file MemcachedClient.php.
References $command, $line, _debugprint(), _fgets(), _fwrite(), COMPRESSED, Wikimedia\LightweightObjectStore\StorageAwareness\ERR_NO_RESPONSE, Wikimedia\LightweightObjectStore\StorageAwareness\ERR_NONE, Wikimedia\LightweightObjectStore\StorageAwareness\ERR_UNEXPECTED, Wikimedia\LightweightObjectStore\StorageAwareness\ERR_UNREACHABLE, get_sock(), INTVAL, serialize(), and SERIALIZED.
| MemcachedClient::add | ( | $key, | |
| $val, | |||
| $exp = 0 ) |
Adds a key/value to the memcache server if one isn't already set with that key.
| string | $key | Key to set with data |
| mixed | $val | Value to store |
| int | $exp | (optional) Expiration time. This can be a number of seconds to cache for (up to 30 days inclusive). Any timespans of 30 days + 1 second or longer must be the timestamp of the time at which the mapping should expire. It is safe to use timestamps in all cases, regardless of expiration eg: strtotime("+3 hour") |
Definition at line 321 of file MemcachedClient.php.
References _set(), and Wikimedia\LightweightObjectStore\StorageAwareness\ERR_NONE.
| MemcachedClient::cas | ( | $casToken, | |
| $key, | |||
| $value, | |||
| $exp = 0 ) |
Sets a key to a given value in the memcache if the current value still corresponds to a known, given value.
Returns true if set successfully.
| float | $casToken | Current known value |
| string | $key | Key to set value as |
| mixed | $value | Value to set |
| int | $exp | (optional) Expiration time. This can be a number of seconds to cache for (up to 30 days inclusive). Any timespans of 30 days + 1 second or longer must be the timestamp of the time at which the mapping should expire. It is safe to use timestamps in all cases, regardless of expiration eg: strtotime("+3 hour") |
Definition at line 733 of file MemcachedClient.php.
References _set().
| MemcachedClient::decr | ( | $key, | |
| $amt = 1 ) |
Decrease a value stored on the memcache server.
| string | $key | Key to decrease |
| int | $amt | (optional) amount to decrease |
Definition at line 338 of file MemcachedClient.php.
References _incrdecr(), and Wikimedia\LightweightObjectStore\StorageAwareness\ERR_NONE.
| MemcachedClient::delete | ( | $key, | |
| $time = 0 ) |
Deletes a key from the server, optionally after $time.
| string | $key | Key to delete |
| int | $time | (optional) how long to wait before deleting |
Definition at line 355 of file MemcachedClient.php.
References $res, _debugprint(), _fgets(), _fwrite(), Wikimedia\LightweightObjectStore\StorageAwareness\ERR_NONE, Wikimedia\LightweightObjectStore\StorageAwareness\ERR_UNEXPECTED, and get_sock().
| MemcachedClient::disconnect_all | ( | ) |
Disconnects all connected sockets.
Definition at line 443 of file MemcachedClient.php.
| MemcachedClient::enable_compress | ( | $enable | ) |
Enable / Disable compression.
| bool | $enable | True to enable, false to disable |
Definition at line 459 of file MemcachedClient.php.
| MemcachedClient::forget_dead_hosts | ( | ) |
Forget about all of the dead hosts.
Definition at line 469 of file MemcachedClient.php.
| MemcachedClient::get | ( | $key, | |
| & | $casToken = null ) |
Retrieves the value associated with the key from the memcache server.
| array | string | $key | key to retrieve |
| float | $casToken | [optional] |
Definition at line 484 of file MemcachedClient.php.
References _debugprint(), _fwrite(), _load_items(), Wikimedia\LightweightObjectStore\StorageAwareness\ERR_NO_RESPONSE, Wikimedia\LightweightObjectStore\StorageAwareness\ERR_NONE, Wikimedia\LightweightObjectStore\StorageAwareness\ERR_UNEXPECTED, Wikimedia\LightweightObjectStore\StorageAwareness\ERR_UNREACHABLE, get_sock(), and serialize().
| MemcachedClient::get_multi | ( | $keys | ) |
Get multiple keys from the server(s)
| array | $keys | Keys to retrieve |
Definition at line 557 of file MemcachedClient.php.
References $keys, _debugprint(), _fwrite(), _load_items(), Wikimedia\LightweightObjectStore\StorageAwareness\ERR_NO_RESPONSE, Wikimedia\LightweightObjectStore\StorageAwareness\ERR_NONE, Wikimedia\LightweightObjectStore\StorageAwareness\ERR_UNEXPECTED, Wikimedia\LightweightObjectStore\StorageAwareness\ERR_UNREACHABLE, and get_sock().
| MemcachedClient::get_sock | ( | $key | ) |
get_sock
| string | $key | Key to retrieve value for; |
Definition at line 905 of file MemcachedClient.php.
References $_bucketcount, _hashfunc(), and sock_to_host().
Referenced by _incrdecr(), _set(), delete(), get(), get_multi(), and touch().
| MemcachedClient::incr | ( | $key, | |
| $amt = 1 ) |
Increments $key (optionally) by $amt.
| string | $key | Key to increment |
| int | $amt | (optional) amount to increment |
Definition at line 635 of file MemcachedClient.php.
References _incrdecr().
| MemcachedClient::replace | ( | $key, | |
| $value, | |||
| $exp = 0 ) |
Overwrites an existing value for key; only works if key is already set.
| string | $key | Key to set value as |
| mixed | $value | Value to store |
| int | $exp | (optional) Expiration time. This can be a number of seconds to cache for (up to 30 days inclusive). Any timespans of 30 days + 1 second or longer must be the timestamp of the time at which the mapping should expire. It is safe to use timestamps in all cases, regardless of expiration eg: strtotime("+3 hour") |
Definition at line 655 of file MemcachedClient.php.
References _set().
| MemcachedClient::run_command | ( | $sock, | |
| $cmd ) |
Passes through $cmd to the memcache server connected by $sock; returns output as an array (null array if no output)
| Resource | $sock | Socket to send command on |
| string | $cmd | Command to run |
Definition at line 671 of file MemcachedClient.php.
| MemcachedClient::serialize | ( | $value | ) |
| mixed | $value |
Definition at line 293 of file MemcachedClient.php.
References serialize().
| MemcachedClient::set | ( | $key, | |
| $value, | |||
| $exp = 0 ) |
Unconditionally sets a key to a given value in the memcache.
Returns true if set successfully.
| string | $key | Key to set value as |
| mixed | $value | Value to set |
| int | $exp | (optional) Expiration time. This can be a number of seconds to cache for (up to 30 days inclusive). Any timespans of 30 days + 1 second or longer must be the timestamp of the time at which the mapping should expire. It is safe to use timestamps in all cases, regardless of expiration eg: strtotime("+3 hour") |
Definition at line 711 of file MemcachedClient.php.
References _set().
| MemcachedClient::set_compress_threshold | ( | $thresh | ) |
Set the compression threshold.
| int | $thresh | Threshold to compress if larger than |
Definition at line 745 of file MemcachedClient.php.
| MemcachedClient::set_debug | ( | $dbg | ) |
Set the debug flag.
| bool | $dbg | True for debugging, false otherwise |
Definition at line 758 of file MemcachedClient.php.
| MemcachedClient::set_servers | ( | $list | ) |
Set the server list to distribute key gets and puts between.
| array | $list | Array of servers to connect to |
Definition at line 771 of file MemcachedClient.php.
Referenced by __construct().
| MemcachedClient::set_timeout | ( | $seconds, | |
| $microseconds ) |
Sets the timeout for new connections.
| int | $seconds | Number of seconds |
| int | $microseconds | Number of microseconds |
Definition at line 789 of file MemcachedClient.php.
| MemcachedClient::sock_to_host | ( | $host | ) |
Returns the socket for the host.
| string | $host | Host:IP to get socket for |
Definition at line 1211 of file MemcachedClient.php.
References _connect_sock().
Referenced by get_sock().
| MemcachedClient::touch | ( | $key, | |
| $time = 0 ) |
Changes the TTL on a key from the server to $time.
| string | $key | |
| int | $time | TTL in seconds |
Definition at line 401 of file MemcachedClient.php.
References $res, _debugprint(), _fgets(), _fwrite(), Wikimedia\LightweightObjectStore\StorageAwareness\ERR_NONE, and get_sock().
| MemcachedClient::unserialize | ( | $value | ) |
| string | $value |
Definition at line 301 of file MemcachedClient.php.
References unserialize().
Referenced by _load_items(), and unserialize().
| int MemcachedClient::$_active |
| int MemcachedClient::$_bucketcount |
Total # of bit buckets we have.
Definition at line 210 of file MemcachedClient.php.
Referenced by get_sock().
| array MemcachedClient::$_buckets |
| array MemcachedClient::$_cache_sock |
Cached Sockets that are connected.
Definition at line 130 of file MemcachedClient.php.
| bool MemcachedClient::$_compress_enable |
| int MemcachedClient::$_compress_threshold |
At how many bytes should we compress?
Definition at line 170 of file MemcachedClient.php.
| MemcachedClient::$_connect_attempts |
Number of connection attempts for each server.
Definition at line 244 of file MemcachedClient.php.
Referenced by _connect_sock().
| MemcachedClient::$_connect_timeout |
Connect timeout in seconds.
Definition at line 239 of file MemcachedClient.php.
Referenced by _connect_sock().
| bool MemcachedClient::$_debug |
Current debug status; 0 - none to 9 - profiling.
Definition at line 138 of file MemcachedClient.php.
| bool MemcachedClient::$_have_zlib |
| array MemcachedClient::$_host_dead |
Dead hosts, assoc array, 'host'=>'unixtime when ok to check again'.
Definition at line 146 of file MemcachedClient.php.
| int MemcachedClient::$_last_cmd_status = self::ERR_NONE |
StorageAwareness:ERR_* constant of the last cache command.
Definition at line 247 of file MemcachedClient.php.
| bool MemcachedClient::$_persistent |
| array MemcachedClient::$_servers |
Array containing ip:port or array(ip:port, weight)
Definition at line 194 of file MemcachedClient.php.
| string MemcachedClient::$_single_sock |
If only using one server; contains ip:port to connect to.
Definition at line 186 of file MemcachedClient.php.
| int MemcachedClient::$_timeout_microseconds |
| int MemcachedClient::$_timeout_seconds |
Stream timeout in seconds.
Applies for example to fread()
Definition at line 226 of file MemcachedClient.php.
| array MemcachedClient::$stats |
| const MemcachedClient::COMPRESSED = 2 |
Flag: indicates data is compressed.
Definition at line 97 of file MemcachedClient.php.
Referenced by _set().
| const MemcachedClient::COMPRESSION_SAVINGS = 0.20 |
Minimum savings to store data compressed.
Definition at line 109 of file MemcachedClient.php.
| const MemcachedClient::INTVAL = 4 |
Flag: indicates data is an integer.
Definition at line 102 of file MemcachedClient.php.
Referenced by _set().
| const MemcachedClient::SERIALIZED = 1 |
Flag: indicates data is serialized.
Definition at line 92 of file MemcachedClient.php.
Referenced by _set().