Method queue_manager

lib_acl_cpp/src/queue/queue_manager.cpp:18–55

{

queue_manager::queue_manager(const char* home, const char* queueName,
	unsigned sub_width)
: m_scanDir(NULL)
, m_home(home)
, m_queueName(queueName)
{
	if (sub_width == 0) {
		sub_width_ = 2;
	} else {
		sub_width_ = sub_width;
	}

	string buf(home);
	buf << PATH_SEP << queueName;

	// �ȴ�����Ŀ¼
	if (acl_make_dirs(buf.c_str(), 0700) == -1) {
		logger_error("create dir: %s error %s", buf.c_str(),
			last_serror());
	} else {
		logger("create dir: %s ok", buf.c_str());
	}

	char  node[32];
	for (unsigned i = 0; i < sub_width_; i++) {
		buf.clear();
		safe_snprintf(node, sizeof(node), "%d", i);
		buf << home << PATH_SEP << queueName
			<< PATH_SEP << node;
		// ������������Ŀ¼
		if (acl_make_dirs(buf.c_str(), 0700) == -1) {
			logger_error("create dir: %s error %s",
				buf.c_str(), last_serror());
		} else {
			logger("create dir: %s ok", buf.c_str());
		}
	}
}

queue_manager::~queue_manager(void)
{