Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 542b8653 authored by fionaxu's avatar fionaxu Committed by android-build-merger
Browse files

Merge "Notify carrier app of other default networks" into oc-dr1-dev 

am: b60182fd

Change-Id: I7eead5b646d150b436597cb0526e00b0de952cee
parents 2a96037b b60182fd

src/java/com/android/internal/telephony/CarrierActionAgent.java

+43 −21
Original line number Original line Diff line number Diff line
@@ -57,22 +57,26 @@ public class CarrierActionAgent extends Handler { 
    public static final int CARRIER_ACTION_SET_METERED_APNS_ENABLED        = 0;

    public static final int CARRIER_ACTION_SET_METERED_APNS_ENABLED        = 0;

    public static final int CARRIER_ACTION_SET_RADIO_ENABLED               = 1;

    public static final int CARRIER_ACTION_SET_RADIO_ENABLED               = 1;

    public static final int CARRIER_ACTION_RESET                           = 2;

    public static final int CARRIER_ACTION_RESET                           = 2;

    public static final int EVENT_APM_SETTINGS_CHANGED                   = 3;

    public static final int CARRIER_ACTION_REPORT_DEFAULT_NETWORK_STATUS   = 3;

    public static final int EVENT_MOBILE_DATA_SETTINGS_CHANGED           = 4;

    public static final int EVENT_APM_SETTINGS_CHANGED                     = 4;

    public static final int EVENT_DATA_ROAMING_OFF                       = 5;

    public static final int EVENT_MOBILE_DATA_SETTINGS_CHANGED             = 5;

    public static final int EVENT_SIM_STATE_CHANGED                      = 6;

    public static final int EVENT_DATA_ROAMING_OFF                         = 6;

    public static final int EVENT_SIM_STATE_CHANGED                        = 7;





    /** Member variables */

    /** Member variables */

    private final Phone mPhone;

    private final Phone mPhone;

    /** registrant list per carrier action */

    /** registrant list per carrier action */

    private RegistrantList mMeteredApnEnableRegistrants = new RegistrantList();

    private RegistrantList mMeteredApnEnableRegistrants = new RegistrantList();

    private RegistrantList mRadioEnableRegistrants = new RegistrantList();

    private RegistrantList mRadioEnableRegistrants = new RegistrantList();

    private RegistrantList mDefaultNetworkReportRegistrants = new RegistrantList();

    /** local log for carrier actions */

    /** local log for carrier actions */

    private LocalLog mMeteredApnEnabledLog = new LocalLog(10);

    private LocalLog mMeteredApnEnabledLog = new LocalLog(10);

    private LocalLog mRadioEnabledLog = new LocalLog(10);

    private LocalLog mRadioEnabledLog = new LocalLog(10);

    /** carrier actions, true by default */

    private LocalLog mReportDefaultNetworkStatusLog = new LocalLog(10);

    /** carrier actions */

    private Boolean mCarrierActionOnMeteredApnEnabled = true;

    private Boolean mCarrierActionOnMeteredApnEnabled = true;

    private Boolean mCarrierActionOnRadioEnabled = true;

    private Boolean mCarrierActionOnRadioEnabled = true;

    private Boolean mCarrierActionReportDefaultNetworkStatus = false;

    /** content observer for APM change */

    /** content observer for APM change */

    private final SettingsObserver mSettingsObserver;

    private final SettingsObserver mSettingsObserver;
@@ -102,6 +106,9 @@ public class CarrierActionAgent extends Handler { 




    @Override

    @Override

    public void handleMessage(Message msg) {

    public void handleMessage(Message msg) {

        // skip notification if the input carrier action is same as the current one.

        Boolean enabled = getCarrierActionEnabled(msg.what);

        if (enabled != null && enabled == (boolean) msg.obj) return;

        switch (msg.what) {

        switch (msg.what) {

            case CARRIER_ACTION_SET_METERED_APNS_ENABLED:

            case CARRIER_ACTION_SET_METERED_APNS_ENABLED:

                mCarrierActionOnMeteredApnEnabled = (boolean) msg.obj;

                mCarrierActionOnMeteredApnEnabled = (boolean) msg.obj;
@@ -118,6 +125,15 @@ public class CarrierActionAgent extends Handler { 
                mRadioEnableRegistrants.notifyRegistrants(

                mRadioEnableRegistrants.notifyRegistrants(

                        new AsyncResult(null, mCarrierActionOnRadioEnabled, null));

                        new AsyncResult(null, mCarrierActionOnRadioEnabled, null));

                break;

                break;

            case CARRIER_ACTION_REPORT_DEFAULT_NETWORK_STATUS:

                mCarrierActionReportDefaultNetworkStatus = (boolean) msg.obj;

                log("CARRIER_ACTION_REPORT_AT_DEFAULT_NETWORK_STATUS: "

                        + mCarrierActionReportDefaultNetworkStatus);

                mReportDefaultNetworkStatusLog.log("REGISTER_DEFAULT_NETWORK_STATUS: "

                        + mCarrierActionReportDefaultNetworkStatus);

                mDefaultNetworkReportRegistrants.notifyRegistrants(

                        new AsyncResult(null, mCarrierActionReportDefaultNetworkStatus, null));

                break;

            case CARRIER_ACTION_RESET:

            case CARRIER_ACTION_RESET:

                log("CARRIER_ACTION_RESET");

                log("CARRIER_ACTION_RESET");

                carrierActionReset();

                carrierActionReset();
@@ -170,17 +186,6 @@ public class CarrierActionAgent extends Handler { 
        }

        }

    }

    }





    /**

     * Return current carrier action values

     */

    public Object getCarrierActionValue(int action) {

        Object val = getCarrierAction(action);

        if (val == null) {

            throw new IllegalArgumentException("invalid carrier action: " + action);

        }

        return val;

    }



    /**

    /**

     * Action set from carrier app to enable/disable radio

     * Action set from carrier app to enable/disable radio

     */

     */
@@ -195,7 +200,15 @@ public class CarrierActionAgent extends Handler { 
        sendMessage(obtainMessage(CARRIER_ACTION_SET_METERED_APNS_ENABLED, enabled));

        sendMessage(obtainMessage(CARRIER_ACTION_SET_METERED_APNS_ENABLED, enabled));

    }

    }





    /**

     * Action set from carrier app to start/stop reporting default network status.

     */

    public void carrierActionReportDefaultNetworkStatus(boolean report) {

        sendMessage(obtainMessage(CARRIER_ACTION_REPORT_DEFAULT_NETWORK_STATUS, report));

    }



    private void carrierActionReset() {

    private void carrierActionReset() {

        carrierActionReportDefaultNetworkStatus(false);

        carrierActionSetMeteredApnsEnabled(true);

        carrierActionSetMeteredApnsEnabled(true);

        carrierActionSetRadioEnabled(true);

        carrierActionSetRadioEnabled(true);

        // notify configured carrier apps for reset

        // notify configured carrier apps for reset
@@ -209,18 +222,22 @@ public class CarrierActionAgent extends Handler { 
                return mMeteredApnEnableRegistrants;

                return mMeteredApnEnableRegistrants;

            case CARRIER_ACTION_SET_RADIO_ENABLED:

            case CARRIER_ACTION_SET_RADIO_ENABLED:

                return mRadioEnableRegistrants;

                return mRadioEnableRegistrants;

            case CARRIER_ACTION_REPORT_DEFAULT_NETWORK_STATUS:

                return mDefaultNetworkReportRegistrants;

            default:

            default:

                loge("Unsupported action: " + action);

                loge("Unsupported action: " + action);

                return null;

                return null;

        }

        }

    }

    }





    private Object getCarrierAction(int action) {

    private Boolean getCarrierActionEnabled(int action) {

        switch (action) {

        switch (action) {

            case CARRIER_ACTION_SET_METERED_APNS_ENABLED:

            case CARRIER_ACTION_SET_METERED_APNS_ENABLED:

                return mCarrierActionOnMeteredApnEnabled;

                return mCarrierActionOnMeteredApnEnabled;

            case CARRIER_ACTION_SET_RADIO_ENABLED:

            case CARRIER_ACTION_SET_RADIO_ENABLED:

                return mCarrierActionOnRadioEnabled;

                return mCarrierActionOnRadioEnabled;

            case CARRIER_ACTION_REPORT_DEFAULT_NETWORK_STATUS:

                return mCarrierActionReportDefaultNetworkStatus;

            default:

            default:

                loge("Unsupported action: " + action);

                loge("Unsupported action: " + action);

                return null;

                return null;
@@ -235,7 +252,7 @@ public class CarrierActionAgent extends Handler { 
     */

     */

    public void registerForCarrierAction(int action, Handler h, int what, Object obj,

    public void registerForCarrierAction(int action, Handler h, int what, Object obj,

                                         boolean notifyNow) {

                                         boolean notifyNow) {

        Object carrierAction = getCarrierAction(action);

        Boolean carrierAction = getCarrierActionEnabled(action);

        if (carrierAction == null) {

        if (carrierAction == null) {

            throw new IllegalArgumentException("invalid carrier action: " + action);

            throw new IllegalArgumentException("invalid carrier action: " + action);

        }

        }
@@ -287,5 +304,10 @@ public class CarrierActionAgent extends Handler { 
        ipw.increaseIndent();

        ipw.increaseIndent();

        mRadioEnabledLog.dump(fd, ipw, args);

        mRadioEnabledLog.dump(fd, ipw, args);

        ipw.decreaseIndent();

        ipw.decreaseIndent();



        pw.println(" mCarrierActionReportDefaultNetworkStatus Log:");

        ipw.increaseIndent();

        mReportDefaultNetworkStatusLog.dump(fd, ipw, args);

        ipw.decreaseIndent();

    }

    }

}
 
}

src/java/com/android/internal/telephony/CarrierSignalAgent.java

+70 −2
Original line number Original line Diff line number Diff line
@@ -22,6 +22,11 @@ import android.content.Context; 
import android.content.Intent;

import android.content.Intent;

import android.content.IntentFilter;

import android.content.IntentFilter;

import android.content.pm.PackageManager;

import android.content.pm.PackageManager;

import android.net.ConnectivityManager;

import android.net.Network;

import android.os.AsyncResult;

import android.os.Handler;

import android.os.Message;

import android.os.PersistableBundle;

import android.os.PersistableBundle;

import android.telephony.CarrierConfigManager;

import android.telephony.CarrierConfigManager;

import android.telephony.Rlog;

import android.telephony.Rlog;
@@ -49,7 +54,7 @@ import static android.telephony.CarrierConfigManager.KEY_CARRIER_APP_NO_WAKE_SIG 
 * repeated polling and send the intent to the interested receivers.

 * repeated polling and send the intent to the interested receivers.

 * Each CarrierSignalAgent is associated with a phone object.

 * Each CarrierSignalAgent is associated with a phone object.

 */

 */

public class CarrierSignalAgent {

public class CarrierSignalAgent extends Handler {





    private static final String LOG_TAG = CarrierSignalAgent.class.getSimpleName();

    private static final String LOG_TAG = CarrierSignalAgent.class.getSimpleName();

    private static final boolean DBG = true;

    private static final boolean DBG = true;
@@ -63,6 +68,7 @@ public class CarrierSignalAgent { 




    /** Member variables */

    /** Member variables */

    private final Phone mPhone;

    private final Phone mPhone;

    private boolean mDefaultNetworkAvail;





    /**

    /**

     * This is a map of intent action -> set of component name of statically registered

     * This is a map of intent action -> set of component name of statically registered
@@ -84,6 +90,8 @@ public class CarrierSignalAgent { 
     */

     */

    private Map<String, Set<ComponentName>> mCachedNoWakeSignalConfigs = new HashMap<>();

    private Map<String, Set<ComponentName>> mCachedNoWakeSignalConfigs = new HashMap<>();





    private static final int EVENT_REGISTER_DEFAULT_NETWORK_AVAIL = 0;



    /**

    /**

     * This is a list of supported signals from CarrierSignalAgent

     * This is a list of supported signals from CarrierSignalAgent

     */

     */
@@ -91,7 +99,8 @@ public class CarrierSignalAgent { 
            TelephonyIntents.ACTION_CARRIER_SIGNAL_PCO_VALUE,

            TelephonyIntents.ACTION_CARRIER_SIGNAL_PCO_VALUE,

            TelephonyIntents.ACTION_CARRIER_SIGNAL_REDIRECTED,

            TelephonyIntents.ACTION_CARRIER_SIGNAL_REDIRECTED,

            TelephonyIntents.ACTION_CARRIER_SIGNAL_REQUEST_NETWORK_FAILED,

            TelephonyIntents.ACTION_CARRIER_SIGNAL_REQUEST_NETWORK_FAILED,

            TelephonyIntents.ACTION_CARRIER_SIGNAL_RESET));

            TelephonyIntents.ACTION_CARRIER_SIGNAL_RESET,

            TelephonyIntents.ACTION_CARRIER_SIGNAL_DEFAULT_NETWORK_AVAILABLE));





    private final LocalLog mErrorLocalLog = new LocalLog(20);

    private final LocalLog mErrorLocalLog = new LocalLog(20);
@@ -105,6 +114,8 @@ public class CarrierSignalAgent { 
        }

        }

    };

    };





    private ConnectivityManager.NetworkCallback mNetworkCallback;



    /** Constructor */

    /** Constructor */

    public CarrierSignalAgent(Phone phone) {

    public CarrierSignalAgent(Phone phone) {

        mPhone = phone;

        mPhone = phone;
@@ -112,6 +123,61 @@ public class CarrierSignalAgent { 
        // reload configurations on CARRIER_CONFIG_CHANGED

        // reload configurations on CARRIER_CONFIG_CHANGED

        mPhone.getContext().registerReceiver(mReceiver,

        mPhone.getContext().registerReceiver(mReceiver,

                new IntentFilter(CarrierConfigManager.ACTION_CARRIER_CONFIG_CHANGED));

                new IntentFilter(CarrierConfigManager.ACTION_CARRIER_CONFIG_CHANGED));

        mPhone.getCarrierActionAgent().registerForCarrierAction(

                CarrierActionAgent.CARRIER_ACTION_REPORT_DEFAULT_NETWORK_STATUS, this,

                EVENT_REGISTER_DEFAULT_NETWORK_AVAIL, null, false);

    }



    @Override

    public void handleMessage(Message msg) {

        switch (msg.what) {

            case EVENT_REGISTER_DEFAULT_NETWORK_AVAIL:

                AsyncResult ar = (AsyncResult) msg.obj;

                if (ar.exception != null) {

                    Rlog.e(LOG_TAG, "Register default network exception: " + ar.exception);

                    return;

                }

                final ConnectivityManager connectivityMgr =  ConnectivityManager

                        .from(mPhone.getContext());

                if ((boolean) ar.result) {

                    mNetworkCallback = new ConnectivityManager.NetworkCallback() {

                        @Override

                        public void onAvailable(Network network) {

                            // an optimization to avoid signaling on every default network switch.

                            if (!mDefaultNetworkAvail) {

                                if (DBG) log("Default network available: " + network);

                                Intent intent = new Intent(TelephonyIntents

                                        .ACTION_CARRIER_SIGNAL_DEFAULT_NETWORK_AVAILABLE);

                                intent.putExtra(

                                        TelephonyIntents.EXTRA_DEFAULT_NETWORK_AVAILABLE_KEY, true);

                                notifyCarrierSignalReceivers(intent);

                                mDefaultNetworkAvail = true;

                            }

                        }

                        @Override

                        public void onLost(Network network) {

                            if (DBG) log("Default network lost: " + network);

                            Intent intent = new Intent(TelephonyIntents

                                    .ACTION_CARRIER_SIGNAL_DEFAULT_NETWORK_AVAILABLE);

                            intent.putExtra(

                                    TelephonyIntents.EXTRA_DEFAULT_NETWORK_AVAILABLE_KEY, false);

                            notifyCarrierSignalReceivers(intent);

                            mDefaultNetworkAvail = false;

                        }

                    };

                    connectivityMgr.registerDefaultNetworkCallback(mNetworkCallback, mPhone);

                    log("Register default network");



                } else if (mNetworkCallback != null) {

                    connectivityMgr.unregisterNetworkCallback(mNetworkCallback);

                    mNetworkCallback = null;

                    mDefaultNetworkAvail = false;

                    log("unregister default network");

                }

                break;

            default:

                break;

        }

    }

    }





    /**

    /**
@@ -316,6 +382,8 @@ public class CarrierSignalAgent { 
        }

        }

        ipw.decreaseIndent();

        ipw.decreaseIndent();





        pw.println("mDefaultNetworkAvail: " + mDefaultNetworkAvail);



        pw.println("error log:");

        pw.println("error log:");

        ipw.increaseIndent();

        ipw.increaseIndent();

        mErrorLocalLog.dump(fd, pw, args);

        mErrorLocalLog.dump(fd, pw, args);

src/java/com/android/internal/telephony/GsmCdmaPhone.java

+4 −0
Original line number Original line Diff line number Diff line
@@ -205,6 +205,10 @@ public class GsmCdmaPhone extends Phone { 
        mPrecisePhoneType = precisePhoneType;

        mPrecisePhoneType = precisePhoneType;

        initOnce(ci);

        initOnce(ci);

        initRatSpecific(precisePhoneType);

        initRatSpecific(precisePhoneType);

        // CarrierSignalAgent uses CarrierActionAgent in construction so it needs to be created

        // after CarrierActionAgent.

        mCarrierActionAgent = mTelephonyComponentFactory.makeCarrierActionAgent(this);

        mCarrierSignalAgent = mTelephonyComponentFactory.makeCarrierSignalAgent(this);

        mSST = mTelephonyComponentFactory.makeServiceStateTracker(this, this.mCi);

        mSST = mTelephonyComponentFactory.makeServiceStateTracker(this, this.mCi);

        // DcTracker uses SST so needs to be created after it is instantiated

        // DcTracker uses SST so needs to be created after it is instantiated

        mDcTracker = mTelephonyComponentFactory.makeDcTracker(this);

        mDcTracker = mTelephonyComponentFactory.makeDcTracker(this);

src/java/com/android/internal/telephony/Phone.java

+9 −4
Original line number Original line Diff line number Diff line
@@ -251,9 +251,9 @@ public abstract class Phone extends Handler implements PhoneInternalInterface { 
    private boolean mDnsCheckDisabled;

    private boolean mDnsCheckDisabled;

    public DcTracker mDcTracker;

    public DcTracker mDcTracker;

    /* Used for dispatching signals to configured carrier apps */

    /* Used for dispatching signals to configured carrier apps */

    private CarrierSignalAgent mCarrierSignalAgent;

    protected CarrierSignalAgent mCarrierSignalAgent;

    /* Used for dispatching carrier action from carrier apps */

    /* Used for dispatching carrier action from carrier apps */

    private CarrierActionAgent mCarrierActionAgent;

    protected CarrierActionAgent mCarrierActionAgent;

    private boolean mDoesRilSendMultipleCallRing;

    private boolean mDoesRilSendMultipleCallRing;

    private int mCallRingContinueToken;

    private int mCallRingContinueToken;

    private int mCallRingDelay;

    private int mCallRingDelay;
@@ -535,8 +535,6 @@ public abstract class Phone extends Handler implements PhoneInternalInterface { 
        mSmsUsageMonitor = mTelephonyComponentFactory.makeSmsUsageMonitor(context);

        mSmsUsageMonitor = mTelephonyComponentFactory.makeSmsUsageMonitor(context);

        mUiccController = UiccController.getInstance();

        mUiccController = UiccController.getInstance();

        mUiccController.registerForIccChanged(this, EVENT_ICC_CHANGED, null);

        mUiccController.registerForIccChanged(this, EVENT_ICC_CHANGED, null);

        mCarrierSignalAgent = mTelephonyComponentFactory.makeCarrierSignalAgent(this);

        mCarrierActionAgent = mTelephonyComponentFactory.makeCarrierActionAgent(this);

        mSimActivationTracker = mTelephonyComponentFactory.makeSimActivationTracker(this);

        mSimActivationTracker = mTelephonyComponentFactory.makeSimActivationTracker(this);

        if (getPhoneType() != PhoneConstants.PHONE_TYPE_SIP) {

        if (getPhoneType() != PhoneConstants.PHONE_TYPE_SIP) {

            mCi.registerForSrvccStateChanged(this, EVENT_SRVCC_STATE_CHANGED, null);

            mCi.registerForSrvccStateChanged(this, EVENT_SRVCC_STATE_CHANGED, null);
@@ -2823,6 +2821,13 @@ public abstract class Phone extends Handler implements PhoneInternalInterface { 
        mCarrierActionAgent.carrierActionSetRadioEnabled(enabled);

        mCarrierActionAgent.carrierActionSetRadioEnabled(enabled);

    }

    }





    /**

     * Action set from carrier app to start/stop reporting default network condition.

     */

    public void carrierActionReportDefaultNetworkStatus(boolean report) {

        mCarrierActionAgent.carrierActionReportDefaultNetworkStatus(report);

    }



    /**

    /**

     * Notify registrants of a new ringing Connection.

     * Notify registrants of a new ringing Connection.

     * Subclasses of Phone probably want to replace this with a

     * Subclasses of Phone probably want to replace this with a

tests/telephonytests/src/com/android/internal/telephony/CarrierActionAgentTest.java

+15 −4
Original line number Original line Diff line number Diff line
@@ -26,6 +26,7 @@ import static org.mockito.Mockito.verify; 
import android.content.Intent;

import android.content.Intent;

import android.database.ContentObserver;

import android.database.ContentObserver;

import android.net.Uri;

import android.net.Uri;

import android.os.AsyncResult;

import android.os.Handler;

import android.os.Handler;

import android.os.HandlerThread;

import android.os.HandlerThread;

import android.os.Message;

import android.os.Message;
@@ -106,13 +107,21 @@ public class CarrierActionAgentTest extends TelephonyTest { 
        mContext.sendBroadcast(intent);

        mContext.sendBroadcast(intent);

        waitForMs(200);

        waitForMs(200);





        // carrier actions triggered from sim loading

        // no carrier actions triggered from sim loading since there are same as the current one

        ArgumentCaptor<Message> message = ArgumentCaptor.forClass(Message.class);

        ArgumentCaptor<Message> message = ArgumentCaptor.forClass(Message.class);

        verify(mDataActionHandler).sendMessageAtTime(message.capture(), anyLong());

        verify(mDataActionHandler, times(0)).sendMessageAtTime(message.capture(), anyLong());

        assertEquals(DATA_CARRIER_ACTION_EVENT, message.getValue().what);

        verify(mRadioActionHandler, times(0)).sendMessageAtTime(message.capture(), anyLong());





        verify(mRadioActionHandler).sendMessageAtTime(message.capture(), anyLong());

        // disable metered apns and radio

        mCarrierActionAgentUT.carrierActionSetRadioEnabled(false);

        mCarrierActionAgentUT.carrierActionSetMeteredApnsEnabled(false);

        waitForMs(200);

        verify(mDataActionHandler, times(1)).sendMessageAtTime(message.capture(), anyLong());

        assertEquals(DATA_CARRIER_ACTION_EVENT, message.getValue().what);

        assertEquals(false, ((AsyncResult) message.getValue().obj).result);

        verify(mRadioActionHandler, times(1)).sendMessageAtTime(message.capture(), anyLong());

        assertEquals(RADIO_CARRIER_ACTION_EVENT, message.getValue().what);

        assertEquals(RADIO_CARRIER_ACTION_EVENT, message.getValue().what);

        assertEquals(false, ((AsyncResult) message.getValue().obj).result);





        // simulate APM change from off -> on

        // simulate APM change from off -> on

        Settings.Global.putInt(mFakeContentResolver, Settings.Global.AIRPLANE_MODE_ON, 1);

        Settings.Global.putInt(mFakeContentResolver, Settings.Global.AIRPLANE_MODE_ON, 1);
@@ -123,9 +132,11 @@ public class CarrierActionAgentTest extends TelephonyTest { 
        // carrier actions triggered from APM

        // carrier actions triggered from APM

        verify(mDataActionHandler, times(2)).sendMessageAtTime(message.capture(), anyLong());

        verify(mDataActionHandler, times(2)).sendMessageAtTime(message.capture(), anyLong());

        assertEquals(DATA_CARRIER_ACTION_EVENT, message.getValue().what);

        assertEquals(DATA_CARRIER_ACTION_EVENT, message.getValue().what);

        assertEquals(true, ((AsyncResult) message.getValue().obj).result);





        verify(mRadioActionHandler, times(2)).sendMessageAtTime(message.capture(), anyLong());

        verify(mRadioActionHandler, times(2)).sendMessageAtTime(message.capture(), anyLong());

        assertEquals(RADIO_CARRIER_ACTION_EVENT, message.getValue().what);

        assertEquals(RADIO_CARRIER_ACTION_EVENT, message.getValue().what);

        assertEquals(true, ((AsyncResult) message.getValue().obj).result);

    }

    }





    @After

    @After