osdc (reference) in projects: linux - OpenGrok search results

Project(s)

Full Search
Definition
Symbol
File Path
History
Type

Searched refs:osdc (Results 1 – 16 of 16) sorted by relevance

/linux/net/ceph/
H A D	osd_client.c	69 static inline void verify_osdc_locked(struct ceph_osd_client osdc) in verify_osdc_locked() argument 71 WARN_ON(!rwsem_is_locked(&osdc->lock)); in verify_osdc_locked() 73 static inline void verify_osdc_wrlocked(struct ceph_osd_client osdc) in verify_osdc_wrlocked() argument 75 WARN_ON(!rwsem_is_wrlocked(&osdc->lock)); in verify_osdc_wrlocked() 79 struct ceph_osd_client osdc = osd->o_osdc; in verify_osd_locked() local 82 rwsem_is_locked(&osdc->lock)) && in verify_osd_locked() 83 !rwsem_is_wrlocked(&osdc->lock)); in verify_osd_locked() 90 static inline void verify_osdc_locked(struct ceph_osd_client osdc) { } in verify_osdc_locked() argument 91 static inline void verify_osdc_wrlocked(struct ceph_osd_client osdc) { } in verify_osdc_wrlocked() argument 544 struct ceph_osd_request ceph_osdc_alloc_request(struct ceph_osd_client osdc, in ceph_osdc_alloc_request() argument 585 struct ceph_osd_client osdc = req->r_osdc; __ceph_osdc_alloc_messages() local 1055 ceph_osdc_new_request(struct ceph_osd_client * osdc,struct ceph_file_layout * layout,struct ceph_vino vino,u64 off,u64 * plen,unsigned int which,int num_ops,int opcode,int flags,struct ceph_snap_context * snapc,u32 truncate_seq,u64 truncate_size,bool use_mempool) ceph_osdc_new_request() argument 1260 create_osd(struct ceph_osd_client * osdc,int onum) create_osd() argument 1303 struct ceph_osd_client osdc = osd->o_osdc; DEFINE_RB_FUNCS() local 1324 struct ceph_osd_client osdc = osd->o_osdc; __remove_osd_from_lru() local 1340 struct ceph_osd_client osdc = osd->o_osdc; close_osd() local 1415 lookup_create_osd(struct ceph_osd_client osdc,int o,bool wrlocked) lookup_create_osd() argument 1491 have_pool_full(struct ceph_osd_client * osdc) have_pool_full() argument 1506 pool_full(struct ceph_osd_client * osdc,s64 pool_id) pool_full() argument 1521 target_should_be_paused(struct ceph_osd_client * osdc,const struct ceph_osd_request_target * t,struct ceph_pg_pool_info * pi) target_should_be_paused() argument 1550 pick_closest_replica(struct ceph_osd_client * osdc,const struct ceph_osds * acting) pick_closest_replica() argument 1581 calc_target(struct ceph_osd_client * osdc,struct ceph_osd_request_target * t,bool any_change) calc_target() argument 2357 maybe_request_map(struct ceph_osd_client * osdc) maybe_request_map() argument 2383 struct ceph_osd_client osdc = req->r_osdc; __submit_request() local 2495 struct ceph_osd_client osdc = req->r_osdc; finish_request() local 2553 struct ceph_osd_client osdc = req->r_osdc; cancel_map_check() local 2597 ceph_osdc_abort_requests(struct ceph_osd_client osdc,int err) ceph_osdc_abort_requests() argument 2607 ceph_osdc_clear_abort_err(struct ceph_osd_client * osdc) ceph_osdc_clear_abort_err() argument 2615 update_epoch_barrier(struct ceph_osd_client * osdc,u32 eb) update_epoch_barrier() argument 2627 ceph_osdc_update_epoch_barrier(struct ceph_osd_client * osdc,u32 eb) ceph_osdc_update_epoch_barrier() argument 2649 struct ceph_osd_client osdc = req->r_osdc; abort_on_full_fn() local 2671 ceph_osdc_abort_on_full(struct ceph_osd_client osdc) ceph_osdc_abort_on_full() argument 2682 struct ceph_osd_client osdc = req->r_osdc; check_pool_dne() local 2716 struct ceph_osd_client osdc = &greq->monc->client->osdc; map_check_cb() local 2743 struct ceph_osd_client osdc = req->r_osdc; send_map_check() local 2804 linger_alloc(struct ceph_osd_client osdc) linger_alloc() argument 2883 struct ceph_osd_client osdc = lreq->osdc; linger_registered() local 2895 struct ceph_osd_client osdc = lreq->osdc; linger_register() local 2907 struct ceph_osd_client osdc = lreq->osdc; linger_unregister() local 2976 struct ceph_osd_client osdc = lreq->osdc; lwork_queue() local 3128 struct ceph_osd_client osdc = lreq->osdc; send_linger() local 3216 struct ceph_osd_client osdc = lreq->osdc; send_linger_ping() local 3260 struct ceph_osd_client osdc = lreq->osdc; linger_submit() local 3276 struct ceph_osd_client osdc = lreq->osdc; cancel_linger_map_check() local 3307 struct ceph_osd_client osdc = lreq->osdc; linger_cancel() local 3319 struct ceph_osd_client osdc = lreq->osdc; check_linger_pool_dne() local 3350 struct ceph_osd_client osdc = &greq->monc->client->osdc; linger_map_check_cb() local 3378 struct ceph_osd_client osdc = lreq->osdc; send_linger_map_check() local 3431 struct ceph_osd_client osdc = handle_timeout() local 3520 struct ceph_osd_client osdc = handle_osds_timeout() local 3751 struct ceph_osd_client osdc = osd->o_osdc; handle_reply() local 3881 set_pool_was_full(struct ceph_osd_client osdc) set_pool_was_full() argument 3893 pool_cleared_full(struct ceph_osd_client * osdc,s64 pool_id) pool_cleared_full() argument 3907 struct ceph_osd_client osdc = lreq->osdc; recalc_linger_target() local 3934 struct ceph_osd_client osdc = osd->o_osdc; scan_requests() local 4006 handle_one_map(struct ceph_osd_client * osdc,void * p,void * end,bool incremental,struct rb_root * need_resend,struct list_head * need_resend_linger) handle_one_map() argument 4077 kick_requests(struct ceph_osd_client * osdc,struct rb_root * need_resend,struct list_head * need_resend_linger) kick_requests() argument 4134 ceph_osdc_handle_map(struct ceph_osd_client * osdc,struct ceph_msg * msg) ceph_osdc_handle_map() argument 4280 struct ceph_osd_client osdc = osd->o_osdc; osd_fault() local 4517 struct ceph_osd_client osdc = osd->o_osdc; handle_backoff() local 4559 handle_watch_notify(struct ceph_osd_client * osdc,struct ceph_msg * msg) handle_watch_notify() argument 4658 ceph_osdc_start_request(struct ceph_osd_client * osdc,struct ceph_osd_request * req) ceph_osdc_start_request() argument 4678 struct ceph_osd_client osdc = req->r_osdc; ceph_osdc_cancel_request() local 4711 ceph_osdc_wait_request(struct ceph_osd_client osdc,struct ceph_osd_request * req) ceph_osdc_wait_request() argument 4721 ceph_osdc_sync(struct ceph_osd_client * osdc) ceph_osdc_sync() argument 4764 ceph_osdc_watch(struct ceph_osd_client * osdc,struct ceph_object_id * oid,struct ceph_object_locator * oloc,rados_watchcb2_t wcb,rados_watcherrcb_t errcb,void * data) ceph_osdc_watch() argument 4811 ceph_osdc_unwatch(struct ceph_osd_client * osdc,struct ceph_osd_linger_request * lreq) ceph_osdc_unwatch() argument 4876 ceph_osdc_notify_ack(struct ceph_osd_client * osdc,struct ceph_object_id * oid,struct ceph_object_locator * oloc,u64 notify_id,u64 cookie,void * payload,u32 payload_len) ceph_osdc_notify_ack() argument 4921 ceph_osdc_notify(struct ceph_osd_client * osdc,struct ceph_object_id * oid,struct ceph_object_locator * oloc,void * payload,u32 payload_len,u32 timeout,struct page *** preply_pages,size_t * preply_len) ceph_osdc_notify() argument 5054 ceph_osdc_list_watchers(struct ceph_osd_client * osdc,struct ceph_object_id * oid,struct ceph_object_locator * oloc,struct ceph_watch_item ** watchers,u32 * num_watchers) ceph_osdc_list_watchers() argument 5106 ceph_osdc_flush_notifies(struct ceph_osd_client * osdc) ceph_osdc_flush_notifies() argument 5113 ceph_osdc_maybe_request_map(struct ceph_osd_client * osdc) ceph_osdc_maybe_request_map() argument 5127 ceph_osdc_call(struct ceph_osd_client * osdc,struct ceph_object_id * oid,struct ceph_object_locator * oloc,const char * class,const char * method,unsigned int flags,struct page * req_page,size_t req_len,struct page ** resp_pages,size_t * resp_len) ceph_osdc_call() argument 5181 ceph_osdc_reopen_osds(struct ceph_osd_client * osdc) ceph_osdc_reopen_osds() argument 5199 ceph_osdc_init(struct ceph_osd_client * osdc,struct ceph_client * client) ceph_osdc_init() argument 5269 ceph_osdc_stop(struct ceph_osd_client * osdc) ceph_osdc_stop() argument 5362 struct ceph_osd_client osdc = osd->o_osdc; osd_dispatch() local 5415 struct ceph_osd_client osdc = osd->o_osdc; get_reply() local 5555 struct ceph_osd_client osdc = o->o_osdc; osd_get_authorizer() local 5572 struct ceph_osd_client osdc = o->o_osdc; osd_add_authorizer_challenge() local 5582 struct ceph_osd_client osdc = o->o_osdc; osd_verify_authorizer_reply() local 5594 struct ceph_osd_client osdc = o->o_osdc; osd_invalidate_authorizer() local [all...]
H A D	debugfs.c	62 struct ceph_osd_client osdc = &client->osdc; in osdmap_show() local 66 down_read(&osdc->lock); in osdmap_show() 67 map = osdc->osdmap; in osdmap_show() 72 osdc->epoch_barrier, map->flags); in osdmap_show() 140 up_read(&osdc->lock); in osdmap_show() 351 struct ceph_osd_client osdc = &client->osdc; in osdc_show() local 354 down_read(&osdc->lock); in osdc_show() 356 atomic_read(&osdc->num_requests), in osdc_show() 357 atomic_read(&osdc->num_homeless)); in osdc_show() 358 for (n = rb_first(&osdc->osds); n; n = rb_next(n)) { in osdc_show() [all …]
H A D	cls_lock_client.c	25 int ceph_cls_lock(struct ceph_osd_client osdc, in ceph_cls_lock() argument 75 ret = ceph_osdc_call(osdc, oid, oloc, "lock", "lock", in ceph_cls_lock() 93 int ceph_cls_unlock(struct ceph_osd_client osdc, in ceph_cls_unlock() argument 125 ret = ceph_osdc_call(osdc, oid, oloc, "lock", "unlock", in ceph_cls_unlock() 144 int ceph_cls_break_lock(struct ceph_osd_client osdc, in ceph_cls_break_lock() argument 180 ret = ceph_osdc_call(osdc, oid, oloc, "lock", "break_lock", in ceph_cls_break_lock() 190 int ceph_cls_set_cookie(struct ceph_osd_client osdc, in ceph_cls_set_cookie() argument 231 ret = ceph_osdc_call(osdc, oid, oloc, "lock", "set_cookie", in ceph_cls_set_cookie() 343 int ceph_cls_lock_info(struct ceph_osd_client *osdc, in ceph_cls_lock_info() argument 380 ret = ceph_osdc_call(osdc, oid, oloc, "lock", "get_info", in ceph_cls_lock_info()
H A D	ceph_common.c	744 err = ceph_osdc_init(&client->osdc, client); in ceph_create_client() 768 ceph_osdc_stop(&client->osdc); in ceph_destroy_client() 783 ceph_osdc_reopen_osds(&client->osdc); in ceph_reset_client_addr() 809 down_read(&client->osdc.lock); in __ceph_open_session() 810 have_osdmap = client->osdc.osdmap && client->osdc.osdmap->epoch; in __ceph_open_session() 811 up_read(&client->osdc.lock); in __ceph_open_session() 867 if (client->osdc.osdmap->epoch >= newest_epoch) in ceph_wait_for_latest_osdmap() 870 ceph_osdc_maybe_request_map(&client->osdc); in ceph_wait_for_latest_osdmap()
H A D	mon_client.c	`1477 ceph_osdc_handle_map(&monc->client->osdc, msg); in mon_dispatch()`
/linux/include/linux/ceph/
H A D	osd_client.h	311 struct ceph_osd_client osdc; member 439 static inline bool ceph_osdmap_flag(struct ceph_osd_client osdc, int flag) in ceph_osdmap_flag() argument 441 return osdc->osdmap->flags & flag; in ceph_osdmap_flag() 447 extern int ceph_osdc_init(struct ceph_osd_client osdc, 449 extern void ceph_osdc_stop(struct ceph_osd_client osdc); 450 extern void ceph_osdc_reopen_osds(struct ceph_osd_client osdc); 452 extern void ceph_osdc_handle_map(struct ceph_osd_client osdc, 454 void ceph_osdc_update_epoch_barrier(struct ceph_osd_client osdc, u32 eb); 455 void ceph_osdc_abort_requests(struct ceph_osd_client osdc, int err); 456 void ceph_osdc_clear_abort_err(struct ceph_osd_client *osdc); [all …]
H A D	cls_lock_client.h	`27 int ceph_cls_lock(struct ceph_osd_client osdc, 32 int ceph_cls_unlock(struct ceph_osd_client osdc, 36 int ceph_cls_break_lock(struct ceph_osd_client osdc, 41 int ceph_cls_set_cookie(struct ceph_osd_client osdc, 49 int ceph_cls_lock_info(struct ceph_osd_client *osdc,`
H A D	libceph.h	`134 struct ceph_osd_client osdc; member`
/linux/fs/ceph/
H A D	ioctl.c	191 struct ceph_osd_client *osdc = in ceph_ioctl_get_dataloc() local 192 &ceph_sb_to_fs_client(inode->i_sb)->client->osdc; in ceph_ioctl_get_dataloc() 204 down_read(&osdc->lock); in ceph_ioctl_get_dataloc() 222 r = ceph_object_locator_to_pg(osdc->osdmap, &oid, &oloc, &pgid); in ceph_ioctl_get_dataloc() 226 up_read(&osdc->lock); in ceph_ioctl_get_dataloc() 230 dl.osd = ceph_pg_to_acting_primary(osdc->osdmap, &pgid); in ceph_ioctl_get_dataloc() 233 ceph_osd_addr(osdc->osdmap, dl.osd); in ceph_ioctl_get_dataloc() 239 up_read(&osdc->lock); in ceph_ioctl_get_dataloc()
H A D	file.c	1074 struct ceph_osd_client osdc = &fsc->client->osdc; in __ceph_sync_read() local 1121 req = ceph_osdc_new_request(osdc, &ci->i_layout, in __ceph_sync_read() 1161 ceph_osdc_start_request(osdc, req); in __ceph_sync_read() 1162 ret = ceph_osdc_wait_request(osdc, req); in __ceph_sync_read() 1580 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_direct_read_write() 1660 ret = ceph_osdc_wait_request(&fsc->client->osdc, req); in ceph_direct_read_write() 1768 struct ceph_osd_client osdc = &fsc->client->osdc; in ceph_sync_write() local 1860 req = ceph_osdc_new_request(osdc, &ci->i_layout, in ceph_sync_write() 1923 ceph_osdc_start_request(osdc, req); in ceph_sync_write() 1924 ret = ceph_osdc_wait_request(osdc, req); in ceph_sync_write() [all …]
H A D	xattr.c	62 struct ceph_osd_client osdc = &fsc->client->osdc; in ceph_vxattrcb_layout() local 74 down_read(&osdc->lock); in ceph_vxattrcb_layout() 75 pool_name = ceph_pg_pool_name_by_id(osdc->osdmap, pool); in ceph_vxattrcb_layout() 110 up_read(&osdc->lock); in ceph_vxattrcb_layout() 166 struct ceph_osd_client osdc = &fsc->client->osdc; in ceph_vxattrcb_layout_pool() local 170 down_read(&osdc->lock); in ceph_vxattrcb_layout_pool() 171 pool_name = ceph_pg_pool_name_by_id(osdc->osdmap, pool); in ceph_vxattrcb_layout_pool() 179 up_read(&osdc->lock); in ceph_vxattrcb_layout_pool() 1114 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_sync_setxattr() local 1154 cpu_to_le32(osdc->osdmap->epoch); in ceph_sync_setxattr()
H A D	addr.c	386 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, vino, in ceph_netfs_issue_read() 736 struct ceph_osd_client *osdc = &fsc->client->osdc; in write_folio_nounlock() local 786 req = ceph_osdc_new_request(osdc, &ci->i_layout, ceph_vino(inode), in write_folio_nounlock() 832 ceph_osdc_start_request(osdc, req); in write_folio_nounlock() 833 err = ceph_osdc_wait_request(osdc, req); in write_folio_nounlock() 1450 req = ceph_osdc_new_request(&fsc->client->osdc, in ceph_submit_write() 1457 req = ceph_osdc_new_request(&fsc->client->osdc, in ceph_submit_write() 1606 ceph_osdc_start_request(&fsc->client->osdc, req); in ceph_submit_write() 2283 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_uninline_data() 2293 ceph_osdc_start_request(&fsc->client->osdc, req); in ceph_uninline_data() [all …]
H A D	super.c	`139 ceph_osdc_sync(&fsc->client->osdc); in ceph_sync_fs() 1019 ceph_osdc_abort_requests(&fsc->client->osdc, -EIO); in __ceph_umount_begin() 1625 ceph_osdc_clear_abort_err(&fsc->client->osdc); in ceph_force_reconnect()`
H A D	caps.c	`1249 struct ceph_osd_client osdc = &mdsc->fsc->client->osdc; in encode_cap_msg() local 1315 ceph_encode_32(&p, READ_ONCE(osdc->epoch_barrier)); in encode_cap_msg() 4424 struct ceph_osd_client osdc = &mdsc->fsc->client->osdc; in ceph_handle_caps() local 4428 ceph_osdc_update_epoch_barrier(osdc, epoch_barrier); in ceph_handle_caps()`
H A D	mds_client.c	`2456 struct ceph_osd_client *osdc = &mdsc->fsc->client->osdc; in ceph_send_cap_releases() local 2462 down_read(&osdc->lock); in ceph_send_cap_releases() 2463 barrier = cpu_to_le32(osdc->epoch_barrier); in ceph_send_cap_releases() 2464 up_read(&osdc->lock); in ceph_send_cap_releases()`
/linux/drivers/block/
H A D	rbd.c	1424 struct ceph_osd_client osdc = &rbd_dev->rbd_client->client->osdc; in __rbd_obj_add_osd_request() local 1430 req = ceph_osdc_alloc_request(osdc, snapc, num_ops, false, GFP_NOIO); in __rbd_obj_add_osd_request() 1723 struct ceph_osd_client osdc = &rbd_dev->rbd_client->client->osdc; in rbd_object_map_lock() local 1735 ret = ceph_cls_lock(osdc, &oid, &rbd_dev->header_oloc, RBD_LOCK_NAME, in rbd_object_map_lock() 1745 ret = ceph_cls_lock_info(osdc, &oid, &rbd_dev->header_oloc, in rbd_object_map_lock() 1763 ret = ceph_cls_break_lock(osdc, &oid, &rbd_dev->header_oloc, in rbd_object_map_lock() 1781 struct ceph_osd_client osdc = &rbd_dev->rbd_client->client->osdc; in rbd_object_map_unlock() local 1787 ret = ceph_cls_unlock(osdc, &oid, &rbd_dev->header_oloc, RBD_LOCK_NAME, in rbd_object_map_unlock() 1820 struct ceph_osd_client osdc = &rbd_dev->rbd_client->client->osdc; in __rbd_object_map_load() local 1844 ret = ceph_osdc_call(osdc, &oid, &rbd_dev->header_oloc, in __rbd_object_map_load() [all …]