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

Add more logging to the xDS interop client

This commit is contained in:
Michael Lumish 2020-08-21 11:02:33 -07:00
parent 14eea7d6d2
commit 362b77259f
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
packages/grpc-js/interop/xds-interop-client.ts
View File

@ -184,11 +184,13 @@ function main() {
.number(['num_channels', 'qps']) .number(['num_channels', 'qps'])
.require(['fail_on_failed_rpcs', 'num_channels', 'qps', 'server', 'stats_port']) .require(['fail_on_failed_rpcs', 'num_channels', 'qps', 'server', 'stats_port'])
.argv; .argv;
console.log('Starting xDS interop client. Args: ', argv);
const callStatsTracker = new CallStatsTracker(); const callStatsTracker = new CallStatsTracker();
for (let i = 0; i < argv.num_channels; i++) { for (let i = 0; i < argv.num_channels; i++) {
/* The 'unique' channel argument is there solely to ensure that the /* The 'unique' channel argument is there solely to ensure that the
* channels do not share any subchannels. It does not have any * channels do not share any subchannels. It does not have any
* inherent function. */ * inherent function. */
console.log(`Interop client channel ${i} starting sending ${argv.qps} QPS to ${argv.server}`);
sendConstantQps(new loadedProto.grpc.testing.TestService(argv.server, grpc.credentials.createInsecure(), {'unique': i}), sendConstantQps(new loadedProto.grpc.testing.TestService(argv.server, grpc.credentials.createInsecure(), {'unique': i}),
argv.qps, argv.qps,
argv.fail_on_failed_rpcs === 'true', argv.fail_on_failed_rpcs === 'true',
@ -211,6 +213,7 @@ function main() {
if (error) { if (error) {
throw error; throw error;
} }
console.log(`Starting stats service server bound to port ${port}`);
server.start(); server.start();
}); });
} }