Home
last modified time | relevance | path

Searched refs:env_ (Results 1 – 25 of 90) sorted by relevance

1234

/external/tensorflow/tensorflow/core/platform/
Denv_test.cc60 void SetUp() override { TF_CHECK_OK(env_->CreateDir(BaseDir())); } in SetUp()
65 env_->DeleteRecursively(BaseDir(), &undeleted_files, &undeleted_dirs)); in TearDown()
68 Env* env_ = Env::Default(); member in tensorflow::DefaultEnvTest
73 const string input = CreateTestFile(env_, filename, 2); in TEST_F()
75 TF_EXPECT_OK(env_->NewRandomAccessFile(filename, &f)); in TEST_F()
94 const string input = CreateTestFile(env_, filename, length); in TEST_F()
98 TF_EXPECT_OK(ReadFileToString(env_, filename, &output)); in TEST_F()
104 TF_EXPECT_OK(env_->Stat(filename, &stat)); in TEST_F()
115 TF_EXPECT_OK(WriteBinaryProto(env_, filename, proto)); in TEST_F()
119 TF_EXPECT_OK(ReadBinaryProto(env_, filename, &result)); in TEST_F()
[all …]
/external/libchrome/base/android/
Dscoped_java_ref.h33 JNIEnv* env_;
149 constexpr ScopedJavaLocalRef() : env_(nullptr) {} in ScopedJavaLocalRef()
150 constexpr 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 …]
Dscoped_java_ref.cc18 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/tensorflow/tensorflow/core/distributed_runtime/
Dworker.cc31 Worker::Worker(WorkerEnv* env) : env_(env) {} in Worker()
35 DeviceMgr* dm = env_->device_mgr; in GetStatusAsync()
48 Status s = env_->session_mgr->CreateSession(request->session_handle(), in CreateWorkerSessionAsync()
58 Status s = env_->session_mgr->DeleteSession(request->session_handle()); in DeleteWorkerSessionAsync()
68 s = env_->session_mgr->WorkerSessionForSession(request->session_handle(), in RegisterGraphAsync()
71 session = env_->session_mgr->LegacySession(); in RegisterGraphAsync()
89 s = env_->session_mgr->WorkerSessionForSession(request->session_handle(), in DeregisterGraphAsync()
92 session = env_->session_mgr->LegacySession(); in DeregisterGraphAsync()
102 Rendezvous* rendez = env_->rendezvous_mgr->Find(step_id); in AbortStep()
162 s = env_->session_mgr->WorkerSessionForSession(request->session_handle(), in DoRunGraph()
[all …]
Dmaster.cc65 : env_(env), in Master()
75 gc_thread_ = env_->env->StartThread(ThreadOptions(), "TF_master_GC", in Master()
157 : env_(env), worker_cache_(worker_cache) { in DeviceFinder()
181 CHECK_GT(env_->local_devices.size(), 0) << "No local devices provided."; in DeviceFinder()
182 const string& local_device_name = env_->local_devices[0]->name(); in DeviceFinder()
249 NewRemoteDevices(env_->env, worker_cache_, targets_[i], in Start()
296 const MasterEnv* env_; member in tensorflow::DeviceFinder
402 if (env_->local_devices[0]->parsed_name().job == job.name() && in CreateSession()
403 env_->local_devices[0]->parsed_name().task == task.first) { in CreateSession()
419 status = env_->worker_cache_factory(worker_cache_factory_options, in CreateSession()
[all …]
/external/libtextclassifier/actions/
Dlua-utils.h57 : env_(env), entity_data_schema_(entity_data_schema) {} in AnnotationIterator()
60 PushAnnotation((*annotations)[pos], entity_data_schema_, env_); in Item()
67 LuaEnvironment* env_;
102 : env_(env), annotation_iterator_(annotation_iterator) {} in AnnotatedSpanIterator()
105 : env_(env), annotation_iterator_(entity_data_schema, env) {} in AnnotatedSpanIterator()
109 PushAnnotatedSpan((*spans)[pos], annotation_iterator_, env_); in Item()
114 LuaEnvironment* env_;
140 : env_(env), in ActionsIterator()
146 env_); in Item()
151 LuaEnvironment* env_;
[all …]
/external/libtextclassifier/utils/java/
Dscoped_local_ref.h31 LocalRefDeleter() : env_(nullptr) {} in LocalRefDeleter()
35 LocalRefDeleter(JNIEnv* env) : env_(env) {} // NOLINT(runtime/explicit) in LocalRefDeleter()
43 TC3_CHECK_EQ(env_, rhs.env_);
49 if (env_) { in operator()
50 env_->DeleteLocalRef(object); in operator()
56 JNIEnv* const env_;
Dstring_utils.h35 StringCharsReleaser() : env_(nullptr) {} in StringCharsReleaser()
37 StringCharsReleaser(JNIEnv* env, jstring jstr) : env_(env), jstr_(jstr) {} in StringCharsReleaser()
45 TC3_CHECK_EQ(env_, rhs.env_);
51 if (env_ != nullptr) { in operator()
52 env_->ReleaseStringUTFChars(jstr_, chars); in operator()
58 JNIEnv* const env_;
/external/tensorflow/tensorflow/core/util/
Dexec_on_stall.h43 env_(Env::Default()), in disabled_()
46 deadline_ = env_->NowMicros() + 1000000 * delay_secs; in disabled_()
47 env_->SchedClosure([this]() { in disabled_()
48 while (env_->NowMicros() < deadline_) { in disabled_()
55 env_->SleepForMicroseconds(poll_microseconds_); in disabled_()
82 Env* env_; variable
Devents_writer.cc35 : env_(Env::Default()), in EventsWriter()
65 int64 time_in_seconds = env_->NowMicros() / 1000000; in InitIfNeeded()
77 env_->NewWritableFile(filename_, &recordio_file_), in InitIfNeeded()
166 if (env_->FileExists(filename_).ok()) { in FileStillExists()
/external/tensorflow/tensorflow/core/grappler/inputs/
Dutils_test.cc30 TF_CHECK_OK(env_->CreateDir(BaseDir())); in SetUp()
33 TF_CHECK_OK(WriteStringToFile(env_, actual_file_, "Some test data")); in SetUp()
46 TF_CHECK_OK(WriteTextProto(env_, text_graph_def_file_, graph_def_)); in SetUp()
47 TF_CHECK_OK(WriteBinaryProto(env_, binary_graph_def_file_, graph_def_)); in SetUp()
50 WriteTextProto(env_, text_meta_graph_def_file_, meta_graph_def_)); in SetUp()
52 WriteBinaryProto(env_, binary_meta_graph_def_file_, meta_graph_def_)); in SetUp()
58 env_->DeleteRecursively(BaseDir(), &undeleted_files, &undeleted_dirs)); in TearDown()
69 Env* env_ = Env::Default(); member in tensorflow::grappler::__anon5e71ad6f0111::UtilsTest
/external/tensorflow/tensorflow/core/summary/
Dsummary_db_writer_test.cc98 FakeClockEnv env_; member in tensorflow::__anon7a82372c0111::SummaryDbWriterTest
104 TF_ASSERT_OK(CreateSummaryDbWriter(db_, "histtest", "test1", "user1", &env_, in TEST_F()
154 TF_ASSERT_OK(CreateSummaryDbWriter(db_, "mad-science", "train", "jart", &env_, in TEST_F()
178 TF_ASSERT_OK(CreateSummaryDbWriter(db_, "mad-science", "train", "jart", &env_, in TEST_F()
180 env_.AdvanceByMillis(23); in TEST_F()
183 env_.AdvanceByMillis(23); in TEST_F()
234 TF_ASSERT_OK(CreateSummaryDbWriter(db_, "", "", "", &env_, &writer_)); in TEST_F()
245 TF_ASSERT_OK(CreateSummaryDbWriter(db_, "", "", "", &env_, &writer_)); in TEST_F()
272 TF_ASSERT_OK(CreateSummaryDbWriter(db_, "", "R", "", &env_, &writer_)); in TEST_F()
273 env_.AdvanceByMillis(23); in TEST_F()
[all …]
Dsummary_file_writer.cc37 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()
145 env_->NowMicros() - last_flush_ > 1000 * flush_millis_) { in WriteEvent()
155 return static_cast<double>(env_->NowMicros()) / 1.0e6; in GetWallTime()
165 last_flush_ = env_->NowMicros(); in InternalFlush()
173 Env* env_; member in tensorflow::__anon5ecb8bc70111::SummaryFileWriter
/external/tensorflow/tensorflow/core/debug/
Ddebug_io_utils_test.cc41 env_ = Env::Default(); in Initialize()
54 Env* env_; member in tensorflow::__anonc081fd840111::DebugIOUtilsTest
112 const uint64 wall_time = env_->NowMicros(); in TEST_F()
142 env_->DeleteRecursively(test_dir, &undeleted_files, &undeleted_dirs) in TEST_F()
155 const uint64 wall_time = env_->NowMicros(); in TEST_F()
193 env_->DeleteRecursively(test_dir, &undeleted_files, &undeleted_dirs) in TEST_F()
210 if (!env_->FileExists(txt_file_dir).ok()) { in TEST_F()
211 ASSERT_TRUE(env_->RecursivelyCreateDir(txt_file_dir).ok()); in TEST_F()
213 ASSERT_EQ(error::Code::NOT_FOUND, env_->FileExists(txt_file_name).code()); in TEST_F()
216 ASSERT_TRUE(env_->NewWritableFile(txt_file_name, &file).ok()); in TEST_F()
[all …]
/external/pdfium/testing/
Dunit_test_main.cpp44 Environment* env_ = nullptr; variable
49 return env_->FontManager(); in GetGlobalFontManager()
59 env_ = new Environment(); in main()
61 AddGlobalTestEnvironment(env_); in main()
Dembedder_test_main.cpp64 Environment* env_ = nullptr; variable
75 env_ = new Environment(); in main()
77 AddGlobalTestEnvironment(env_); in main()
/external/tensorflow/tensorflow/core/distributed_runtime/eager/
Deager_service_impl.h41 explicit EagerServiceImpl(const WorkerEnv* env) : env_(env) { in EagerServiceImpl()
43 env_->env->StartThread({}, "EagerServiceContextGC", [this]() { in EagerServiceImpl()
109 : ctx_(std::move(ctx)), env_(env) { in ServerContext()
165 last_accessed_micros_ = env_->env->NowMicros(); in RecordAccess()
171 (env_->env->NowMicros() - last_accessed_micros_) > in IsStale()
188 const WorkerEnv* const env_; // Not owned. variable
200 const WorkerEnv* const env_; // Not owned. variable
/external/webrtc/webrtc/modules/utility/source/
Dhelpers_android.cc99 : 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/
Dscoped_utf_chars.h34 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/
DNonBlockingThreadPool.h23 : 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()
DSimpleThreadPool.h25 : 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/platform/cloud/
Dexpiring_lru_cache.h42 : max_age_(max_age), max_entries_(max_entries), env_(env) {} in max_age_()
128 if (env_->NowSeconds() - it->second.timestamp > max_age_) { in LookupLocked()
141 Entry entry{env_->NowSeconds(), value, lru_list_.begin()}; in InsertLocked()
171 Env* const env_; // not owned variable
/external/tensorflow/tensorflow/core/kernels/data/
Dcache_dataset_ops.cc57 env_(env), in FileDataset()
116 if (params.dataset->env_ in FileIterator()
160 ->env_->FileExists(MetaFilename(dataset()->filename_)) in RestoreInternal()
328 writer_ = absl::make_unique<BundleWriter>(dataset()->env_, filename_); in RestoreInternal()
345 if (dataset()->env_->FileExists(MetaFilename(filename_)).ok()) { in EnsureLockFileExists()
354 if (dataset()->env_->FileExists(lockfile_).ok()) { in EnsureLockFileExists()
359 if (dataset()->env_->NewRandomAccessFile(lockfile_, &file).ok()) { in EnsureLockFileExists()
375 dataset()->env_->NewWritableFile(lockfile_, &lockfile)); in EnsureLockFileExists()
377 "Created at: ", dataset()->env_->NowSeconds()))); in EnsureLockFileExists()
389 absl::make_unique<BundleWriter>(dataset()->env_, filename_); in EnsureLockFileExists()
[all …]
/external/tensorflow/tensorflow/core/kernels/
Dtf_record_reader_op.cc33 env_(env), in TFRecordReader()
39 TF_RETURN_IF_ERROR(env_->NewRandomAccessFile(current_work(), &file_)); in OnWorkStartedLocked()
76 Env* const env_; member in tensorflow::TFRecordReader
Dtext_line_reader_op.cc33 env_(env), in TextLineReader()
38 TF_RETURN_IF_ERROR(env_->NewRandomAccessFile(current_work(), &file_)); in OnWorkStartedLocked()
89 Env* const env_; member in tensorflow::TextLineReader

1234