storm/skald
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Write out disk writer packets unconditionally.

Browse Source 
If the stream was very short, we may not have created
a writer yet.  Write out packets even in that case.
This commit is contained in:
Juliusz Chroboczek
2022-01-25 22:04:57 +01:00
parent e8fbfcb9ba
commit 0cbfa7b0ca
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
diskwriter/diskwriter.go
+2 -2
View File
@@ -184,8 +184,8 @@ func (conn *diskConn) warn(message string) {
// called locked // called locked
func (conn *diskConn) reopen(extension string) error { func (conn *diskConn) reopen(extension string) error {
for _, t := range conn.tracks { for _, t := range conn.tracks {
t.writeBuffered(true)
if t.writer != nil { if t.writer != nil {
t.writeBuffered(true)
t.writer.Close() t.writer.Close()
t.writer = nil t.writer = nil
} }
@@ -207,8 +207,8 @@ func (conn *diskConn) Close() error {
conn.mu.Lock() conn.mu.Lock()
tracks := make([]*diskTrack, 0, len(conn.tracks)) tracks := make([]*diskTrack, 0, len(conn.tracks))
for _, t := range conn.tracks { for _, t := range conn.tracks {
t.writeBuffered(true)
if t.writer != nil { if t.writer != nil {
t.writeBuffered(true)
t.writer.Close() t.writer.Close()
t.writer = nil t.writer = nil
} }