Home | History | Annotate | Download | only in webdatabase 
      1 /*
      2  * Copyright (C) 2007, 2008 Apple Inc. All rights reserved.
      3  *
      4  * Redistribution and use in source and binary forms, with or without
      5  * modification, are permitted provided that the following conditions
      6  * are met:
      7  *
      8  * 1.  Redistributions of source code must retain the above copyright
      9  *     notice, this list of conditions and the following disclaimer.
     10  * 2.  Redistributions in binary form must reproduce the above copyright
     11  *     notice, this list of conditions and the following disclaimer in the
     12  *     documentation and/or other materials provided with the distribution.
     13  * 3.  Neither the name of Apple Computer, Inc. ("Apple") nor the names of
     14  *     its contributors may be used to endorse or promote products derived
     15  *     from this software without specific prior written permission.
     16  *
     17  * THIS SOFTWARE IS PROVIDED BY APPLE AND ITS CONTRIBUTORS "AS IS" AND ANY
     18  * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
     19  * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
     20  * DISCLAIMED. IN NO EVENT SHALL APPLE OR ITS CONTRIBUTORS BE LIABLE FOR ANY
     21  * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
     22  * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
     23  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
     24  * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
     25  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
     26  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
     27  */
     28 #ifndef DatabaseThread_h
     29 #define DatabaseThread_h
     30 
     31 #include "public/platform/WebThread.h"
     32 #include "wtf/Deque.h"
     33 #include "wtf/HashMap.h"
     34 #include "wtf/HashSet.h"
     35 #include "wtf/OwnPtr.h"
     36 #include "wtf/PassOwnPtr.h"
     37 #include "wtf/PassRefPtr.h"
     38 #include "wtf/RefPtr.h"
     39 #include "wtf/ThreadSafeRefCounted.h"
     40 
     41 namespace WebCore {
     42 
     43 class DatabaseBackend;
     44 class DatabaseTask;
     45 class DatabaseTaskSynchronizer;
     46 class Document;
     47 class SQLTransactionClient;
     48 class SQLTransactionCoordinator;
     49 
     50 class DatabaseThread : public ThreadSafeRefCounted<DatabaseThread> {
     51 public:
     52     static PassRefPtr<DatabaseThread> create() { return adoptRef(new DatabaseThread); }
     53     ~DatabaseThread();
     54 
     55     void start();
     56     void requestTermination(DatabaseTaskSynchronizer* cleanupSync);
     57     bool terminationRequested(DatabaseTaskSynchronizer* taskSynchronizer = 0) const;
     58 
     59     void scheduleTask(PassOwnPtr<DatabaseTask>);
     60 
     61     void recordDatabaseOpen(DatabaseBackend*);
     62     void recordDatabaseClosed(DatabaseBackend*);
     63     bool isDatabaseOpen(DatabaseBackend*);
     64 
     65     bool isDatabaseThread() { return m_thread && m_thread->isCurrentThread(); }
     66 
     67     SQLTransactionClient* transactionClient() { return m_transactionClient.get(); }
     68     SQLTransactionCoordinator* transactionCoordinator() { return m_transactionCoordinator.get(); }
     69 
     70 private:
     71     DatabaseThread();
     72 
     73     void cleanupDatabaseThread();
     74 
     75     OwnPtr<blink::WebThread> m_thread;
     76 
     77     // This set keeps track of the open databases that have been used on this thread.
     78     typedef HashSet<RefPtr<DatabaseBackend> > DatabaseSet;
     79     DatabaseSet m_openDatabaseSet;
     80 
     81     OwnPtr<SQLTransactionClient> m_transactionClient;
     82     OwnPtr<SQLTransactionCoordinator> m_transactionCoordinator;
     83     DatabaseTaskSynchronizer* m_cleanupSync;
     84     bool m_terminationRequested;
     85 };
     86 
     87 } // namespace WebCore
     88 
     89 #endif // DatabaseThread_h
     90