From 120dbe0b0aa143ec51e1d607704015cd0cef2458 Mon Sep 17 00:00:00 2001 From: garrettmills Date: Sun, 29 Nov 2020 11:57:10 -0600 Subject: [PATCH] Fix debugging output --- Streamer.js | 2 -- ops/flush.js | 2 -- ops/release.js | 2 -- ops/write.js | 1 - 4 files changed, 7 deletions(-) diff --git a/Streamer.js b/Streamer.js index f3ad0f9..75ebf35 100644 --- a/Streamer.js +++ b/Streamer.js @@ -1,7 +1,5 @@ const WebSocketStream = require('websocket-stream') -const ConcatStream = require('concat-stream') const CombinedStream = require('combined-stream') -const { Duplex, Readable } = require('stream') const { Buffer } = require('buffer') class Streamer { diff --git a/ops/flush.js b/ops/flush.js index d964dd7..3fa0bf4 100644 --- a/ops/flush.js +++ b/ops/flush.js @@ -4,7 +4,6 @@ const Message = require('../../shared/Message') const connector = require('../connector') module.exports = exports = function (path, fd, cb) { -console.log('[FLUSH]') connector.send( Message.route('fs.flush') .data({ path, descriptor: fd }) @@ -13,7 +12,6 @@ console.log('[FLUSH]') return Errors.toCallback(cb, msg.error()) } -console.log('[/FLUSH]') return process.nextTick(cb, 0) }) ) diff --git a/ops/release.js b/ops/release.js index 7cdceb1..8f52f2a 100644 --- a/ops/release.js +++ b/ops/release.js @@ -4,7 +4,6 @@ const Message = require('../../shared/Message') const connector = require('../connector') module.exports = exports = function (path, fd, cb) { -console.log('[RELEASE]') connector.send( Message.route('fs.release') .data({ path, descriptor: fd }) @@ -13,7 +12,6 @@ console.log('[RELEASE]') return Errors.toCallback(cb, msg.error()) } -console.log('[/RELEASE]') return process.nextTick(cb, 0) }) ) diff --git a/ops/write.js b/ops/write.js index 18de17f..75e6244 100644 --- a/ops/write.js +++ b/ops/write.js @@ -7,7 +7,6 @@ const Streamer = require('../Streamer') module.exports = exports = async function (path, fd, buffer, length, position, cb) { try { const { socket_uuid, node_uuid, descriptor } = await connector.simple_request('stream.getfd', { descriptor: fd }) - console.log({socket_uuid, node_uuid, descriptor}) const streamer = new Streamer(socket_uuid, node_uuid, length, position, descriptor) streamer.write(buffer).then(() => {