[qpid-site] 01/02: fix up current releases entries
This is an automated email from the ASF dual-hosted git repository. robbie pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/qpid-site.git commit d88838c35c6179c8d82c5f3cb6fd8c31ab8d28c1 Author: Robbie Gemmell AuthorDate: Fri Jul 2 10:23:52 2021 +0100 fix up current releases entries --- input/releases/index.md | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/input/releases/index.md b/input/releases/index.md index 7e7eba5..e0db6bb 100644 --- a/input/releases/index.md +++ b/input/releases/index.md @@ -28,13 +28,12 @@ the - [Qpid Broker-J 8.0.5](qpid-broker-j-8.0.5/index.html), June 2021 - - [Qpid ProtonJ2 1.0.0-M1](qpid-protonj2-1.0.0-M2/index.html), May 2021 + - [Qpid ProtonJ2 1.0.0-M2](qpid-protonj2-1.0.0-M2/index.html), May 2021 + - [Qpid Dispatch 1.16.0](qpid-dispatch-1.16.0/index.html), May 2021 - [Qpid JMS 1.0.0](qpid-jms-1.0.0/index.html), May 2021 - [Qpid JMS 0.59.0](qpid-jms-0.59.0/index.html), May 2021 - - [Qpid ProtonJ2 1.0.0-M1](qpid-protonj2-1.0.0-M1/index.html), May 2021 - [Qpid Proton 0.34.0](qpid-proton-0.34.0/index.html), April 2021 - [Qpid Broker-J 7.1.12](qpid-broker-j-7.1.12/index.html), February 2021 - - [Qpid Dispatch 1.16.0](qpid-dispatch-1.16.0/index.html), May 2021 - [Qpid Proton-J 0.33.8](qpid-proton-j-0.33.8/index.html), November 2020 - [Qpid JMS AMQP 0-x 6.4.0](qpid-jms-amqp-0-x-6.4.0/index.html), June 2020 - [Qpid C++ 1.39.0](qpid-cpp-1.39.0/index.html), October 2018 - To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
[qpid-dispatch] branch main updated: NO-JIRA: Replace tab characters with spaces
This is an automated email from the ASF dual-hosted git repository. chug pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/qpid-dispatch.git The following commit(s) were added to refs/heads/main by this push: new d7688f4 NO-JIRA: Replace tab characters with spaces d7688f4 is described below commit d7688f473459909288bc833be25d801ed1849596 Author: Chuck Rolke AuthorDate: Fri Jul 2 10:09:31 2021 -0400 NO-JIRA: Replace tab characters with spaces --- src/adaptors/tcp_adaptor.c | 12 ++-- 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/adaptors/tcp_adaptor.c b/src/adaptors/tcp_adaptor.c index af5faa6..a5bd0d4 100644 --- a/src/adaptors/tcp_adaptor.c +++ b/src/adaptors/tcp_adaptor.c @@ -79,8 +79,8 @@ struct qdr_tcp_connection_t { bool egress_dispatcher; bool connector_closed;//only used if egress_dispatcher=true bool in_list; // This connection is in the adaptor's connections list -sys_atomic_t raw_closed_read; // proton event seen -sys_atomic_t raw_closed_write; // proton event seen or write_close called +sys_atomic_t raw_closed_read; // proton event seen +sys_atomic_t raw_closed_write; // proton event seen or write_close called bool raw_read_shutdown; // stream closed bool read_eos_seen; qdr_delivery_t *initial_delivery; @@ -381,7 +381,7 @@ static int handle_incoming(qdr_tcp_connection_t *conn, const char *msg) int count = handle_incoming_raw_read(conn, &buffers); // Grant more buffers to proton for reading if read side is still open - grant_read_buffers(conn); +grant_read_buffers(conn); // Push the bytes just read into the streaming message if (count > 0) { @@ -721,7 +721,7 @@ static void qdr_tcp_connection_ingress_accept(qdr_tcp_connection_t* tc) "", // *ssl_cipher, "", // *user, "TcpAdaptor",// *container, - tcp_conn_properties, // *connection_properties, + tcp_conn_properties, // *connection_properties, 0, // ssl_ssf, false, // ssl, "", // peer router version, @@ -983,7 +983,7 @@ static void qdr_tcp_open_server_side_connection(qdr_tcp_connection_t* tc) "", //const char *ssl_cipher, "", //const char *user, "TcpAdaptor",//const char *container, - tcp_conn_properties,// pn_data_t *connection_properties, + tcp_conn_properties,// pn_data_t *connection_properties, 0, //int ssl_ssf, false, //bool ssl, "", // peer router version, @@ -1003,7 +1003,7 @@ static void qdr_tcp_open_server_side_connection(qdr_tcp_connection_t* tc) 250, // link_capacity 0, // vhost 0, // policy_spec - info, // connection_info + info,// connection_info 0, // context_binder 0); // bind_token tc->qdr_conn = conn; - To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
[qpid-proton] branch main updated: PROTON-2403: libuv proactor update for newer libuv library versions
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 The following commit(s) were added to refs/heads/main by this push: new 471d043 PROTON-2403: libuv proactor update for newer libuv library versions 471d043 is described below commit 471d043db648e9fc855ae2d9330fa5dfb4332dd3 Author: Cliff Jansen AuthorDate: Fri Jul 2 09:46:05 2021 -0700 PROTON-2403: libuv proactor update for newer libuv library versions --- c/src/proactor/libuv.c | 11 +-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/c/src/proactor/libuv.c b/c/src/proactor/libuv.c index 3e50685..b450919 100644 --- a/c/src/proactor/libuv.c +++ b/c/src/proactor/libuv.c @@ -177,6 +177,7 @@ typedef struct pconnection_t { uv_timer_t timer; uv_write_t write; size_t writing; /* size of pending write request, 0 if none pending */ + bool read_started; uv_shutdown_t shutdown; /* Locked for thread-safe access */ @@ -936,9 +937,12 @@ static bool leader_process_pconnection(pconnection_t *pc) { uv_shutdown(&pc->shutdown, (uv_stream_t*)&pc->tcp, NULL); } } - if (!err && rbuf.size > 0) { + if (!err && !pc->read_started && rbuf.size > 0) { what = "read"; err = uv_read_start((uv_stream_t*)&pc->tcp, alloc_read_buffer, on_read); +if (!err) { + pc->read_started = true; +} } if (err) { /* Some IO requests failed, generate the error events */ @@ -952,7 +956,10 @@ static bool leader_process_pconnection(pconnection_t *pc) { /* Detach a connection from the UV loop so it can be used safely by a worker */ void pconnection_detach(pconnection_t *pc) { if (pc->connected && !pc->writing) { /* Can't detach while a write is pending */ -uv_read_stop((uv_stream_t*)&pc->tcp); +if (pc->read_started) { + uv_read_stop((uv_stream_t*)&pc->tcp); + pc->read_started = false; +} uv_timer_stop(&pc->timer); } } - To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org