Commit fb35f696 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent ef6d0669
...@@ -152,6 +152,16 @@ class tDB: ...@@ -152,6 +152,16 @@ class tDB:
t.wc.close() t.wc.close()
dbclose(t.root) dbclose(t.root)
# open opens wcfs file corresponding to zf@at and starts to track it.
# see returned tFile for details.
def open(t, zf, at=None): # -> tFile
return tFile(t, zf, at=at)
# openwatch opens /head/watch on wcfs.
# see returned tWatch for details.
def openwatch(t): # -> tWatch
return tWatch(t)
# change schedules zf to be changed according changeDelta at commit. # change schedules zf to be changed according changeDelta at commit.
# #
# changeDelta is {} blk -> data. # changeDelta is {} blk -> data.
...@@ -189,7 +199,7 @@ class tDB: ...@@ -189,7 +199,7 @@ class tDB:
t.head = head t.head = head
t._headv.append(head) t._headv.append(head)
# sync wcfs # synchronize wcfs to db
t._wcsync() t._wcsync()
return head return head
...@@ -211,7 +221,7 @@ class tDB: ...@@ -211,7 +221,7 @@ class tDB:
# path returns path for object on wcfs. # path returns path for object on wcfs.
# - str: wcfs root + obj; # - str: wcfs root + obj;
# - Persistent: wcfs root + (head|@<at>)/bigfile/obj # - Persistent: wcfs root + (head|@<at>)/bigfile/obj
def path(t, obj, at=None): def path(t, obj, at=None):
if isinstance(obj, Persistent): if isinstance(obj, Persistent):
...@@ -239,16 +249,6 @@ class tDB: ...@@ -239,16 +249,6 @@ class tDB:
path = t.path(obj, at=at) path = t.path(obj, at=at)
return open(path, mode, 0) # unbuffered return open(path, mode, 0) # unbuffered
# open opens wcfs file corresponding to zf@at and starts to track it.
# see returned tFile for details.
def open(t, zf, at=None): # -> tFile
return tFile(t, zf, at=at)
# openwatch opens /head/watch on wcfs.
# see returned tWatch for details.
def openwatch(t): # -> tWatch
return tWatch(t)
# tFile provides testing environment for one bigfile on wcfs. # tFile provides testing environment for one bigfile on wcfs.
class tFile: class tFile:
......
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