message: set high priority for peering

want peering as fast as it can

Signed-off-by: yaoning <yaoning@unitedstack.com>

diff --git a/src/messages/MOSDPGInfo.h b/src/messages/MOSDPGInfo.h
index 83e74fb8c36bd6eb93fa8e6cb558ff367d0d097e..b7fe6d04433dd824287d745833c29c7dfa56ac65 100644 (file)
--- a/src/messages/MOSDPGInfo.h
+++ b/src/messages/MOSDPGInfo.h
@@ -31,10 +31,14 @@ public:
   epoch_t get_epoch() { return epoch; }
 
   MOSDPGInfo()
-    : Message(MSG_OSD_PG_INFO, HEAD_VERSION, COMPAT_VERSION) {}
+    : Message(MSG_OSD_PG_INFO, HEAD_VERSION, COMPAT_VERSION) {
+    set_priority(CEPH_MSG_PRIO_HIGH);
+  }
   MOSDPGInfo(version_t mv)
     : Message(MSG_OSD_PG_INFO, HEAD_VERSION, COMPAT_VERSION),
-      epoch(mv) { }
+      epoch(mv) {
+    set_priority(CEPH_MSG_PRIO_HIGH);
+  }
 private:
   ~MOSDPGInfo() {}
 

diff --git a/src/messages/MOSDPGLog.h b/src/messages/MOSDPGLog.h
index 741b14170a107b49926195b777be8a60cee9fa2f..66764256d2e3a6ce0a67f648a62ff35d6614542c 100644 (file)
--- a/src/messages/MOSDPGLog.h
+++ b/src/messages/MOSDPGLog.h
@@ -42,18 +42,24 @@ public:
   spg_t get_pgid() { return spg_t(info.pgid.pgid, to); }
   epoch_t get_query_epoch() { return query_epoch; }
 
-  MOSDPGLog() : Message(MSG_OSD_PG_LOG, HEAD_VERSION, COMPAT_VERSION) { }
+  MOSDPGLog() : Message(MSG_OSD_PG_LOG, HEAD_VERSION, COMPAT_VERSION) { 
+    set_priority(CEPH_MSG_PRIO_HIGH); 
+  }
   MOSDPGLog(shard_id_t to, shard_id_t from, version_t mv, pg_info_t& i)
     : Message(MSG_OSD_PG_LOG, HEAD_VERSION, COMPAT_VERSION),
       epoch(mv), query_epoch(mv),
       to(to), from(from),
-      info(i)  { }
+      info(i)  {
+    set_priority(CEPH_MSG_PRIO_HIGH); 
+  }
   MOSDPGLog(shard_id_t to, shard_id_t from,
            version_t mv, pg_info_t& i, epoch_t query_epoch)
     : Message(MSG_OSD_PG_LOG, HEAD_VERSION, COMPAT_VERSION),
       epoch(mv), query_epoch(query_epoch),
       to(to), from(from),
-      info(i)  { }
+      info(i)  {
+    set_priority(CEPH_MSG_PRIO_HIGH);
+  }
 
 private:
   ~MOSDPGLog() {}

diff --git a/src/messages/MOSDPGNotify.h b/src/messages/MOSDPGNotify.h
index 6b9bdb33a825687747a6a157ef54a01f897b9afc..dcd7480199bdc585f04c808cb5867c9667039b93 100644 (file)
--- a/src/messages/MOSDPGNotify.h
+++ b/src/messages/MOSDPGNotify.h
@@ -40,11 +40,14 @@ class MOSDPGNotify : public Message {
   vector<pair<pg_notify_t,pg_interval_map_t> >& get_pg_list() { return pg_list; }
 
   MOSDPGNotify()
-    : Message(MSG_OSD_PG_NOTIFY, HEAD_VERSION, COMPAT_VERSION) { }
+    : Message(MSG_OSD_PG_NOTIFY, HEAD_VERSION, COMPAT_VERSION) { 
+    set_priority(CEPH_MSG_PRIO_HIGH); 
+  }
   MOSDPGNotify(epoch_t e, vector<pair<pg_notify_t,pg_interval_map_t> >& l)
     : Message(MSG_OSD_PG_NOTIFY, HEAD_VERSION, COMPAT_VERSION),
       epoch(e) {
     pg_list.swap(l);
+    set_priority(CEPH_MSG_PRIO_HIGH);
   }
 private:
   ~MOSDPGNotify() {}

diff --git a/src/messages/MOSDPGQuery.h b/src/messages/MOSDPGQuery.h
index 81a55c24f13b2c0f154c147ad8510783dbe19427..2306d755a897ba48406e3cb3eaacad73447638ef 100644 (file)
--- a/src/messages/MOSDPGQuery.h
+++ b/src/messages/MOSDPGQuery.h
@@ -34,13 +34,16 @@ class MOSDPGQuery : public Message {
 
   MOSDPGQuery() : Message(MSG_OSD_PG_QUERY,
                          HEAD_VERSION,
-                         COMPAT_VERSION) {}
+                         COMPAT_VERSION) {
+    set_priority(CEPH_MSG_PRIO_HIGH);
+  }
   MOSDPGQuery(epoch_t e, map<spg_t,pg_query_t>& ls) :
     Message(MSG_OSD_PG_QUERY,
            HEAD_VERSION,
            COMPAT_VERSION),
     epoch(e) {
     pg_list.swap(ls);
+    set_priority(CEPH_MSG_PRIO_HIGH);
   }
 private:
   ~MOSDPGQuery() {}