defer func() {
log.Println("Got entry", keys, "(error", err, ")")
}()
- flock := lockFile(cachePath(keys...))
- flock.Lock()
- defer flock.Unlock()
+ if flock := lockFile(cachePath(keys...)); flock != nil {
+ flock.Lock()
+ defer flock.Unlock()
+ }
fh, err := c.Open(keys...)
if err != nil {
}
// We have good data, time to actually put it in the cache
- flock := lockFile(cachePath(keys...))
- flock.Lock()
- defer flock.Unlock()
+ if flock := lockFile(cachePath(keys...)); flock != nil {
+ flock.Lock()
+ defer flock.Unlock()
+ }
fh, err := c.Create(keys...)
if err != nil {
// Loads the database from anime-titles.dat.gz in the cache dir.
func RefreshTitles() error {
- flock := lockFile(cachePath("anime-titles.dat.gz"))
- flock.Lock()
- defer flock.Unlock()
+ if flock := lockFile(cachePath("anime-titles.dat.gz")); flock != nil {
+ flock.Lock()
+ defer flock.Unlock()
+ }
fh, err := cache.Open("anime-titles.dat.gz")
if err != nil {
return nil
}
- flock := lockFile(cachePath("anime-titles.dat.gz"))
- flock.Lock()
- defer flock.Unlock()
+ if flock := lockFile(cachePath("anime-titles.dat.gz")); flock != nil {
+ flock.Lock()
+ defer flock.Unlock()
+ }
c := &http.Client{Transport: &http.Transport{DisableCompression: true}}