mirrors/vector-im-hydrogen-web
1
0
Fork 0
mirror of https://github.com/vector-im/hydrogen-web.git synced 2024-12-23 03:25:12 +01:00
Code Issues Projects Releases Wiki Activity

reduce megolm sync cache size to 1 session

Browse Source 
as this is kept around for every e2ee room, and we only have
limited olm memory
This commit is contained in:
Bruno Windels 2020-10-14 12:43:35 +02:00
parent 16b3b7e282
commit 07701117cd
3 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/matrix/e2ee/RoomEncryption.js
View File

@ -41,7 +41,7 @@ export class RoomEncryption {
this._encryptionParams = encryptionParams;
this._megolmBackfillCache = this._megolmDecryption.createSessionCache();
this._megolmSyncCache = this._megolmDecryption.createSessionCache();
this._megolmSyncCache = this._megolmDecryption.createSessionCache(1);
// session => event ids of messages we tried to decrypt and the session was missing
this._missingSessions = new SessionToEventIdsMap();
// sessions that may or may not be missing, but that while

4
src/matrix/e2ee/megolm/Decryption.js
View File

@ -41,8 +41,8 @@ export class Decryption {
this._olmWorker = olmWorker;
}
createSessionCache(fallback) {
return new SessionCache(fallback);
createSessionCache(size) {
return new SessionCache(size);
}
/**

11
src/matrix/e2ee/megolm/decryption/SessionCache.js
View File

@ -14,13 +14,14 @@ See the License for the specific language governing permissions and
limitations under the License.
*/
const CACHE_MAX_SIZE = 10;
const DEFAULT_CACHE_SIZE = 10;
/**
* Cache of unpickled inbound megolm session.
*/
export class SessionCache {
constructor() {
constructor(size) {
this._size = typeof size === "number" ? size : DEFAULT_CACHE_SIZE;
this._sessions = [];
}
@ -51,12 +52,12 @@ export class SessionCache {
sessionInfo.retain();
// add new at top
this._sessions.unshift(sessionInfo);
if (this._sessions.length > CACHE_MAX_SIZE) {
if (this._sessions.length > this._size) {
// free sessions we're about to remove
for (let i = CACHE_MAX_SIZE; i < this._sessions.length; i += 1) {
for (let i = this._size; i < this._sessions.length; i += 1) {
this._sessions[i].release();
}
this._sessions = this._sessions.slice(0, CACHE_MAX_SIZE);
this._sessions = this._sessions.slice(0, this._size);
}
}