mirror/monocles_chat_clean
1
0
Fork 1
Code Activity

Synchronize payload access

Browse source 
(cherry picked from commit 30a45604f661e85317f9f2fe94ca1e2ab0d4b807)
This commit is contained in:
Stephen Paul Weber 2025-01-06 11:37:29 -05:00 committed by Arne
parent 5dac7289a1
commit aa9097d89d
1 changed files with 10 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
src/main/java/eu/siacs/conversations/entities/Message.java
View file

@ -443,7 +443,7 @@ public class Message extends AbstractEntity implements AvatarService.Avatarable
return m; return m;
} }
public void clearReplyReact() { public synchronized void clearReplyReact() {
mInReplyTo = null; mInReplyTo = null;
this.payloads.remove(getReactionsEl()); this.payloads.remove(getReactionsEl());
this.payloads.remove(getReply()); this.payloads.remove(getReply());
@ -491,7 +491,7 @@ public class Message extends AbstractEntity implements AvatarService.Avatarable
addPayload(reactions); addPayload(reactions);
} }
public Element getReply() { public synchronized Element getReply() {
if (this.payloads == null) return null; if (this.payloads == null) return null;
for (Element el : this.payloads) { for (Element el : this.payloads) {
@ -503,7 +503,7 @@ public class Message extends AbstractEntity implements AvatarService.Avatarable
return null; return null;
} }
public boolean isAttention() { public synchronized boolean isAttention() {
if (this.payloads == null) return false; if (this.payloads == null) return false;
for (Element el : this.payloads) { for (Element el : this.payloads) {
@ -1323,21 +1323,21 @@ public class Message extends AbstractEntity implements AvatarService.Avatarable
} }
} }
public void clearPayloads() { public synchronized void clearPayloads() {
this.payloads.clear(); this.payloads.clear();
} }
public void addPayload(Element el) { public synchronized void addPayload(Element el) {
if (el == null) return; if (el == null) return;
this.payloads.add(el); this.payloads.add(el);
} }
public List<Element> getPayloads() { public synchronized List<Element> getPayloads() {
return new ArrayList<>(this.payloads); return new ArrayList<>(this.payloads);
} }
public List<Element> getFallbacks(String... includeFor) { public synchronized List<Element> getFallbacks(String... includeFor) {
List<Element> fallbacks = new ArrayList<>(); List<Element> fallbacks = new ArrayList<>();
if (this.payloads == null) return fallbacks; if (this.payloads == null) return fallbacks;
@ -1362,7 +1362,7 @@ public class Message extends AbstractEntity implements AvatarService.Avatarable
return getHtml(false); return getHtml(false);
} }
public Element getHtml(boolean root) { public synchronized Element getHtml(boolean root) {
if (this.payloads == null) return null; if (this.payloads == null) return null;
for (Element el : this.payloads) { for (Element el : this.payloads) {
@ -1374,7 +1374,7 @@ public class Message extends AbstractEntity implements AvatarService.Avatarable
return null; return null;
} }
public List<Element> getCommands() { public synchronized List<Element> getCommands() {
if (this.payloads == null) return null; if (this.payloads == null) return null;
for (Element el : this.payloads) { for (Element el : this.payloads) {
@ -1386,7 +1386,7 @@ public class Message extends AbstractEntity implements AvatarService.Avatarable
return null; return null;
} }
public List<Element> getLinkDescriptions() { public synchronized List<Element> getLinkDescriptions() {
final ArrayList<Element> result = new ArrayList<>(); final ArrayList<Element> result = new ArrayList<>();
if (this.payloads == null) return result; if (this.payloads == null) return result;