You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
51 lines
758 B
Go
51 lines
758 B
Go
4 years ago
|
package iperf
|
||
|
|
|
||
|
|
import (
|
||
|
|
"fmt"
|
||
|
|
"github.com/google/uuid"
|
||
|
|
"io"
|
||
|
|
)
|
||
|
|
|
||
|
|
func NewServer() *Server {
|
||
|
|
s := &Server{
|
||
|
|
}
|
||
|
|
s.Id = uuid.New().String()
|
||
|
|
return s
|
||
|
|
}
|
||
|
|
|
||
|
|
type Server struct {
|
||
|
|
SharedOptions
|
||
|
|
OneOff *bool
|
||
|
|
ExitCode *int
|
||
|
|
Running bool
|
||
|
|
outputStream io.ReadCloser
|
||
|
|
errorStream io.ReadCloser
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *Server) Start() (err error) {
|
||
|
|
exit := make(chan int, 0)
|
||
|
|
err = Execute(fmt.Sprintf("%s -s", binaryLocation), s.outputStream, s.errorStream, exit)
|
||
|
|
if err != nil {
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
s.Running = true
|
||
|
|
go func() {
|
||
|
|
ds := DebugScanner{}
|
||
|
|
ds.Scan(s.outputStream)
|
||
|
|
}()
|
||
|
|
go func() {
|
||
|
|
ds := DebugScanner{}
|
||
|
|
ds.Scan(s.errorStream)
|
||
|
|
}()
|
||
|
|
go func() {
|
||
|
|
exitCode := <- exit
|
||
|
|
s.ExitCode = &exitCode
|
||
|
|
s.Running = false
|
||
|
|
}()
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *Server) Stop() {
|
||
|
|
|
||
|
|
}
|