aiden
/
bidirectiond
1
1
Fork 0
Code Issues 13 Projects Releases 3 Wiki Activity

bdd_io_blocking, bdd_io_epoll_events, bdd_io_set_blocking

This commit is contained in:
aiden 2022-05-16 12:14:49 +01:00
parent 5c680a2ec6
commit 45b7ff20fb
No known key found for this signature in database
GPG Key ID: 0D87FF3415416DB1
3 changed files with 71 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/core/services.h
View File

@ -52,5 +52,7 @@ bool bdd_name_descriptions_add_service_instance(
);
bool bdd_io_set_epoll_events(struct bdd_conversation *conversation, bdd_io_id io_id, short int epoll_events);
bool bdd_io_set_blocking(struct bdd_conversation *conversation, bdd_io_id io_id, bool block);
short int bdd_io_epoll_events(struct bdd_conversation *conversation, bdd_io_id io_id);
bool bdd_io_blocking(struct bdd_conversation *conversation, bdd_io_id io_id);
#endif

71
src/core/src/conversations.c
View File

@ -478,7 +478,7 @@ enum bdd_io_shutdown_state bdd_io_shutdown(struct bdd_conversation *conversation
}
struct bdd_io *io = &(conversation->io[io_id]);
if (bdd_io_state(io) != BDD_IO_STATE_SSL_CONNECTING && bdd_io_state(io) != BDD_IO_STATE_ESTABLISHED) {
err = "programming error: bdd_io_shutdown called with an io_id which is in a state which is not BDD_IO_STATE_SSL_CONNECTING and is not BDD_IO_STATE_ESTABLISHED\n";
err = "programming error: bdd_io_shutdown called with an io_id which is in an invalid state\n";
goto err;
}
if (
@ -557,8 +557,14 @@ bool bdd_io_set_blocking(struct bdd_conversation *conversation, bdd_io_id io_id,
return false;
}
struct bdd_io *io = &(conversation->io[io_id]);
if (bdd_io_state(io) == BDD_IO_STATE_UNUSED || bdd_io_state(io) == BDD_IO_STATE_BROKEN) {
fputs("programming error: bdd_io_set_blocking called with an io_id which is in a state equal to BDD_IO_STATE_UNUSED or a state equal to BDD_IO_STATE_BROKEN\n", stderr);
if (
bdd_io_state(io) != BDD_IO_STATE_CREATED &&
bdd_io_state(io) != BDD_IO_STATE_CONNECT &&
bdd_io_state(io) != BDD_IO_STATE_CONNECTING &&
bdd_io_state(io) != BDD_IO_STATE_SSL_CONNECTING &&
bdd_io_state(io) != BDD_IO_STATE_ESTABLISHED
) {
fputs("programming error: bdd_io_set_blocking called with an io_id which is in an invalid state\n", stderr);
assert(false);
return false;
}
@ -568,9 +574,9 @@ bool bdd_io_set_blocking(struct bdd_conversation *conversation, bdd_io_id io_id,
return false;
}
if (block) {
flags |= O_NONBLOCK;
} else {
flags &= ~(O_NONBLOCK);
} else {
flags |= O_NONBLOCK;
}
if (fcntl(fd, F_SETFL, flags) == -1) {
return false;
@ -584,8 +590,14 @@ bool bdd_io_set_epoll_events(struct bdd_conversation *conversation, bdd_io_id io
return false;
}
struct bdd_io *io = &(conversation->io[io_id]);
if (bdd_io_state(io) == BDD_IO_STATE_UNUSED || bdd_io_state(io) == BDD_IO_STATE_BROKEN) {
fputs("programming error: bdd_io_set_epoll_events called with an io_id which is in a state equal to BDD_IO_STATE_UNUSED or a state equal to BDD_IO_STATE_BROKEN\n", stderr);
if (
bdd_io_state(io) != BDD_IO_STATE_CREATED &&
bdd_io_state(io) != BDD_IO_STATE_CONNECT &&
bdd_io_state(io) != BDD_IO_STATE_CONNECTING &&
bdd_io_state(io) != BDD_IO_STATE_SSL_CONNECTING &&
bdd_io_state(io) != BDD_IO_STATE_ESTABLISHED
) {
fputs("programming error: bdd_io_set_epoll_events called with an io_id which is in an invalid state\n", stderr);
assert(false);
return false;
}
@ -595,6 +607,51 @@ bool bdd_io_set_epoll_events(struct bdd_conversation *conversation, bdd_io_id io
io->epoll_events = epoll_events;
return true;
}
bool bdd_io_blocking(struct bdd_conversation *conversation, bdd_io_id io_id) {
if (conversation == NULL || io_id < 0 || io_id >= bdd_conversation_n_max_io(conversation)) {
fputs("programming error: bdd_io_blocking called with invalid arguments\n", stderr);
assert(false);
return false;
}
struct bdd_io *io = &(conversation->io[io_id]);
if (
bdd_io_state(io) != BDD_IO_STATE_CREATED &&
bdd_io_state(io) != BDD_IO_STATE_CONNECT &&
bdd_io_state(io) != BDD_IO_STATE_CONNECTING &&
bdd_io_state(io) != BDD_IO_STATE_SSL_CONNECTING &&
bdd_io_state(io) != BDD_IO_STATE_ESTABLISHED
) {
fputs("programming error: bdd_io_blocking called with an io_id which is in an invalid state\n", stderr);
assert(false);
return false;
}
int fd = bdd_io_fd(io);
int flags = fcntl(fd, F_GETFL, 0);
if (flags == -1) {
return false;
}
return (flags & O_NONBLOCK) ? false : true;
}
short int bdd_io_epoll_events(struct bdd_conversation *conversation, bdd_io_id io_id) {
if (conversation == NULL || io_id < 0 || io_id >= bdd_conversation_n_max_io(conversation)) {
fputs("programming error: bdd_io_epoll_events called with invalid arguments\n", stderr);
assert(false);
return -1;
}
struct bdd_io *io = &(conversation->io[io_id]);
if (
bdd_io_state(io) != BDD_IO_STATE_CREATED &&
bdd_io_state(io) != BDD_IO_STATE_CONNECT &&
bdd_io_state(io) != BDD_IO_STATE_CONNECTING &&
bdd_io_state(io) != BDD_IO_STATE_SSL_CONNECTING &&
bdd_io_state(io) != BDD_IO_STATE_ESTABLISHED
) {
fputs("programming error: bdd_io_epoll_events called with an io_id which is in an invalid state\n", stderr);
assert(false);
return -1;
}
return io->epoll_events;
}
enum bdd_conversation_init_status bdd_conversation_init(
struct bdd_conversation *conversation,

10
src/core/src/headers/bdd_io.h
View File

@ -6,11 +6,11 @@
#define BDD_IO_STATE_UNUSED 0
#define BDD_IO_STATE_CREATED 1
#define BDD_IO_STATE_CONNECT 3
#define BDD_IO_STATE_CONNECTING 4
#define BDD_IO_STATE_SSL_CONNECTING 5
#define BDD_IO_STATE_ESTABLISHED 6
#define BDD_IO_STATE_BROKEN 7
#define BDD_IO_STATE_CONNECT 2
#define BDD_IO_STATE_CONNECTING 3
#define BDD_IO_STATE_SSL_CONNECTING 4
#define BDD_IO_STATE_ESTABLISHED 5
#define BDD_IO_STATE_BROKEN 6
struct bdd_io {
short int epoll_events;