summaryrefslogtreecommitdiff
path: root/test/git/odb/test_channel.py
diff options
context:
space:
mode:
Diffstat (limited to 'test/git/odb/test_channel.py')
-rw-r--r--test/git/odb/test_channel.py61
1 files changed, 0 insertions, 61 deletions
diff --git a/test/git/odb/test_channel.py b/test/git/odb/test_channel.py
deleted file mode 100644
index d845a6ec..00000000
--- a/test/git/odb/test_channel.py
+++ /dev/null
@@ -1,61 +0,0 @@
-"""Channel testing"""
-from test.testlib import *
-from git.odb.channel import *
-
-import time
-
-class TestChannels(TestBase):
-
- def test_base(self):
- # creating channel yields a write and a read channal
- wc, rc = Channel()
- assert isinstance(wc, WChannel)
- assert isinstance(rc, RChannel)
-
- # everything else fails
- self.failUnlessRaises(ValueError, Channel, 1, "too many args")
-
- # TEST UNLIMITED SIZE CHANNEL - writing+reading is FIFO
- item = 1
- item2 = 2
- wc.write(item)
- wc.write(item2)
- assert rc.read() == item
- assert rc.read() == item2
-
- # next read blocks, then raises - it waits a second
- st = time.time()
- self.failUnlessRaises(IOError, rc.read, True, 1)
- assert time.time() - st >= 1.0
-
- # writing to a closed channel raises
- assert not wc.closed
- wc.close()
- assert wc.closed
- wc.close() # fine
- assert wc.closed
-
- self.failUnlessRaises(IOError, wc.write, 1)
-
- # reading from a closed channel never blocks
- self.failUnlessRaises(IOError, rc.read)
-
-
-
- # TEST LIMITED SIZE CHANNEL
- # channel with max-items set
- wc, rc = Channel(1)
- wc.write(item) # fine
-
- # blocks for a second, its full
- st = time.time()
- self.failUnlessRaises(IOError, wc.write, item, True, 1)
- assert time.time() - st >= 1.0
-
- # get one
- assert rc.read() == item
-
- # its empty,can put one again
- wc.write(item2)
- assert rc.read() == item2
- wc.close()