991 	int ret, nif;  in mtcp_connect()  local
1064 			ret = FetchAddressPerCore(mtcp->ap,   in mtcp_connect()
1072 			ret = FetchAddress(ap[nif],   in mtcp_connect()
1075 		if (ret < 0) {  in mtcp_connect()
1155 	ret = StreamEnqueue(mtcp->connectq, cur_stream);  in mtcp_connect()
1158 	if (ret < 0) {  in mtcp_connect()
1202 	int ret;  in CloseStreamSocket()  local
1257 	ret = StreamEnqueue(mtcp->closeq, cur_stream);  in CloseStreamSocket()
1261 	if (ret < 0) {  in CloseStreamSocket()
1310 	int ret;  in mtcp_close()  local
1334 		ret = CloseStreamSocket(mctx, sockid);  in mtcp_close()
1338 		ret = CloseListeningSocket(mctx, sockid);  in mtcp_close()
1342 		ret = CloseEpollSocket(mctx, sockid);  in mtcp_close()
1346 		ret = PipeClose(mctx, sockid);  in mtcp_close()
1351 		ret = -1;  in mtcp_close()
1357 	return ret;  in mtcp_close()
1365 	int ret;  in mtcp_abort()  local
1441 	ret = StreamEnqueue(mtcp->resetq, cur_stream);  in mtcp_abort()
1445 	if (ret < 0) {  in mtcp_abort()
1509 	int ret;  in mtcp_recv()  local
1571 		ret = CopyToUser(mtcp, cur_stream, buf, len);  in mtcp_recv()
1574 		ret = PeekForUser(mtcp, cur_stream, buf, len);  in mtcp_recv()
1578 		ret = -1;  in mtcp_recv()
1580 		return ret;  in mtcp_recv()
1594 	    merged_len == 0 && ret > 0) {  in mtcp_recv()
1607 	TRACE_API("Stream %d: mtcp_recv() returning %d\n", cur_stream->id, ret);  in mtcp_recv()
1608 	return ret;  in mtcp_recv()
1624 	int ret, bytes_read, i;  in mtcp_readv()  local
1687 		ret = CopyToUser(mtcp, cur_stream, iov[i].iov_base, iov[i].iov_len);  in mtcp_readv()
1688 		if (ret <= 0)  in mtcp_readv()
1691 		bytes_read += ret;  in mtcp_readv()
1693 		if (ret < iov[i].iov_len)  in mtcp_readv()
1732 	int ret;  in CopyFromUser()  local
1751 	ret = SBPut(mtcp->rbm_snd, sndvar->sndbuf, buf, sndlen);  in CopyFromUser()
1752 	assert(ret == sndlen);  in CopyFromUser()
1754 	if (ret <= 0) {  in CopyFromUser()
1756 				ret, sndlen, sndvar->sndbuf->len);  in CopyFromUser()
1766 	return ret;  in CopyFromUser()
1776 	int ret;  in mtcp_write()  local
1827 	ret = CopyFromUser(mtcp, cur_stream, buf, len);  in mtcp_write()
1831 	if (ret > 0 && !(sndvar->on_sendq || sndvar->on_send_list)) {  in mtcp_write()
1839 	if (ret == 0 && (socket->opts & MTCP_NONBLOCK)) {  in mtcp_write()
1840 		ret = -1;  in mtcp_write()
1852 	TRACE_API("Stream %d: mtcp_write() returning %d\n", cur_stream->id, ret);  in mtcp_write()
1853 	return ret;  in mtcp_write()
1863 	int ret, to_write, i;  in mtcp_writev()  local
1907 		ret = CopyFromUser(mtcp, cur_stream, iov[i].iov_base, iov[i].iov_len);  in mtcp_writev()
1908 		if (ret <= 0)  in mtcp_writev()
1911 		to_write += ret;  in mtcp_writev()
1913 		if (ret < iov[i].iov_len)  in mtcp_writev()