diff options
author | Sage Weil <sage@newdream.net> | 2010-08-03 13:25:11 -0400 |
---|---|---|
committer | Sage Weil <sage@newdream.net> | 2010-08-03 13:25:11 -0400 |
commit | 213c99ee0cf17ff0fbffb6fb540bd29615cd19d5 (patch) | |
tree | 168f72ba71feff5bf24707be622135b1016cdff5 /fs | |
parent | 40819f6fb227c1832935b775ac22aef10aa6f6dd (diff) |
ceph: whitespace cleanup
Signed-off-by: Sage Weil <sage@newdream.net>
Diffstat (limited to 'fs')
-rw-r--r-- | fs/ceph/addr.c | 14 | ||||
-rw-r--r-- | fs/ceph/debugfs.c | 17 | ||||
-rw-r--r-- | fs/ceph/file.c | 2 | ||||
-rw-r--r-- | fs/ceph/mds_client.c | 5 | ||||
-rw-r--r-- | fs/ceph/messenger.c | 9 | ||||
-rw-r--r-- | fs/ceph/osd_client.c | 6 | ||||
-rw-r--r-- | fs/ceph/osdmap.c | 2 |
7 files changed, 31 insertions, 24 deletions
diff --git a/fs/ceph/addr.c b/fs/ceph/addr.c index e00797eed29c..5598a0d02295 100644 --- a/fs/ceph/addr.c +++ b/fs/ceph/addr.c | |||
@@ -309,7 +309,8 @@ static int ceph_readpages(struct file *file, struct address_space *mapping, | |||
309 | zero_user_segment(page, s, PAGE_CACHE_SIZE); | 309 | zero_user_segment(page, s, PAGE_CACHE_SIZE); |
310 | } | 310 | } |
311 | 311 | ||
312 | if (add_to_page_cache_lru(page, mapping, page->index, GFP_NOFS)) { | 312 | if (add_to_page_cache_lru(page, mapping, page->index, |
313 | GFP_NOFS)) { | ||
313 | page_cache_release(page); | 314 | page_cache_release(page); |
314 | dout("readpages %p add_to_page_cache failed %p\n", | 315 | dout("readpages %p add_to_page_cache failed %p\n", |
315 | inode, page); | 316 | inode, page); |
@@ -797,9 +798,12 @@ get_more_pages: | |||
797 | dout("%p will write page %p idx %lu\n", | 798 | dout("%p will write page %p idx %lu\n", |
798 | inode, page, page->index); | 799 | inode, page, page->index); |
799 | 800 | ||
800 | writeback_stat = atomic_long_inc_return(&client->writeback_count); | 801 | writeback_stat = |
801 | if (writeback_stat > CONGESTION_ON_THRESH(client->mount_args->congestion_kb)) { | 802 | atomic_long_inc_return(&client->writeback_count); |
802 | set_bdi_congested(&client->backing_dev_info, BLK_RW_ASYNC); | 803 | if (writeback_stat > CONGESTION_ON_THRESH( |
804 | client->mount_args->congestion_kb)) { | ||
805 | set_bdi_congested(&client->backing_dev_info, | ||
806 | BLK_RW_ASYNC); | ||
803 | } | 807 | } |
804 | 808 | ||
805 | set_page_writeback(page); | 809 | set_page_writeback(page); |
@@ -1036,7 +1040,7 @@ static int ceph_write_begin(struct file *file, struct address_space *mapping, | |||
1036 | *pagep = page; | 1040 | *pagep = page; |
1037 | 1041 | ||
1038 | dout("write_begin file %p inode %p page %p %d~%d\n", file, | 1042 | dout("write_begin file %p inode %p page %p %d~%d\n", file, |
1039 | inode, page, (int)pos, (int)len); | 1043 | inode, page, (int)pos, (int)len); |
1040 | 1044 | ||
1041 | r = ceph_update_writeable_page(file, pos, len, page); | 1045 | r = ceph_update_writeable_page(file, pos, len, page); |
1042 | } while (r == -EAGAIN); | 1046 | } while (r == -EAGAIN); |
diff --git a/fs/ceph/debugfs.c b/fs/ceph/debugfs.c index 968dc5a86c3e..360c4f22718d 100644 --- a/fs/ceph/debugfs.c +++ b/fs/ceph/debugfs.c | |||
@@ -291,7 +291,7 @@ static int dentry_lru_show(struct seq_file *s, void *ptr) | |||
291 | return 0; | 291 | return 0; |
292 | } | 292 | } |
293 | 293 | ||
294 | #define DEFINE_SHOW_FUNC(name) \ | 294 | #define DEFINE_SHOW_FUNC(name) \ |
295 | static int name##_open(struct inode *inode, struct file *file) \ | 295 | static int name##_open(struct inode *inode, struct file *file) \ |
296 | { \ | 296 | { \ |
297 | struct seq_file *sf; \ | 297 | struct seq_file *sf; \ |
@@ -432,11 +432,12 @@ int ceph_debugfs_client_init(struct ceph_client *client) | |||
432 | if (!client->debugfs_caps) | 432 | if (!client->debugfs_caps) |
433 | goto out; | 433 | goto out; |
434 | 434 | ||
435 | client->debugfs_congestion_kb = debugfs_create_file("writeback_congestion_kb", | 435 | client->debugfs_congestion_kb = |
436 | 0600, | 436 | debugfs_create_file("writeback_congestion_kb", |
437 | client->debugfs_dir, | 437 | 0600, |
438 | client, | 438 | client->debugfs_dir, |
439 | &congestion_kb_fops); | 439 | client, |
440 | &congestion_kb_fops); | ||
440 | if (!client->debugfs_congestion_kb) | 441 | if (!client->debugfs_congestion_kb) |
441 | goto out; | 442 | goto out; |
442 | 443 | ||
@@ -466,7 +467,7 @@ void ceph_debugfs_client_cleanup(struct ceph_client *client) | |||
466 | debugfs_remove(client->debugfs_dir); | 467 | debugfs_remove(client->debugfs_dir); |
467 | } | 468 | } |
468 | 469 | ||
469 | #else // CONFIG_DEBUG_FS | 470 | #else /* CONFIG_DEBUG_FS */ |
470 | 471 | ||
471 | int __init ceph_debugfs_init(void) | 472 | int __init ceph_debugfs_init(void) |
472 | { | 473 | { |
@@ -486,4 +487,4 @@ void ceph_debugfs_client_cleanup(struct ceph_client *client) | |||
486 | { | 487 | { |
487 | } | 488 | } |
488 | 489 | ||
489 | #endif // CONFIG_DEBUG_FS | 490 | #endif /* CONFIG_DEBUG_FS */ |
diff --git a/fs/ceph/file.c b/fs/ceph/file.c index e850e63f9563..8c044a4f0457 100644 --- a/fs/ceph/file.c +++ b/fs/ceph/file.c | |||
@@ -665,7 +665,7 @@ more: | |||
665 | * throw out any page cache pages in this range. this | 665 | * throw out any page cache pages in this range. this |
666 | * may block. | 666 | * may block. |
667 | */ | 667 | */ |
668 | truncate_inode_pages_range(inode->i_mapping, pos, | 668 | truncate_inode_pages_range(inode->i_mapping, pos, |
669 | (pos+len) | (PAGE_CACHE_SIZE-1)); | 669 | (pos+len) | (PAGE_CACHE_SIZE-1)); |
670 | } else { | 670 | } else { |
671 | pages = ceph_alloc_page_vector(num_pages, GFP_NOFS); | 671 | pages = ceph_alloc_page_vector(num_pages, GFP_NOFS); |
diff --git a/fs/ceph/mds_client.c b/fs/ceph/mds_client.c index 9f0833e1631a..a75ddbf9fe37 100644 --- a/fs/ceph/mds_client.c +++ b/fs/ceph/mds_client.c | |||
@@ -1985,8 +1985,9 @@ static void handle_reply(struct ceph_mds_session *session, struct ceph_msg *msg) | |||
1985 | */ | 1985 | */ |
1986 | if (result == -ESTALE) { | 1986 | if (result == -ESTALE) { |
1987 | dout("got ESTALE on request %llu", req->r_tid); | 1987 | dout("got ESTALE on request %llu", req->r_tid); |
1988 | if (!req->r_inode) ; //do nothing; not an authority problem | 1988 | if (!req->r_inode) { |
1989 | else if (req->r_direct_mode != USE_AUTH_MDS) { | 1989 | /* do nothing; not an authority problem */ |
1990 | } else if (req->r_direct_mode != USE_AUTH_MDS) { | ||
1990 | dout("not using auth, setting for that now"); | 1991 | dout("not using auth, setting for that now"); |
1991 | req->r_direct_mode = USE_AUTH_MDS; | 1992 | req->r_direct_mode = USE_AUTH_MDS; |
1992 | __do_request(mdsc, req); | 1993 | __do_request(mdsc, req); |
diff --git a/fs/ceph/messenger.c b/fs/ceph/messenger.c index 79b0995dc825..2502d76fcec1 100644 --- a/fs/ceph/messenger.c +++ b/fs/ceph/messenger.c | |||
@@ -1302,8 +1302,8 @@ static void process_ack(struct ceph_connection *con) | |||
1302 | 1302 | ||
1303 | 1303 | ||
1304 | static int read_partial_message_section(struct ceph_connection *con, | 1304 | static int read_partial_message_section(struct ceph_connection *con, |
1305 | struct kvec *section, unsigned int sec_len, | 1305 | struct kvec *section, |
1306 | u32 *crc) | 1306 | unsigned int sec_len, u32 *crc) |
1307 | { | 1307 | { |
1308 | int left; | 1308 | int left; |
1309 | int ret; | 1309 | int ret; |
@@ -1434,7 +1434,8 @@ static int read_partial_message(struct ceph_connection *con) | |||
1434 | 1434 | ||
1435 | /* middle */ | 1435 | /* middle */ |
1436 | if (m->middle) { | 1436 | if (m->middle) { |
1437 | ret = read_partial_message_section(con, &m->middle->vec, middle_len, | 1437 | ret = read_partial_message_section(con, &m->middle->vec, |
1438 | middle_len, | ||
1438 | &con->in_middle_crc); | 1439 | &con->in_middle_crc); |
1439 | if (ret <= 0) | 1440 | if (ret <= 0) |
1440 | return ret; | 1441 | return ret; |
@@ -1920,7 +1921,7 @@ out: | |||
1920 | /* | 1921 | /* |
1921 | * in case we faulted due to authentication, invalidate our | 1922 | * in case we faulted due to authentication, invalidate our |
1922 | * current tickets so that we can get new ones. | 1923 | * current tickets so that we can get new ones. |
1923 | */ | 1924 | */ |
1924 | if (con->auth_retry && con->ops->invalidate_authorizer) { | 1925 | if (con->auth_retry && con->ops->invalidate_authorizer) { |
1925 | dout("calling invalidate_authorizer()\n"); | 1926 | dout("calling invalidate_authorizer()\n"); |
1926 | con->ops->invalidate_authorizer(con); | 1927 | con->ops->invalidate_authorizer(con); |
diff --git a/fs/ceph/osd_client.c b/fs/ceph/osd_client.c index 707d2dbd8776..bed6391e52c7 100644 --- a/fs/ceph/osd_client.c +++ b/fs/ceph/osd_client.c | |||
@@ -1473,8 +1473,8 @@ static void put_osd_con(struct ceph_connection *con) | |||
1473 | * authentication | 1473 | * authentication |
1474 | */ | 1474 | */ |
1475 | static int get_authorizer(struct ceph_connection *con, | 1475 | static int get_authorizer(struct ceph_connection *con, |
1476 | void **buf, int *len, int *proto, | 1476 | void **buf, int *len, int *proto, |
1477 | void **reply_buf, int *reply_len, int force_new) | 1477 | void **reply_buf, int *reply_len, int force_new) |
1478 | { | 1478 | { |
1479 | struct ceph_osd *o = con->private; | 1479 | struct ceph_osd *o = con->private; |
1480 | struct ceph_osd_client *osdc = o->o_osdc; | 1480 | struct ceph_osd_client *osdc = o->o_osdc; |
@@ -1494,7 +1494,7 @@ static int get_authorizer(struct ceph_connection *con, | |||
1494 | &o->o_authorizer_reply_buf, | 1494 | &o->o_authorizer_reply_buf, |
1495 | &o->o_authorizer_reply_buf_len); | 1495 | &o->o_authorizer_reply_buf_len); |
1496 | if (ret) | 1496 | if (ret) |
1497 | return ret; | 1497 | return ret; |
1498 | } | 1498 | } |
1499 | 1499 | ||
1500 | *proto = ac->protocol; | 1500 | *proto = ac->protocol; |
diff --git a/fs/ceph/osdmap.c b/fs/ceph/osdmap.c index e94c6fb2e2a4..e31f118f1392 100644 --- a/fs/ceph/osdmap.c +++ b/fs/ceph/osdmap.c | |||
@@ -855,7 +855,7 @@ struct ceph_osdmap *osdmap_apply_incremental(void **p, void *end, | |||
855 | node)->pgid, pgid) <= 0) { | 855 | node)->pgid, pgid) <= 0) { |
856 | struct ceph_pg_mapping *cur = | 856 | struct ceph_pg_mapping *cur = |
857 | rb_entry(rbp, struct ceph_pg_mapping, node); | 857 | rb_entry(rbp, struct ceph_pg_mapping, node); |
858 | 858 | ||
859 | rbp = rb_next(rbp); | 859 | rbp = rb_next(rbp); |
860 | dout(" removed pg_temp %llx\n", *(u64 *)&cur->pgid); | 860 | dout(" removed pg_temp %llx\n", *(u64 *)&cur->pgid); |
861 | rb_erase(&cur->node, &map->pg_temp); | 861 | rb_erase(&cur->node, &map->pg_temp); |