| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
- Now the the node monitor waits for all shards of the file,
which was modified on a remote computer, to arrive on this
computer, before it re-constructs the file into the respective
location in the combox directory.
- Tests for it is at
tests.events_test.TestEvents.test_NDM_onmodified method.
modified: combox/events.py
modified: tests/events_test.py
Part of this was done while listening to Avril's "Complicated" ; I
think this is the only modern Pop song which I like.
|
|
|
|
|
|
|
| |
this computer, its info is removed from the 'file_created' dictionary in the silo.
modified: combox/events.py
modified: tests/events_test.py
|
|
|
|
|
|
|
|
|
|
|
| |
The method removes information about a file in the category `type_'
where `type_' can be 'file_created', 'file_modified', 'file_removed',
'file_moved'.
Also wrote tests for it :~(
modified: combox/silo.py
modified: tests/silo_test.py
|
|
|
|
| |
modified: tests/events_test.py
|
|
|
|
|
|
| |
tests.events_test.TestEvents.test_NDM_oncreated.
modified: tests/events_test.py
|
|
|
|
|
|
| |
tests.event_test.TestEvents.
modified: tests/events_test.py
|
| |
|
|
|
|
|
|
| |
the silo is purged using the deldb method instead of doing a os.remove.
modfied: tests/events_test.py
|
| |
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
- Now the the node monitor waits for all shards of the file, which
was created on a remote computer, to arrive on this computer, before
it re-constructs the file into the respective location in the combox
directory.
- Tests for it is at tests.events_test.TestEvents.test_NDM_oncreate
method.
- The main test method, tests.events_test.TestEvents.test_NDM, was
disabled by renaming it to tests.events_test.TestEvents.test_NDM.
- Now the NodeDirMonitor requires passing the 'node monitor lock' when
creating an instance of it.
:~(
modified: combox/events.py
modified: tests/events_test.py
|
| |
|
|
|
|
|
|
|
|
|
| |
This method now returns relative paths w. r. t all node directories. Before it used to return relative paths only w. r. t the first node directory.
Also updated the tests for it :~(
modified: combox/file.py
modified: tests/file_test.py
|
|
|
|
|
|
|
| |
`num_nodes' a value that represents the number of node directories.
modified: combox/events.py
modified: tests/events_test.py
|
|
|
|
|
|
|
|
| |
The main zarking reason for the name is that we might also want to
track directories apart from shards in the node directories.
modified: combox/silo.py
modified: tests/silo_test.py
|
| |
|
|
|
|
|
| |
modified: combox/events.py
modified: combox/silo.py
|
| |
|
| |
|
|
|
|
|
|
|
|
| |
modified: combox/cbox.py
modified: combox/events.py
modified: combox/silo.py
modified: tests/events_test.py
modified: tests/silo_test.py
|
| |
|
|
|
|
|
|
|
|
| |
These methods will be used to manage the dictionaries in the db
related to the zarking shards.
modified: combox/silo.py
modified: tests/silo_test.py
|
|
|
|
|
|
|
| |
the shards.
modified: combox/events.py
modified: combox/silo.py
|
| |
|
| |
|
| |
|
|
|
|
|
|
|
| |
wrote tests for it too :~(
modified: combox/events.py
modified: tests/events_test.py
|
| |
|
|
|
|
|
|
|
| |
shards/directories in node directories.
modified: combox/file.py
modified: tests/file_test.py
|
| |
|
|
|
|
|
|
|
|
| |
a function.
modified: tests/events_test.py
modified: tests/file_test.py
modified: tests/utils.py
|
| |
|
|
|
|
|
|
|
| |
This just means, only one damn Thread is allowed to access the DB at a
time.
We are using thread.Lock to achieve this.
|
| |
|
|
|
|
|
|
|
| |
As usual, wrote correponding tests for it; zarking TDD or whatever :~|
modified: combox/events.py
modified: tests/events_test.py
|
|
|
|
| |
test method.
|
|
|
|
|
| |
The statement that removes the key from db is now put in a try-catch
f#*king block.
|
| |
|
|
|
|
|
|
|
| |
Now they check if the event.src_path is a shard or a directory before
doing anything.
modified: combox/events.py
|
|
|
|
|
| |
modified: combox/events.py
modified: tests/events_test.py
|
|
|
|
|
|
|
| |
Now the method deletes the corresponding file in the combox directory
only if has not already been deleted.
modified: combox/events.py
|
| |
|
|
|
|
|
|
|
| |
It now deletes the directory or file shard in the node directories
only if they were not already deleted.
modified: combox/events.py
|
|
|
|
|
|
|
|
|
|
|
| |
It has a third argument (boolean) which tells whether `cb_path' (the
first argument) is a file or not.
Updated the test for node_path function + code wherever node_path was used.
modified: combox/events.py
modified: combox/file.py
modified: tests/file_test.py
|
| |
|
| |
|
|
|
|
|
|
|
| |
As usual, wrote correponding tests for it :|
modified: combox/events.py
modified: tests/events_test.py
|
|
|
|
|
|
| |
instead of using `path.isfile' to check if the path is a shard file or
not, it is checked if the path endswidth 'shard.N' where `N' is a
number.
|