Lines Matching refs:shard1
119 def _testShardHeartbeatLabelRemovalRaceHelper(self, shard1, host1, label1): argument
128 rpc_interface.remove_board_from_shard(shard1.hostname, label1.name)
140 def _testShardRetrieveJobsHelper(self, shard1, host1, label1, shard2, argument
177 def _testResendJobsAfterFailedHeartbeatHelper(self, shard1, host1, label1): argument
228 rpc_interface.delete_shard(hostname=shard1.hostname)
231 models.Shard.DoesNotExist, models.Shard.objects.get, pk=shard1.id)
422 shard1 = models.Shard.objects.create(hostname='shard1')
423 host2.shard = shard1
443 shard1 = models.Shard.objects.create(hostname='shard1')
444 host2.shard = shard1
566 shard1 = models.Shard.smart_get(shard.id)
568 self.assertItemsEqual(shard1.labels.all(), [])
658 shard1, host1, label1 = self._createShardAndHostWithStaticLabel(
664 shard1, host1, label1 = self._createShardAndHostWithStaticLabel(
670 shard1, host1, label1 = self._createShardAndHostWithStaticLabel(
672 self._testShardHeartbeatLabelRemovalRaceHelper(shard1, host1, label1)
676 shard1, host1, label1 = self._createShardAndHostWithStaticLabel()
679 self._testShardRetrieveJobsHelper(shard1, host1, label1,
684 shard1, host1, label1 = self._createShardAndHostWithStaticLabel()
685 self._testResendJobsAfterFailedHeartbeatHelper(shard1, host1, label1)
689 shard1, host1, label1 = self._createShardAndHostWithStaticLabel(
1201 shard1 = models.Shard.objects.create(hostname='shard1')
1202 host1.shard = shard1
1225 host_filter_data={'id__in': [shard1.id, shard2.id]},
1234 host_filter_data={'id__in': [shard1.id, shard2.id]},
1255 shard1 = models.Shard.objects.create(hostname='shard1')
1256 host1.shard = shard1
1279 shard1 = models.Shard.objects.create(hostname='shard1')
1280 host1.shard = shard1
1283 rpc_interface.delete_shard(hostname=shard1.hostname)
1288 models.Shard.smart_get, shard1.hostname)
1296 shard1 = models.Shard.objects.create(hostname='shard1')
1297 host2.shard = shard1
1319 shard1 = models.Shard.objects.create(hostname='shard1')
1320 host2.shard = shard1
1713 shard1 = models.Shard.objects.create(hostname='shard1')
1715 job1 = self._create_job(shard=shard1, control_file='foo1')
1782 shard1, host1, lumpy_label = self._createShardAndHostWithLabel()
1787 shard1.hostname, stumpy_label.name)
1792 shard1, host1, lumpy_label = self._createShardAndHostWithLabel()
1794 self.assertEqual(host1.shard, shard1)
1795 self.assertItemsEqual(shard1.labels.all(), [lumpy_label])
1797 shard1.hostname, lumpy_label.name)
1799 shard1 = models.Shard.smart_get(shard1.id)
1801 self.assertItemsEqual(shard1.labels.all(), [])
1834 shard1, host1, lumpy_label = self._createShardAndHostWithLabel()
1859 shard1, host1, label1 = self._createShardAndHostWithLabel()
1864 shard1, host1, label1 = self._createShardAndHostWithLabel()
1869 shard1, host1, label1 = self._createShardAndHostWithLabel()
1870 self._testShardHeartbeatLabelRemovalRaceHelper(shard1, host1, label1)
1874 shard1, host1, label1 = self._createShardAndHostWithLabel()
1877 self._testShardRetrieveJobsHelper(shard1, host1, label1,
1882 shard1, host1, label1 = self._createShardAndHostWithLabel()
1883 self._testResendJobsAfterFailedHeartbeatHelper(shard1, host1, label1)
1887 shard1, host1, label1 = self._createShardAndHostWithLabel()