Method transfer

app/master/tools/master_dispatch/server/client/ManagerTimer.cpp:13–58

}

bool ManagerTimer::transfer(ClientConnection* client)
{
	ServerConnection* server;
	const char* peer;
	char  buf[256];
	int   ret;

	// �ӷ�������ӹ���������ȡ����������С��һ��
	// ����˶��󣬲��������ͻ������Ӵ��ݸ�����
	// һֱ���ɹ������д��䶼ʧ��Ϊֹ

	while (true)
	{
		server = ServerManager::get_instance().min();
		if (server == NULL)
		{
			logger_error("no server available for client: %s",
				client->get_peer());
			return false;
		}

		peer = client->get_peer();
		if (peer == NULL)
			peer = "unkonwn";
		memset(buf, 0, sizeof(buf));
		snprintf(buf, sizeof(buf), "%s", peer);

		// ���ͻ������Ӵ��ݸ�����ˣ����ʧ�ܣ�������һ��
		// ����ˣ�ͬʱ��ʧ�ܵķ���˴ӷ���˹���������ɾ��
		ret = acl_write_fd(server->sock_handle(), buf,
			strlen(buf), client->sock_handle());
		if (ret == -1)
		{
			logger_error("write fd to backend error: %s",
				acl::last_serror());
			ServerManager::get_instance().del(server);
			server->close();
		}
		// ���ͳɹ����ȸ��÷�����̵Ŀͻ�����������1���Ա����µ���
		// ���ӿ����л������������������
		else
			server->inc_conns();

		return true;
	}
}

void ManagerTimer::timer_callback(unsigned int)
{