Foundry376/Mailspring
1
1
Fork 0
mirror of https://github.com/Foundry376/Mailspring.git synced 2024-12-28 11:24:11 +08:00
Code Issues Projects Releases Packages Wiki Activity

Always expand stdin buffer, send identity data in separate write

Browse source
This commit is contained in:
Ben Gotow 2018-02-12 12:33:54 -08:00
parent 1a26071bde
commit a95e926424
1 changed files with 13 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
app/src/mailsync-process.es6
View file

@ -117,13 +117,23 @@ export default class MailsyncProcess extends EventEmitter {
}
this._proc = spawn(this.binaryPath, args, { env });
/* Allow us to buffer up to 1MB on stdin instead of 16k. This is necessary
because some tasks (creating replies to drafts, etc.) can be gigantic amounts
of HTML, many tasks can be created at once, etc, and we don't want to kill
the channel. */
if (this._proc.stdin) {
this._proc.stdin.setDefaultEncoding('utf-8');
this._proc.stdin.highWaterMark = 1024 * 1024;
}
// stdout may not be present if an error occurred. Error handler hasn't been
// attached yet, but will be by the caller of spawnProcess.
if (this.account && this._proc.stdout) {
this._proc.stdout.once('data', () => {
this._proc.stdin.write(
`${JSON.stringify(this.account)}\n${JSON.stringify(this.identity)}\n`
);
this._proc.stdout.once('data', () => {
this._proc.stdin.write(`${JSON.stringify(this.identity)}\n`);
});
this._proc.stdin.write(`${JSON.stringify(this.account)}\n`);
});
}
}
@ -198,13 +208,6 @@ export default class MailsyncProcess extends EventEmitter {
let outBuffer = '';
let errBuffer = null;
/* Allow us to buffer up to 1MB on stdin instead of 16k. This is necessary
because some tasks (creating replies to drafts, etc.) can be gigantic amounts
of HTML, many tasks can be created at once, etc, and we don't want to kill
the channel. */
if (this._proc.stdin) {
this._proc.stdin.highWaterMark = 1024 * 1024;
}
if (this._proc.stdout) {
this._proc.stdout.on('data', data => {
const added = data.toString();