d/ppd
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

echo

Browse Source
This commit is contained in:
quackerd 2023-03-12 14:13:10 +01:00
parent 62dddff785
commit b67f77e824
3 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dsmbr/dsmbr.cc
View File

@ -269,7 +269,7 @@ dsmbr_conn_create(void *thrd_ctx)
bsock_ctx = (void *)(uintptr_t)conn_fd;
}
conn->bsock = bsock_create(bsock_ctx, &io, BSOCK_BUF_SZ, BSOCK_BUF_SZ);
conn->bsock = bsock_create(bsock_ctx, &io, BSOCK_BUF_SZ, 0);
conn->ia_gen = createGenerator(options.ia_dist);
if (conn->ia_gen == NULL) {

3
modules/echo/ppd_mod.c
View File

@ -40,7 +40,8 @@ conn_send_cb(UNUSED const char *out, UNUSED size_t sz, size_t *out_sz, UNUSED vo
return 0;
}
static struct ppd_mod_info minfo = { .global_init_cb = global_init_cb,
static struct ppd_mod_info minfo = { .name = "ECHO",
.global_init_cb = global_init_cb,
.thread_create_cb = thread_create_cb,
.conn_create_cb = conn_create_cb,
.conn_destroy_cb = conn_destroy_cb,

4
ppd/ppd.cc
View File

@ -634,12 +634,12 @@ loop_main(int m_kq, std::vector<struct ppd_thread_ctx *> *workers)
conn->ssl_io_ctx.ssl = conn->ssl;
conn->ssl_io_ctx.ssl_readbuf_len = BSOCK_BUF_SZ;
V("Established TLS on connection %d...\n", conn_fd);
conn->bsock = bsock_create((void*)&conn->ssl_io_ctx, &io, BSOCK_BUF_SZ, BSOCK_BUF_SZ);
conn->bsock = bsock_create((void*)&conn->ssl_io_ctx, &io, BSOCK_BUF_SZ, 0);
} else {
conn->ssl = nullptr;
conn->ssl_readbuf = nullptr;
struct bsock_ringbuf_io io = bsock_io_posix();
conn->bsock = bsock_create((void*)(uintptr_t)conn_fd, &io, BSOCK_BUF_SZ, BSOCK_BUF_SZ);
conn->bsock = bsock_create((void*)(uintptr_t)conn_fd, &io, BSOCK_BUF_SZ, 0);
}
if (conn->bsock == nullptr) {