+ DSS_WARNING_LOG("disk space low and nothing obvious to remove\n");
+ ret = remove_oldest_snapshot(&sl);
+ if (ret)
+ goto out;
+ DSS_CRIT_LOG("uhuhu: not enough disk space for a single snapshot\n");
+ ret= -ENOSPC;
+out:
+ free_snapshot_list(&sl);
+ return ret;
+}
+
+int select_loop(void)
+{
+ int ret;
+ struct timeval tv = {.tv_sec = 0, .tv_usec = 0};
+
+ for (;;) {
+ fd_set rfds;
+ int low_disk_space;
+ char **rsync_argv;
+ struct timeval now, *tvp = &tv;
+
+ if (rsync_pid)
+ tv.tv_sec = 60; /* check every 60 seconds for free disk space */
+ else if (rm_pid)
+ tvp = NULL; /* sleep until rm process dies */
+ FD_ZERO(&rfds);
+ FD_SET(signal_pipe, &rfds);
+ DSS_DEBUG_LOG("tvp: %p, tv_sec: %lu\n", tvp, (long unsigned) tv.tv_sec);
+ ret = dss_select(signal_pipe + 1, &rfds, NULL, tvp);
+ if (ret < 0)
+ return ret;
+ if (FD_ISSET(signal_pipe, &rfds))
+ handle_signal();
+ 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);
+ if (ret < 0)
+ break;
+ if (rm_pid)
+ continue;
+ restart_rsync_process();
+ gettimeofday(&now, NULL);
+ if (tv_diff(&next_snapshot_time, &now, &tv) > 0)
+ continue;
+ switch (snapshot_creation_status) {
+ case SCS_READY:
+ ret = pre_create_hook();
+ if (ret < 0)
+ goto out;
+ continue;
+ case SCS_PRE_HOOK_RUNNING:
+ continue;
+ case SCS_PRE_HOOK_SUCCESS:
+ create_rsync_argv(&rsync_argv, ¤t_snapshot_creation_time);
+ ret = create_snapshot(rsync_argv);
+ free_rsync_argv(rsync_argv);
+ if (ret < 0)
+ goto out;
+ continue;
+ case SCS_RSYNC_RUNNING:
+ continue;
+ case SCS_RSYNC_SUCCESS:
+ ret = post_create_hook();
+ if (ret < 0)
+ goto out;
+ continue;
+ case SCS_POST_HOOK_RUNNING:
+ continue;
+ }