Lines Matching defs:seq
122 trans->journal_res.seq = wb->journal_seq;
141 EBUG_ON(!trans->c->btree_write_buffer.flushing.pin.seq);
142 EBUG_ON(trans->c->btree_write_buffer.flushing.pin.seq > wb->journal_seq);
177 * Update a btree with a write buffered key using the journal seq of the
182 * have already been modified in the active write buffer in a seq that comes
196 trans->journal_res.seq = wb->journal_seq;
374 * The fastpath zapped the seq of keys that were successfully flushed so
412 static int fetch_wb_keys_from_journal(struct bch_fs *c, u64 seq)
418 while (!ret && (buf = bch2_next_write_buffer_flush_journal_buf(j, seq))) {
426 static int btree_write_buffer_flush_seq(struct btree_trans *trans, u64 seq)
435 fetch_from_journal_err = fetch_wb_keys_from_journal(c, seq);
446 (wb->inc.pin.seq && wb->inc.pin.seq <= seq) ||
447 (wb->flushing.pin.seq && wb->flushing.pin.seq <= seq)));
453 struct journal_entry_pin *_pin, u64 seq)
457 return bch2_trans_run(c, btree_write_buffer_flush_seq(trans, seq));
525 bch2_journal_pin_add(&c->journal, dst->seq, &dst->wb->pin,
537 BUG_ON(!dst->seq);
540 wb_k->journal_seq = dst->seq;
548 void bch2_journal_keys_to_write_buffer_start(struct bch_fs *c, struct journal_keys_to_wb *dst, u64 seq)
575 dst->seq = seq;
577 bch2_journal_pin_add(&c->journal, seq, &dst->wb->pin,
603 bch2_journal_keys_to_write_buffer_start(c, &dst, le64_to_cpu(buf->data->seq));