Changeset 681

Timestamp:

12/13/07 09:09:41 (1 year ago)

Author:

hachi

Message:

CAS testing

Files:

• branches/binary/server/t/binary.t (modified) (10 diffs)

branches/binary/server/t/binary.t

@@ -26 +26 @@
-# Flags, expiration
-use constant SET_PKT_FMT => "NN";
-
-
-
+
+
+
+
-# How long until the deletion takes effect.
-use constant DEL_PKT_FMT => "N";
-
+
-# amount, initial value, expiration
-use constant INCRDECR_PKT_FMT => "NNNNN";
@@ -39 +40 @@
-
-use constant PKT_FMT => "CCCxNN";
+
-#min recv packet size
-use constant MIN_RECV_PACKET => length(pack(PKT_FMT));
@@ -61 +63 @@
-        is($rv, 0, "Didn't get a result from get");
-        ok($@->not_found, "We got a not found error when we expected one");
-
-};
-
@@ -70 +71 @@
-};
-
- if 0
+
-
-{
@@ -142 +143 @@
-}
-
+{
+        diag "MultiGet";
+        $mc->add('xx', 5, 1, "ex");
+        $mc->add('wye', 5, 2, "why");
+        my $rv = $mc->getMulti(qw(xx wye zed));
+
+        is_deeply([1, 'ex'], $rv->{xx}, "X is correct");
+        is_deeply([2, 'why'], $rv->{wye}, "Y is correct");
+        is(keys(%$rv), 2, "Got only two answers like we expect");
+}
+
-<<EOT;
-    def testMultiGet(self):
-        """Testing multiget functionality"""
-        self.mc.add("x", 5, 1, "ex")
-        self.mc.add("y", 5, 2, "why")
-        vals=self.mc.getMulti('xyz')
-        self.assertEquals((1, 'ex'), vals['x'])
-        self.assertEquals((2, 'why'), vals['y'])
-        self.assertEquals(2, len(vals))
-
-    def testIncrDoesntExistNoCreate(self):
-        """Testing incr when a value doesn't exist (and not creating)."""
@@ -179 +182 @@
-        self.assertNotExists("x")
-        self.assertEquals(19, self.mc.decr("x", init=19))
-
-    def testCas(self):
-        """Test CAS operation."""
-        try:
-            self.mc.cas("x", 5, 19, 0x7fffffffff, "bad value")
-            self.fail("Expected error CASing with no existing value")
-        except MemcachedError, e:
-            self.assertEquals(memcacheConstants.ERR_NOT_FOUND, e.status)
-        self.mc.add("x", 5, 19, "original value")
-        flags, i, val=self.mc.gets("x")
-        self.assertEquals("original value", val)
-        try:
-            self.mc.cas("x", 5, 19, i+1, "broken value")
-            self.fail("Expected error CASing with invalid id")
-        except MemcachedError, e:
-            self.assertEquals(memcacheConstants.ERR_EXISTS, e.status)
-        self.mc.cas("x", 5, 19, i, "new value")
-        newflags, newi, newval=self.mc.gets("x")
-        self.assertEquals("new value", newval)
-
-        # Test a CAS replay
-        try:
-            self.mc.cas("x", 5, 19, i, "crap value")
-            self.fail("Expected error CASing with invalid id")
-        except MemcachedError, e:
-            self.assertEquals(memcacheConstants.ERR_EXISTS, e.status)
-        newflags, newi, newval=self.mc.gets("x")
-        self.assertEquals("new value", newval)
-EOT
+
+{
+        diag "CAS";
+        $mc->flush;
+        
+        {
+                my $rv =()= eval { $mc->cas("x", 5, 19, 0x7FFFFFFFFF, "bad value") };
+                is($rv, 0, "Empty return on expected failure");
+                ok($@->not_found, "Error was 'not found' as expected");
+        }
+
+        $mc->add("x", 5, 19, "original value");
+
+        my ($flags, $i, $val) = $mc->gets("x");
+        is($val, "original value", "->gets returned proper value");
+        
+        {
+                my $rv =()= eval { $mc->cas("x", 5, 19, $i+1, "broken value") };
+                is($rv, 0, "Empty return on expected failure (1)");
+                ok($@->exists, "Expected error state of 'exists' (1)");
+        }
+
+        $mc->cas("x", 5, 19, $i, "new value");
+
+        my ($newflags, $newi, $newval) = $mc->gets("x");
+        is($newval, "new value", "CAS properly overwrote value");
+
+        {
+                my $rv =()= eval { $mc->cas("x", 5, 19, $i, "replay value") };
+                is($rv, 0, "Empty return on expected failure (2)");
+                ok($@->exists, "Expected error state of 'exists' (2)");
+        }
+
+        (undef, undef, my $newval2) = $mc->gets("x");
+        is($newval2, "new value", "CAS replay didn't overwrite value");
+}
-
-$mc->flush;
@@ -378 +389 @@
-}
-
+sub getMulti {
+        my $self = shift;
+        my @keys = @_;
+
+        for (my $i = 0; $i < @keys; $i++) {
+                $self->_sendCmd(::CMD_GETQ, $keys[$i], '', $i);
+        }
+
+        my $terminal = @keys + 10;
+        $self->_sendCmd(::CMD_NOOP, '', '', $terminal);
+
+        my %return;
+
+        while (1) {
+                my ($opaque, $data) = $self->_handleSingleResponse;
+                last if $opaque == $terminal;
+
+                $return{$keys[$opaque]} = [$self->__parseGet($data)];
+        }
+        return %return if wantarray;
+        return \%return;
+}
+
-sub gets {
-        my $self = shift;
@@ -384 +418 @@
-        my $data = $self->_doCmd(::CMD_GETS, $key, '');
-        my $header = substr $data, 0, 12, '';
-data
+header
-        my $ident = ($ident_hi * 2 ** 32) + $ident_lo;
-
@@ -390 +424 @@
-}
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
-
-sub noop {
@@ -480 +492 @@
-        return $self->[0] == ERR_EXISTS;
-}
+
+# vim: filetype=perl