1
    2
    3
    4
    5
    6
    7
    8
    9
   10
   11
   12
   13
   14
   15
   16
   17
   18
   19
   20
   21
   22
   23
   24
   25
   26
   27
   28
   29
   30
   31
   32
   33
   34
   35
   36
   37
   38
   39
   40
   41
   42
   43
   44
   45
   46
   47
   48
   49
   50
   51
   52
   53
   54
   55
   56
   57
   58
   59
   60
   61
   62
   63
   64
   65
   66
   67
   68
   69
   70
   71
   72
   73
   74
   75
   76
   77
   78
   79
   80
   81
   82
   83
   84
   85
   86
   87
   88
   89
   90
   91
   92
   93
   94
   95
   96
   97
   98
   99
  100
  101
  102
  103
  104


content / test / data / indexeddb / quota_test.js [blame]

// Copyright 2012 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

function test() {
  if (navigator.storage) {
    window.jsTestIsAsync = true;
    navigator.storage.estimate()
        .then(initUsageCallback)
        .catch(unexpectedErrorCallback);
  } else
    debug('This test requires navigator.storage.');
}

function initUsageCallback(result) {
  origReturnedUsage = returnedUsage = result.usage;
  origReturnedQuota = returnedQuota = result.quota;
  debug("original quota is " + displaySize(origReturnedQuota));
  debug("original usage is " + displaySize(origReturnedUsage));

  indexedDBTest(prepareDatabase, initQuotaEnforcing);
}

function prepareDatabase()
{
  db = event.target.result;
  objectStore = db.createObjectStore("test123");
}

function displaySize(bytes) {
  var k = bytes / 1024;
  var m = k / 1024;
  return bytes + " (" + k + "k) (" + m + "m)";
}

function initQuotaEnforcing() {
  var availableSpace = origReturnedQuota - origReturnedUsage;
  var kMaxMbPerWrite = 5;
  var kMinWrites = 5;
  var len = Math.min(kMaxMbPerWrite * 1024 * 1024,
                     Math.floor(availableSpace / kMinWrites));
  maxExpectedWrites = Math.floor(availableSpace / len) + 1;
  debug("Chunk size: " + displaySize(len));
  debug("Expecting at most " + maxExpectedWrites + " writes, but we could " +
        "have more if snappy is used or LevelDB is about to compact.");
  // The data needs to be randomized to avoid compression.
  data = '';
  for (let i = 0; i < 1 + len / 8; i++) {
    data += Math.random().toString(36).slice(2, 10);
  }
  dataLength = data.length;
  dataAdded = 0;
  successfulWrites = 0;
  startNewTransaction();
}

function startNewTransaction() {
  if (dataAdded > origReturnedQuota) {
    fail("dataAdded > quota " + dataAdded + " > " + origReturnedQuota);
    return;
  }
  debug("");
  debug("Starting new transaction.");

  var trans = db.transaction(['test123'], 'readwrite');
  trans.onabort = onAbort;
  trans.oncomplete = getQuotaAndUsage;
  var store = trans.objectStore('test123');
  request = store.put({x: data}, dataAdded);
  request.onerror = logError;
}

function getQuotaAndUsage() {
  successfulWrites++;
  if (successfulWrites > maxExpectedWrites) {
    debug("Weird: too many writes. There were " + successfulWrites +
          " but we only expected " + maxExpectedWrites);
  }
  navigator.webkitTemporaryStorage.queryUsageAndQuota(
    usageCallback, unexpectedErrorCallback);
}

function usageCallback(usage, quota) {
  debug("Transaction finished.");
  dataAdded += dataLength;
  debug("We've added "+ displaySize(dataAdded));
  returnedUsage = usage;
  returnedQuota = quota;
  debug("Allotted quota is " + displaySize(returnedQuota));
  debug("LevelDB usage is " + displaySize(returnedUsage));
  startNewTransaction();
}

function onAbort() {
  shouldBeEqualToString("event.target.error.name", "QuotaExceededError");
  done("Transaction aborted. Data added: " + displaySize(dataAdded));
  debug("There were " + successfulWrites + " successful writes");
}

function logError() {
  debug("Error function called: (" + event.target.error.name + ") " +
        event.target.error.message);
  event.preventDefault();
}