Class RemoteCall

andlinker/src/main/java/com/codezjx/andlinker/RemoteCall.java:10–131

Created by codezjx on 2017/10/14.

 * Created by codezjx on 2017/10/14.<br/>
 */
final class RemoteCall implements Call<Object> {
    
    private static final String TAG = "RemoteCall";

    private final ITransfer mTransferService;
    private final ServiceMethod mServiceMethod;
    private final Object[] mArgs;
    private final Dispatcher mDispatcher;
    private volatile boolean mExecuted;
    private volatile boolean mCanceled;

    RemoteCall(ITransfer transferService, ServiceMethod serviceMethod, Object[] args, Dispatcher dispatcher) {
        mTransferService = transferService;
        mServiceMethod = serviceMethod;
        mArgs = args;
        mDispatcher = dispatcher;
    }

    private Object executeInternal() throws RemoteException {
        if (mTransferService == null) {
            Logger.e(TAG, "TransferService null when execute, this may occur if the client is not already bind to the service.");
            return null;
        }
        @SuppressWarnings("unchecked")
        ParameterHandler<Object>[] handlers = (ParameterHandler<Object>[]) mServiceMethod.getParameterHandlers();

        int argumentCount = mArgs != null ? mArgs.length : 0;
        if (argumentCount != handlers.length) {
            throw new IllegalArgumentException("Argument count (" + argumentCount
                    + ") doesn't match expected count (" + handlers.length + ")");
        }

        RequestBuilder requestBuilder = new RequestBuilder(mServiceMethod.getClassName(), mServiceMethod.getMethodName(), argumentCount, mServiceMethod.isOneWay());
        for (int p = 0; p < argumentCount; p++) {
            handlers[p].apply(requestBuilder, mArgs[p], p);
        }
        
        Response response = mTransferService.execute(requestBuilder.build());
        // May return null in one-way mode.
        if (response == null) {
            return null;
        }
        if (response.getStatusCode() != Response.STATUS_CODE_SUCCESS) {
            Logger.e(TAG, "Execute remote call fail: " + response.toString());
        }
        return response.getResult();
    }

    @Override
    public Object execute() {
        checkExecuted();
        if (mCanceled) {
            Logger.w(TAG, "Already canceled");
            return null;
        }
        Object result = null;
        try {
            result = executeInternal();