sum7/Conversations
sum7
/
Conversations
1
1
Fork 0
Code Issues Pull Requests Releases Wiki Activity

resend session proposal on rebind

This commit is contained in:
Daniel Gultsch 2021-02-12 11:36:44 +01:00
parent 6cab0ad496
commit db447f845e
2 changed files with 18 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/eu/siacs/conversations/services/XmppConnectionService.java
View File

@ -344,7 +344,7 @@ public class XmppConnectionService extends Service {
synchronized (account.inProgressConferencePings) {
account.inProgressConferencePings.clear();
}
mJingleConnectionManager.notifyRebound();
mJingleConnectionManager.notifyRebound(account);
mQuickConversationsService.considerSyncBackground(false);
fetchRosterFromServer(account);
@ -370,6 +370,7 @@ public class XmppConnectionService extends Service {
}
connectMultiModeConversations(account);
syncDirtyContacts(account);
}
};
private final AtomicLong mLastExpiryRun = new AtomicLong(0);

17
src/main/java/eu/siacs/conversations/xmpp/jingle/JingleConnectionManager.java
View File

@ -605,7 +605,6 @@ public class JingleConnectionManager extends AbstractConnectionManager {
RtpEndUserState.FINDING_DEVICE
);
final MessagePacket messagePacket = mXmppConnectionService.getMessageGenerator().sessionProposal(proposal);
Log.d(Config.LOGTAG, messagePacket.toString());
mXmppConnectionService.sendMessagePacket(account, messagePacket);
}
}
@ -657,10 +656,11 @@ public class JingleConnectionManager extends AbstractConnectionManager {
account.getXmppConnection().sendIqPacket(packet.generateResponse(IqPacket.TYPE.ERROR), null);
}
public void notifyRebound() {
public void notifyRebound(final Account account) {
for (final AbstractJingleConnection connection : this.connections.values()) {
connection.notifyRebound();
}
resendSessionProposals(account);
}
public WeakReference<JingleRtpConnection> findJingleRtpConnection(Account account, Jid with, String sessionId) {
@ -672,6 +672,19 @@ public class JingleConnectionManager extends AbstractConnectionManager {
return null;
}
private void resendSessionProposals(final Account account) {
synchronized (this.rtpSessionProposals) {
for (final Map.Entry<RtpSessionProposal, DeviceDiscoveryState> entry : this.rtpSessionProposals.entrySet()) {
final RtpSessionProposal proposal = entry.getKey();
if (entry.getValue() == DeviceDiscoveryState.SEARCHING && proposal.account == account) {
Log.d(Config.LOGTAG, account.getJid().asBareJid() + ": resending session proposal to " + proposal.with);
final MessagePacket messagePacket = mXmppConnectionService.getMessageGenerator().sessionProposal(proposal);
mXmppConnectionService.sendMessagePacket(account, messagePacket);
}
}
}
}
public void updateProposedSessionDiscovered(Account account, Jid from, String sessionId, final DeviceDiscoveryState target) {
synchronized (this.rtpSessionProposals) {
final RtpSessionProposal sessionProposal = getRtpSessionProposal(account, from.asBareJid(), sessionId);