wdye: clean up, add process.pid
All checks were successful
OpenBSD 7.5 Success
Alpine 3.20 Success

This commit is contained in:
Přemysl Eric Janouch 2025-01-07 03:07:39 +01:00
parent 6c47e384f5
commit 51231d84ba
Signed by: p
GPG Key ID: A0420B94F92B9493
3 changed files with 23 additions and 15 deletions

View File

@ -25,7 +25,9 @@ cat:send("Closing...\r"):send("\004")
local v = expect(cat:eof {true}, local v = expect(cat:eof {true},
cat:default {.5, function (p) error "expected EOF, got a timeout" end}) cat:default {.5, function (p) error "expected EOF, got a timeout" end})
assert(cat.pid > 0, "process has no ID")
local s1, exit, signal = cat:wait () local s1, exit, signal = cat:wait ()
assert(s1 == 0 and exit == 0 and not signal, "unexpected exit status") assert(s1 == 0 and exit == 0 and not signal, "unexpected exit status")
assert(cat.pid < 0, "process still has an ID")
local s2 = cat:wait (true) local s2 = cat:wait (true)
assert(s1 == s2, "exit status not remembered") assert(s1 == s2, "exit status not remembered")

View File

@ -31,7 +31,7 @@ The *env* map may be used to override environment variables, notably _TERM_.
Variables evaluating to _false_ will be removed from the environment. Variables evaluating to _false_ will be removed from the environment.
The program's whole process group receives SIGKILL when the _process_ The program's whole process group receives SIGKILL when the _process_
is garbage-collected. is garbage-collected, unless *wait* has collected the process group leader.
wdye.expect ([pattern1, ...]) wdye.expect ([pattern1, ...])
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
@ -57,6 +57,10 @@ PROCESS.buffer
~~~~~~~~~~~~~~ ~~~~~~~~~~~~~~
A string with the _process_' current read buffer contents. A string with the _process_' current read buffer contents.
PROCESS.pid
~~~~~~~~~~~
An integer with the _process_' process ID, or -1 if *wait* has collected it.
PROCESS.term PROCESS.term
~~~~~~~~~~~~ ~~~~~~~~~~~~
A table with the _process_' *terminfo*(5) capabilities, A table with the _process_' *terminfo*(5) capabilities,

View File

@ -175,7 +175,7 @@ pty_fork (int *ptrfdm, char **slave_name,
char *pts_name = NULL; char *pts_name = NULL;
if ((fdm = ptym_open (&pts_name)) < 0) if ((fdm = ptym_open (&pts_name)) < 0)
{ {
error_set (e, "cant open master pty: %s", strerror (errno)); error_set (e, "can't open master pty: %s", strerror (errno));
return -1; return -1;
} }
if (slave_name != NULL) if (slave_name != NULL)
@ -194,7 +194,7 @@ pty_fork (int *ptrfdm, char **slave_name,
if (setsid () < 0) if (setsid () < 0)
exit_fatal ("setsid: %s", strerror (errno)); exit_fatal ("setsid: %s", strerror (errno));
if ((fds = ptys_open (pts_name)) < 0) if ((fds = ptys_open (pts_name)) < 0)
exit_fatal ("cant open slave pty: %s", strerror (errno)); exit_fatal ("can't open slave pty: %s", strerror (errno));
xclose (fdm); xclose (fdm);
#if defined BSD #if defined BSD
@ -401,7 +401,7 @@ xlua_pattern_index (lua_State *L)
if (!strcmp (key, "process")) if (!strcmp (key, "process"))
lua_rawgeti (L, LUA_REGISTRYINDEX, self->ref_process); lua_rawgeti (L, LUA_REGISTRYINDEX, self->ref_process);
else else
return luaL_argerror (L, 2, "not a readable property"); return luaL_error (L, "not a readable property: %s", key);
return 1; return 1;
} }
@ -411,8 +411,8 @@ xlua_pattern_index (lua_State *L)
case PATTERN_REGEX: case PATTERN_REGEX:
{ {
const regmatch_t *m = self->matches + group; const regmatch_t *m = self->matches + group;
if (group < 0 || group > self->regex->re_nsub if (group < 0 || (size_t) group > self->regex->re_nsub
|| m->rm_so < 0 || m->rm_eo < 0 || m->rm_eo > self->input.len) || m->rm_so < 0 || m->rm_eo < 0 || (size_t) m->rm_eo > self->input.len)
lua_pushnil (L); lua_pushnil (L);
else else
lua_pushlstring (L, lua_pushlstring (L,
@ -428,7 +428,7 @@ xlua_pattern_index (lua_State *L)
lua_pushlstring (L, self->input.str, self->input.len); lua_pushlstring (L, self->input.str, self->input.len);
return 1; return 1;
default: default:
return luaL_argerror (L, 2, "indexing unavailable for this pattern"); return luaL_argerror (L, 1, "indexing unavailable for this pattern");
} }
} }
@ -519,10 +519,12 @@ xlua_process_index (lua_State *L)
if (!strcmp (key, "buffer")) if (!strcmp (key, "buffer"))
lua_pushlstring (L, self->buffer.str, self->buffer.len); lua_pushlstring (L, self->buffer.str, self->buffer.len);
else if (!strcmp (key, "pid"))
lua_pushinteger (L, self->pid);
else if (!strcmp (key, "term")) else if (!strcmp (key, "term"))
lua_rawgeti (L, LUA_REGISTRYINDEX, self->ref_term); lua_rawgeti (L, LUA_REGISTRYINDEX, self->ref_term);
else else
return luaL_argerror (L, 2, "not a readable property"); return luaL_error (L, "not a readable property: %s", key);
return 1; return 1;
} }
@ -542,7 +544,7 @@ xlua_process_send (lua_State *L)
ssize_t written = write (self->terminal_fd, arg, len); ssize_t written = write (self->terminal_fd, arg, len);
if (written == -1) if (written == -1)
return luaL_error (L, "write failed: %s", strerror (errno)); return luaL_error (L, "write failed: %s", strerror (errno));
else if (written != len) else if (written != (ssize_t) len)
return luaL_error (L, "write failed: %s", "short write"); return luaL_error (L, "write failed: %s", "short write");
if (self->asciicast) if (self->asciicast)
@ -560,7 +562,7 @@ xlua_process_send (lua_State *L)
static int static int
xlua_process_regex (lua_State *L) xlua_process_regex (lua_State *L)
{ {
struct process *self = luaL_checkudata (L, 1, XLUA_PROCESS_METATABLE); (void) luaL_checkudata (L, 1, XLUA_PROCESS_METATABLE);
luaL_checktype (L, 2, LUA_TTABLE); luaL_checktype (L, 2, LUA_TTABLE);
if (lua_gettop (L) != 2) if (lua_gettop (L) != 2)
return luaL_error (L, "too many arguments"); return luaL_error (L, "too many arguments");
@ -593,7 +595,7 @@ xlua_process_regex (lua_State *L)
static int static int
xlua_process_exact (lua_State *L) xlua_process_exact (lua_State *L)
{ {
struct process *self = luaL_checkudata (L, 1, XLUA_PROCESS_METATABLE); (void) luaL_checkudata (L, 1, XLUA_PROCESS_METATABLE);
luaL_checktype (L, 2, LUA_TTABLE); luaL_checktype (L, 2, LUA_TTABLE);
if (lua_gettop (L) != 2) if (lua_gettop (L) != 2)
return luaL_error (L, "too many arguments"); return luaL_error (L, "too many arguments");
@ -618,7 +620,7 @@ xlua_process_exact (lua_State *L)
static int static int
xlua_process_eof (lua_State *L) xlua_process_eof (lua_State *L)
{ {
struct process *self = luaL_checkudata (L, 1, XLUA_PROCESS_METATABLE); (void) luaL_checkudata (L, 1, XLUA_PROCESS_METATABLE);
luaL_checktype (L, 2, LUA_TTABLE); luaL_checktype (L, 2, LUA_TTABLE);
if (lua_gettop (L) != 2) if (lua_gettop (L) != 2)
return luaL_error (L, "too many arguments"); return luaL_error (L, "too many arguments");
@ -634,7 +636,7 @@ xlua_process_eof (lua_State *L)
static int static int
xlua_process_default (lua_State *L) xlua_process_default (lua_State *L)
{ {
struct process *self = luaL_checkudata (L, 1, XLUA_PROCESS_METATABLE); (void) luaL_checkudata (L, 1, XLUA_PROCESS_METATABLE);
luaL_checktype (L, 2, LUA_TTABLE); luaL_checktype (L, 2, LUA_TTABLE);
if (lua_gettop (L) != 2) if (lua_gettop (L) != 2)
return luaL_error (L, "too many arguments"); return luaL_error (L, "too many arguments");
@ -1081,7 +1083,7 @@ expect_prepare_pattern (struct expect_context *ctx, struct pattern *p)
{ {
str_reset (&p->input); str_reset (&p->input);
if (p->kind == PATTERN_REGEX) if (p->kind == PATTERN_REGEX)
for (int i = 0; i <= p->regex->re_nsub; i++) for (size_t i = 0; i <= p->regex->re_nsub; i++)
p->matches[i] = (regmatch_t) { .rm_so = -1, .rm_eo = -1 }; p->matches[i] = (regmatch_t) { .rm_so = -1, .rm_eo = -1 };
if (p->kind == PATTERN_REGEX if (p->kind == PATTERN_REGEX
@ -1168,7 +1170,7 @@ pattern_match (struct pattern *self)
if (regexec (self->regex, buffer->str, if (regexec (self->regex, buffer->str,
self->regex->re_nsub + 1, self->matches, flags)) self->regex->re_nsub + 1, self->matches, flags))
{ {
for (int i = 0; i <= self->regex->re_nsub; i++) for (size_t i = 0; i <= self->regex->re_nsub; i++)
self->matches[i] = (regmatch_t) { .rm_so = -1, .rm_eo = -1 }; self->matches[i] = (regmatch_t) { .rm_so = -1, .rm_eo = -1 };
return false; return false;
} }