Commit 2aa8e196 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 496019d6
// Copyright (C) 2018-2019 Nexedi SA and Contributors. // Copyright (C) 2018-2020 Nexedi SA and Contributors.
// Kirill Smelkov <kirr@nexedi.com> // Kirill Smelkov <kirr@nexedi.com>
// //
// This program is free software: you can Use, Study, Modify and Redistribute // This program is free software: you can Use, Study, Modify and Redistribute
...@@ -190,6 +190,12 @@ func newConnection(db *DB, at Tid) *Connection { ...@@ -190,6 +190,12 @@ func newConnection(db *DB, at Tid) *Connection {
} }
} }
// DB returns database handle under which the connection was opened.
func (conn *Connection) DB() *DB {
conn.checkLive("db") // XXX needed?
return conn.db
}
// At returns database state corresponding to the connection. // At returns database state corresponding to the connection.
func (conn *Connection) At() Tid { func (conn *Connection) At() Tid {
conn.checkLive("at") conn.checkLive("at")
......
...@@ -166,6 +166,10 @@ func (db *DB) Close() error { ...@@ -166,6 +166,10 @@ func (db *DB) Close() error {
return nil return nil
} }
// Storage returns storage this database handle was created for.
func (db *DB) Storage() IStorage {
return db.stor
}
// ConnOptions describes options to DB.Open . // ConnOptions describes options to DB.Open .
type ConnOptions struct { type ConnOptions struct {
......
// Copyright (C) 2018-2019 Nexedi SA and Contributors. // Copyright (C) 2018-2020 Nexedi SA and Contributors.
// Kirill Smelkov <kirr@nexedi.com> // Kirill Smelkov <kirr@nexedi.com>
// //
// This program is free software: you can Use, Study, Modify and Redistribute // This program is free software: you can Use, Study, Modify and Redistribute
...@@ -266,7 +266,7 @@ func testdb(t0 *testing.T, rawcache bool) *tDB { ...@@ -266,7 +266,7 @@ func testdb(t0 *testing.T, rawcache bool) *tDB {
return t return t
} }
// Reopen repoens zodb/go .stor and .db . // Reopen reopens zodb/go .stor and .db .
func (t *tDB) Reopen() { func (t *tDB) Reopen() {
t.Helper() t.Helper()
X := t.fatalif X := t.fatalif
......
// Copyright (C) 2017-2019 Nexedi SA and Contributors. // Copyright (C) 2017-2020 Nexedi SA and Contributors.
// Kirill Smelkov <kirr@nexedi.com> // Kirill Smelkov <kirr@nexedi.com>
// //
// This program is free software: you can Use, Study, Modify and Redistribute // This program is free software: you can Use, Study, Modify and Redistribute
...@@ -591,6 +591,7 @@ mainloop: ...@@ -591,6 +591,7 @@ mainloop:
fs.syncMu.Unlock() fs.syncMu.Unlock()
// check f size, to see whether there could be any updates. // check f size, to see whether there could be any updates.
// XXX /tmp/δBTail491926614/1.fs: watcher: stat /tmp/δBTail491926614/1.fs: use of closed file
fi, err := f.Stat() fi, err := f.Stat()
if err != nil { if err != nil {
return err return err
......
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