From 8d81a8b8d9c74efd1d5498a764c9173366da7da4 Mon Sep 17 00:00:00 2001
From: Jeromy <jeromyj@gmail.com>
Date: Tue, 17 Mar 2015 14:51:26 -0700
Subject: [PATCH] fix locking in the pinner

---
 pin/pin.go | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/pin/pin.go b/pin/pin.go
index 7ae36f607..5f726a457 100644
--- a/pin/pin.go
+++ b/pin/pin.go
@@ -200,6 +200,8 @@ func (p *pinner) IsPinned(key util.Key) bool {
 }
 
 func (p *pinner) RemovePinWithMode(key util.Key, mode PinMode) {
+	p.lock.Lock()
+	defer p.lock.Unlock()
 	switch mode {
 	case Direct:
 		p.directPin.RemoveBlock(key)
@@ -265,8 +267,8 @@ func (p *pinner) RecursiveKeys() []util.Key {
 
 // Flush encodes and writes pinner keysets to the datastore
 func (p *pinner) Flush() error {
-	p.lock.RLock()
-	defer p.lock.RUnlock()
+	p.lock.Lock()
+	defer p.lock.Unlock()
 
 	err := storeSet(p.dstore, directPinDatastoreKey, p.directPin.GetKeys())
 	if err != nil {
@@ -311,6 +313,8 @@ func loadSet(d ds.Datastore, k ds.Key, val interface{}) error {
 // PinWithMode is a method on ManualPinners, allowing the user to have fine
 // grained control over pin counts
 func (p *pinner) PinWithMode(k util.Key, mode PinMode) {
+	p.lock.Lock()
+	defer p.lock.Unlock()
 	switch mode {
 	case Recursive:
 		p.recursePin.AddBlock(k)