Method beanstalk_request

lib_acl_cpp/src/beanstalk/beanstalk.cpp:153–209

}

ACL_ARGV* beanstalk::beanstalk_request(const string& cmdline,
	const void* data /*= NULL */, size_t len /* = 0 */)
{
	string line(128);
	bool retried = false;

	while (true) {
		if (!beanstalk_open()) {
			return NULL;
		}

		// ��д������ͷ
		if (conn_.write(cmdline) == -1) {
			conn_.close();
			if (retry_ && !retried) {
				retried = true;
				continue;
			}
			logger_error("write to beanstalkd(%s) error: %s",
				addr_, last_serror());
			errbuf_ = "write";
			return NULL;
		}

		// ����������壬��д��������
		if (data && len > 0 && (conn_.write(data, len) == -1
			|| conn_.write("\r\n", 2) == -1)) {

			conn_.close();
			if (retry_ && !retried) {
				retried = true;
				continue;
			}
			logger_error("write to beanstalkd(%s) error: %s",
				addr_, last_serror());
			errbuf_ = "write";
			return NULL;
		}

		line.clear();
		if (!conn_.gets(line) || line.empty()) {
			conn_.close();
			if (retry_ && !retried) {
				retried = true;
				continue;
			}
			logger_error("gets from beanstalkd(%s) error: %s",
				addr_, last_serror());
			errbuf_ = "gets";
			return NULL;
		}
		break;
	}

	ACL_ARGV* tokens = acl_argv_split(line.c_str(), "\t ");
	return tokens;
}