nikto_b/hmmmm
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Request reset at config upload, increase client req handling freq on idle

Browse Source
This commit is contained in:
root
2026-04-24 14:48:17 +03:00
parent 14b005dbb3
commit 7a272788f8
3 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

BIN
src/.main.c.swp Normal file
View File

Binary file not shown.

4
src/main.c
View File

@@ -167,7 +167,7 @@ void my_sleep(int microseconds) {
// Compact threshold: if a client has more than this many messages in a single // Compact threshold: if a client has more than this many messages in a single
// outgoing buffer that all arrived within COMPACT_WINDOW_US, pack them into // outgoing buffer that all arrived within COMPACT_WINDOW_US, pack them into
// a single CompactedMessage frame to reduce ws_sendframe_bin syscall overhead. // a single CompactedMessage frame to reduce ws_sendframe_bin syscall overhead.
#define COMPACT_THRESHOLD 4 #define COMPACT_THRESHOLD 10
#define COMPACT_WINDOW_US 100000ULL // 100 ms #define COMPACT_WINDOW_US 100000ULL // 100 ms
static void compact_outgoing_buffer(SizedPtr* buf) static void compact_outgoing_buffer(SizedPtr* buf)
@@ -570,7 +570,7 @@ int main(int argc, char** argv)
} }
if (clients_try_timer == 0) if (clients_try_timer == 0 || emulState != EMUL_STATE_EXEC)
{ {
if(getCurrentUsec() - lastTickCountWindowAt > 1000000) if(getCurrentUsec() - lastTickCountWindowAt > 1000000)

2
src/proto/handlers/config.c
View File

@@ -601,6 +601,7 @@ void handleConfigCtrlMessage(
return; return;
} }
printf("[CTRL/CONFIG] loaded %zu devices\n", st.count); printf("[CTRL/CONFIG] loaded %zu devices\n", st.count);
// Apply projections // Apply projections
@@ -733,6 +734,7 @@ void handleConfigCtrlMessage(
st.seg_names[i][j] = strdup(handl->ctx->deviceMem->memsegNames[j]); st.seg_names[i][j] = strdup(handl->ctx->deviceMem->memsegNames[j]);
} }
} }
*emulContext->resetRequest = 1;
uint8_t* out = fb_build_config_device_id_mapping( uint8_t* out = fb_build_config_device_id_mapping(
nonce, st.paths, st.path_lens, st.seg_names, st.seg_counts, dc, &msg_len); nonce, st.paths, st.path_lens, st.seg_names, st.seg_counts, dc, &msg_len);