fix deadlock

iobeam · Mar 23, 2016 · dfcc855 · dfcc855
1 parent 830794d
commit dfcc855
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/schema_registry.go b/schema_registry.go
@@ -127,12 +127,14 @@ func (this *CachedSchemaRegistryClient) Register(subject string, schema avro.Sch
 
 	this.lock.RLock()
 	if schemaIdMap, exists = this.schemaCache[subject]; exists {
+		this.lock.RUnlock()
 		var id int32
 		if id, exists = schemaIdMap[schema]; exists {
 			return id, nil
 		}
+	} else {
+		this.lock.RUnlock()
 	}
-	this.lock.RUnlock()
 
 	this.lock.Lock()
 	defer this.lock.Unlock()