diff options
Diffstat (limited to 'worker_test.go')
| -rwxr-xr-x | worker_test.go | 226 |
1 files changed, 113 insertions, 113 deletions
diff --git a/worker_test.go b/worker_test.go index 78738064..43bb8b65 100755 --- a/worker_test.go +++ b/worker_test.go @@ -65,116 +65,116 @@ func Test_OnStarted(t *testing.T) { assert.Equal(t, "can't attach to running process", err.Error()) } -func TestErrBuffer_Write_Len(t *testing.T) { - buf := newErrBuffer(nil) - defer func() { - buf.Close() - }() - - _, err := buf.Write([]byte("hello")) - if err != nil { - t.Errorf("fail to write: error %v", err) - } - assert.Equal(t, 5, buf.Len()) - assert.Equal(t, "hello", buf.String()) -} - -func TestErrBuffer_Write_Event(t *testing.T) { - buf := newErrBuffer(nil) - defer func() { - buf.Close() - }() - - wg := &sync.WaitGroup{} - wg.Add(1) - buf.logCallback = func(log []byte) { - assert.Equal(t, []byte("hello\n"), log) - wg.Done() - } - buf.enable = true - - _, err := buf.Write([]byte("hello\n")) - if err != nil { - t.Errorf("fail to write: error %v", err) - } - - wg.Wait() - - // messages are read - assert.Equal(t, 0, buf.Len()) -} - -func TestErrBuffer_Write_Event_Separated(t *testing.T) { - buf := newErrBuffer(nil) - defer func() { - buf.Close() - }() - - wg := &sync.WaitGroup{} - wg.Add(1) - - buf.logCallback = func(log []byte) { - assert.Equal(t, []byte("hello\nending"), log) - wg.Done() - } - buf.enable = true - - _, err := buf.Write([]byte("hel")) - if err != nil { - t.Errorf("fail to write: error %v", err) - } - - _, err = buf.Write([]byte("lo\n")) - if err != nil { - t.Errorf("fail to write: error %v", err) - } - - _, err = buf.Write([]byte("ending")) - if err != nil { - t.Errorf("fail to write: error %v", err) - } - - wg.Wait() - assert.Equal(t, 0, buf.Len()) - assert.Equal(t, "", buf.String()) -} - -func TestErrBuffer_Write_Event_Separated_NoListener(t *testing.T) { - buf := newErrBuffer(nil) - defer func() { - buf.Close() - }() - - _, err := buf.Write([]byte("hel")) - if err != nil { - t.Errorf("fail to write: error %v", err) - } - - _, err = buf.Write([]byte("lo\n")) - if err != nil { - t.Errorf("fail to write: error %v", err) - } - - _, err = buf.Write([]byte("ending")) - if err != nil { - t.Errorf("fail to write: error %v", err) - } - - assert.Equal(t, 12, buf.Len()) - assert.Equal(t, "hello\nending", buf.String()) -} - -func TestErrBuffer_Write_Remaining(t *testing.T) { - buf := newErrBuffer(nil) - defer func() { - buf.Close() - }() - - _, err := buf.Write([]byte("hel")) - if err != nil { - t.Errorf("fail to write: error %v", err) - } - - assert.Equal(t, 3, buf.Len()) - assert.Equal(t, "hel", buf.String()) -} +//func TestErrBuffer_Write_Len(t *testing.T) { +// buf := newErrBuffer(nil) +// defer func() { +// buf.Close() +// }() +// +// _, err := buf.Write([]byte("hello")) +// if err != nil { +// t.Errorf("fail to write: error %v", err) +// } +// assert.Equal(t, 5, buf.Len()) +// assert.Equal(t, "hello", buf.String()) +//} +// +//func TestErrBuffer_Write_Event(t *testing.T) { +// buf := newErrBuffer(nil) +// defer func() { +// buf.Close() +// }() +// +// wg := &sync.WaitGroup{} +// wg.Add(1) +// buf.logCallback = func(log []byte) { +// assert.Equal(t, []byte("hello\n"), log) +// wg.Done() +// } +// buf.enable = true +// +// _, err := buf.Write([]byte("hello\n")) +// if err != nil { +// t.Errorf("fail to write: error %v", err) +// } +// +// wg.Wait() +// +// // messages are read +// assert.Equal(t, 0, buf.Len()) +//} +// +//func TestErrBuffer_Write_Event_Separated(t *testing.T) { +// buf := newErrBuffer(nil) +// defer func() { +// buf.Close() +// }() +// +// wg := &sync.WaitGroup{} +// wg.Add(1) +// +// buf.logCallback = func(log []byte) { +// assert.Equal(t, []byte("hello\nending"), log) +// wg.Done() +// } +// buf.enable = true +// +// _, err := buf.Write([]byte("hel")) +// if err != nil { +// t.Errorf("fail to write: error %v", err) +// } +// +// _, err = buf.Write([]byte("lo\n")) +// if err != nil { +// t.Errorf("fail to write: error %v", err) +// } +// +// _, err = buf.Write([]byte("ending")) +// if err != nil { +// t.Errorf("fail to write: error %v", err) +// } +// +// wg.Wait() +// assert.Equal(t, 0, buf.Len()) +// assert.Equal(t, "", buf.String()) +//} +// +//func TestErrBuffer_Write_Event_Separated_NoListener(t *testing.T) { +// buf := newErrBuffer(nil) +// defer func() { +// buf.Close() +// }() +// +// _, err := buf.Write([]byte("hel")) +// if err != nil { +// t.Errorf("fail to write: error %v", err) +// } +// +// _, err = buf.Write([]byte("lo\n")) +// if err != nil { +// t.Errorf("fail to write: error %v", err) +// } +// +// _, err = buf.Write([]byte("ending")) +// if err != nil { +// t.Errorf("fail to write: error %v", err) +// } +// +// assert.Equal(t, 12, buf.Len()) +// assert.Equal(t, "hello\nending", buf.String()) +//} +// +//func TestErrBuffer_Write_Remaining(t *testing.T) { +// buf := newErrBuffer(nil) +// defer func() { +// buf.Close() +// }() +// +// _, err := buf.Write([]byte("hel")) +// if err != nil { +// t.Errorf("fail to write: error %v", err) +// } +// +// assert.Equal(t, 3, buf.Len()) +// assert.Equal(t, "hel", buf.String()) +//} |