FM / DynamoDb

/home/techb158/immovalet.com/vendor/aws/aws-sdk-php/src/DynamoDb/

/home/techb158/immovalet.com/vendor/aws/aws-sdk-php/src/DynamoDb

Name	Size	Mode	Actions
Exception/	-	0755	rm
BinaryValue.php	714	0644	edit dl rm
DynamoDbClient.php	12439	0644	edit dl rm
LockingSessionConnection.php	1932	0644	edit dl rm
Marshaler.php	9744	0644	edit dl rm
NumberValue.php	523	0644	edit dl rm
SessionConnectionConfigTrait.php	5992	0644	edit dl rm
SessionConnectionInterface.php	1017	0644	edit dl rm
SessionHandler.php	7854	0644	edit dl rm
SetValue.php	838	0644	edit dl rm
StandardSessionConnection.php	4572	0644	edit dl rm
WriteRequestBatch.php	9563	0644	edit dl rm

Edit: /home/techb158/immovalet.com/vendor/aws/aws-sdk-php/src/DynamoDb/LockingSessionConnection.php (1932B)

<?php
namespace Aws\DynamoDb;

use Aws\DynamoDb\Exception\DynamoDbException;

/**
 * The locking connection adds locking logic to the read operation.
 */
class LockingSessionConnection extends StandardSessionConnection
{
    public function __construct(DynamoDbClient $client, array $config = [])
    {
        parent::__construct($client, $config);
    }

/**
     * {@inheritdoc}
     * Retries the request until the lock can be acquired
     */
    public function read($id)
    {
        // Create the params for the UpdateItem operation so that a lock can be
        // set and item returned (via ReturnValues) in a one, atomic operation.
        $params = [
            'TableName'        => $this->getTableName(),
            'Key'              => $this->formatKey($id),
            'Expected'         => ['lock' => ['Exists' => false]],
            'AttributeUpdates' => ['lock' => ['Value' => ['N' => '1']]],
            'ReturnValues'     => 'ALL_NEW',
        ];

// Acquire the lock and fetch the item data.
        $timeout  = time() + $this->getMaxLockWaitTime();
        while (true) {
            try {
                $item = [];
                $result = $this->client->updateItem($params);
                if (isset($result['Attributes'])) {
                    foreach ($result['Attributes'] as $key => $value) {
                        $item[$key] = current($value);
                    }
                }
                return $item;
            } catch (DynamoDbException $e) {
                if ($e->getAwsErrorCode() === 'ConditionalCheckFailedException'
                    && time() < $timeout
                ) {
                    usleep(rand(
                        $this->getMinLockRetryMicrotime(),
                        $this->getMaxLockRetryMicrotime()
                    ));
                } else {
                    break;
                }
            }
        }
    }
}

$this->getTableName(), 'Key' => $this->formatKey($id), 'Expected' => ['lock' => ['Exists' => false]], 'AttributeUpdates' => ['lock' => ['Value' => ['N' => '1']]], 'ReturnValues' => 'ALL_NEW', ]; // Acquire the lock and fetch the item data. $timeout = time() + $this->getMaxLockWaitTime(); while (true) { try { $item = []; $result = $this->client->updateItem($params); if (isset($result['Attributes'])) { foreach ($result['Attributes'] as $key => $value) { $item[$key] = current($value); } } return $item; } catch (DynamoDbException $e) { if ($e->getAwsErrorCode() === 'ConditionalCheckFailedException' && time() < $timeout ) { usleep(rand( $this->getMinLockRetryMicrotime(), $this->getMaxLockRetryMicrotime() )); } else { break; } } } } }