diff options
| author | Sage Weil <sage@newdream.net> | 2008-10-08 19:52:46 +0200 |
|---|---|---|
| committer | Sage Weil <sage@newdream.net> | 2008-10-08 19:52:46 +0200 |
| commit | 48295b8ec5290bbd5dbbbc26094e2a2a8c35e193 (patch) | |
| tree | 0d6b61779bea909fb99833f6ff024163be591a41 | |
| parent | msgr: include priority in msg header, make dispatch a priority queue (diff) | |
| download | ceph-48295b8ec5290bbd5dbbbc26094e2a2a8c35e193.tar.xz ceph-48295b8ec5290bbd5dbbbc26094e2a2a8c35e193.zip | |
osd: prioritize heartbeat messages
| -rw-r--r-- | src/osd/OSD.cc | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/osd/OSD.cc b/src/osd/OSD.cc index 5732da9c796..381d688d05e 100644 --- a/src/osd/OSD.cc +++ b/src/osd/OSD.cc @@ -957,8 +957,9 @@ void OSD::heartbeat() i++) { _share_map_outgoing( osdmap->get_inst(*i) ); my_stat_on_peer[*i] = my_stat; - messenger->send_message(new MOSDPing(osdmap->get_epoch(), my_stat), - osdmap->get_inst(*i)); + Message *m = new MOSDPing(osdmap->get_epoch(), my_stat); + m->set_priority(CEPH_MSG_PRIO_HIGH); + messenger->send_message(m, osdmap->get_inst(*i)); } // check for incoming heartbeats (move me elsewhere?) |