Method sock_read

lib_acl_cpp/src/stream/mbedtls_io.cpp:482–541

}

int mbedtls_io::sock_read(void *ctx, unsigned char *buf, size_t len)
{
#ifdef HAS_MBEDTLS
	mbedtls_io* io = (mbedtls_io*) ctx;
	ACL_VSTREAM* vs = io->stream_;
	ACL_SOCKET fd = ACL_VSTREAM_SOCK(vs);

	//logger(">>>non_block: %s, sys_ready: %s",
	//	io->nblock_ ? "yes" : "no",
	//	vs->read_ready ? "yes":"no");

	// ������ģʽ�£���� read_ready ��־λΪ 0����˵���п���
	// ���� IO �����������ݣ�Ϊ�˷�ֹ�ö����̱����������Դ˴�ֱ��
	// ���ظ� mbedtls ����֮�ȴ��´ζ����´ζ����������¼����津����
	// ���������ŵ����ڷ�����ģʽ�¼�ʹ�׽���û������Ϊ������״̬
	// Ҳ���������̣߳���ȱ�����������¼�ѭ�������Ĵ���
	if (io->nblock_ && vs->read_ready == 0) {
		 int ret = acl_readable(fd);
		 if (ret == -1) {
			 return MBEDTLS_ERR_NET_RECV_FAILED;
		 } else if (ret == 0) {
			// �����ڴ˴�����ϵͳ�� errno �ţ��˴���ģ����
			// ������������
			acl_set_error(ACL_EWOULDBLOCK);
			return MBEDTLS_ERR_SSL_WANT_READ;
		 }
		 // else: ret == 1
	}

	// acl_socket_read �ڲ������ vs->read_ready ��־λ�����Ƿ���Ҫ
	// �Գ�ʱ��ʽ�����ݣ�ͬʱ���Զ���� vs->read_ready ��־λ
	int ret = acl_socket_read(fd, buf, len, vs->rw_timeout, vs, NULL);
	if (ret < 0) {
		int errnum = acl_last_error();

		if (errnum == ACL_EINTR) {
			return MBEDTLS_ERR_SSL_WANT_READ;
		} else if (errnum == ACL_EWOULDBLOCK) {
			return MBEDTLS_ERR_SSL_WANT_READ;
#if ACL_EWOULDBLOCK != ACL_EAGAIN
		} else if (errnum == ACL_EAGAIN) {
			return MBEDTLS_ERR_SSL_WANT_READ;
#endif
		} else if (errnum == ACL_ECONNRESET || errno == EPIPE) {
			return MBEDTLS_ERR_NET_CONN_RESET;
		} else {
			return MBEDTLS_ERR_NET_RECV_FAILED;
		}
	}


	return ret;
#else
	(void) ctx;
	(void) buf;
	(void) len;
	logger_error("HAS_MBEDTLS not defined!");
	return -1;