Home
last modified time | relevance | path

Searched refs:cursor (Results 1 – 10 of 10) sorted by relevance

/net/ceph/
A Dmessenger.c788 cursor->bvec_iter.bi_size = cursor->resid; in ceph_msg_data_bvecs_cursor_init()
790 BUG_ON(cursor->resid < bvec_iter_len(bvecs, cursor->bvec_iter)); in ceph_msg_data_bvecs_cursor_init()
859 BUG_ON(cursor->page_index >= cursor->page_count); in ceph_msg_data_pages_next()
886 BUG_ON(cursor->page_index >= cursor->page_count); in ceph_msg_data_pages_advance()
932 BUG_ON(cursor->offset + cursor->resid != pagelist->length); in ceph_msg_data_pagelist_next()
951 BUG_ON(cursor->offset + cursor->resid != pagelist->length); in ceph_msg_data_pagelist_advance()
968 cursor->page = list_next_entry(cursor->page, lru); in ceph_msg_data_pagelist_advance()
980 cursor->resid = iov_iter_count(&cursor->iov_iter); in ceph_msg_data_iter_cursor_init()
990 iov_iter_revert(&cursor->iov_iter, cursor->lastlen); in ceph_msg_data_iter_next()
1021 iov_iter_advance(&cursor->iov_iter, bytes - cursor->lastlen); in ceph_msg_data_iter_advance()
[all …]
A Dmessenger_v1.c468 struct ceph_msg_data_cursor *cursor = &msg->cursor; in write_partial_message_data() local
486 while (cursor->total_resid) { in write_partial_message_data()
492 if (!cursor->resid) { in write_partial_message_data()
997 struct ceph_msg_data_cursor *cursor = &con->in_msg->cursor; in read_partial_sparse_msg_extent() local
1023 cursor->sr_resid -= ret; in read_partial_sparse_msg_extent()
1032 struct ceph_msg_data_cursor *cursor = &con->in_msg->cursor; in read_partial_sparse_msg_data() local
1040 while (cursor->total_resid) { in read_partial_sparse_msg_data()
1069 struct ceph_msg_data_cursor *cursor = &con->in_msg->cursor; in read_partial_msg_data() local
1080 if (!cursor->resid) { in read_partial_msg_data()
1106 struct ceph_msg_data_cursor *cursor = &con->in_msg->cursor; in read_partial_msg_data_bounce() local
[all …]
A Dmessenger_v2.c865 WARN_ON(!cursor->total_resid); in get_bvec_at()
868 while (!cursor->resid) in get_bvec_at()
905 get_bvec_at(cursor, &bv); in calc_sg_cnt_cursor()
955 get_bvec_at(cursor, &bv); in init_sgs_cursor()
1114 get_bvec_at(cursor, &bv); in process_v2_sparse_read()
1940 get_bvec_at(cursor, &bv); in prepare_sparse_read_cont()
1955 WARN_ON_ONCE(cursor->sr_resid > cursor->total_resid); in prepare_sparse_read_cont()
1956 if (cursor->sr_resid) { in prepare_sparse_read_cont()
1957 get_bvec_at(cursor, &bv); in prepare_sparse_read_cont()
2002 __func__, ret, cursor->total_resid, cursor->resid); in prepare_sparse_read_cont()
[all …]
A Dosd_client.c5692 static void advance_cursor(struct ceph_msg_data_cursor *cursor, size_t len, in advance_cursor() argument
5699 page = ceph_msg_data_next(cursor, &poff, &plen); in advance_cursor()
5705 ceph_msg_data_advance(cursor, plen); in advance_cursor()
5710 struct ceph_msg_data_cursor *cursor) in prep_next_sparse_read() argument
5740 __func__, o->o_osd, op->extent.sparse_ext_cnt, cursor->resid); in prep_next_sparse_read()
5744 advance_cursor(cursor, sr->sr_req_len - end, false); in prep_next_sparse_read()
5796 struct ceph_msg_data_cursor *cursor, in osd_sparse_read() argument
5808 ret = prep_next_sparse_read(con, cursor); in osd_sparse_read()
5882 advance_cursor(cursor, eoff - sr->sr_pos, true); in osd_sparse_read()
5888 cursor->sr_resid = elen; in osd_sparse_read()
/net/rxrpc/
A Dpeer_event.c246 u8 cursor) in rxrpc_peer_keepalive_dispatch() argument
283 slot += cursor; in rxrpc_peer_keepalive_dispatch()
307 u8 cursor, stop; in rxrpc_peer_keepalive_worker() local
312 cursor = rxnet->peer_keepalive_cursor; in rxrpc_peer_keepalive_worker()
313 _enter("%lld,%u", base - now, cursor); in rxrpc_peer_keepalive_worker()
329 while (base <= now && (s8)(cursor - stop) < 0) { in rxrpc_peer_keepalive_worker()
333 cursor++; in rxrpc_peer_keepalive_worker()
340 rxnet->peer_keepalive_cursor = cursor; in rxrpc_peer_keepalive_worker()
345 cursor = rxnet->peer_keepalive_cursor; in rxrpc_peer_keepalive_worker()
346 stop = cursor + RXRPC_KEEPALIVE_TIME - 1; in rxrpc_peer_keepalive_worker()
[all …]
A Dconn_service.c67 struct rxrpc_connection *cursor = NULL; in rxrpc_publish_service_conn() local
77 cursor = rb_entry(parent, in rxrpc_publish_service_conn()
80 if (cursor->proto.index_key < k.index_key) in rxrpc_publish_service_conn()
82 else if (cursor->proto.index_key > k.index_key) in rxrpc_publish_service_conn()
97 if (refcount_read(&cursor->ref) == 0) in rxrpc_publish_service_conn()
109 rb_replace_node_rcu(&cursor->service_node, in rxrpc_publish_service_conn()
112 clear_bit(RXRPC_CONN_IN_SERVICE_CONNS, &cursor->flags); in rxrpc_publish_service_conn()
A Dlocal_object.c252 struct hlist_node *cursor; in rxrpc_lookup_local() local
261 hlist_for_each(cursor, &rxnet->local_endpoints) { in rxrpc_lookup_local()
262 local = hlist_entry(cursor, struct rxrpc_local, link); in rxrpc_lookup_local()
297 if (cursor) { in rxrpc_lookup_local()
298 hlist_replace_rcu(cursor, &local->link); in rxrpc_lookup_local()
299 cursor->pprev = NULL; in rxrpc_lookup_local()
/net/sunrpc/
A Dxprtmultipath.c417 struct rpc_xprt **cursor, in xprt_switch_set_next_cursor() argument
422 old = smp_load_acquire(cursor); in xprt_switch_set_next_cursor()
424 smp_store_release(cursor, pos); in xprt_switch_set_next_cursor()
/net/smc/
A Dsmc_cdc.c42 &cdcpend->cursor); in smc_cdc_tx_handler()
48 smc_curs_copy(&conn->tx_curs_fin, &cdcpend->cursor, conn); in smc_cdc_tx_handler()
107 pend->cursor = conn->tx_curs_sent; in smc_cdc_add_pending_send()
A Dsmc_cdc.h284 union smc_host_cursor cursor; /* tx sndbuf cursor sent */ member

Completed in 36 milliseconds