andreacavalli/JTDLib
Archived
1
0
Fork 0
forked from ErnyTech/JTDLib
Code Releases Activity

Use the same arrays

Browse Source
This commit is contained in:
Andrea Cavalli 2020-05-13 15:21:00 +02:00
parent 32a21ccf01
commit 31e464e630
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/main/java/it/ernytech/tdlib/Client.java
View File

@ -21,6 +21,7 @@ package it.ernytech.tdlib;
import it.ernytech.tdlib.utils.Init; import it.ernytech.tdlib.utils.Init;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.concurrent.locks.ReentrantLock; import java.util.concurrent.locks.ReentrantLock;
import java.util.concurrent.locks.StampedLock; import java.util.concurrent.locks.StampedLock;
@ -65,6 +66,9 @@ public class Client implements TelegramClient {
nativeClientSend(this.clientId, request.getId(), request.getFunction()); nativeClientSend(this.clientId, request.getId(), request.getFunction());
} }
private long[] eventIds;
private TdApi.Object[] events;
/** /**
* Receives incoming updates and request responses from TDLib. May be called from any thread, but shouldn't be called simultaneously from two different threads. * Receives incoming updates and request responses from TDLib. May be called from any thread, but shouldn't be called simultaneously from two different threads.
* @param timeout Maximum number of seconds allowed for this function to wait for new records. * @param timeout Maximum number of seconds allowed for this function to wait for new records.
@ -78,8 +82,15 @@ public class Client implements TelegramClient {
} }
var responseList = new ArrayList<Response>(); var responseList = new ArrayList<Response>();
var eventIds = new long[eventSize]; if (eventIds == null) {
var events = new TdApi.Object[eventSize]; eventIds = new long[eventSize];
events = new TdApi.Object[eventSize];
} else if (eventIds.length != eventSize) {
throw new IllegalArgumentException("EventSize can't change! Previous value = " + eventIds.length + " New value = " + eventSize);
} else {
Arrays.fill(eventIds, 0);
Arrays.fill(events, null);
}
if (this.receiveLock.isLocked()) { if (this.receiveLock.isLocked()) {
throw new IllegalThreadStateException("Thread: " + Thread.currentThread().getName() + " trying receive incoming updates but shouldn't be called simultaneously from two different threads!"); throw new IllegalThreadStateException("Thread: " + Thread.currentThread().getName() + " trying receive incoming updates but shouldn't be called simultaneously from two different threads!");