KeyStreamOutput freezes after 1 minute

[pavelsmolka]

When I implement KeyStreamOutput and use it, it freezes after 1 minute:

class DeleteStream implements KeyStreamOutput {

    /** @var Bucket */
    public $bucket;

    public function __construct(Bucket $bucket) {
        $this->bucket = $bucket;
    }

    public function process($key) {
        echo "Deleting key $key\n";
        $this->bucket->delete($key);
    }
}

$bucket = $riak->getBucket('test');
$bucket->getKeyStream(new DeleteStream($bucket));

This example works for approximately 1 minute and then stops printing anything. Also, no more keys are deleted, after 1 minute. Is is possible Riak disconnects the connection and our library does not reconnects?

[pavelsmolka]

I restarted my script couple of times. After a while, it worked just fine and deleted everything in the bucket. I wonder whether if there are too many keys, it fails, but if there are just several thousands, it finishes the job. In the last run, it took more than 5 minutes to stream all remaining keys and the script did not freeze.

[bachpedersen]

php_riak will not auto retry stream or listkeys as they are very dangerous, but it should however throw an exception if something went wrong.

Now that I think about it I am unsure what happens if the process function throws an exception, I will check this when I get the time.

[bachpedersen]

Does not look like a problem with exceptions not propagating, I have not been able to recreate it still.
Will try to recreate it using stress tests instead.

[guilhermeblanco]

Have you tried to check your default_socket_timeout PHP config? It may be the issue... =)