Pass the ending timestamp, now that the API calls can do something with it.

Prevents (unlikely) race condition if an object is updated on the server
during a sync-session between the time the current sync timestamp is
saved and the the history backend is queried.

diff --git a/framework/SyncML/SyncML/Backend/Horde.php b/framework/SyncML/SyncML/Backend/Horde.php
index bacf65e..d7395e1 100644 (file)
--- a/framework/SyncML/SyncML/Backend/Horde.php
+++ b/framework/SyncML/SyncML/Backend/Horde.php
@@ -158,8 +158,8 @@ class SyncML_Backend_Horde extends SyncML_Backend {
                 $database . '/listBy',
                 array('action' => 'add',
                       'timestamp' => $from_ts,
-                      'source' => SyncML_Backend::getParameter($databaseURI,
-                                                               'source')));
+                      'source' => SyncML_Backend::getParameter($databaseURI, 'source'),
+                      'end' => $to_ts));
         }
 
         if (is_a($data, 'PEAR_Error')) {
@@ -212,7 +212,8 @@ class SyncML_Backend_Horde extends SyncML_Backend {
             $database. '/listBy',
             array('action' => 'modify',
                   'timestamp' => $from_ts,
-                  'source' => SyncML_Backend::getParameter($databaseURI,'source')));
+                  'source' => SyncML_Backend::getParameter($databaseURI,'source'),
+                  'end' => $to_ts));
         if (is_a($data, 'PEAR_Error')) {
             $this->logMessage(
                 "$database/listBy failed while retrieving server modifications:"
@@ -260,7 +261,8 @@ class SyncML_Backend_Horde extends SyncML_Backend {
             $database . '/listBy',
             array('action' => 'delete',
                   'timestamp' => $from_ts,
-                  'source' => SyncML_Backend::getParameter($databaseURI, 'source')));
+                  'source' => SyncML_Backend::getParameter($databaseURI, 'source'),
+                  'end' => $to_ts));
 
         if (is_a($data, 'PEAR_Error')) {
             $this->logMessage(