+ if (conf.min_free_mb_arg)
+ if (ds.free_mb < conf.min_free_mb_arg)
+ return 1;
+ if (conf.min_free_percent_arg)
+ if (ds.percent_free < conf.min_free_percent_arg)
+ return 1;
+ return 0;
+}
+
+int try_to_free_disk_space(int low_disk_space, struct snapshot_list *sl)
+{
+ int ret;
+
+ ret = remove_outdated_snapshot(sl);
+ if (ret) /* error, or we are removing something */
+ return ret;
+ /* no outdated snapshot */
+ ret = remove_redundant_snapshot(sl);
+ if (ret)
+ return ret;
+ if (!low_disk_space)
+ return 0;
+ DSS_WARNING_LOG("disk space low and nothing obvious to remove\n");
+ ret = remove_oldest_snapshot();
+ if (ret)
+ return ret;
+ make_err_msg("uhuhu: not enough disk space for a single snapshot");
+ return -ENOSPC;
+}
+
+int select_loop(void)
+{
+ int ret;
+ struct timeval tv = {.tv_sec = 0, .tv_usec = 0};
+ struct snapshot_list sl = {.num_snapshots = 0};
+
+ for (;;) {
+ struct timeval now, *tvp = &tv;
+ fd_set rfds;
+ int low_disk_space;
+ char **rsync_argv;
+
+ free_snapshot_list(&sl);
+ get_snapshot_list(&sl);
+ compute_next_snapshot_time(&sl);
+ FD_ZERO(&rfds);
+ FD_SET(signal_pipe, &rfds);
+ if (rsync_pid)
+ tv.tv_sec = 60;
+ else if (rm_pid)
+ tvp = NULL;
+ ret = dss_select(signal_pipe + 1, &rfds, NULL, tvp);
+ if (ret < 0)
+ return ret;
+ if (FD_ISSET(signal_pipe, &rfds)) {
+ handle_signal();
+ continue;
+ }
+ if (rm_pid)
+ continue;
+ ret = disk_space_low();
+ if (ret < 0)
+ break;
+ low_disk_space = ret;
+ if (low_disk_space)
+ stop_rsync_process();
+ ret = try_to_free_disk_space(low_disk_space, &sl);
+ if (ret < 0)
+ break;
+ if (rm_pid)
+ continue;
+ if (rsync_pid) {
+ restart_rsync_process();
+ continue;
+ }
+ /* neither rsync nor rm are running. Start rsync? */
+ gettimeofday(&now, NULL);
+ if (tv_diff(&next_snapshot_time, &now, &tv) > 0)
+ continue;
+ create_rsync_argv(&rsync_argv, ¤t_snapshot_creation_time);
+ ret = create_snapshot(rsync_argv);
+ free_rsync_argv(rsync_argv);
+ if (ret < 0)
+ break;