Grab the metadata after lock (#39)

msales · Jan 15, 2019 · 1432497 · 1432497
1 parent 1cc1c48
commit 1432497
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/metastore.go b/metastore.go
@@ -94,8 +94,6 @@ func (s *metastore) Mark(p Processor, src Source, meta Metadata) error {
 		return nil
 	}
 
-	procMeta := s.metadata.Load().(*map[Processor]Metaitems)
-
 	if meta != nil {
 		o := ProcessorOrigin
 		if _, ok := p.(Committer); ok {
@@ -104,8 +102,11 @@ func (s *metastore) Mark(p Processor, src Source, meta Metadata) error {
 
 		meta.WithOrigin(o)
 	}
-
+	
 	s.procMu.Lock()
+
+	procMeta := s.metadata.Load().(*map[Processor]Metaitems)
+
 	items, ok := (*procMeta)[p]
 	if !ok {
 		(*procMeta)[p] = Metaitems{{Source: src, Metadata: meta}}