Method sock_send

lib_acl_cpp/src/stream/mbedtls_io.cpp:543–588

}

int mbedtls_io::sock_send(void *ctx, const 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);
	int timeout = io->nblock_ ? 0 : vs->rw_timeout;

	time_t begin = time(NULL);
	if (acl_write_wait(fd, timeout) < 0) {
		time_t end = time(NULL);
		logger_error("acl_write_wait error=%s, fd=%d, cost=%ld",
			last_serror(), (int) fd, (long) (end - begin));
		return MBEDTLS_ERR_NET_SEND_FAILED;
	}

	// ��Ϊ������ģʽʱ����ʱ�ȴ�Ϊ 0 ��
	int ret = acl_socket_write(fd, buf, len, io->nblock_
			? 0 : vs->rw_timeout, vs, NULL);
	if (ret < 0) {
		int errnum = acl_last_error();

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

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

} // namespace acl