Method service_on_accept

lib_acl_cpp/src/master/master_threads.cpp:216–255

}

int master_threads::service_on_accept(void* ctx, ACL_VSTREAM* client)
{
	master_threads* mt = (master_threads *) ctx;
	acl_assert(mt);

	// client->context ��Ӧ��ռ��
	if (client->context != NULL) {
		logger_fatal("client->context not null!");
	}

	socket_stream* stream = NEW socket_stream();

	// ���� client->context Ϊ�����󣬸�������ͳһ��
	// service_on_close �б��ͷ�
	client->context = stream;

	if (!stream->open(client)) {
		logger_error("open stream error(%s)", acl_last_serror());
		// ���� -1 ���ϲ��ܵ��� service_on_close ���̣�������
		// �ͷ� stream ����
		return -1;
	}

	// �������� thread_on_accept �������� false����ֱ�ӷ��ظ��ϲ�
	// ��� -1�����ϲ����ٵ��� service_on_close ���̣��Ӷ��ڸù���
	// �н� stream �����ͷ�
	if (!mt->thread_on_accept(stream)) {
		return -1;
	}

	// �������� thread_on_handshake �������� false����ֱ�ӷ��ظ��ϲ�
	// ��� -1�����ϲ����ٵ��� service_on_close ���̣��Ӷ��ڸù���
	// �н� stream �����ͷ�
	//if (mt->thread_on_handshake(stream) == false)
	//	return -1;

	// ���� 0 ��ʾ���Լ��������ÿͻ������ӣ��Ӷ����ϲ��ܽ�������
	// ����ؼ�����
	return 0;
}

int master_threads::service_on_handshake(void* ctx, ACL_VSTREAM *client)
{