RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2024-12-17 17:05:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

*** empty log message ***

Browse Source 
git-svn-id: https://ceph.svn.sf.net/svnroot/ceph@598 29311d96-e01e-0410-9327-a35deaab8ce9
This commit is contained in:
sage 2006-02-10 02:06:05 +00:00
parent f741218756
commit 343565f68c
5 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
ceph/config.cc
View File

@ -156,6 +156,7 @@ md_config_t g_conf = {
bdev_el_bw_max_ms: 300, // restart elevator at least once every 300 ms
bdev_el_bidir: true, // bidirectional elevator?
bdev_iov_max: 512, // max # iov's to collect into a single readv()/writev() call
bdev_debug_check_io_overlap: true, // [DEBUG] check for any pending io overlaps
// --- fakeclient (mds regression testing) (ancient history) ---
num_fakeclient: 100,

1
ceph/config.h
View File

@ -129,6 +129,7 @@ struct md_config_t {
int bdev_el_bw_max_ms;
bool bdev_el_bidir;
int bdev_iov_max;
bool bdev_debug_check_io_overlap;
// fake client
int num_fakeclient;

2
ceph/ebofs/BlockDevice.cc
View File

@ -382,7 +382,7 @@ void BlockDevice::_submit_io(biovec *b)
io_wakeup.SignalAll();
// [DEBUG] check for overlapping ios
if (0) {
if (g_conf.bdev_debug_check_io_overlap) {
// BUG: this doesn't catch everything! eg 1~10000000 will be missed....
multimap<block_t, biovec*>::iterator p = io_queue.lower_bound(b->start);
if ((p != io_queue.end() &&

1
ceph/osd/FakeStore.cc
View File

@ -2,6 +2,7 @@
#include "FakeStore.h"
#include "include/types.h"
#include "common/Timer.h"
#include <unistd.h>
#include <stdlib.h>

5
ceph/osd/OSDMap.h
View File

@ -88,7 +88,7 @@ class OSDMap {
// oid -> ps
ps_t object_to_ps(object_t oid) {
static crush::Hash H(777);
return H( (oid & 0xffffffffUL) ^ (oid >> 32) ) & PG_PS_MASK;
return H( oid ^ (oid >> 32) ) & PG_PS_MASK;
}
// (ps, nrep) -> pg
@ -112,8 +112,9 @@ class OSDMap {
int pg_to_osds(pg_t pg,
vector<int>& osds) { // list of osd addr's
int num_rep = pg_to_nrep(pg);
pg_t ps = pg_to_ps(pg);
crush.do_rule(crush.rules[num_rep],
(pg & 0xffffffff) ^ (pg >> 32),
ps ^ (ps >> 32),
osds);
return osds.size();
}