[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
