Method watch

lib_acl_cpp/src/beanstalk/beanstalk.cpp:334–377

}

unsigned beanstalk::watch(const char* tube)
{
	// �ȼ���Ƿ��Ѿ������ͬ����
	std::vector<char*>::iterator it = tubes_watched_.begin();
	for (; it != tubes_watched_.end(); ++it) {
		if (strcmp(*it, tube) == 0) {
			break;
		}
	}

	string cmdline(128);
	cmdline.format("watch %s\r\n", tube);
	ACL_ARGV* tokens = beanstalk_request(cmdline);
	if (tokens == NULL) {
		logger_error("'%s' error", cmdline.c_str());
		return 0;
	}
	if (tokens->argc < 2 || strcasecmp(tokens->argv[0], "WATCHING")) {
		logger_error("'%s' error %s", cmdline.c_str(), tokens->argv[0]);
		errbuf_ = tokens->argv[0];
		acl_argv_free(tokens);
		close();
		return 0;
	}

	unsigned n = (unsigned) atoi(tokens->argv[1]);
	acl_argv_free(tokens);

	// �����������������ע�Ķ�����Ϊ 0���϶��dz����ˣ���Ϊ���ٻ���һ��
	// ȱʡ���У�default�����Դ�ʱ��Ҫ�ر����ӣ��Ծ��������뱾�������
	// �Ĵ�����һ��������Զ��������������Իָ���������
	if (n == 0) {
		logger_error("'%s' error, tube watched is 0", cmdline.c_str());
		errbuf_ = "watching";
		close();
	}

	// ���ӽ���ؼ�����
	else if (it == tubes_watched_.end()) {
		tubes_watched_.push_back(acl_mystrdup(tube));
	}

	return n;
}

unsigned beanstalk::ignore(const char* tube)
{