Method create

lib_acl_cpp/src/queue/queue_file.cpp:45–142

}

bool queue_file::create(const char* home, const char* queueName,
	const char* extName, unsigned width)
{
	acl_assert(width > 0);

	struct timeval tv;
	acl::string buf;
	acl::fstream* fp = NULL;
	int   i = 0;
	bool  dir_exist;

	ACL_SAFE_STRNCPY(m_home, home, sizeof(m_home));
	ACL_SAFE_STRNCPY(m_queueName, queueName, sizeof(m_queueName));
	ACL_SAFE_STRNCPY(m_extName, extName, sizeof(m_extName));

	unsigned int n;

	while (true) {
		// ���������ļ���
		memset(&tv, 0, sizeof(tv));
		gettimeofday(&tv, NULL);
		safe_snprintf(m_partName, sizeof(m_partName),
			"%u_%lu_%08x_%08x_%u",
			(unsigned int) getpid(),
			(unsigned long) acl::thread::thread_self(),
			(unsigned int) tv.tv_sec,
			(unsigned int) tv.tv_usec,
			(unsigned int) __counter);
		if (__counter++ >= 1024000) {
			__counter = 0;
		}

		// ���������Ŀ¼
		n = queue_manager::hash_queueSub(m_partName, width);
		safe_snprintf(m_queueSub, sizeof(m_queueSub), "%u", n);

		buf.clear();
		buf << m_home << PATH_SEP << m_queueName << PATH_SEP << m_queueSub
			<< PATH_SEP << m_partName << "." << extName;

		fp = NEW fstream;

		dir_exist = false;

		while (true) {
			// �����Դ���Ψһ�ļ�
			if (fp->open(buf.c_str(), O_RDWR | O_CREAT | O_EXCL, 0600)) {
				goto END;
			}

			logger_warn("open file %s error(%s)", buf.c_str(), acl_last_serror());

			if (last_error() != ENOENT || dir_exist) {
				break;
			}

			// �����Դ���Ŀ¼
			buf.clear();