dom
/
telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fix graylog test race

This commit is contained in:
Cameron Sparr 2016-06-01 16:00:55 +01:00
parent fb5f40319e
commit c842724b61
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
plugins/outputs/graylog/graylog_test.go
View File

@ -15,8 +15,11 @@ import (
func TestWrite(t *testing.T) { func TestWrite(t *testing.T) {
var wg sync.WaitGroup var wg sync.WaitGroup
var wg2 sync.WaitGroup
wg.Add(1) wg.Add(1)
go UDPServer(t, &wg) wg2.Add(1)
go UDPServer(t, &wg, &wg2)
wg2.Wait()
i := Graylog{ i := Graylog{
Servers: []string{"127.0.0.1:12201"}, Servers: []string{"127.0.0.1:12201"},
@ -33,12 +36,13 @@ func TestWrite(t *testing.T) {
type GelfObject map[string]interface{} type GelfObject map[string]interface{}
func UDPServer(t *testing.T, wg *sync.WaitGroup) { func UDPServer(t *testing.T, wg *sync.WaitGroup, wg2 *sync.WaitGroup) {
serverAddr, _ := net.ResolveUDPAddr("udp", "127.0.0.1:12201") serverAddr, _ := net.ResolveUDPAddr("udp", "127.0.0.1:12201")
udpServer, _ := net.ListenUDP("udp", serverAddr) udpServer, _ := net.ListenUDP("udp", serverAddr)
defer wg.Done() defer wg.Done()
bufR := make([]byte, 1024) bufR := make([]byte, 1024)
wg2.Done()
n, _, _ := udpServer.ReadFromUDP(bufR) n, _, _ := udpServer.ReadFromUDP(bufR)
b := bytes.NewReader(bufR[0:n]) b := bytes.NewReader(bufR[0:n])