123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228 |
- <?php
- namespace Doctrine\Common\Cache;
- use Riak\Bucket;
- use Riak\Exception;
- use Riak\Input;
- use Riak\Object;
- use function count;
- use function serialize;
- use function time;
- use function unserialize;
- /**
- * Riak cache provider.
- *
- * @link www.doctrine-project.org
- *
- * @deprecated
- */
- class RiakCache extends CacheProvider
- {
- public const EXPIRES_HEADER = 'X-Riak-Meta-Expires';
- /** @var Bucket */
- private $bucket;
- /**
- * Sets the riak bucket instance to use.
- */
- public function __construct(Bucket $bucket)
- {
- $this->bucket = $bucket;
- }
- /**
- * {@inheritdoc}
- */
- protected function doFetch($id)
- {
- try {
- $response = $this->bucket->get($id);
- // No objects found
- if (! $response->hasObject()) {
- return false;
- }
- // Check for attempted siblings
- $object = ($response->hasSiblings())
- ? $this->resolveConflict($id, $response->getVClock(), $response->getObjectList())
- : $response->getFirstObject();
- // Check for expired object
- if ($this->isExpired($object)) {
- $this->bucket->delete($object);
- return false;
- }
- return unserialize($object->getContent());
- } catch (Exception\RiakException $e) {
- // Covers:
- // - Riak\ConnectionException
- // - Riak\CommunicationException
- // - Riak\UnexpectedResponseException
- // - Riak\NotFoundException
- }
- return false;
- }
- /**
- * {@inheritdoc}
- */
- protected function doContains($id)
- {
- try {
- // We only need the HEAD, not the entire object
- $input = new Input\GetInput();
- $input->setReturnHead(true);
- $response = $this->bucket->get($id, $input);
- // No objects found
- if (! $response->hasObject()) {
- return false;
- }
- $object = $response->getFirstObject();
- // Check for expired object
- if ($this->isExpired($object)) {
- $this->bucket->delete($object);
- return false;
- }
- return true;
- } catch (Exception\RiakException $e) {
- // Do nothing
- }
- return false;
- }
- /**
- * {@inheritdoc}
- */
- protected function doSave($id, $data, $lifeTime = 0)
- {
- try {
- $object = new Object($id);
- $object->setContent(serialize($data));
- if ($lifeTime > 0) {
- $object->addMetadata(self::EXPIRES_HEADER, (string) (time() + $lifeTime));
- }
- $this->bucket->put($object);
- return true;
- } catch (Exception\RiakException $e) {
- // Do nothing
- }
- return false;
- }
- /**
- * {@inheritdoc}
- */
- protected function doDelete($id)
- {
- try {
- $this->bucket->delete($id);
- return true;
- } catch (Exception\BadArgumentsException $e) {
- // Key did not exist on cluster already
- } catch (Exception\RiakException $e) {
- // Covers:
- // - Riak\Exception\ConnectionException
- // - Riak\Exception\CommunicationException
- // - Riak\Exception\UnexpectedResponseException
- }
- return false;
- }
- /**
- * {@inheritdoc}
- */
- protected function doFlush()
- {
- try {
- $keyList = $this->bucket->getKeyList();
- foreach ($keyList as $key) {
- $this->bucket->delete($key);
- }
- return true;
- } catch (Exception\RiakException $e) {
- // Do nothing
- }
- return false;
- }
- /**
- * {@inheritdoc}
- */
- protected function doGetStats()
- {
- // Only exposed through HTTP stats API, not Protocol Buffers API
- return null;
- }
- /**
- * Check if a given Riak Object have expired.
- */
- private function isExpired(Object $object) : bool
- {
- $metadataMap = $object->getMetadataMap();
- return isset($metadataMap[self::EXPIRES_HEADER])
- && $metadataMap[self::EXPIRES_HEADER] < time();
- }
- /**
- * On-read conflict resolution. Applied approach here is last write wins.
- * Specific needs may override this method to apply alternate conflict resolutions.
- *
- * {@internal Riak does not attempt to resolve a write conflict, and store
- * it as sibling of conflicted one. By following this approach, it is up to
- * the next read to resolve the conflict. When this happens, your fetched
- * object will have a list of siblings (read as a list of objects).
- * In our specific case, we do not care about the intermediate ones since
- * they are all the same read from storage, and we do apply a last sibling
- * (last write) wins logic.
- * If by any means our resolution generates another conflict, it'll up to
- * next read to properly solve it.}
- *
- * @param string $id
- * @param string $vClock
- * @param array $objectList
- *
- * @return Object
- */
- protected function resolveConflict($id, $vClock, array $objectList)
- {
- // Our approach here is last-write wins
- $winner = $objectList[count($objectList) - 1];
- $putInput = new Input\PutInput();
- $putInput->setVClock($vClock);
- $mergedObject = new Object($id);
- $mergedObject->setContent($winner->getContent());
- $this->bucket->put($mergedObject, $putInput);
- return $mergedObject;
- }
- }
|