From 02dde6c2a2efeb34820f6bf72abc01867ea11cb0 Mon Sep 17 00:00:00 2001
From: Benjamin Grewell <bgrewell@gmail.com>
Date: Wed, 7 Apr 2021 07:46:27 -0700
Subject: [PATCH] add macOS support

---
 .idea/workspace.xml |  16 +++---
 reporter_darwin.go  | 128 ++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 134 insertions(+), 10 deletions(-)
 create mode 100644 reporter_darwin.go

diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index 890bc6a..951badb 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -2,12 +2,7 @@
 <project version="4">
   <component name="ChangeListManager">
     <list default="true" id="fc2840de-29dc-4fca-8e0e-a283562f60ca" name="Default Changelist" comment="">
-      <change afterPath="$PROJECT_DIR$/tests/extract/main.go" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/bindata.go" beforeDir="false" afterPath="$PROJECT_DIR$/bindata.go" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/go.mod" beforeDir="false" afterPath="$PROJECT_DIR$/go.mod" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/go.sum" beforeDir="false" afterPath="$PROJECT_DIR$/go.sum" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/iperf.go" beforeDir="false" afterPath="$PROJECT_DIR$/iperf.go" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/reporter_darwin.go" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
@@ -42,18 +37,19 @@
     <property name="go.import.settings.migrated" value="true" />
     <property name="go.sdk.automatically.set" value="true" />
     <property name="go.tried.to.enable.integration.vgo.integrator" value="true" />
-    <property name="last_opened_file_path" value="$PROJECT_DIR$/../ran_onf/onos-ric-master/cmd/apps/onos-ric-mlb/onos-ran-mlb.go" />
+    <property name="last_opened_file_path" value="$PROJECT_DIR$" />
     <property name="nodejs_interpreter_path.stuck_in_default_project" value="undefined stuck path" />
     <property name="nodejs_npm_path_reset_for_default_project" value="true" />
   </component>
   <component name="RecentsManager">
+    <key name="MoveFile.RECENT_KEYS">
+      <recent name="C:\Users\BGrewell\source\repos\go-iperf\tests\server" />
+    </key>
     <key name="CopyFile.RECENT_KEYS">
+      <recent name="$PROJECT_DIR$" />
       <recent name="C:\Users\BGrewell\source\repos\go-iperf" />
       <recent name="C:\Users\BGrewell\repos\go-iperf\embedded" />
     </key>
-    <key name="MoveFile.RECENT_KEYS">
-      <recent name="C:\Users\BGrewell\source\repos\go-iperf\tests\server" />
-    </key>
   </component>
   <component name="RunManager" selected="Go Build.go build github.com/BGrewell/go-iperf/tests/controller">
     <configuration name="go build github.com/BGrewell/go-iperf/cmd" type="GoApplicationRunConfiguration" factoryName="Go Application" temporary="true" nameIsGenerated="true">
diff --git a/reporter_darwin.go b/reporter_darwin.go
new file mode 100644
index 0000000..40f0f31
--- /dev/null
+++ b/reporter_darwin.go
@@ -0,0 +1,128 @@
+package iperf
+
+import (
+	"fmt"
+	"github.com/BGrewell/go-conversions"
+	"github.com/BGrewell/tail"
+	"log"
+	"strconv"
+	"strings"
+	"time"
+)
+
+/*
+Connecting to host 10.254.100.100, port 5201
+[  4] local 192.168.3.182 port 54104 connected to 10.254.100.100 port 5201
+[ ID] Interval           Transfer     Bandwidth       Retr  Cwnd
+[  4]   0.00-1.00   sec   109 MBytes   913 Mbits/sec   13    634 KBytes       (omitted)
+[  4]   1.00-2.00   sec   110 MBytes   927 Mbits/sec    7    550 KBytes       (omitted)
+[  4]   2.00-3.00   sec   109 MBytes   918 Mbits/sec    6    559 KBytes       (omitted)
+[  4]   3.00-4.00   sec   111 MBytes   930 Mbits/sec    6    690 KBytes       (omitted)
+[  4]   4.00-5.00   sec   111 MBytes   933 Mbits/sec    0    803 KBytes       (omitted)
+[  4]   5.00-6.00   sec   111 MBytes   933 Mbits/sec    6    673 KBytes       (omitted)
+[  4]   6.00-7.00   sec   111 MBytes   932 Mbits/sec    6    605 KBytes       (omitted)
+[  4]   7.00-8.00   sec   110 MBytes   925 Mbits/sec    0    732 KBytes       (omitted)
+[  4]   8.00-9.00   sec   111 MBytes   932 Mbits/sec    0    840 KBytes       (omitted)
+[  4]   9.00-10.00  sec   110 MBytes   923 Mbits/sec    6    690 KBytes       (omitted)
+[  4]   0.00-1.00   sec   111 MBytes   928 Mbits/sec    6    618 KBytes
+[  4]   1.00-2.00   sec   111 MBytes   931 Mbits/sec    0    745 KBytes
+[  4]   2.00-3.00   sec   111 MBytes   929 Mbits/sec   11    614 KBytes
+[  4]   3.00-4.00   sec   110 MBytes   922 Mbits/sec    6    551 KBytes
+[  4]   4.00-5.00   sec   111 MBytes   933 Mbits/sec    6    519 KBytes
+[  4]   5.00-6.00   sec   111 MBytes   928 Mbits/sec    0    663 KBytes
+[  4]   6.00-7.00   sec   111 MBytes   932 Mbits/sec    0    783 KBytes
+[  4]   7.00-8.00   sec   111 MBytes   933 Mbits/sec    6    656 KBytes
+[  4]   8.00-9.00   sec   111 MBytes   933 Mbits/sec    6    598 KBytes
+[  4]   9.00-10.00  sec   110 MBytes   925 Mbits/sec    0    728 KBytes
+[  4]  10.00-11.00  sec   111 MBytes   933 Mbits/sec    0    839 KBytes
+[  4]  11.00-12.00  sec   109 MBytes   918 Mbits/sec    6    680 KBytes
+[  4]  12.00-12.24  sec  25.0 MBytes   888 Mbits/sec    0    711 KBytes
+- - - - - - - - - - - - - - - - - - - - - - - - -
+[ ID] Interval           Transfer     Bandwidth       Retr
+[  4]   0.00-12.24  sec  1.32 GBytes   928 Mbits/sec   47             sender
+[  4]   0.00-12.24  sec  0.00 Bytes  0.00 bits/sec                  receiver
+
+iperf Done.
+
+*/
+func (r *Reporter) runLogProcessor() {
+	var err error
+	r.tailer, err = tail.TailFile(r.LogFile, tail.Config{
+		Follow:    true,
+		ReOpen:    true,
+		Poll:      false, // on linux we don't need to poll as the fsnotify works properly
+		MustExist: true,
+	})
+	if err != nil {
+		log.Fatalf("failed to tail log file: %v", err)
+	}
+
+	for {
+		select {
+		case line := <-r.tailer.Lines:
+			if line == nil {
+				continue
+			}
+			if len(line.Text) > 5 {
+				id := line.Text[1:4]
+				stream, err := strconv.Atoi(strings.TrimSpace(id))
+				if err != nil {
+					continue
+				}
+				fields := strings.Fields(line.Text[5:])
+				if len(fields) >= 9 {
+					if fields[0] == "local" {
+						continue
+					}
+					timeFields := strings.Split(fields[0], "-")
+					start, err := strconv.ParseFloat(timeFields[0], 32)
+					if err != nil {
+						log.Printf("failed to convert start time: %s\n", err)
+					}
+					end, err := strconv.ParseFloat(timeFields[1], 32)
+					transferedStr := fmt.Sprintf("%s%s", fields[2], fields[3])
+					transferedBytes, err := conversions.StringBitRateToInt(transferedStr)
+					if err != nil {
+						log.Printf("failed to convert units: %s\n", err)
+					}
+					transferedBytes = transferedBytes / 8
+					rateStr := fmt.Sprintf("%s%s", fields[4], fields[5])
+					rate, err := conversions.StringBitRateToInt(rateStr)
+					if err != nil {
+						log.Printf("failed to convert units: %s\n", err)
+					}
+					retrans, err := strconv.Atoi(fields[6])
+					if err != nil {
+						log.Printf("failed to convert units: %s\n", err)
+					}
+					cwndStr := fmt.Sprintf("%s%s", fields[7], fields[8])
+					cwnd, err := conversions.StringBitRateToInt(cwndStr)
+					if err != nil {
+						log.Printf("failed to convert units: %s\n", err)
+					}
+					cwnd = cwnd / 8
+					omitted := false
+					if len(fields) >= 10 && fields[9] == "(omitted)" {
+						omitted = true
+					}
+					report := &StreamIntervalReport{
+						Socket:           stream,
+						StartInterval:    float32(start),
+						EndInterval:      float32(end),
+						Seconds:          float32(end - start),
+						Bytes:            int(transferedBytes),
+						BitsPerSecond:    float64(rate),
+						Retransmissions:  retrans,
+						CongestionWindow: int(cwnd),
+						Omitted:          omitted,
+					}
+					r.ReportingChannel <- report
+				}
+			}
+		case <-time.After(100 * time.Millisecond):
+			if !r.running {
+				return
+			}
+		}
+	}
+}