fluencelabs/tendermint
1
0
Fork 0
mirror of https://github.com/fluencelabs/tendermint synced 2025-06-12 12:51:22 +00:00
Code Issues Projects Releases Wiki Activity

Fix race condition

Browse Source
This commit is contained in:
Jae Kwon
2016-11-21 20:26:47 -08:00
parent 2a306419c8
commit 63186e34b3
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
autofile.go
View File

@ -100,6 +100,9 @@ func (af *AutoFile) Write(b []byte) (n int, err error) {
} }
func (af *AutoFile) Sync() error { func (af *AutoFile) Sync() error {
af.mtx.Lock()
defer af.mtx.Unlock()
return af.file.Sync() return af.file.Sync()
} }
@ -115,6 +118,7 @@ func (af *AutoFile) openFile() error {
func (af *AutoFile) Size() (int64, error) { func (af *AutoFile) Size() (int64, error) {
af.mtx.Lock() af.mtx.Lock()
defer af.mtx.Unlock() defer af.mtx.Unlock()
if af.file == nil { if af.file == nil {
err := af.openFile() err := af.openFile()
if err != nil { if err != nil {