Lines Matching refs:ret
123 int ret; in SendUntilAvailable() local
132 ret = 1; in SendUntilAvailable()
133 while (ret > 0) { in SendUntilAvailable()
138 ret = mtcp_write(ctx->mctx, sockid, in SendUntilAvailable()
140 if (ret < 0) { in SendUntilAvailable()
143 "try: %d, sent: %d\n", sockid, len, ret); in SendUntilAvailable()
147 TRACE_APP("Socket %d: mtcp_write try: %d, ret: %d\n", sockid, len, ret); in SendUntilAvailable()
148 sent += ret; in SendUntilAvailable()
149 sv->total_sent += ret; in SendUntilAvailable()
311 int ret; in CreateListeningSocket() local
319 ret = mtcp_setsock_nonblock(ctx->mctx, listener); in CreateListeningSocket()
320 if (ret < 0) { in CreateListeningSocket()
329 ret = mtcp_bind(ctx->mctx, listener, in CreateListeningSocket()
331 if (ret < 0) { in CreateListeningSocket()
337 ret = mtcp_listen(ctx->mctx, listener, 4096); in CreateListeningSocket()
338 if (ret < 0) { in CreateListeningSocket()
357 int ret; in GlobInitServer() local
407 ret = read(fd, fcache[nfiles].file + total_read, in GlobInitServer()
409 if (ret < 0) { in GlobInitServer()
411 } else if (ret == 0) { in GlobInitServer()
414 total_read += ret; in GlobInitServer()
476 int i, ret; in RunServer() local
527 ret = HandleReadEvent(ctx, events[i].data.sock, in RunServer()
530 if (ret == 0) { in RunServer()
534 } else if (ret < 0) { in RunServer()
559 ret = AcceptConnection(ctx, ctx->listener); in RunServer()
560 if (ret < 0) in RunServer()
615 int ret, i; in main() local
634 ret = mtcp_init(fname); in main()
635 if (ret) { in main()