Changeset 56

Timestamp:

09/02/09 23:37:58 (4 years ago)

Author:

jesus

Message:

update a cache with the asset locations

Files:

• trunk/perl/lib/Cornea/RecallTable.pm (modified) (3 diffs)

trunk/perl/lib/Cornea/RecallTable.pm

@@ -3 +3 @@
-use Cornea::Config;
-use Cornea::Utils;
+use Memcached::libmemcached qw(:memcached_behavior :memcached_server_distribution
+                               memcached_create memcached_behavior_set
+                               memcached_server_add memcached_set);
-use YAML;
-use DBI;
@@ -55 +58 @@
-    die $@ if $@;
-  }
+  $self->asset_cache_replace(@_);
-  return 1;
-}
@@ -549 +553 @@
-  });
-}
+
+my $_g_mc;
+my $_g_mc_id = '';
+
+sub asset_cache_replace {
+  my $self = shift;
+  my ($serviceId, $assetId, $repId, $snl) = @_;
+  my $all = $self->getNodes(['open','closed','truant']);
+  my @nodes = sort (map { $_->ip() } ($all->items()));
+  my $id = join(',', @nodes);
+  if (!$_g_mc or $_g_mc_id ne $id) {
+    $_g_mc_id = $id;
+    $_g_mc = memcached_create();
+    memcached_behavior_set($_g_mc, MEMCACHED_BEHAVIOR_DISTRIBUTION(),
+                           MEMCACHED_DISTRIBUTION_CONSISTENT());
+    foreach my $ip (@nodes) {
+      memcached_server_add($_g_mc, $ip, 11211);
+    }
+  }
+  memcached_set($_g_mc, "$serviceId-$assetId-$repId",
+                join(',', map { $_->id() } ($snl->items())));
+}
-1;