| /art/runtime/gc/space/ |
| space_create_test.cc | 99 Thread* self = Thread::Current(); local
100 ScopedObjectAccess soa(self);
104 StackHandleScope<3> hs(soa.Self());
106 self,
118 mirror::Object* ptr2 = Alloc(space, self, 8 * MB, &dummy, nullptr, &dummy);
124 self,
136 mirror::Object* ptr4 = space->Alloc(self, 8 * MB, &dummy, nullptr, &dummy);
140 mirror::Object* ptr5 = space->AllocWithGrowth(self, 8 * MB, &dummy, nullptr, &dummy);
146 EXPECT_EQ(free3, space->Free(self, ptr3.Assign(nullptr)));
152 self,
230 Thread* self = Thread::Current(); local
309 Thread* self = Thread::Current(); local
[all...] |
| /art/runtime/ |
| indirect_reference_table.cc | 183 auto* self = Thread::Current(); local
184 if (self->HandleScopeContains(reinterpret_cast<jobject>(iref))) {
185 auto* env = self->GetJniEnv();
188 ScopedObjectAccess soa(self);
191 self->Dump(LOG(WARNING));
|
| monitor_test.cc | 60 static void FillHeap(Thread* self, ClassLinker* class_linker,
66 hsp->reset(new StackHandleScope<kMaxHandles>(self));
68 Handle<mirror::Class> c((*hsp)->NewHandle(class_linker->FindSystemClass(self,
71 Handle<mirror::Class> ca((*hsp)->NewHandle(class_linker->FindSystemClass(self,
78 mirror::ObjectArray<mirror::Object>::Alloc(self, ca.Get(), length / 4)));
79 if (self->IsExceptionPending() || h.Get() == nullptr) {
80 self->ClearException();
95 while (!self->IsExceptionPending()) {
96 MutableHandle<mirror::Object> h = (*hsp)->NewHandle<mirror::Object>(c->AllocObject(self));
97 if (!self->IsExceptionPending() && h.Get() != nullptr)
293 Thread* const self = Thread::Current(); local
[all...] |
| reflection_test.cc | 91 Thread* self = Thread::Current(); local
92 StackHandleScope<2> hs(self);
95 ScopedObjectAccessUnchecked(self).Decode<mirror::ClassLoader*>(jclass_loader)));
97 MakeExecutable(ScopedObjectAccessUnchecked(self).Decode<mirror::ClassLoader*>(jclass_loader),
102 MakeExecutable(ScopedObjectAccessUnchecked(self).Decode<mirror::ClassLoader*>(jclass_loader),
106 mirror::Class* c = class_linker_->FindClass(self, DotToDescriptor(class_name).c_str(),
118 StackHandleScope<1> hs2(self);
120 bool initialized = class_linker_->EnsureInitialized(self, h_class, true, true);
122 *receiver = c->AllocObject(self);
128 self->TransitionFromSuspendedToRunnable()
[all...] |
| thread-inl.h | 39 return full_env->self;
261 DCHECK(Thread::Current() == this) << "Should be called by self";
273 // Note: self is not necessarily equal to this thread since thread may be suspended.
274 Thread* self = Thread::Current(); local
275 DCHECK(this == self || IsSuspended() || GetState() == kWaitingPerformingGc)
276 << GetState() << " thread " << this << " self " << self;
|
| thread_pool.cc | 75 Thread* self = Thread::Current(); local
77 thread_pool_->creation_barier_.Wait(self);
78 while ((task = thread_pool_->GetTask(self)) != nullptr) {
79 task->Run(self);
94 void ThreadPool::AddTask(Thread* self, Task* task) {
95 MutexLock mu(self, task_queue_lock_);
99 task_queue_condition_.Signal(self);
103 void ThreadPool::RemoveAllTasks(Thread* self) {
104 MutexLock mu(self, task_queue_lock_);
121 Thread* self = Thread::Current() local
140 Thread* self = Thread::Current(); local
[all...] |
| /art/runtime/jit/ |
| profile_compilation_info_test.cc | 38 Thread* self = Thread::Current(); local
39 ScopedObjectAccess soa(self);
40 StackHandleScope<1> hs(self);
42 reinterpret_cast<mirror::ClassLoader*>(self->DecodeJObject(class_loader))));
43 mirror::Class* klass = class_linker->FindClass(self, clazz.c_str(), h_loader);
96 Thread* self = Thread::Current(); local
99 ScopedObjectAccess soa(self);
114 ScopedObjectAccess soa(self);
130 ScopedObjectAccess soa(self);
|
| /art/runtime/lambda/ |
| box_table.cc | 79 Thread* self = Thread::Current(); local
83 /*Reader*/MutexLock mu(self, *Locks::lambda_table_lock_);
113 mirror::ByteArray::Alloc(self, closure->GetSize());
119 CHECK(self->IsExceptionPending());
130 MutexLock mu(self, *Locks::lambda_table_lock_);
161 Thread* self = Thread::Current(); local
186 LeakingAllocator::MakeFlexibleInstance<Closure>(self, boxed_closure_as_array->GetLength());
210 Thread* self = Thread::Current(); local
212 (kUseReadBarrier && !self->GetWeakRefAccessEnabled()))) {
213 new_weaks_condition_.WaitHoldingLocks(self); // wait while holding mutator loc
220 Thread* self = Thread::Current(); local
263 Thread* self = Thread::Current(); local
271 Thread* self = Thread::Current(); local
280 Thread* self = Thread::Current(); local
[all...] |
| /art/runtime/mirror/ |
| object.cc | 75 Object* Object::CopyObject(Thread* self, mirror::Object* dest, mirror::Object* src,
102 heap->AddFinalizerReference(self, &dest);
110 CopyObjectVisitor(Thread* self, Handle<Object>* orig, size_t num_bytes)
111 : self_(self), orig_(orig), num_bytes_(num_bytes) {
126 Object* Object::Clone(Thread* self) {
132 StackHandleScope<1> hs(self);
135 CopyObjectVisitor visitor(self, &this_object, num_bytes);
137 copy = heap->AllocObject<true>(self, GetClass(), num_bytes, visitor);
139 copy = heap->AllocNonMovableObject<true>(self, GetClass(), num_bytes, visitor);
177 Thread* self = Thread::Current() local
[all...] |
| object_array-inl.h | 37 inline ObjectArray<T>* ObjectArray<T>::Alloc(Thread* self, Class* object_array_class,
39 Array* array = Array::Alloc<true>(self, object_array_class, length,
52 inline ObjectArray<T>* ObjectArray<T>::Alloc(Thread* self, Class* object_array_class,
54 return Alloc(self, object_array_class, length,
239 Thread* self = Thread::Current(); local
241 self->ThrowNewExceptionF("Ljava/lang/ArrayStoreException;",
252 inline ObjectArray<T>* ObjectArray<T>::CopyOf(Thread* self, int32_t new_length) {
255 StackHandleScope<1> hs(self);
260 ObjectArray<T>* new_array = Alloc(self, GetClass(), new_length, allocator_type);
|
| string-inl.h | 137 Thread* self = Thread::Current(); local
138 self->ThrowNewExceptionF("Ljava/lang/StringIndexOutOfBoundsException;",
156 inline String* String::Alloc(Thread* self, int32_t utf16_length, gc::AllocatorType allocator_type,
178 self->ThrowOutOfMemoryError(StringPrintf("%s of length %d would overflow",
186 heap->AllocObjectWithAllocator<kIsInstrumented, true>(self, string_class, alloc_size,
191 inline String* String::AllocFromByteArray(Thread* self, int32_t byte_length,
195 String* string = Alloc<kIsInstrumented>(self, byte_length, allocator_type, visitor);
200 inline String* String::AllocFromCharArray(Thread* self, int32_t count,
206 String* new_string = Alloc<kIsInstrumented>(self, count, allocator_type, visitor);
211 inline String* String::AllocFromString(Thread* self, int32_t string_length, Handle<String> string
[all...] |
| /art/runtime/native/ |
| java_lang_System.cc | 41 Thread* self = Thread::Current(); local
42 self->ThrowNewExceptionF("Ljava/lang/ArrayStoreException;",
80 soa.Self()->ThrowNewExceptionF("Ljava/lang/ArrayIndexOutOfBoundsException;",
139 soa.Self()->ThrowNewExceptionF("Ljava/lang/ArrayStoreException;",
|
| org_apache_harmony_dalvik_ddmc_DdmVmInternal.cc | 50 Thread* const self = Thread::Current(); local
51 if (static_cast<uint32_t>(thin_lock_id) == self->GetThreadId()) {
54 jobject internal_trace = self->CreateInternalStackTrace<false>(soa);
132 Thread* self = static_cast<JNIEnvExt*>(env)->self; local
134 MutexLock mu(self, *Locks::thread_list_lock_);
|
| /cts/suite/audio_quality/lib/src/audio/ |
| RemoteAudio.cpp | 140 RemoteAudio* self = reinterpret_cast<RemoteAudio*>(data); local
143 if (!self->handlePacket()) { //error, stop polling
|
| /external/avahi/avahi-gobject/ |
| ga-client.c | 66 static void ga_client_init(GaClient * self) {
67 GaClientPrivate *priv = GA_CLIENT_GET_PRIVATE(self);
69 self->avahi_client = NULL;
156 GaClient *self = GA_CLIENT(object); local
157 GaClientPrivate *priv = GA_CLIENT_GET_PRIVATE(self);
164 if (self->avahi_client) {
165 avahi_client_free(self->avahi_client);
166 self->avahi_client = NULL;
216 GaClient *self = GA_CLIENT(data); local
217 GaClientPrivate *priv = GA_CLIENT_GET_PRIVATE(self);
[all...] |
| ga-record-browser.c | 269 GaRecordBrowser *self = GA_RECORD_BROWSER(object); local
270 GaRecordBrowserPrivate *priv = GA_RECORD_BROWSER_GET_PRIVATE(self);
291 GaRecordBrowser *self = GA_RECORD_BROWSER(object); local
292 GaRecordBrowserPrivate *priv = GA_RECORD_BROWSER_GET_PRIVATE(self);
326 GaRecordBrowser *self = GA_RECORD_BROWSER(userdata); local
333 g_signal_emit(self, signals[signalid], 0,
339 g_signal_emit(self, signals[CACHE_EXHAUSTED], 0);
342 g_signal_emit(self, signals[ALL_FOR_NOW], 0);
350 g_signal_emit(self, signals[FAILURE], 0, error);
|
| ga-service-browser.c | 259 GaServiceBrowser *self = GA_SERVICE_BROWSER(object); local
260 GaServiceBrowserPrivate *priv = GA_SERVICE_BROWSER_GET_PRIVATE(self);
281 GaServiceBrowser *self = GA_SERVICE_BROWSER(object); local
282 GaServiceBrowserPrivate *priv = GA_SERVICE_BROWSER_GET_PRIVATE(self);
298 GaServiceBrowser *self = GA_SERVICE_BROWSER(userdata); local
299 GaServiceBrowserPrivate *priv = GA_SERVICE_BROWSER_GET_PRIVATE(self);
310 g_signal_emit(self, signals[signalid], 0,
315 g_signal_emit(self, signals[CACHE_EXHAUSTED], 0);
318 g_signal_emit(self, signals[ALL_FOR_NOW], 0);
326 g_signal_emit(self, signals[FAILURE], 0, error)
[all...] |
| ga-service-resolver.c | 269 GaServiceResolver *self = GA_SERVICE_RESOLVER(object); local
270 GaServiceResolverPrivate *priv = GA_SERVICE_RESOLVER_GET_PRIVATE(self);
292 GaServiceResolver *self = GA_SERVICE_RESOLVER(object); local
293 GaServiceResolverPrivate *priv = GA_SERVICE_RESOLVER_GET_PRIVATE(self);
318 GaServiceResolver *self = GA_SERVICE_RESOLVER(userdata); local
319 GaServiceResolverPrivate *priv = GA_SERVICE_RESOLVER_GET_PRIVATE(self);
326 g_signal_emit(self, signals[FOUND], 0,
338 g_signal_emit(self, signals[FAILURE], 0, error);
|
| /external/chromium-trace/catapult/telemetry/telemetry/core/ |
| local_server.py | 22 def __init__(self):
25 def StartAndGetNamedPorts(self, args):
33 def ServeForever(self):
39 def __init__(self, server_backend_class):
48 self._server_backend_class = server_backend_class
49 self._subprocess = None
50 self._devnull = None
51 self._local_server_controller = None
52 self.forwarder = None
53 self.host_ip = Non
221 from telemetry.core import local_server # pylint: disable=import-self namespace
[all...] |
| /external/gemmlowp/profiling/ |
| instrumentation.h | 181 ThreadInfo* self = static_cast<ThreadInfo*>(ptr); local
182 ThreadsUnderProfiling().erase(self);
183 pthread_key_delete(self->key);
|
| /external/google-breakpad/src/client/mac/tests/ |
| crash_generation_server_test.cc | 153 CrashGenerationServerTest* self = local
156 self->last_dump_name = file_path;
157 self->child_pid = client_info.pid();
358 CrashGenerationServerTest* self = local
360 self->filter_callback_called = true;
|
| /external/iproute2/lib/ |
| json_writer.c | 33 static void jsonw_indent(json_writer_t *self)
36 for (i = 0; i <= self->depth; ++i)
37 fputs(" ", self->out);
41 static void jsonw_eol(json_writer_t *self)
43 if (!self->pretty)
46 putc('\n', self->out);
47 jsonw_indent(self);
51 static void jsonw_eor(json_writer_t *self)
53 if (self->sep != '\0')
54 putc(self->sep, self->out)
99 json_writer_t *self = malloc(sizeof(*self)); local
113 json_writer_t *self = *self_p; local
[all...] |
| /external/libbrillo/brillo/glib/ |
| dbus.cc | 345 SignalWatcher* self = static_cast<SignalWatcher*>(data); local
347 message, self->interface_.c_str(), self->signal_.c_str())) {
348 self->OnSignal(message);
|
| /external/libchrome/dbus/ |
| exported_object.cc | 314 ExportedObject* self = reinterpret_cast<ExportedObject*>(user_data); local
315 return self->HandleMessage(connection, raw_message);
320 ExportedObject* self = reinterpret_cast<ExportedObject*>(user_data); local
321 return self->OnUnregistered(connection);
|
| /external/skia/src/ports/ |
| SkOSFile_posix.cpp | 115 SkOSFileIterData& self = *static_cast<SkOSFileIterData*>(fSelf.get()); local
116 if (self.fDIR) {
117 ::closedir(self.fDIR);
119 self.~SkOSFileIterData();
123 SkOSFileIterData& self = *static_cast<SkOSFileIterData*>(fSelf.get()); local
124 if (self.fDIR) {
125 ::closedir(self.fDIR);
126 self.fDIR = 0;
129 self.fPath.set(path);
131 self.fDIR = ::opendir(path)
148 SkOSFileIterData& self = *static_cast<SkOSFileIterData*>(fSelf.get()); local
[all...] |
