From 8c4f369e50cd56cfcb3d2a09da640309f1fe8a44 Mon Sep 17 00:00:00 2001 From: Jeff Mitchell Date: Tue, 19 Dec 2017 12:53:21 -0500 Subject: [PATCH] Revert grabbing lock in database Connection funcs --- plugins/database/cassandra/connection_producer.go | 3 --- plugins/database/mongodb/connection_producer.go | 3 --- plugins/helper/database/connutil/sql.go | 3 --- 3 files changed, 9 deletions(-) diff --git a/plugins/database/cassandra/connection_producer.go b/plugins/database/cassandra/connection_producer.go index c8aae59613..ff4cae79f0 100644 --- a/plugins/database/cassandra/connection_producer.go +++ b/plugins/database/cassandra/connection_producer.go @@ -116,9 +116,6 @@ func (c *cassandraConnectionProducer) Initialize(ctx context.Context, conf map[s } func (c *cassandraConnectionProducer) Connection(_ context.Context) (interface{}, error) { - c.Lock() - defer c.Unlock() - if !c.Initialized { return nil, connutil.ErrNotInitialized } diff --git a/plugins/database/mongodb/connection_producer.go b/plugins/database/mongodb/connection_producer.go index aa674aafe3..9182e5af91 100644 --- a/plugins/database/mongodb/connection_producer.go +++ b/plugins/database/mongodb/connection_producer.go @@ -90,9 +90,6 @@ func (c *mongoDBConnectionProducer) Initialize(ctx context.Context, conf map[str // Connection creates a database connection. func (c *mongoDBConnectionProducer) Connection(_ context.Context) (interface{}, error) { - c.Lock() - defer c.Unlock() - if !c.Initialized { return nil, connutil.ErrNotInitialized } diff --git a/plugins/helper/database/connutil/sql.go b/plugins/helper/database/connutil/sql.go index 8a7f57e077..2e34065d03 100644 --- a/plugins/helper/database/connutil/sql.go +++ b/plugins/helper/database/connutil/sql.go @@ -76,9 +76,6 @@ func (c *SQLConnectionProducer) Initialize(ctx context.Context, conf map[string] } func (c *SQLConnectionProducer) Connection(ctx context.Context) (interface{}, error) { - c.Lock() - defer c.Unlock() - if !c.Initialized { return nil, ErrNotInitialized }