← Back to branch summary

~verterok/ubuntuone-client/fix-435137

« back to all changes in this revision

Viewing changes to tests/syncdaemon/test_eventsnanny.py

  • Committer: Tarmac
  • Author(s): facundo at com
  • Date: 2009-10-01 18:21:35 UTC
  • mfrom: (225.3.3 move-over-conflict)
  • Revision ID: john.lenton@canonical.com-20091001182135-r37pyh7fsrll4wdy
This allows fix the .conflict file moving it over the old one (or rename it to no conflict).

Show diffs side-by-side

added added

removed removed

Lines of Context:
tests/syncdaemon/test_eventsnanny.py
447
447
        d.callback(None)
448
448
        return d
449
449
 
450
 
 
 
450
    def test_create_discards(self):
 
451
        '''The block and open count is discarded when file created.'''
 
452
        self.eq.push("FS_FILE_OPEN", self.tf)
 
453
        self.eq.push("AQ_DOWNLOAD_COMMIT", "", "nodeid", "s_hash")
 
454
 
 
455
        def check1(_):
 
456
            self.assertEqual(self.listener.events(), [
 
457
                        ("FS_FILE_OPEN", self.tf),
 
458
                        ("AQ_DOWNLOAD_COMMIT", "", "nodeid", "s_hash"),
 
459
            ])
 
460
            self.assertTrue(self.tf in self.nanny._blocked)
 
461
            self.assertEqual(self.nanny._opened[self.tf], 1)
 
462
 
 
463
        def check2(_):
 
464
            self.assertEqual(self.listener.events(), [
 
465
                        ("FS_FILE_CREATE", self.tf),
 
466
            ])
 
467
            self.assertFalse(self.tf in self.nanny._blocked)
 
468
            self.assertFalse(self.tf in self.nanny._opened)
 
469
 
 
470
        d = defer.Deferred()
 
471
        d.addCallback(check1)
 
472
        d.addCallback(lambda _: self.eq.push("FS_FILE_CREATE", self.tf))
 
473
        d.addCallback(check2)
 
474
        d.callback(None)
 
475
        return d
 
476
 
 
477
    def test_create_noblocked(self):
 
478
        '''Create is received, nothing was blocked.'''
 
479
        def check(_):
 
480
            self.assertEqual(self.listener.events(), [
 
481
                        ("FS_FILE_CREATE", self.tf),
 
482
            ])
 
483
 
 
484
        d = defer.Deferred()
 
485
        d.addCallback(lambda _: self.eq.push("FS_FILE_CREATE", self.tf))
 
486
        d.addCallback(check)
 
487
        d.callback(None)
 
488
        return d
451
489
 
452
490
    def test_delete_discards(self):
453
 
        '''The block is discarded when file deleted.'''
 
491
        '''The block and open count is discarded when file deleted.'''
454
492
        self.eq.push("FS_FILE_OPEN", self.tf)
455
493
        self.eq.push("AQ_DOWNLOAD_COMMIT", "", "nodeid", "s_hash")
456
494
 
460
498
                        ("AQ_DOWNLOAD_COMMIT", "", "nodeid", "s_hash"),
461
499
            ])
462
500
            self.assertTrue(self.tf in self.nanny._blocked)
 
501
            self.assertEqual(self.nanny._opened[self.tf], 1)
463
502
 
464
503
        def check2(_):
465
504
            self.assertEqual(self.listener.events(), [
466
505
                        ("FS_FILE_DELETE", self.tf),
467
506
            ])
468
507
            self.assertFalse(self.tf in self.nanny._blocked)
 
508
            self.assertFalse(self.tf in self.nanny._opened)
469
509
 
470
510
        d = defer.Deferred()
471
511
        d.addCallback(check1)