From: Sarah Hoffmann <lonvia@denofr.de>
Date: Sun, 11 Jun 2017 07:27:18 +0000 (+0200)
Subject: Merge remote-tracking branch 'upstream/master'
X-Git-Tag: deploy~380
X-Git-Url: https://git.openstreetmap.org./nominatim.git/commitdiff_plain/cb908b0a30bbffb3a35f49aa13e249cf3b61b152?ds=sidebyside;hp=-c

Merge remote-tracking branch 'upstream/master'
---

cb908b0a30bbffb3a35f49aa13e249cf3b61b152
diff --combined utils/update.php
index 099ca0b3,d8611715..1f036ff0
--- a/utils/update.php
+++ b/utils/update.php
@@@ -38,7 -38,6 +38,7 @@@ $aCMDOption
  getCmdOpt($_SERVER['argv'], $aCMDOptions, $aResult, true, true);
  
  if (!isset($aResult['index-instances'])) $aResult['index-instances'] = 1;
 +
  if (!isset($aResult['index-rank'])) $aResult['index-rank'] = 0;
  
  date_default_timezone_set('Etc/UTC');
@@@ -242,9 -241,7 +242,7 @@@ if ($aResult['import-osmosis'] || $aRes
  
      while (true) {
          $fStartTime = time();
-         $iFileSize = 1001;
- 
-         $aLastState = chksql($oDB->getRow('SELECT * FROM import_status'));
+         $aLastState = chksql($oDB->getRow('SELECT *, EXTRACT (EPOCH FROM lastimportdate) as unix_ts FROM import_status'));
  
          if (!$aLastState['sequence_id']) {
              echo "Updates not set up. Please run ./utils/update.php --init-updates.\n";
@@@ -258,7 -255,7 +256,7 @@@
  
          if ($aLastState['indexed'] == 't') {
              // Sleep if the update interval has not yet been reached.
-             $fNextUpdate = $aLastState['lastimportdate'] + CONST_Replication_Update_Interval;
+             $fNextUpdate = $aLastState['unix_ts'] + CONST_Replication_Update_Interval;
              if ($fNextUpdate > $fStartTime) {
                  $iSleepTime = $fNextUpdate - $fStartTime;
                  echo "Waiting for next update for $iSleepTime sec.";
@@@ -285,6 -282,23 +283,23 @@@
                  }
              } while ($iResult);
  
+             // get the newest object from the diff file
+             $sBatchEnd = 0;
+             $iRet = 0;
+             exec(CONST_BasePath.'/utils/osm_file_date.py '.$sImportFile, $sBatchEnd, $iRet);
+             if ($iRet == 5) {
+                 echo "Diff file is empty. skipping import.\n";
+                 if (!$aResult['import-osmosis-all']) {
+                     exit(0);
+                 } else {
+                     continue;
+                 }
+             }
+             if ($iRet != 0) {
+                 fail('Error getting date from diff file.');
+             }
+             $sBatchEnd = $sBatchEnd[0];
+ 
              // Import the file
              $fCMDStartTime = time();
              echo $sCMDImport."\n";
@@@ -297,14 -311,6 +312,6 @@@
  
              // write the update logs
              $iFileSize = filesize($sImportFile);
-             // get the newest object from the diff file
-             $sBatchEnd = 0;
-             $iRet = 0;
-             exec(CONST_BasePath.'/utils/osm_file_date.py '.$sImportFile, $sBatchEnd, $iRet);
-             if ($iRet != 0) {
-                 fail('Error getting date from diff file.');
-             }
-             $sBatchEnd = $sBatchEnd[0];
              $sSQL = "INSERT INTO import_osmosis_log (batchend, batchseq, batchsize, starttime, endtime, event) values ('$sBatchEnd',$iEndSequence,$iFileSize,'".date('Y-m-d H:i:s', $fCMDStartTime)."','".date('Y-m-d H:i:s')."','import')";
              var_Dump($sSQL);
              chksql($oDB->query($sSQL));