chore: add trace logs to mss and remove commented perf code

libp2p · Nov 17, 2023 · 3e621f3 · 3e621f3
1 parent 6625a27
commit 3e621f3
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 62 deletions.
diff --git a/packages/multistream-select/src/handle.ts b/packages/multistream-select/src/handle.ts
@@ -71,8 +71,8 @@ export async function handle <Stream extends Duplex<any, any, any>> (stream: Str
     }
 
     if (protocols.includes(protocol)) {
-      await multistream.write(lp, uint8ArrayFromString(`${protocol}\n`), options)
       options.log.trace('respond with "%s" for "%s"', protocol, protocol)
+      await multistream.write(lp, uint8ArrayFromString(`${protocol}\n`), options)
 
       return { stream: lp.unwrap(), protocol }
     }
@@ -89,7 +89,7 @@ export async function handle <Stream extends Duplex<any, any, any>> (stream: Str
       continue
     }
 
-    await multistream.write(lp, uint8ArrayFromString('na\n'), options)
     options.log('respond with "na" for "%s"', protocol)
+    await multistream.write(lp, uint8ArrayFromString('na\n'), options)
   }
 }
diff --git a/packages/multistream-select/src/select.ts b/packages/multistream-select/src/select.ts
@@ -66,11 +66,13 @@ export async function select <Stream extends Duplex<any, any, any>> (stream: Str
   const p2 = uint8ArrayFromString(`${protocol}\n`)
   await multistream.writeAll(lp, [p1, p2], options)
 
+  options?.log.trace('select: reading multistream-select header')
   let response = await multistream.readString(lp, options)
   options?.log.trace('select: read "%s"', response)
 
   // Read the protocol response if we got the protocolId in return
   if (response === PROTOCOL_ID) {
+    options?.log.trace('select: reading protocol response')
     response = await multistream.readString(lp, options)
     options?.log.trace('select: read "%s"', response)
   }
@@ -84,6 +86,7 @@ export async function select <Stream extends Duplex<any, any, any>> (stream: Str
   for (const protocol of protocols) {
     options?.log.trace('select: write "%s"', protocol)
     await multistream.write(lp, uint8ArrayFromString(`${protocol}\n`), options)
+    options?.log.trace('select: reading protocol response')
     const response = await multistream.readString(lp, options)
     options?.log.trace('select: read "%s" for "%s"', response, protocol)
 

diff --git a/packages/protocol-perf/src/perf-service.ts b/packages/protocol-perf/src/perf-service.ts
@@ -160,71 +160,11 @@ export class Perf implements Startable, PerfInterface {
 
       yield * output
 
-      /*
-      const b = byteStream(stream)
-      await b.write(uint8Buf.subarray(0, 8), options)
-
-      while (sendBytes > 0) {
-        let toSend: number = writeBlockSize
-
-        if (toSend > sendBytes) {
-          toSend = sendBytes
-        }
-
-        const chunk = uint8Buf.subarray(0, toSend)
-
-        await b.write(chunk, options)
-
-        sendBytes -= toSend
-
-        if (Date.now() - lastReportedTime > 1000) {
-          yield {
-            type: 'intermediary',
-            timeSeconds: (Date.now() - lastReportedTime) / 1000,
-            uploadBytes: lastAmountOfBytesSent,
-            downloadBytes: 0
-          }
-
-          // record last reported time after `console.log` because it can
-          // affect benchmark timings
-          lastReportedTime = Date.now()
-          lastAmountOfBytesSent = 0
-        }
-
-        lastAmountOfBytesSent += toSend
-        totalBytesSent += toSend
-      }
-
-      // sent all the bytes, close the write end of the stream
-      await b.unwrap().closeWrite()
-
-*/
       // Read the received bytes
       let lastAmountOfBytesReceived = 0
       lastReportedTime = Date.now()
       let totalBytesReceived = 0
-      /*
-      while (totalBytesReceived < receiveBytes) {
-        const buf = await b.read(1024, options)
-
-        if (Date.now() - lastReportedTime > 1000) {
-          yield {
-            type: 'intermediary',
-            timeSeconds: (Date.now() - lastReportedTime) / 1000,
-            uploadBytes: 0,
-            downloadBytes: lastAmountOfBytesReceived
-          }
 
-          // record last reported time after `console.log` because it can
-          // affect benchmark timings
-          lastReportedTime = Date.now()
-          lastAmountOfBytesReceived = 0
-        }
-
-        lastAmountOfBytesReceived += buf.byteLength
-        totalBytesReceived += buf.byteLength
-      }
-*/
       for await (const buf of stream.source) {
         if (Date.now() - lastReportedTime > 1000) {
           yield {