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

Commit 2602030a authored by Wink Saville's avatar Wink Saville Committed by Android (Google) Code Review
Browse files

Merge "Add protected log methods to StateMachine"

parents a0d089f2 58c73c3f
Loading
Loading
Loading
Loading
+0 −9
Original line number Diff line number Diff line
@@ -370,13 +370,4 @@ public class CaptivePortalTracker extends StateMachine {
        }
        mNotificationShown = visible;
    }

    private static void log(String s) {
        Log.d(TAG, s);
    }

    private static void loge(String s) {
        Log.e(TAG, s);
    }

}
+69 −48
Original line number Diff line number Diff line
@@ -148,7 +148,7 @@ class HelloWorld extends StateMachine {

    class State1 extends State {
        @Override public boolean processMessage(Message message) {
            Log.d(TAG, "Hello World");
            log("Hello World");
            return HANDLED;
        }
    }
@@ -232,8 +232,6 @@ state mP2 {
 * <p>The implementation is below and also in StateMachineTest:</p>
<code>
class Hsm1 extends StateMachine {
    private static final String TAG = "hsm1";

    public static final int CMD_1 = 1;
    public static final int CMD_2 = 2;
    public static final int CMD_3 = 3;
@@ -241,16 +239,16 @@ class Hsm1 extends StateMachine {
    public static final int CMD_5 = 5;

    public static Hsm1 makeHsm1() {
        Log.d(TAG, "makeHsm1 E");
        log("makeHsm1 E");
        Hsm1 sm = new Hsm1("hsm1");
        sm.start();
        Log.d(TAG, "makeHsm1 X");
        log("makeHsm1 X");
        return sm;
    }

    Hsm1(String name) {
        super(name);
        Log.d(TAG, "ctor E");
        log("ctor E");

        // Add states, use indentation to show hierarchy
        addState(mP1);
@@ -260,16 +258,16 @@ class Hsm1 extends StateMachine {

        // Set the initial state
        setInitialState(mS1);
        Log.d(TAG, "ctor X");
        log("ctor X");
    }

    class P1 extends State {
        &#64;Override public void enter() {
            Log.d(TAG, "mP1.enter");
            log("mP1.enter");
        }
        &#64;Override public boolean processMessage(Message message) {
            boolean retVal;
            Log.d(TAG, "mP1.processMessage what=" + message.what);
            log("mP1.processMessage what=" + message.what);
            switch(message.what) {
            case CMD_2:
                // CMD_2 will arrive in mS2 before CMD_3
@@ -286,16 +284,16 @@ class Hsm1 extends StateMachine {
            return retVal;
        }
        &#64;Override public void exit() {
            Log.d(TAG, "mP1.exit");
            log("mP1.exit");
        }
    }

    class S1 extends State {
        &#64;Override public void enter() {
            Log.d(TAG, "mS1.enter");
            log("mS1.enter");
        }
        &#64;Override public boolean processMessage(Message message) {
            Log.d(TAG, "S1.processMessage what=" + message.what);
            log("S1.processMessage what=" + message.what);
            if (message.what == CMD_1) {
                // Transition to ourself to show that enter/exit is called
                transitionTo(mS1);
@@ -306,17 +304,17 @@ class Hsm1 extends StateMachine {
            }
        }
        &#64;Override public void exit() {
            Log.d(TAG, "mS1.exit");
            log("mS1.exit");
        }
    }

    class S2 extends State {
        &#64;Override public void enter() {
            Log.d(TAG, "mS2.enter");
            log("mS2.enter");
        }
        &#64;Override public boolean processMessage(Message message) {
            boolean retVal;
            Log.d(TAG, "mS2.processMessage what=" + message.what);
            log("mS2.processMessage what=" + message.what);
            switch(message.what) {
            case(CMD_2):
                sendMessage(obtainMessage(CMD_4));
@@ -334,17 +332,17 @@ class Hsm1 extends StateMachine {
            return retVal;
        }
        &#64;Override public void exit() {
            Log.d(TAG, "mS2.exit");
            log("mS2.exit");
        }
    }

    class P2 extends State {
        &#64;Override public void enter() {
            Log.d(TAG, "mP2.enter");
            log("mP2.enter");
            sendMessage(obtainMessage(CMD_5));
        }
        &#64;Override public boolean processMessage(Message message) {
            Log.d(TAG, "P2.processMessage what=" + message.what);
            log("P2.processMessage what=" + message.what);
            switch(message.what) {
            case(CMD_3):
                break;
@@ -357,13 +355,13 @@ class Hsm1 extends StateMachine {
            return HANDLED;
        }
        &#64;Override public void exit() {
            Log.d(TAG, "mP2.exit");
            log("mP2.exit");
        }
    }

    &#64;Override
    void onHalting() {
        Log.d(TAG, "halting");
        log("halting");
        synchronized (this) {
            this.notifyAll();
        }
@@ -386,7 +384,7 @@ synchronize(hsm) {
          // wait for the messages to be handled
          hsm.wait();
     } catch (InterruptedException e) {
          Log.e(TAG, "exception while waiting " + e.getMessage());
          loge("exception while waiting " + e.getMessage());
     }
}
</code>
@@ -418,8 +416,7 @@ D/hsm1 ( 1999): halting
</code>
 */
public class StateMachine {

    private static final String TAG = "StateMachine";
    // Name of the state machine and used as logging tag
    private String mName;

    /** Message.what value when quitting */
@@ -772,7 +769,7 @@ public class StateMachine {
         */
        @Override
        public final void handleMessage(Message msg) {
            if (mDbg) Log.d(TAG, "handleMessage: E msg.what=" + msg.what);
            if (mDbg) mSm.log("handleMessage: E msg.what=" + msg.what);

            /** Save the current message */
            mMsg = msg;
@@ -793,7 +790,7 @@ public class StateMachine {
            }
            performTransitions(msgProcessedState);

            if (mDbg) Log.d(TAG, "handleMessage: X");
            if (mDbg) mSm.log("handleMessage: X");
        }

        /**
@@ -813,7 +810,7 @@ public class StateMachine {
            boolean recordLogMsg = mSm.recordLogRec(mMsg);

            while (mDestState != null) {
                if (mDbg) Log.d(TAG, "handleMessage: new destination call exit");
                if (mDbg) mSm.log("handleMessage: new destination call exit");

                /**
                 * Save mDestState locally and set to null
@@ -905,7 +902,7 @@ public class StateMachine {
         * Complete the construction of the state machine.
         */
        private final void completeConstruction() {
            if (mDbg) Log.d(TAG, "completeConstruction: E");
            if (mDbg) mSm.log("completeConstruction: E");

            /**
             * Determine the maximum depth of the state hierarchy
@@ -921,7 +918,7 @@ public class StateMachine {
                    maxDepth = depth;
                }
            }
            if (mDbg) Log.d(TAG, "completeConstruction: maxDepth=" + maxDepth);
            if (mDbg) mSm.log("completeConstruction: maxDepth=" + maxDepth);

            mStateStack = new StateInfo[maxDepth];
            mTempStateStack = new StateInfo[maxDepth];
@@ -930,7 +927,7 @@ public class StateMachine {
            /** Sending SM_INIT_CMD message to invoke enter methods asynchronously */
            sendMessageAtFrontOfQueue(obtainMessage(SM_INIT_CMD, mSmHandlerObj));

            if (mDbg) Log.d(TAG, "completeConstruction: X");
            if (mDbg) mSm.log("completeConstruction: X");
        }

        /**
@@ -942,7 +939,7 @@ public class StateMachine {
        private final State processMsg(Message msg) {
            StateInfo curStateInfo = mStateStack[mStateStackTopIndex];
            if (mDbg) {
                Log.d(TAG, "processMsg: " + curStateInfo.state.getName());
                mSm.log("processMsg: " + curStateInfo.state.getName());
            }

            if (isQuit(msg)) {
@@ -961,7 +958,7 @@ public class StateMachine {
                        break;
                    }
                    if (mDbg) {
                        Log.d(TAG, "processMsg: " + curStateInfo.state.getName());
                        mSm.log("processMsg: " + curStateInfo.state.getName());
                    }
                }
           }
@@ -976,7 +973,7 @@ public class StateMachine {
            while ((mStateStackTopIndex >= 0) &&
                    (mStateStack[mStateStackTopIndex] != commonStateInfo)) {
                State curState = mStateStack[mStateStackTopIndex].state;
                if (mDbg) Log.d(TAG, "invokeExitMethods: " + curState.getName());
                if (mDbg) mSm.log("invokeExitMethods: " + curState.getName());
                curState.exit();
                mStateStack[mStateStackTopIndex].active = false;
                mStateStackTopIndex -= 1;
@@ -988,7 +985,7 @@ public class StateMachine {
         */
        private final void invokeEnterMethods(int stateStackEnteringIndex) {
            for (int i = stateStackEnteringIndex; i <= mStateStackTopIndex; i++) {
                if (mDbg) Log.d(TAG, "invokeEnterMethods: " + mStateStack[i].state.getName());
                if (mDbg) mSm.log("invokeEnterMethods: " + mStateStack[i].state.getName());
                mStateStack[i].state.enter();
                mStateStack[i].active = true;
            }
@@ -1006,7 +1003,7 @@ public class StateMachine {
             */
            for (int i = mDeferredMessages.size() - 1; i >= 0; i-- ) {
                Message curMsg = mDeferredMessages.get(i);
                if (mDbg) Log.d(TAG, "moveDeferredMessageAtFrontOfQueue; what=" + curMsg.what);
                if (mDbg) mSm.log("moveDeferredMessageAtFrontOfQueue; what=" + curMsg.what);
                sendMessageAtFrontOfQueue(curMsg);
            }
            mDeferredMessages.clear();
@@ -1024,7 +1021,7 @@ public class StateMachine {
            int i = mTempStateStackCount - 1;
            int j = startingIndex;
            while (i >= 0) {
                if (mDbg) Log.d(TAG, "moveTempStackToStateStack: i=" + i + ",j=" + j);
                if (mDbg) mSm.log("moveTempStackToStateStack: i=" + i + ",j=" + j);
                mStateStack[j] = mTempStateStack[i];
                j += 1;
                i -= 1;
@@ -1032,7 +1029,7 @@ public class StateMachine {

            mStateStackTopIndex = j - 1;
            if (mDbg) {
                Log.d(TAG, "moveTempStackToStateStack: X mStateStackTop="
                mSm.log("moveTempStackToStateStack: X mStateStackTop="
                      + mStateStackTopIndex + ",startingIndex=" + startingIndex
                      + ",Top=" + mStateStack[mStateStackTopIndex].state.getName());
            }
@@ -1065,7 +1062,7 @@ public class StateMachine {
            } while ((curStateInfo != null) && !curStateInfo.active);

            if (mDbg) {
                Log.d(TAG, "setupTempStateStackWithStatesToEnter: X mTempStateStackCount="
                mSm.log("setupTempStateStackWithStatesToEnter: X mTempStateStackCount="
                      + mTempStateStackCount + ",curStateInfo: " + curStateInfo);
            }
            return curStateInfo;
@@ -1076,7 +1073,7 @@ public class StateMachine {
         */
        private final void setupInitialStateStack() {
            if (mDbg) {
                Log.d(TAG, "setupInitialStateStack: E mInitialState="
                mSm.log("setupInitialStateStack: E mInitialState="
                    + mInitialState.getName());
            }

@@ -1117,7 +1114,7 @@ public class StateMachine {
         */
        private final StateInfo addState(State state, State parent) {
            if (mDbg) {
                Log.d(TAG, "addStateInternal: E state=" + state.getName()
                mSm.log("addStateInternal: E state=" + state.getName()
                        + ",parent=" + ((parent == null) ? "" : parent.getName()));
            }
            StateInfo parentStateInfo = null;
@@ -1142,7 +1139,7 @@ public class StateMachine {
            stateInfo.state = state;
            stateInfo.parentStateInfo = parentStateInfo;
            stateInfo.active = false;
            if (mDbg) Log.d(TAG, "addStateInternal: X stateInfo: " + stateInfo);
            if (mDbg) mSm.log("addStateInternal: X stateInfo: " + stateInfo);
            return stateInfo;
        }

@@ -1162,19 +1159,19 @@ public class StateMachine {

        /** @see StateMachine#setInitialState(State) */
        private final void setInitialState(State initialState) {
            if (mDbg) Log.d(TAG, "setInitialState: initialState=" + initialState.getName());
            if (mDbg) mSm.log("setInitialState: initialState=" + initialState.getName());
            mInitialState = initialState;
        }

        /** @see StateMachine#transitionTo(IState) */
        private final void transitionTo(IState destState) {
            mDestState = (State) destState;
            if (mDbg) Log.d(TAG, "transitionTo: destState=" + mDestState.getName());
            if (mDbg) mSm.log("transitionTo: destState=" + mDestState.getName());
        }

        /** @see StateMachine#deferMessage(Message) */
        private final void deferMessage(Message msg) {
            if (mDbg) Log.d(TAG, "deferMessage: msg=" + msg.what);
            if (mDbg) mSm.log("deferMessage: msg=" + msg.what);

            /* Copy the "msg" to "newMsg" as "msg" will be recycled */
            Message newMsg = obtainMessage();
@@ -1185,17 +1182,17 @@ public class StateMachine {

        /** @see StateMachine#quit() */
        private final void quit() {
            if (mDbg) Log.d(TAG, "quit:");
            if (mDbg) mSm.log("quit:");
            sendMessage(obtainMessage(SM_QUIT_CMD, mSmHandlerObj));
        }

        /** @see StateMachine#quitNow() */
        private final void quitNow() {
            if (mDbg) Log.d(TAG, "abort:");
            if (mDbg) mSm.log("quitNow:");
            sendMessageAtFrontOfQueue(obtainMessage(SM_QUIT_CMD, mSmHandlerObj));
        }

        /** Validate that the message was sent by quit or abort. */
        /** Validate that the message was sent by quit or quitNow. */
        private final boolean isQuit(Message msg) {
            return (msg.what == SM_QUIT_CMD) && (msg.obj == mSmHandlerObj);
        }
@@ -1337,7 +1334,7 @@ public class StateMachine {
     * @param msg that couldn't be handled.
     */
    protected void unhandledMessage(Message msg) {
        if (mSmHandler.mDbg) Log.e(TAG, mName + " - unhandledMessage: msg.what=" + msg.what);
        if (mSmHandler.mDbg) loge(" - unhandledMessage: msg.what=" + msg.what);
    }

    /**
@@ -1696,4 +1693,28 @@ public class StateMachine {
        }
        pw.println("curState=" + getCurrentState().getName());
    }

    protected void log(String s) {
        Log.d(mName, s);
    }

    protected void logv(String s) {
        Log.v(mName, s);
    }

    protected void logi(String s) {
        Log.i(mName, s);
    }

    protected void logd(String s) {
        Log.d(mName, s);
    }

    protected void logw(String s) {
        Log.w(mName, s);
    }

    protected void loge(String s) {
        Log.e(mName, s);
    }
}
+5 −14
Original line number Diff line number Diff line
@@ -103,7 +103,6 @@ import java.util.regex.Pattern;
 */
public class WifiStateMachine extends StateMachine {

    private static final String TAG = "WifiStateMachine";
    private static final String NETWORKTYPE = "WIFI";
    private static final boolean DBG = false;

@@ -565,7 +564,7 @@ public class WifiStateMachine extends StateMachine {
    private final IBatteryStats mBatteryStats;

    public WifiStateMachine(Context context, String wlanInterface) {
        super(TAG);
        super("WifiStateMachine");

        mContext = context;
        mInterfaceName = wlanInterface;
@@ -678,7 +677,7 @@ public class WifiStateMachine extends StateMachine {
        mScanResultCache = new LruCache<String, ScanResult>(SCAN_RESULT_CACHE_SIZE);

        PowerManager powerManager = (PowerManager)mContext.getSystemService(Context.POWER_SERVICE);
        mWakeLock = powerManager.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK, TAG);
        mWakeLock = powerManager.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK, getName());

        mSuspendWakeLock = powerManager.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK, "WifiSuspend");
        mSuspendWakeLock.setReferenceCounted(false);
@@ -3132,14 +3131,14 @@ public class WifiStateMachine extends StateMachine {
                            break;
                        default:
                            result = new WpsResult(Status.FAILURE);
                            Log.e(TAG, "Invalid setup for WPS");
                            loge("Invalid setup for WPS");
                            break;
                    }
                    if (result.status == Status.SUCCESS) {
                        replyToMessage(message, WifiManager.START_WPS_SUCCEEDED, result);
                        transitionTo(mWpsRunningState);
                    } else {
                        Log.e(TAG, "Failed to start WPS with config " + wpsInfo.toString());
                        loge("Failed to start WPS with config " + wpsInfo.toString());
                        replyToMessage(message, WifiManager.WPS_FAILED, WifiManager.ERROR);
                    }
                    break;
@@ -3465,7 +3464,7 @@ public class WifiStateMachine extends StateMachine {
        public void exit() {
            /* Request a CS wakelock during transition to mobile */
            checkAndSetConnectivityInstance();
            mCm.requestNetworkTransitionWakelock(TAG);
            mCm.requestNetworkTransitionWakelock(getName());
        }
    }

@@ -4040,12 +4039,4 @@ public class WifiStateMachine extends StateMachine {
        msg.arg2 = srcMsg.arg2;
        return msg;
    }

    private void log(String s) {
        Log.d(TAG, s);
    }

    private void loge(String s) {
        Log.e(TAG, s);
    }
}
+1 −10
Original line number Diff line number Diff line
@@ -77,7 +77,6 @@ public class WifiWatchdogStateMachine extends StateMachine {

    /* STOPSHIP: Keep this configurable for debugging until ship */
    private static boolean DBG = false;
    private static final String TAG = "WifiWatchdogStateMachine";

    private static final int BASE = Protocol.BASE_WIFI_WATCHDOG;

@@ -306,7 +305,7 @@ public class WifiWatchdogStateMachine extends StateMachine {
     *                       (all other states)
     */
    private WifiWatchdogStateMachine(Context context) {
        super(TAG);
        super("WifiWatchdogStateMachine");
        mContext = context;
        mContentResolver = context.getContentResolver();
        mWifiManager = (WifiManager) context.getSystemService(Context.WIFI_SERVICE);
@@ -968,14 +967,6 @@ public class WifiWatchdogStateMachine extends StateMachine {
        return Settings.Global.putInt(cr, name, value ? 1 : 0);
    }

    private static void logd(String s) {
        Log.d(TAG, s);
    }

    private static void loge(String s) {
        Log.e(TAG, s);
    }

    /**
     * Bundle of good link count parameters
     */
+4 −2
Original line number Diff line number Diff line
@@ -2460,11 +2460,13 @@ public class WifiP2pService extends IWifiP2pManager.Stub {
        return msg;
    }

    private void logd(String s) {
    @Override
    protected void logd(String s) {
        Slog.d(TAG, s);
    }

    private void loge(String s) {
    @Override
    protected void loge(String s) {
        Slog.e(TAG, s);
    }