Lab_NHMFL
/
upsilon
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

check hangup

This commit is contained in:
Peter McGoron 2023-04-03 18:24:50 +00:00
parent 1e0ae4b432
commit 9df7126566
1 changed files with 19 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
software/src/main.c
View File

@ -58,6 +58,18 @@ static const char *const run_ret_str[CREOLE_RUN_RET_LEN] = {
[CREOLE_JUMP_OVERFLOW] = "jump overflow" [CREOLE_JUMP_OVERFLOW] = "jump overflow"
}; };
static int
hup(int sock)
{
struct zsock_pollfd fd = {
.fd = sock,
.events = POLLHUP,
.revents = 0
};
return zsock_pollfd(&fd, 1, 0);
}
static void static void
exec_creole(unsigned char *buf, int size, int sock) exec_creole(unsigned char *buf, int size, int sock)
{#define DATLEN 64 {#define DATLEN 64
@ -104,6 +116,11 @@ exec_creole(unsigned char *buf, int size, int sock)
creole_run_ret[e]); creole_run_ret[e]);
return; return;
} }
if (hup(sock) != 0) {
LOG_WRN("%s: hangup", get_thread_name());
return;
}
} }
} }
@ -115,8 +132,8 @@ exec_entry(void *client_p, void *threadnum_p,
intptr_t threadnum = threadnum_p; intptr_t threadnum = threadnum_p;
int size = read_size(client); int size = read_size(client);
const char thread_name[32]; const char thread_name[64];
vsnprintk(thread_name, sizeof(thread_name), "%d", client); vsnprintk(thread_name, sizeof(thread_name), "%d:%d", client, threadnum);
k_thread_name_set(k_current_get(), thread_name); k_thread_name_set(k_current_get(), thread_name);
LOG_INF("%s: Connection initiated", thread_name); LOG_INF("%s: Connection initiated", thread_name);