Function process_archive

src/remote/server/ReplServer.cpp:640–1020

	enum ProcessStatus { PROCESS_SUSPEND, PROCESS_CONTINUE, PROCESS_ERROR, PROCESS_SHUTDOWN };

	ProcessStatus process_archive(MemoryPool& pool, Target* target)
	{
		ProcessQueue queue(pool);

		ProcessStatus ret = PROCESS_SUSPEND;

		const auto config = target->getConfig();

		try
		{
			// First pass: create the processing queue

			AutoPtr<PathUtils::DirIterator> iter;

			for (iter = PathUtils::newDirIterator(pool, config->sourceDirectory);
				*iter; ++(*iter))
			{
				if (shutdownFlag)
					return PROCESS_SHUTDOWN;

				const auto filename = **iter;

#ifdef PRESERVE_LOG
				PathName path, name;
				PathUtils::splitLastComponent(path, name, filename);

				if (name.find('~') == 0)
					continue;
#endif

				if (filename.find('{') != PathName::npos &&
					filename.find('}') != PathName::npos &&
					filename.find('-') != PathName::npos)
				{
					continue;
				}

				const int fd = os_utils::open(filename.c_str(), O_RDONLY | O_BINARY);
				if (fd < 0)
				{
					if (errno == EACCES || errno == EAGAIN)
					{
						target->verbose("Skipping file (%s) due to sharing violation", filename.c_str());
						continue;
					}

					raiseError("Journal file %s open failed (error: %d)", filename.c_str(), ERRNO);
				}

				AutoFile file(fd);

				struct stat stats;
				if (fstat(file, &stats) < 0)
					raiseError("Journal file %s fstat failed (error: %d)", filename.c_str(), ERRNO);

				const size_t fileSize = stats.st_size;

				if (fileSize < sizeof(SegmentHeader))