Home
last modified time | relevance | path

Searched refs:pin (Results 1 – 18 of 18) sorted by relevance

/fs/bcachefs/
A Djournal_reclaim.h22 static inline bool journal_pin_active(struct journal_entry_pin *pin) in journal_pin_active() argument
24 return pin->seq != 0; in journal_pin_active()
30 EBUG_ON(seq < j->pin.front || seq >= j->pin.back); in journal_seq_pin()
32 return &j->pin.data[seq & j->pin.mask]; in journal_seq_pin()
44 struct journal_entry_pin *pin, in bch2_journal_pin_add() argument
47 if (unlikely(!journal_pin_active(pin) || pin->seq > seq)) in bch2_journal_pin_add()
48 bch2_journal_pin_set(j, seq, pin, flush_fn); in bch2_journal_pin_add()
57 struct journal_entry_pin *pin, in bch2_journal_pin_update() argument
60 if (unlikely(!journal_pin_active(pin) || pin->seq < seq)) in bch2_journal_pin_update()
61 bch2_journal_pin_set(j, seq, pin, flush_fn); in bch2_journal_pin_update()
A Djournal_reclaim.c64 bool low_on_pin = fifo_free(&j->pin) < j->pin.size / 4; in bch2_journal_set_watermark()
341 j->pin.front++; in bch2_journal_reclaim_fast()
379 pin->seq = 0; in __journal_pin_drop()
431 pin->seq = seq; in bch2_journal_pin_set_locked()
432 pin->flush = flush_fn; in bch2_journal_pin_set_locked()
587 if (pin) { in journal_flush_pins()
591 flush_fn = pin->flush; in journal_flush_pins()
595 if (!pin) in journal_flush_pins()
904 !fifo_used(&j->pin); in journal_flush_done()
1016 prt_printf(out, "\t%px %ps\n", pin, pin->flush); in bch2_journal_seq_pins_to_text()
[all …]
A Dbtree_write_buffer.c145 EBUG_ON(!trans->c->btree_write_buffer.flushing.pin.seq); in wb_flush_one()
146 EBUG_ON(trans->c->btree_write_buffer.flushing.pin.seq > wb->journal_seq); in wb_flush_one()
256 bch2_journal_pin_drop(j, &wb->inc.pin); in move_keys_from_inc_to_flushing()
258 bch2_journal_pin_update(j, wb->inc.keys.data[0].journal_seq, &wb->inc.pin, in move_keys_from_inc_to_flushing()
449 bch2_journal_pin_update(j, i->journal_seq, &wb->flushing.pin, in bch2_btree_write_buffer_flush_locked()
496 bch2_journal_pin_drop(j, &wb->flushing.pin); in bch2_btree_write_buffer_flush_locked()
576 (wb->inc.pin.seq && wb->inc.pin.seq <= max_seq) || in btree_write_buffer_flush_seq()
577 (wb->flushing.pin.seq && wb->flushing.pin.seq <= max_seq))); in btree_write_buffer_flush_seq()
741 bch2_journal_pin_add(&c->journal, dst->seq, &dst->wb->pin, in bch2_journal_key_to_wb_slowpath()
793 bch2_journal_pin_add(&c->journal, seq, &dst->wb->pin, in bch2_journal_keys_to_write_buffer_start()
[all …]
A Djournal.c409 if (!fifo_free(&j->pin)) in journal_entry_open()
452 if (fifo_empty(&j->pin) && j->reclaim_thread) in journal_entry_open()
460 journal_pin_list_init(fifo_push_ref(&j->pin), 1); in journal_entry_open()
470 BUG_ON(j->pin.back - 1 != atomic64_read(&j->seq)); in journal_entry_open()
1513 init_fifo(&j->pin, roundup_pow_of_two(nr), GFP_KERNEL); in bch2_fs_journal_start()
1514 if (!j->pin.data) { in bch2_fs_journal_start()
1525 j->pin.front = last_seq; in bch2_fs_journal_start()
1526 j->pin.back = cur_seq; in bch2_fs_journal_start()
1530 fifo_for_each_entry_ptr(p, &j->pin, seq) in bch2_fs_journal_start()
1670 free_fifo(&j->pin); in bch2_fs_journal_exit()
[all …]
A Dbtree_trans_commit.c229 static int __btree_node_flush(struct journal *j, struct journal_entry_pin *pin, in __btree_node_flush() argument
233 struct btree_write *w = container_of(pin, struct btree_write, journal); in __btree_node_flush()
262 int bch2_btree_node_flush0(struct journal *j, struct journal_entry_pin *pin, u64 seq) in bch2_btree_node_flush0() argument
264 return __btree_node_flush(j, pin, 0, seq); in bch2_btree_node_flush0()
267 int bch2_btree_node_flush1(struct journal *j, struct journal_entry_pin *pin, u64 seq) in bch2_btree_node_flush1() argument
269 return __btree_node_flush(j, pin, 1, seq); in bch2_btree_node_flush1()
A Dbtree_write_buffer_types.h46 struct journal_entry_pin pin; member
A Dalloc_foreground.h141 if (atomic_dec_and_test(&ob->pin)) in bch2_open_bucket_put()
182 atomic_inc(&ob->pin); in bch2_open_bucket_get()
A Dalloc_types.h42 atomic_t pin; member
A Djournal_types.h255 } pin; member
A Djournal.h128 return j->pin.front; in journal_last_seq()
A Dbtree_key_cache.c536 struct journal_entry_pin *pin, u64 seq) in bch2_btree_key_cache_journal_flush() argument
540 container_of(pin, struct bkey_cached, journal); in bch2_btree_key_cache_journal_flush()
A Dalloc_foreground.c147 atomic_set(&ob->pin, 1); in bch2_open_bucket_alloc()
1459 atomic_read(&ob->pin)); in bch2_open_bucket_to_text()
A Djournal_io.c1733 if (seq >= j->pin.front) in CLOSURE_CALLBACK()
/fs/
A Dfs_pin.c10 void pin_remove(struct fs_pin *pin) in pin_remove() argument
13 hlist_del_init(&pin->m_list); in pin_remove()
14 hlist_del_init(&pin->s_list); in pin_remove()
16 spin_lock_irq(&pin->wait.lock); in pin_remove()
17 pin->done = 1; in pin_remove()
18 wake_up_locked(&pin->wait); in pin_remove()
19 spin_unlock_irq(&pin->wait.lock); in pin_remove()
22 void pin_insert(struct fs_pin *pin, struct vfsmount *m) in pin_insert() argument
25 hlist_add_head(&pin->s_list, &m->mnt_sb->s_pins); in pin_insert()
26 hlist_add_head(&pin->m_list, &real_mount(m)->mnt_pins); in pin_insert()
/fs/gfs2/
A Dtrace_gfs2.h329 TP_PROTO(const struct gfs2_bufdata *bd, int pin),
331 TP_ARGS(bd, pin),
335 __field( int, pin )
343 __entry->pin = pin;
351 __entry->pin ? "pin" : "unpin",
/fs/resctrl/
A DKconfig30 Software mechanism to pin data in a cache portion using
/fs/f2fs/
A Dfile.c3488 __u32 pin; in f2fs_ioc_set_pin_file() local
3491 if (get_user(pin, (__u32 __user *)arg)) in f2fs_ioc_set_pin_file()
3500 if (!pin && IS_DEVICE_ALIASING(inode)) in f2fs_ioc_set_pin_file()
3514 if (!pin) { in f2fs_ioc_set_pin_file()
3561 __u32 pin = 0; in f2fs_ioc_get_pin_file() local
3564 pin = F2FS_I(inode)->i_gc_failures; in f2fs_ioc_get_pin_file()
3565 return put_user(pin, (u32 __user *)arg); in f2fs_ioc_get_pin_file()
/fs/btrfs/
A Dtree-log.c317 int pin; member
368 if (wc->pin) { in process_one_buffer()
7265 wc.pin = 1; in btrfs_recover_log_trees()
7388 if (wc.pin) { in btrfs_recover_log_trees()
7389 wc.pin = 0; in btrfs_recover_log_trees()

Completed in 66 milliseconds