Commit b6c4446b authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent ed63d1a4
...@@ -176,7 +176,6 @@ will be our future approach after we teach NEO about object deduplication. ...@@ -176,7 +176,6 @@ will be our future approach after we teach NEO about object deduplication.
from wendelin.bigfile import WRITEOUT_STORE, WRITEOUT_MARKSTORED from wendelin.bigfile import WRITEOUT_STORE, WRITEOUT_MARKSTORED
from wendelin import wcfs
from wendelin.bigfile._file_zodb import _ZBigFile from wendelin.bigfile._file_zodb import _ZBigFile
from wendelin.lib.mem import bzero, memcpy from wendelin.lib.mem import bzero, memcpy
from wendelin.lib.zodb import LivePersistent, deactivate_btree, zconn_at from wendelin.lib.zodb import LivePersistent, deactivate_btree, zconn_at
......
...@@ -23,7 +23,7 @@ sysread(/head/watch) is unblocked and canceled when kernel asks WCFS to cancel ...@@ -23,7 +23,7 @@ sysread(/head/watch) is unblocked and canceled when kernel asks WCFS to cancel
that read request. that read request.
Without proper FUSE INTERRUPT handling on WCFS side, such reads are not Without proper FUSE INTERRUPT handling on WCFS side, such reads are not
cancelled, which results in processes that were abort or even kill-9`ed being cancelled, which results in processes that were aborted or even kill-9`ed being
stuck forever waiting for WCFS to release them. stuck forever waiting for WCFS to release them.
""" """
...@@ -36,7 +36,6 @@ import os, sys ...@@ -36,7 +36,6 @@ import os, sys
def main(): def main():
wcfs_root = sys.argv[1] wcfs_root = sys.argv[1]
#print("\n\n\n --------\n\n\n")
f = open("%s/head/watch" % wcfs_root) f = open("%s/head/watch" % wcfs_root)
wg = sync.WorkGroup(context.background()) wg = sync.WorkGroup(context.background())
def _(ctx): def _(ctx):
......
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