file_stripe_count(0),
object_size(0),
file_replication(0),
- preferred_pg(-1),
client_lock("Client::client_lock")
{
monclient->set_messenger(m);
req->head.args.open.stripe_count = file_stripe_count;
req->head.args.open.object_size = object_size;
req->head.args.open.file_replication = file_replication;
- req->head.args.open.preferred = preferred_pg;
+ req->head.args.open.preferred = -1;
req->dentry_drop = CEPH_CAP_FILE_SHARED;
req->dentry_unless = CEPH_CAP_FILE_EXCL;
<< ' ' << file_stripe_count
<< ' ' << object_size
<< ' ' << file_replication
- << ' ' << preferred_pg
<<") = " << res << dendl;
return res;
file_replication = replication;
}
-void Client::set_default_preferred_pg(int pg)
-{
- if (pg >= -1)
- preferred_pg = pg;
- else
- ldout(cct, 5) << "Attempt to set preferred_pg " << pg << " < -1!" << dendl;
-}
-
// expose file layouts
int file_stripe_count;
int object_size;
int file_replication;
- int preferred_pg;
public:
entity_name_t get_myname() { return messenger->get_myname(); }
void sync_write_commit(Inode *in);
void set_default_file_stripe_count(int count);
void set_default_object_size(int size);
void set_default_file_replication(int replication);
- void set_default_preferred_pg(int osd);
int enumerate_layout(int fd, vector<ObjectExtent>& result,
loff_t length, loff_t offset);