grpc
/
grpc-node
mirror of https://github.com/grpc/grpc-node.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2530 from murgatroid99/benchmark_stop_delay 

benchmark: Delay shutdown in quitWorker
This commit is contained in:
Michael Lumish 2023-07-31 14:43:16 -07:00 committed by GitHub
parent 90adc8a3e2 1f08883e2a
commit 426768d6cd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
test/performance/driver.js
View File

@ -74,6 +74,20 @@ function main() {
}); });
serverWorkerStream.on('status', (status) => { serverWorkerStream.on('status', (status) => {
console.log('Received server worker status ' + JSON.stringify(status)); console.log('Received server worker status ' + JSON.stringify(status));
clientWorker.quitWorker({}, (error, response) => {
if (error) {
console.log('Received error on clientWorker.quitWorker:', error);
} else {
console.log('Received response from clientWorker.quitWorker');
}
});
serverWorker.quitWorker({}, (error, response) => {
if (error) {
console.log('Received error on serverWorker.quitWorker:', error);
} else {
console.log('Received response from serverWorker.quitWorker');
}
});
}); });
} }

7
test/performance/worker_service_impl.js
View File

@ -41,7 +41,12 @@ module.exports = function WorkerServiceImpl(benchmark_impl, server) {
this.quitWorker = function quitWorker(call, callback) { this.quitWorker = function quitWorker(call, callback) {
callback(null, {}); callback(null, {});
server.tryShutdown(function() {}); /* Due to https://github.com/nodejs/node/issues/42713, tryShutdown acts
* like forceShutdown on some Node versions. So, delay calling tryShutdown
* until after done handling this request. */
setTimeout(() => {
server.tryShutdown(function() {});
}, 10);
}; };
this.runClient = function runClient(call) { this.runClient = function runClient(call) {