Home
last modified time | relevance | path

Searched refs:front (Results 1 – 20 of 20) sorted by relevance

/fs/netfs/
A Dread_collect.c208 front = READ_ONCE(stream->front); in netfs_collect_read_results()
209 while (front) { in netfs_collect_read_results()
214 front->debug_index, front->start, front->transferred, front->len); in netfs_collect_read_results()
236 front->error == 0 && in netfs_collect_read_results()
241 transferred = front->transferred = front->len; in netfs_collect_read_results()
252 rreq->abandon_to = front->start + front->len; in netfs_collect_read_results()
253 front->transferred = front->len; in netfs_collect_read_results()
288 if (front->transferred < front->len) in netfs_collect_read_results()
297 remove = front; in netfs_collect_read_results()
298 trace_netfs_sreq(front, in netfs_collect_read_results()
[all …]
A Dwrite_collect.c231 front = stream->front; in netfs_collect_write_results()
232 while (front) { in netfs_collect_write_results()
239 stream->collected_to = front->start; in netfs_collect_write_results()
250 stream->collected_to = front->start + front->len; in netfs_collect_write_results()
254 if (front->start + front->transferred > stream->collected_to) { in netfs_collect_write_results()
255 stream->collected_to = front->start + front->transferred; in netfs_collect_write_results()
262 stream->error = front->error; in netfs_collect_write_results()
268 if (front->transferred < front->len) { in netfs_collect_write_results()
278 remove = front; in netfs_collect_write_results()
279 list_del_init(&front->rreq_link); in netfs_collect_write_results()
[all …]
A Ddirect_read.c74 stream->front = subreq; in netfs_dispatch_unbuffered_reads()
76 stream->collected_to = stream->front->start; in netfs_dispatch_unbuffered_reads()
A Dread_single.c110 stream->front = subreq; in netfs_single_dispatch_read()
A Dbuffered_read.c174 stream->front = subreq; in netfs_queue_read()
176 stream->collected_to = stream->front->start; in netfs_queue_read()
A Dwrite_issue.c210 stream->front = subreq; in netfs_prepare_write()
212 stream->collected_to = stream->front->start; in netfs_prepare_write()
/fs/bcachefs/
A Dfifo.h9 size_t front, back, size, mask; \
22 (fifo)->front = (fifo)->back = 0; \
38 swap((l)->front, (r)->front); \
53 #define fifo_used(fifo) (((fifo)->back - (fifo)->front))
56 #define fifo_empty(fifo) ((fifo)->front == (fifo)->back)
64 ? (fifo)->front : (fifo)->back) & ~(fifo)->mask) + \
96 (i) = (fifo)->data[(fifo)->front++ & (fifo)->mask]; \
114 for (typecheck(typeof((_fifo)->front), _iter), \
115 (_iter) = (_fifo)->front; \
121 for (typecheck(typeof((_fifo)->front), _iter), \
[all …]
A Djournal_reclaim.h30 EBUG_ON(seq < j->pin.front || seq >= j->pin.back); in journal_seq_pin()
A Djournal_types.h253 u64 front, back, size, mask; member
A Djournal_reclaim.c339 j->pin.front <= j->seq_ondisk && in bch2_journal_reclaim_fast()
341 j->pin.front++; in bch2_journal_reclaim_fast()
999 *seq = max(*seq, j->pin.front); in bch2_journal_seq_pins_to_text()
A Djournal.h128 return j->pin.front; in journal_last_seq()
A Djournal.c1525 j->pin.front = last_seq; in bch2_fs_journal_start()
A Djournal_io.c1733 if (seq >= j->pin.front) in CLOSURE_CALLBACK()
/fs/ceph/
A Dmds_client.c1453 h = msg->front.iov_base; in ceph_create_session_msg()
1592 p = msg->front.iov_base; in create_session_full_msg()
1593 end = p + msg->front.iov_len; in create_session_full_msg()
1650 msg->front.iov_len = p - msg->front.iov_base; in create_session_full_msg()
2350 head = msg->front.iov_base; in ceph_send_cap_releases()
2353 item = msg->front.iov_base + msg->front.iov_len; in ceph_send_cap_releases()
2364 cap_barrier = msg->front.iov_base + msg->front.iov_len; in ceph_send_cap_releases()
2384 cap_barrier = msg->front.iov_base + msg->front.iov_len; in ceph_send_cap_releases()
3146 end = msg->front.iov_base + msg->front.iov_len; in create_request_message()
3207 msg->front.iov_len = p - msg->front.iov_base; in create_request_message()
[all …]
A Dmetric.c60 head = msg->front.iov_base; in ceph_mdsc_send_metrics()
176 msg->front.iov_len = len; in ceph_mdsc_send_metrics()
179 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in ceph_mdsc_send_metrics()
A Dquota.c45 struct ceph_mds_quota *h = msg->front.iov_base; in ceph_handle_quota()
54 if (msg->front.iov_len < sizeof(*h)) { in ceph_handle_quota()
56 session->s_mds, (int)msg->front.iov_len); in ceph_handle_quota()
A Dsnap.c1027 void *p = msg->front.iov_base; in ceph_handle_snap()
1028 void *e = p + msg->front.iov_len; in ceph_handle_snap()
1040 if (msg->front.iov_len < sizeof(*h)) in ceph_handle_snap()
A Dcaps.c1264 fc = msg->front.iov_base; in encode_cap_msg()
4354 end = msg->front.iov_base + msg->front.iov_len; in ceph_handle_caps()
4355 if (msg->front.iov_len < sizeof(*h)) in ceph_handle_caps()
4357 h = msg->front.iov_base; in ceph_handle_caps()
/fs/f2fs/
A Dextent_cache.c150 struct extent_info *front, enum extent_type type) in __is_extent_mergeable() argument
156 if (front->c_len && front->len != front->c_len) in __is_extent_mergeable()
159 return (back->fofs + back->len == front->fofs && in __is_extent_mergeable()
160 back->blk + back->len == front->blk); in __is_extent_mergeable()
162 return (back->fofs + back->len == front->fofs && in __is_extent_mergeable()
163 abs(back->age - front->age) <= SAME_AGE_REGION && in __is_extent_mergeable()
164 abs(back->last_blocks - front->last_blocks) <= in __is_extent_mergeable()
177 struct extent_info *front, enum extent_type type) in __is_front_mergeable() argument
179 return __is_extent_mergeable(cur, front, type); in __is_front_mergeable()
A Df2fs.h929 struct discard_info *front, unsigned int max_len) in __is_discard_mergeable() argument
931 return (back->lstart + back->len == front->lstart) && in __is_discard_mergeable()
932 (back->len + front->len <= max_len); in __is_discard_mergeable()
942 struct discard_info *front, unsigned int max_len) in __is_discard_front_mergeable() argument
944 return __is_discard_mergeable(cur, front, max_len); in __is_discard_front_mergeable()

Completed in 77 milliseconds