Eugeny/tabby
1
1
Fork 0
mirror of https://github.com/Eugeny/tabby.git synced 2024-11-13 10:58:00 +03:00
Code Issues Projects Releases Wiki Activity

improved flow control for more speed - fixes #6394

Browse Source
This commit is contained in:
Eugene Pankov 2022-05-21 19:08:23 -07:00
parent 50e9399ee1
commit 740c77374e
No known key found for this signature in database
GPG Key ID: 5896FCBBDD1CF4F4
1 changed files with 39 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
tabby-terminal/src/frontends/xtermFrontend.ts
View File

@ -1,3 +1,4 @@
import { BehaviorSubject, filter, firstValueFrom } from 'rxjs'
import { Injector } from '@angular/core'
import { ConfigService, getCSSFontFamily, HostAppService, HotkeysService, Platform, PlatformService } from 'tabby-core'
import { Frontend, SearchOptions, SearchState } from './frontend'
@ -20,6 +21,41 @@ const COLOR_NAMES = [
'brightBlack', 'brightRed', 'brightGreen', 'brightYellow', 'brightBlue', 'brightMagenta', 'brightCyan', 'brightWhite',
]
class FlowControl {
private blocked = false
private blocked$ = new BehaviorSubject<boolean>(false)
private pendingCallbacks = 0
private lowWatermark = 5
private highWatermark = 10
private bytesWritten = 0
private bytesThreshold = 1024 * 128
constructor (private xterm: Terminal) { }
async write (data: string) {
if (this.blocked) {
await firstValueFrom(this.blocked$.pipe(filter(x => !x)))
}
this.bytesWritten += data.length
if (this.bytesWritten > this.bytesThreshold) {
this.pendingCallbacks++
if (this.pendingCallbacks > this.highWatermark) {
this.blocked = true
this.blocked$.next(true)
}
this.xterm.write(data, () => {
this.pendingCallbacks--
if (this.pendingCallbacks < this.lowWatermark) {
this.blocked = false
this.blocked$.next(false)
}
})
} else {
this.xterm.write(data)
}
}
}
/** @hidden */
export class XTermFrontend extends Frontend {
enableResizing = true
@ -41,6 +77,7 @@ export class XTermFrontend extends Frontend {
private webGLAddon?: WebglAddon
private opened = false
private resizeObserver?: any
private flowControl: FlowControl
private configService: ConfigService
private hotkeysService: HotkeysService
@ -59,6 +96,7 @@ export class XTermFrontend extends Frontend {
overviewRulerWidth: 8,
windowsMode: process.platform === 'win32',
})
this.flowControl = new FlowControl(this.xterm)
this.xtermCore = this.xterm['_core']
this.xterm.onBinary(data => {
@ -248,7 +286,7 @@ export class XTermFrontend extends Frontend {
}
async write (data: string): Promise<void> {
await new Promise<void>(r => this.xterm.write(data, r))
await this.flowControl.write(data)
}
clear (): void {