From e86c82c68d95c23bf6f4aba3d48e9182ee1328df Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Michael=20Mur=C3=A9?= Date: Fri, 23 Oct 2015 21:57:29 +0200 Subject: [PATCH] Add log events when blocks are added/removed from the blockstore MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit License: MIT Signed-off-by: Michael Muré --- blocks/blockstore/write_cache.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/blocks/blockstore/write_cache.go b/blocks/blockstore/write_cache.go index 73a7813f5..ecb8933bc 100644 --- a/blocks/blockstore/write_cache.go +++ b/blocks/blockstore/write_cache.go @@ -22,6 +22,7 @@ type writecache struct { } func (w *writecache) DeleteBlock(k key.Key) error { + defer log.EventBegin(context.TODO(), "writecache.BlockRemoved", &k).Done() w.cache.Remove(k) return w.blockstore.DeleteBlock(k) } @@ -38,9 +39,12 @@ func (w *writecache) Get(k key.Key) (*blocks.Block, error) { } func (w *writecache) Put(b *blocks.Block) error { - if _, ok := w.cache.Get(b.Key()); ok { + k := b.Key() + if _, ok := w.cache.Get(k); ok { return nil } + defer log.EventBegin(context.TODO(), "writecache.BlockAdded", &k).Done() + w.cache.Add(b.Key(), struct{}{}) return w.blockstore.Put(b) } @@ -50,6 +54,8 @@ func (w *writecache) PutMany(bs []*blocks.Block) error { for _, b := range bs { if _, ok := w.cache.Get(b.Key()); !ok { good = append(good, b) + k := b.Key() + defer log.EventBegin(context.TODO(), "writecache.BlockAdded", &k).Done() } } return w.blockstore.PutMany(good)