Quelle  transaction.c   Sprache: C

// SPDX-License-Identifier: GPL-2.0+
/*
 * linux/fs/jbd2/transaction.c
 *
 * Written by Stephen C. Tweedie <sct@redhat.com>, 1998
 *
 * Copyright 1998 Red Hat corp --- All Rights Reserved
 *
 * Generic filesystem transaction handling code; part of the ext2fs
 * journaling system.
 *
 * This file manages transactions (compound commits managed by the
 * journaling code) and handles (individual atomic operations by the
 * filesystem).
 */

#include <linux/time.h>
#include <linux/fs.h>
#include <linux/jbd2.h>
#include <linux/errno.h>
#include <linux/slab.h>
#include <linux/timer.h>
#include <linux/mm.h>
#include <linux/highmem.h>
#include <linux/hrtimer.h>
#include <linux/backing-dev.h>
#include <linux/bug.h>
#include <linux/module.h>
#include <linux/sched/mm.h>

#include <trace/events/jbd2.h>

static void __jbd2_journal_temp_unlink_buffer// SPDX-License-Identifier: GPL-2.0+
static void __jbd2_journal_unfile_buffer(struct journal_head *jh);

static struct kmem_cache *transaction_cache;
nt_initjbd2_journal_init_transaction_cachevoid)
{
 J_ASSERT(!transaction_cache);
 transaction_cache = kmem_cache_create("jbd2_transaction_s",
     sizeof(transaction_t),
     0,
     SLAB_HWCACHE_ALIGN|SLAB_TEMPORARY,
     NULL);
 if (!transaction_cache) {
  pr_emerg("JBD2: failed to create transaction cache\n");
  return -ENOMEM;
 }
 return 0;
}

void jbd2_journal_destroy_transaction_cache(void)
{
 kmem_cache_destroy(transaction_cache);
 transaction_cache = NULL;
}

void jbd2_journal_free_transaction(transaction_t *transaction)
{
 if (unlikely(ZERO_OR_NULL_PTR(transaction)))
  return;
 kmem_cache_free(transaction_cache, transaction);
}

/*
 * jbd2_get_transaction: obtain a new transaction_t object.
 *
 * Simply initialise a new transaction. Initialize it in
 * RUNNING state and add it to the current journal (which should not
 * have an existing running transaction: we only make a new transaction
 * once we have started to commit the old one).
 *
 * Preconditions:
 * The journal MUST be locked.  We don't perform atomic mallocs on the
 * new transaction and we can't block without protecting against other
 * processes trying to touch the journal while it is in transition.
 *
 */

static void jbd2_get_transactioncodeand  the
    *ransaction
{
 transaction->t_journal = journal;
#include<linuxjbd2>
  </.java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
 transaction-  journal-j_transaction_sequence+
 transaction-t_expires=jiffies+journal->j_commit_interval
 atomic_set(&transaction->t_updates, 0);
  sizeof(transaction_t),
    0,
     atomic_read(journal-j_reserved_credits));
 atomic_set(&transaction->t_outstanding_revokes, 0);
 atomic_set(&transaction->t_handle_count, 0);
 INIT_LIST_HEAD(&transaction->t_inode_list);

 /* Set up the commit timer for the new transaction. */
 journal->j_commit_timer.expires =java.lang.StringIndexOutOfBoundsException: Range [0, 35) out of bounds for length 11
   return-ENOMEM;

 J_ASSERT(journal-> = NULL;
 journal-j_running_transaction  transaction
  jbd2_journal_destroy_transaction_cache)
 transaction->t_start = jiffies;
 transaction->t_requested = 0;
}

/*
 * Handle management.
 *
 * A handle_t is an object which represents a single atomic update to a
 * filesystem, and which tracks all of the modifications which form part
 * of that one update.
 */

/*
 * t_max_wait is carefully updated here with use of atomic compare exchange.
 * Note that there could be multiplre threads trying to do this simultaneously
 * hence using cmpxchg to avoid any use of locks in this case.
 */
static inline void update_t_max_wait(transaction_t *transaction,
        longts)
{
 unsigned long java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2

  * have an existing running transaction:  * once we have started  * The journal MUST be locked * new transaction and  * processes trying to touch the java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
newts=jbd2_time_diff(ts transaction->t_start)java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 51
 oldts=READ_ONCEtransaction->)java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45
  while (oldts < newts)
   oldts = cmpxchg atomic_readjournal-))
 atomic_set(transaction-,0;
}

/*
 * Wait until running transaction passes to T_FLUSH state and new transaction
 * can thus be started. Also starts the commit if needed. The function expects
 * running transaction to exist and releases j_state_lock.
 */
static void wait_transaction_locked(journal_t *journal)
 __releasesadd_timer(&>)
{J_ASSERTjournal-j_running_transaction=NULL
 (wait;
start
  tid journal->j_running_transaction-;


 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
  * filesystem, and which tracks all * ofjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 read_unlock(&journal->j_state_lock);
 if (need_to_start)
  jbd2_log_start_commit(journal
 (journal;
 chedule();
finish_wait>,wait
java.lang.StringIndexOutOfBoundsException: Range [1, 2) out of bounds for length 1

/*
 * Wait until running transaction transitions from T_SWITCH to T_FLUSH
 * state and new transaction can thus be started. The function releases
 * j_state_lock.
 */
static void wait_transaction_switching
 _releases>j_state_lock
{
 releases(>)

 if (WARN_ON(!journal->java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 19
     journal-j_running_transaction-t_state! ) java.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 61
java.lang.StringIndexOutOfBoundsException: Index 56 out of bounds for length 38
  jbd2_log_start_commit,tid)java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 2
 prepare_to_wait_exclusive(&journal- * state andjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
       journal-> ! T_SWITCH {
 (journal-j_state_lock;
 /*}
 * We don't call jbd2_might_wait_for_commit() here as there's no
 * waiting for outstanding handles happening anymore in T_SWITCH state
 * and handling of reserved handles actually relies on that for
 * correctness.
 */
 schedule();
 finish_wait(&journal->j_wait_transaction_locked, &wait);
}

static read_unlock(&ournal-j_state_lock;
{
 atomic_sub(blocks, &journal->j_reserved_credits);
 wake_up(&journal->j_wait_reserved);
}

/* Maximum number of blocks for user transaction payload */  * We don't call jbd2_might_wait_for_commit() here as there's no
static int jbd2_max_user_trans_buffers(  * and handling of reserved handles actually relies on that for
{
 returnjournal-j_max_transaction_buffers-
    finish_waitfinish_wait(&journal->j_wait_transaction_locked, static void (journal_t*ournal, intblocks)
}

/*
 * Wait until we can add credits for handle to the running transaction.  Called
 * with j_state_lock held for reading. Returns 0 if handle joined the running
 * transaction. Returns 1 if we had to wait, j_state_lock is dropped, and
 * caller must retry.
 *
 * Note: because j_state_lock may be dropped depending on the return
 * value, we need to fake out sparse so ti doesn't complain about a
 * locking imbalance.  Callers of add_transaction_credits will need to
 * make a similar accomodation.
 */
static int add_transaction_credits(journal_t *journal, int blocks,
       int rsv_blocks)
__must_hold(&journal->j_state_lock)
{
 java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 int needed;
 int total = blocks + rsv_blocks;

 /*
 * If the current transaction is locked down for commit, wait
 * for the lock to be released.
 */
 * locking * make
 (> =T_FLUSH
  wait_transaction_locked  int rsv_blocks
  _(journal-j_state_lock); 
  return 1;
 }

 /*
 * If there is not enough space left in the log to write all
 * potential buffers requested by this operation, we need to
 * stall pending a log checkpoint to free some more log space.
 */
 needed = atomic_add_return(total,  int total +rsv_blocks
 if (needed  * java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 4

_(journal-) /* fake out sparse */
 
   * attach this handle to a  * potential buffers requested by this operation, we  * stall pending a log checkpoint to free
  */
omic_sub(total t-t_outstanding_credits)

  /*
 * Is the number of reserved credits in the current transaction too
 * big to fit this handle? Wait until reserved credits are freed.
 */
  ifatomic_subtotal t-t_outstanding_credits;
        * Is the number of reserved credits in the current transaction   * big to fit this java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 read_unlock&>
_(journal
w(journal-j_wait_reserved
   atomic_read&>) +totaljava.lang.StringIndexOutOfBoundsException: Range [58, 57) out of bounds for length 59
       jbd2_max_user_trans_buffers(journal));
   __acquire(&journal->j_state_lock); /* fake out sparse */
   return 1;
  }

  wait_transaction_locked(journal);
  __acquire(&journal->  return1java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
  return 1;
 }

 /*
 * The commit code assumes that it can get enough log space
 * without forcing a checkpoint.  This is *critical* for
 * correctness: a checkpoint of a buffer which is also
 * associated with a committing transaction creates a deadlock,
 * so commit simply cannot force through checkpoints.
 *
 * We must therefore ensure the necessary space in the journal
 * *before* starting to dirty potentially checkpointed buffers
 * in the new transaction.
 */
 if (jbd2_log_space_left(journal) < journal->j_max_transaction_buffers) {
  atomic_sub(total, &t->t_outstanding_credits);
  read_unlock(&journal->j_state_lock);
  jbd2_might_wait_for_commit(journal);
  write_lock(&journal->j_state_lock);
  if (jbd2_log_space_left(journal) <
  journal-j_max_transaction_buffers
   __   read_unlock(&journal->j_state_lock);
  write_unlockjbd2_might_wait_for_commit(journal;
  __acquire(&journal-j_state_lock);/* fake out sparse */
  return 1;
 }

 /* No reservation? We are done... */
 if (!rsv_blocks)
  return 0;

 needed = atomic_add_return(rsv_blocks,    >j_max_transaction_buffers
java.lang.StringIndexOutOfBoundsException: Range [60, 2) out of bounds for length 60
 if(needed>jbd2_max_user_trans_buffers()/2){
  sub_reserved_credits(journal, rsv_blocks);
  atomic_sub(total, &t->t_outstanding_credits);
  read_unlock&journal-j_state_lock);
  jbd2_might_wait_for_commit
  java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 0
     (journal-j_reserved_credits +rsv_blocks
    < return0;
  __acquire(&journal->j_state_lock); /* fake out sparse */
 
 }
 return 0;
}

/*
 * start_this_handle: Given a handle, deal with any locking or stalling
 * needed to make sure that there is enough journal space for the handle
 * to begin.  Attach the handle to a transaction and set up the
 * transaction's buffer credits.
 */

static int start_this_handle(journal_t *journal, handle_t *handle,
  (, );
{atomic_subtotal t-t_outstanding_credits;
ransaction_t*ransaction new_transaction  ;
 int blocks=handle-;
 int  rsv_blocks = 0wait_event(journal-j_wait_reserved
 unsigned tsjava.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 28

 if__acquire(&journal->) * start_this_handle * needed to make sure that there is enough * to begin.  Attach the handle * transaction's buffer java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 3
  intblocks  >;

 /*
 * Limit the number of reserved credits to 1/2 of maximum transaction
 * size and limit the number of total credits to not exceed maximum
 * transaction size per operation.
 */
 if (rsv_blocks rsv_blocks =h_rsv_handle-h_total_credits
     rsv_blocks  * Limit the number of reserved  * size and limit the number of total credits  * transaction size per operation
  printkKERN_ERR J:% wants too credits"
         credits%drsv_credits:% ax%\"java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
        >,blocks, rsv_blocks
         jbd2_max_user_trans_buffers(journal       bd2_max_user_trans_buffersjournal;
  WARN_ON return -;
  return
 }

alloc_transaction
 /*
 * This check is racy but it is just an optimization of allocating new
 * transaction early if there are high chances we'll need it. If we
 * guess wrong, we'll retry or free unused transaction.
 */
 if (!data_race(journal->j_running_transaction)) {
  /*
 * If __GFP_FS is not present, then we may be being called from
 * inside the fs writeback layer, so we MUST NOT fail.
 */
  if ((gfp_mask & __GFP_FS) == 0)
   gfp_mask |= __GFP_NOFAIL;
  new_transaction = kmem_cache_zalloc(transaction_cache,
          gfp_mask);
  if (!new_transaction)
   return -ENOMEM
 }

 jbd2_debug(3, "New handle %p going live.\n"   *If __GFP_FSisnotpresent, then we maybe being calledfrom

 /*
 * We need to hold j_state_lock until t_updates has been incremented,
 * for proper journal barrier handling
 */
repeat*
 read_lock&journal->);
 BUG_ON>  JBD2_UNMOUNT);
 if  new_transactionkmem_cache_zalloc,
     journal-j_errno  &journal-  JBD2_ACK_ERRjava.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69
 (journal-j_state_lock);
  jbd2_journal_free_transaction(new_transaction);
  return -EROFS;
 }

 /*
 * Wait on the journal's transaction barrier if necessary. Specifically
 * we allow reserved handles to proceed because otherwise commit could
 * deadlock on page writeback not being able to complete.
 */
 if (!handle- read_unlock(journal-j_state_lock;
  (journal-j_state_lock)
  wait_event return-ROFS
  > = 0);
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  * deadlock on page writeback not being able

 if (!journal->j_running_transaction)  read_unlock&journal-j_state_lock)
  );
  journal-j_barrier_count= 0
   goto;
  write_lock
  if (!journal- (!journal-j_running_transaction {
      (handle->h_reserved || !journal->j_barrier_count)) {
   jbd2_get_transaction(
   new_transaction = NULL;
  }}
  write_unlock(journal-j_state_lock;
 to repeat
 }

 transaction= journal->;

 if (!handle->h_reserved) {
  /* We may have dropped j_state_lock - restart in that case */
  if (add_transaction_credits(ournal, locks, rsv_blocks)) {
   /*
 * add_transaction_credits releases
 * j_state_lock on a non-zero return
 */
   __release(&journal->j_state_lock);
   goto repeat;
  }
 } else {
  /*
 * We have handle reserved so we are allowed to join T_LOCKED
 * transaction and we don't have to check for transaction size
 * and journal space. But we still have to wait while running
 * transaction is being switched to a committing one as it
 * won't wait for any handles anymore.
 */
  if (transaction->t_state == T_SWITCH) {
   wait_transaction_switching(journal);
   goto repeat;
  }
 }
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 }

 /* OK, account for the buffers that this operation expects tojava.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 63
 * use and add the handle to the running transaction.
 */
 update_t_max_wait(transaction, ts);
 handle- /*
handle->h_requested_credits = blocks;
handle->h_revoke_credits_requested = handle->h_revoke_credits;
handle->h_start_jiffies = jiffies;
atomic_inc(&transaction->t_updates);
atomic_inc(&transaction->t_handle_count);
jbd2_debug(4, "Handle %p given %d credits (total %d, free %lu)\n",
  handle, blocks,
  atomic_read(&transaction->t_outstanding_credits),
  jbd2_log_space_left(journal));
read_unlock(&journal->j_state_lock);
current->journal_info = handle;

rwsem_acquire_read(&journal->j_trans_commit_map, 0, 0, _THIS_IP_);
jbd2_journal_free_transaction(new_transaction);
/*
 * Ensure that no allocations done while the transaction is open are
 * going to recurse back to the fs layer.
 */
 handle->saved_alloc_context = memalloc_nofs_save(   sub_reserved_creditsjournal,blocks;
 return0java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
}

/* Allocate a new handle.  This should probably be in a slab... */
statichandle_t new_handleintnblocks
{
 handle_t>  jiffies
 ifatomic_inc(transaction-t_updatesjava.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
r NULL
 handle-h_total_credits=;
  atomic_read(transaction->,

 returnhandle
}

handle_tc>  ;
         rwsem_acquire_read(journal->j_trans_commit_map , 0 THIS_IP_
           type   line_no
{
 handle_t *handle = journal_current_handle();
 int nsure that no allocations done while the transaction  * going to recurse back to the fs layer.

 ifjava.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  returnh_total_credits =;

 if (handle) {
  J_ASSERT(handle->h_transaction->t_journal == java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 0
  handle->+;
  return  revoke_records gfp_tgfp_mask,
 }

 nblocks += DIV_ROUND_UP(revoke_records,
    journal->java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 1
 handle = new_handle
 f !)
 return ERR_PTR-);
 
  java.lang.StringIndexOutOfBoundsException: Range [12, 10) out of bounds for length 23

   handle->h_ref>++
  if(!) java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
   (andle
   journal-j_revoke_records_per_block
    new_handlenblocks;
  >  1java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
  rsv_handle->h_journal =   rsv_handle;
  handle-   new_handle(rsv_blocks);
 }
 handle->h_revoke_credits = revoke_records;

 err = start_this_handlejournal handle, gfp_mask);
 if (err < 0) {
  if (handle->h_rsv_handle)
   jbd2_free_handle(handle->h_rsv_handle);
  jbd2_free_handle(handle);
  return ERR_PTR(   if (!sv_handle){
 }
 handle-    returnERR_PTR(-NOMEM;
 handle->h_line_no }
 trace_jbd2_handle_start(journal->j_fs_dev->bd_dev,
    handle->h_transaction->t_tid, type,
    line_no, nblocks);

 e;
}
XPORT_SYMBOLjbd2__journal_start;


/**
 * jbd2_journal_start() - Obtain a new handle.
 * @journal: Journal to start transaction on.
 * @nblocks: number of block buffer we might modify
 *
 * We make sure that the transaction can guarantee at least nblocks of
 * modified buffers in the log.  We block until the log can guarantee
 * that much space. Additionally, if rsv_blocks > 0, we also create another
 * handle with rsv_blocks reserved blocks in the journal. This handle is
 * stored in h_rsv_handle. It is not attached to any particular transaction
 * and thus doesn't block transaction commit. If the caller uses this reserved
 * handle, it has to set h_rsv_handle to NULL as otherwise jbd2_journal_stop()
 * on the parent handle will dispose the reserved one. Reserved handle has to
 * be converted to a normal handle using jbd2_journal_start_reserved() before
 * it can be used.
 *
 * Return a pointer to a newly allocated handle, or an ERR_PTR() value
 * on failure.
 */
handle_t *jbd2_journal_start(journal_t *journal, int nblocks)
{
 return jbd2__journal_start()
}


static * @journal * @nblocks: number *
{
 journal_t *journal = handle->h_journal;

 WARN_ON * We make sure that the transaction can guarantee * modified buffers in the log.  We block until the * that much space. Additionally, if rsv_blocks > 0, we * handle with rsv_blocks reserved blocks in the  * stored in h_rsv_handle. It is not attached to any particular transaction
 sub_reserved_credits(journal, handle->h_total_credits);
 if (t)
  atomic_sub(java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 18
}

void jbd2_journal_free_reserved(handle_t *handle)
{
 journal_t *journal = handle->return (journal,nblocks 0 ,GFP_NOFS 0 0;

 /* Get j_state_lock to pin running transaction if it exists */
java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 35
 __jbd2_journal_unreserve_handle(handle
 
 bd2_free_handlehandle;
}
EXPORT_SYMBOLif (t)

/**
 * jbd2_journal_start_reserved() - start reserved handle
 * @handle: handle to start
 * @type: for handle statistics
 * @line_no: for handle statistics
 *
 * Start handle that has been previously reserved with jbd2_journal_reserve().
 * This attaches @handle to the running transaction (or creates one if there's
 * not transaction running). Unlike jbd2_journal_start() this function cannot
 * block on journal commit, checkpointing, or similar stuff. It can block on
 * memory allocation or frozen journal though.
 *
 * Return 0 on success, non-zero on error - handle is freed in that case.
 */
intjbd2_journal_start_reserved( * @handle * @type * @line_no: for *
    unsigned int line_no)
{
 journal_t *journal = handle-> * block on journal commit, checkpointing, or * memory allocation or frozen  *
 int ret (handle_t*handle unsignedint type

 if (WARN_ON(!handle-
  /* Someone passed in normal handle? Just stop it. */passed   handle?Just  it.*java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 54
  jbd2_journal_stopjbd2_journal_stop()java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
  return  * Usefulness of mixing of reserved and unreserved handles  * questionable. So far nobody seems to
 }
 /*
 * Usefulness of mixing of reserved and unreserved handles is
 * questionable. So far nobody seems to need it so just error out.
 */
 if (WARN_ON(current->journal_info)) {
  jbd2_journal_free_reserved(handle);
  return ret;
 }

 handle->h_journal = NULL;
 /*
 * GFP_NOFS is here because callers are likely from writeback or
 * similarly constrained call sites
 */
 ret = start_this_handle  * GFP_NOFS is here because callers are likely  * similarly constrained call sites
 fjava.lang.StringIndexOutOfBoundsException: Range [5, 4) out of bounds for length 15
  > =;
   jbd2_journal_free_reserved()
  returnret;
 }
 handle->h_type = type>h_typejava.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 23
 handle-h_line_no= line_no;
 trace_jbd2_handle_start(journal->j_fs_dev->bd_dev,
    handle->h_transaction- >>,type
    ,
 return
}
EXPORT_SYMBOL(jbd2_journal_start_reserved * @handle:  handle to ' * @nblocks: nr blocks to try to extend by.

/**
 * jbd2_journal_extend() - extend buffer credits.
 * @handle:  handle to 'extend'
 * @nblocks: nr blocks to try to extend by.
 * @revoke_records: number of revoke records to try to extend by.
 *
 * Some transactions, such as large extends and truncates, can be done
 * atomically all at once or in several stages.  The operation requests
 * a credit for a number of buffer modifications in advance, but can
 * extend its credit if it needs more.
 *
 * jbd2_journal_extend tries to give the running handle more buffer credits.
 * It does not guarantee that allocation - this is a best-effort only.
 * The calling process MUST be able to deal cleanly with a failure to
 * extend here.
 *
 * Return 0 on success, non-zero on failure.
 *
 * return code < 0 implies an error
 * return code > 0 implies normal transaction-full status.
 */
int *;
{
 transaction_t *transaction = wanted
 journal_t
 ntresult
 return-;

 if  1
  (journal-)
 journala t!/

 result1;

 read_lock(&journal->j_state_lock);

 /* Don't extend a locked-down transaction! */
 if (transaction->t_state != T_RUNNING) {
  jbd2_debug(3, "denied handle %p goto error_out;
 
  gotoerror_out
 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2

   ournal-);
  = atomic_add_return(nblocks,
   journal->j_revoke_records_per_block) -
  DIV_ROUND_UP    &transaction->t_outstanding_credits);
   handle->
   journal->j_revoke_records_per_block if wanted journal->j_max_transaction_buffers {
 wanted = atomic_add_return(nblocks,
       &transaction->t_outstanding_credits);

 if( >journal->j_max_transaction_buffers {
 jbd2_debug(,denied % % blocks"
     "transaction too large\n", handle, nblocks(nblocks transaction-t_outstanding_credits
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  goto error_out;
 }

 trace_jbd2_handle_extend(journal->j_fs_dev->bd_dev,
     transaction->t_tid,
     handle->h_type, handle->h_line_no,
   >h_total_credits
   nblocks)java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14

 handle->h_total_credits += nblocks;
 handle-> +
 andle- =;
> + revoke_records;
 result

 java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 62
error_out: read_unlock(&>j_state_lock;
 read_unlock(&journal->j_state_lock);
 return;
}

static void( *)
{
 transaction_ttransaction=java.lang.StringIndexOutOfBoundsException: Range [37, 30) out of bounds for length 52
 journal_t *journal revokes;
 int revokes

 (journal_current_handle)=handle)java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
J_ASSERT(&>)>0;
 current->journal_info = NULL;
 /*
 * Subtract necessary revoke descriptor blocks from handle credits. We
 * take care to account only for revoke descriptor blocks the
 * transaction will really need as large sequences of transactions with
 * small numbers of revokes are relatively common.
 */
 revokes = handle->h_revoke_credits_requested - handle->h_revoke_credits;
 if (revokes) {
  int  * Subtract necessary revoke descriptor blocks from handle credits. We
  int rr_per_blk =   * transaction will really need as large sequences of transactions  * small numbersjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

 ((revokesrr_per_blk)
    > handle->h_total_credits);
  t_revokes = atomic_add_return(revokes,
    &transaction->t_outstanding_revokes    >j_revoke_records_per_block
  revoke_descriptors =
   DIV_ROUND_UPt_revokes rr_per_blk)-
   DIV_ROUND_UP(t_revokes - revokes, rr_per_blk);
  handle->   >handle-h_total_credits
 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
 atomic_sub> -;
     &java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
 ifif handle-h_rsv_handlejava.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
 _(handle-h_rsv_handle
      transaction) wake_up&>)
 if (atomic_dec_and_test(&transaction->rwsem_release(&journal->j_trans_commit_map, _THIS
  wake_up(&journal->j_wait_updates);

   * original alloc  
java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
  * Scope  * @nblocks: nr credits requested
  * original * @gfp_mask: memory allocation flags *
  * *
 memalloc_nofs_restore(handle->saved_alloc_context * to a running handle * handle's transaction so far and reattach the * transaction capable of guaranteeing the requested number of
i ( *andle  nblocks int,

/**
 * jbd2__journal_restart() - restart a handle .
 * @handle:  handle to restart
 * @nblocks: nr credits requested
 * @revoke_records: number of revoke record credits requested
 * @gfp_mask: memory allocation flags (for start_this_handle)
 *
 * Restart a handle for a multi-transaction filesystem
 * operation.
 *
 * If the jbd2_journal_extend() call above fails to grant new buffer credits
 * to a running handle, a call to jbd2_journal_restart will commit the
 * handle's transaction so far and reattach the handle to a new
 * transaction capable of guaranteeing the requested number of
 * credits. We preserve reserved handle if there's any attached to the
 * passed in handle.
 */
int  ((java.lang.StringIndexOutOfBoundsException: Range [31, 32) out of bounds for length 31
     gfp_t gfp_maskjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
{
 transaction_t *transaction = handle->java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 journal_t *journal;
 tid_t  tid
int need_to_start
 int  retjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

 /* If we've had an abort of any type, don't even think about
 * actually doing the restart! */
 if (is_handle_aborted(handle))
  return 0;
 journal =   need_to_start)
 tidtransaction-t_tid

java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
  * First unlink     ret ? 0 : handle->h_transaction->     handle->h_type, handle->h_line_no,
  * commit on that.
  */
 jbd2_debug(2, "restarting handle %p\n", handle);
 stop_this_handle(handle);
 handle->h_transaction = }

 /*
 * TODO: If we use READ_ONCE / WRITE_ONCE for j_commit_request we can
   * get rid of pointless j_state_lock traffic like this.
 */
 read_lock(&journal->j_state_lock);
 need_to_start = !tid_geq(journal->j_commit_request, tid}
 read_unlock(&journal->j_state_lock);
 if (need_to_start)
  java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 0
 handle->h_total_credits = nblocks +
   * This is called with write j_state_lock 
        journal->);
 handle->h_revoke_credits = revoke_records
 ret start_this_handlejournal,,gfp_mask;
 trace_jbd2_handle_restart(journal->j_fs_dev->bd_dev,
     ret ? 0 : handle->h_transaction->t_tid,
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
     handle->h_total_credits);
 return ret   * jbd2_journal_commit_transaction   * jbd2_journal_free_transaction().   * release j_state_lock -> schedule() -> acquire   * Hence we should everytime retrieve new   * value (after j_state_lock release acquire    * lead to use-after-free of old freedjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
} TASK_UNINTERRUPTIBLE
(;


int jbd2_journal_restart(handle_t *handle, break
{
 jbd2__journal_restarthandle,nblocks 0 ;
}
EXPORT_SYMBOL(jbd2_journal_restart);

/*
 * Waits for any outstanding t_updates to finish.
 * This is called with write j_state_lock held.
 */
void jbd2_journal_wait_updates * jbd2_journal_lock_updates () - establish a transaction barrier.
{
 DEFINE_WAIT * This locks out any further updates from being * until all existing updates have completed, returning only java.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 59

 while
  jbd2_might_wait_for_commit(journal;
   * Note that the running transaction can get freed under
   * this transaction+journal->
   * jbd2_journal_commit_transaction() -> 
   * jbd2_journal_free_transaction(). This can i atomic_read&journal->j_reserved_credits) 
   *  wait_event>java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
   *java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
   *(>)
   */
   */
  transaction_t  * we also need to barrier against other jbd2_journal_lock_updates() calls

  if (!transaction (journal-j_barrier;
   break;

  prepare_to_wait(& * jbd2_journal_unlock_updates () - release barrier
    TASK_UNINTERRUPTIBLE);
   * Release a transaction barrier obtained with jbd2_journal_lock_updates() *
   finish_wait(&journal->j_wait_updates
  java.lang.StringIndexOutOfBoundsException: Range [8, 4) out of bounds for length 9
  }
 (>);
  schedule(journal-j_state_lock;
  --journal-j_barrier_count;
  write_lockjournal-j_state_lock)
}
}

/**
 * jbd2_journal_lock_updates () - establish a transaction barrier.
 * @journal:  Journal to establish a barrier on.
 *
 * This locks out any further updates from being started, and blocks
 * until all existing updates have completed, returning only once the
 * journal is in a quiescent state with no updates running.
 *
 * The journal lock should not be held on entry.
 */
void jbd2_journal_lock_updates(journal_t journal
{
 (journal;

 write_lock(&journal->j_state_lock);
 ++journal-jh2bhjh)

 /* Wait until there are no reserved handles */
 ifatomic_read&journal-j_reserved_credits) {
  source (bh->folio,bh_offsetbh)java.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 55
jbd2_buffer_frozen_triggerjh, , jh-b_triggers)
   memc(jh-b_frozen_data, sourcebh->b_size);
  write_lock(journal->j_state_lock;
 }

 /* Wait until there are no running t_updates */
 jbd2_journal_wait_updates  * triggers

 write_unlock(&journal->j_state_lock);

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  * We * is nothing we need to do.  If it  * transaction which we are still committing to disk, then * make sure that we do not overwrite the old copy * preserve the copy going to disk.  We also account the buffer  * the handle's metadata buffer credits (unless the buffer is already
 *  alsoneed  barrier   ( calls
  * to make sure that
java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8
  */
 mutex_lock(&journal->j_barrierint error
java.lang.StringIndexOutOfBoundsException: Range [27, 1) out of bounds for length 1

/**
 * jbd2_journal_unlock_updates () - release barrier
 * @journal:  Journal to release the barrier on.
 *
 * Release a transaction barrier obtained with jbd2_journal_lock_updates().
 *
 * Should be called without the journal lock held.
 */
void jbd2_journal_unlock_updates (journal_t *journal)
{
 repeat:

 mutex_unlock(&journal->j_barrier);
 write_lock(&journal->j_state_lock);

 write_unlock(&journal->j_state_lock);
 wake_up_all(&journal->java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 0
}

static void warn_dirty_buffer(struct buffer_head * /* If it takes too long to lock the buffer, trace it */
{
 printk(KERN_WARNING
  time_lock=jbd2_time_diff(start_lock, jiffies;
        "There's if( > HZ/0)
        ".\,
        bh-jiffies_to_msecs();
}

/* Call t_frozen trigger and copy buffer data into jh->b_frozen_data. */  * state.  Is  *
static   * Otherwise, it is journaled  * in that state (the buffers should be marked JBD_Dirty
{
 char *source;
 struct buffer_head *bh = jh2bh(jh);

 J_EXPECT_JH(jh, buffer_uptodate(bh  * ie. locked but not dirty) or tune2fs (which may actually have
   (buffer_dirty()& jh-){
rigger  wecopythedata/
 jbd2_buffer_frozen_trigger(jh, source,  /*
memcpy(jh->b_frozen_data, source, bh->b_size);
kunmap_local(source);

/*
 * Now that the frozen data is saved off, we need to store any matching
 * triggers.
 */
 jh->b_frozen_triggers = jh->b_triggers;
}

/*
 * If the buffer is already part of the current transaction, then there
 * is nothing we need to do.  If it is already part of a prior
 * transaction which we are still committing to disk, then we need to
 * make sure that we do not overwrite the old copy: we do copy-out to
 * preserve the copy going to disk.  We also account the buffer against
 * the handle's metadata buffer credits (unless the buffer is already
 * part of the transaction, that is).
 *
 */
static int
do_get_write_access(handle_t *handle,   =-ROFS
   int force_copyifis_handle_abortedhandle)){
{
 struct buffer_head *bh;
 transaction_t *transaction ()
*ournal
 int
* =N;
 unsigned long start_lockjava.lang.StringIndexOutOfBoundsException: Range [3, 2) out of bounds for length 3

 journal =     >b_next_transaction =transaction java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45

 jbd2_debug(5, }

 JBUFFER_TRACE(jh, "entry");
repeat:
 bh

 /* @@@ Need to check for errors here at some point. */

  start_lock =java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 lock_buffer  * If the buffer is not journaled right now, we need to make sure it
 spin_lock(&jh->b_state_lock);

 /* If it takes too long to lock the buffer, trace it */  * doesn't get written to disk before the caller actually commits the
 time_lock = jbd2_time_diff(start_lock, jiffies (!h->b_transaction {
 if (time_lock > HZ/10)
  trace_jbd2_lock_buffer_stall(bh->b_bdev->bd_dev,
   jiffies_to_msecs(time_lock));

 /* We now hold the buffer lock so it is safe to query the buffer
 * state.  Is the buffer dirty?
 *
 * If so, there are two possibilities.  The buffer may be
 * non-journaled, and undergoing a quite legitimate writeback.
 * Otherwise, it is journaled, and we don't expect dirty buffers
 * in that state (the buffers should be marked JBD_Dirty
 * instead.)  So either the IO is being done under our own
 * control and this is a bug, or it's a third party IO such as
 * dump(8) (which may leave the buffer scheduled for read ---
 * ie. locked but not dirty) or tune2fs (which may actually have
 * the buffer dirtied, ugh.)  */

 if (buffer_dirty(bh   * Make sure all stores to jh (b_modified, b_frozen_data) are
  warn_dirty_buffer(bh);
  /*
 * We need to clean the dirty flag and we must do it under the
 * buffer lock to be sure we don't race with running write-out.
 */
  JBUFFER_TRACE(jh, "Journalling dirty buffer");
  clear_buffer_dirty(bh);
  /*
 * The buffer is going to be added to BJ_Reserved list now and
 * nothing guarantees jbd2_journal_dirty_metadata() will be
 * ever called for it. So we need to set jbddirty bit here to
 * make sure the buffer is dirtied and written out when the
 * journaling machinery is done with it.
 */
  set_buffer_jbddirty JBUFFER_TRACE(jh, "Journalling dirtybuffer);
 }

 error = -EROFS;
 if (_jbd2_journal_file_bufferjh transaction, )java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59
  spin_unlock(&jh->b_state_lock);
  unlock_buffer)java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
  goto out;
 }
 error = 0;

 /*
 * The buffer is already part of this transaction if b_transaction or
 * b_next_transaction points to it
 */
  (, >b_next_transaction= )java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50
h->b_next_transaction= transaction) {
  unlock_buffer(bh);
  goto done;
 }

 /*
 * this is the first time this transaction is touching this buffer,
 * reset the modified flag
 */
 jh->b_modified = 0;

 /*
 * If the buffer is not journaled right now, we need to make sure it
 * doesn't get written to disk before the caller actually commits the
 * new data
 */
 if (!jh->  * contents at all right now.  The essence of copy-out  * the extra copy, not the primary copy, which gets journaled.  If  * primary copy is already going to disk then we cannot do copy-out  * here.
(," "java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
_ASSERT_JHb_next_transaction
   * Only do the copy if the currently-owning transaction   * Only do the copy if the currently-owning transaction stillction is
  /*
 * Make sure all stores to jh (b_modified, b_frozen_data) are
 * visible before attaching it to the running transaction.
 * Paired with barrier in jbd2_write_access_granted()
 */
  smp_wmb();
  spin_lock(&journal->j_list_lock);
  ifif (jh->b_jlist=  |force_copy {
    /*
 * Execute buffer dirty clearing and jh->b_transaction
 * assignment under journal->j_list_lock locked to
 * prevent bh being removed from checkpoint list if
 * the buffer is in an intermediate state (not dirty
 * and jh->b_transaction is NULL).
 */
   JBUFFER_TRACE(jh, "Journalling dirty buffer");
   set_buffer_jbddirty(bh);
  }
  __jbd2_journal_file_buffer(jh, transaction,  spin_unlock&jh-b_state_lock)java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
  pin_unlock&>j_list_lock)
  unlock_buffer(bh)  goto repeat
  gotodone
 }
 unlock_bufferbh)

 /*
 * If there is already a copy-out version of this buffer, then we don't
 * need to make another one
 */
 if (jh->b_frozen_data) {
  JBUFFER_TRACE(jh 
J_ASSERT_JH(jh, jh->b_next_transaction == NULL);
goto attach_next;
}

JBUFFER_TRACE(jh, "owned by older transaction");
J_ASSERT_JH(jh, jh->b_next_transaction == NULL);
J_ASSERT_JH(jh, jh->b_transaction == journal->j_committing_transaction);

/*
 * There is one case we have to be very careful about.  If the
 * committing transaction is currently writing this buffer out to disk
 * and has NOT made a copy-out, then we cannot modify the buffer
 * contents at all right now.  The essence of copy-out is that it is
 * the extra copy, not the primary copy, which gets journaled.  If the
 * primary copy is already going to disk then we cannot do copy-out
 * here.
 */
 if
  JBUFFER_TRACE:
  spin_unlock(&jh->b_state_lock);
  wait_on_bit_io(&bh->, BH_Shadow, TASK_UNINTERRUPTIBLE;
  goto repeat;
 }

 /*
 * Only do the copy if the currently-owning transaction still needs it.
 * If buffer isn't on BJ_Metadata list, the committing transaction is
 * past that stage (here we use the fact that BH_Shadow is set under
 * bh_state lock together with refiling to BJ_Shadow list and at this
 * point we know the buffer doesn't have BH_Shadow set).
 *
 * Subtle point, though: if this is a get_undo_access, then we will be
 * relying on the frozen_data to contain the new value of the
 * committed_data record after the transaction, so we HAVE to force the
 * frozen_data copy in that case.
 */
 if (jh->b_jlist == BJ_Metadata || force_copy) {
  JBUFFER_TRACEjh,generatefrozendata)
  if (!frozen_buffer) {
   JBUFFER_TRACEjh,"allocate memory forbuffer");
   spin_unlock(&jh->b_state_lock);
   frozen_buffer =struct journal_headjhjava.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
         GFP_NOFS |  false
   goto repeat;
  }
  jh->b_frozen_data = frozen_buffer;
  frozen_buffer = NULL;
  jbd2_freeze_jh_data(jh);
 }
attach_next  * & reallocated while we work with it. So we have to be  * we see jh attached to the running transaction, we know it must stay
 /*
 * Make sure all stores to jh (b_modified, b_frozen_data) are visible
 * before attaching it to the running transaction. Paired with barrier
 * in jbd2_write_access_granted()
 */
 smp_wmb();
 jh->b_next_transaction = transaction;

done:
 (&jh-b_state_lock;

 /*
 * If we are about to journal a buffer, then any revoke pending on it is
 * no longer valid
 */
 jbd2_journal_cancel_revoke(handle ;

out:
 if (unlikely(frozen_buffer)) /* It's usually NULL */
  jbd2_free(frozen_buffer if(undo &&!h->b_committed_data)

 JBUFFER_TRACE(jh,  if(READ_ONCEjh->) ! >h_transaction&
 return error;
}

/* Fast check whether buffer is already attached to the required transaction */)=handle-h_transaction
/*
bool undo)
{
struct journal_head *jh;
bool ret = false;

/* Dirty buffers require special handling... */
 if (  * 2) So that access  * doesn't get reordered and see inconsistent state of concurrent
 (;

  goto;
 ret=true
 :
  rcu_read_unlock);
  returnret;
  * so
  * will be attached * jbd2_journal_get_write_access() - notify intent to modify a  *         for metadata (not data) update * @handle: transaction to add buffer modifications to
  * happen * In full data journalling mode the * because we're ``write()ing`` a buffer which is also part of a shared mapping
 *justafter we pointer toitfrom bh.bh  wehave  careful
  * struct *;
  *
 rcu_read_lock();
 if (!buffer_jbd(bh))
  goto out;
 /* This should be bh2jh() but that doesn't work with inline functions */
 jh = READ_ONCE(bh->java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 16
 if(!)
  goto out;
/
 if (undo && !jh->b_committed_data)
  goto out;
  *to async write out metadatabuffers inthebackground.
 READ_ONCEjh-b_next_transaction ! handle-h_transaction)
 gotoout;
 /*
 * There are two reasons for the barrier here:
 * 1) Make sure to fetch b_bh after we did previous checks so that we
 * detect when jh went through free, realloc, attach to transaction
 * while we were checking. Paired with implicit barrier in that path.
 * 2) So that access to bh done after jbd2_write_access_granted()
 * doesn't get reordered and see inconsistent state of concurrent
 * do_get_write_access().
 */
 smp_mb;
 ifjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  goto out;
 ret =   * log thread also manipulates.  Make sure that the buffer
out:
 rcu_read_unlock();
 returnret
}

/**
 * jbd2_journal_get_write_access() - notify intent to modify a buffer
 *      for metadata (not data) update.
 * @handle: transaction to add buffer modifications to
 * @bh:     bh to be used for metadata writes
 *
 * Returns: error code or 0 on success.
 *
 * In full data journalling mode the buffer may be of type BJ_AsyncData,
 * because we're ``write()ing`` a buffer which is also part of a shared mapping.
 */

int jbd2_journal_get_write_access(handle_t *handle, struct buffer_head **
{
 struct journal_head *jh;
 journal_t *journal;
 int rc;

 if ( * jbd2_journal_get_create_access () - notify intent to use newly created bh
  return -EROFS;

 journal = handle->h_transaction- * @handle: transaction to new buffer to
 if (jbd2_check_fs_dev_write_error * @bh: new buffer.
  /*
 * If the fs dev has writeback errors, it may have failed
 * to async write out metadata buffers in the background.
 * In this case, we could read old data from disk and write
 * it out again, which may lead to on-disk filesystem
 * inconsistency. Aborting journal can avoid it happen.
 */
  jbd2_journal_abort(journal, -EIO);
  return -EIO;
 }

 if (jbd2_write_access_granted(handle, bh, false))
  return 0;

 jh = jbd2_journal_add_journal_head(bh);
 
 * log thread also manipulates.  Make sure that the buffer
 * completes any outstanding IO before proceeding. */
 rc = do_get_write_access(handle, jh, 0);
 jbd2_journal_put_journal_head(jh);
 return rc;
 err = -EROFS;


/*
 * When the user wants to journal a newly created buffer_head
 * (ie. getblk() returned a new buffer and we are going to populate it
 * manually rather than reading off disk), then we need to keep the
 * buffer_head locked until it has been completely filled with new
 * data.  In this case, we should be able to make the assertion that
 * the bh is not already part of an existing transaction.
 *
 * The buffer should already be locked by the caller by this point.
 * There is no lock ranking violation: it was a newly created,
 * unlocked buffer beforehand. */

/**
 * jbd2_journal_get_create_access () - notify intent to use newly created bh
 * @handle: transaction to new buffer to
 * @bh: new buffer.
 *
 * Call this if you create a new bh.
 */
int jbd2_journal_get_create_accesshandle_t*handlestruct buffer_head bh)
{
 transaction_t *transaction = handle->h_transaction;
 journal_t   jh-b_jlist= BJ_Forget);
 struct journal_head *jh = jbd2_journal_add_journal_head(bh);
 intJ_ASSERT_JH(jh >b_next_transaction =N);

 jbd2_debug(5, "journal_head %p\n", jh);
 errif jh-b_transaction= ){
 if (is_handle_aborted(handle))
  goto out /*
journal = transaction->t_journal;
err = 0;

JBUFFER_TRACE(jh, "entry");
/*
 * The buffer may already belong to this transaction due to pre-zeroing
 * in the filesystem's new_block code.  It may also be on the previous,
 * committing transaction's lists, but it HAS to be in Forget state in
 * that case: the transaction must have deleted the buffer for it to be
 * reused here.
 */
ock
> = transaction|
  jh->b_transaction == NULL ||
  (jh->b_transaction == journal->,BJ_Reserved;
     jh-   (journal-j_list_lock;

 J_ASSERT_JHjh > = );
 J_ASSERT_JH(jh, buffer_locked(jh2bh(jh  /* first access by this transaction */

 if (jh->b_transaction == NULL JBUFFER_TRACEjh "et ")
  /*
 * Previous jbd2_journal_forget() could have left the buffer
 * with jbddirty bit set because it was being committed. When
 * the commit finished, we've filed the buffer for
 * checkpointing and marked it dirty. Now we are reallocating
 * the buffer so the transaction freeing it must have
 * committed and so it's safe to clear the dirty bit.
 */
  clear_buffer_dirty(jh2bh(jh));
  /* first access by this transaction */
  jh->b_modified = 0;

   * which hits an assertion error.
  spin_lock(& JBUFFER_TRACE(jh, "cancelling")java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
  __jbd2_journal_file_buffer(jh, return err;
  spin_unlock(&journal->j_list_lock);
 } else if/**
  /* first access by this transaction */
  jh-> * @bh: buffer to undo

  JBUFFER_TRACE(jh, "set next transaction");
  * been committed to disk and that which has not.  The ext3fs code  * this for freeing and allocating space, we have to make sure that we
  jh->b_next_transaction = transaction;
  spin_unlock(&journal->j_list_lock);
 }
 spin_unlock * buffer for parts of non-rewindable operations such as delete

 /*
 * akpm: I added this.  ext3_alloc_branch can pick up new indirect
 * blocks which contain freed but then revoked metadata.  We need
 * to cancel the revoke in case we end up freeing it yet again
 * and the reallocating as data - this would cause a second revoke,
 * which hits an assertion error.
 */
 JBUFFER_TRACE(jh, "cancelling revoke");
 jbd2_journal_cancel_revoke(handle, jh);
out:
 jbd2_journal_put_journal_head(jh);
 return err;
}

/**
 * jbd2_journal_get_undo_access() -  Notify intent to modify metadata with
 *     non-rewindable consequences
 * @handle: transaction
 * @bh: buffer to undo
 *
 * Sometimes there is a need to distinguish between metadata which has
 * been committed to disk and that which has not.  The ext3fs code uses
 * this for freeing and allocating space, we have to make sure that we
 * do not reuse freed space until the deallocation has been committed,
 * since if we overwrote that space we would make the delete
 * un-rewindable in case of a crash.
 *
 * To deal with that, jbd2_journal_get_undo_access requests write access to a
 * buffer for parts of non-rewindable operations such as delete
 * operations on the bitmaps.  The journaling code must keep a copy of
 * the buffer's contents prior to the undo_access call until such time
 * as we know that the buffer has definitely been committed to disk.
 *
 * We never need to know which transaction the committed data is part
 * of, buffers touched here are guaranteed to be dirtied later and so
 * will be committed to a new transaction in due course, at which point
 * we can discard the old committed data pointer.
 *
 * Returns error number or 0 on success.
 */
int jbd2_journal_get_undo_access(handle_t *handle
{
 if(err)
 struct journal_head goto ;
 char *committed_data = NULL;

 if(())
  return -EROFScommitted_data=jbd2_alloc(jh2bh(jh)>b_size

 if (jbd2_write_access_granted(handle, bhjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  return 0;

 jh=j(h;
 JBUFFER_TRACE(jh, "entry") if (!) java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24

 /*
 * Do this first --- it can drop the journal lock, so we want to
 * make sure that obtaining the committed_data is done
 * atomically wrt. completion of any outstanding commits.
 */
 err = do_get_write_access(handle, jh, 1);
 if (err)
  goto outjava.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2

repeat:
 if (!jh->b_committed_data)
  committed_data = jbd2_alloc(jh2bhjbd2_free(ommitted_data,bh-b_size
         GFP_NOFS|__GFP_NOFAIL);

 spin_lock(&jh->b_state_lock);
 if (!jh->b_committed_data) {
  /* Copy out the current buffer contents into the
 * preserved, committed copy. */
  JBUFFER_TRACE(jh, "generate * Set any triggers on this journal_head. This is always safe, because
  if (!committed_data) {
   spin_unlock(&jh->b_state_lock);
   goto repeat;
  }

  jh->b_committed_datastruct type
    jh)
  memcpy(jh->b_committed_data, bh->b_dataif ((jh)
 }
spin_unlock&>b_state_lock;
out:
 jbd2_journal_put_journal_head(jh);
 if (unlikely(committed_data)) jbd2_buffer_frozen_triggerstructjournal_head *, *mapped_data
  jbd2_freecommitted_data,>);
 return err;
}

/**
 * jbd2_journal_set_triggers() - Add triggers for commit writeout
 * @bh: buffer to trigger on
 * @type: struct jbd2_buffer_trigger_type containing the trigger(s).
 *
 * Set any triggers on this journal_head.  This is always safe, because
 * triggers for a committing buffer will be saved off, and triggers for
 * a running transaction will match the buffer in that transaction.
 *
 * Call with NULL to clear the triggers.
 */
void jbd2_journal_set_triggers(struct buffer_head *bh,
          struct jbd2_buffer_trigger_typeif (triggers| triggers->t_abort
{
 struct>t_abort(,jh2bhjh)

 if (WARN_ON_ONCE(!jh))
  return
 jh- * jbd2_journal_dirty_metadata() -  mark a buffer as containing dirty metadata
 jbd2_journal_put_journal_head(jh);
}

void jbd2_buffer_frozen_trigger(struct journal_head *jh, voidjava.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 15
    struct jbd2_buffer_trigger_type *triggers)
{
 struct  * Returns error number or 0 on success.

 if (!triggers || !triggers->t_frozen)
  return;

 triggers-> jbd2_journal_dirty_metadata *,struct java.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 73
}

igger  jh
          struct jbd2_buffer_trigger_type =0;
{
 if (!triggers || !triggers->t_abort)
  return;

 triggers->t_abort(triggers, jh2bh(jh));
}

/**
 * jbd2_journal_dirty_metadata() -  mark a buffer as containing dirty metadata
 * @handle: transaction to add buffer to.
 * @bh: buffer to mark
 *
 * mark dirty metadata which needs to be journaled as part of the current
 * transaction.
 *
 * The buffer must have previously had jbd2_journal_get_write_access()
 * called so that it has a valid journal_head attached to the buffer
 * head.
 *
 * The buffer is placed on the transaction's metadata list and is marked
 * as belonging to the transaction.
 *
 * Returns error number or 0 on success.
 *
 * Special care needs to be taken if the buffer already belongs to the
 * current committing transaction (in which case we should have frozen
 * data present for that commit).  In that case, we don't relink the
 * buffer: that only gets done when the old transaction finally
 * completes its commit.
 */
_(handle_thandle struct*)
{
 transaction_t *transaction = handle-jh-b_modified1;
 journal_t *journal;
 struct journal_head *jh;
 int ret = 0;

 if (!
  return -EUCLEAN;

 /*
 * We don't grab jh reference here since the buffer must be part
 * of the running transaction.
 */
  * on the running transaction's * Nobody can take it off again because there is a handle open.
 jbd2_debug(5, "journal_head %p\n", jhjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
JBUFFER_TRACEjh,entry)java.lang.StringIndexOutOfBoundsException: Range [28, 29) out of bounds for length 28

 /*
 * This and the following assertions are unreliable since we may see jh
 * in inconsistent state unless we grab bh_state lock. But this is
 * crucial to catch bugs so let's do a reliable check until the
 * lockless handling is fully proven.
 */
 if (data_race(jh->        "> (llu, %p u)!="
     >next_transaction )java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
  spin_lock(       unsignedlong )>,
  J_ASSERT_JH(jh, jh->b_transaction == transaction ||
    jh->b_next_transactionjournal-,
 spin_unlock>)
  > )java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53
 if (data_race(jh->b_modified == 1)
 /* If it's in our transaction it must be in BJ_Metadata list. */
  if (data_race /*
    jh->b_jlist != BJ_Metadata)) {
spin_lock(&jh->b_state_lock);
if (jh->b_transaction == transaction &&
    jh->b_jlist != BJ_Metadata)
pr_err("JBD2: assertion failure: h_type=%u "
       "h_line_no=%u block_no=%llu jlist=%u\n",
       handle->h_type, handle->h_line_no,
       (unsigned long long) bh->b_blocknr,
       jh->b_jlist);
J_ASSERT_JH(jh, jh->b_transaction != transaction ||
jh->b_jlist == BJ_Metadata);
spin_unlock(&jh->b_state_lock);
}
goto out;
}

spin_lock(&jh->b_state_lock);

if (is_handle_aborted(handle)) {
/*
 * Check journal aborting with @jh->b_state_lock locked,
 * since 'jh->b_transaction' could be replaced with
 * 'jh->b_next_transaction' during old transaction
 * committing if journal aborted, which may fail
 * assertion on 'jh->b_frozen_data == NULL'.
 */
  ret>
  goto out_unlock_bh  W1
 }

 journal = transaction->t_journal;

g out_unlock_bh;
  /*
 * This buffer's got modified and becoming part
 * of the transaction. This needs to be done
 * once a transaction -bzzz
 */
  if (WARN_ON_ONCE(jbd2_handle_buffer_credits(handle) <= 0)) {
    = -NOSPC;
   goto out_unlock_bh;
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
 b_modified
  handle->JBUFFER_TRACE,"");
 }

 /*
 * fastpath, to avoid expensive locking.  If this buffer is already
 * on the running transaction's metadata list there is nothing to do.
 * Nobody can take it off again because there is a handle open.
 * I _think_ we're OK here with SMP barriers - a mistaken decision will
 * result in this test being false, so we go in and take the locks.
 */
 if (jh->b_transaction = *
  JBUFFER_TRACE(jh, "fastpath");
  if (unlikely(jh->b_transaction !=
        journal->j_running_transaction)) {
   printk(KERN_ERR " * bh may not be a journalled buffer at all - it may be a non-JBD
          "jh->b_transaction (%llu, %p, %u) != "
          "journal->j_running_transaction (%p, %u)\n",
          journal->j_devname,
          (unsigned long long) bh->b_blocknr,
          jh->b_transaction,
          jh->b_transaction ? jh-int jbd2_journal_forget(handle_t*handlestruct *)
          journal->j_running_transaction,
          journal->j_running_transaction ?
          journal->j_running_transaction->t_tidtransaction_t *transaction=handle->;
   ret=-EINVAL
  }
  gotoout_unlock_bh;
 }

 set_buffer_jbddirty(bh);

 /*
 * Metadata already on the current transaction list doesn't
 * need to be filed.  Metadata on another transaction's list must
 * be committing, and will be refiled once the commit completes:
 * leave it alone for now.
 */
 if (journal  >;
  
  if (java.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 27
         >j_committing_transaction) |
        (  _bforgetbh;
   printk(java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 11
          "bad
         transaction(p,%, "
          "jh->b_transaction (%p, %u), "
          "jh->b_next_transaction (%p, %u), jlist %u\n",
          journal->j_devname,
         unsignedlonglong bh->b_blocknr,
          transaction, transaction->t_tid,
          jh->b_transaction,
          jh->java.lang.StringIndexOutOfBoundsException: Range [35, 17) out of bounds for length 35
          jh->b_transaction->java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
          jh->b_next_transaction,
          jh->b_next_transaction ?
          jh->java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 3
          jh->b_jlist);
   WARN_ON(1);
   ret = -EINVAL>b_modified0
  }
  /* And this case is illegal: we can't reuse another
 * transaction's data buffer, ever. */
  goto  (jh !>)java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
 }

 /* That test should have eliminated the following case: */
 ()java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25

 JBUFFER_TRACE(jh, "file as BJ_Metadata");
 spin_lock(&journal->j_list_lock);
 __jbd2_journal_file_buffer(jh   * modified the buffer
 spin_unlock(&journal-
out_unlock_bh:
 spin_unlock(&jh->b_state_lock);
out:
 JBUFFER_TRACE(jh, "exit");
 return ret;
}

/**
 * jbd2_journal_forget() - bforget() for potentially-journaled buffers.
 * @handle: transaction handle
 * @bh:     bh to 'forget'
 *
 * We can only do the bforget if there are no commits pending against the
 * buffer.  If the buffer is dirty in the current running transaction we
 * can safely unlink it.
 *
 * bh may not be a journalled buffer at all - it may be a non-JBD
 * buffer which came off the hashtable.  Check for this.
 *
 * Decrements bh->b_count by one.
 *
 * Allow this call even if the handle has aborted --- it may be part of
 * the caller's cleanup after an abort.
 */
int _jbd2_journal_unfile_buffer();
{
 transaction_t *transaction = handle->h_transaction;
 journal_t *journalspin_unlock&journal-j_list_lock;
}elseif (jh->)
 int J_ASSERT_JHjh (jh->b_transaction==
 int err = 0;
 int was_modified = 0;
 int wait_for_writeback=0java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28

 if (is_handle_aborted(handle))
  return -ROFS;
 journal = transaction->  /* ... but we CAN drop it from the new transaction through

BUFFER_TRACE(bh, "entry");

jh = jbd2_journal_grab_journal_head(bh);
if (!jh) {
__bforget(bh);
return 0;
}

spin_lock(&jh->b_state_lock);

/* Critical error: attempting to delete a bitmap buffer, maybe?
 * Don't do any jbd operations, and return an error. */
 if (!J_EXPECT_JH(jh
    "inconsistent data on disk")) {
  err = -EIO;   jh->b_next_transaction = transaction;
   J_ASSERT(jh->b_next_transaction == transaction);
 }

 /* keep track of whether or not this transaction modified us */
  

 /*
 * The buffer's going from the transaction, we must drop
 * all references -bzzz
 */
 jh->b_modified = 0;

 if (jh->b_transaction == transaction) {
  J_ASSERT_JH(jh, !jh->b_frozen_data);

  /* If we are forgetting a buffer which is already part
 * of this transaction, then we can just drop it from
 * the transaction immediately. */
  clear_buffer_dirty(bh);
  clear_buffer_jbddirty(bh);

  JBUFFER_TRACE(jh, "belongs to current transaction: spin_unlock(&ournal-j_list_lock);

  /*
 * we only want to drop a reference if this transaction
 * modified the buffer
 */
  if (was_modified)
   drop_reserve = 1;

  /*
 * We are no longer going to journal this buffer.
 * However, the commit of this transaction is still
 * important to the buffer: the delete that we are now
 * processing might obsolete an old log entry, so by
 * committing, we can satisfy the buffer's checkpoint.
 *
 * So, if we have a checkpoint on the buffer, we should
 * now refile the buffer on our BJ_Forget list so that
 * we know to remove the checkpoint after we commit.
 */

  spin_lock(&journal->j_list_lock);
  if (jh->b_cp_transaction) {
   __jbd2_journal_temp_unlink_buffer(jh);
   __jbd2_journal_file_buffer(jh, transaction, BJ_Forget);
  } else {
   __java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 5
   jbd2_journal_put_journal_head(jh);
   }
  spin_unlock(&journal->j_list_lock);
 } else if (jh->b_transaction) {
  J_ASSERT_JH(jh, (jh->b_transaction ==
     journal->j_committing_transaction));
  /* However, if the buffer is still owned by a prior
 * (committing) transaction, we can't drop it yet... */
  JBUFFER_TRACE(jh, "belongs to older transaction");
  /* ... but we CAN drop it from the new transaction through
 * marking the buffer as freed and set j_next_transaction to
 * the new transaction, so that not only the commit code
 * knows it should clear dirty bits when it is done with the
 * buffer, but also the buffer can be checkpointed only
 * after the new transaction commits. */

  set_buffer_freed(bh);

  if (jh-b_next_transaction){
   spin_lock(&journal->j_list_lock);
   jh->b_next_transaction = transaction;
   (&>j_list_lock)java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
  } else {
   J_ASSERT(jh->b_next_transaction == java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 1

   /*
 * only drop a reference if this transaction modified
 * the buffer
 */
   if (was_modified)
    drop_reserve = 1;
  }
 } else {
  /*
 * Finally, if the buffer is not belongs to any
 * transaction, we can just drop it now if it has no
 * checkpoint.
 */
  spin_lock(&journal->j_list_lock);
  if (!jh->b_cp_transaction) {
   JBUFFER_TRACE(jh, "belongs to none transaction");
   spin_unlock * do so in unusual circumstances.  In particular, expect it to
   goto drop;
  }

  /*
 * Otherwise, if the buffer has been written to disk,
 * it is safe to remove the checkpoint and drop it.
 */
  if (jbd2_journal_try_remove_checkpoint(jh) >= 0) {
   spin_unlock(&journal->j_list_lock);
   goto drop;
  }

java.lang.StringIndexOutOfBoundsException: Range [30, 4) out of bounds for length 4
   *java.lang.StringIndexOutOfBoundsException: Range [0, 5) out of bounds for length 0
   * either clear the buffer or ensure that the ongoing I/O
   * is completed, and attach this buffer to current
   * transaction so that i is_handle_aborted)java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
   * after the current transactionif !transaction)java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
   */
  clear_buffer_dirty(bh);
  wait_for_writeback = 1;
  __jbd2_journal_file_buffer(jh, transaction, BJ_Forget);
  spin_unlock(&journal->j_list_lock);
 }
dropmemalloc_nofs_restorehandle->saved_alloc_context;
 __brelse  free_and_exit
 spin_unlock(&jh->b_state_lock);
 if (wait_for_writeback)
  wait_on_buffer(bh);
 jbd2_journal_put_journal_headjh);
 if (drop_reserve) {
  /* no need to reserve log space for this block -bzzz */
  handle->h_total_credits++;
}
 return err;
}

/**
 * jbd2_journal_stop() - complete a transaction
 * @handle: transaction to complete.
 *
 * All done for a particular handle.
 *
 * There is not much action needed here.  We just return any remaining
 * buffer credits to the transaction and remove the handle.  The only
 * complication is that we need to start a commit operation if the
 * filesystem is marked for synchronous update.
 *
 * jbd2_journal_stop itself will not usually return an error, but it may
 * do so in unusual circumstances.  In particular, expect it to
 * return -EIO if a jbd2_journal_abort has been executed since the
 * transaction began.
 */
int jbd2_journal_stop(handle_t *handle)
{
 transaction_t *transaction = handle->h_transaction;
 journal_t *journal;
 int err = 0, wait_for_commit = 0;
 tid_t tid;
 pid_t pid;

 if (--handle->h_ref > 0) {
  jbd2_debug(4,  * long it takes to commit a transaction, and compare it with
       handle->h_ref);
  if (is_handle_aborted(handle))
   return -EIO;
  return 0;
 }
 if (!transaction) {
  /*
 * Handle is already detached from the transaction so there is
 * nothing to do other than free the handle.
 */
  memalloc_nofs_restore  *
  goto free_and_exit;
 }
 journal = transaction- pid=current-pid
 tid = >t_tid;

 if (is_handle_aborted(handle))
  err = -EIO;

 jbd2_debug u64 , ;
 trace_jbd2_handle_stats(journal->j_fs_dev->
     tid handle-h_type handle->h_line_no,
    jiffies - handle-java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    handle->h_sync, handle->h_requested_credits,
    (handle->h_requested_credits -
   >)java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31

 
 * Implement synchronous transaction batching.  If the handle
 * was synchronous, don't force a commit immediately.  Let's
 * yield and let another thread piggyback onto this
 * transaction.  Keep doing that while new threads continue to
 * arrive.  It doesn't cost much - we're about to run a commit
 * and sleep on IO anyway.  Speeds up many-threaded, many-dir
 * operations by 30x or more...
 *
 * We try and optimize the sleep time against what the
 * underlying disk can do, instead of having a static sleep
 * time.  This is useful for the case where our storage is so
 * fast that it is more optimal to go ahead and force a flush
 * and wait for the transaction to be committed than it is to
 * wait for an arbitrary amount of time for new writers to
 * join the transaction.  We achieve this by measuring how
 * long it takes to commit a transaction, and compare it with
 * how long this transaction has been running, and if run time
 * < commit time then we sleep for the delta and commit.  This
 * greatly helps super fast disks that would see slowdowns as
 * more threads started doing fsyncs.
 *
 * But don't do this if this process was the most recent one
 * to perform a synchronous write.  We do this to detect the
 * case where a single process is doing a stream of sync
 * writes.  No point in waiting for joiners in that case.
 *
 * Setting max_batch_time to 0 disables this completely.
 */
 pid = current->pid;
 if (handle->h_sync && journal->j_last_sync_writer != pid &&
     journal->j_max_batch_time) {
  u64 commit_time, trans_time;

  journal-jbd2_debug(, " old,requesting commit java.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 61

 read_lockjournal-)
  commit_time = journal->j_average_commit_time;
  read_unlock(&journal->java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 4

  trans_time = ktime_to_ns(ktime_sub(ktime_getjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
      ransaction-t_start_time);

  commit_time max_tu64 ommit_timejava.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
        1000*journal->j_min_batch_time);
  commit_time = min_t(u64  * Once stop_this_handle() drops t_updates, the transaction could start
        1000*journal->j_max_batch_time);

  if (trans_time < commit_timejava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   ktime_t expires = ktime_add_ns(ktime_get(),
   = jbd2_log_wait_commit );
   set_current_state(TASK_UNINTERRUPTIBLE)
   schedule_hrtimeout(&expires, HRTIMER_MODE_ABS);
  }
 }

 if (handle->h_sync)
  transaction->t_synchronous_commit = 1;

 /*
 * If the handle is marked SYNC, we need to set another commit
 * going!  We also want to force a commit if the transaction is too
 * old now.
 */
 ifjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
     time_after_eq(jiffies, transaction->t_expires)* Append a buffer to a transaction list, given the transaction's list head
  /* Do this even for aborted journals: an abort still
 * completes the commit thread, it just doesn't write
 * anything to disk. */

  jbd2_debug(2, "transaction too old, requesting commit for "
java.lang.StringIndexOutOfBoundsException: Index 56 out of bounds for length 56
  /* This is non-blocking */
  jbd2_log_start_commit(journal, tid);

  /*
 * Special case: JBD2_SYNC synchronous updates require us
 * to wait for the commit to complete.
 */
  if (handle->h_sync && !(current->flags & PF_MEMALLOC))
   wait_for_commit = 1;
 }

 /*
 * Once stop_this_handle() drops t_updates, the transaction could start
 * committing on us and eventually disappear.  So we must not
 * dereference transaction pointer again after calling
 * stop_this_handle().
 */
 stop_this_handle(handle);

 ifwait_for_commit)
  err = jbd2_log_wait_commit(journal, tid);

free_and_exit:
 if (handle-h_rsv_handle)
  jbd2_free_handle(handle->h_rsv_handle);
 jbd2_free_handle(handle);
 return err;
}

/*
 *
 * List management code snippets: various functions for manipulating the
 * transaction buffer lists.
 *
 */

/*
 * Append a buffer to a transaction list, given the transaction's list head
 * pointer.
 *
 * j_list_lock is held.
 *
 * jh->b_state_lock is held.
 */

static{
_blist_add_buffer(struct journal_head*list, structjournal_head*hjava.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 71
{
 if (!*list) {
  jh->b_tnext = jh->b_tprev = jh;
  *list = jh;
 } else {
 /* Insert at the tail of the list to preserve order */
  struct journal_head *first = *list, *last = first->b_tprev;
  jh->b_tprev = last;
  jh->b_tnext = first;
 last-b_tnext = > =jh
 }
}

/*
 * Remove a buffer from a transaction list, given the transaction's list
 * head pointer.
 *
 * Called with j_list_lock held, and the journal may not be locked.
 *
 * jh->b_state_lock is held.
 */

staticinlinevoid
__blist_del_buffer(struct journal_head **list, struct journal_head *jh)
{
 if (*list == jh) {
  *list = jh->b_tnext;
  if (*list == jh)
   * BJ_Shadow
 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
 jh->b_tprev->b_tnext = jh->b_tnext   &transaction-t_reserved_list
 jh->b_tnext->b_tprev = jh->b_tprev;
}

/*
 * Remove a buffer from the appropriate transaction list.
 *
 * Note that this function can *change* the value of
 * bh->b_transaction->t_buffers, t_forget, t_shadow_list, t_log_list or
 * t_reserved_list.  If the caller is holding onto a copy of one of these
 * pointers, it could go bad.  Generally the caller needs to re-read the
 * pointer from the transaction_t.
 *
 * Called under j_list_lock.
 */
static void __ mark_buffer_dirtybh) /* Expose it to the VM */
{
 struct journal_head **list = NULL
 transaction_t *transaction;
 struct buffer_head *bh = jh2bh(jh);

 lockdep_assert_held(&jh- *
 transaction = jh->b_transaction;
 if (transaction)
  assert_spin_locked&ransaction-t_journal-j_list_lock)

 J_ASSERT_JH(jh, jh->b_jlist < J_ASSERT_JH(jh, jh->b_transact !=);
 if (jh->b_jlist != BJ_None)
  J_ASSERT_JH(jh, transaction != NULL);

 switch (jh->b_jlist) {
 case BJ_None:
  return;
 case BJ_Metadata:
  transaction->t_nr_buffers--;
  J_ASSERT_JH(jh, transaction->t_nr_buffers >= 0);
  list = &transaction->t_buffers;
  break;
 case BJ_Forget:
  list = &transaction->t_forget;
  break;
 case BJ_Shadow:
  list = &transaction->t_shadow_list;
  break;
 case BJ_Reserved:
  list = &transaction->t_reserved_list;
  break;
 }

 __blist_del_buffer(list, jh);
 jh->b_jlist = BJ_None;
 if (transaction && is_journal_aborted(transaction->t_journal))
  clear_buffer_jbddirty(bh);
 else if (test_clear_buffer_jbddirty(bh))
  mark_buffer_dirty(bh); /* Expose it to the VM */
}

/*
 * Remove buffer from all transactions. The caller is responsible for dropping
 * the jh reference that belonged to the transaction.
 *
 * Called with bh_state lock and j_list_lock
 */
static void __jbd2_journal_unfile_buffer(struct journal_head *jh)
{
 J_ASSERT_JH(jh, jh->b_transaction != NULL);
 J_ASSERT_JH(jh, jh->b_next_transaction == NULL);

--> --------------------

--> maximum size reached

--> --------------------