(t *testing.T)
| 150 | } |
| 151 | |
| 152 | func TestHandleLogUpdatePartialLine(t *testing.T) { |
| 153 | ta := makeTestTail(t) |
| 154 | |
| 155 | logfile := filepath.Join(ta.tmpDir, "log") |
| 156 | f := testutil.TestOpenFile(t, logfile) |
| 157 | defer f.Close() |
| 158 | |
| 159 | testutil.FatalIfErr(t, ta.TailPath(logfile)) |
| 160 | ta.awakenStreams(1, 1) // ensure we've hit an EOF before writing starts |
| 161 | |
| 162 | testutil.WriteString(t, f, "a") |
| 163 | ta.awakenStreams(1, 1) |
| 164 | |
| 165 | testutil.WriteString(t, f, "b") |
| 166 | ta.awakenStreams(1, 1) |
| 167 | |
| 168 | testutil.WriteString(t, f, "\n") |
| 169 | ta.awakenStreams(1, 1) |
| 170 | |
| 171 | ta.stop() |
| 172 | |
| 173 | received := testutil.LinesReceived(ta.lines) |
| 174 | expected := []*logline.LogLine{ |
| 175 | {Context: context.Background(), Filename: logfile, Line: "ab"}, |
| 176 | } |
| 177 | testutil.ExpectNoDiff(t, expected, received, testutil.IgnoreFields(logline.LogLine{}, "Context")) |
| 178 | } |
| 179 | |
| 180 | // Test that broken files are skipped. |
| 181 | func TestTailerUnreadableFile(t *testing.T) { |
nothing calls this directly
no test coverage detected