You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2022/06/17 04:00:30 UTC

[pulsar] branch master updated (e685742cf70 -> 5fd6e5f3709)

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


    from e685742cf70 fix npe when doCacheEviction (#15184)
     add 5fd6e5f3709 [improve][proxy] Support zero-copy of NIC to NIC on Proxy (#15678)

No new revisions were added by this update.

Summary of changes:
 conf/proxy.conf                                    |  4 ++
 .../protocol/OptionalProxyProtocolDecoder.java     |  5 +++
 .../pulsar/proxy/server/DirectProxyHandler.java    | 32 +++++++++++---
 .../pulsar/proxy/server/ProxyConfiguration.java    |  5 +++
 .../pulsar/proxy/server/ProxyConnection.java       | 41 ++++++++++++++++++
 .../proxy/server/ProxyReadTimeoutHandler.java      | 30 ++++++++-----
 .../apache/pulsar/proxy/server/ProxyService.java   | 14 ++++++-
 .../proxy/server/ServiceChannelInitializer.java    |  3 +-
 .../proxy/server/ProxyDisableZeroCopyTest.java     | 49 ++++++++++++++++++++++
 .../ProxyServiceStarterDisableZeroCopyTest.java    | 27 ++++++------
 .../proxy/server/ProxyServiceStarterTest.java      | 23 +++++-----
 .../org/apache/pulsar/proxy/server/ProxyTest.java  |  5 +--
 pulsar-proxy/src/test/resources/proxy.conf         |  4 ++
 site2/docs/reference-configuration.md              |  1 +
 .../integration/containers/ProxyContainer.java     |  8 ++++
 15 files changed, 205 insertions(+), 46 deletions(-)
 copy pulsar-broker/src/test/java/org/apache/pulsar/socks5/handler/IdleHandler.java => pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyReadTimeoutHandler.java (50%)
 create mode 100644 pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyDisableZeroCopyTest.java
 copy pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentFailoverStreamingDispatcherE2ETest.java => pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyServiceStarterDisableZeroCopyTest.java (52%)