in lib/ec2macossystemmonitor/relayd.go [83:102]
func PassToRelayd(messageBytes []byte) (n int, err error) {
// Make sure we have socket to connect to.
if !fileExists(DefaultRelaydSocketPath) {
return 0, fmt.Errorf("ec2macossystemmonitor: %s does not exist, cannot send message: %s", DefaultRelaydSocketPath, string(messageBytes))
}
// Connect and relay!
sock, err := net.Dial("unix", DefaultRelaydSocketPath)
if err != nil {
return 0, fmt.Errorf("cec2macossystemmonitor: could not connect to %s: %s", DefaultRelaydSocketPath, err)
}
defer sock.Close()
n, err = sock.Write(messageBytes)
if err != nil {
return n, fmt.Errorf("ec2macossystemmonitor: error while writing to socket: %s", err)
}
return n, nil
}