/external/grpc-grpc/src/ruby/pb/grpc/health/ |
checker.rb | 28 # Initializes the statuses of participating services 30 @statuses = {} 31 @status_mutex = Mutex.new # guards access to @statuses 38 status = @statuses["#{req.service}"] 48 @status_mutex.synchronize { @statuses["#{service}"] = status } 54 services.each { |service| @statuses["#{service}"] = status } 61 service_statuses.each_pair { |service, status| @statuses["#{service}"] = status } 67 @status_mutex.synchronize { @statuses.delete("#{service}") } 70 # Clears alls the statuses. 72 @status_mutex.synchronize { @statuses = {} [all...] |
/external/autotest/tko/ |
status_lib.py | 6 statuses = log.job_statuses variable 10 """ Compare two statuses and return a boolean indicating if the LHS status 12 return (statuses.index(lhs) < statuses.index(rhs)) 16 """ Compare two statuses and return a boolean indicating if the LHS status 31 self.status_stack = [statuses[-1]] 39 if new_status not in statuses: 46 self.status_stack.append(statuses[-1]) 52 self.status_stack.append(statuses[-1])
|
status_lib_unittest.py | 104 statuses = log.job_statuses variable in class:status_stack_test 129 for status in self.statuses: 136 for i in xrange(len(self.statuses)): 137 worse_status = self.statuses[i] 138 for j in xrange(i + 1, len(self.statuses)): 140 better_status = self.statuses[j] 148 for i in xrange(len(self.statuses)): 149 better_status = self.statuses[i] 152 worse_status = self.statuses[j]
|
/external/tensorflow/tensorflow/core/common_runtime/ |
collective_param_resolver_local_test.cc | 159 Status statuses[NUM_DEVS]; local 175 Env::Default()->SchedClosure([this, i, cp, ¬e, &statuses]() { 178 [&statuses, ¬e, i](const Status& s) { 179 statuses[i] = s; 188 TF_ASSERT_OK(statuses[i]); 223 Status statuses[NUM_DEVS]; local 228 Env::Default()->SchedClosure([this, i, cp, ¬e, &statuses]() { 231 [&statuses, ¬e, i](const Status& s) { 232 statuses[i] = s; 241 TF_ASSERT_OK(statuses[i]) 261 Status statuses[NUM_DEVS]; local [all...] |
/external/autotest/server/cros/dynamic_suite/ |
job_status_unittest.py | 48 entries = [s.entry for s in job.statuses] 53 job.statuses) 75 for status in jobs[4].statuses: 98 for status in job.statuses: 111 for status in job.statuses: 119 expected_name = '%s_%s' % (job_name, job.statuses[i].test_name) 122 expected_name = job.statuses[i].test_name 123 expected_subdir = os.path.join(job_tag, job.statuses[i].subdir) 135 statuses = {} 147 statuses[hostname] = statu [all...] |
fakes.py | 38 def __init__(self, id=0, statuses=[], hostnames=[], parent_job_id=None): 43 self.statuses = statuses
|
job_status.py | 129 @yields an iterator of Statuses, one per test. 157 @yields an iterator of Statuses, one per test. 167 # job_tag, this query will return no results. When statuses is not 170 statuses = tko.get_job_test_statuses_from_db(job.id) 171 if not statuses: 177 for s in statuses) 178 for s in statuses: 323 # else, if the statuses are the same...
|
/external/chromium-trace/catapult/devil/devil/android/tools/ |
device_status.py | 159 statuses = parallel_devices.pMap(blacklisting_device_status).pGet(None) 160 return statuses 163 def _LogStatuses(statuses): 165 for status in statuses: 185 def _WriteBuildbotFile(file_path, statuses): 189 for status in statuses: 265 statuses = DeviceStatus(devices, blacklist) 268 _LogStatuses(statuses) 274 path, [status['serial'] for status in statuses]) 277 _WriteBuildbotFile(args.buildbot_path, statuses) [all...] |
device_recovery.py | 130 statuses = device_status.DeviceStatus(devices, blacklist) 133 status['serial'] for status in statuses 137 status['serial'] for status in statuses 140 status['serial'] for status in statuses
|
/external/autotest/venv/skylab_suite/ |
tko_test_views.py | 114 statuses = _get_status_map(conn) 125 Row(name, statuses.get(s_idx, 'UNKNOWN'), reason)) 184 statuses = {} 189 statuses[idx] = word 190 return statuses
|
/external/autotest/server/lib/ |
suite_report.py | 21 # TODO: Handle other statuses like infra failures. 81 def find_start_finish_times(statuses): 82 """Determines the start and finish times for a list of statuses. 84 @param statuses: A list of job test statuses. 90 for s in statuses if s.test_started_time != 'None'} 92 for s in statuses if s.test_finished_time != 'None'} 109 statuses = tko.get_job_test_statuses_from_db(job.id) 112 for s in statuses: 121 start_time, finish_time = find_start_finish_times(statuses) [all...] |
/external/autotest/contrib/ |
find_suite_tasks.py | 56 statuses = tko.get_job_test_statuses_from_db(suite_job_id) 57 if len(statuses): 58 for s in statuses: 66 for s in statuses if s.test_started_time != 'None') 68 s.test_finished_time)) for s in statuses
|
always_failing_tests.py | 45 statuses = {s.status_idx: s.word for s in tko_models.Status.objects.all()} 61 word = statuses[t.status_id]
|
/external/skia/tools/skdiff/ |
skdiff.cpp | 98 bool DiffResource::getMatchingStatuses(char* selector, bool statuses[kStatusCount]) { 101 statuses[statusIndex] = true; 107 statuses[statusIndex] = false; 122 statuses[statusIndex] |= isStatusFailed(status); 129 statuses[status] = true;
|
/external/skqp/tools/skdiff/ |
skdiff.cpp | 98 bool DiffResource::getMatchingStatuses(char* selector, bool statuses[kStatusCount]) { 101 statuses[statusIndex] = true; 107 statuses[statusIndex] = false; 122 statuses[statusIndex] |= isStatusFailed(status); 129 statuses[status] = true;
|
/external/grpc-grpc/tools/github/ |
pr_latency.py | 114 status_url = statuses_url.replace('statuses', 'status') 115 statuses = json.loads(gh(status_url + '?per_page=100')) 120 if not statuses: return None 123 for status in statuses['statuses']:
|
/external/autotest/frontend/client/src/autotest/afe/ |
HostTableDecorator.java | 50 JSONArray statuses = staticData.getData("host_statuses").isArray(); local 51 String[] statusStrings = Utils.JSONtoStrings(statuses);
|
/external/testng/src/main/java/org/testng/reporters/jq/ |
SuitePanel.java | 30 String[] statuses = new String[] { FAILED, SKIPPED, PASSED }; local 40 generateClassPanel(c, byClass.getResults(c), xsb, statuses[i], suite);
|
/external/autotest/tko/parsers/ |
version_0_unittest.py | 136 statuses = ["GOOD", "WARN", "FAIL", "ABORT"] variable in class:test_status_line 153 for stat in self.statuses: 161 for stat in self.statuses: 169 for stat in self.statuses:
|
version_1_unittest.py | 13 statuses = ['GOOD', 'WARN', 'FAIL', 'ABORT'] variable in class:test_status_line 34 for stat in self.statuses: 43 for stat in self.statuses: 52 for stat in self.statuses: 154 """Tests good reboot statuses.""" 162 """Tests bad reboot statuses."""
|
/cts/tests/tests/net/src/android/net/wifi/rtt/cts/ |
WifiRttTest.java | 79 int[] statuses = new int[NUM_OF_RTT_ITERATIONS]; local 108 statuses[i] = status; 147 reportLog.addValues("status_codes", statuses, ResultType.NEUTRAL, ResultUnit.NONE);
|
/external/autotest/client/cros/update_engine/ |
update_engine_util.py | 29 # Update engine statuses. 144 statuses = [self._UPDATE_STATUS_UPDATED_NEED_REBOOT] 146 statuses.append(self._UPDATE_ENGINE_FINALIZING) 162 if any(arg in status[self._CURRENT_OP] for arg in statuses):
|
/external/grpc-grpc/test/cpp/qps/ |
client.h | 153 StatusHistogram statuses; local 171 MergeStatusHistogram(to_merge_status[i], &statuses); 178 threads_[i]->MergeStatsInto(&latencies, &statuses); 201 for (StatusHistogram::const_iterator it = statuses.begin(); 202 it != statuses.end(); ++it) {
|
/frameworks/av/camera/tests/ |
CameraBinderTests.cpp | 326 std::vector<hardware::CameraStatus> statuses; local 327 res = service->addListener(listener, &statuses); 330 EXPECT_EQ(numCameras, static_cast<const int>(statuses.size())); 331 for (const auto &it : statuses) { 436 std::vector<hardware::CameraStatus> statuses; local 437 service->addListener(serviceListener, &statuses); 438 for (const auto &it : statuses) {
|
/external/autotest/venv/lucifer/ |
handlers.py | 339 statuses = list(models.HostQueueEntry.PRE_JOB_STATUSES) 341 statuses = list(models.HostQueueEntry.IDLE_PRE_JOB_STATUSES) 343 job=job, status__in=statuses)
|