Commit f7b570c2 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 26d111af
...@@ -72,7 +72,8 @@ func NewDB(stor IStorage) *DB { ...@@ -72,7 +72,8 @@ func NewDB(stor IStorage) *DB {
// The connection is opened to current latest database state. // The connection is opened to current latest database state.
// //
// Open must be called under transaction. // Open must be called under transaction.
// Opened connection must be used under the same transaction only. // Opened connection must be used only under the same transaction and only
// until that transaction is complete.
// //
// XXX text // XXX text
// //
...@@ -163,7 +164,10 @@ func (db *DB) get(at Tid) *Connection { ...@@ -163,7 +164,10 @@ func (db *DB) get(at Tid) *Connection {
// put puts connection back into db pool. // put puts connection back into db pool.
func (db *DB) put(conn *Connection) { func (db *DB) put(conn *Connection) {
// XXX assert conn.db == db if conn.db != db {
panic("DB.put: conn.db != db")
}
conn.txn = nil conn.txn = nil
db.mu.Lock() db.mu.Lock()
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment