danog/telegram-tt
1
0
Fork 0
mirror of https://github.com/danog/telegram-tt.git synced 2025-01-22 05:11:55 +01:00
Code Issues Packages Projects Releases Wiki Activity

[Perf] GramJs: Fix memory leaks (#1546)

Browse Source
This commit is contained in:
Alexander Zinchuk 2021-11-17 17:49:41 +03:00
parent 03b8698856
commit a31aa31b6b
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/lib/gramjs/extensions/MessagePacker.js
View File

@ -1,6 +1,6 @@
const MessageContainer = require('../tl/core/MessageContainer'); const MessageContainer = require('../tl/core/MessageContainer');
const TLMessage = require('../tl/core/TLMessage'); const TLMessage = require('../tl/core/TLMessage');
const BinaryWriter = require('../extensions/BinaryWriter'); const BinaryWriter = require('./BinaryWriter');
const USE_INVOKE_AFTER_WITH = [ const USE_INVOKE_AFTER_WITH = [
'messages.SendMessage', 'messages.SendMedia', 'messages.SendMultiMedia', 'messages.SendMessage', 'messages.SendMedia', 'messages.SendMultiMedia',
@ -35,11 +35,10 @@ class MessagePacker {
} }
} }
this._queue.push(state); this._queue.push(state);
this.setReady(true); this.setReady(true);
// 1658238041=MsgsAck, we don't care about MsgsAck here because they never resolve anyway.
if (state) { if (state && state.request.CONSTRUCTOR_ID !== 1658238041) {
this._pendingStates.push(state); this._pendingStates.push(state);
state.promise state.promise
// Using finally causes triggering `unhandledrejection` event // Using finally causes triggering `unhandledrejection` event

3
src/lib/gramjs/network/MTProtoSender.js
View File

@ -338,6 +338,9 @@ class MTProtoSender {
const ack = new RequestState(new MsgsAck({ msgIds: Array(...this._pending_ack) })); const ack = new RequestState(new MsgsAck({ msgIds: Array(...this._pending_ack) }));
this._send_queue.append(ack); this._send_queue.append(ack);
this._last_acks.push(ack); this._last_acks.push(ack);
if (this._last_acks.length >= 10) {
this._last_acks.shift();
}
this._pending_ack.clear(); this._pending_ack.clear();
} }
this._log.debug(`Waiting for messages to send...${this._reconnecting}`); this._log.debug(`Waiting for messages to send...${this._reconnecting}`);