-------------------------------------------------------------------------*\ * Waits for and returns a client object attempting connection to the * server object \*-------------------------------------------------------------------------*/
| 162 | * server object |
| 163 | \*-------------------------------------------------------------------------*/ |
| 164 | static int meth_accept(lua_State *L) { |
| 165 | p_unix server = (p_unix) auxiliar_checkclass(L, "unix{server}", 1); |
| 166 | p_timeout tm = timeout_markstart(&server->tm); |
| 167 | t_socket sock; |
| 168 | int err = socket_accept(&server->sock, &sock, NULL, NULL, tm); |
| 169 | /* if successful, push client socket */ |
| 170 | if (err == IO_DONE) { |
| 171 | p_unix clnt = (p_unix) lua_newuserdata(L, sizeof(t_unix)); |
| 172 | auxiliar_setclass(L, "unix{client}", -1); |
| 173 | /* initialize structure fields */ |
| 174 | socket_setnonblocking(&sock); |
| 175 | clnt->sock = sock; |
| 176 | io_init(&clnt->io, (p_send)socket_send, (p_recv)socket_recv, |
| 177 | (p_error) socket_ioerror, &clnt->sock); |
| 178 | timeout_init(&clnt->tm, -1, -1); |
| 179 | buffer_init(&clnt->buf, &clnt->io, &clnt->tm); |
| 180 | return 1; |
| 181 | } else { |
| 182 | lua_pushnil(L); |
| 183 | lua_pushstring(L, socket_strerror(err)); |
| 184 | return 2; |
| 185 | } |
| 186 | } |
| 187 | |
| 188 | /*-------------------------------------------------------------------------*\ |
| 189 | * Binds an object to an address |
nothing calls this directly
no test coverage detected