| /external/tensorflow/tensorflow/core/platform/ |
| D | env_test.cc | 58 void SetUp() override { TF_CHECK_OK(env_->CreateDir(BaseDir())); } in SetUp()
63 env_->DeleteRecursively(BaseDir(), &undeleted_files, &undeleted_dirs)); in TearDown()
66 Env* env_ = Env::Default(); member in tensorflow::DefaultEnvTest
71 const string input = CreateTestFile(env_, filename, 2); in TEST_F()
73 TF_EXPECT_OK(env_->NewRandomAccessFile(filename, &f)); in TEST_F()
92 const string input = CreateTestFile(env_, filename, length); in TEST_F()
96 TF_EXPECT_OK(ReadFileToString(env_, filename, &output)); in TEST_F()
102 TF_EXPECT_OK(env_->Stat(filename, &stat)); in TEST_F()
113 TF_EXPECT_OK(WriteBinaryProto(env_, filename, proto)); in TEST_F()
117 TF_EXPECT_OK(ReadBinaryProto(env_, filename, &result)); in TEST_F()
[all …]
|
| /external/libmojo/base/android/ |
| D | scoped_java_ref.h | 33 JNIEnv* env_;
149 ScopedJavaLocalRef() : env_(nullptr) {} in ScopedJavaLocalRef()
150 ScopedJavaLocalRef(std::nullptr_t) : env_(nullptr) {} in ScopedJavaLocalRef()
155 : env_(other.env_) { in ScopedJavaLocalRef()
156 this->SetNewLocalRef(env_, other.obj()); in ScopedJavaLocalRef()
159 ScopedJavaLocalRef(ScopedJavaLocalRef<T>&& other) : env_(other.env_) { in ScopedJavaLocalRef()
163 explicit ScopedJavaLocalRef(const JavaRef<T>& other) : env_(nullptr) { in ScopedJavaLocalRef()
171 ScopedJavaLocalRef(JNIEnv* env, T obj) : JavaRef<T>(env, obj), env_(env) {} in ScopedJavaLocalRef()
184 env_ = other.env_;
189 this->ResetLocalRef(env_); in Reset()
[all …]
|
| D | scoped_java_ref.cc | 18 ScopedJavaLocalFrame::ScopedJavaLocalFrame(JNIEnv* env) : env_(env) { in ScopedJavaLocalFrame()
19 int failed = env_->PushLocalFrame(kDefaultLocalFrameCapacity); in ScopedJavaLocalFrame()
24 : env_(env) { in ScopedJavaLocalFrame()
25 int failed = env_->PushLocalFrame(capacity); in ScopedJavaLocalFrame()
30 env_->PopLocalFrame(nullptr); in ~ScopedJavaLocalFrame()
|
| /external/libtextclassifier/util/java/ |
| D | scoped_local_ref.h | 31 LocalRefDeleter() : env_(nullptr) {} in LocalRefDeleter()
35 LocalRefDeleter(JNIEnv* env) : env_(env) {} // NOLINT(runtime/explicit) in LocalRefDeleter()
43 TC_CHECK_EQ(env_, rhs.env_);
49 if (env_) { in operator()
50 env_->DeleteLocalRef(object); in operator()
56 JNIEnv* const env_;
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | master.cc | 64 : env_(env), in Master()
73 gc_thread_ = env_->env->StartThread(ThreadOptions(), "TF_master_GC", in Master()
155 : env_(env), worker_cache_(worker_cache) { in DeviceFinder()
202 NewRemoteDevices(env_->env, worker_cache_, targets_[i], in Start()
249 const MasterEnv* env_; member in tensorflow::DeviceFinder
354 if (env_->local_devices[0]->parsed_name().job == job.name() && in CreateSession()
355 env_->local_devices[0]->parsed_name().task == task.first) { in CreateSession()
371 status = env_->worker_cache_factory(worker_cache_factory_options, in CreateSession()
378 DeviceFinder::GetRemoteDevices(req->config().device_filters(), env_, in CreateSession()
392 worker_cache = env_->worker_cache; in CreateSession()
[all …]
|
| D | worker.cc | 29 : env_(env), cancellation_manager_(new CancellationManager) {} in Worker()
33 DeviceMgr* dm = env_->device_mgr; in GetStatusAsync()
46 Status s = env_->session_mgr->CreateSession(request->session_handle(), in CreateWorkerSessionAsync()
55 Status s = env_->session_mgr->DeleteSession(request->session_handle()); in DeleteWorkerSessionAsync()
63 env_->session_mgr->WorkerSessionForSession(request->session_handle()); in RegisterGraphAsync()
75 env_->session_mgr->WorkerSessionForSession(request->session_handle()); in DeregisterGraphAsync()
82 Rendezvous* rendez = env_->rendezvous_mgr->Find(step_id); in AbortStep()
139 env_->session_mgr->WorkerSessionForSession(request->session_handle()); in DoRunGraph()
213 env_->session_mgr->WorkerSessionForSession(request->session_handle()); in DoPartialRunGraph()
288 env_->rendezvous_mgr->Cleanup(step_id); in CleanupGraphAsync()
[all …]
|
| /external/tensorflow/tensorflow/contrib/tensorboard/db/ |
| D | summary_db_writer_test.cc | 98 FakeClockEnv env_; member in tensorflow::__anonf957877b0111::SummaryDbWriterTest
104 TF_ASSERT_OK(CreateSummaryDbWriter(db_, "mad-science", "train", "jart", &env_, in TEST_F()
128 TF_ASSERT_OK(CreateSummaryDbWriter(db_, "mad-science", "train", "jart", &env_, in TEST_F()
130 env_.AdvanceByMillis(23); in TEST_F()
133 env_.AdvanceByMillis(23); in TEST_F()
184 TF_ASSERT_OK(CreateSummaryDbWriter(db_, "", "", "", &env_, &writer_)); in TEST_F()
195 TF_ASSERT_OK(CreateSummaryDbWriter(db_, "", "", "", &env_, &writer_)); in TEST_F()
222 TF_ASSERT_OK(CreateSummaryDbWriter(db_, "", "R", "", &env_, &writer_)); in TEST_F()
223 env_.AdvanceByMillis(23); in TEST_F()
306 TF_ASSERT_OK(CreateSummaryDbWriter(db_, "mad-science", "train", "jart", &env_, in TEST_F()
[all …]
|
| D | summary_file_writer.cc | 37 env_(env) {} in SummaryFileWriter()
40 const Status is_dir = env_->IsDirectory(logdir); in Initialize()
45 TF_RETURN_IF_ERROR(env_->RecursivelyCreateDir(logdir)); in Initialize()
53 last_flush_ = env_->NowMicros(); in Initialize()
136 env_->NowMicros() - last_flush_ > 1000 * flush_millis_) { in WriteEvent()
146 return static_cast<double>(env_->NowMicros()) / 1.0e6; in GetWallTime()
156 last_flush_ = env_->NowMicros(); in InternalFlush()
164 Env* env_; member in tensorflow::__anon0faf26760111::SummaryFileWriter
|
| D | summary_file_writer_test.cc | 51 &env_, &writer)); in SummaryTestHelper()
58 TF_CHECK_OK(env_.GetChildren(testing::TmpDir(), &files)); in SummaryTestHelper()
67 TF_CHECK_OK(env_.NewRandomAccessFile(io::JoinPath(testing::TmpDir(), f), in SummaryTestHelper()
87 FakeClockEnv env_; member in tensorflow::__anon4e9b28150111::SummaryFileWriterTest
202 env_.AdvanceByMillis(7023); in TEST_F()
|
| /external/tensorflow/tensorflow/core/debug/ |
| D | debug_io_utils_test.cc | 39 env_ = Env::Default(); in Initialize()
52 Env* env_; member in tensorflow::__anon86e7c9410111::DebugIOUtilsTest
110 const uint64 wall_time = env_->NowMicros(); in TEST_F()
140 env_->DeleteRecursively(test_dir, &undeleted_files, &undeleted_dirs) in TEST_F()
153 const uint64 wall_time = env_->NowMicros(); in TEST_F()
191 env_->DeleteRecursively(test_dir, &undeleted_files, &undeleted_dirs) in TEST_F()
208 if (!env_->FileExists(txt_file_dir).ok()) { in TEST_F()
209 ASSERT_TRUE(env_->RecursivelyCreateDir(txt_file_dir).ok()); in TEST_F()
211 ASSERT_EQ(error::Code::NOT_FOUND, env_->FileExists(txt_file_name).code()); in TEST_F()
214 ASSERT_TRUE(env_->NewWritableFile(txt_file_name, &file).ok()); in TEST_F()
[all …]
|
| /external/pdfium/testing/ |
| D | unit_test_main.cpp | 44 Environment* env_ = nullptr; variable
49 return env_->FontManager(); in GetGlobalFontManager()
59 env_ = new Environment(); in main()
61 AddGlobalTestEnvironment(env_); in main()
|
| D | embedder_test_main.cpp | 64 Environment* env_ = nullptr; variable
75 env_ = new Environment(); in main()
77 AddGlobalTestEnvironment(env_); in main()
|
| /external/tensorflow/tensorflow/core/grappler/inputs/ |
| D | utils_test.cc | 30 TF_CHECK_OK(env_->CreateDir(BaseDir())); in SetUp()
33 TF_CHECK_OK(WriteStringToFile(env_, actual_file_, "Some test data")); in SetUp()
39 env_->DeleteRecursively(BaseDir(), &undeleted_files, &undeleted_dirs)); in TearDown()
44 Env* env_ = Env::Default(); member in tensorflow::grappler::__anonf190f0cc0111::UtilsTest
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | cache_dataset_ops.cc | 54 env_(env), in FileDataset()
69 if (env_->FileExists(strings::StrCat(filename_, ".index")).ok()) { in MakeIterator()
110 writer_(params.dataset->env_, params.dataset->filename_), in FileWriterIterator()
166 if (dataset()->env_->FileExists(lockfile_).ok()) { in EnsureLockFileExists()
171 if (dataset()->env_->NewRandomAccessFile(lockfile_, &file).ok()) { in EnsureLockFileExists()
186 dataset()->env_->NewWritableFile(lockfile_, &lockfile)); in EnsureLockFileExists()
188 strings::StrCat("Created at: ", dataset()->env_->NowSeconds()))); in EnsureLockFileExists()
197 TF_RETURN_IF_ERROR(dataset()->env_->DeleteFile(lockfile_)); in Finish()
215 reader_(dataset()->env_, dataset()->filename_) {} in FileReaderIterator()
255 Env* const env_; member in tensorflow::__anon785ee0740111::CacheDatasetOp::FileDataset
|
| /external/webrtc/webrtc/modules/utility/source/ |
| D | helpers_android.cc | 99 : attached_(false), jvm_(jvm), env_(NULL) { in AttachThreadScoped()
100 env_ = GetEnv(jvm); in AttachThreadScoped()
101 if (!env_) { in AttachThreadScoped()
106 jint res = jvm->AttachCurrentThread(&env_, NULL); in AttachThreadScoped()
121 JNIEnv* AttachThreadScoped::env() { return env_; } in env()
|
| /external/conscrypt/common/src/jni/unbundled/include/nativehelper/ |
| D | ScopedUtfChars.h | 34 ScopedUtfChars(JNIEnv* env, jstring s) : env_(env), string_(s) { in ScopedUtfChars()
45 env_->ReleaseStringUTFChars(string_, utf_chars_); in ~ScopedUtfChars()
62 JNIEnv* env_;
|
| /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| D | NonBlockingThreadPool.h | 23 : env_(env), in env_() function
58 threads_.push_back(env_.CreateThread([this, i]() { WorkerLoop(i); })); in env_()
75 Task t = env_.CreateTask(std::move(fn)); in Schedule()
97 env_.ExecuteTask(t); // Push failed, execute directly. in Schedule()
124 Environment env_; variable
167 env_.ExecuteTask(t); in WorkerLoop()
|
| D | SimpleThreadPool.h | 25 : env_(env), threads_(num_threads), waiters_(num_threads) { in env_() function
59 Task t = env_.CreateTask(std::move(fn)); in Schedule()
113 env_.ExecuteTask(t); in WorkerLoop()
136 Environment env_; variable
|
| /external/tensorflow/tensorflow/core/util/ |
| D | events_writer.cc | 35 : env_(Env::Default()), in EventsWriter()
65 int64 time_in_seconds = env_->NowMicros() / 1000000; in InitIfNeeded()
73 env_->NewWritableFile(filename_, &recordio_file_), in InitIfNeeded()
159 if (env_->FileExists(filename_).ok()) { in FileStillExists()
|
| /external/tensorflow/tensorflow/core/platform/cloud/ |
| D | expiring_lru_cache.h | 42 : max_age_(max_age), max_entries_(max_entries), env_(env) {} in max_age_()
120 if (env_->NowSeconds() - it->second.timestamp > max_age_) { in LookupLocked()
133 Entry entry{env_->NowSeconds(), value, lru_list_.begin()}; in InsertLocked()
153 Env* const env_; // not owned variable
|
| D | file_block_cache.h | 57 env_(env) { in block_size_()
59 pruning_thread_.reset(env_->StartThread(ThreadOptions(), "TF_prune_FBC", in block_size_()
115 Env* const env_; // not owned variable
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | tf_record_reader_op.cc | 33 env_(env), in TFRecordReader()
39 TF_RETURN_IF_ERROR(env_->NewRandomAccessFile(current_work(), &file_)); in OnWorkStartedLocked()
76 Env* const env_; member in tensorflow::TFRecordReader
|
| D | text_line_reader_op.cc | 33 env_(env), in TextLineReader()
38 TF_RETURN_IF_ERROR(env_->NewRandomAccessFile(current_work(), &file_)); in OnWorkStartedLocked()
89 Env* const env_; member in tensorflow::TextLineReader
|
| /external/tensorflow/tensorflow/core/lib/monitoring/ |
| D | collection_registry.cc | 65 CollectionRegistry::CollectionRegistry(Env* const env) : env_(env) {} in CollectionRegistry()
82 {metric_def, collection_function, env_->NowMicros() / 1000}}); in Register()
95 internal::Collector collector(env_->NowMicros() / 1000); in CollectMetrics()
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | allocator_retry.cc | 24 AllocatorRetry::AllocatorRetry() : env_(Env::Default()) {} in AllocatorRetry()
41 uint64 now = env_->NowMicros(); in AllocateRaw()
|