Method move_file

lib_acl_cpp/src/queue/queue_file.cpp:312–370

}

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;
		}
	}

#ifdef ACL_WINDOWS
	// win32 ����Ҫ�����ٴ�
	return open(m_home, queueName, m_queueSub, m_partName, extName);
#else
	if (m_queueName != queueName) {
		ACL_SAFE_STRNCPY(m_queueName, queueName, sizeof(m_queueName));
	}
	if (m_extName != extName) {
		ACL_SAFE_STRNCPY(m_extName, extName, sizeof(m_extName));
	}
	m_filePath.clear();
	m_filePath << m_home << PATH_SEP << m_queueName << PATH_SEP
		<< m_queueSub << PATH_SEP << m_partName << "." << m_extName;
#endif
	return true;