You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by cl...@apache.org on 2023/09/14 05:14:28 UTC
[qpid-proton] 02/02: PROTON-2764: schedule failed raw connections from pn_listener_raw_accept() so they can process events and cleanup
This is an automated email from the ASF dual-hosted git repository.
cliffjansen pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/qpid-proton.git
commit c542df80c51abdc52ccde9eb7b581922563e8240
Author: Clifford Jansen <cl...@apache.org>
AuthorDate: Wed Sep 13 19:18:24 2023 -0700
PROTON-2764: schedule failed raw connections from pn_listener_raw_accept() so they can process events and cleanup
---
c/src/proactor/epoll_raw_connection.c | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/c/src/proactor/epoll_raw_connection.c b/c/src/proactor/epoll_raw_connection.c
index 83f950b02..7e4dcb4a4 100644
--- a/c/src/proactor/epoll_raw_connection.c
+++ b/c/src/proactor/epoll_raw_connection.c
@@ -244,10 +244,12 @@ void pn_listener_raw_accept(pn_listener_t *l, pn_raw_connection_t *rc) {
praw_connection_connected_lh(prc);
} else {
psocket_error(prc, err, "pn_listener_accept");
+ pni_raw_connect_failed(&prc->raw_connection);
+ notify = schedule(&prc->task);
}
if (!l->task.working && listener_has_event(l)) {
- notify = schedule(&l->task);
+ notify |= schedule(&l->task);
}
unlock(&prc->task.mutex);
unlock(&l->task.mutex);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org