| /* |
| * Copyright (C) 2005 The Android Open Source Project |
| * |
| * Licensed under the Apache License, Version 2.0 (the "License"); |
| * you may not use this file except in compliance with the License. |
| * You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| #ifndef ANDROID_IPC_THREAD_STATE_H |
| #define ANDROID_IPC_THREAD_STATE_H |
| |
| #include <utils/Errors.h> |
| #include <binder/Parcel.h> |
| #include <binder/ProcessState.h> |
| #include <utils/Vector.h> |
| |
| #if defined(_WIN32) |
| typedef int uid_t; |
| #endif |
| |
| // --------------------------------------------------------------------------- |
| namespace android { |
| |
| class IPCThreadState |
| { |
| public: |
| static IPCThreadState* self(); |
| static IPCThreadState* selfOrNull(); // self(), but won't instantiate |
| |
| sp<ProcessState> process(); |
| |
| status_t clearLastError(); |
| |
| pid_t getCallingPid() const; |
| uid_t getCallingUid() const; |
| |
| void setStrictModePolicy(int32_t policy); |
| int32_t getStrictModePolicy() const; |
| |
| void setLastTransactionBinderFlags(int32_t flags); |
| int32_t getLastTransactionBinderFlags() const; |
| |
| int64_t clearCallingIdentity(); |
| void restoreCallingIdentity(int64_t token); |
| |
| int setupPolling(int* fd); |
| status_t handlePolledCommands(); |
| void flushCommands(); |
| |
| void joinThreadPool(bool isMain = true); |
| |
| // Stop the local process. |
| void stopProcess(bool immediate = true); |
| |
| status_t transact(int32_t handle, |
| uint32_t code, const Parcel& data, |
| Parcel* reply, uint32_t flags); |
| |
| void incStrongHandle(int32_t handle, BpBinder *proxy); |
| void decStrongHandle(int32_t handle); |
| void incWeakHandle(int32_t handle, BpBinder *proxy); |
| void decWeakHandle(int32_t handle); |
| status_t attemptIncStrongHandle(int32_t handle); |
| static void expungeHandle(int32_t handle, IBinder* binder); |
| status_t requestDeathNotification( int32_t handle, |
| BpBinder* proxy); |
| status_t clearDeathNotification( int32_t handle, |
| BpBinder* proxy); |
| |
| static void shutdown(); |
| |
| // Call this to disable switching threads to background scheduling when |
| // receiving incoming IPC calls. This is specifically here for the |
| // Android system process, since it expects to have background apps calling |
| // in to it but doesn't want to acquire locks in its services while in |
| // the background. |
| static void disableBackgroundScheduling(bool disable); |
| bool backgroundSchedulingDisabled(); |
| |
| // Call blocks until the number of executing binder threads is less than |
| // the maximum number of binder threads threads allowed for this process. |
| void blockUntilThreadAvailable(); |
| |
| private: |
| IPCThreadState(); |
| ~IPCThreadState(); |
| |
| status_t sendReply(const Parcel& reply, uint32_t flags); |
| status_t waitForResponse(Parcel *reply, |
| status_t *acquireResult=NULL); |
| status_t talkWithDriver(bool doReceive=true); |
| status_t writeTransactionData(int32_t cmd, |
| uint32_t binderFlags, |
| int32_t handle, |
| uint32_t code, |
| const Parcel& data, |
| status_t* statusBuffer); |
| status_t getAndExecuteCommand(); |
| status_t executeCommand(int32_t command); |
| void processPendingDerefs(); |
| void processPostWriteDerefs(); |
| |
| void clearCaller(); |
| |
| static void threadDestructor(void *st); |
| static void freeBuffer(Parcel* parcel, |
| const uint8_t* data, size_t dataSize, |
| const binder_size_t* objects, size_t objectsSize, |
| void* cookie); |
| |
| const sp<ProcessState> mProcess; |
| Vector<BBinder*> mPendingStrongDerefs; |
| Vector<RefBase::weakref_type*> mPendingWeakDerefs; |
| Vector<RefBase*> mPostWriteStrongDerefs; |
| Vector<RefBase::weakref_type*> mPostWriteWeakDerefs; |
| Parcel mIn; |
| Parcel mOut; |
| status_t mLastError; |
| pid_t mCallingPid; |
| uid_t mCallingUid; |
| int32_t mStrictModePolicy; |
| int32_t mLastTransactionBinderFlags; |
| }; |
| |
| }; // namespace android |
| |
| // --------------------------------------------------------------------------- |
| |
| #endif // ANDROID_IPC_THREAD_STATE_H |