Pied/client
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fix debugging output

Browse Source
This commit is contained in:
Garrett Mills 2020-11-29 11:57:10 -06:00
parent 203dda2abb
commit 120dbe0b0a
Signed by: garrettmills
GPG Key ID: D2BF5FBA8298F246
4 changed files with 0 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Streamer.js
View File

@ -1,7 +1,5 @@
const WebSocketStream = require('websocket-stream') const WebSocketStream = require('websocket-stream')
const ConcatStream = require('concat-stream')
const CombinedStream = require('combined-stream') const CombinedStream = require('combined-stream')
const { Duplex, Readable } = require('stream')
const { Buffer } = require('buffer') const { Buffer } = require('buffer')
class Streamer { class Streamer {

2
ops/flush.js
View File

@ -4,7 +4,6 @@ const Message = require('../../shared/Message')
const connector = require('../connector') const connector = require('../connector')
module.exports = exports = function (path, fd, cb) { module.exports = exports = function (path, fd, cb) {
console.log('[FLUSH]')
connector.send( connector.send(
Message.route('fs.flush') Message.route('fs.flush')
.data({ path, descriptor: fd }) .data({ path, descriptor: fd })
@ -13,7 +12,6 @@ console.log('[FLUSH]')
return Errors.toCallback(cb, msg.error()) return Errors.toCallback(cb, msg.error())
} }
console.log('[/FLUSH]')
return process.nextTick(cb, 0) return process.nextTick(cb, 0)
}) })
) )

2
ops/release.js
View File

@ -4,7 +4,6 @@ const Message = require('../../shared/Message')
const connector = require('../connector') const connector = require('../connector')
module.exports = exports = function (path, fd, cb) { module.exports = exports = function (path, fd, cb) {
console.log('[RELEASE]')
connector.send( connector.send(
Message.route('fs.release') Message.route('fs.release')
.data({ path, descriptor: fd }) .data({ path, descriptor: fd })
@ -13,7 +12,6 @@ console.log('[RELEASE]')
return Errors.toCallback(cb, msg.error()) return Errors.toCallback(cb, msg.error())
} }
console.log('[/RELEASE]')
return process.nextTick(cb, 0) return process.nextTick(cb, 0)
}) })
) )

1
ops/write.js
View File

@ -7,7 +7,6 @@ const Streamer = require('../Streamer')
module.exports = exports = async function (path, fd, buffer, length, position, cb) { module.exports = exports = async function (path, fd, buffer, length, position, cb) {
try { try {
const { socket_uuid, node_uuid, descriptor } = await connector.simple_request('stream.getfd', { descriptor: fd }) 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) const streamer = new Streamer(socket_uuid, node_uuid, length, position, descriptor)
streamer.write(buffer).then(() => { streamer.write(buffer).then(() => {