add cleanRemote

Elena.Budnik
1 parent a1227fb6
Showing 4 changed files with 101 additions and 0 deletions Show diff stats
CMakeLists.txt
scripts/CleanRemote.sh
src/DATA/MANAGER/CleanRemote.php
src/DATA/MANAGER/DDBaseMgr.php
@@ -77,6 +77,7 @@ install(FILES &quot;scripts/AddLocalVI.sh&quot; DESTINATION . PERMISSIONS OWNER_READ OWNER
 install(FILES "scripts/UpdateInfoVI.sh" DESTINATION . PERMISSIONS OWNER_READ OWNER_WRITE OWNER_EXECUTE GROUP_READ GROUP_EXECUTE WORLD_READ WORLD_EXECUTE)
 install(FILES "scripts/RemoveVI.sh" DESTINATION . PERMISSIONS OWNER_READ OWNER_WRITE OWNER_EXECUTE GROUP_READ GROUP_EXECUTE WORLD_READ WORLD_EXECUTE)
 install(FILES "scripts/MakeRemoteProxy.sh" DESTINATION . PERMISSIONS OWNER_READ OWNER_WRITE OWNER_EXECUTE GROUP_READ GROUP_EXECUTE WORLD_READ WORLD_EXECUTE)
+install(FILES "scripts/CleanRemote.sh" DESTINATION . PERMISSIONS OWNER_READ OWNER_WRITE OWNER_EXECUTE GROUP_READ GROUP_EXECUTE WORLD_READ WORLD_EXECUTE)
  
 install(DIRECTORY "src/CALLEXT/" DESTINATION bin/CALLEXT)
 install(DIRECTORY "src/DATA/MANAGER/" DESTINATION bin/DATAMANAGER)
@@ -0,0 +1,10 @@
+#!/bin/sh
+
+BASEDIR=$(dirname "$0")
+
+. ${BASEDIR}/DDServer.env
+
+php ${DATAMANAGER}/CleanRemote.php
+
+ 
+
@@ -0,0 +1,21 @@
+<?php
+
+/**
+*  @file CleanRemote.php
+*  @brief DD Server Tools: 
+*/
+	if (!function_exists('__autoload')) 
+	{
+		function __autoload($class_name) {
+				require_once $class_name . '.php';
+		}
+	}
+   
+	putenv("LD_LIBRARY_PATH=".getenv("LD_LIBRARY_PATH"));
+	putenv("PATH=./:".getenv("DDBASEBIN").":/bin:/usr/bin");
+	set_include_path("./:".getenv("DATAMANAGER")); 
+
+   $baseMgr = new DDBaseMgr();
+   $baseMgr->cleanRemote();
+ 
+?>
@@ -290,6 +290,75 @@ class DDBaseMgr
 		system("infoLocal2nc ".$this->info_xml." ".$this->info);
 		chdir($currDir);
 	}
+	
+	public function cleanRemote($opt = NULL)
+	{
+		$res_before = disk_free_space(getenv("DDBASE"));
+		$Days = 10;  // default
+		$SecDay = 3600*24;
+		$nodata = false;
+
+		if (isset($opt)) {
+			if ($opt == "NODATA") 
+					$nodata = true;
+			else {
+				$Days = is_numeric($opt) ? $opt : 10;
+				settype($Days, "int");
+				echo "!!!!!!!!!!!!!!!! Days   ".$Days.PHP_EOL;
+			}
+		}
+		
+		$GlobalDelta = $Days*$SecDay;
+	
+		$xp = new domxpath($this->DDsysDoc);
+		$dataSets = $xp->query("//NAME[attribute::base!='LOCAL']");
+		
+		for ($i = 0; $i < $dataSets->length; $i++) 
+		{ 
+			$parent = $dataSets->item($i)->parentNode;
+			$location = $parent->getElementsByTagName("LOCATION")->item(0)->nodeValue;
+ 
+			if (!is_dir($location)) {
+				$parent->parentNode->removeChild($parent);
+			}
+			else {
+				$time_info = $parent->getElementsByTagName("TIMES")->item(0)->nodeValue;
+				chdir($location);
+				system("./clean");
+				touch($location."/LOCK");
+
+				fprintf(STDERR,"In the ".$location."\n");
+
+				/*  Delete No Data Intervals */        
+				if ($nodata) {
+					system("CleanNoData ".$time_info); 
+				}
+				/*  Delete Old Files */  
+				else {
+					foreach (glob("*.gz") as $filename) {
+						$info = stat($filename);
+						if ((time() - $info['atime']) > $GlobalDelta) {
+							//fprintf(STDERR, $filename."\n");
+							system("TimesUpdate -d ".$time_info." ".$filename);
+						}
+						//fprintf(STDERR, date("Y-m-d",$info['atime'])." - ".date("Y-m-d",$info['mtime'])."\n");
+					}
+				}
+
+			system("DDClearTimes ".$time_info);
+			unlink($location."/LOCK");  
+        }
+		}
+    /* 
+		$res_after = disk_free_space(getenv("DDBASE"));
+		$difference = ($res_after - $res_before)/1024.0;
+		$res_after /=  1024.0;
+		fprintf(STDERR,"+ Free Space  ".$difference." kB\n");
+		fprintf(STDERR,"  Free Space  ".$res_after." kB\n");*/
+		
+		$this->DDsysDoc->save($this->DDsys);
+		system("makeDDsys");	
+	}
 } 
 ?>