sync around individual calls instead of synchronizing entire object

1 files changed, 43 insertions, 13 deletions

diff --git a/src/main/java/eu/siacs/conversations/entities/MucOptions.java b/src/main/java/eu/siacs/conversations/entities/MucOptions.java
index d26ecd7c..44d16cf2 100644
--- a/src/main/java/eu/siacs/conversations/entities/MucOptions.java
+++ b/src/main/java/eu/siacs/conversations/entities/MucOptions.java
@@ -28,6 +28,7 @@ public class MucOptions {
 
 	public void changeAffiliation(Jid jid, Affiliation affiliation) {
 		User user = findUserByRealJid(jid);
+		synchronized (users) {
 			if (user != null && user.getRole() == Role.NONE) {
 				users.remove(user);
 				if (affiliation.ranks(Affiliation.MEMBER)) {
@@ -36,6 +37,7 @@ public class MucOptions {
 				}
 			}
 		}
+	}
 
 	public enum Affiliation {
 		OWNER("owner", 4, R.string.owner),
@@ -155,10 +157,6 @@ public class MucOptions {
 			this.realJid = jid != null ? jid.toBareJid() : null;
 		}
 
-		public Jid getRealJid() {
-			return this.realJid;
-		}
-
 		public Role getRole() {
 			return this.role;
 		}
@@ -299,10 +297,14 @@ public class MucOptions {
 				return getName().compareToIgnoreCase(another.getName());
 			}
 		}
+
+		public Jid getRealJid() {
+			return realJid;
+		}
 	}
 
 	private Account account;
-	private final Set<User> users = Collections.synchronizedSet(new HashSet<User>());
+	private final Set<User> users = new HashSet<>();
 	private final List<String> features = new ArrayList<>();
 	private Data form = new Data();
 	private Conversation conversation;
@@ -373,6 +375,7 @@ public class MucOptions {
 	public User deleteUser(Jid jid) {
 		User user = findUserByFullJid(jid);
 		if (user != null) {
+			synchronized (users) {
 				users.remove(user);
 				if (user.affiliation.ranks(Affiliation.MEMBER) && user.realJid != null) {
 					user.role = Role.NONE;
@@ -381,6 +384,7 @@ public class MucOptions {
 					users.add(user);
 				}
 			}
+		}
 		return user;
 	}
 
@@ -389,30 +393,42 @@ public class MucOptions {
 		if (user.fullJid == null && user.realJid != null) {
 			old = findUserByRealJid(user.realJid);
 			if (old != null) {
+				if (old.fullJid != null) {
 					return; //don't add. user already exists
+				} else {
+					synchronized (users) {
+						users.remove(old);
+					}
+				}
 			}
 		} else if (user.realJid != null) {
 			old = findUserByRealJid(user.realJid);
+			synchronized (users) {
 				if (old != null && old.fullJid == null) {
 					users.remove(old);
 				}
 			}
+		}
 		old = findUserByFullJid(user.getFullJid());
+		synchronized (this.users) {
 			if (old != null) {
 				users.remove(old);
 			}
 			this.users.add(user);
 		}
+	}
 
 	public User findUserByFullJid(Jid jid) {
 		if (jid == null) {
 			return null;
 		}
+		synchronized (users) {
 			for (User user : users) {
 				if (jid.equals(user.getFullJid())) {
 					return user;
 				}
 			}
+		}
 		return null;
 	}
 
@@ -420,11 +436,13 @@ public class MucOptions {
 		if (jid == null) {
 			return null;
 		}
+		synchronized (users) {
 			for (User user : users) {
-			if (jid.equals(user.getRealJid())) {
+				if (jid.equals(user.realJid)) {
 					return user;
 				}
 			}
+		}
 		return null;
 	}
 
@@ -446,6 +464,7 @@ public class MucOptions {
 	}
 
 	public ArrayList<User> getUsers(boolean includeOffline) {
+		synchronized (users) {
 			if (includeOffline) {
 				return new ArrayList<>(users);
 			} else {
@@ -458,6 +477,7 @@ public class MucOptions {
 				return onlineUsers;
 			}
 		}
+	}
 
 	public List<User> getUsers(int max) {
 		ArrayList<User> users = getUsers();
@@ -465,7 +485,9 @@ public class MucOptions {
 	}
 
 	public int getUserCount() {
-		return this.users.size();
+		synchronized (users) {
+			return users.size();
+		}
 	}
 
 	public String getProposedNick() {
@@ -501,7 +523,9 @@ public class MucOptions {
 	}
 
 	public void setOffline() {
+		synchronized (users) {
 			this.users.clear();
+		}
 		this.error = Error.NO_RESPONSE;
 		this.isOnline = false;
 	}
@@ -519,7 +543,7 @@ public class MucOptions {
 	}
 
 	public String createNameFromParticipants() {
-		if (users.size() >= 2) {
+		if (getUserCount() >= 2) {
 			List<String> names = new ArrayList<>();
 			for (User user : getUsers(5)) {
 				Contact contact = user.getContact();
@@ -558,20 +582,24 @@ public class MucOptions {
 	}
 
 	public boolean pgpKeysInUse() {
-		for (User user : this.users) {
+		synchronized (users) {
+			for (User user : users) {
 				if (user.getPgpKeyId() != 0) {
 					return true;
 				}
 			}
+		}
 		return false;
 	}
 
 	public boolean everybodyHasKeys() {
-		for (User user : this.users) {
+		synchronized (users) {
+			for (User user : users) {
 				if (user.getPgpKeyId() == 0) {
 					return false;
 				}
 			}
+		}
 		return true;
 	}
 
@@ -588,7 +616,7 @@ public class MucOptions {
 			return account.getJid().toBareJid();
 		}
 		User user = findUserByFullJid(jid);
-		return user == null ? null : user.getRealJid();
+		return user == null ? null : user.realJid;
 	}
 
 	public String getPassword() {
@@ -616,9 +644,11 @@ public class MucOptions {
 
 	public List<Jid> getMembers() {
 		ArrayList<Jid> members = new ArrayList<>();
+		synchronized (users) {
 			for (User user : users) {
-			if (user.affiliation.ranks(Affiliation.MEMBER) && user.getRealJid() != null) {
-				members.add(user.getRealJid());
+				if (user.affiliation.ranks(Affiliation.MEMBER) && user.realJid != null) {
+					members.add(user.realJid);
+				}
 			}
 		}
 		return members;