Method remove

lib_acl_cpp/src/queue/queue_file.cpp:297–410

}

bool queue_file::remove(void)
{
	this->close();
#ifdef ACL_WINDOWS
	if (_unlink(m_filePath.c_str()) != 0) {
#else
	if (unlink(m_filePath.c_str()) != 0) {
#endif
		logger_error("unlink %s error(%s)",
			m_filePath.c_str(), last_serror());
		return false;
	}
	return true;
}

bool queue_file::move_file(const char* queueName, const char* extName)
{
	acl::string buf(256);
	bool once_again = false;

	while (true) {
		buf.clear();
		buf << m_home << PATH_SEP << queueName << PATH_SEP << m_queueSub
			<< PATH_SEP << m_partName << "." << extName;

#ifdef ACL_WINDOWS
		// ��win32�±����ȹر��ļ����
		this->close();
#endif

		if (rename(m_filePath.c_str(), buf.c_str()) == 0) {
			break;
		}

		// ������ش���ԭ����Ŀ��·�������ڣ����Դ���Ŀ¼�ṹ

		if (once_again || acl_last_error() != ENOENT) {
			logger_error("move from %s to %s error(%s), errno: %d, %d",
				m_filePath.c_str(), buf.c_str(), last_serror(),
				last_error(), ENOENT);
			return false;
		}

		// �������Ա�־λ
		once_again = true;

		buf.clear();
		buf << m_home << PATH_SEP << queueName
			<< PATH_SEP << m_queueSub;

		// ��������Ŀ¼
		if (acl_make_dirs(buf.c_str(), 0700) == -1) {
			logger_error("mkdir: %s error(%s)",
				buf.c_str(), last_serror());
			return false;
		}
	}