/* * * Copyright (C) 2020, University of the Basque Country (UPV/EHU) * * Contact for licensing options: * * This file is part of MCOP MCPTT Client * * This is free software: you can redistribute it and/or modify it under the terms of * the GNU General Public License as published by the Free Software Foundation, either version 3 * of the License, or (at your option) any later version. * * This is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. * See the GNU General Public License for more details. * * You should have received a copy of the GNU General Public License along * with this program; if not, write to the Free Software Foundation, Inc., * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. */ package org.mcopenplatform.muoapi.managerIapi; import android.content.ComponentName; import android.content.Context; import android.content.Intent; import android.os.IBinder; import android.os.Message; import android.os.RemoteException; import android.util.Log; import org.doubango.ngn.NgnEngine; import org.mcopenplatform.muoapi.BuildConfig; import java.util.HashMap; import java.util.Map; public class ManagerMBMSGroupCom extends ManagerIapiBase implements org.doubango.ngn.services.mbms.IMyMbmsService.MbmsExternalServiceListener , org.doubango.ngn.services.mbms.IMyMbmsService.OnMbmsListener { private final static String TAG = org.mcopenplatform.muoapi.utils.Utils.getTAG(ManagerMBMSGroupCom.class.getCanonicalName()); private final org.mcopenplatform.iapi.IMBMSGroupCommListener.Stub mMBMSGroupComListener; private OnManagerMBMSGroupComListener onManagerMBMSGroupComListener; public enum StatusTMGI{ NONE, AVAILABLE, UNAVAILABLE } private Map statusTMGIMap; protected String ORIGIN_PACKET_MAIN_SERVICE=null; protected String ORIGIN_PACKET_SERVICE=null; protected String PACKET_MAIN_SERVICE="com.expway.embmsserver"; protected String PACKET_SERVICE="com.expway.embmsserver.MCOP"; private org.doubango.ngn.services.mbms.IMyMbmsService mbmsService; public ManagerMBMSGroupCom() { super(); ORIGIN_PACKET_MAIN_SERVICE=String.valueOf(this.PACKET_MAIN_SERVICE); ORIGIN_PACKET_SERVICE=String.valueOf(this.PACKET_SERVICE); mMBMSGroupComListener= new org.mcopenplatform.iapi.IMBMSGroupCommListener.Stub() { /* @Override public void notifySaiList(int[] sai) throws RemoteException { if(BuildConfig.DEBUG){ String stringData=""; for(int saI:sai)stringData=stringData+";"+saI; Log.d(TAG,"notifySAIList: "+stringData); } //TODO: Should check if any available for this group of TMGI SAIs } */ /* @Override public void notifySAIList(int[] SAI) throws RemoteException { if(BuildConfig.DEBUG){ String stringData=""; for(int saI:SAI)stringData=stringData+";"+saI; Log.d(TAG,"notifySAIList: "+stringData); } //TODO: Should check if any available for this group of TMGI SAIs } */ @Override public void notifySaiList(int[] sai) throws RemoteException { if(BuildConfig.DEBUG){ String stringData=""; for(int saI:sai)stringData=stringData+";"+saI; Log.d(TAG,"notifySAIList: "+stringData); } //TODO: Should check if any available for this group of TMGI SAIs } @Override public void notifyCellInfo(int MCC, int MNC, int ECI) throws RemoteException { if(BuildConfig.DEBUG){ Log.d(TAG,"notifyCellInfo: MCC->"+MCC+" MNC->"+MNC+" ECI->"+ECI); } } @Override public void notifyMBMSGroupCommAvailability(long TMGI, int available, int goodQuality) throws RemoteException { notifyMBMSGroupCommAvailabilityMCOP( TMGI, available, goodQuality); } @Override public void notifyOpenMBMSGroupCommResult(long TMGI, int result, String netInterfaceName) throws RemoteException { if(BuildConfig.DEBUG){ Log.d(TAG,"notifyOpenMBMSGroupCommResult: TMGI->"+TMGI+" result->"+result+" netInterfaceName->"+netInterfaceName); } if(result>=0){ if(BuildConfig.DEBUG){ Log.d(TAG,"notifyOpenMBMSGroupCommResult: result is ok"); } mbmsService.onChangeServiceArea(mbmsService.getSais(TMGI),mContext); mbmsService.startMbmsManager(netInterfaceName,TMGI); } } @Override public void notifyCloseMBMSGroupCommResult(long TMGI, int result) throws RemoteException { if(BuildConfig.DEBUG){ Log.d(TAG,"notifyCloseMBMSGroupCommResult: TMGI->"+TMGI+" result->"+result); if(result>0){ if(BuildConfig.DEBUG){ Log.d(TAG,"notifyCloseMBMSGroupCommResult: result is ok"); } mbmsService.stopMbmsManager(TMGI); } } } }; statusTMGIMap=new HashMap<>(); } @Override protected void isServiceConnected() { } private void notifyMBMSGroupCommAvailabilityMCOP(long TMGI, int available, int goodQuality){ if(BuildConfig.DEBUG){ Log.d(TAG,"notifyMBMSGroupCommAvailability: TMGI->"+TMGI+" available->"+available+" goodQuality->"+goodQuality); } StatusTMGI statusTMGI; if(TMGI>0 && (mbmsService.getMbmsDataOfTmgi(TMGI))!=null && (statusTMGI=statusTMGIMap.get(TMGI))!=null){ if(available>=0){ statusTMGI=(StatusTMGI.AVAILABLE); }else{ statusTMGI=(StatusTMGI.UNAVAILABLE); } switch (statusTMGI) { case AVAILABLE: if(BuildConfig.DEBUG)Log.d(TAG,"notifyMBMSGroupCommAvailability Status: AVAILABLE"); try { if(mService!=null){ int[] sais=null; sais= mbmsService.getSais(TMGI); int[] frequencies=null; frequencies=mbmsService.getFrequencies(TMGI); if(BuildConfig.DEBUG){ String saiString=""; if(sais!=null && sais.length>0) for(int sai:sais)saiString=saiString+" "+sai; String freString=""; if(frequencies!=null && frequencies.length>0) for(int fre:frequencies)freString=freString+" "+fre; Log.i(TAG,"AVAILABLE TMGI with SAIs: "+sais.length+" frequencies:"+freString ); } ((org.mcopenplatform.iapi.IMBMSGroupComm)mService).openGroupComm(TMGI, sais,frequencies); } } catch (RemoteException e) { if(BuildConfig.DEBUG)Log.e(TAG,"Error in openGroupComm in ManagerMBMSGroupCom:"+e.getMessage()); }catch (Exception e) { if(BuildConfig.DEBUG)Log.e(TAG,"Error in openGroupComm in ManagerMBMSGroupCom:"+e.getMessage()); } break; case UNAVAILABLE: if(BuildConfig.DEBUG)Log.d(TAG,"notifyMBMSGroupCommAvailability status: UNAVAILABLE"); case NONE: break; } }else{ Log.e(TAG,"Now, we don´t have this TMGI"); } } @Override protected void startInternal() { mbmsService= NgnEngine.getInstance().getMbmsService(); mbmsService.setMbmsExternalServiceListener(this); mbmsService.setOnMbmsListener(this); } @Override protected void stopInternal() { //Test stopServer(mContext); } //Test protected void stopServer(Context context) { Log.d(TAG,"Stopping MBMS SERVER."); String mMspPackageName = "com.expway.embmsserver"; try { ComponentName component = new ComponentName( getPACKET_MAIN_SERVICE(),getPACKET_SERVICE()); Intent explicitIntent = new Intent(); explicitIntent.setComponent(component); Intent intent = explicitIntent; if (intent != null) { boolean isStop = context.stopService(intent); if (!isStop) { Log.e(TAG, "eMBMS Service not found!"); } else { Log.v(TAG, "Stopping Service..."); } } else { Log.e(TAG, "Could not get explicit intent to eMBMS Service."); } } catch (Exception e) { Log.e(TAG, "Error stopping the eMBMS Service intent."); } } @Override protected Object registerInterface(IBinder service) { org.mcopenplatform.iapi.IMBMSGroupComm imbmsGroupCom = org.mcopenplatform.iapi.IMBMSGroupComm.Stub.asInterface(service); Log.d(TAG,"Register notification in "+getPACKET_SERVICE()); try { (imbmsGroupCom).registerApplication(mMBMSGroupComListener); } catch (RemoteException e) { if(BuildConfig.DEBUG)Log.e(TAG,"Error in registerApplication in ManagerMBMSGroupCom:"+e.getMessage()); }catch (Exception e) { if(BuildConfig.DEBUG)Log.e(TAG,"Error in registerApplication in ManagerMBMSGroupCom:"+e.getMessage()); } return imbmsGroupCom; } @Override protected boolean receiveEvent(Message message) { if(BuildConfig.DEBUG) Log.d(TAG,"Execute receiveEvent in "+getPACKET_SERVICE()+": what: "+message.what); return false; } /** * It allows to distinguish between the different PACKET_SERVICE for each of the extended class of ManagerIapiBase * @return PACKET_SERVICE constant */ @Override protected String getPACKET_SERVICE() { return PACKET_SERVICE; } @Override protected String getPACKET_MAIN_SERVICE() { return PACKET_MAIN_SERVICE; } @Override protected void setPACKET_SERVICE(String packetService) { changedPacket=true; PACKET_SERVICE = packetService; } @Override protected void setPACKET_MAIN_SERVICE(String packetMainService) { changedPacket=true; PACKET_MAIN_SERVICE = packetMainService; } @Override protected boolean checkChangedPacket(){ return changedPacket && (ORIGIN_PACKET_MAIN_SERVICE.compareTo(PACKET_MAIN_SERVICE)!=0 || ORIGIN_PACKET_SERVICE.compareTo(PACKET_SERVICE)!=0) ; } //START EXTERNAL MBMS @Override public void startedClient(boolean status) { //TODO: } @Override public void startedServer(boolean status) { //TODO: } @Override public void startMbmsMedia(long sessionID,long tmgi){ if(sessionID<=0 || tmgi<=0){ if(BuildConfig.DEBUG)Log.e(TAG,"Error in event startMbmsMedia"); return; } if(onManagerMBMSGroupComListener!=null)onManagerMBMSGroupComListener.startMbmsMedia(Long.toString(sessionID),Long.toString(tmgi)); } @Override public boolean mbmsListeningServiceAreaCurrent(long TMGI, int[] sai, int[] frequencies) { //TODO: return false; } @Override public void stopMbmsMedia(long sessionID,long tmgi){ if(sessionID<=0 || tmgi<=0){ if(BuildConfig.DEBUG)Log.e(TAG,"Error in event stopMbmsMedia"); return; } if (mService != null){ try { if(BuildConfig.DEBUG) Log.d(TAG,"closeGroupComm tmgi: "+tmgi); ((org.mcopenplatform.iapi.IMBMSGroupComm)mService).closeGroupComm(tmgi); } catch (RemoteException e) { if(BuildConfig.DEBUG)Log.e(TAG,"Error in closeGroupComm in ManagerMBMSGroupCom:"+e.getMessage()); }catch (Exception e) { if(BuildConfig.DEBUG)Log.e(TAG,"Error in closeGroupComm in ManagerMBMSGroupCom:"+e.getMessage()); } } if(onManagerMBMSGroupComListener!=null)onManagerMBMSGroupComListener.stopMbmsMedia(Long.toString(sessionID),Long.toString(tmgi)); } @Override public void stopServiceMBMS() { if(BuildConfig.DEBUG)Log.i(TAG,"Execute stopServiceMBMS"); //TODO: incorrect //Test for(long tmgi:statusTMGIMap.keySet()){ if (mService != null) { try { if(BuildConfig.DEBUG) Log.d(TAG,"closeGroupComm tmgi: "+tmgi); ((org.mcopenplatform.iapi.IMBMSGroupComm)mService).closeGroupComm(tmgi); if(onManagerMBMSGroupComListener!=null)onManagerMBMSGroupComListener.stopMbmsMedia(null,Long.toString(tmgi)); } catch (RemoteException e) { if(BuildConfig.DEBUG)Log.e(TAG,"Error in closeGroupComm in ManagerMBMSGroupCom:"+e.getMessage()); }catch (Exception e) { if(BuildConfig.DEBUG)Log.e(TAG,"Error in closeGroupComm in ManagerMBMSGroupCom:"+e.getMessage()); } try { if(BuildConfig.DEBUG) Log.d(TAG,"stopMBMSGroupCommMonitoring tmgi: "+tmgi); ((org.mcopenplatform.iapi.IMBMSGroupComm) mService).stopMBMSGroupCommMonitoring(tmgi); } catch (RemoteException e) { if (BuildConfig.DEBUG) Log.e(TAG, "Error in stopMBMSGroupCommMonitoring in ManagerMBMSGroupCom:" + e.getMessage()); } catch (Exception e) { if (BuildConfig.DEBUG) Log.e(TAG, "Error in stopMBMSGroupCommMonitoring in ManagerMBMSGroupCom:" + e.getMessage()); } } } } @Override public void onNewServiceArea(long TMGI, int[] sai, int[] frequencies, long QCI) { if(BuildConfig.DEBUG){ String sias=""; for(int sai1:sai)sias=sias+" "+sai1; Log.i(TAG,"onNewServiceArea TMGI: "+TMGI+" sais: "+sias); } if(frequencies==null)frequencies=new int[0]; if(statusTMGIMap!=null && statusTMGIMap.get(TMGI)==null) statusTMGIMap.put(TMGI,StatusTMGI.NONE); try { if(mService!=null){ if(QCI<=0)QCI=0; ((org.mcopenplatform.iapi.IMBMSGroupComm)mService).startMBMSGroupCommMonitoring(TMGI, sai, frequencies, (((QCI>=Integer.MAX_VALUE || QCI<=Integer.MIN_VALUE))?Integer.MAX_VALUE:(int)QCI)); }else { if(BuildConfig.DEBUG)Log.e(TAG,"Error in service MBMS"); } } catch (RemoteException e) { if(BuildConfig.DEBUG)Log.e(TAG,"Error in startMBMSGroupCommMonitoring in ManagerMBMSGroupCom:"+e.getMessage()); }catch (Exception e) { if(BuildConfig.DEBUG)Log.e(TAG,"Error in startMBMSGroupCommMonitoring in ManagerMBMSGroupCom:"+e.getMessage()); } if(checkChangedPacket()){ if(BuildConfig.DEBUG)Log.d(TAG,"The packet selection is changed"); } //TODO: receive new TMGI } public interface OnManagerMBMSGroupComListener{ void startMbmsMedia(String sessionID,String tmgi); void stopMbmsMedia(String sessionID,String tmgi); } public void setOnManagerMBMSGroupComListener(OnManagerMBMSGroupComListener onManagerMBMSGroupComListener){ this.onManagerMBMSGroupComListener=onManagerMBMSGroupComListener; } }