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

osd: optimize send_message to peers #30968

Merged
merged 6 commits into from Nov 19, 2019
Merged

osd: optimize send_message to peers #30968

merged 6 commits into from Nov 19, 2019

Commits on Oct 29, 2019

  1. osd: avoid check local dest when send message to osd cluster. 

    Signed-off-by: Jianpeng Ma <jianpeng.ma@intel.com>
    @majianpeng
    majianpeng committed Oct 29, 2019
    Configuration menu
    Copy the full SHA
    cef0799 View commit details
    Browse the repository at this point in the history

Commits on Nov 7, 2019

  1. osd: add new api send_message_osd_cluster(std::vector<std::pair<int,M… 

    …essage*>>& messages, epoch_t from_epoch).

Batch send message to osd cluster.

Signed-off-by: Jianpeng Ma <jianpeng.ma@intel.com>
    @majianpeng
    majianpeng committed Nov 7, 2019
    Configuration menu
    Copy the full SHA
    079dbff View commit details
    Browse the repository at this point in the history

  2. osd:using send_message_osd_cluster(Message*, const ConnectionRef) for… 

    … MOSDECSubOpReadReply.

Currently, MOSDECSubOpReadReply use send_message_osd_cluster(int, Message *, epoch_t) which is lookup for Connection.
So we use func send_message_osd_cluster(Message*, const ConnectionRef) to avoid lookup.

Signed-off-by: Jianpeng Ma <jianpeng.ma@intel.com>
    @majianpeng
    majianpeng committed Nov 7, 2019
    Configuration menu
    Copy the full SHA
    a8e557a View commit details
    Browse the repository at this point in the history

  3. osd: reduce unnessary notify. 

    Only has pre_publish_waiter, it call notify.

Signed-off-by: Jianpeng Ma <jianpeng.ma@intel.com>
    @majianpeng
    majianpeng committed Nov 7, 2019
    Configuration menu
    Copy the full SHA
    bb201f3 View commit details
    Browse the repository at this point in the history

  4. msg/async: add "bool unregistered" to avoid check whether in deleted_… 

    …conns.

We don't use deleted_lock to protect func is_unregistered. This because if
race occur, func send_message still check state of AsyncConnection and
skip this message.

Signed-off-by: Jianpeng Ma <jianpeng.ma@intel.com>
    @majianpeng
    majianpeng committed Nov 7, 2019
    Configuration menu
    Copy the full SHA
    f6fd2c3 View commit details
    Browse the repository at this point in the history

  5. osd/PrimaryLogPG: change PrimaryLogPG::send_message_osd_cluster to in… 

    …line func.

Signed-off-by: Jianpeng Ma <jianpeng.ma@intel.com>
    @majianpeng
    majianpeng committed Nov 7, 2019
    Configuration menu
    Copy the full SHA
    0b542de View commit details
    Browse the repository at this point in the history