Loading src/java/com/android/internal/telephony/imsphone/ImsPhoneConnection.java +33 −11 Original line number Diff line number Diff line Loading @@ -996,11 +996,29 @@ public class ImsPhoneConnection extends Connection implements } public void onRttMessageReceived(String message) { getOrCreateRttTextHandler().sendToInCall(message); synchronized (this) { if (mRttTextHandler == null) { Rlog.w(LOG_TAG, "onRttMessageReceived: RTT text handler not available." + " Attempting to create one."); if (mRttTextStream == null) { Rlog.e(LOG_TAG, "onRttMessageReceived:" + " Unable to process incoming message. No textstream available"); return; } createRttTextHandler(); } } mRttTextHandler.sendToInCall(message); } public void setCurrentRttTextStream(android.telecom.Connection.RttTextStream rttTextStream) { synchronized (this) { mRttTextStream = rttTextStream; if (mRttTextHandler == null && mIsRttEnabledForCall) { Rlog.i(LOG_TAG, "setCurrentRttTextStream: Creating a text handler"); createRttTextHandler(); } } } public boolean hasRttTextStream() { Loading @@ -1012,20 +1030,24 @@ public class ImsPhoneConnection extends Connection implements } public void startRttTextProcessing() { synchronized (this) { if (mRttTextStream == null) { Rlog.w(LOG_TAG, "startRttTextProcessing: no RTT text stream. Ignoring."); return; } getOrCreateRttTextHandler().initialize(mRttTextStream); } private ImsRttTextHandler getOrCreateRttTextHandler() { if (mRttTextHandler != null) { return mRttTextHandler; Rlog.w(LOG_TAG, "startRttTextProcessing: RTT text handler already exists"); return; } createRttTextHandler(); } } // Make sure to synchronize on ImsPhoneConnection.this before calling. private void createRttTextHandler() { mRttTextHandler = new ImsRttTextHandler(Looper.getMainLooper(), (message) -> getImsCall().sendRttMessage(message)); return mRttTextHandler; mRttTextHandler.initialize(mRttTextStream); } /** Loading Loading
src/java/com/android/internal/telephony/imsphone/ImsPhoneConnection.java +33 −11 Original line number Diff line number Diff line Loading @@ -996,11 +996,29 @@ public class ImsPhoneConnection extends Connection implements } public void onRttMessageReceived(String message) { getOrCreateRttTextHandler().sendToInCall(message); synchronized (this) { if (mRttTextHandler == null) { Rlog.w(LOG_TAG, "onRttMessageReceived: RTT text handler not available." + " Attempting to create one."); if (mRttTextStream == null) { Rlog.e(LOG_TAG, "onRttMessageReceived:" + " Unable to process incoming message. No textstream available"); return; } createRttTextHandler(); } } mRttTextHandler.sendToInCall(message); } public void setCurrentRttTextStream(android.telecom.Connection.RttTextStream rttTextStream) { synchronized (this) { mRttTextStream = rttTextStream; if (mRttTextHandler == null && mIsRttEnabledForCall) { Rlog.i(LOG_TAG, "setCurrentRttTextStream: Creating a text handler"); createRttTextHandler(); } } } public boolean hasRttTextStream() { Loading @@ -1012,20 +1030,24 @@ public class ImsPhoneConnection extends Connection implements } public void startRttTextProcessing() { synchronized (this) { if (mRttTextStream == null) { Rlog.w(LOG_TAG, "startRttTextProcessing: no RTT text stream. Ignoring."); return; } getOrCreateRttTextHandler().initialize(mRttTextStream); } private ImsRttTextHandler getOrCreateRttTextHandler() { if (mRttTextHandler != null) { return mRttTextHandler; Rlog.w(LOG_TAG, "startRttTextProcessing: RTT text handler already exists"); return; } createRttTextHandler(); } } // Make sure to synchronize on ImsPhoneConnection.this before calling. private void createRttTextHandler() { mRttTextHandler = new ImsRttTextHandler(Looper.getMainLooper(), (message) -> getImsCall().sendRttMessage(message)); return mRttTextHandler; mRttTextHandler.initialize(mRttTextStream); } /** Loading