diff --git a/src/node/examples/math_server.js b/src/node/examples/math_server.js index e0104453898..e1bd11b5a6d 100644 --- a/src/node/examples/math_server.js +++ b/src/node/examples/math_server.js @@ -69,7 +69,6 @@ function mathDiv(call, cb) { * @param {stream} stream The stream for sending responses. */ function mathFib(stream) { - console.log(stream); // Here, call is a standard writable Node object Stream var previous = 0, current = 1; for (var i = 0; i < stream.request.limit; i++) { diff --git a/src/node/interop/interop_server.js b/src/node/interop/interop_server.js index 271fe5962e3..54e9715d1e3 100644 --- a/src/node/interop/interop_server.js +++ b/src/node/interop/interop_server.js @@ -106,7 +106,6 @@ function handleStreamingOutput(call) { testProto.PayloadType.COMPRESSABLE, testProto.PayloadType.UNCOMPRESSABLE][Math.random() < 0.5 ? 0 : 1]; } - console.log('req:', req); _.each(req.response_parameters, function(resp_param) { call.write({ payload: { diff --git a/src/node/src/client.js b/src/node/src/client.js index 36a6f41d7bb..4b7eda324ee 100644 --- a/src/node/src/client.js +++ b/src/node/src/client.js @@ -56,7 +56,6 @@ function ClientWritableStream(call, serialize) { this.call = call; this.serialize = common.wrapIgnoreNull(serialize); this.on('finish', function() { - console.log('Send close from client'); var batch = {}; batch[grpc.opType.SEND_CLOSE_FROM_CLIENT] = true; call.startBatch(batch, function() {}); @@ -73,7 +72,6 @@ function ClientWritableStream(call, serialize) { function _write(chunk, encoding, callback) { var batch = {}; batch[grpc.opType.SEND_MESSAGE] = this.serialize(chunk); - console.log(batch); this.call.startBatch(batch, function(err, event) { if (err) { throw err; @@ -153,7 +151,6 @@ function ClientDuplexStream(call, serialize, deserialize) { var reading = false; this.call = call; this.on('finish', function() { - console.log('Send close from client'); var batch = {}; batch[grpc.opType.SEND_CLOSE_FROM_CLIENT] = true; call.startBatch(batch, function() {}); @@ -279,7 +276,6 @@ function makeClientStreamRequestFunction(method, serialize, deserialize) { callback(err); return; } - console.log(response); if (response.status.code != grpc.status.OK) { callback(response.status); return; @@ -323,7 +319,6 @@ function makeServerStreamRequestFunction(method, serialize, deserialize) { } var stream = new ClientReadableStream(call, deserialize); var start_batch = {}; - console.log('Starting server streaming request on', method); start_batch[grpc.opType.SEND_INITIAL_METADATA] = metadata; start_batch[grpc.opType.RECV_INITIAL_METADATA] = true; start_batch[grpc.opType.SEND_MESSAGE] = serialize(argument); @@ -332,7 +327,6 @@ function makeServerStreamRequestFunction(method, serialize, deserialize) { if (err) { throw err; } - console.log(response); stream.emit('metadata', response.metadata); }); var status_batch = {}; diff --git a/src/node/src/server.js b/src/node/src/server.js index 3c214913195..82d521ddf12 100644 --- a/src/node/src/server.js +++ b/src/node/src/server.js @@ -95,7 +95,6 @@ function setUpWritable(stream, serialize) { }; stream.serialize = common.wrapIgnoreNull(serialize); function sendStatus() { - console.log('Server sending status'); var batch = {}; batch[grpc.opType.SEND_STATUS_FROM_SERVER] = stream.status; stream.call.startBatch(batch, function(){}); @@ -169,7 +168,6 @@ function ServerWritableStream(call, serialize) { function _write(chunk, encoding, callback) { var batch = {}; batch[grpc.opType.SEND_MESSAGE] = this.serialize(chunk); - console.log('Server writing', batch); this.call.startBatch(batch, function(err, value) { if (err) { this.emit('error', err); @@ -207,14 +205,11 @@ function _read(size) { return; } if (self.finished) { - console.log('Pushing null'); self.push(null); return; } var data = event.read; - console.log(data); if (self.push(self.deserialize(data)) && data != null) { - console.log('Reading again'); var read_batch = {}; read_batch[grpc.opType.RECV_MESSAGE] = true; self.call.startBatch(read_batch, readCallback); @@ -276,7 +271,6 @@ function handleUnary(call, handler, metadata) { } function handleServerStreaming(call, handler, metadata) { - console.log('Handling server streaming call'); var stream = new ServerWritableStream(call, handler.serialize); waitForCancel(call, stream); var batch = {}; @@ -360,7 +354,6 @@ function Server(getMetadata, options) { * @param {grpc.Event} event The event to handle with tag SERVER_RPC_NEW */ function handleNewCall(err, event) { - console.log('Handling new call'); if (err) { return; } @@ -376,9 +369,7 @@ function Server(getMetadata, options) { var deadline = details.deadline; if (handlers.hasOwnProperty(method)) { handler = handlers[method]; - console.log(handler); } else { - console.log(handlers); var batch = {}; batch[grpc.opType.SEND_INITIAL_METADATA] = {}; batch[grpc.opType.SEND_STATUS_FROM_SERVER] = { diff --git a/src/node/test/end_to_end_test.js b/src/node/test/end_to_end_test.js index 34ce2500f6c..f8899beae82 100644 --- a/src/node/test/end_to_end_test.js +++ b/src/node/test/end_to_end_test.js @@ -148,7 +148,6 @@ describe('end-to-end', function() { }); server.requestCall(function(err, call_details) { - console.log("Server received new call"); var new_call = call_details['new call']; assert.notEqual(new_call, null); assert.strictEqual(new_call.metadata.client_key[0].toString(),