--- /dev/null
+/*
+ * Copyright (c) [2011-2012] Novell, Inc.
+ *
+ * All Rights Reserved.
+ *
+ * This program is free software; you can redistribute it and/or modify it
+ * under the terms of version 2 of the GNU General Public License as published
+ * by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
+ * more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, contact Novell, Inc.
+ *
+ * To contact Novell about this file by physical or electronic mail, you may
+ * find current contact information at www.novell.com.
+ */
+
+
+#include <algorithm>
+
+#include "commands.h"
+
+
+using namespace std;
+
+
+struct younger_than
+{
+ younger_than(time_t t)
+ : t(t) {}
+ bool operator()(XSnapshots::const_iterator it)
+ { return it->getDate() > t; }
+ const time_t t;
+};
+
+
+// Removes snapshots younger than min_age from tmp
+void
+filter1(list<XSnapshots::const_iterator>& tmp, time_t min_age)
+{
+ tmp.remove_if(younger_than(time(NULL) - min_age));
+}
+
+
+// Removes pre and post snapshots from tmp that do have a corresponding
+// snapshot but which is not included in tmp.
+void
+filter2(const XSnapshots& snapshots, list<XSnapshots::const_iterator>& tmp)
+{
+ list<XSnapshots::const_iterator> ret;
+
+ for (list<XSnapshots::const_iterator>::const_iterator it1 = tmp.begin(); it1 != tmp.end(); ++it1)
+ {
+ if ((*it1)->getType() == XPRE)
+ {
+ XSnapshots::const_iterator it2 = snapshots.findPost(*it1);
+ if (it2 != snapshots.end())
+ {
+ if (find(tmp.begin(), tmp.end(), it2) == tmp.end())
+ continue;
+ }
+ }
+
+ if ((*it1)->getType() == XPOST)
+ {
+ XSnapshots::const_iterator it2 = snapshots.findPre(*it1);
+ if (it2 != snapshots.end())
+ {
+ if (find(tmp.begin(), tmp.end(), it2) == tmp.end())
+ continue;
+ }
+ }
+
+ ret.push_back(*it1);
+ }
+
+ swap(ret, tmp);
+}
+
+
+bool
+do_cleanup_number(DBus::Connection& conn, const string& config_name)
+{
+ time_t min_age = 1800;
+ size_t limit = 50;
+
+ /*
+ TODO
+ string val;
+ if (config->getValue("NUMBER_MIN_AGE", val))
+ val >> min_age;
+ if (config->getValue("NUMBER_LIMIT", val))
+ val >> limit;
+ */
+
+ XSnapshots snapshots = command_list_xsnapshots(conn, config_name);
+
+ list<XSnapshots::const_iterator> tmp;
+
+ for (XSnapshots::const_iterator it = snapshots.begin(); it != snapshots.end(); ++it)
+ {
+ if (it->getCleanup() == "number")
+ tmp.push_back(it);
+ }
+
+ if (tmp.size() > limit)
+ {
+ list<XSnapshots::const_iterator>::iterator it = tmp.end();
+ advance(it, - limit);
+ tmp.erase(it, tmp.end());
+
+ filter1(tmp, min_age);
+ filter2(snapshots, tmp);
+
+ for (list<XSnapshots::const_iterator>::const_iterator it = tmp.begin(); it != tmp.end(); ++it)
+ command_delete_xsnapshot(conn, config_name, (*it)->getNum());
+ }
+
+ return true;
+}
+
+
+bool
+is_first(list<XSnapshots::const_iterator>::const_iterator first,
+ list<XSnapshots::const_iterator>::const_iterator last,
+ XSnapshots::const_iterator it1,
+ std::function<bool(const struct tm& tmp1, const struct tm& tmp2)> pred)
+{
+ time_t t1 = it1->getDate();
+ struct tm tmp1;
+ localtime_r(&t1, &tmp1);
+
+ for (list<XSnapshots::const_iterator>::const_iterator it2 = first; it2 != last; ++it2)
+ {
+ if (it1 == *it2)
+ continue;
+
+ time_t t2 = (*it2)->getDate();
+ struct tm tmp2;
+ localtime_r(&t2, &tmp2);
+
+ if (!pred(tmp1, tmp2))
+ return true;
+
+ if (t1 > t2)
+ return false;
+ }
+
+ return true;
+}
+
+
+bool
+equal_year(const struct tm& tmp1, const struct tm& tmp2)
+{
+ return tmp1.tm_year == tmp2.tm_year;
+}
+
+bool
+equal_month(const struct tm& tmp1, const struct tm& tmp2)
+{
+ return equal_year(tmp1, tmp2) && tmp1.tm_mon == tmp2.tm_mon;
+}
+
+bool
+equal_day(const struct tm& tmp1, const struct tm& tmp2)
+{
+ return equal_month(tmp1, tmp2) && tmp1.tm_mday == tmp2.tm_mday;
+}
+
+bool
+equal_hour(const struct tm& tmp1, const struct tm& tmp2)
+{
+ return equal_day(tmp1, tmp2) && tmp1.tm_hour == tmp2.tm_hour;
+}
+
+
+bool
+is_first_yearly(list<XSnapshots::const_iterator>::const_iterator first,
+ list<XSnapshots::const_iterator>::const_iterator last,
+ XSnapshots::const_iterator it1)
+{
+ return is_first(first, last, it1, equal_year);
+}
+
+bool
+is_first_monthly(list<XSnapshots::const_iterator>::const_iterator first,
+ list<XSnapshots::const_iterator>::const_iterator last,
+ XSnapshots::const_iterator it1)
+{
+ return is_first(first, last, it1, equal_month);
+}
+
+bool
+is_first_daily(list<XSnapshots::const_iterator>::const_iterator first,
+ list<XSnapshots::const_iterator>::const_iterator last,
+ XSnapshots::const_iterator it1)
+{
+ return is_first(first, last, it1, equal_day);
+}
+
+bool
+is_first_hourly(list<XSnapshots::const_iterator>::const_iterator first,
+ list<XSnapshots::const_iterator>::const_iterator last,
+ XSnapshots::const_iterator it1)
+{
+ return is_first(first, last, it1, equal_hour);
+}
+
+
+bool
+do_cleanup_timeline(DBus::Connection& conn, const string& config_name)
+{
+ time_t min_age = 1800;
+ size_t limit_hourly = 10;
+ size_t limit_daily = 10;
+ size_t limit_monthly = 10;
+ size_t limit_yearly = 10;
+
+ /*
+ TODO
+ string val;
+ if (config->getValue("TIMELINE_MIN_AGE", val))
+ val >> min_age;
+ if (config->getValue("TIMELINE_LIMIT_HOURLY", val))
+ val >> limit_hourly;
+ if (config->getValue("TIMELINE_LIMIT_DAILY", val))
+ val >> limit_daily;
+ if (config->getValue("TIMELINE_LIMIT_MONTHLY", val))
+ val >> limit_monthly;
+ if (config->getValue("TIMELINE_LIMIT_YEARLY", val))
+ val >> limit_yearly;
+ */
+
+ size_t num_hourly = 0;
+ size_t num_daily = 0;
+ size_t num_monthly = 0;
+ size_t num_yearly = 0;
+
+ XSnapshots snapshots = command_list_xsnapshots(conn, config_name);
+
+ list<XSnapshots::const_iterator> tmp;
+
+ for (XSnapshots::const_iterator it = snapshots.begin(); it != snapshots.end(); ++it)
+ {
+ if (it->getCleanup() == "timeline")
+ tmp.push_front(it);
+ }
+
+ list<XSnapshots::const_iterator>::iterator it = tmp.begin();
+ while (it != tmp.end())
+ {
+ if (num_hourly < limit_hourly && is_first_hourly(it, tmp.end(), *it))
+ {
+ ++num_hourly;
+ it = tmp.erase(it);
+ }
+ else if (num_daily < limit_daily && is_first_daily(it, tmp.end(), *it))
+ {
+ ++num_daily;
+ it = tmp.erase(it);
+ }
+ else if (num_monthly < limit_monthly && is_first_monthly(it, tmp.end(), *it))
+ {
+ ++num_monthly;
+ it = tmp.erase(it);
+ }
+ else if (num_yearly < limit_yearly && is_first_yearly(it, tmp.end(), *it))
+ {
+ ++num_yearly;
+ it = tmp.erase(it);
+ }
+ else
+ {
+ ++it;
+ }
+ }
+
+ tmp.reverse();
+
+ filter1(tmp, min_age);
+ filter2(snapshots, tmp);
+
+ for (list<XSnapshots::const_iterator>::const_iterator it = tmp.begin(); it != tmp.end(); ++it)
+ command_delete_xsnapshot(conn, config_name, (*it)->getNum());
+
+ return true;
+}
+
+
+bool
+do_cleanup_empty_pre_post(DBus::Connection& conn, const string& config_name)
+{
+ time_t min_age = 1800;
+
+ /*
+ TODO
+ string val;
+ if (config->getValue("EMPTY_PRE_POST_MIN_AGE", val))
+ val >> min_age;
+ */
+
+ XSnapshots snapshots = command_list_xsnapshots(conn, config_name);
+
+ list<XSnapshots::const_iterator> tmp;
+
+ for (XSnapshots::const_iterator it1 = snapshots.begin(); it1 != snapshots.end(); ++it1)
+ {
+ if (it1->getType() == XPRE)
+ {
+ XSnapshots::const_iterator it2 = snapshots.findPost(it1);
+
+ if (it2 != snapshots.end())
+ {
+ command_create_xcomparison(conn, config_name, it1->getNum(), it2->getNum());
+
+ list<XFile> files = command_get_xfiles(conn, config_name, it1->getNum(), it2->getNum());
+
+ if (files.empty())
+ {
+ tmp.push_back(it1);
+ tmp.push_back(it2);
+ }
+ }
+ }
+ }
+
+ filter1(tmp, min_age);
+ filter2(snapshots, tmp);
+
+ for (list<XSnapshots::const_iterator>::const_iterator it = tmp.begin(); it != tmp.end(); ++it)
+ command_delete_xsnapshot(conn, config_name, (*it)->getNum());
+
+ return true;
+}
#include "utils/GetOpts.h"
#include "commands.h"
+#include "cleanup.h"
using namespace snapper;
using namespace std;
bool quiet = false;
bool verbose = false;
string config_name = "root";
-bool disable_filters = false;
unsigned int
string cleanup = getopts.popArg();
- if (cleanup == "number" || cleanup == "timeline" || cleanup == "empty-pre-post")
+ if (cleanup == "number")
{
- command_xcleanup(conn, config_name, cleanup);
+ do_cleanup_number(conn, config_name);
+ }
+ else if (cleanup == "timeline")
+ {
+ do_cleanup_timeline(conn, config_name);
+ }
+ else if (cleanup == "empty-pre-post")
+ {
+ do_cleanup_empty_pre_post(conn, config_name);
}
else
{
<< _("\t--verbose, -v\t\t\tIncrease verbosity.") << endl
<< _("\t--table-style, -t <style>\tTable style (integer).") << endl
<< _("\t--config, -c <name>\t\tSet name of config to use.") << endl
- << _("\t--disable-filters\t\tDisable filters.") << endl
<< _("\t--version\t\t\tPrint version and exit.") << endl
<< endl;
{ "verbose", no_argument, 0, 'v' },
{ "table-style", required_argument, 0, 't' },
{ "config", required_argument, 0, 'c' },
- { "disable-filters", no_argument, 0, 0 },
{ "version", no_argument, 0, 0 },
{ "help", no_argument, 0, 0 },
{ 0, 0, 0, 0 }
if ((opt = opts.find("config")) != opts.end())
config_name = opt->second;
- if ((opt = opts.find("disable-filters")) != opts.end())
- disable_filters = true;
-
if ((opt = opts.find("version")) != opts.end())
{
cout << "snapper " << VERSION << endl;
" <arg name='number-delete' type='u' direction='out'/>\n"
" </method>\n"
- " <method name='Cleanup'>\n"
- " <arg name='config-name' type='s' direction='in'/>\n"
- " <arg name='algorithm' type='s' direction='in'/>\n"
- " </method>\n"
-
" </interface>\n"
"</node>\n";
}
-void
-reply_to_command_cleanup(DBus::Connection& conn, DBus::Message& msg)
-{
- string config_name;
- string algorithm;
-
- DBus::Hihi hihi(msg);
- hihi >> config_name >> algorithm;
-
- y2mil("GetDiff config_name:" << config_name << " algorithm:" << algorithm);
-
- check_permission(conn, msg, config_name);
-
- Snapper* snapper = getSnapper(config_name);
-
- // TODO: at least the last algorithm must be in a seperate thread
-
- if (algorithm == "number")
- {
- snapper->doCleanupNumber();
- }
- else if (algorithm == "timeline")
- {
- snapper->doCleanupTimeline();
- }
- else if (algorithm == "empty-pre-post")
- {
- snapper->doCleanupEmptyPrePost();
- }
-
- DBus::MessageMethodReturn reply(msg);
-
- conn.send(reply);
-}
-
-
void
reply_to_command_debug(DBus::Connection& conn, DBus::Message& msg)
{
reply_to_command_set_undo_all(conn, msg);
else if (msg.is_method_call(INTERFACE, "GetUndoStatistic"))
reply_to_command_get_undo_statistics(conn, msg);
- else if (msg.is_method_call(INTERFACE, "Cleanup"))
- reply_to_command_cleanup(conn, msg);
else if (msg.is_method_call(INTERFACE, "Debug"))
reply_to_command_debug(conn, msg);
else
projects / thirdparty / snapper.git / commitdiff
