Jan 20, 2025 · Jan 21, 2025 · Jan 21, 2025 · Jan 21, 2025 · Jan 21, 2025 · Jan 22, 2025
diff --git a/config/config.ini b/config/config.ini
 origins = https://local.arduino.cc:8000
 #httpProxy = http://your.proxy:port # Proxy server for HTTP requests
 crashreport = false # enable crashreport logging
 autostartMacOS = true # the Arduino Create Agent is able to start automatically after login on macOS (launchd agent)
 autostartMacOS = true # the Arduino Create Agent is able to start automatically after login on macOS (launchd agent)
diff --git a/conn.go b/conn.go
 "os"
 "path/filepath"

 "github.com/arduino/arduino-create-agent/tools"
 "github.com/arduino/arduino-create-agent/upload"
 "github.com/arduino/arduino-create-agent/utilities"
 "github.com/gin-gonic/gin"

 var uploadStatusStr = "ProgrammerStatus"

 func uploadHandler(pubKey *rsa.PublicKey) func(*gin.Context) {
 func uploadHandler(hub *hub,pubKey *rsa.PublicKey, tools *tools.Tools) func(*gin.Context) {
 return func(c *gin.Context) {
 data := new(Upload)
 if err := c.BindJSON(data); err != nil {

 go func() {
 // Resolve commandline
 commandline, err := upload.PartiallyResolve(data.Board, filePath, tmpdir, data.Commandline, data.Extra,Tools)
 commandline, err := upload.PartiallyResolve(data.Board, filePath, tmpdir, data.Commandline, data.Extra,tools)
 if err != nil {
 send(map[string]string{uploadStatusStr: "Error", "Msg": err.Error()})
 send(hub,map[string]string{uploadStatusStr: "Error", "Msg": err.Error()})
 return
 }

 l := PLogger{Verbose: true}
 l := PLogger{Verbose: true, hub: hub}

 // Upload
 if data.Extra.Network {
 err = errors.New("network upload is not supported anymore, pease use OTA instead")
 } else {
 send(map[string]string{uploadStatusStr: "Starting", "Cmd": "Serial"})
 send(hub,map[string]string{uploadStatusStr: "Starting", "Cmd": "Serial"})
 err = upload.Serial(data.Port, commandline, data.Extra, l)
 }

 // Handle result
 if err != nil {
 send(map[string]string{uploadStatusStr: "Error", "Msg": err.Error()})
 send(hub,map[string]string{uploadStatusStr: "Error", "Msg": err.Error()})
 return
 }
 send(map[string]string{uploadStatusStr: "Done", "Flash": "Ok"})
 send(hub,map[string]string{uploadStatusStr: "Done", "Flash": "Ok"})
 }()

 c.String(http.StatusAccepted, "")
 // PLogger sends the info from the upload to the websocket
 type PLogger struct {
 Verbose bool
 hub     *hub
 }

 // Debug only sends messages if verbose is true (always true for now)
 func (l PLogger) Info(args ...interface{}) {
 output := fmt.Sprint(args...)
 log.Println(output)
 send(map[string]string{uploadStatusStr: "Busy", "Msg": output})
 send(l.hub,map[string]string{uploadStatusStr: "Busy", "Msg": output})
 }

 func send(args map[string]string) {
 func send(h *hub,args map[string]string) {
 mapB, _ := json.Marshal(args)
 h.broadcastSys <- mapB
 }

 func wsHandler() *WsServer {
 func wsHandler(h *hub) *WsServer {
 server, err := socketio.NewServer(nil)
 if err != nil {
 log.Fatal(err)
diff --git a/hub.go b/hub.go
 "runtime/debug"
 "strconv"
 "strings"
 "sync"

 "github.com/arduino/arduino-create-agent/systray"
 "github.com/arduino/arduino-create-agent/tools"
 "github.com/arduino/arduino-create-agent/upload"
 log "github.com/sirupsen/logrus"
 )

 // Unregister requests from connections.
 unregister chan *connection

 // Serial hub to communicate with serial ports
 serialHub *serialhub

 serialPortList *SerialPortList

 tools *tools.Tools

 systray *systray.Systray

 // This lock is used to prevent multiple threads from trying to open the same port at the same time.
 // It presents issues with the serial port driver on some OS's: https://github.com/arduino/arduino-create-agent/issues/1031
 spHandlerOpenLock sync.Mutex
 }

 var h = hub{
 broadcast:    make(chan []byte, 1000),
 broadcastSys: make(chan []byte, 1000),
 register:     make(chan *connection),
 unregister:   make(chan *connection),
 connections:  make(map[*connection]bool),
 func newHub(tools *tools.Tools, systray *systray.Systray) *hub {
 broadcastSys := make(chan []byte, 1000)

 onRegister := func(port *serport, msg string) {
 broadcastSys <- []byte("{\"Cmd\":\"Open\",\"Desc\":\"" + msg + "\",\"Port\":\"" + port.portConf.Name + "\",\"Baud\":" + strconv.Itoa(port.portConf.Baud) + ",\"BufferType\":\"" + port.BufferType + "\"}")
 }
 onUnregister := func(port *serport) {
 broadcastSys <- []byte("{\"Cmd\":\"Close\",\"Desc\":\"Got unregister/close on port.\",\"Port\":\"" + port.portConf.Name + "\",\"Baud\":" + strconv.Itoa(port.portConf.Baud) + "}")
 }
 serialHubub := newSerialHub(onRegister, onUnregister)

 onList := func(data []byte) {
 broadcastSys <- data
 }
 onErr := func(err string) {
 broadcastSys <- []byte("{\"Error\":\"" + err + "\"}")
 }
 serialPortList := newSerialPortList(tools, onList, onErr)

 return &hub{
 broadcast:      make(chan []byte, 1000),
 broadcastSys:   broadcastSys,
 register:       make(chan *connection),
 unregister:     make(chan *connection),
 connections:    make(map[*connection]bool),
 serialHub:      serialHubub,
 serialPortList: serialPortList,
 tools:          tools,
 systray:        systray,
 }
 }

 const commands = `{
 }

 func (h *hub) run() {
 go h.serialPortList.Run()

 for {
 select {
 case c := <-h.register:
 h.unregisterConnection(c)
 case m := <-h.broadcast:
 if len(m) > 0 {
 checkCmd(m)
 h.checkCmd(m)
 h.sendToRegisteredConnections(m)
 }
 case m := <-h.broadcastSys:
 }
 }

 func checkCmd(m []byte) {
 func(h *hub)checkCmd(m []byte) {
 //log.Print("Inside checkCmd")
 s := string(m[:])


 args := strings.Split(s, " ")
 if len(args) < 3 {
 go spErr("You did not specify a port and baud rate in your open cmd")
 goh.spErr("You did not specify a port and baud rate in your open cmd")
 return
 }
 if len(args[1]) < 1 {
 go spErr("You did not specify a serial port")
 goh.spErr("You did not specify a serial port")
 return
 }

 baudStr := strings.Replace(args[2], "\n", "", -1)
 baud, err := strconv.Atoi(baudStr)
 if err != nil {
 go spErr("Problem converting baud rate " + args[2])
 goh.spErr("Problem converting baud rate " + args[2])
 return
 }
 // pass in buffer type now as string. if user does not
 buftype := strings.Replace(args[3], "\n", "", -1)
 bufferAlgorithm = buftype
 }
 go spHandlerOpen(args[1], baud, bufferAlgorithm)
 goh.spHandlerOpen(args[1], baud, bufferAlgorithm)

 } else if strings.HasPrefix(sl, "close") {

 args := strings.Split(s, " ")
 if len(args) > 1 {
 go spClose(args[1])
 goh.spClose(args[1])
 } else {
 go spErr("You did not specify a port to close")
 goh.spErr("You did not specify a port to close")
 }

 } else if strings.HasPrefix(sl, "killupload") {

 } else if strings.HasPrefix(sl, "send") {
 // will catch send and sendnobuf and sendraw
 go spWrite(s)
 goh.spWrite(s)
 } else if strings.HasPrefix(sl, "list") {
 goserialPorts.List()
 goh.serialPortList.List()
 } else if strings.HasPrefix(sl, "downloadtool") {
 go func() {
 args := strings.Split(s, " ")
 behaviour = args[4]
 }

 err := Tools.Download(pack, tool, toolVersion, behaviour)
 reportPendingProgress := func(msg string) {
 mapD := map[string]string{"DownloadStatus": "Pending", "Msg": msg}
 mapB, _ := json.Marshal(mapD)
 h.broadcastSys <- mapB
 }
 err := h.tools.Download(pack, tool, toolVersion, behaviour, reportPendingProgress)
 if err != nil {
 mapD := map[string]string{"DownloadStatus": "Error", "Msg": err.Error()}
 mapB, _ := json.Marshal(mapD)
 }
 }()
 } else if strings.HasPrefix(sl, "log") {
 go logAction(sl)
 goh.logAction(sl)
 } else if strings.HasPrefix(sl, "restart") {
 // potentially, the sysStray dependencies can be removed  https://github.com/arduino/arduino-create-agent/issues/1013
 log.Println("Received restart from the daemon. Why? Boh")
 Systray.Restart()
 h.systray.Restart()
 } else if strings.HasPrefix(sl, "exit") {
 Systray.Quit()
 h.systray.Quit()
 } else if strings.HasPrefix(sl, "memstats") {
 memoryStats()
 h.memoryStats()
 } else if strings.HasPrefix(sl, "gc") {
 garbageCollection()
 h.garbageCollection()
 } else if strings.HasPrefix(sl, "hostname") {
 getHostname()
 h.getHostname()
 } else if strings.HasPrefix(sl, "version") {
 getVersion()
 h.getVersion()
 } else {
 go spErr("Could not understand command.")
 goh.spErr("Could not understand command.")
 }
 }

 func logAction(sl string) {
 // ChanWriter is a simple io.Writer that sends data to a channel.
 type ChanWriter struct {
 Ch chan<- []byte
 }

 func (u *ChanWriter) Write(p []byte) (n int, err error) {
 u.Ch <- p
 return len(p), nil
 }

 func (h *hub) logAction(sl string) {
 if strings.HasPrefix(sl, "log on") {
 *logDump = "on"
 multiWriter := io.MultiWriter(&loggerWs, os.Stderr)

 multiWriter := io.MultiWriter(&ChanWriter{Ch: h.broadcastSys}, os.Stderr)
 log.SetOutput(multiWriter)
 } else if strings.HasPrefix(sl, "log off") {
 *logDump = "off"
 }
 }

 func memoryStats() {
 func(h *hub)memoryStats() {
 var memStats runtime.MemStats
 runtime.ReadMemStats(&memStats)
 json, _ := json.Marshal(memStats)
 log.Printf("memStats:%v\n", string(json))
 h.broadcastSys <- json
 }

 func getHostname() {
 func(h *hub)getHostname() {
 h.broadcastSys <- []byte("{\"Hostname\" : \"" + *hostname + "\"}")
 }

 func getVersion() {
 func(h *hub)getVersion() {
 h.broadcastSys <- []byte("{\"Version\" : \"" + version + "\"}")
 }

 func garbageCollection() {
 func(h *hub)garbageCollection() {
 log.Printf("Starting garbageCollection()\n")
 h.broadcastSys <- []byte("{\"gc\":\"starting\"}")
 memoryStats()
 h.memoryStats()
 debug.SetGCPercent(100)
 debug.FreeOSMemory()
 debug.SetGCPercent(-1)
 log.Printf("Done with garbageCollection()\n")
 h.broadcastSys <- []byte("{\"gc\":\"done\"}")
 memoryStats()
 h.memoryStats()
 }
diff --git a/info.go b/info.go
 "runtime"
 "strings"

 "github.com/arduino/arduino-create-agent/systray"
 "github.com/gin-gonic/gin"
 "go.bug.st/serial"
 )
 })
 }

 func pauseHandler(c *gin.Context) {
 go func() {
 ports, _ := serial.GetPortsList()
 for _, element := range ports {
 spClose(element)
 }
 *hibernate = true
 Systray.Pause()
 }()
 c.JSON(200, nil)
 func pauseHandler(hub *hub, s *systray.Systray) func(c *gin.Context) {
 return func(c *gin.Context) {
 go func() {
 ports, _ := serial.GetPortsList()
 for _, element := range ports {
 hub.spClose(element)
 }
 *hibernate = true
 s.Pause()
 }()
 c.JSON(200, nil)
 }
 }
Original file line number	Diff line number	Diff line change
Expand Up		@@ -7,4 +7,4 @@ updateUrl = https://downloads.arduino.cc/
		origins = https://local.arduino.cc:8000
		#httpProxy = http://your.proxy:port # Proxy server for HTTP requests
		crashreport = false # enable crashreport logging
		autostartMacOS = true # the Arduino Create Agent is able to start automatically after login on macOS (launchd agent)
		autostartMacOS = true # the Arduino Create Agent is able to start automatically after login on macOS (launchd agent)
Original file line number	Diff line number	Diff line change
Expand Up		@@ -27,6 +27,7 @@ import (
		"os"
		"path/filepath"

		"github.com/arduino/arduino-create-agent/tools"
		"github.com/arduino/arduino-create-agent/upload"
		"github.com/arduino/arduino-create-agent/utilities"
		"github.com/gin-gonic/gin"
Expand DownExpand Up		@@ -80,7 +81,7 @@ type Upload struct {

		var uploadStatusStr = "ProgrammerStatus"

		func uploadHandler(pubKey rsa.PublicKey) func(gin.Context) {
		func uploadHandler(hub hub,pubKey rsa.PublicKey, tools tools.Tools) func(gin.Context) {
		return func(c *gin.Context) {
		data := new(Upload)
		if err := c.BindJSON(data); err != nil {
Expand DownExpand Up		@@ -162,28 +163,28 @@ func uploadHandler(pubKey rsa.PublicKey) func(gin.Context) {

		go func() {
		// Resolve commandline
		commandline, err := upload.PartiallyResolve(data.Board, filePath, tmpdir, data.Commandline, data.Extra,Tools)
		commandline, err := upload.PartiallyResolve(data.Board, filePath, tmpdir, data.Commandline, data.Extra,tools)
		if err != nil {
		send(map[string]string{uploadStatusStr: "Error", "Msg": err.Error()})
		send(hub,map[string]string{uploadStatusStr: "Error", "Msg": err.Error()})
		return
		}

		l := PLogger{Verbose: true}
		l := PLogger{Verbose: true, hub: hub}

		// Upload
		if data.Extra.Network {
		err = errors.New("network upload is not supported anymore, pease use OTA instead")
		} else {
		send(map[string]string{uploadStatusStr: "Starting", "Cmd": "Serial"})
		send(hub,map[string]string{uploadStatusStr: "Starting", "Cmd": "Serial"})
		err = upload.Serial(data.Port, commandline, data.Extra, l)
		}

		// Handle result
		if err != nil {
		send(map[string]string{uploadStatusStr: "Error", "Msg": err.Error()})
		send(hub,map[string]string{uploadStatusStr: "Error", "Msg": err.Error()})
		return
		}
		send(map[string]string{uploadStatusStr: "Done", "Flash": "Ok"})
		send(hub,map[string]string{uploadStatusStr: "Done", "Flash": "Ok"})
		}()

		c.String(http.StatusAccepted, "")
Expand All		@@ -193,6 +194,7 @@ func uploadHandler(pubKey rsa.PublicKey) func(gin.Context) {
		// PLogger sends the info from the upload to the websocket
		type PLogger struct {
		Verbose bool
		hub *hub
		}

		// Debug only sends messages if verbose is true (always true for now)
Expand All		@@ -206,15 +208,15 @@ func (l PLogger) Debug(args ...interface{}) {
		func (l PLogger) Info(args ...interface{}) {
		output := fmt.Sprint(args...)
		log.Println(output)
		send(map[string]string{uploadStatusStr: "Busy", "Msg": output})
		send(l.hub,map[string]string{uploadStatusStr: "Busy", "Msg": output})
		}

		func send(args map[string]string) {
		func send(h *hub,args map[string]string) {
		mapB, _ := json.Marshal(args)
		h.broadcastSys <- mapB
		}

		func wsHandler() *WsServer {
		func wsHandler(h hub) WsServer {
		server, err := socketio.NewServer(nil)
		if err != nil {
		log.Fatal(err)
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -25,7 +25,10 @@ import (
		"runtime/debug"
		"strconv"
		"strings"
		"sync"

		"github.com/arduino/arduino-create-agent/systray"
		"github.com/arduino/arduino-create-agent/tools"
		"github.com/arduino/arduino-create-agent/upload"
		log "github.com/sirupsen/logrus"
		)
Expand All		@@ -45,14 +48,51 @@ type hub struct {

		// Unregister requests from connections.
		unregister chan *connection

		// Serial hub to communicate with serial ports
		serialHub *serialhub

		serialPortList *SerialPortList

		tools *tools.Tools

		systray *systray.Systray

		// This lock is used to prevent multiple threads from trying to open the same port at the same time.
		// It presents issues with the serial port driver on some OS's: https://github.com/arduino/arduino-create-agent/issues/1031
		spHandlerOpenLock sync.Mutex
		}

		var h = hub{
		broadcast: make(chan []byte, 1000),
		broadcastSys: make(chan []byte, 1000),
		register: make(chan *connection),
		unregister: make(chan *connection),
		connections: make(map[*connection]bool),
		func newHub(tools tools.Tools, systray systray.Systray) *hub {
		broadcastSys := make(chan []byte, 1000)

		onRegister := func(port *serport, msg string) {
		broadcastSys <- []byte("{\"Cmd\":\"Open\",\"Desc\":\"" + msg + "\",\"Port\":\"" + port.portConf.Name + "\",\"Baud\":" + strconv.Itoa(port.portConf.Baud) + ",\"BufferType\":\"" + port.BufferType + "\"}")
		}
		onUnregister := func(port *serport) {
		broadcastSys <- []byte("{\"Cmd\":\"Close\",\"Desc\":\"Got unregister/close on port.\",\"Port\":\"" + port.portConf.Name + "\",\"Baud\":" + strconv.Itoa(port.portConf.Baud) + "}")
		}
		serialHubub := newSerialHub(onRegister, onUnregister)

		onList := func(data []byte) {
		broadcastSys <- data
		}
		onErr := func(err string) {
		broadcastSys <- []byte("{\"Error\":\"" + err + "\"}")
		}
		serialPortList := newSerialPortList(tools, onList, onErr)

		return &hub{
		broadcast: make(chan []byte, 1000),
		broadcastSys: broadcastSys,
		register: make(chan *connection),
		unregister: make(chan *connection),
		connections: make(map[*connection]bool),
		serialHub: serialHubub,
		serialPortList: serialPortList,
		tools: tools,
		systray: systray,
		}
		}

		const commands = `{
Expand DownExpand Up		@@ -95,6 +135,8 @@ func (h *hub) sendToRegisteredConnections(data []byte) {
		}

		func (h *hub) run() {
		go h.serialPortList.Run()

		for {
		select {
		case c := <-h.register:
Expand All		@@ -108,7 +150,7 @@ func (h *hub) run() {
		h.unregisterConnection(c)
		case m := <-h.broadcast:
		if len(m) > 0 {
		checkCmd(m)
		h.checkCmd(m)
		h.sendToRegisteredConnections(m)
		}
		case m := <-h.broadcastSys:
Expand All		@@ -117,7 +159,7 @@ func (h *hub) run() {
		}
		}

		func checkCmd(m []byte) {
		func(h *hub)checkCmd(m []byte) {
		//log.Print("Inside checkCmd")
		s := string(m[:])

Expand All		@@ -132,18 +174,18 @@ func checkCmd(m []byte) {

		args := strings.Split(s, " ")
		if len(args) < 3 {
		go spErr("You did not specify a port and baud rate in your open cmd")
		goh.spErr("You did not specify a port and baud rate in your open cmd")
		return
		}
		if len(args[1]) < 1 {
		go spErr("You did not specify a serial port")
		goh.spErr("You did not specify a serial port")
		return
		}

		baudStr := strings.Replace(args[2], "\n", "", -1)
		baud, err := strconv.Atoi(baudStr)
		if err != nil {
		go spErr("Problem converting baud rate " + args[2])
		goh.spErr("Problem converting baud rate " + args[2])
		return
		}
		// pass in buffer type now as string. if user does not
Expand All		@@ -154,15 +196,15 @@ func checkCmd(m []byte) {
		buftype := strings.Replace(args[3], "\n", "", -1)
		bufferAlgorithm = buftype
		}
		go spHandlerOpen(args[1], baud, bufferAlgorithm)
		goh.spHandlerOpen(args[1], baud, bufferAlgorithm)

		} else if strings.HasPrefix(sl, "close") {

		args := strings.Split(s, " ")
		if len(args) > 1 {
		go spClose(args[1])
		goh.spClose(args[1])
		} else {
		go spErr("You did not specify a port to close")
		goh.spErr("You did not specify a port to close")
		}

		} else if strings.HasPrefix(sl, "killupload") {
Expand All		@@ -175,9 +217,9 @@ func checkCmd(m []byte) {

		} else if strings.HasPrefix(sl, "send") {
		// will catch send and sendnobuf and sendraw
		go spWrite(s)
		goh.spWrite(s)
		} else if strings.HasPrefix(sl, "list") {
		goserialPorts.List()
		goh.serialPortList.List()
		} else if strings.HasPrefix(sl, "downloadtool") {
		go func() {
		args := strings.Split(s, " ")
Expand DownExpand Up		@@ -208,7 +250,12 @@ func checkCmd(m []byte) {
		behaviour = args[4]
		}

		err := Tools.Download(pack, tool, toolVersion, behaviour)
		reportPendingProgress := func(msg string) {
		mapD := map[string]string{"DownloadStatus": "Pending", "Msg": msg}
		mapB, _ := json.Marshal(mapD)
		h.broadcastSys <- mapB
		}
		err := h.tools.Download(pack, tool, toolVersion, behaviour, reportPendingProgress)
		if err != nil {
		mapD := map[string]string{"DownloadStatus": "Error", "Msg": err.Error()}
		mapB, _ := json.Marshal(mapD)
Expand All		@@ -220,29 +267,41 @@ func checkCmd(m []byte) {
		}
		}()
		} else if strings.HasPrefix(sl, "log") {
		go logAction(sl)
		goh.logAction(sl)
		} else if strings.HasPrefix(sl, "restart") {
		// potentially, the sysStray dependencies can be removed https://github.com/arduino/arduino-create-agent/issues/1013
		log.Println("Received restart from the daemon. Why? Boh")
		Systray.Restart()
		h.systray.Restart()
		} else if strings.HasPrefix(sl, "exit") {
		Systray.Quit()
		h.systray.Quit()
		} else if strings.HasPrefix(sl, "memstats") {
		memoryStats()
		h.memoryStats()
		} else if strings.HasPrefix(sl, "gc") {
		garbageCollection()
		h.garbageCollection()
		} else if strings.HasPrefix(sl, "hostname") {
		getHostname()
		h.getHostname()
		} else if strings.HasPrefix(sl, "version") {
		getVersion()
		h.getVersion()
		} else {
		go spErr("Could not understand command.")
		goh.spErr("Could not understand command.")
		}
		}

		func logAction(sl string) {
		// ChanWriter is a simple io.Writer that sends data to a channel.
		type ChanWriter struct {
		Ch chan<- []byte
		}

		func (u *ChanWriter) Write(p []byte) (n int, err error) {
		u.Ch <- p
		return len(p), nil
		}

		func (h *hub) logAction(sl string) {
		if strings.HasPrefix(sl, "log on") {
		*logDump = "on"
		multiWriter := io.MultiWriter(&loggerWs, os.Stderr)

		multiWriter := io.MultiWriter(&ChanWriter{Ch: h.broadcastSys}, os.Stderr)
		log.SetOutput(multiWriter)
		} else if strings.HasPrefix(sl, "log off") {
		*logDump = "off"
Expand All		@@ -253,30 +312,30 @@ func logAction(sl string) {
		}
		}

		func memoryStats() {
		func(h *hub)memoryStats() {
		var memStats runtime.MemStats
		runtime.ReadMemStats(&memStats)
		json, _ := json.Marshal(memStats)
		log.Printf("memStats:%v\n", string(json))
		h.broadcastSys <- json
		}

		func getHostname() {
		func(h *hub)getHostname() {
		h.broadcastSys <- []byte("{\"Hostname\" : \"" + *hostname + "\"}")
		}

		func getVersion() {
		func(h *hub)getVersion() {
		h.broadcastSys <- []byte("{\"Version\" : \"" + version + "\"}")
		}

		func garbageCollection() {
		func(h *hub)garbageCollection() {
		log.Printf("Starting garbageCollection()\n")
		h.broadcastSys <- []byte("{\"gc\":\"starting\"}")
		memoryStats()
		h.memoryStats()
		debug.SetGCPercent(100)
		debug.FreeOSMemory()
		debug.SetGCPercent(-1)
		log.Printf("Done with garbageCollection()\n")
		h.broadcastSys <- []byte("{\"gc\":\"done\"}")
		memoryStats()
		h.memoryStats()
		}
Original file line number	Diff line number	Diff line change
Expand Up		@@ -19,6 +19,7 @@ import (
		"runtime"
		"strings"

		"github.com/arduino/arduino-create-agent/systray"
		"github.com/gin-gonic/gin"
		"go.bug.st/serial"
		)
Expand All		@@ -40,14 +41,16 @@ func infoHandler(c *gin.Context) {
		})
		}

		func pauseHandler(c *gin.Context) {
		go func() {
		ports, _ := serial.GetPortsList()
		for _, element := range ports {
		spClose(element)
		}
		*hibernate = true
		Systray.Pause()
		}()
		c.JSON(200, nil)
		func pauseHandler(hub hub, s systray.Systray) func(c *gin.Context) {
		return func(c *gin.Context) {
		go func() {
		ports, _ := serial.GetPortsList()
		for _, element := range ports {
		hub.spClose(element)
		}
		*hibernate = true
		s.Pause()
		}()
		c.JSON(200, nil)
		}
		}