diff options
author | murgatroid99 <mlumish@google.com> | 2016-11-01 11:13:58 -0700 |
---|---|---|
committer | murgatroid99 <mlumish@google.com> | 2016-11-01 11:13:58 -0700 |
commit | fdbf73305345e1446fd3d9224bcd1887dea185f8 (patch) | |
tree | b7617fe910fc8c446e62e4a34bca0b6c684e9a8b /src/node/performance/worker.js | |
parent | eaf796400169786c33a438c56c41a46d8ed45b02 (diff) | |
parent | 2a15a3134689a73e3cf6012313bc043015f14b36 (diff) |
Merge branch 'master' into node_electron_build
Diffstat (limited to 'src/node/performance/worker.js')
-rw-r--r-- | src/node/performance/worker.js | 10 |
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; |