[prev in list] [next in list] [prev in thread] [next in thread] 

List:       intermezzo-cvs
Subject:    CVS: intermezzo/lento/Lento KML.pm,1.72,1.73 Replicator.pm,1.59,1.60
From:       Phil Schwan <pschwan () users ! sourceforge ! net>
Date:       2001-10-17 19:54:49
[Download RAW message or body]

Update of /cvsroot/intermezzo/intermezzo/lento/Lento
In directory usw-pr-cvs1:/tmp/cvs-serv1235/Lento

Modified Files:
	KML.pm Replicator.pm 
Log Message:
Summary: Update the last_rcvd file on the permitholder when we receive
confirmation of remote reintegration

Lento/KML.pm: call $replicator->set_local_offset when we receive a confirmation
Lento/Replicator.pm: added set_local_offset() a-la set_remote_offset()
Lento/RPCS/ReintegrateKML.pm: keep in sync with KML.pm


Index: KML.pm
===================================================================
RCS file: /cvsroot/intermezzo/intermezzo/lento/Lento/KML.pm,v
retrieving revision 1.72
retrieving revision 1.73
diff -U2 -r1.72 -r1.73
--- KML.pm	2001/10/16 17:11:08	1.72
+++ KML.pm	2001/10/17 19:54:47	1.73
@@ -628,5 +628,8 @@
              DEBUG("  >>  Last confirmed extent: $confirmed_len, nts: %s\n", 
                  $replicator->next_to_send());
-             
+
+             # Update the last_rcvd file
+             $replicator->set_local_offset($replicator->next_to_send());
+
              $_[KERNEL]->yield('finish', 0);
          },

Index: Replicator.pm
===================================================================
RCS file: /cvsroot/intermezzo/intermezzo/lento/Lento/Replicator.pm,v
retrieving revision 1.59
retrieving revision 1.60
diff -U2 -r1.59 -r1.60
--- Replicator.pm	2001/10/16 17:11:08	1.59
+++ Replicator.pm	2001/10/17 19:54:47	1.60
@@ -273,4 +273,20 @@
 }
 
+# last_local_offset is a quad
+sub set_local_offset ($$) {
+    my ($self, $last_local_offset) = @_;
+
+    die "offset must be passed in" unless defined $last_local_offset;
+
+    print("set_local_offset($self->{sysid}, $last_local_offset)\n");
+
+    my ($remote_recno,$remote_offset,$local_recno,$local_offset,$last_ctime) =
+      $self->last_rcvd();
+
+    #replace old remote offset values with new ones
+    $self->write_last_rcvd($remote_recno, $remote_offset,
+                           $local_recno, $last_local_offset, $last_ctime);
+}
+
 # last_remote_offset is a quad
 sub set_remote_offset {


_______________________________________________
intermezzo-commit mailing list
intermezzo-commit@lists.sourceforge.net
https://lists.sourceforge.net/lists/listinfo/intermezzo-commit

[prev in list] [next in list] [prev in thread] [next in thread]