Lines Matching refs:ret
122 int ret; in SendUntilAvailable() local
131 ret = 1; in SendUntilAvailable()
132 while (ret > 0) { in SendUntilAvailable()
137 ret = mtcp_write(ctx->mctx, sockid, in SendUntilAvailable()
139 if (ret < 0) { in SendUntilAvailable()
142 "try: %d, sent: %d\n", sockid, len, ret); in SendUntilAvailable()
146 TRACE_APP("Socket %d: mtcp_write try: %d, ret: %d\n", sockid, len, ret); in SendUntilAvailable()
147 sent += ret; in SendUntilAvailable()
148 sv->total_sent += ret; in SendUntilAvailable()
310 int ret; in CreateListeningSocket() local
318 ret = mtcp_setsock_nonblock(ctx->mctx, listener); in CreateListeningSocket()
319 if (ret < 0) { in CreateListeningSocket()
328 ret = mtcp_bind(ctx->mctx, listener, in CreateListeningSocket()
330 if (ret < 0) { in CreateListeningSocket()
336 ret = mtcp_listen(ctx->mctx, listener, 4096); in CreateListeningSocket()
337 if (ret < 0) { in CreateListeningSocket()
356 int ret; in GlobInitServer() local
406 ret = read(fd, fcache[nfiles].file + total_read, in GlobInitServer()
408 if (ret < 0) { in GlobInitServer()
410 } else if (ret == 0) { in GlobInitServer()
413 total_read += ret; in GlobInitServer()
475 int i, ret; in RunServer() local
526 ret = HandleReadEvent(ctx, events[i].data.sock, in RunServer()
529 if (ret == 0) { in RunServer()
533 } else if (ret < 0) { in RunServer()
558 ret = AcceptConnection(ctx, ctx->listener); in RunServer()
559 if (ret < 0) in RunServer()
613 int ret/*, i*/; in main() local
639 ret = mtcp_init(fname); in main()
640 if (ret) { in main()