Commit 213c99ee authored by Sage Weil's avatar Sage Weil

ceph: whitespace cleanup

Signed-off-by: default avatarSage Weil <sage@newdream.net>
parent 40819f6f
...@@ -309,7 +309,8 @@ static int ceph_readpages(struct file *file, struct address_space *mapping, ...@@ -309,7 +309,8 @@ static int ceph_readpages(struct file *file, struct address_space *mapping,
zero_user_segment(page, s, PAGE_CACHE_SIZE); zero_user_segment(page, s, PAGE_CACHE_SIZE);
} }
if (add_to_page_cache_lru(page, mapping, page->index, GFP_NOFS)) { if (add_to_page_cache_lru(page, mapping, page->index,
GFP_NOFS)) {
page_cache_release(page); page_cache_release(page);
dout("readpages %p add_to_page_cache failed %p\n", dout("readpages %p add_to_page_cache failed %p\n",
inode, page); inode, page);
...@@ -797,9 +798,12 @@ static int ceph_writepages_start(struct address_space *mapping, ...@@ -797,9 +798,12 @@ static int ceph_writepages_start(struct address_space *mapping,
dout("%p will write page %p idx %lu\n", dout("%p will write page %p idx %lu\n",
inode, page, page->index); inode, page, page->index);
writeback_stat = atomic_long_inc_return(&client->writeback_count); writeback_stat =
if (writeback_stat > CONGESTION_ON_THRESH(client->mount_args->congestion_kb)) { atomic_long_inc_return(&client->writeback_count);
set_bdi_congested(&client->backing_dev_info, BLK_RW_ASYNC); if (writeback_stat > CONGESTION_ON_THRESH(
client->mount_args->congestion_kb)) {
set_bdi_congested(&client->backing_dev_info,
BLK_RW_ASYNC);
} }
set_page_writeback(page); set_page_writeback(page);
...@@ -1036,7 +1040,7 @@ static int ceph_write_begin(struct file *file, struct address_space *mapping, ...@@ -1036,7 +1040,7 @@ static int ceph_write_begin(struct file *file, struct address_space *mapping,
*pagep = page; *pagep = page;
dout("write_begin file %p inode %p page %p %d~%d\n", file, dout("write_begin file %p inode %p page %p %d~%d\n", file,
inode, page, (int)pos, (int)len); inode, page, (int)pos, (int)len);
r = ceph_update_writeable_page(file, pos, len, page); r = ceph_update_writeable_page(file, pos, len, page);
} while (r == -EAGAIN); } while (r == -EAGAIN);
......
...@@ -291,7 +291,7 @@ static int dentry_lru_show(struct seq_file *s, void *ptr) ...@@ -291,7 +291,7 @@ static int dentry_lru_show(struct seq_file *s, void *ptr)
return 0; return 0;
} }
#define DEFINE_SHOW_FUNC(name) \ #define DEFINE_SHOW_FUNC(name) \
static int name##_open(struct inode *inode, struct file *file) \ static int name##_open(struct inode *inode, struct file *file) \
{ \ { \
struct seq_file *sf; \ struct seq_file *sf; \
...@@ -432,11 +432,12 @@ int ceph_debugfs_client_init(struct ceph_client *client) ...@@ -432,11 +432,12 @@ int ceph_debugfs_client_init(struct ceph_client *client)
if (!client->debugfs_caps) if (!client->debugfs_caps)
goto out; goto out;
client->debugfs_congestion_kb = debugfs_create_file("writeback_congestion_kb", client->debugfs_congestion_kb =
0600, debugfs_create_file("writeback_congestion_kb",
client->debugfs_dir, 0600,
client, client->debugfs_dir,
&congestion_kb_fops); client,
&congestion_kb_fops);
if (!client->debugfs_congestion_kb) if (!client->debugfs_congestion_kb)
goto out; goto out;
...@@ -466,7 +467,7 @@ void ceph_debugfs_client_cleanup(struct ceph_client *client) ...@@ -466,7 +467,7 @@ void ceph_debugfs_client_cleanup(struct ceph_client *client)
debugfs_remove(client->debugfs_dir); debugfs_remove(client->debugfs_dir);
} }
#else // CONFIG_DEBUG_FS #else /* CONFIG_DEBUG_FS */
int __init ceph_debugfs_init(void) int __init ceph_debugfs_init(void)
{ {
...@@ -486,4 +487,4 @@ void ceph_debugfs_client_cleanup(struct ceph_client *client) ...@@ -486,4 +487,4 @@ void ceph_debugfs_client_cleanup(struct ceph_client *client)
{ {
} }
#endif // CONFIG_DEBUG_FS #endif /* CONFIG_DEBUG_FS */
...@@ -665,7 +665,7 @@ static ssize_t ceph_sync_write(struct file *file, const char __user *data, ...@@ -665,7 +665,7 @@ static ssize_t ceph_sync_write(struct file *file, const char __user *data,
* throw out any page cache pages in this range. this * throw out any page cache pages in this range. this
* may block. * may block.
*/ */
truncate_inode_pages_range(inode->i_mapping, pos, truncate_inode_pages_range(inode->i_mapping, pos,
(pos+len) | (PAGE_CACHE_SIZE-1)); (pos+len) | (PAGE_CACHE_SIZE-1));
} else { } else {
pages = ceph_alloc_page_vector(num_pages, GFP_NOFS); pages = ceph_alloc_page_vector(num_pages, GFP_NOFS);
......
...@@ -1985,8 +1985,9 @@ static void handle_reply(struct ceph_mds_session *session, struct ceph_msg *msg) ...@@ -1985,8 +1985,9 @@ static void handle_reply(struct ceph_mds_session *session, struct ceph_msg *msg)
*/ */
if (result == -ESTALE) { if (result == -ESTALE) {
dout("got ESTALE on request %llu", req->r_tid); dout("got ESTALE on request %llu", req->r_tid);
if (!req->r_inode) ; //do nothing; not an authority problem if (!req->r_inode) {
else if (req->r_direct_mode != USE_AUTH_MDS) { /* do nothing; not an authority problem */
} else if (req->r_direct_mode != USE_AUTH_MDS) {
dout("not using auth, setting for that now"); dout("not using auth, setting for that now");
req->r_direct_mode = USE_AUTH_MDS; req->r_direct_mode = USE_AUTH_MDS;
__do_request(mdsc, req); __do_request(mdsc, req);
......
...@@ -1302,8 +1302,8 @@ static void process_ack(struct ceph_connection *con) ...@@ -1302,8 +1302,8 @@ static void process_ack(struct ceph_connection *con)
static int read_partial_message_section(struct ceph_connection *con, static int read_partial_message_section(struct ceph_connection *con,
struct kvec *section, unsigned int sec_len, struct kvec *section,
u32 *crc) unsigned int sec_len, u32 *crc)
{ {
int left; int left;
int ret; int ret;
...@@ -1434,7 +1434,8 @@ static int read_partial_message(struct ceph_connection *con) ...@@ -1434,7 +1434,8 @@ static int read_partial_message(struct ceph_connection *con)
/* middle */ /* middle */
if (m->middle) { if (m->middle) {
ret = read_partial_message_section(con, &m->middle->vec, middle_len, ret = read_partial_message_section(con, &m->middle->vec,
middle_len,
&con->in_middle_crc); &con->in_middle_crc);
if (ret <= 0) if (ret <= 0)
return ret; return ret;
...@@ -1920,7 +1921,7 @@ static void ceph_fault(struct ceph_connection *con) ...@@ -1920,7 +1921,7 @@ static void ceph_fault(struct ceph_connection *con)
/* /*
* in case we faulted due to authentication, invalidate our * in case we faulted due to authentication, invalidate our
* current tickets so that we can get new ones. * current tickets so that we can get new ones.
*/ */
if (con->auth_retry && con->ops->invalidate_authorizer) { if (con->auth_retry && con->ops->invalidate_authorizer) {
dout("calling invalidate_authorizer()\n"); dout("calling invalidate_authorizer()\n");
con->ops->invalidate_authorizer(con); con->ops->invalidate_authorizer(con);
......
...@@ -1473,8 +1473,8 @@ static void put_osd_con(struct ceph_connection *con) ...@@ -1473,8 +1473,8 @@ static void put_osd_con(struct ceph_connection *con)
* authentication * authentication
*/ */
static int get_authorizer(struct ceph_connection *con, static int get_authorizer(struct ceph_connection *con,
void **buf, int *len, int *proto, void **buf, int *len, int *proto,
void **reply_buf, int *reply_len, int force_new) void **reply_buf, int *reply_len, int force_new)
{ {
struct ceph_osd *o = con->private; struct ceph_osd *o = con->private;
struct ceph_osd_client *osdc = o->o_osdc; struct ceph_osd_client *osdc = o->o_osdc;
...@@ -1494,7 +1494,7 @@ static int get_authorizer(struct ceph_connection *con, ...@@ -1494,7 +1494,7 @@ static int get_authorizer(struct ceph_connection *con,
&o->o_authorizer_reply_buf, &o->o_authorizer_reply_buf,
&o->o_authorizer_reply_buf_len); &o->o_authorizer_reply_buf_len);
if (ret) if (ret)
return ret; return ret;
} }
*proto = ac->protocol; *proto = ac->protocol;
......
...@@ -855,7 +855,7 @@ struct ceph_osdmap *osdmap_apply_incremental(void **p, void *end, ...@@ -855,7 +855,7 @@ struct ceph_osdmap *osdmap_apply_incremental(void **p, void *end,
node)->pgid, pgid) <= 0) { node)->pgid, pgid) <= 0) {
struct ceph_pg_mapping *cur = struct ceph_pg_mapping *cur =
rb_entry(rbp, struct ceph_pg_mapping, node); rb_entry(rbp, struct ceph_pg_mapping, node);
rbp = rb_next(rbp); rbp = rb_next(rbp);
dout(" removed pg_temp %llx\n", *(u64 *)&cur->pgid); dout(" removed pg_temp %llx\n", *(u64 *)&cur->pgid);
rb_erase(&cur->node, &map->pg_temp); rb_erase(&cur->node, &map->pg_temp);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment