| /external/tensorflow/tensorflow/core/kernels/ |
| tf_record_reader_op.cc | 33 env_(env),
39 TF_RETURN_IF_ERROR(env_->NewRandomAccessFile(current_work(), &file_));
76 Env* const env_; member in class:tensorflow::TFRecordReader
|
| /external/tensorflow/tensorflow/core/platform/cloud/ |
| expiring_lru_cache.h | 42 : max_age_(max_age), max_entries_(max_entries), env_(env) {}
120 if (env_->NowSeconds() - it->second.timestamp > max_age_) {
133 Entry entry{env_->NowSeconds(), value, lru_list_.begin()};
153 Env* const env_; // not owned member in class:tensorflow::ExpiringLRUCache
|
| file_block_cache.h | 57 env_(env) {
59 pruning_thread_.reset(env_->StartThread(ThreadOptions(), "TF_prune_FBC",
115 Env* const env_; // not owned member in class:tensorflow::FileBlockCache
|
| google_auth_provider.h | 57 Env* env_; member in class:tensorflow::GoogleAuthProvider
|
| oauth_client.h | 56 Env* env_; member in class:tensorflow::OAuthClient
|
| /external/tensorflow/tensorflow/core/util/ |
| events_writer.cc | 35 : env_(Env::Default()),
65 int64 time_in_seconds = env_->NowMicros() / 1000000;
73 env_->NewWritableFile(filename_, &recordio_file_),
159 if (env_->FileExists(filename_).ok()) {
|
| events_writer.h | 86 Env* env_; member in class:tensorflow::EventsWriter
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| master.cc | 64 : env_(env),
73 gc_thread_ = env_->env->StartThread(ThreadOptions(), "TF_master_GC",
155 : env_(env), worker_cache_(worker_cache) {
202 NewRemoteDevices(env_->env, worker_cache_, targets_[i],
249 const MasterEnv* env_; member in class:tensorflow::DeviceFinder
354 if (env_->local_devices[0]->parsed_name().job == job.name() &&
355 env_->local_devices[0]->parsed_name().task == task.first) {
371 status = env_->worker_cache_factory(worker_cache_factory_options,
378 DeviceFinder::GetRemoteDevices(req->config().device_filters(), env_,
392 worker_cache = env_->worker_cache
[all...] |
| worker.cc | 29 : env_(env), cancellation_manager_(new CancellationManager) {}
33 DeviceMgr* dm = env_->device_mgr;
46 Status s = env_->session_mgr->CreateSession(request->session_handle(),
55 Status s = env_->session_mgr->DeleteSession(request->session_handle());
63 env_->session_mgr->WorkerSessionForSession(request->session_handle());
75 env_->session_mgr->WorkerSessionForSession(request->session_handle());
82 Rendezvous* rendez = env_->rendezvous_mgr->Find(step_id);
139 env_->session_mgr->WorkerSessionForSession(request->session_handle());
213 env_->session_mgr->WorkerSessionForSession(request->session_handle());
288 env_->rendezvous_mgr->Cleanup(step_id)
[all...] |
| /external/tensorflow/tensorflow/contrib/tensorboard/db/ |
| summary_file_writer.cc | 37 env_(env) {}
40 const Status is_dir = env_->IsDirectory(logdir);
45 TF_RETURN_IF_ERROR(env_->RecursivelyCreateDir(logdir));
53 last_flush_ = env_->NowMicros();
136 env_->NowMicros() - last_flush_ > 1000 * flush_millis_) {
146 return static_cast<double>(env_->NowMicros()) / 1.0e6;
156 last_flush_ = env_->NowMicros();
164 Env* env_; member in class:tensorflow::__anon39436::SummaryFileWriter
|
| /art/runtime/ |
| jni_env_ext.h | 213 env_(env),
219 env_->locals_.SetSegmentState(env_->local_ref_cookie_);
220 env_->local_ref_cookie_ = saved_local_ref_cookie_;
224 JNIEnvExt* const env_; member in class:art::ScopedJniEnvLocalRefState
|
| scoped_thread_state_change-inl.h | 100 : self_(ThreadForEnv(env)), env_(down_cast<JNIEnvExt*>(env)), vm_(env_->GetVm()) {}
104 env_(down_cast<JNIEnvExt*>(self->GetJniEnv())),
105 vm_(env_ != nullptr ? env_->GetVm() : nullptr) {}
|
| reflection_test.cc | 44 vm_->AttachCurrentThread(&env_, nullptr);
46 ScopedLocalRef<jclass> aioobe(env_,
47 env_->FindClass("java/lang/ArrayIndexOutOfBoundsException"));
49 aioobe_ = reinterpret_cast<jclass>(env_->NewGlobalRef(aioobe.get()));
51 ScopedLocalRef<jclass> ase(env_, env_->FindClass("java/lang/ArrayStoreException"));
53 ase_ = reinterpret_cast<jclass>(env_->NewGlobalRef(ase.get()));
55 ScopedLocalRef<jclass> sioobe(env_,
56 env_->FindClass("java/lang/StringIndexOutOfBoundsException"));
58 sioobe_ = reinterpret_cast<jclass>(env_->NewGlobalRef(sioobe.get()))
507 JNIEnv* env_; member in class:art::ReflectionTest
[all...] |
| scoped_thread_state_change.h | 76 return env_;
115 : self_(nullptr), env_(nullptr), vm_(reinterpret_cast<JavaVMExt*>(vm)) {}
126 JNIEnvExt* const env_; member in class:art::ScopedObjectAccessAlreadyRunnable
|
| /art/compiler/jni/ |
| jni_compiler_test.cc | 301 env_ = Thread::Current()->GetJniEnv();
302 jklass_ = env_->FindClass("MyClassNatives");
306 jmethod_ = env_->GetStaticMethodID(jklass_, method_name, method_sig);
308 jmethod_ = env_->GetMethodID(jklass_, method_name, method_sig);
314 ASSERT_EQ(JNI_OK, env_->RegisterNatives(jklass_, methods, 1))
317 env_->UnregisterNatives(jklass_);
320 jmethodID constructor = env_->GetMethodID(jklass_, "<init>", "()V");
321 jobj_ = env_->NewObject(jklass_, constructor);
381 JNIEnv* env_; member in class:art::JniCompilerTest
646 env_->CallNonvirtualVoidMethod(jobj_, jklass_, jmethod_)
[all...] |
| /external/tensorflow/tensorflow/core/debug/ |
| debug_io_utils_test.cc | 39 env_ = Env::Default();
52 Env* env_; member in class:tensorflow::__anon39522::DebugIOUtilsTest
110 const uint64 wall_time = env_->NowMicros();
140 env_->DeleteRecursively(test_dir, &undeleted_files, &undeleted_dirs)
153 const uint64 wall_time = env_->NowMicros();
191 env_->DeleteRecursively(test_dir, &undeleted_files, &undeleted_dirs)
208 if (!env_->FileExists(txt_file_dir).ok()) {
209 ASSERT_TRUE(env_->RecursivelyCreateDir(txt_file_dir).ok());
211 ASSERT_EQ(error::Code::NOT_FOUND, env_->FileExists(txt_file_name).code());
214 ASSERT_TRUE(env_->NewWritableFile(txt_file_name, &file).ok())
[all...] |
| /cts/tests/signature/dex-checker/ |
| dex-checker.cpp | 21 ScopedUtfChars(JNIEnv* env, jstring s) : env_(env), string_(s) {
31 env_->ReleaseStringUTFChars(string_, utf_chars_);
40 JNIEnv* env_; member in class:ScopedUtfChars
|
| /external/tensorflow/tensorflow/core/framework/ |
| device_base.h | 99 explicit DeviceBase(Env* env) : env_(env) {}
102 Env* env() const { return env_; }
231 Env* const env_; member in class:tensorflow::DeviceBase
|
| /external/tensorflow/tensorflow/core/lib/monitoring/ |
| collection_registry.cc | 65 CollectionRegistry::CollectionRegistry(Env* const env) : env_(env) {}
82 {metric_def, collection_function, env_->NowMicros() / 1000}});
95 internal::Collector collector(env_->NowMicros() / 1000);
|
| /art/openjdkjvmti/ |
| events-inl.h | 55 ScopedEventDispatchEnvironment() : env_(nullptr), throw_(nullptr, nullptr) {
60 : env_(env),
61 throw_(env_, env_->ExceptionOccurred()) {
65 env_->PushLocalFrame(128);
66 env_->ExceptionClear();
70 if (env_ != nullptr) {
71 if (throw_.get() != nullptr && !env_->ExceptionCheck()) {
74 env_->Throw(throw_.get());
76 env_->PopLocalFrame(nullptr)
82 JNIEnv* env_; member in class:openjdkjvmti::impl::FINAL
[all...] |
| /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| SimpleThreadPool.h | 25 : env_(env), threads_(num_threads), waiters_(num_threads) {
59 Task t = env_.CreateTask(std::move(fn));
113 env_.ExecuteTask(t);
136 Environment env_; member in class:Eigen::SimpleThreadPoolTempl
|
| NonBlockingThreadPool.h | 23 : env_(env),
58 threads_.push_back(env_.CreateThread([this, i]() { WorkerLoop(i); }));
75 Task t = env_.CreateTask(std::move(fn));
97 env_.ExecuteTask(t); // Push failed, execute directly.
124 Environment env_; member in class:Eigen::NonBlockingThreadPoolTempl
167 env_.ExecuteTask(t);
|
| /art/tools/titrace/ |
| titrace.cc | 46 explicit TiMemory(jvmtiEnv* env, T* mem, size_t size) : env_(env), mem_(mem), size_(size) {
51 env_->Deallocate(static_cast<unsigned char*>(mem_));
58 env_ = other.env_;
63 other.env_ = nullptr;
86 jvmtiEnv* env_; member in struct:titrace::TiMemory
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| cache_dataset_ops.cc | 54 env_(env),
69 if (env_->FileExists(strings::StrCat(filename_, ".index")).ok()) {
110 writer_(params.dataset->env_, params.dataset->filename_),
166 if (dataset()->env_->FileExists(lockfile_).ok()) {
171 if (dataset()->env_->NewRandomAccessFile(lockfile_, &file).ok()) {
186 dataset()->env_->NewWritableFile(lockfile_, &lockfile));
188 strings::StrCat("Created at: ", dataset()->env_->NowSeconds())));
197 TF_RETURN_IF_ERROR(dataset()->env_->DeleteFile(lockfile_));
215 reader_(dataset()->env_, dataset()->filename_) {}
255 Env* const env_; member in class:tensorflow::__anon39736::CacheDatasetOp::FileDataset
[all...] |
| /art/compiler/driver/ |
| compiler_driver_test.cc | 62 env_ = Thread::Current()->GetJniEnv();
63 class_ = env_->FindClass(class_name);
66 mid_ = env_->GetMethodID(class_, method, signature);
68 mid_ = env_->GetStaticMethodID(class_, method, signature);
100 JNIEnv* env_; member in class:art::CompilerDriverTest
166 jclass c_class = env_->FindClass("ConcreteClass");
168 jmethodID constructor = env_->GetMethodID(c_class, "<init>", "()V");
170 jobject jobj_ = env_->NewObject(c_class, constructor);
174 env_->CallNonvirtualVoidMethod(jobj_, class_, mid_);
176 EXPECT_EQ(env_->ExceptionCheck(), JNI_TRUE)
[all...] |
