RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-21 01:47:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

OSD: queue ops based on message priority

Browse Source 
Signed-off-by: Samuel Just <sam.just@inktank.com>
This commit is contained in:
Samuel Just 2012-09-28 17:24:40 -07:00
parent a62d778e06
commit 5d47db2d16
1 changed files with 18 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/osd/OSD.cc
View File

@ -5613,8 +5613,15 @@ void OSD::enqueue_op(PG *pg, OpRequestRef op)
void OSD::OpWQ::_enqueue(pair<PGRef, OpRequestRef> item)
{
pqueue.enqueue(item.second->request->get_source_inst(),
1, 1, item);
unsigned priority = item.second->request->get_priority();
unsigned cost = item.second->request->get_data().length();
if (priority >= CEPH_MSG_PRIO_LOW)
pqueue.enqueue_immediate(
item.second->request->get_source_inst(),
priority, item);
else
pqueue.enqueue(item.second->request->get_source_inst(),
priority, cost, item);
osd->logger->set(l_osd_opq, pqueue.length());
}
@ -5628,8 +5635,15 @@ void OSD::OpWQ::_enqueue_front(pair<PGRef, OpRequestRef> item)
pg_for_processing[&*(item.first)].pop_back();
}
}
pqueue.enqueue_front(item.second->request->get_source_inst(),
1, 1, item);
unsigned priority = item.second->request->get_priority();
unsigned cost = item.second->request->get_data().length();
if (priority >= CEPH_MSG_PRIO_HIGH)
pqueue.enqueue_immediate_front(
item.second->request->get_source_inst(),
priority, item);
else
pqueue.enqueue_front(item.second->request->get_source_inst(),
priority, cost, item);
osd->logger->set(l_osd_opq, pqueue.length());
}