Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Ack handler #2516

Merged
merged 29 commits into from
Jul 31, 2019
Merged

Ack handler #2516

merged 29 commits into from
Jul 31, 2019

Commits on Jul 25, 2019

  1. Merge condtion 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    f467eda View commit details
    Browse the repository at this point in the history

  2. Wrap mutex and waiting queue 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    d452d50 View commit details
    Browse the repository at this point in the history

  3. create ACKWaitingSockInfo in enqueue 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    1bc39a4 View commit details
    Browse the repository at this point in the history

  4. share ack_handler between nodes 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    69af0cb View commit details
    Browse the repository at this point in the history

  5. Copy read_ack_from_sock 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    a94646d View commit details
    Browse the repository at this point in the history

  6. log 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    77488a1 View commit details
    Browse the repository at this point in the history

  7. trim receiver 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    a21e94c View commit details
    Browse the repository at this point in the history

  8. make find and delete private 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    f22490a View commit details
    Browse the repository at this point in the history

  9. move code and return chunk_id directly 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    f6d0765 View commit details
    Browse the repository at this point in the history

  10. Return the value success or not and info 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    a1d87f0 View commit details
    Browse the repository at this point in the history

  11. copy ack_reader 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    c9f4e9a View commit details
    Browse the repository at this point in the history

  12. same class 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    5d6e700 View commit details
    Browse the repository at this point in the history

  13. log 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    0d4435b View commit details
    Browse the repository at this point in the history

  14. pass success or not to caller 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    41e4b50 View commit details
    Browse the repository at this point in the history

  15. readable_sockets can be nil 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    f6259c0 View commit details
    Browse the repository at this point in the history

  16. Move method position and remove unused code 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    2623750 View commit details
    Browse the repository at this point in the history

  17. cosmetic change 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    f8aecda View commit details
    Browse the repository at this point in the history

  18. extract as file 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    c4b7629 View commit details
    Browse the repository at this point in the history

  19. move unapcker into ack_handler 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    3c637ac View commit details
    Browse the repository at this point in the history

  20. cosmetic change 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 25, 2019
    Configuration menu
    Copy the full SHA
    08a3954 View commit details
    Browse the repository at this point in the history

Commits on Jul 26, 2019

  1. Add result module 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 26, 2019
    Configuration menu
    Copy the full SHA
    1dcd3dc View commit details
    Browse the repository at this point in the history

  2. chunk_id is better 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 26, 2019
    Configuration menu
    Copy the full SHA
    3bac793 View commit details
    Browse the repository at this point in the history

  3. Fix failed test 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 26, 2019
    Configuration menu
    Copy the full SHA
    11a8232 View commit details
    Browse the repository at this point in the history

  4. Add test for ack_handler 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 26, 2019
    Configuration menu
    Copy the full SHA
    f6e4dda View commit details
    Browse the repository at this point in the history

  5. Add require for 

    Fluent::Engine.msgpack_unpacker
Fluent::PluginHelper::Socket::WrappedSocket::TLS

Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 26, 2019
    Configuration menu
    Copy the full SHA
    8940b4d View commit details
    Browse the repository at this point in the history

  6. Change method name to proper name 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 26, 2019
    Configuration menu
    Copy the full SHA
    134070d View commit details
    Browse the repository at this point in the history

  7. Change timeout to keyword arg 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 26, 2019
    Configuration menu
    Copy the full SHA
    cce3112 View commit details
    Browse the repository at this point in the history

Commits on Jul 30, 2019

  1. Calculate expired_time in advance 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 30, 2019
    Configuration menu
    Copy the full SHA
    bf149c8 View commit details
    Browse the repository at this point in the history

Commits on Jul 31, 2019

  1. add BUG prefix 

    Signed-off-by: Yuta Iwama <ganmacs@gmail.com>
    @ganmacs
    ganmacs committed Jul 31, 2019
    Configuration menu
    Copy the full SHA
    07a85d3 View commit details
    Browse the repository at this point in the history