You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by wu...@apache.org on 2019/11/15 15:33:49 UTC
[skywalking] branch master updated (e8f6789 -> d7038fe)
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/skywalking.git.
from e8f6789 Make kafka-scenario stable (#3866)
add d7038fe Refactor DataCarrier, support ArrayBlockingQueueBuffer as implementor (#3849)
No new revisions were added by this update.
Summary of changes:
.../commons/datacarrier/BlockingDataCarrier.java | 37 ---------
.../apm/commons/datacarrier/DataCarrier.java | 5 --
.../buffer/ArrayBlockingQueueBuffer.java | 69 ++++++++++++++++
.../apm/commons/datacarrier/buffer/Buffer.java | 30 ++-----
.../commons/datacarrier/buffer/BufferStrategy.java | 1 -
.../apm/commons/datacarrier/buffer/Channels.java | 25 +++---
.../{BufferStrategy.java => QueueBuffer.java} | 32 ++++++--
.../callback/QueueBlockingCallback.java | 28 -------
.../datacarrier/consumer/ConsumeDriver.java | 54 ++++---------
.../datacarrier/consumer/ConsumerThread.java | 29 ++-----
.../consumer/MultipleChannelsConsumer.java | 7 +-
.../apm/commons/datacarrier/DataCarrierTest.java | 49 ++++--------
.../datacarrier/consumer/BulkConsumePoolTest.java | 91 ----------------------
.../commons/datacarrier/consumer/ConsumerTest.java | 2 +-
.../core/remote/client/GRPCRemoteClient.java | 2 -
15 files changed, 154 insertions(+), 307 deletions(-)
delete mode 100644 apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/BlockingDataCarrier.java
create mode 100644 apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/buffer/ArrayBlockingQueueBuffer.java
copy apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/buffer/{BufferStrategy.java => QueueBuffer.java} (62%)
delete mode 100644 apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/callback/QueueBlockingCallback.java
delete mode 100644 apm-commons/apm-datacarrier/src/test/java/org/apache/skywalking/apm/commons/datacarrier/consumer/BulkConsumePoolTest.java