| /frameworks/base/core/java/android/os/ |
| AsyncResult.java | 22 public class AsyncResult
35 public static AsyncResult
38 AsyncResult ret;
40 ret = new AsyncResult (m.obj, r, ex);
48 public static AsyncResult
51 AsyncResult ret;
53 ret = new AsyncResult (m.obj, null, null);
62 AsyncResult (Object uo, Object r, Throwable ex)
|
| Registrant.java | 64 notifyRegistrant(AsyncResult ar)
81 msg.obj = new AsyncResult(userObj, result, exception);
|
| /external/perfetto/include/perfetto/ipc/ |
| async_result.h | 33 class AsyncResult {
35 static AsyncResult Create() {
36 return AsyncResult(std::unique_ptr<T>(new T()));
39 AsyncResult(std::unique_ptr<T> msg = nullptr,
45 AsyncResult(AsyncResult&&) noexcept = default;
46 AsyncResult& operator=(AsyncResult&&) = default;
|
| deferred.h | 49 // reply.Bind([] (AsyncResult<HelloReply> reply) {
57 // AsyncResult<HelloReply> reply = AsyncResult<HelloReply>::Create();
71 std::function<void(AsyncResult<ProtoMessage>)> callback = nullptr);
80 void Bind(std::function<void(AsyncResult<ProtoMessage>)> callback);
82 void Resolve(AsyncResult<ProtoMessage>);
90 std::function<void(AsyncResult<ProtoMessage>)> callback_;
96 explicit Deferred(std::function<void(AsyncResult<T>)> callback = nullptr) {
108 void Bind(std::function<void(AsyncResult<T>)> callback) {
113 // callback that takes an AsyncResult<ProtoMessage>, so that it can b
[all...] |
| /external/perfetto/src/ipc/ |
| deferred.cc | 26 std::function<void(AsyncResult<ProtoMessage>)> callback)
54 std::function<void(AsyncResult<ProtoMessage>)> callback) {
62 void DeferredBase::Resolve(AsyncResult<ProtoMessage> async_result) {
75 Resolve(AsyncResult<ProtoMessage>());
|
| deferred_unittest.cc | 37 deferred.Bind([num_callbacks](AsyncResult<TestMessage> msg) {
46 AsyncResult<TestMessage> res = AsyncResult<TestMessage>::Create();
64 deferred.Bind([num_callbacks](AsyncResult<TestMessage> msg) {
72 AsyncResult<TestMessage> res = AsyncResult<TestMessage>::Create();
85 deferred.Bind([num_callbacks](AsyncResult<TestMessage> msg) {
100 [num_callbacks](AsyncResult<TestMessage>) { (*num_callbacks)++; });
108 deferred.Bind([](AsyncResult<TestMessage>) {});
113 deferred.Bind([num_callbacks](AsyncResult<TestMessage> msg)
[all...] |
| /frameworks/opt/telephony/src/java/com/android/internal/telephony/uicc/euicc/async/ |
| AsyncMessageInvocation.java | 19 import android.os.AsyncResult;
53 AsyncResult result = (AsyncResult) msg.obj;
71 protected abstract Response parseResult(AsyncResult result) throws Throwable;
|
| /frameworks/opt/telephony/src/java/com/android/internal/telephony/ |
| OemHookIndication.java | 20 import android.os.AsyncResult;
50 mRil.mUnsolOemHookRawRegistrant.notifyRegistrant(new AsyncResult(null, response, null));
|
| RadioConfigIndication.java | 21 import android.os.AsyncResult;
47 new AsyncResult(null, ret, null));
|
| IccCard.java | 19 import android.os.AsyncResult;
90 * onComplete.obj will be an AsyncResult
92 * ((AsyncResult)onComplete.obj).exception == null on success
93 * ((AsyncResult)onComplete.obj).exception != null on fail
96 * ((AsyncResult)onComplete.obj).exception != null
97 * && ((AsyncResult)onComplete.obj).exception
99 * && ((CommandException)(((AsyncResult)onComplete.obj).exception))
163 * onComplete.obj will be an AsyncResult
164 * ((AsyncResult)onComplete.obj).exception == null on success
165 * ((AsyncResult)onComplete.obj).exception != null on fai
[all...] |
| RadioIndication.java | 87 import android.os.AsyncResult;
163 mRil.mGsmSmsRegistrant.notifyRegistrant(new AsyncResult(null, sms, null));
174 mRil.mSmsStatusRegistrant.notifyRegistrant(new AsyncResult(null, pduArray, null));
184 mRil.mSmsOnSimRegistrant.notifyRegistrant(new AsyncResult(null, recordNumber, null));
198 mRil.mUSSDRegistrant.notifyRegistrant(new AsyncResult (null, resp, null));
219 mRil.mNITZTimeRegistrant.notifyRegistrant(new AsyncResult (null, result, null));
236 mRil.mSignalStrengthRegistrant.notifyRegistrant(new AsyncResult (null, ss, null));
252 mRil.mLceInfoRegistrants.notifyRegistrants(new AsyncResult(null, response, null));
268 mRil.mSignalStrengthRegistrant.notifyRegistrant(new AsyncResult(null, ss, null));
302 new AsyncResult(null, response, null))
[all...] |
| /frameworks/opt/telephony/tests/telephonytests/src/com/android/internal/telephony/uicc/ |
| UiccCarrierPrivilegeRulesTest.java | 27 import android.os.AsyncResult;
108 AsyncResult ar = new AsyncResult(null, new int[]{0}, null);
120 AsyncResult ar = new AsyncResult(null, iir, null);
318 AsyncResult ar = new AsyncResult(null, new int[]{0}, null);
323 AsyncResult ar = new AsyncResult(null, null, null);
336 AsyncResult ar = new AsyncResult(null, iir, null)
[all...] |
| IsimUiccRecordsTest.java | 43 import android.os.AsyncResult;
81 msg.obj = new AsyncResult(null, null, null);
|
| /frameworks/opt/telephony/src/java/com/android/internal/telephony/uicc/ |
| AdnRecordCache.java | 19 import android.os.AsyncResult;
81 AsyncResult ar = new AsyncResult(null, null, new RuntimeException("AdnCache reset"));
125 AsyncResult.forMessage(response).exception = e;
264 AsyncResult.forMessage(response).result = result;
295 AsyncResult.forMessage(response).exception
311 notifyWaiters(ArrayList<Message> waiters, AsyncResult ar) {
320 AsyncResult.forMessage(waiter, ar.result, ar.exception);
330 AsyncResult ar;
336 ar = (AsyncResult) msg.obj
[all...] |
| UiccPkcs15.java | 19 import android.os.AsyncResult;
102 AsyncResult ar = (AsyncResult) msg.obj;
105 AsyncResult.forMessage(mCallback, null, ar.exception);
120 AsyncResult.forMessage(mCallback, result, (result == null) ?
147 AsyncResult ar;
151 ar = (AsyncResult) msg.obj;
155 AsyncResult.forMessage(mCallback, null, null);
158 AsyncResult.forMessage(mCallback, null, ar.exception);
195 AsyncResult ar = (AsyncResult) msg.obj
[all...] |
| AdnRecordLoader.java | 21 import android.os.AsyncResult;
145 AsyncResult ar;
152 ar = (AsyncResult)(msg.obj);
186 ar = (AsyncResult)(msg.obj);
195 ar = (AsyncResult)(msg.obj);
226 ar = (AsyncResult)(msg.obj);
254 ar = (AsyncResult)(msg.obj);
285 AsyncResult.forMessage(mUserResponse)
296 AsyncResult.forMessage(mUserResponse).result
|
| IsimUiccRecords.java | 21 import android.os.AsyncResult;
102 AsyncResult ar;
123 ar = (AsyncResult)msg.obj;
195 public void onRecordLoaded(AsyncResult ar) {
206 public void onRecordLoaded(AsyncResult ar) {
223 public void onRecordLoaded(AsyncResult ar) {
234 public void onRecordLoaded(AsyncResult ar) {
244 public void onRecordLoaded(AsyncResult ar) {
297 mLockedRecordsLoadedRegistrants.notifyRegistrants(new AsyncResult(null, null, null));
300 new AsyncResult(null, null, null))
[all...] |
| /packages/services/Telephony/src/com/android/services/telephony/ |
| PstnPhoneCapabilitiesNotifier.java | 19 import android.os.AsyncResult;
52 handleVideoCapabilitesChanged((AsyncResult) msg.obj);
90 private void handleVideoCapabilitesChanged(AsyncResult ar) {
|
| /packages/services/Telephony/src/com/android/phone/ |
| CdmaVoicePrivacySwitchPreference.java | 22 import android.os.AsyncResult;
79 AsyncResult ar = (AsyncResult) msg.obj;
95 AsyncResult ar = (AsyncResult) msg.obj;
|
| /external/perfetto/src/tracing/ipc/consumer/ |
| consumer_ipc_client_impl.cc | 78 [weak_this](ipc::AsyncResult<protos::EnableTracingResponse> response) {
98 [](ipc::AsyncResult<protos::DisableTracingResponse> response) {
119 [this](ipc::AsyncResult<protos::ReadBuffersResponse> response) {
127 ipc::AsyncResult<protos::ReadBuffersResponse> response) {
152 [](ipc::AsyncResult<protos::FreeBuffersResponse> response) {
169 [callback](ipc::AsyncResult<protos::FlushResponse> response) {
|
| /external/perfetto/src/tracing/ipc/service/ |
| consumer_ipc_service.cc | 77 resp.Resolve(ipc::AsyncResult<protos::DisableTracingResponse>::Create());
92 resp.Resolve(ipc::AsyncResult<protos::FreeBuffersResponse>::Create());
116 response.Resolve(ipc::AsyncResult<protos::FlushResponse>::Create());
139 auto result = ipc::AsyncResult<protos::EnableTracingResponse>::Create();
150 auto result = ipc::AsyncResult<protos::ReadBuffersResponse>::Create();
164 result = ipc::AsyncResult<protos::ReadBuffersResponse>::Create();
|
| producer_ipc_service.cc | 81 ipc::AsyncResult<protos::InitializeConnectionResponse>::Create();
102 ipc::AsyncResult<protos::RegisterDataSourceResponse>::Create());
131 ipc::AsyncResult<protos::UnregisterDataSourceResponse>::Create());
156 resp.Resolve(ipc::AsyncResult<protos::CommitDataResponse>::Create());
205 auto cmd = ipc::AsyncResult<protos::GetAsyncCommandResponse>::Create();
220 auto cmd = ipc::AsyncResult<protos::GetAsyncCommandResponse>::Create();
236 auto cmd = ipc::AsyncResult<protos::GetAsyncCommandResponse>::Create();
254 auto cmd = ipc::AsyncResult<protos::GetAsyncCommandResponse>::Create();
|
| /frameworks/opt/telephony/src/java/com/android/internal/telephony/cdma/ |
| CdmaSubscriptionSourceManager.java | 24 import android.os.AsyncResult;
111 AsyncResult ar;
117 ar = (AsyncResult) msg.obj;
127 ar = (AsyncResult)msg.obj;
182 * @param ar AsyncResult object that contains the result of get CDMA
185 private void handleGetCdmaSubscriptionSource(AsyncResult ar) {
195 mCdmaSubscriptionSourceChangedRegistrants.notifyRegistrants(new AsyncResult(null,
|
| /frameworks/opt/telephony/tests/telephonytests/src/com/android/internal/telephony/ |
| CarrierActionAgentTest.java | 29 import android.os.AsyncResult;
121 assertEquals(false, ((AsyncResult) message.getValue().obj).result);
124 assertEquals(false, ((AsyncResult) message.getValue().obj).result);
135 assertEquals(true, ((AsyncResult) message.getValue().obj).result);
139 assertEquals(true, ((AsyncResult) message.getValue().obj).result);
164 assertEquals(false, ((AsyncResult) message.getValue().obj).result);
168 assertEquals(false, ((AsyncResult) message.getValue().obj).result);
177 assertEquals(true, ((AsyncResult) message.getValue().obj).result);
181 assertEquals(true, ((AsyncResult) message.getValue().obj).result);
|
| /frameworks/opt/telephony/src/java/com/android/internal/telephony/uicc/euicc/apdu/ |
| CloseLogicalChannelInvocation.java | 19 import android.os.AsyncResult;
50 protected Boolean parseResult(AsyncResult ar) {
|
