Home | History | Annotate | Download | only in server 
      1 /*
      2  * Copyright (C) 2008 The Android Open Source Project
      3  *
      4  * Licensed under the Apache License, Version 2.0 (the "License");
      5  * you may not use this file except in compliance with the License.
      6  * You may obtain a copy of the License at
      7  *
      8  *      http://www.apache.org/licenses/LICENSE-2.0
      9  *
     10  * Unless required by applicable law or agreed to in writing, software
     11  * distributed under the License is distributed on an "AS IS" BASIS,
     12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     13  * See the License for the specific language governing permissions and
     14  * limitations under the License.
     15  */
     16 
     17 package com.android.server;
     18 
     19 import android.content.BroadcastReceiver;
     20 import android.content.Context;
     21 import android.content.Intent;
     22 import android.content.IntentFilter;
     23 import android.os.Handler;
     24 import android.os.Looper;
     25 import android.os.Message;
     26 import android.os.PowerManager;
     27 import android.os.PowerManager.WakeLock;
     28 import android.os.UEventObserver;
     29 import android.util.Slog;
     30 import android.media.AudioManager;
     31 import android.util.Log;
     32 import android.view.InputDevice;
     33 
     34 import com.android.internal.R;
     35 import com.android.server.input.InputManagerService;
     36 import com.android.server.input.InputManagerService.WiredAccessoryCallbacks;
     37 import static com.android.server.input.InputManagerService.SW_HEADPHONE_INSERT;
     38 import static com.android.server.input.InputManagerService.SW_MICROPHONE_INSERT;
     39 import static com.android.server.input.InputManagerService.SW_HEADPHONE_INSERT_BIT;
     40 import static com.android.server.input.InputManagerService.SW_MICROPHONE_INSERT_BIT;
     41 
     42 import java.io.File;
     43 import java.io.FileReader;
     44 import java.io.FileNotFoundException;
     45 import java.util.ArrayList;
     46 import java.util.List;
     47 import java.util.Locale;
     48 
     49 /**
     50  * <p>WiredAccessoryManager monitors for a wired headset on the main board or dock using
     51  * both the InputManagerService notifyWiredAccessoryChanged interface and the UEventObserver
     52  * subsystem.
     53  */
     54 final class WiredAccessoryManager implements WiredAccessoryCallbacks {
     55     private static final String TAG = WiredAccessoryManager.class.getSimpleName();
     56     private static final boolean LOG = true;
     57 
     58     private static final int BIT_HEADSET = (1 << 0);
     59     private static final int BIT_HEADSET_NO_MIC = (1 << 1);
     60     private static final int BIT_USB_HEADSET_ANLG = (1 << 2);
     61     private static final int BIT_USB_HEADSET_DGTL = (1 << 3);
     62     private static final int BIT_HDMI_AUDIO = (1 << 4);
     63     private static final int SUPPORTED_HEADSETS = (BIT_HEADSET|BIT_HEADSET_NO_MIC|
     64                                                    BIT_USB_HEADSET_ANLG|BIT_USB_HEADSET_DGTL|
     65                                                    BIT_HDMI_AUDIO);
     66 
     67     private static final String NAME_H2W = "h2w";
     68     private static final String NAME_USB_AUDIO = "usb_audio";
     69     private static final String NAME_HDMI_AUDIO = "hdmi_audio";
     70     private static final String NAME_HDMI = "hdmi";
     71 
     72     private static final int MSG_NEW_DEVICE_STATE = 1;
     73 
     74     private final Object mLock = new Object();
     75 
     76     private final WakeLock mWakeLock;  // held while there is a pending route change
     77     private final AudioManager mAudioManager;
     78 
     79     private int mHeadsetState;
     80 
     81     private int mSwitchValues;
     82 
     83     private final WiredAccessoryObserver mObserver;
     84     private final InputManagerService mInputManager;
     85 
     86     private final boolean mUseDevInputEventForAudioJack;
     87 
     88     public WiredAccessoryManager(Context context, InputManagerService inputManager) {
     89         PowerManager pm = (PowerManager)context.getSystemService(Context.POWER_SERVICE);
     90         mWakeLock = pm.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK, "WiredAccessoryManager");
     91         mWakeLock.setReferenceCounted(false);
     92         mAudioManager = (AudioManager)context.getSystemService(Context.AUDIO_SERVICE);
     93         mInputManager = inputManager;
     94 
     95         mUseDevInputEventForAudioJack =
     96                 context.getResources().getBoolean(R.bool.config_useDevInputEventForAudioJack);
     97 
     98         mObserver = new WiredAccessoryObserver();
     99 
    100         context.registerReceiver(new BroadcastReceiver() {
    101                     @Override
    102                     public void onReceive(Context ctx, Intent intent) {
    103                         bootCompleted();
    104                     }
    105                 },
    106                 new IntentFilter(Intent.ACTION_BOOT_COMPLETED), null, null);
    107     }
    108 
    109     private void bootCompleted() {
    110         if (mUseDevInputEventForAudioJack) {
    111             int switchValues = 0;
    112             if (mInputManager.getSwitchState(-1, InputDevice.SOURCE_ANY, SW_HEADPHONE_INSERT) == 1) {
    113                 switchValues |= SW_HEADPHONE_INSERT_BIT;
    114             }
    115             if (mInputManager.getSwitchState(-1, InputDevice.SOURCE_ANY, SW_MICROPHONE_INSERT) == 1) {
    116                 switchValues |= SW_MICROPHONE_INSERT_BIT;
    117             }
    118             notifyWiredAccessoryChanged(0, switchValues,
    119                     SW_HEADPHONE_INSERT_BIT | SW_MICROPHONE_INSERT_BIT);
    120         }
    121 
    122         mObserver.init();
    123     }
    124 
    125     @Override
    126     public void notifyWiredAccessoryChanged(long whenNanos, int switchValues, int switchMask) {
    127         if (LOG) Slog.v(TAG, "notifyWiredAccessoryChanged: when=" + whenNanos
    128                 + " bits=" + switchCodeToString(switchValues, switchMask)
    129                 + " mask=" + Integer.toHexString(switchMask));
    130 
    131         synchronized (mLock) {
    132             int headset;
    133             mSwitchValues = (mSwitchValues & ~switchMask) | switchValues;
    134             switch (mSwitchValues & (SW_HEADPHONE_INSERT_BIT | SW_MICROPHONE_INSERT_BIT)) {
    135                 case 0:
    136                     headset = 0;
    137                     break;
    138 
    139                 case SW_HEADPHONE_INSERT_BIT:
    140                     headset = BIT_HEADSET_NO_MIC;
    141                     break;
    142 
    143                 case SW_HEADPHONE_INSERT_BIT | SW_MICROPHONE_INSERT_BIT:
    144                     headset = BIT_HEADSET;
    145                     break;
    146 
    147                 case SW_MICROPHONE_INSERT_BIT:
    148                     headset = BIT_HEADSET;
    149                     break;
    150 
    151                 default:
    152                     headset = 0;
    153                     break;
    154             }
    155 
    156             updateLocked(NAME_H2W, (mHeadsetState & ~(BIT_HEADSET | BIT_HEADSET_NO_MIC)) | headset);
    157         }
    158     }
    159 
    160     /**
    161      * Compare the existing headset state with the new state and pass along accordingly. Note
    162      * that this only supports a single headset at a time. Inserting both a usb and jacked headset
    163      * results in support for the last one plugged in. Similarly, unplugging either is seen as
    164      * unplugging all.
    165      *
    166      * @param newName One of the NAME_xxx variables defined above.
    167      * @param newState 0 or one of the BIT_xxx variables defined above.
    168      */
    169     private void updateLocked(String newName, int newState) {
    170         // Retain only relevant bits
    171         int headsetState = newState & SUPPORTED_HEADSETS;
    172         int usb_headset_anlg = headsetState & BIT_USB_HEADSET_ANLG;
    173         int usb_headset_dgtl = headsetState & BIT_USB_HEADSET_DGTL;
    174         int h2w_headset = headsetState & (BIT_HEADSET | BIT_HEADSET_NO_MIC);
    175         boolean h2wStateChange = true;
    176         boolean usbStateChange = true;
    177         if (LOG) Slog.v(TAG, "newName=" + newName
    178                 + " newState=" + newState
    179                 + " headsetState=" + headsetState
    180                 + " prev headsetState=" + mHeadsetState);
    181 
    182         if (mHeadsetState == headsetState) {
    183             Log.e(TAG, "No state change.");
    184             return;
    185         }
    186 
    187         // reject all suspect transitions: only accept state changes from:
    188         // - a: 0 headset to 1 headset
    189         // - b: 1 headset to 0 headset
    190         if (h2w_headset == (BIT_HEADSET | BIT_HEADSET_NO_MIC)) {
    191             Log.e(TAG, "Invalid combination, unsetting h2w flag");
    192             h2wStateChange = false;
    193         }
    194         // - c: 0 usb headset to 1 usb headset
    195         // - d: 1 usb headset to 0 usb headset
    196         if (usb_headset_anlg == BIT_USB_HEADSET_ANLG && usb_headset_dgtl == BIT_USB_HEADSET_DGTL) {
    197             Log.e(TAG, "Invalid combination, unsetting usb flag");
    198             usbStateChange = false;
    199         }
    200         if (!h2wStateChange && !usbStateChange) {
    201             Log.e(TAG, "invalid transition, returning ...");
    202             return;
    203         }
    204 
    205         mWakeLock.acquire();
    206 
    207         Message msg = mHandler.obtainMessage(MSG_NEW_DEVICE_STATE, headsetState,
    208                 mHeadsetState, newName);
    209         mHandler.sendMessage(msg);
    210 
    211         mHeadsetState = headsetState;
    212     }
    213 
    214     private final Handler mHandler = new Handler(Looper.myLooper(), null, true) {
    215         @Override
    216         public void handleMessage(Message msg) {
    217             switch (msg.what) {
    218                 case MSG_NEW_DEVICE_STATE:
    219                     setDevicesState(msg.arg1, msg.arg2, (String)msg.obj);
    220                     mWakeLock.release();
    221             }
    222         }
    223     };
    224 
    225     private void setDevicesState(
    226             int headsetState, int prevHeadsetState, String headsetName) {
    227         synchronized (mLock) {
    228             int allHeadsets = SUPPORTED_HEADSETS;
    229             for (int curHeadset = 1; allHeadsets != 0; curHeadset <<= 1) {
    230                 if ((curHeadset & allHeadsets) != 0) {
    231                     setDeviceStateLocked(curHeadset, headsetState, prevHeadsetState, headsetName);
    232                     allHeadsets &= ~curHeadset;
    233                 }
    234             }
    235         }
    236     }
    237 
    238     private void setDeviceStateLocked(int headset,
    239             int headsetState, int prevHeadsetState, String headsetName) {
    240         if ((headsetState & headset) != (prevHeadsetState & headset)) {
    241             int device;
    242             int state;
    243 
    244             if ((headsetState & headset) != 0) {
    245                 state = 1;
    246             } else {
    247                 state = 0;
    248             }
    249 
    250             if (headset == BIT_HEADSET) {
    251                 device = AudioManager.DEVICE_OUT_WIRED_HEADSET;
    252             } else if (headset == BIT_HEADSET_NO_MIC){
    253                 device = AudioManager.DEVICE_OUT_WIRED_HEADPHONE;
    254             } else if (headset == BIT_USB_HEADSET_ANLG) {
    255                 device = AudioManager.DEVICE_OUT_ANLG_DOCK_HEADSET;
    256             } else if (headset == BIT_USB_HEADSET_DGTL) {
    257                 device = AudioManager.DEVICE_OUT_DGTL_DOCK_HEADSET;
    258             } else if (headset == BIT_HDMI_AUDIO) {
    259                 device = AudioManager.DEVICE_OUT_AUX_DIGITAL;
    260             } else {
    261                 Slog.e(TAG, "setDeviceState() invalid headset type: "+headset);
    262                 return;
    263             }
    264 
    265             if (LOG)
    266                 Slog.v(TAG, "device "+headsetName+((state == 1) ? " connected" : " disconnected"));
    267 
    268             mAudioManager.setWiredDeviceConnectionState(device, state, headsetName);
    269         }
    270     }
    271 
    272     private String switchCodeToString(int switchValues, int switchMask) {
    273         StringBuffer sb = new StringBuffer();
    274         if ((switchMask & SW_HEADPHONE_INSERT_BIT) != 0 &&
    275                 (switchValues & SW_HEADPHONE_INSERT_BIT) != 0) {
    276             sb.append("SW_HEADPHONE_INSERT ");
    277         }
    278         if ((switchMask & SW_MICROPHONE_INSERT_BIT) != 0 &&
    279                 (switchValues & SW_MICROPHONE_INSERT_BIT) != 0) {
    280             sb.append("SW_MICROPHONE_INSERT");
    281         }
    282         return sb.toString();
    283     }
    284 
    285     class WiredAccessoryObserver extends UEventObserver {
    286         private final List<UEventInfo> mUEventInfo;
    287 
    288         public WiredAccessoryObserver() {
    289             mUEventInfo = makeObservedUEventList();
    290         }
    291 
    292         void init() {
    293             synchronized (mLock) {
    294                 if (LOG) Slog.v(TAG, "init()");
    295                 char[] buffer = new char[1024];
    296 
    297                 for (int i = 0; i < mUEventInfo.size(); ++i) {
    298                     UEventInfo uei = mUEventInfo.get(i);
    299                     try {
    300                         int curState;
    301                         FileReader file = new FileReader(uei.getSwitchStatePath());
    302                         int len = file.read(buffer, 0, 1024);
    303                         file.close();
    304                         curState = Integer.valueOf((new String(buffer, 0, len)).trim());
    305 
    306                         if (curState > 0) {
    307                             updateStateLocked(uei.getDevPath(), uei.getDevName(), curState);
    308                         }
    309                     } catch (FileNotFoundException e) {
    310                         Slog.w(TAG, uei.getSwitchStatePath() +
    311                                 " not found while attempting to determine initial switch state");
    312                     } catch (Exception e) {
    313                         Slog.e(TAG, "" , e);
    314                     }
    315                 }
    316             }
    317 
    318             // At any given time accessories could be inserted
    319             // one on the board, one on the dock and one on HDMI:
    320             // observe three UEVENTs
    321             for (int i = 0; i < mUEventInfo.size(); ++i) {
    322                 UEventInfo uei = mUEventInfo.get(i);
    323                 startObserving("DEVPATH="+uei.getDevPath());
    324             }
    325         }
    326 
    327         private List<UEventInfo> makeObservedUEventList() {
    328             List<UEventInfo> retVal = new ArrayList<UEventInfo>();
    329             UEventInfo uei;
    330 
    331             // Monitor h2w
    332             if (!mUseDevInputEventForAudioJack) {
    333                 uei = new UEventInfo(NAME_H2W, BIT_HEADSET, BIT_HEADSET_NO_MIC);
    334                 if (uei.checkSwitchExists()) {
    335                     retVal.add(uei);
    336                 } else {
    337                     Slog.w(TAG, "This kernel does not have wired headset support");
    338                 }
    339             }
    340 
    341             // Monitor USB
    342             uei = new UEventInfo(NAME_USB_AUDIO, BIT_USB_HEADSET_ANLG, BIT_USB_HEADSET_DGTL);
    343             if (uei.checkSwitchExists()) {
    344                 retVal.add(uei);
    345             } else {
    346                 Slog.w(TAG, "This kernel does not have usb audio support");
    347             }
    348 
    349             // Monitor HDMI
    350             //
    351             // If the kernel has support for the "hdmi_audio" switch, use that.  It will be
    352             // signalled only when the HDMI driver has a video mode configured, and the downstream
    353             // sink indicates support for audio in its EDID.
    354             //
    355             // If the kernel does not have an "hdmi_audio" switch, just fall back on the older
    356             // "hdmi" switch instead.
    357             uei = new UEventInfo(NAME_HDMI_AUDIO, BIT_HDMI_AUDIO, 0);
    358             if (uei.checkSwitchExists()) {
    359                 retVal.add(uei);
    360             } else {
    361                 uei = new UEventInfo(NAME_HDMI, BIT_HDMI_AUDIO, 0);
    362                 if (uei.checkSwitchExists()) {
    363                     retVal.add(uei);
    364                 } else {
    365                     Slog.w(TAG, "This kernel does not have HDMI audio support");
    366                 }
    367             }
    368 
    369             return retVal;
    370         }
    371 
    372         @Override
    373         public void onUEvent(UEventObserver.UEvent event) {
    374             if (LOG) Slog.v(TAG, "Headset UEVENT: " + event.toString());
    375 
    376             try {
    377                 String devPath = event.get("DEVPATH");
    378                 String name = event.get("SWITCH_NAME");
    379                 int state = Integer.parseInt(event.get("SWITCH_STATE"));
    380                 synchronized (mLock) {
    381                     updateStateLocked(devPath, name, state);
    382                 }
    383             } catch (NumberFormatException e) {
    384                 Slog.e(TAG, "Could not parse switch state from event " + event);
    385             }
    386         }
    387 
    388         private void updateStateLocked(String devPath, String name, int state) {
    389             for (int i = 0; i < mUEventInfo.size(); ++i) {
    390                 UEventInfo uei = mUEventInfo.get(i);
    391                 if (devPath.equals(uei.getDevPath())) {
    392                     updateLocked(name, uei.computeNewHeadsetState(mHeadsetState, state));
    393                     return;
    394                 }
    395             }
    396         }
    397 
    398         private final class UEventInfo {
    399             private final String mDevName;
    400             private final int mState1Bits;
    401             private final int mState2Bits;
    402 
    403             public UEventInfo(String devName, int state1Bits, int state2Bits) {
    404                 mDevName = devName;
    405                 mState1Bits = state1Bits;
    406                 mState2Bits = state2Bits;
    407             }
    408 
    409             public String getDevName() { return mDevName; }
    410 
    411             public String getDevPath() {
    412                 return String.format(Locale.US, "/devices/virtual/switch/%s", mDevName);
    413             }
    414 
    415             public String getSwitchStatePath() {
    416                 return String.format(Locale.US, "/sys/class/switch/%s/state", mDevName);
    417             }
    418 
    419             public boolean checkSwitchExists() {
    420                 File f = new File(getSwitchStatePath());
    421                 return f.exists();
    422             }
    423 
    424             public int computeNewHeadsetState(int headsetState, int switchState) {
    425                 int preserveMask = ~(mState1Bits | mState2Bits);
    426                 int setBits = ((switchState == 1) ? mState1Bits :
    427                               ((switchState == 2) ? mState2Bits : 0));
    428 
    429                 return ((headsetState & preserveMask) | setBits);
    430             }
    431         }
    432     }
    433 }
    434