Java Code Examples for android.os.RemoteException

@Override public void onServiceConnected(final ComponentName classname,final IBinder obj){
  mService=IMediaPlaybackService.Stub.asInterface(obj);
  try {
    if (Utils.isNotEmpty(mService.getPath())) {
      podcastPlayer.setVisibility(View.VISIBLE);
      updateTrackInfo();
      refreshNow();
      return;
    }
 else {
      podcastPlayer.setVisibility(View.GONE);
    }
  }
 catch (  final RemoteException ex) {
  }
}
 

private void showDebugInfoForAuthAgent(){
  Log.d(TAG,"authAgent=" + authAgent);
  try {
    Log.d(TAG,"authAgent.getIdentities()=" + authAgent.getIdentities());
  }
 catch (  RemoteException e) {
    e.printStackTrace();
  }
}
 

/** 
 * Try running the request directly if the service is already connected.
 * @return true if the request ran successfully; false if the serviceis not connected or there was an error when trying to use it
 */
public boolean runIfConnected(){
  if (mService != null) {
    try {
      mRequestId=run();
      if (Consts.DEBUG) {
        Log.d(getClass().getSimpleName(),"request id: " + mRequestId);
      }
      if (mRequestId >= 0) {
        mSentRequests.put(mRequestId,this);
      }
      return true;
    }
 catch (    RemoteException e) {
      onRemoteException(e);
    }
  }
  return false;
}
 

/** 
 * Parse the given  {@link XmlPullParser}, turning into a series of {@link ContentProviderOperation} that are immediately applied using thegiven  {@link ContentResolver}.
 */
public void parseAndApply(XmlPullParser parser,ContentResolver resolver) throws XmlPullParserException, IOException {
  try {
    final ArrayList<ContentProviderOperation> batch=parse(parser,resolver);
    resolver.applyBatch(mAuthority,batch);
  }
 catch (  RemoteException e) {
    LOGW(LOG_TAG,"Problem applying batch operation",e);
  }
catch (  OperationApplicationException e) {
    LOGW(LOG_TAG,"Problem applying batch operation",e);
  }
}
 

public void openInPhone(final String openInPhoneAction) throws RemoteException {
  mCallbackHandler.post(new Runnable(){
    public void run(){
      LiveViewService.this.openInPhone(openInPhoneAction);
    }
  }
);
}
 

/** 
 * Start the channel sync process by sending out fetch requests.
 */
@Override public void start(){
  Cursor cursor=resolver.query(Roster.CONTENT_URI,Roster.PROJECTION_MAP,null,null,null);
  if (cursor.moveToFirst()) {
    while (!cursor.isAfterLast()) {
      String node=cursor.getString(cursor.getColumnIndex(Roster.JID));
      Long lastUpdate=cursor.getLong(cursor.getColumnIndex(Roster.LAST_UPDATED));
      roster.put(node,lastUpdate == null ? 0l : lastUpdate);
      cursor.moveToNext();
    }
  }
  cursor.close();
  PubSub pubsub=new PubSub();
  pubsub.setTo("broadcaster.buddycloud.com");
  SubscriptionsExtension subscription=new SubscriptionsExtension(null);
  pubsub.addExtension(subscription);
  try {
    String fullJid=client.getFullJidByBare(via);
    pubsub.setFrom(fullJid);
    send(pubsub,1);
  }
 catch (  RemoteException e) {
    e.printStackTrace();
  }
}
 

private void refreshAddress(){
  addressAdapter.clear();
  SharedPreferences pref=getSharedPreferences(ContextConstants.PREFS_ADDRESS,0);
  Map<String,String> list=(Map<String,String>)pref.getAll();
  for (  Map.Entry<String,String> entry : list.entrySet()) {
    ContextListItem item=new ContextListItem();
    item.setName(entry.getKey());
    double proximity=0;
    try {
      proximity=mService.proximityToAddress(entry.getValue());
    }
 catch (    RemoteException e) {
      e.printStackTrace();
    }
    item.setValue(String.valueOf(proximity));
    addressAdapter.add(item);
  }
  addressAdapter.notifyDataSetChanged();
}
 

public CursorWindow getWindow(int startPos) throws RemoteException {
  Parcel data=Parcel.obtain();
  Parcel reply=Parcel.obtain();
  data.writeInterfaceToken(IBulkCursor.descriptor);
  data.writeInt(startPos);
  mRemote.transact(GET_CURSOR_WINDOW_TRANSACTION,data,reply,0);
  DatabaseUtils.readExceptionFromParcel(reply);
  CursorWindow window=null;
  if (reply.readInt() == 1) {
    window=CursorWindow.newFromParcel(reply);
  }
  data.recycle();
  reply.recycle();
  return window;
}
 

/** 
 * Try running the request directly if the service is already connected.
 * @return true if the request ran successfully; false if the service is not connected orthere was an error when trying to use it
 */
public boolean runIfConnected(){
  if (Consts.DEBUG) {
    Log.d(TAG,getClass().getSimpleName());
  }
  if (mService != null) {
    try {
      mRequestId=run();
      if (Consts.DEBUG) {
        Log.d(TAG,"request id: " + mRequestId);
      }
      if (mRequestId >= 0) {
        mSentRequests.put(mRequestId,this);
      }
      return true;
    }
 catch (    RemoteException e) {
      onRemoteException(e);
    }
  }
  return false;
}
 

private void refreshToken(){
  Bundle requestData=new Bundle();
  requestData.putString(TOKEN,mAccessToken);
  Message request=Message.obtain();
  request.setData(requestData);
  request.replyTo=messageReceiver;
  try {
    messageSender.send(request);
  }
 catch (  RemoteException e) {
    serviceListener.onError(new Error("Service connection error"));
  }
}
 

public void execute(){
  if (mOperations.size() == 0) {
    return;
  }
  try {
    mResolver.applyBatch(ContactsContract.AUTHORITY,mOperations);
  }
 catch (  final OperationApplicationException e1) {
    Log.e(TAG,"storing contact data failed",e1);
  }
catch (  final RemoteException e2) {
    Log.e(TAG,"storing contact data failed",e2);
  }
  mOperations.clear();
}
 

private void refreshToken(){
  Bundle requestData=new Bundle();
  requestData.putString(TOKEN,mAccessToken);
  Message request=Message.obtain();
  request.setData(requestData);
  request.replyTo=messageReceiver;
  try {
    messageSender.send(request);
  }
 catch (  RemoteException e) {
    serviceListener.onError(new Error("Service connection error"));
  }
}
 

/** 
 * Adds a word to the dictionary and makes it persistent.
 * @param word the word to add. If the word is capitalized, then the dictionary willrecognize it as a capitalized word when searched.
 * @param frequency the frequency of occurrence of the word. A frequency of 255 is consideredthe highest.
 * @TODO use a higher or float range for frequency
 */
@Override public synchronized void addWord(final String word,final int frequency){
  if (getRequiresReload())   loadDictionaryAsync();
  if (word.length() >= getMaxWordLength())   return;
  super.addWord(word,frequency);
  final ContentValues values=new ContentValues(5);
  values.put(Words.WORD,word);
  values.put(Words.FREQUENCY,frequency);
  values.put(Words.LOCALE,mLocale);
  values.put(Words.APP_ID,0);
  final ContentResolver contentResolver=getContext().getContentResolver();
  final ContentProviderClient client=contentResolver.acquireContentProviderClient(Words.CONTENT_URI);
  if (null == client)   return;
  new Thread("addWord"){
    @Override public void run(){
      Cursor cursor=null;
      try {
        cursor=client.query(Words.CONTENT_URI,PROJECTION_ADD,"word=? and ((locale IS NULL) or (locale=?))",new String[]{word,mLocale},null);
        if (cursor != null && cursor.moveToFirst()) {
          final String locale=cursor.getString(cursor.getColumnIndex(Words.LOCALE));
          if (locale != null && locale.equals(mLocale.toString())) {
            final long id=cursor.getLong(cursor.getColumnIndex(Words._ID));
            final Uri uri=Uri.withAppendedPath(Words.CONTENT_URI,Long.toString(id));
            client.update(uri,values,null,null);
          }
        }
 else {
          client.insert(Words.CONTENT_URI,values);
        }
      }
 catch (      RemoteException e) {
      }
 finally {
        if (null != cursor)         cursor.close();
        client.release();
      }
    }
  }
.start();
  setRequiresReload(false);
}
 

public void disconnect(){
  ServiceConnection c=new ServiceConnection(){
    public void onServiceConnected(    ComponentName className,    IBinder service){
      try {
        IVpnService.Stub.asInterface(service).disconnect();
      }
 catch (      RemoteException e) {
        Log.e(TAG,"disconnect()",e);
        checkStatus();
      }
 finally {
        mContext.unbindService(this);
      }
    }
    public void onServiceDisconnected(    ComponentName className){
      checkStatus();
    }
  }
;
  if (!bindService(c)) {
    checkStatus();
  }
}
 

public long run(IMarketBillingService mService) throws RemoteException {
  final Bundle request=makeRequestBundle();
  addParams(request);
  final Bundle response;
  try {
    response=mService.sendBillingRequest(request);
  }
 catch (  NullPointerException e) {
    Log.e(this.getClass().getSimpleName(),"Known IAB bug. See: http://code.google.com/p/marketbilling/issues/detail?id=25",e);
    return IGNORE_REQUEST_ID;
  }
  if (validateResponse(response)) {
    processOkResponse(response);
    return response.getLong(KEY_REQUEST_ID,IGNORE_REQUEST_ID);
  }
 else {
    return IGNORE_REQUEST_ID;
  }
}
 

public void execute(){
  if (mOperations.size() == 0) {
    return;
  }
  try {
    mResolver.applyBatch(ContactsContract.AUTHORITY,mOperations);
  }
 catch (  final OperationApplicationException e1) {
    Log.e(TAG,"storing contact data failed",e1);
  }
catch (  final RemoteException e2) {
    Log.e(TAG,"storing contact data failed",e2);
  }
  mOperations.clear();
}
 

@Override public void onClick(View v){
  try {
    Log.i("ServerContainer","start TCP server container");
    mService.start();
  }
 catch (  RemoteException e) {
    e.printStackTrace();
  }
}
 

void init(){
  try {
    mInstallLocation=mPm.getInstallLocation();
  }
 catch (  RemoteException e) {
    Log.e("CanBeOnSdCardChecker","Is Package Manager running?");
    return;
  }
}
 

/** 
 * @return true if the phone is a CDMA phone type
 */
private static boolean phoneIsCdma(){
  boolean isCdma=false;
  try {
    ITelephony phone=ITelephony.Stub.asInterface(ServiceManager.checkService("phone"));
    if (phone != null) {
      isCdma=(phone.getActivePhoneType() == TelephonyManager.PHONE_TYPE_CDMA);
    }
  }
 catch (  RemoteException e) {
    Log.w(TAG,"phone.getActivePhoneType() failed",e);
  }
  return isCdma;
}
 

@Override protected void onCreate(Bundle savedInstanceState){
  super.onCreate(savedInstanceState);
  mPm=IPackageManager.Stub.asInterface(ServiceManager.getService("package"));
  if (mPm == null) {
    Log.wtf(LOG_TAG,"Unable to get PackageManager!");
  }
  setTitle(R.string.application_settings_title_subhead);
  addPreferencesFromResource(R.xml.application_settings);
  PreferenceScreen prefSet=getPreferenceScreen();
  mInstallLocationPref=(ListPreference)prefSet.findPreference(INSTALL_LOCATION_PREF);
  String installLocation="0";
  try {
    installLocation=String.valueOf(mPm.getInstallLocation());
  }
 catch (  RemoteException e) {
    Log.e(LOG_TAG,"Unable to get default install location!",e);
  }
  mInstallLocationPref.setValue(installLocation);
  mInstallLocationPref.setOnPreferenceChangeListener(this);
  mSwitchStoragePref=(CheckBoxPreference)prefSet.findPreference(SWITCH_STORAGE_PREF);
  mSwitchStoragePref.setChecked((SystemProperties.getInt("persist.sys.vold.switchexternal",0) == 1));
  if (SystemProperties.get("ro.vold.switchablepair","").equals("")) {
    mSwitchStoragePref.setSummaryOff(R.string.pref_storage_switch_unavailable);
    mSwitchStoragePref.setEnabled(false);
  }
  mMoveAllAppsPref=(CheckBoxPreference)prefSet.findPreference(MOVE_ALL_APPS_PREF);
  mMoveAllAppsPref.setChecked(Settings.Secure.getInt(getContentResolver(),Settings.Secure.ALLOW_MOVE_ALL_APPS_EXTERNAL,0) == 1);
  mEnableManagement=(CheckBoxPreference)prefSet.findPreference(ENABLE_PERMISSIONS_MANAGEMENT);
  mEnableManagement.setChecked(Settings.Secure.getInt(getContentResolver(),Settings.Secure.ENABLE_PERMISSIONS_MANAGEMENT,getResources().getBoolean(com.android.internal.R.bool.config_enablePermissionsManagement) ? 1 : 0) == 1);
  mEnableManagement.setOnPreferenceChangeListener(this);
}
 

/** 
 * We apply the batch of CPO's here.  We synchronize on the service to avoid thread-nasties, and we just return quickly if the service has already been stopped.
 */
private ContentProviderResult[] execute(String authority,ArrayList<ContentProviderOperation> ops) throws RemoteException, OperationApplicationException {
synchronized (mService.getSynchronizer()) {
    if (!mService.isStopped()) {
      if (!ops.isEmpty()) {
        ContentProviderResult[] result=mContentResolver.applyBatch(authority,ops);
        mService.userLog("Results: " + result.length);
        return result;
      }
    }
  }
  return new ContentProviderResult[0];
}
 

public boolean performOperation(final int operation,final ArrayList<MediaBucket> mediaBuckets,final Object data){
  try {
    if (operation == MediaFeed.OPERATION_DELETE) {
      ContentProviderClient client=mProviderClient;
      for (int i=0, numBuckets=mediaBuckets.size(); i != numBuckets; ++i) {
        MediaBucket bucket=mediaBuckets.get(i);
        ArrayList<MediaItem> items=bucket.mediaItems;
        if (items == null) {
          String albumUri=PicasaContentProvider.ALBUMS_URI + "/" + bucket.mediaSet.mId;
          client.delete(Uri.parse(albumUri),null,null);
        }
 else {
          for (int j=0, numItems=items.size(); j != numItems; ++j) {
            MediaItem item=items.get(j);
            if (item != null) {
              String itemUri=PicasaContentProvider.PHOTOS_URI + "/" + item.mId;
              client.delete(Uri.parse(itemUri),null,null);
            }
          }
        }
      }
    }
    return true;
  }
 catch (  RemoteException e) {
    return false;
  }
}
 

/** 
 * Tells the ActivityManager to resume allowing app switches. If the current app called stopAppSwitches() then our startActivity() can be delayed for several seconds. This happens with the default home screen.  As a system service we can override this behavior with resumeAppSwitches().
 */
void resumeAppSwitches(){
  try {
    mIActivityManager.resumeAppSwitches();
  }
 catch (  RemoteException e) {
  }
}
 

private void setPriority(BluetoothDevice device,int priority){
  try {
    mBinder.setPriority(device,priority);
  }
 catch (  RemoteException e) {
    Log.e(TAG,"Error while setting priority for: " + device);
  }
}
 

/** 
 * Adds a word to the dictionary and makes it persistent.
 * @param word the word to add. If the word is capitalized, then the dictionary willrecognize it as a capitalized word when searched.
 * @param frequency the frequency of occurrence of the word. A frequency of 255 is consideredthe highest.
 * @TODO use a higher or float range for frequency
 */
@Override public synchronized void addWord(final String word,final int frequency){
  if (getRequiresReload())   loadDictionaryAsync();
  if (word.length() >= getMaxWordLength())   return;
  super.addWord(word,frequency);
  final ContentValues values=new ContentValues(5);
  values.put(Words.WORD,word);
  values.put(Words.FREQUENCY,frequency);
  values.put(Words.LOCALE,mLocale);
  values.put(Words.APP_ID,0);
  final ContentResolver contentResolver=getContext().getContentResolver();
  final ContentProviderClient client=contentResolver.acquireContentProviderClient(Words.CONTENT_URI);
  if (null == client)   return;
  new Thread("addWord"){
    @Override public void run(){
      Cursor cursor=null;
      try {
        cursor=client.query(Words.CONTENT_URI,PROJECTION_ADD,"word=? and ((locale IS NULL) or (locale=?))",new String[]{word,mLocale},null);
        if (cursor != null && cursor.moveToFirst()) {
          final String locale=cursor.getString(cursor.getColumnIndex(Words.LOCALE));
          if (locale != null && locale.equals(mLocale.toString())) {
            final long id=cursor.getLong(cursor.getColumnIndex(Words._ID));
            final Uri uri=Uri.withAppendedPath(Words.CONTENT_URI,Long.toString(id));
            client.update(uri,values,null,null);
          }
        }
 else {
          client.insert(Words.CONTENT_URI,values);
        }
      }
 catch (      RemoteException e) {
      }
 finally {
        if (null != cursor)         cursor.close();
        client.release();
      }
    }
  }
.start();
  setRequiresReload(false);
}
 

public boolean dial(String num) throws RemoteException {
  if (IAX2Service.this.call != null) {
    Log.w("IAX2Service","Can not dial, call in progress");
    return false;
  }
  if (IAX2Service.this.friend == null) {
    Log.w("IAX2Service","Can not dial, not registered");
    return false;
  }
  IAX2Service.this.call=IAX2Service.this.friend.newCall(IAX2Service.this.lastUsername,IAX2Service.this.lastPassword,num,"","");
  return true;
}