mandoline: Start adding trace events for mandoline stuff.

sql/mojo/mojo_vfs.cc

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "sql/mojo/mojo_vfs.h"
 
 #include "base/logging.h"
 #include "base/rand_util.h"
 #include "base/strings/stringprintf.h"
+#include "base/trace_event/trace_event.h"
 #include "components/filesystem/public/interfaces/file.mojom.h"
 #include "components/filesystem/public/interfaces/file_system.mojom.h"
 #include "components/filesystem/public/interfaces/types.mojom.h"
 #include "mojo/public/cpp/bindings/lib/template_util.h"
 #include "mojo/util/capture_util.h"
 #include "third_party/sqlite/sqlite3.h"
 
 using mojo::Capture;
 
 namespace sql {
@@ skipping 33 matching lines @@
   // up.
   filesystem::FilePtr file_ptr;
 };
 
 filesystem::FilePtr& GetFSFile(sqlite3_file* vfs_file) {
   return reinterpret_cast<MojoVFSFile*>(vfs_file)->file_ptr;
 }
 
 int MojoVFSClose(sqlite3_file* file) {
   DVLOG(1) << "MojoVFSClose(*)";
+  TRACE_EVENT0("sql", "MojoVFSClose");
   using filesystem::FilePtr;
   filesystem::FileError error = filesystem::FILE_ERROR_FAILED;
   // Must call File::Close explicitly instead of just deleting the file, since
   // otherwise we wouldn't have an object to wait on.
   GetFSFile(file)->Close(mojo::Capture(&error));
   GetFSFile(file).WaitForIncomingResponse();
   GetFSFile(file).~FilePtr();
   return SQLITE_OK;
 }
 
 int MojoVFSRead(sqlite3_file* sql_file,
                 void* buffer,
                 int size,
                 sqlite3_int64 offset) {
   DVLOG(1) << "MojoVFSRead (" << size << " @ " << offset << ")";
+  TRACE_EVENT0("sql", "MojoVFSRead");
   filesystem::FileError error = filesystem::FILE_ERROR_FAILED;
   mojo::Array<uint8_t> mojo_data;
   GetFSFile(sql_file)->Read(size, offset, filesystem::WHENCE_FROM_BEGIN,
                             Capture(&error, &mojo_data));
   GetFSFile(sql_file).WaitForIncomingResponse();
 
   if (error != filesystem::FILE_ERROR_OK) {
     // TODO(erg): Better implementation here.
     NOTIMPLEMENTED();
     return SQLITE_IOERR_READ;
   }
 
   if (mojo_data.size())
     memcpy(buffer, &mojo_data.front(), mojo_data.size());
   if (mojo_data.size() == static_cast<size_t>(size))
     return SQLITE_OK;
 
   // We didn't read the entire buffer. Fill the rest of the buffer with zeros.
   memset(reinterpret_cast<char*>(buffer) + mojo_data.size(), 0,
          size - mojo_data.size());
 
   return SQLITE_IOERR_SHORT_READ;
 }
 
 int MojoVFSWrite(sqlite3_file* sql_file,
                  const void* buffer,
                  int size,
                  sqlite_int64 offset) {
   DVLOG(1) << "MojoVFSWrite(*, " << size << ", " << offset << ")";
+  TRACE_EVENT0("sql", "MojoVFSWrite");
   mojo::Array<uint8_t> mojo_data(size);
   memcpy(&mojo_data.front(), buffer, size);
 
   filesystem::FileError error = filesystem::FILE_ERROR_FAILED;
   uint32_t num_bytes_written = 0;
   GetFSFile(sql_file)->Write(mojo_data.Pass(), offset,
                              filesystem::WHENCE_FROM_BEGIN,
                              Capture(&error, &num_bytes_written));
   GetFSFile(sql_file).WaitForIncomingResponse();
   if (error != filesystem::FILE_ERROR_OK) {
     // TODO(erg): Better implementation here.
     NOTIMPLEMENTED();
     return SQLITE_IOERR_WRITE;
   }
   if (num_bytes_written != static_cast<uint32_t>(size)) {
     NOTIMPLEMENTED();
     return SQLITE_IOERR_WRITE;
   }
 
   return SQLITE_OK;
 }
 
 int MojoVFSTruncate(sqlite3_file* sql_file, sqlite_int64 size) {
   DVLOG(1) << "MojoVFSTruncate(*, " << size << ")";
+  TRACE_EVENT0("sql", "MojoVFSTruncate");
   filesystem::FileError error = filesystem::FILE_ERROR_FAILED;
   GetFSFile(sql_file)->Truncate(size, Capture(&error));
   GetFSFile(sql_file).WaitForIncomingResponse();
   if (error != filesystem::FILE_ERROR_OK) {
     // TODO(erg): Better implementation here.
     NOTIMPLEMENTED();
     return SQLITE_IOERR_TRUNCATE;
   }
 
   return SQLITE_OK;
 }
 
 int MojoVFSSync(sqlite3_file* sql_file, int flags) {
   DVLOG(1) << "MojoVFSSync(*, " << flags << ")";
+  TRACE_EVENT0("sql", "MojoVFSSync");
   filesystem::FileError error = filesystem::FILE_ERROR_FAILED;
   GetFSFile(sql_file)->Flush(Capture(&error));
   GetFSFile(sql_file).WaitForIncomingResponse();
   if (error != filesystem::FILE_ERROR_OK) {
     // TODO(erg): Better implementation here.
     NOTIMPLEMENTED();
     return SQLITE_IOERR_FSYNC;
   }
 
   return SQLITE_OK;
 }
 
 int MojoVFSFileSize(sqlite3_file* sql_file, sqlite_int64* size) {
   DVLOG(1) << "MojoVFSFileSize(*)";
+  TRACE_EVENT0("sql", "MojoVFSFileSize");
 
   filesystem::FileError err = filesystem::FILE_ERROR_FAILED;
   filesystem::FileInformationPtr file_info;
   GetFSFile(sql_file)->Stat(Capture(&err, &file_info));
   GetFSFile(sql_file).WaitForIncomingResponse();
 
   if (err != filesystem::FILE_ERROR_OK) {
     // TODO(erg): Better implementation here.
     NOTIMPLEMENTED();
     return SQLITE_IOERR_FSTAT;
@@ skipping 60 matching lines @@
     MojoVFSSectorSize,            /* xSectorSize */
     MojoVFSDeviceCharacteristics, /* xDeviceCharacteristics */
 };
 
 int MojoVFSOpen(sqlite3_vfs* mojo_vfs,
                 const char* name,
                 sqlite3_file* file,
                 int flags,
                 int* pOutFlags) {
   DVLOG(1) << "MojoVFSOpen(*, " << name << ", *, " << flags << ")";
+  TRACE_EVENT2("sql", "MojoVFSOpen",
+               "name", name,
+               "flags", flags);
   int open_flags = 0;
   if (flags & SQLITE_OPEN_EXCLUSIVE) {
     DCHECK(flags & SQLITE_OPEN_CREATE);
     open_flags = filesystem::kFlagCreate;
   } else if (flags & SQLITE_OPEN_CREATE) {
     DCHECK(flags & SQLITE_OPEN_READWRITE);
     open_flags = filesystem::kFlagOpenAlways;
   } else {
     open_flags = filesystem::kFlagOpen;
   }
@@ skipping 37 matching lines @@
   // |file| is actually a malloced buffer of size szOsFile. This means that we
   // need to manually use placement new to construct the C++ object which owns
   // the pipe to our file.
   new (&GetFSFile(file)) filesystem::FilePtr(file_ptr.Pass());
 
   return SQLITE_OK;
 }
 
 int MojoVFSDelete(sqlite3_vfs* mojo_vfs, const char* filename, int sync_dir) {
   DVLOG(1) << "MojoVFSDelete(*, " << filename << ", " << sync_dir << ")";
+  TRACE_EVENT2("sql", "MojoVFSDelete",
+               "name", filename,
+               "sync_dir", sync_dir);
   // TODO(erg): The default windows sqlite VFS has retry code to work around
   // antivirus software keeping files open. We'll probably have to do something
   // like that in the far future if we ever support Windows.
   filesystem::FileError error = filesystem::FILE_ERROR_FAILED;
   GetRootDirectory(mojo_vfs)->Delete(filename, 0, Capture(&error));
   GetRootDirectory(mojo_vfs).WaitForIncomingResponse();
 
   if (error == filesystem::FILE_ERROR_OK && sync_dir) {
     GetRootDirectory(mojo_vfs)->Flush(Capture(&error));
     GetRootDirectory(mojo_vfs).WaitForIncomingResponse();
   }
 
   return error == filesystem::FILE_ERROR_OK ? SQLITE_OK : SQLITE_IOERR_DELETE;
 }
 
 int MojoVFSAccess(sqlite3_vfs* mojo_vfs,
                   const char* filename,
                   int flags,
                   int* result) {
   DVLOG(1) << "MojoVFSAccess(*, " << filename << ", " << flags << ", *)";
+  TRACE_EVENT2("sql", "MojoVFSAccess",
+               "name", filename,
+               "flags", flags);
   filesystem::FileError error = filesystem::FILE_ERROR_FAILED;
 
   if (flags == SQLITE_ACCESS_READWRITE || flags == SQLITE_ACCESS_READ) {
     bool is_writable = false;
     GetRootDirectory(mojo_vfs)
         ->IsWritable(filename, Capture(&error, &is_writable));
     GetRootDirectory(mojo_vfs).WaitForIncomingResponse();
     *result = is_writable;
     return SQLITE_OK;
   }
@@ skipping 100 matching lines @@
 
   CHECK(sqlite3_vfs_register(parent_, 1) == SQLITE_OK);
   CHECK(sqlite3_vfs_unregister(&mojo_vfs) == SQLITE_OK);
 }
 
 filesystem::DirectoryPtr& ScopedMojoFilesystemVFS::GetDirectory() {
   return root_directory_;
 }
 
 }  // namespace sql