From 5a71e04a704ebc4b3e1449e58a6ba78f68ab7b60 Mon Sep 17 00:00:00 2001
From: Alexis Sukrieh <alexis@weborama.com>
Date: Wed, 4 Jul 2012 15:14:10 +0200
Subject: Support for a timeout attribute in the PBC client

The timeout option was only supported for the REST client, the PBC role did
have a hard-coded timeout set to 30 seconds.

This patch allows the caller to change it, by passing the timeout attrbute to
the constructor.

A test script is provided.
---
 lib/Net/Riak/Role/PBC.pm | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

(limited to 'lib/Net/Riak/Role')

diff --git a/lib/Net/Riak/Role/PBC.pm b/lib/Net/Riak/Role/PBC.pm
index 605f032..bc32e3b 100644
--- a/lib/Net/Riak/Role/PBC.pm
+++ b/lib/Net/Riak/Role/PBC.pm
@@ -37,6 +37,12 @@ has socket => (
     predicate => 'has_socket',
 );
 
+has timeout => (
+    is => 'ro',
+    isa => Int,
+    default => 30,
+);
+
 sub is_alive {
     my $self = shift;
     return $self->send_message('PingReq');
@@ -56,7 +62,7 @@ sub connect {
             PeerAddr => $self->host,
             PeerPort => $self->port,
             Proto    => 'tcp',
-            Timeout  => 30,
+            Timeout  => $self->timeout,
         )
     );
 }
-- 
cgit v1.2.3