hostsidetests/net/app/src/com/android/cts/net/hostside/RemoteSocketFactoryClient.java

/*
 * Copyright (C) 2016 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.
 */

package com.android.cts.net.hostside;

import android.content.ComponentName;
import android.content.Context;
import android.content.Intent;
import android.content.ServiceConnection;
import android.os.ConditionVariable;
import android.os.IBinder;
import android.os.RemoteException;

import com.android.cts.net.hostside.IRemoteSocketFactory;

import java.io.FileDescriptor;

public class RemoteSocketFactoryClient {
    private static final int TIMEOUT_MS = 5000;
    private static final String PACKAGE = RemoteSocketFactoryClient.class.getPackage().getName();
    private static final String APP2_PACKAGE = PACKAGE + ".app2";
    private static final String SERVICE_NAME = APP2_PACKAGE + ".RemoteSocketFactoryService";

    private Context mContext;
    private ServiceConnection mServiceConnection;
    private IRemoteSocketFactory mService;

    public RemoteSocketFactoryClient(Context context) {
        mContext = context;
    }

    public void bind() {
        if (mService != null) {
            throw new IllegalStateException("Already bound");
        }

        final ConditionVariable cv = new ConditionVariable();
        mServiceConnection = new ServiceConnection() {
            @Override
            public void onServiceConnected(ComponentName name, IBinder service) {
                mService = IRemoteSocketFactory.Stub.asInterface(service);
                cv.open();
            }
            @Override
            public void onServiceDisconnected(ComponentName name) {
                mService = null;
            }
        };

        final Intent intent = new Intent();
        intent.setComponent(new ComponentName(APP2_PACKAGE, SERVICE_NAME));
        mContext.bindService(intent, mServiceConnection, Context.BIND_AUTO_CREATE);
        cv.block(TIMEOUT_MS);
        if (mService == null) {
            throw new IllegalStateException(
                    "Could not bind to RemoteSocketFactory service after " + TIMEOUT_MS + "ms");
        }
    }

    public void unbind() {
        if (mService != null) {
            mContext.unbindService(mServiceConnection);
        }
    }

    public FileDescriptor openSocketFd(
            String host, int port, int timeoutMs) throws RemoteException {
        return mService.openSocketFd(host, port, timeoutMs).getFileDescriptor();
    }

    public String getPackageName() throws RemoteException {
        return mService.getPackageName();
    }

    public int getUid() throws RemoteException {
        return mService.getUid();
    }
}