-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/25155/
-----------------------------------------------------------

(Updated Sept. 4, 2014, 8:26 p.m.)


Review request for kafka.


Bugs: KAFKA-1616
    https://issues.apache.org/jira/browse/KAFKA-1616


Repository: kafka


Description (updated)
-------

Purgatory size to be the sum of watched list sizes; delayed request to be the 
expiry queue length; remove atomic integers for metrics; add a unit test for 
watched list sizes and enqueued requests


Diffs (updated)
-----

  core/src/main/scala/kafka/server/RequestPurgatory.scala 
ce06d2c381348deef8559374869fcaed923da1d1 
  core/src/test/scala/unit/kafka/server/RequestPurgatoryTest.scala 
168712de241125982d556c188c76514fceb93779 

Diff: https://reviews.apache.org/r/25155/diff/


Testing
-------


Thanks,

Guozhang Wang

Reply via email to