Mailing-List: contact user-help@cassandra.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@cassandra.apache.org
Received-SPF: pass (athena.apache.org: domain of juho.makinen@gmail.com
 designates 209.85.216.179 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:in-reply-to:references:date:message-id:subject:from:to
         :content-type:content-transfer-encoding;
        b=UCcxbYcKRQABfRp5bix1ZBESaW5UqsJGELAUrQO29yKJ4cmhe/g0kGegs1omI/7yjY
         bEQm7M/auQB3byVE9eo+CPbefxjoB97vylGxEnpST4XU7iT66euihhwpsgQh8Rix2CGr
         6SnJHITtoouc1ZQGs3Njr0wGWTxVp8Nm5RJNY=
MIME-Version: 1.0
In-Reply-To: <4C7BB121.6090301@softwareprojects.com>
References: <EA43936A-6DFD-4083-849C-C35FB1624E6D@gmail.com>
	<AANLkTinpa+60Kimm8YiZX34o355+-p7RcgPhoTNBrsEF@mail.gmail.com>
	<AANLkTinwQ_4YrYLmxX_qrzDkxFhV+iJY=TyQvQpMaRcV@mail.gmail.com>
	<AANLkTinfeKPLtZZkUyLqEeoPBJ7M17rudCem_Qg6znUA@mail.gmail.com>
	<AANLkTin_QF9uO+xZb3m1RR9O3DjzrpBFUo4qPuuP5iUD@mail.gmail.com>
	<AANLkTikD9JQ9Uf5NYqOUgh9Be3=EkTX2fgDo5mJLpptE@mail.gmail.com>
	<1283172538437-5478057.post@n2.nabble.com>
	<AANLkTinEJYHcQcAYp_LqE_HDuZVGwEH-h+NDDFMvbmsZ@mail.gmail.com>
	<4C7BB121.6090301@softwareprojects.com>
Date: Mon, 30 Aug 2010 17:43:00 +0300
Message-ID: <AANLkTineqM16axJFZ4p0vbi9-cxaVQ8Rd4Fb=6CBEKHK@mail.gmail.com>
Subject: Re: Thrift + PHP: help!
From: =?ISO-8859-1?Q?Juho_M=E4kinen?= <juho.makinen@gmail.com>
To: user@cassandra.apache.org
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

On Mon, Aug 30, 2010 at 4:24 PM, Mike Peters
<cassandra@softwareprojects.com> wrote:
> Have you considered instead of retrying the failing node, to iterate thro=
ugh
> other nodes in your cluster?


Yes, the $this->connect() does just that: it removes the previous node
from the node list and gives the list back to thrift connection
function. In case all nodes have been tried (and thus removed) it
refills the node list and starts looping it again. In practice this
will never happen but the code is there just to be sure :)

 - Juho M=E4kinen


>
> If one node is failing (let's assume it's overloaded for a minute), you'r=
e
> probably going to be better off having the client send the insert to the
> next node in line.
>
> Thoughts?
>
> On 8/30/2010 9:17 AM, Juho M=E4kinen wrote:
>>
>> Yes, I've already planning to do so. The class has still some
>> dependencies into our other functions which I need to first clear out.
>>
>> Basically each api call is wrapped inside a retry loop as we can
>> assume that each operation can be retried as many times as needed:
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0$tries =3D 0;
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0$this->last_exception =3D null;
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0$delay =3D 1000; // start with 1ms retry =
delay
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0do {
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0try {
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0$this->cl=
ient->insert($this->keyspace,
>> $key, $column_path, $value,
>> $timestamp, $consistency_level);
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0return;
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0} catch (cassandra_Invali=
dRequestException $e) {
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0Logger::e=
rror("InvalidRequestException: " .
>> $e->why . ',
>> stacktrace: ' . $e->getMessage());
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0throw $e;
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0} catch (Exception $e) {
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0$this->la=
st_exception =3D $e;
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0$tries++;
>>
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0// sleep =
for some time and try again
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0usleep($d=
elay);
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0$delay =
=3D $delay * 3;
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0$this->co=
nnect(); // Drop current server
>> and reopen a connection
>> into another server
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0}
>>
>>
>>
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0} while ($tries< =A04);
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0// Give up and throw the last exception
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0throw $this->last_exception;
>>
>>
>> =A0- Juho M=E4kinen
>>
>> On Mon, Aug 30, 2010 at 3:48 PM, Mike Peters
>> <cassandra@softwareprojects.com> =A0wrote:
>>>
>>> Juho, do you mind sharing your implementation with the group?
>>>
>>> We'd love to help as well with rewriting the thrift interface,
>>> specificaly
>>> TSocket.php which seems to be where the majority of the problems are
>>> lurking.
>>>
>>> Has anyone tried compiling native thrift support as described here
>>> https://wiki.fourkitchens.com/display/PF/Using+Cassandra+with+PHP
>>> https://wiki.fourkitchens.com/display/PF/Using+Cassandra+with+PHP
>>> --
>>> View this message in context:
>>> http://cassandra-user-incubator-apache-org.3065146.n2.nabble.com/Thrift=
-PHP-help-tp5437314p5478057.html
>>> Sent from the cassandra-user@incubator.apache.org mailing list archive =
at
>>> Nabble.com.
>>>
>>
>
>