file_delete.h File Reference

shared utility for mapd_server and string dictionary server to remove old files More...

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
void	file_delete (std::atomic< bool > &program_is_running, const unsigned int wait_interval_seconds, const std::string base_path)

Detailed Description

shared utility for mapd_server and string dictionary server to remove old files

Author

micha.nosp@m.el@o.nosp@m.mnisc.nosp@m.i.co.nosp@m.m>

Definition in file file_delete.h.

Function Documentation

void file_delete	(	std::atomic< bool > &	program_is_running,
		const unsigned int	wait_interval_seconds,
		const std::string	base_path
	)

Definition at line 228 of file File.cpp.

References logger::ERROR, error_code, logger::INFO, and LOG.

Referenced by startMapdServer().

                                            {
  const auto wait_duration = std::chrono::seconds(wait_interval_seconds);
  const boost::filesystem::path path(base_path);
  while (program_is_running) {
    using vec = std::vector<boost::filesystem::path>;  // store paths,
    vec v;
    boost::system::error_code ec;

    // copy vector from iterator as was getting weird random errors if
    // removed direct from iterator
    copy(boost::filesystem::directory_iterator(path),
         boost::filesystem::directory_iterator(),
         back_inserter(v));
    for (vec::const_iterator it(v.begin()); it != v.end(); ++it) {
      std::string object_name(it->string());

      if (boost::algorithm::ends_with(object_name, "DELETE_ME")) {
        LOG(INFO) << " removing object " << object_name;
        boost::filesystem::remove_all(*it, ec);
        if (ec.value() != boost::system::errc::success) {
          LOG(ERROR) << "Failed to remove object " << object_name << " error was " << ec;
        }
      }
    }

    std::this_thread::sleep_for(wait_duration);
  }
}

Here is the caller graph for this function: