Method service_main

lib_acl_cpp/src/master/master_threads.cpp:277–316

}

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

	// client->context �� service_on_accept �����
	socket_stream* stream = (socket_stream*) client->context;
	if (stream == NULL) {
		logger_fatal("client->context is null!");
	}

	// ����������麯��ʵ�֣�������� true ��ʾ�ÿ�ܼ�����ظ���������
	// ������Ҫ�رո���
	// ���ϲ��ܷ���ֵ�������£�
	// 0 ��ʾ��������ӱ��ֳ����ӣ�����Ҫ������ظ������Ƿ�ɶ�
	// -1 ��ʾ��Ҫ�رո�����
	// 1 ��ʾ���ټ�ظ�����

	if (mt->thread_on_read(stream)) {
		// ��������ڷ��� true ��ϣ����ܼ������������ֱ�ӷ��ظ���� 1
		if (!mt->keep_read(stream)) {
			return 1;
		}

		// ������Ҫ�������Ƿ��Ѿ��رգ�����رգ�����뷵�� -1
		if (stream->eof()) {
			logger_error("DISCONNECTED, CLOSING, FD: %d",
				(int) stream->sock_handle());
			return -1;
		}

		// ���� 0 ��ʾ������ظ����Ŀɶ�״̬
		return 0;
	}

	// ���� -1 ��ʾ���ϲ��������ر������ϲ����������ر���ǰ
	// ����ص� service_on_close ���̽������ر�ǰ���ƺ���������
	// stream ������ service_on_close �б��ͷ�
	return -1;
}

void master_threads::service_on_listen(void* ctx, ACL_VSTREAM* sstream)
{