3524
72%

Ran 07 Apr 2017 05:52PM UTC

Jobs 1

Files 445

Run time 24s

Badge

Embed ▾

pending completion

Build # 3524

Build Type

Pull #1884

travis-ci

Committed by

web-flow

Commit Message

Decouple the processing of new received messages from the dispatching to
user code
  - Separated the handling of batched received messages from the
    per-message dispatching of message to the user code. In order to
    accomplish this I had to keep the batch in memory while the processing
    of each message will draw from the in-memory batch until completely
    depleted.
    - Drawing flow controller permits on a per message basis (used to
      try to draw permits for the whole batch potentially deadlocking the
      whole subscriber), this addresses the deadlock condition raised here
      https://github.com/GoogleCloudPlatform/google-cloud-java/issues/1868
      - No longer using blocking flow controller, instead pausing and
        resuming pulls/streamed-messages based on the flow controller
        feedback and when new permits become available.
  - A separate executor for alarms (2 threads in it has showed up to
    scale pretty well with many subscriber, given our ack operations
    are pretty lightweight)
  - Setting the maximum of messages to pull per request based on the
    number requested by the user in the flow controller (if any), this
    in a best effort addresses
    https://github.com/GoogleCloudPlatform/google-cloud-java/issues/1868

Fixes #1868, fixes #1865 and fixes #1855

Pull Request Pull Request #1884: Deadlock issues

Run Details

18628 of 22987 relevant lines covered (81.04%)

124.82 hits per line

Jobs

ID	Job ID	Ran	Files	Coverage
2	3524.2	07 Apr 2017 05:52PM UTC	0	81.04	Travis Job 3524.2

Source Files on build 3524

Detailed source file information is not available for this build.

GoogleCloudPlatform / google-cloud-java / 3524
72%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

Jobs

Source Files on build 3524

GoogleCloudPlatform / google-cloud-java / 3524 72%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

Jobs

Source Files on build 3524

GoogleCloudPlatform / google-cloud-java / 3524
72%

README BADGES
x