aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/node/performance/worker.js
diff options
context:
space:
mode:
authorGravatar murgatroid99 <mlumish@google.com>2016-11-01 11:13:58 -0700
committerGravatar murgatroid99 <mlumish@google.com>2016-11-01 11:13:58 -0700
commitfdbf73305345e1446fd3d9224bcd1887dea185f8 (patch)
treeb7617fe910fc8c446e62e4a34bca0b6c684e9a8b /src/node/performance/worker.js
parenteaf796400169786c33a438c56c41a46d8ed45b02 (diff)
parent2a15a3134689a73e3cf6012313bc043015f14b36 (diff)
Merge branch 'master' into node_electron_build
Diffstat (limited to 'src/node/performance/worker.js')
-rw-r--r--src/node/performance/worker.js10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/node/performance/worker.js b/src/node/performance/worker.js
index 7ef9b84fe7..030bf7d7ba 100644
--- a/src/node/performance/worker.js
+++ b/src/node/performance/worker.js
@@ -34,18 +34,18 @@
'use strict';
var console = require('console');
-var worker_service_impl = require('./worker_service_impl');
+var WorkerServiceImpl = require('./worker_service_impl');
var grpc = require('../../../');
var serviceProto = grpc.load({
root: __dirname + '/../../..',
file: 'src/proto/grpc/testing/services.proto'}).grpc.testing;
-function runServer(port) {
+function runServer(port, benchmark_impl) {
var server_creds = grpc.ServerCredentials.createInsecure();
var server = new grpc.Server();
server.addProtoService(serviceProto.WorkerService.service,
- worker_service_impl);
+ new WorkerServiceImpl(benchmark_impl, server));
var address = '0.0.0.0:' + port;
server.bind(address, server_creds);
server.start();
@@ -57,9 +57,9 @@ if (require.main === module) {
Error.stackTraceLimit = Infinity;
var parseArgs = require('minimist');
var argv = parseArgs(process.argv, {
- string: ['driver_port']
+ string: ['driver_port', 'benchmark_impl']
});
- runServer(argv.driver_port);
+ runServer(argv.driver_port, argv.benchmark_impl);
}
exports.runServer = runServer;