thedevstack/PiratX-Archive
Archived
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

change listener lock strategie

Browse source
This commit is contained in:
Christian Schneppe 2018-07-09 22:28:02 +02:00
parent 5d47f14ccc
commit 367de48998
1 changed files with 28 additions and 38 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

66
src/main/java/de/pixart/messenger/services/XmppConnectionService.java
View file

@ -3571,74 +3571,64 @@ public class XmppConnectionService extends Service {
vibrator.vibrate(100);
}
public void showErrorToastInUi(int resId) {
private <T> List<T> threadSafeList(Set<T> set) {
synchronized (LISTENER_LOCK) {
for (OnShowErrorToast listener : this.mOnShowErrorToasts) {
listener.onShowErrorToast(resId);
}
return set.size() == 0 ? Collections.emptyList() : new ArrayList<>(set);
}
}
public void showErrorToastInUi(int resId) {
for (OnShowErrorToast listener : threadSafeList(this.mOnShowErrorToasts)) {
listener.onShowErrorToast(resId);
}
}
public void updateConversationUi() {
synchronized (LISTENER_LOCK) {
for (OnConversationUpdate listener : this.mOnConversationUpdates) {
listener.onConversationUpdate();
}
for (OnConversationUpdate listener : threadSafeList(this.mOnConversationUpdates)) {
listener.onConversationUpdate();
}
}
public void updateAccountUi() {
synchronized (LISTENER_LOCK) {
for (OnAccountUpdate listener : this.mOnAccountUpdates) {
listener.onAccountUpdate();
}
for (OnAccountUpdate listener : threadSafeList(this.mOnAccountUpdates)) {
listener.onAccountUpdate();
}
}
public void updateRosterUi() {
synchronized (LISTENER_LOCK) {
for (OnRosterUpdate listener : this.mOnRosterUpdates) {
listener.onRosterUpdate();
}
for (OnRosterUpdate listener : threadSafeList(this.mOnRosterUpdates)) {
listener.onRosterUpdate();
}
}
public boolean displayCaptchaRequest(Account account, String id, Data data, Bitmap captcha) {
synchronized (LISTENER_LOCK) {
if (mOnCaptchaRequested.size() > 0) {
DisplayMetrics metrics = getApplicationContext().getResources().getDisplayMetrics();
Bitmap scaled = Bitmap.createScaledBitmap(captcha, (int) (captcha.getWidth() * metrics.scaledDensity),
(int) (captcha.getHeight() * metrics.scaledDensity), false);
for (OnCaptchaRequested listener : this.mOnCaptchaRequested) {
listener.onCaptchaRequested(account, id, data, scaled);
}
return true;
if (mOnCaptchaRequested.size() > 0) {
DisplayMetrics metrics = getApplicationContext().getResources().getDisplayMetrics();
Bitmap scaled = Bitmap.createScaledBitmap(captcha, (int) (captcha.getWidth() * metrics.scaledDensity),
(int) (captcha.getHeight() * metrics.scaledDensity), false);
for (OnCaptchaRequested listener : threadSafeList(this.mOnCaptchaRequested)) {
listener.onCaptchaRequested(account, id, data, scaled);
}
return false;
return true;
}
return false;
}
public void updateBlocklistUi(final OnUpdateBlocklist.Status status) {
synchronized (LISTENER_LOCK) {
for (OnUpdateBlocklist listener : this.mOnUpdateBlocklist) {
listener.OnUpdateBlocklist(status);
}
for (OnUpdateBlocklist listener : threadSafeList(this.mOnUpdateBlocklist)) {
listener.OnUpdateBlocklist(status);
}
}
public void updateMucRosterUi() {
synchronized (LISTENER_LOCK) {
for (OnMucRosterUpdate listener : this.mOnMucRosterUpdate) {
listener.onMucRosterUpdate();
}
for (OnMucRosterUpdate listener : threadSafeList(this.mOnMucRosterUpdate)) {
listener.onMucRosterUpdate();
}
}
public void keyStatusUpdated(AxolotlService.FetchStatus report) {
synchronized (LISTENER_LOCK) {
for (OnKeyStatusUpdated listener : this.mOnKeyStatusUpdated) {
listener.onKeyStatusUpdated(report);
}
for (OnKeyStatusUpdated listener : threadSafeList(this.mOnKeyStatusUpdated)) {
listener.onKeyStatusUpdated(report);
}
}