Searched refs:osdc (Results 1 - 4 of 4) sorted by relevance

/net/ceph/
H A Dosd_client.c29 static void __send_queued(struct ceph_osd_client *osdc);
30 static int __reset_osd(struct ceph_osd_client *osdc, struct ceph_osd *osd);
31 static void __register_request(struct ceph_osd_client *osdc,
33 static void __unregister_request(struct ceph_osd_client *osdc,
35 static void __unregister_linger_request(struct ceph_osd_client *osdc,
38 static void __send_request(struct ceph_osd_client *osdc,
352 struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc, argument
376 req = mempool_alloc(osdc->req_mempool, gfp_flags);
384 req->r_osdc = osdc;
403 msg = ceph_msgpool_get(&osdc
705 ceph_osdc_new_request(struct ceph_osd_client *osdc, struct ceph_file_layout *layout, struct ceph_vino vino, u64 off, u64 *plen, int num_ops, int opcode, int flags, struct ceph_snap_context *snapc, u32 truncate_seq, u64 truncate_size, bool use_mempool) argument
777 __insert_request(struct ceph_osd_client *osdc, struct ceph_osd_request *new) argument
799 __lookup_request(struct ceph_osd_client *osdc, u64 tid) argument
818 __lookup_request_ge(struct ceph_osd_client *osdc, u64 tid) argument
841 struct ceph_osd_client *osdc = req->r_osdc; local
873 __kick_osd_requests(struct ceph_osd_client *osdc, struct ceph_osd *osd) argument
940 struct ceph_osd_client *osdc; local
957 create_osd(struct ceph_osd_client *osdc, int onum) argument
1007 __remove_osd(struct ceph_osd_client *osdc, struct ceph_osd *osd) argument
1019 remove_all_osds(struct ceph_osd_client *osdc) argument
1031 __move_osd_to_lru(struct ceph_osd_client *osdc, struct ceph_osd *osd) argument
1041 maybe_move_osd_to_lru(struct ceph_osd_client *osdc, struct ceph_osd *osd) argument
1058 remove_old_osds(struct ceph_osd_client *osdc) argument
1075 __reset_osd(struct ceph_osd_client *osdc, struct ceph_osd *osd) argument
1108 __insert_osd(struct ceph_osd_client *osdc, struct ceph_osd *new) argument
1130 __lookup_osd(struct ceph_osd_client *osdc, int o) argument
1147 __schedule_osd_timeout(struct ceph_osd_client *osdc) argument
1153 __cancel_osd_timeout(struct ceph_osd_client *osdc) argument
1162 __register_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument
1180 __unregister_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument
1224 __register_linger_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument
1237 __unregister_linger_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument
1262 ceph_osdc_set_request_linger(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument
1278 __req_should_be_paused(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument
1329 struct ceph_osd_client *osdc = req->r_osdc; local
1353 __map_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req, int force_resend) argument
1431 __send_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument
1464 __send_queued(struct ceph_osd_client *osdc) argument
1476 __ceph_osdc_start_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req, bool nofail) argument
1518 struct ceph_osd_client *osdc = local
1563 struct ceph_osd_client *osdc = local
1690 handle_reply(struct ceph_osd_client *osdc, struct ceph_msg *msg, struct ceph_connection *con) argument
1883 reset_changed_osds(struct ceph_osd_client *osdc) argument
1906 kick_requests(struct ceph_osd_client *osdc, bool force_resend, bool force_resend_writes) argument
1999 ceph_osdc_handle_map(struct ceph_osd_client *osdc, struct ceph_msg *msg) argument
2156 __insert_event(struct ceph_osd_client *osdc, struct ceph_osd_event *new) argument
2178 __find_event(struct ceph_osd_client *osdc, u64 cookie) argument
2200 struct ceph_osd_client *osdc = event->osdc; local
2211 ceph_osdc_create_event(struct ceph_osd_client *osdc, void (*event_cb)(u64, u64, u8, void *), void *data, struct ceph_osd_event **pevent) argument
2243 struct ceph_osd_client *osdc = event->osdc; local
2274 handle_watch_notify(struct ceph_osd_client *osdc, struct ceph_msg *msg) argument
2426 ceph_osdc_start_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req, bool nofail) argument
2451 struct ceph_osd_client *osdc = req->r_osdc; local
2466 ceph_osdc_wait_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument
2490 ceph_osdc_sync(struct ceph_osd_client *osdc) argument
2525 ceph_osdc_flush_notifies(struct ceph_osd_client *osdc) argument
2535 ceph_osdc_init(struct ceph_osd_client *osdc, struct ceph_client *client) argument
2598 ceph_osdc_stop(struct ceph_osd_client *osdc) argument
2618 ceph_osdc_readpages(struct ceph_osd_client *osdc, struct ceph_vino vino, struct ceph_file_layout *layout, u64 off, u64 *plen, u32 truncate_seq, u64 truncate_size, struct page **pages, int num_pages, int page_align) argument
2659 ceph_osdc_writepages(struct ceph_osd_client *osdc, struct ceph_vino vino, struct ceph_file_layout *layout, struct ceph_snap_context *snapc, u64 off, u64 len, u32 truncate_seq, u64 truncate_size, struct timespec *mtime, struct page **pages, int num_pages) argument
2725 struct ceph_osd_client *osdc; local
2760 struct ceph_osd_client *osdc = osd->o_osdc; local
2879 struct ceph_osd_client *osdc = o->o_osdc; local
2907 struct ceph_osd_client *osdc = o->o_osdc; local
2916 struct ceph_osd_client *osdc = o->o_osdc; local
[all...]
H A Ddebugfs.c23 * .../osdc - active osd requests
56 struct ceph_osdmap *map = client->osdc.osdmap;
145 struct ceph_osd_client *osdc = &client->osdc; local
148 mutex_lock(&osdc->request_mutex);
149 for (p = rb_first(&osdc->requests); p; p = rb_next(p)) {
178 mutex_unlock(&osdc->request_mutex);
223 client->osdc.debugfs_file = debugfs_create_file("osdc",
228 if (!client->osdc
[all...]
H A Dceph_common.c525 err = ceph_osdc_init(&client->osdc, client);
546 ceph_osdc_stop(&client->osdc);
565 client->osdc.osdmap && client->osdc.osdmap->epoch;
H A Dmon_client.c1124 ceph_osdc_handle_map(&monc->client->osdc, msg);

Completed in 77 milliseconds