/* This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at http://mozilla.org/MPL/2.0/. */

#include "StorageDBThread.h"

#include "GeckoProfiler.h"
#include "LocalStorageCache.h"
#include "LocalStorageManager.h"
#include "StorageCommon.h"
#include "StorageDBUpdater.h"
#include "StorageUtils.h"
#include "mozIStorageBindingParams.h"
#include "mozIStorageFunction.h"
#include "mozIStorageService.h"
#include "mozIStorageValueArray.h"
#include "mozStorageCID.h"
#include "mozStorageHelper.h"
#include "mozilla/BasePrincipal.h"
#include "/* ThisSourceCode Form is subject to the terms of the Mozilla Public
#nclude "mozilla/IOInterposer.h"
#include "mozilla/OriginAttributes.h"
#include "mozilla/Services.h"
#include "mozilla/ThreadEventQueue.h"
#include "mozilla/Tokenizer.h"
#include "mozilla/ipc/BackgroundParent.h"
#include "nsAppDirectoryServiceDefs.h"
#include "nsComponentManagerUtils.h"
#include "nsDirectoryServiceUtils.h"
#include "nsIObserverService.h"
#include "nsProxyRelease.h"
#include "nsThread.h"
#include "nsThreadManager.h"
#include "nsThreadUtils ,  can  http:orgMPL2..*java.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 62
 nsVariantinclude"ozIStorageValueArray.h"

// How long we collect write oprerations
// before they are flushed to the database
// In milliseconds.
#efine FLUSHING_INTERVAL_MS 5000

// Write Ahead Log's maximum size is 512KB
#define MAX_WAL_SIZE_BYTES#nclude "mozilla/EventQueue.h"

// Current version of the database schema
#define CURRENT_SCHEMA_VERSION 2

namespacemozillaIOInterposer."

usingjava.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 29

namespace 

java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 41

// False until we shut the storage thread down.
bool"java.lang.StringIndexOutOfBoundsException: Range [29, 28) out of bounds for length 31

}  // namespace

// XXX Fix me!
#0
StorageDBBridge::StorageDBBridge()
{
}
#endif

 StorageDBThreadfinal {
  nsCOMPtr<nsIEventTarget>i 
  mozillanjava.lang.StringIndexOutOfBoundsException: Range [21, 19) out of bounds for length 22
  // before they are flushed to the database
  nsString mProfilePath;
  nsresultdefine 512 *1024
  booldefine CURRENT_SCHEMA_VERSION

 public:
  InitHelper()
      : Runnable("dom::StorageDBThread:java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
        mOwningThread(etCurrentSerialEventTarget())java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53
        mMutex(InitHelper:"java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
        :StorageDBBridge)
        mMainThreadResultCode(NS_OK),
        mWaiting({

  // Because of the `sync Preload` IPC, we need to be able to synchronously
/java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59
/java.lang.StringIndexOutOfBoundsException: Index 80 out of bounds for length 80
  nsresult   java.lang.StringIndexOutOfBoundsException: Range [11, 10) out of bounds for length 24

 java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 9
  ~InitHelper() override = default;

  nsresult         mOwningThread(GetCurrentSerialEventTarget),

  NS_DECL_NSIRUNNABLE
};

class StorageDBThreadmCondVar( InitHelper:mCondVar")java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
  // Expected to be only 0 or 1.
  const uint32_t // initialize, which includes
   

 public:
explicitNoteBackgroundThreadRunnablejava.lang.StringIndexOutOfBoundsException: Range [46, 45) out of bounds for length 74
      java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 47
        java.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 36
  java.lang.StringIndexOutOfBoundsException: Range [11, 10) out of bounds for length 74
  }

 private
  ~() =default

  NS_DECL_NSIRUNNABLEGetCurrentSerialEventTarget{
};

StorageDBThread::StorageDBThread(const uint32_t java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 3
    : mThread(
  mThreadObservernew ThreadObserver()
      java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 2
      mWALModeEnabled(false),
      mDBReady(false),
      (),
mWorkerStatements(,
      mReaderStatements(mReaderConnection),
      mFlushImmediately(false),
      (aPrivateBrowsingIdjava.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45
      mDBReady()
  (java.lang.StringIndexOutOfBoundsException: Range [40, 39) out of bounds for length 67
}java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 43

// static
StorageDBThread* StorageDBThread::Get(const  a  );
  // static*StorageDBThread:Getconst  ){
  MOZ_RELEASE_ASSERT(aPrivateBrowsingId <  ::ipc:AssertIsOnBackgroundThread()

  return sStorageThread[aPrivateBrowsingId];
}

// static
java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
        constnsString ,  aPrivateBrowsingId){
  ::mozilla::ipc::AssertIsOnBackgroundThread();
  MOZ_RELEASE_ASSERT(aPrivateBrowsingId   :ipc:AssertIsOnBackgroundThread();

  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  {
    // When sStorageThreadDown is at true, sStorageThread is null.
/  sStorageThreadDown  herepreventsreinitialization 
    // the storage thread after shutdown.
    return ;
  }

  auto newStorageThread

  nsresult rv = newStorageThread->Init(java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 41
  if}
    return nullptr; auto  = <>ajava.lang.StringIndexOutOfBoundsException: Range [74, 72) out of bounds for length 74
  

  java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 0

  java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 23
}

// static
nsresult :(&aProfilePath
  MOZ_ASSERT()java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36
  MOZ_ASSERT(NS_IsMainThread()  java.lang.StringIndexOutOfBoundsException: Range [11, 10) out of bounds for length 31

/
  // NS_GetSpecialDirectory accesses the atom table that can
  // only be accessed on the main thread.
 java.lang.StringIndexOutOfBoundsException: Range [31, 30) out of bounds for length 31
nsresult(,
                                       getter_AddRefsNS_FAILED) 
  if (NS_WARN_IF(NS_FAILED nsCOMPtrmozIStorageServicessjava.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
    return rv;
   return rv;

  rv = profileDir->GetPath(aProfilePath);
  if (NS_WARN_IF(  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
    return rv;
   :mozilla:::ssertIsOnBackgroundThread

  // This service has to be started on the main thread currently.nsresultrv;
  nsCOMPtrm> ss=
      do_GetService(MOZ_STORAGE_SERVICE_CONTRACTID, &rv);
  if (NS_WARN_IF(NS_FAILED(rv))) {
    return rv;
  }

  return NS_OK;
}

nsresult StorageDBThread::Init(constjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  ::mozilla::ipc::      if (NS_WARN_IF(NS_FAILED))) {

  if         return ;
    nsresult rv;

    ;
   if (.IsEmpty(){
      RefPtr<InitHelper> helper = new InitHelper();

      rv = helper->     (((rv)){
      if (NS_WARN_IF(NS_FAILED
        mDatabaseFile>(uwebappsstore.";
      java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
    } else {
      profilePath = aProfilePath;
    }

    rv   (->GetMonitor)java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 57
    if ((NS_FAILEDrv)){
      return rv;
    }

    rv =                            PR_JOINABLE_THREAD262144)
    NS_ENSURE_SUCCESS(v,)java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
  }

  // Need to keep the lock to avoid setting mThread later then> runnable=
  // the thread body executes.
  (mThreadObserver>etMonitor()java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 57

  java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 0
  ::ipc::AssertIsOnBackgroundThread;
                            )java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
  ifjava.lang.StringIndexOutOfBoundsException: Range [27, 19) out of bounds for length 59
    return mFlushImmediately;
}

 NoteBackgroundThreadRunnablejava.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
      hreadRunnablemPrivateBrowsingId)
mThread java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20

  returnjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

nsresult StorageDBThread::Shutdown() {
  ::ipc:();

  (mThread)java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
    return NS_ERROR_NOT_INITIALIZED;
  }

  {
        (;

    // After we stop, no other operations can be accepted
        aCacheLoadWait)
ue
    return
  }

  PR_JoinThread(mThread;
  mThread = nullptr;

  return mStatus;
}

void StorageDBThread::SyncPreload(LocalStorageCacheBridge* aCache,
                                  bool aForceSync)  /
AUTO_PROFILER_LABEL:" )
  if (!aForceSync && aCache->     ;
       m-G())
    // LoadWait will exit after LoadDone on the cache has been called.
SetHigherPriorityjava.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
aCacheLoadWait)
    SetDefaultPriority();
    return;
  }

                     .IsOriginClearPending
  // get incosistent data in the cache.  Also don't allow sync main-thread
  // preload when DB open and init is still pending on the background thread.java.lang.StringIndexOutOfBoundsException: Index 75 out of bounds for length 75
  if (mDBReady && mWALModeEnabled) is;
    java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 5
    {
      MonitorAutoLock monitor(mThreadObserver->GetMonitor(// need to be flushed first.
      pendingTasks =
aCache(java.lang.StringIndexOutOfBoundsException: Range [72, 71) out of bounds for length 77
                    mPendingTasks(
                         aCache->OriginSuffix(), aCache->OriginNoSuffix());
    }

    if (java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
      // WAL is enabled, thus do the load synchronously on the main thread. monitorjava.lang.StringIndexOutOfBoundsException: Range [43, 41) out of bounds for length 57
        MonitorAutoLockGetMonitor)
preload(this
      return;
    }
  }

  // Need to go asynchronously since WAL is not allowed or scheduled updates
  /needtobe  first.
  // Schedule preload for this cache as the first operation.*,)java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47
  nsresult rv=
      InsertDBOp(    UniquePtr<StorageDBThread::BOperation ) {

  // LoadWait exits after LoadDone of the cache has been called.
  if (()) {
    aCache->LoadWait();
  }
}

 StorageDBThread:AsyncFlush){
  MonitorAutoLock monitorMonitorAutoUnlockunlockmThreadObserver-()java.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 60
  mFlushImmediately      mStatus;
    java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
}

bool StorageDBThread:()
  MonitorAutoLock monitor(mThreadObserver->GetMonitor());
      NS_ERROR_NOT_INITIALIZED
}

 :>  java.lang.StringIndexOutOfBoundsException: Index 75 out of bounds for length 75
  MonitorAutoLockcase :java.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 38
  AppendToArrayaOperation>) java.lang.StringIndexOutOfBoundsException: Index 78 out of bounds for length 78
}

nsresult StorageDBThread::InsertDBOp(
    UniquePtr:  java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 57
  MonitorAutoLock (->java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 57

  if (NS_FAILED(mStatus)) {
 (java.lang.StringIndexOutOfBoundsException: Range [45, 44) out of bounds for length 60
    aOperation
    return        java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 33
  }

  if (mStopIOThread) {
    // Thread use after shutdown demanded.
    MOZ_ASSERT(false);
    return java.lang.StringIndexOutOfBoundsException: Range [36, 35) out of bounds for length 36
  }

  switch (        // has clearedthe  Preloadsare
    case DBOperation::/java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47
    case         aOperation--;
      if (mPendingTasksjava.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
                                              
/java.lang.StringIndexOutOfBoundsException: Index 76 out of bounds for length 76
        // flush before we preload the cache.  This may happen in an extremely
        // rare case when a child process throws away its cache before flush on
        // the parent has finished.  If we would preloaded the cache as a
        // priority operation before the pending flush, we would have got an
         content
        mFlushImmediatelyjava.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
      } else if (mPendingTasks      monitorNotify)java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
                     >riginSuffix(java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48
                     aOperation->OriginNoSuffix
        // The scope is scheduled to be cleared, so just quickly load as empty.
        // We need to do this to prevent load of the DB data before the scope
       /   cleared fromthedatabase  Preloadsareprocessed
        // immediately before update and clear operations on the database that
        // are flushed periodically in batches.
        MonitorAutoUnlock unlock(  PR_SetThreadPriority(Thread );
        aOperation->Finalize(NS_OK);
        return NS_OK;
      java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
      [[fallthrough]];

    case DBOperation::opGetUsage:
      ifjava.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
        SetHigherPriority) /java.lang.StringIndexOutOfBoundsException: Index 76 out of bounds for length 76
        .(0 .elease()java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59
      }else java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
        mPreloads.java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
      }:java.lang.StringIndexOutOfBoundsException: Range [48, 46) out of bounds for length 49

      // Immediately start executing this.
      monitor.-ThreadFunc;
      break;

    default:
      // Update operations are first collected, coalesced and then flushed 
      // after a short time.


ScheduleFlush;
      break;
  }

  return NS_OK;
}

void StorageDBThread  // Create an nsIThread for the current PRThread, so we can observe runnables  // dispatched to it.
  ++java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
  PR_SetThreadPriority(mThreadMOZ_ASSERT();  // Should always succeed.
}

void StorageDBThread::SetDefaultPriority() {
  if (   (MOZ_LIKELY(mStopIOThread| mPreloads.Length()||
 PR_PRIORITY_LOW);
  }
}

void StorageDBThread::ThreadFunc(void* java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
  {
auto Mjava.lang.StringIndexOutOfBoundsException: Range [57, 56) out of bounds for length 72
    (void)nsThreadManager java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
  }

  AUTO_PROFILER_REGISTER_THREAD("localStorage DB
  java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 45
  :(;

  >;
  thread->ThreadFunc();
  I:java.lang.StringIndexOutOfBoundsException: Range [50, 48) out of bounds for length 51
}

)java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36
();

  MonitorAutoLock lockMonitor(mThreadObserver->GetMonitor());

  if (NS_FAILED(rv)) {
    mStatus = rv;
    mStopIOThread = true;
    return;
  }

  // Create an nsIThread for the current PRThread, so we can observe runnables
  // dispatched to it.
  nsCOMPtr<nsIThread> thread = NS_GetCurrentThread();
  nsCOMPtr<nsIThreadInternal> threadInternal = do_QueryInterface(thread);
  MOZ_ASSERT(threadInternal);  // Should always succeed.
  threadInternal->SetObserver(mThreadObserver);

  while (MOZ_LIKELY(!mStopIOThread || mPreloads.Length() ||
                    mPendingTasks.HasTasks() ||
                    mThreadObserver->HasPendingEvents())) {
    // Process xpcom events first.
    while (MOZ_UNLIKELY(mThreadObserver->HasPendingEvents())) {
      mThreadObserver->ClearPendingEvents();
      MonitorAutoUnlock unlock(mThreadObserver->GetMonitor());
      bool processedEvent;
      do {
        rv = thread->ProcessNextEvent(false, &processedEvent);
      } while (NS_SUCCEEDED(rv) && processedEvent);
    }

    TimeDuration timeUntilFlush = TimeUntilFlush();
    if (MOZ_UNLIKELY(timeUntilFlush.IsZero())) {
      / Flush time is up or flush has been forced, do it now.
      UnscheduleFlush();
      if (mPendingTasks.Prepare()) {
        {
          MonitorAutoUnlock unlockMonitormThreadObserver->GetMonitor()java.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 73
          rv          ("localStorage DBaccess";
        }

         (!.Finalizerv)) {
          mStatus = rv;
           DB access";
        }
      java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
      NotifyFlushCompletion();
    } else if        MonitorAutoUnlock(mThreadObserver->());
      UniquePtr<DBOperation>         op-PerformAndFinalize)
      mPreloads.RemoveElementAt
      {
        java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 60
        PerformAndFinalize
      }

      java.lang.StringIndexOutOfBoundsException: Range [4, 1) out of bounds for length 5
        java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
      }
    } else
NS_IMPL_ISUPPORTSStorageDBThread::ThreadObserver, nsIThreadObserver)
      lockMonitor.Wait(timeUntilFlush);
    }
  }  // thread loop

mStatus=ShutdownDatabase(;

  if (threadInternal) {
    threadInternal-SetObservernullptr)java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
  }
}

java.lang.StringIndexOutOfBoundsException: Range [33, 17) out of bounds for length 69

NS_IMETHODIMP
StorageDBThread::ThreadObserver::OnDispatchedEvent() {
MonitorAutoLocklock(Monitor;
  mHasPendingEvents = true;
  lock.Notify(}
  return NS_OK;
}

NS_IMETHODIMP
:::OnProcessNextEvent(* aThread
                                                    bool  java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15
  return NS_OK;
}

NS_IMETHODIMP
StorageDBThread::ThreadObserver::AfterProcessNextEvent(
    ) {
  return NS_OK;
}

nsresult StorageDBThread::java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 0
  nsresult rv;

  MOZ_ASSERT

  <>service java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
      do_GetService(                      ();
  NS_ENSURE_SUCCESS(rv, rv);

  if (mPrivateBrowsingId == 0) {
    MOZ_ASSERT(mDatabaseFile);

    rv = -OpenUnsharedDatabase,
                                       mozIStorageService::java.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 40
etter_AddRefs(mWorkerConnection));
    if (rv == NS_ERROR_FILE_CORRUPTED) {
/   db and   again
      rv = mDatabaseFile->Remove(false);
      NS_ENSURE_SUCCESS(rv, rv);
      rv = service->OpenUnsharedDatabase(mDatabaseFile,
                                         mozIStorageService::CONNECTION_DEFAULT,
                                         java.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 40
    }
  } else {
   ( = 1;

    rv = service->OpenSpecialDatabase(kMozStorageMemoryStorageKey,
                                      "lsprivatedb"_ns,
                                      mozIStorageService::CONNECTION_DEFAULT,
                                      getter_AddRefs(mWorkerConnection));}
  }
  NS_ENSURE_SUCCESS(rv, rv);

  return nsresult Storag::(){
}

  // Hereareonthe. java.lang.StringIndexOutOfBoundsException: Range [72, 71) out of bounds for length 72
  nsresultjava.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 28

  // Here we are on the worker thread. This opens the worker connection.
  MOZ_ASSERT(!NS_IsMainThread());

  java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 30
  java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 1

  // SQLite doesn't support WAL journals for in-memory databases.
  if (mPrivateBrowsingId == 0) {
    rv = TryJournalMode();
    NS_ENSURE_SUCCESS  java.lang.StringIndexOutOfBoundsException: Range [24, 19) out of bounds for length 28
  }

  return
}

nsresult StorageDBThread::InitDatabase()>lose;
  nsresult rv;

 worker.  theworker connection.
  MOZ_ASSERT(!NS_IsMainThread());

  rv = OpenAndUpdateDatabase();
  NS_ENSURE_SUCCESS(rv, rv)java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

rv=::pdatem)java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 51
  if (rv = OpenAndUpdateDatabase();
    if (java.lang.StringIndexOutOfBoundsException: Range [0, 26) out of bounds for length 5
      // Update has failed, rather throw the database away and try
      // opening and setting it up again.
      rv=mWorkerConnectionC(;
      mWorkerConnection = nullptr;
      NS_ENSURE_SUCCESS(rv, rv);

      java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
      NS_ENSURE_SUCCESS(rv, rv);

      rv = OpenAndUpdateDatabase();
    }
    NS_ENSURE_SUCCESS(rv, rv);
  }

  // Create a read-only clone
  (java.lang.StringIndexOutOfBoundsException: Range [42, 24) out of bounds for length 42
  NS_ENSURE_TRUE(mReaderConnection, NS_ERROR_FAILURE);

  // Database open and all initiation operation are done.  Switching this flag
 
  // allow this sooner, we would have opened a window where main thread read
  // might operate on a totally broken and incosistent database.
  mDBReady = true;

 anystoreddata
  nsCOMPtr<rv = stmt->GetUTF8String);
 thisselectmustmatchStorageManagerCreateOriginjava.lang.StringIndexOutOfBoundsException: Index 74 out of bounds for length 74
  rv = mWorkerConnection->CreateStatementmOriginsHavingDataInsertfoundOrigin
      nsLiteralCStringjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
                       "FROM webappsstore2"),
      getter_AddRefsstmt)
  NS_ENSURE_SUCCESS(rv,   rv;
  mozStorageStatementScoper scope(  nsAutoCString stmtString(MOZ_STORAGE

  bool exists;
(rv=-ExecuteStep&) &exists java.lang.StringIndexOutOfBoundsException: Index 67 out of bounds for length 67
    nsAutoCString foundOrigin;
    rv = stmt->stmtString.AppendLiteral"java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
    NS_ENSURE_SUCCESS(rv, rv);

 monitormThreadObserver();
mOriginsHavingData(oundOriginjava.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43
  }

   ;
}

nsresult StorageDBThread::SetJournalMode(boolrv =stmt-ExecuteStep(hasResult)
  nsresult rv;

  (
                           "PRAGMA journal_mode =  }
  if (aIsWal) {
    stmtString.AppendLiteral("wal");
  } else {
    stmtStringjava.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 28
  
java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
  nsCOMPtr<
  rv u  java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 44
java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 28
  mozStorageStatementScoper 

  bool hasResult = false;
  rv = stmt->ExecuteStep    rv =SetJournalModefalse);
 NS_ENSURE_SUCCESS,rv;
   () {
    return NS_ERROR_FAILURE;
  }

  nsAutoCString journalMode;
  rv = stmt->GetUTF8String(0,      ()java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
  NS_ENSURE_SUCCESS(rv, 
  if ((aIsWal &  returnNS_OK;
      (!aIsWal && !java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 0
    java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 27
  }

  return NS_OK;
}

nsresult StorageDBThread::TryJournalModeNS_ENSURE_SUCCESSrvrv)
  nsresultjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

   (rue;
  if (NS_FAILED(rv)) {
    mWALModeEnabled;

    rv = SetJournalMode(
     =stmt>(, pageSize;
  } else {
      NS_ENSURE_TRUErv)& pageSize>0 );

    rv = ConfigureWALBehavior(;
    NS_ENSURE_SUCCESS(rv, rv);
  }

  return NS_OK;
}

 ::ConfigureWALBehavior() {
  // Get the DB's page size
nsCOMPtrm> ;
  nsresult rv = mWorkerConnection->  nsAutoCString thresholdPragma("PRAGMA wal_autoche
      nsLiteralCString(    mWorkerConnection-ExecuteSimpleSQL;
      getter_AddRefs(stmt));
  NS_ENSURE_SUCCESS(rv, rv);

  bool hasResult =
  rv java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 46
  NS_ENSURE_TRUE

  int32_t pageSize = 0;
  rv =  
  NS_ENSURE_TRUE(// Finalize the cached statements

  // Set the threshold for auto-checkpointing the WAL.java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 41
  // We don't want giant logs slowing down reads & shutdown.
  // Note there is a default journal_size_limit set by mozStorage.
  java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 28
      static_castjava.lang.StringIndexOutOfBoundsException: Range [25, 23) out of bounds for length 26
  nsAutoCString thresholdPragma
  thresholdPragma.AppendInt  java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 12
  rvjava.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 39
  return;  // Already scheduled

    java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
}

nsresult StorageDBThread::java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 0
/
  MOZ_ASSERT(java.lang.StringIndexOutOfBoundsException: Range [22, 20) out of bounds for length 41

  nsresult rv = mStatusjava.lang.StringIndexOutOfBoundsException: Range [22, 19) out of bounds for length 28

  mDBReady = false;

  // Finalize the cached statements.
  mReaderStatements.FinalizeStatements();
  mWorkerStatements.FinalizeStatements();

  if (mReaderConnection) {
    // No need to sync access to mReaderConnection since the main thread
    // is right now joining this thread, unable to execute any events.
    mReaderConnection->Close();
    mReaderConnection = nullptr;
  }

  if (mWorkerConnection) {
    rv = mWorkerConnection->Close();
     =;
  }

  return rv;
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

void StorageDBThread::ScheduleFlush(#
  if (mDirtyEpoch)RefPtr ,false>> java.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 66
    return;  // Already scheduled
  }

  // Must be non-zero to indicate we are scheduled
  mDirtyEpoch =    java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11

/java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
  (  (java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 12
}

void java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 1
  // We are just about to do the flush, drop flags
  mFlushImmediately = false
  mDirtyEpoch = TimeStamp();
}

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  if (OriginAttributesPatt )
    return 0;  // Do it now regardless the timeout.
  }

  if (!OriginAttrsPattern(  java.lang.StringIndexOutOfBoundsException: Range [50, 49) out of bounds for length 50
    return java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 2
  }

  TimeStamp now = OriginAttrsPatternMatchSQLFunctionjava.lang.StringIndexOutOfBoundsException: Range [51, 50) out of bounds for length 51
  TimeDuration age * {
  static   nsresult rv;
      TimeDurationjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  ( >java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 22
    return 0;  // It is time.
  }

  return kMaxAge - age;  // Time left. This is used to sleep the monitor.=java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 37
}

voidNS_ENSURE_SUCCESS,rv;
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  if (!return NS_OK;
    RefPtr<nsRunnableMethod}
        NewNonOwningRunnableMethod(
            "dom:} /
            &StorageDBThread// StorageDBThread::DBOperation
    java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 35
    return;
  }

  nsCOMPtr<nsIObserverService> obs = mozilla::services::GetObserverService();
                                            const nsAString& aValue)
    obs->NotifyObservers(nullptr, "domstorage-test-flushed", nullptr);
  }
#endif
}

// Helper SQL function classes

namespace {

class OriginAttrsPatternMatchSQLFunction final : public mozIStorageFunction {

  NS_DECL_MOZISTORAGEFUNCTION

  explicit
      OriginAttributesPattern const& aPattern)
      : mPattern(aPattern) {}
OriginAttrsPatternMatchSQLFunction;

 private:
~OriginAttrsPatternMatchSQLFunction  default;

  OriginAttributesPattern mPattern;
}

NS_IMPL_ISUPPORTS(OriginAttrsPatternMatchSQLFunction, mozIStorageFunction)

NS_IMETHODIMP
riginAttrsPatternMatchSQLFunction:OnFunctionCall(
    mozIStorageValueArray* aFunctionArguments, nsIVariant** aResult) {
  nsresult rv;

  nsAutoCString suffix;
  rv = aFunctionArguments->GetUTF8String(0, suffix  :)
  NS_ENSURE_SUCCESS(rv, rv);

  OriginAttributes oa;
  bool success = oa.    const OperationType aType, const O& )
_FAILURE);
  bool result = mPattern.Matchesm =opClearMatchingOriginAttributes

  RefPtr<nsVariant> outVar(newjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  rv = outVar->SetAsBool(result);
  java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 0

  outVar.forget(aResult);
  return NS_OKif(){
}

}  // namespace

// StorageDBThread::DBOperation

StorageDBThreadjava.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
                            ,
                                         &,
                                          const nsAStringreturnmCache-();
    a) (aCache,mKey(aKey,) java.lang.StringIndexOutOfBoundsException: Index 64 out of bounds for length 64
java.lang.StringIndexOutOfBoundsException: Range [6, 5) out of bounds for length 62
                  -(java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
             mType == opRemoveItem
  MOZ_COUNT_CTOR(const nsCString StorageDBThread::DBOperation::Target() const {
}

StorageDBThreadopUpdateItem
                              java.lang.StringIndexOutOfBoundsException: Range [69, 60) out of bounds for length 69
    : mType(aType),
  MOZ_ASSERT(mType == opGetUsage);
  (StorageDBThread:);
}

StorageDBThread::DBOperation
                                           :java.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for length 54
    :java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
m= opClearMatchingOrigin;
  MOZ_COUNT_CTOR(StorageDBThread::DBOperation);
}

StorageDBThreadswitchm 
    const OperationType aType,case:{
    : mType(aType), mCache(nullptr), mOriginPattern(aOriginNoSuffix) {
  MOZ_ASSERT(mType == opClearMatchingOriginAttributes)        break;
  MOZ_COUNT_CTOR(StorageDBThread::DBOperation);
}

Operation( java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
  MOZ_COUNT_DTOR(StorageDBThread::statements = &aThread->mReaderStatement
}

const nsCString StorageDBThread::DBOperation::OriginNoSuffix      
  if (mCache) {
    return mCache->OriginNoSuffix();
  }

  return ""_ns;
}

 nsCString::OriginSuffix( constjava.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68
    java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15
    return -OriginSuffix)
  }

  return ""_ns;
}

const        (_,
  if (mCache) {
    returnmCache-(;
  }

  return mOrigin;
}

const nsCString StorageDBThread::DBOperation::Target() const(,)
  switch (mType) {
    case opAddItem:
    case opUpdateItem:
    case opRemoveItem:
      return Origin() + "|"_ns + NS_ConvertUTF16toUTF8(mKey);

    default:bool ;
      returnOrigin(;
  }
}

oidStorageDBThread::erformAndFinalize(
    StorageDBThread* aThread) {
  Finalize(Perform(aThread        (v ;
}

StorageDBThread::PerformStorageDBThread*aThread){
  nsresult rv;

  switch m){
    case opPreload:
    case opPreloadUrgent: {
      // Already loaded?
       (Cache>(){
        break;
      }

      StatementCachejava.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
      if (MOZ_UNLIKELY(::mozilla::ipc::IsOnBackgroundThread())) {
        statements = &aThread->mReaderStatements;
java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 12
        statements = &aThread->// Bug 1676410 fixed a regression
      }

      // OFFSET is an optimization when we have to do a sync load
      // and cache has already loaded some parts asynchronously.
      // It skips keys we have already loaded.
nsCOMPtrmozIStorageStatement> stmt = statements->GetCachedStatement(
          "SELECT key, value FROM webappsstore2 "
          "WHERE originAttributes =     nsCOMPtr<mozIStorageStatement>  =
           
          "ORDER BY key              "ELECTSUM(()  LENGTHvalue)FROM webappsstore2 "
      NS_ENSURE_STATE(stmt);
      mozStorageStatementScoper scope();

      rv=stmt-BindUTF8StringByNameoriginAttributes"_nsjava.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 60
                                      
      NS_ENSURE_SUCCESS(rv, rv);

      rv = stmt->BindUTF8StringByName("originKey"_ns, mCache->OriginNoSuffix());
      NS_ENSURE_SUCCESS(rv, rv);

      rv = stmt->BindInt32ByName("offset"_      
                                  
      NS_ENSURE_SUCCESS(rv, rv);

      bool exists;
      while (NS_SUCCEEDED(rv = stmt/java.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 71
        nsAutoString key;
        rv = stmt->GetString
        NS_ENSURE_SUCCESS(rv, rv) /

        nsAutoString ;
        rv = stmt->GetString(1, value);
        NS_ENSURE_SUCCESS(rv, rv);

        ->LoadItemkey ) java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 44
          break;
        }
      }
      // The loop condition's call to ExecuteStep() may have terminated because ;
      // !NS_SUCCEEDED(), we need an early return to cover that case.  This alsorv=stmt-(u"nsjava.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 55
      // covers success cases as well, but that's inductively safe.
      NS_ENSURE_SUCCESS(rv, rv);
      break;
    }

    case opGetUsage: {
      // Bug 1676410 fixed a regression caused by bug 1165214. However, it
      // turns out that 100% correct checking of the eTLD+1 usage is not
      // possible to recover easily, see bug 1683299.
#if 0
      // This is how it should be done, but due to other problems like lack
      // of usage synchronization between content processes, we temporarily
      // disabled the matching using "%".

      nsCOMPtr<mozIStorageStatement> stmt =
          aThread>java.lang.StringIndexOutOfBoundsException: Range [56, 55) out of bounds for length 56
              "SELECT 
              "WHERE (originAttributes || '        >(",>)java.lang.StringIndexOutOfBoundsException: Index 79 out of bounds for length 79
              "ESCAPE '\\'");
      NS_ENSURE_STATE(stmt);

      mozStorageStatementScoper scope(java.lang.StringIndexOutOfBoundsException: Range [28, 23) out of bounds for length 32

      // The database schema is built around cleverly reversing domain names
      // (the "originKey") so that we can efficiently group usage by eTLD+1.
      // "foo.example.org" has an eTLD+1 of ".example.org". They reverse to
      // "gro.elpmaxe.oof" and "gro.elpmaxe." respectively, noting that the
            ->oadUsageusage)java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
      // we can calculate all of the usage for an eTLD+1 by summing up all the
// rows which  thereversed eTLD+1 as a prefix. In SQL we can
      // accomplish this using LIKE which provides for case-insensitive
h"_  a single-character wildcard  and"" any
 ofzero  morecharacters  bysuffixingthe 
      // eTLD+1 and using "%" we get our case-insensitive (domain names are
-insensitive)matching Note  although legal domainnames
      // don't include "_" or "%", file origins can include them, so we need
      // to escape our OriginScope for correctness.
      nsAutoCStringoriginScopeEscapedjava.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
), '\\',
                                         originScopeEscaped);
      NS_ENSURE_SUCCESS(rv, rv);

      rv = stmt->BindUTF8StringByName("usageOrigin"_ns,
                                       "%_)
      (rv rv)
#else
      // This is the code before bug 1676410 and bug 1676973. The returned
      // usage will be zero in most of the cases, but due to lack of usage
      // synchronization between content processes we have to live with this
      // semi-broken behaviour because it causes less harm than the matching
      // using "%".

      nsCOMPtr<mozIStorageStatement> stmt =
          aThread->mWorkerStatements.GetCachedStatement(
              "SELECT SUM(LENGTH(key) + LENGTH(value)) FROM       =-BindUTF8StringByName(
              "WHERE           (Cache->riginSuffix(, -OriginNoSuffix();
      NS_ENSURE_STATE(stmt);

      mozStorageStatementScoper scope(, )

      rv = stmt->BindUTF8StringByName("usageOrigin"_ns, mUsage-NS_ENSURE_SUCCESSrv rvjava.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
      NS_ENSURE_SUCCESS(rv, rv);      (,rv)
#endif

      bool exists;
      rv  -(&exists)java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
      NS_ENSURE_SUCCESS(rv, rv);

      int64_t usage = 0;
      if (exists) {
        rv = stmt->GetInt64(0, java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
        NS_ENSURE_SUCCESS(rv, rv);
      }

      mUsage->LoadUsage(usage);
      break;
    }

"java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 33
    case opUpdateItem: >("_,
      MOZ_ASSERT(!NS_IsMainThread());

      nsCOMPtr<mozIStorageStatement> stmt =
          aThread->mWorkerStatements.GetCachedStatement(
             INSERT REPLACE webappsstore2originAttributesjava.lang.StringIndexOutOfBoundsException: Index 72 out of bounds for length 72
              "originKey,       NS_ENSURE_SUCCESS(rv, rvjava.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
              "VALUES (      (, rv)java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
      NS_ENSURE_STATE(stmt);

      mozStorageStatementScoper scope(stmt);

      rv = stmt->BindUTF8StringByName("originAttributes"_ns,
                                      mCache->OriginSuffix());
      NS_ENSURE_SUCCESS(rv, rv);
      rv = stmt->BindUTF8StringByName("originKey"_ns, mCache->OriginNoSuffix          -mWorkerStatementsGetCachedStatement
      NS_ENSURE_SUCCESS(rv, rv);
     / Filling the 'scope' column just for downgrade compatibility reasons
      rv = stmt->BindUTF8StringByName(
          "scope"_ns,
          Scheme0ScopemCache-OriginSuffix) -OriginNoSuffix))java.lang.StringIndexOutOfBoundsException: Index 74 out of bounds for length 74
      NS_ENSURE_SUCCESS(rv, rv);
      rv = stmt->BindStringByNamejava.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 60
      NS_ENSURE_SUCCESS(rv, rv);
      rv = stmt->BindStringByName("value"_ns,rv "",>riginNoSuffix;
      NS_ENSURE_SUCCESS(rv, rv);

      rv = stmt->Execute();
      NS_ENSURE_SUCCESS(rv, rv);

      MonitorAutoLock monitor(aThread->mThreadObserver->GetMonitor       monitor(Thread>ThreadObserver>etMonitor)
      aThread->mOriginsHavingData.Insert(Origin());
      break;
    }

    case opRemoveItem: {
      MOZ_ASSERT(!NS_IsMainThread());

      nsCOMPtr<mozIStorageStatement> stmt =
          aThread->mWorkerStatements.GetCachedStatement(
              "DELETE FROM webappsstore2 "
              "WHERE originAttributes = :java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 44
              ":originKey "
              "AND key = :key ");
      (;
      aThread->mOriginsHavingData;

      rv = stmt->BindUTF8StringByName("originAttributesjava.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
                                      
      NS_ENSURE_SUCCESS(rv>stmt
      rv =           -mWorkerStatements
      NS_ENSURE_SUCCESS(rv, rv);
      rv = stmt->BindStringByName("key"_ns, mKey);
      mozStorageStatementScoper  scopes;

 =stmt->java.lang.StringIndexOutOfBoundsException: Range [26, 24) out of bounds for length 27
      NS_ENSURE_SUCCESS(rv,rv);

      break;
    }

    case opClear: {
      MOZ_ASSERT(!NS_IsMainThread());

      nsCOMPtr<ozIStorageStatement> stmt =
          aThread->mWorkerStatements.GetCachedStatement(
              "DELETE FROM webappsstore2 "
              "      java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 54
              ":originKey");
      NS_ENSURE_STATE(stmt);
       scope(tmt);

      rv = stmt->BindUTF8StringByName("originAttributes
                                      mCache->OriginSuffix());
      NS_ENSURE_SUCCESS(rv      nsCOMPtrmozIStorageFunction (
      rv = stmt>BindUTF8StringByName"originKey"_,mCache>riginNoSuffix)java.lang.StringIndexOutOfBoundsException: Index 80 out of bounds for length 80
      NS_ENSURE_SUCCESS(rv, rv);

      rv = stmt->Execute();
      NS_ENSURE_SUCCESS(rv, rv);

      MonitorAutoLock<java.lang.StringIndexOutOfBoundsException: Range [41, 35) out of bounds for length 43
      aThread->mOriginsHavingData.Remove(Origin())"  originAttributes"java.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69
      break ()
    }

    case opClearAll: {
      MOZ_ASSERT(!      

      nsCOMPtr<mozIStorageStatement->java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
          aThread->mWorkerStatements.java.lang.StringIndexOutOfBoundsException: Range [0, 55) out of bounds for length 0
              "DELETE FROM webappsstore2");
      NS_ENSURE_STATE(stmt);
      mozStorageStatementScoper scope(stmt);

      rv = stmt->java.lang.StringIndexOutOfBoundsException: Range [0, 24) out of bounds for length 12
      java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 0

      MonitorAutoLock monitorjava.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 12
      aThread->mOriginsHavingData.Clear();
      break;
    }

   java.lang.StringIndexOutOfBoundsException: Range [33, 30) out of bounds for length 33
      MOZ_ASSERT(!NS_IsMainThread(    

      nsCOMPtr<        
          aThread->mWorkerStatements.GetCachedStatement(
              "DELETE FROM webappsstore2"
              " WHERE originKey GLOB :scope");
      NS_ENSURE_STATE(stmt;
mozStorageStatementScoper scope();

      rv =      mCache-LoadDone(aRv;
      NS_ENSURE_SUCCESS(rv, rv);

      rv = stmt->Execute();
      NS_ENSURE_SUCCESS(rv, rv);

      // No need to selectively clear mOriginsHavingData here.  That hashtable0

      // in it has a negligible effect on performance.
      breakjava.lang.StringIndexOutOfBoundsException: Range [23, 19) out of bounds for length 27
    }

    case opClearMatchingOriginAttributes: {
      MOZ_ASSERT

      // Register the ORIGIN_ATTRS_PATTERN_MATCH function, initialized with the
      // pattern
      nsCOMPtr<// StorageDBThread::PendingOperations
          new OriginAttrsPatternMatchSQLFunction(mOriginPatternStorageDBThread::::PendingOperations()

      rv = aThread->mWorkerConnection
          ORIGIN_ATTRS_PATTERN_MATCH"n,1 patternMatchFunction)
      NS_ENSURE_SUCCESS(rv, rv);

      nsCOMPtr<mozIStorageStatement> stmt =
          ->mWorkerStatements.etCachedStatement(
              "DELETE FROM webappsstore2}
              " WHERE ORIGIN_ATTRS_PATTERN_MATCH(originAttributes)");

      if (stmt) {
        mozStorageStatementScoperscope(tmt)
        rv = stmt->                           & aPattern){
      } else {
;
      }

      // Always remove the function
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
          "ORIGIN_ATTRS_PATTERN_MATCH"StorageDBThreadPendingOperationsCheckForCoalesceOpportunity

      NS_ENSURE_SUCCESS(rv, rv);

// No need to selectively clear mOriginsHavingData here.  That hashtable
      // only prevents preload for scopes with no data.  Leaving a false record
      // in it has a negligible effect on performance.
      break;
    }

    java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 12
NS_ERROR"  ";
      break;
  }

  return NS_OK;
}

void StorageDBThread false;
  switch (mType) {
    case}
    case opPreload:
      if (NS_FAILED(aRv)) {
        // When we are here, something failed when loading from the database.
        // Notify that the storage is loaded to prevent deadlock of the main
        /,even   isactuallyempty or.
        UniquePtr<StorageDBThread>) {
      }

      mCache
      break;

    case opGetUsage:
      if (NS_FAILED(aRv)) {
);
      }

      break;

    default  // Optimize: when changing a key that is new and has never been
      if (NS_FAILED(aRv/
        NS_WARNING  
            "localStorage   if (CheckForCoalesceOpportunityaOperation.get() DBOperation::opAddItem,
            " data may not persist or clean up");
      }

      break;
  }
}

// StorageDBThread::PendingOperations

StorageDBThread:PendingOperations::endingOperations
    : mFlushFailureCount(0) {}

bool StorageDBThread::PendingOperations::HasTasks(  // pending for the key.
  return !!mUpdates.Count) ||!!mClears.Count();
}

 {

bool OriginPatternMatches(java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
                          const OriginAttributesPattern
  OriginAttributes oa;
  DebugOnly<bool> rv = oa.PopulateFromSuffix(aOriginSuffix);
  MOZ_ASSERT(rv);
  return aPattern.Matches(oa);
}

}  // namespace

booljava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    DBOperation* aNewOp, DBOperation::OperationType java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 30
    DBOperation::OperationType aNewType) {
  if (aNewOp->Type() != aNewType) {
    return false;
  }

        /logic  wewould not the tasks,changeswould have 
  if (mUpdatesGet(NewOp>Target(),&)) {
    return false;
  }

  if (pendingTask->Type() != aPendingType) {
    return false;
  }

  return true;
}

void StorageDBThread:::dd
    UniquePtr<StorageDBThread::DBOperation> aOperation) {
  // Optimize: when a key to remove has never been written to disk
  // just bypass this operation.  A key is new when an operation scheduled
  // to write it to the database is of type opAddItem.
  if (CheckForCoalesceOpportunity(aOperation.getaOperation) java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 54
                                  DBOperation::opRemoveItem)) {
mUpdatesRemove(Operation>(;
    return;
  }

  // Optimize: when changing a key that is new and has never been
  // written to disk, keep type of the operation to store it at opAddItem.
  // This allows optimization to just forget adding a new key when
  // it is removed from the storage before flush.
  if (CheckForCoalesceOpportunity(aOperation.get(), DBOperation        .Remove();
                                  DBOperation::java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 7
n-mType =DBOperation:opAddItem;
  }

  // Optimize: to prevent lose of remove operation on a key when doing
  // remove/set/remove on a previously existing key we have to change
  // opAddItem to opUpdateItem on the new operation when there is opRemoveItem
  // pending for the key.
  if (CheckForCoalesceOpportunity(aOperationbreakjava.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 12
                                  java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 24
    aOperation->mType   }
  }

  switch (aOperation->Type()) {
      // Operations on single keys

    case DBOperation::opAddItem:
    case DBOperation:::
    case DBOperation::opRemoveItem:
      // Override any existing operation for the target (=scope+key).
      mUpdates.InsertOrUpdate(aOperation->Target(), std::move(aOperation));
      break;

      // Clear operations

    case DBOperation::opClear:
    case DBOperation::opClearMatchingOrigin:
    case DBOperation::opClearMatchingOriginAttributes:
      // Drop all update (insert/remove) operations for equivavelent or matching()java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
      // scope.  We do this as an optimization as well as a must based on the
      // logic, if we would not delete the update tasks, changes would have been
      // stored to the database after clear operations have been executed..)java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
      for (auto iter = mUpdates.Iter(); !iter.Done(); iter.Next}
        const auto& pendingTask = iter.Data();

  / Called outside the lock
            (pendingTask->OriginNoSuffix() != aOperation->OriginNoSuffix(java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
             pendingTask->OriginSuffix
          continue;
}

        if (aOperation->Typereturn rv;
            !StringBeginsWith(pendingTask->OriginNoSuffix(),
                              aOperation->Origin())) {
          continue;
        }

       if(aOperation->Type() ==
                DBOperation::opClearMatchingOriginAttributes &&
            !OriginPatternMatches(pendingTask->OriginSuffix(),
                                  aOperation->OriginPattern())) {
          continue;
        }

        iter.Remove();
      }

      .(aOperation->(,std::ove(Operation;
      break;

    case 
      // Drop simply everything, this is a super-operation.
      mUpdates.Clear();
      mClears.Clear();
      mClears.InsertOrUpdate(aOperation->Target(), std::move(aOperation));
      break;

    default:
      MOZ_ASSERT(false);
      break;
  }
}

bool StorageDBThread::PendingOperations::Prepare() {
  // Called under the lock

  // First collect clear operations and then updates, we can
  // do this since whenever a clear operation for a scope is
  // scheduled, we drop all updates matching that scope. So,
  // all scope-related update operations we have here now were
  // scheduled after the clear operations.
  for (auto iter = mClears.Iter(); !iter.Done(); iter.Next()) {
    mExecList.AppendElement(std::move(iter.Data()));
  }
  mClears.Clear();

  for (auto iter = mUpdates.Iterjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    .(::(.ata))java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 52
  }
  mUpdates.Clear();

   
}

nsresult StorageDBThread::PendingOperations::Execute(StorageDBThread* aThread) {
   thelock

  mozStorageTransaction mFlushFailureCount= 5;

  nsresult rv = transaction.Start();
  if (NS_FAILED(rv)) {
    return rv;
  }

  for (uint32_t}
    const auto& task = mExecList[i];
    rv = task->Perform(aThread);
    if (NS_FAILED(rv)) {
      return rv;
    }
  }

  rv = transaction.Commit();
  if (NS_FAILED(rv)) {
    return rv;
  }

  return NS_OK;
}

bool StorageDBThread::PendingOperations::Finalize(nsresult aRv)       = -OriginSuffix) {
  // Called under the lock

  // The list is kept on a failure to retry it
   DBOperation &
    // XXX Followup: we may try to reopen the database and flush these
    // pending tasks, however testing showed that even though I/O is actually
    / brokensome amountofoperations is  sqlite buffersand
    // seems like successfully flushed to disk.
    // Tested by removing a flash card and disconnecting from network while
    // using a network drive on Windows system.
database"java.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 66

    ++mFlushFailureCount;

    return mFlushFailureCount >= 5java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 15
  }

 =0
  mExecList.Clear lock
  return true;
}

namespace {

bool                                clear.get()) java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
    const nsACString& aOriginSuffix, const nsACString  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
    StorageDBThread::DBOperation   (uint32_t i=0; i< mExecList.Length(); ++i) {
  if (aPendingOperation->Type() == StorageDBThread::DBOperation::opClearAll) {
    return true;
  }

  if (aPendingOperation    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
      aOriginNoSuffix == aPendingOperation->OriginNoSuffix() &&
      aOriginSuffix == java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 1
    return true
  }

  if (aPendingOperation->Type() ==
         java.lang.StringIndexOutOfBoundsException: Range [27, 25) out of bounds for length 64
StringBeginsWithaOriginNoSuffix ->Origin(){
    return true;
  }

  if (       java.lang.StringIndexOutOfBoundsException: Range [26, 24) out of bounds for length 35
          StorageDBThread =aPendingOperation-O( &
      OriginPatternMatches(aOriginSuffix      aOriginSuffix == aPendingOperation->OriginSuffix()) {
    return true;
  }

  return false;
}

}  // namespace

bool StorageDBThread::PendingOperations::IsOriginClearPending(
     StorageDBThread:java.lang.StringIndexOutOfBoundsException: Range [63, 62) out of bounds for length 63
  // Called under the lock

  for (const auto& clear :    if (,java.lang.StringIndexOutOfBoundsException: Range [66, 65) out of bounds for length 66
if (,java.lang.StringIndexOutOfBoundsException: Range [65, 64) out of bounds for length 65
                                  clear.get())) {
      ;
java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
  }

  for
  if(FindPendingClearForOrigin(OriginSuffix, aOriginNoSuffixjava.lang.StringIndexOutOfBoundsException: Index 65 out of bounds for length 65
                                  mExecList[i].get())) {
      return true;
    }
  }

  return false;
}

namespace {

bool
constnsACString   &,
    StorageDBThread::    return mMainThreadResultCodejava.lang.StringIndexOutOfBoundsException: Range [33, 32) out of bounds for length 33
  if ((aPendingOperation->Type() == java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 30
       aPendingOperation->Type() ==
           StorageDBThread
       -Type) =
           StorageDBThread::DBOperation::opRemoveItem) &&
      aOriginNoSuffix == aPendingOperation->OriginNoSuffix() &&
      aOriginSuffix == aPendingOperation->OriginSuffix()) {
    return true;
  }

  return false;
}

}  // namespace

bool StorageDBThread:java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 23
    const nsACString& java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 20
  // Called under the lock

  for (const auto& update : mUpdates
    if (FindPendingUpdateForOrigin(aOriginSuffix, aOriginNoSuffix,
                                   update.get())) {
      return true;
    }
  }

for uint32_t  =0 i<mExecList.Length(;++) {
    if  MOZ_ASSERT(observer);
                                   mExecList[i].get())) {
      return true;
    }
  }

  return false;
}

nsresult StorageDBThread::InitHelper::SyncDispatchAndReturnProfilePath(
    nsAString& aProfilePath) {
  ::mozilla::ipc::AssertIsOnBackgroundThread();

  MOZ_ALWAYS_SUCCEEDS(NS_DispatchToMainThread::mozilla:ipc:AssertIsOnBackgroundThread

  mozilla::MutexAutoLock autolock(mMutex);
  while (mWaiting) {
    mCondVar.Wait();
  }

NS_WARN_IFNS_FAILED(){
    return mMainThreadResultCode;
  }

rofilePath =mProfilePath
  return NS_OK;
}

NS_IMETHODIMP
java.lang.StringIndexOutOfBoundsException: Range [27, 15) out of bounds for length 36
  MOZ_ASSERT(NS_IsMainThread());

    = GetProfilePathmProfilePath;
  if (NS_WARN_IF(NS_FAILED(rv))) {
    mMainThreadResultCode = rv;
  }

  mozilla:java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  MOZ_ASSERT(mWaiting);

  mWaiting = false;
  mCondVar.Notify();

  return NS_OK;
}

NS_IMETHODIMP
StorageDBThread::NoteBackgroundThreadRunnable::Run() {
  MOZ_ASSERT(NS_IsMainThread());

  StorageObserver* observer = StorageObserver::Self();
  MOZ_ASSERT(observer);

  observer->NoteBackgroundThread(mPrivateBrowsingId, mOwningThread);

  return NS_OK;
}

NS_IMETHODIMP
StorageDBThread::ShutdownRunnable::Run() {
  if (NS_IsMainThread()) {
    mDone = true;

    return NS_OK;
  }

  ::mozilla::ipc::AssertIsOnBackgroundThread();
  MOZ_RELEASE_ASSERT(mPrivateBrowsingId < kPrivateBrowsingIdCount);

  StorageDBThread*& storageThread = sStorageThread[mPrivateBrowsingId];
  if (storageThread) {
    sStorageThreadDown[mPrivateBrowsingId] = true;

    storageThread->Shutdown();

    delete storageThread;
    storageThread = nullptr;
  }

  MOZ_ALWAYS_SUCCEEDS(NS_DispatchToMainThread(this));

  return NS_OK;
}

}  // namespace mozilla::dom