X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/2bef371e8429430942193fff02599ec51c081e70..0e2a467a923bd490f3e1dc4d8c00a9e2f29e59d4:/services/ws/event_source.go diff --git a/services/ws/event_source.go b/services/ws/event_source.go index cfb828b2a5..309dab7a40 100644 --- a/services/ws/event_source.go +++ b/services/ws/event_source.go @@ -8,7 +8,6 @@ import ( "context" "database/sql" "strconv" - "strings" "sync" "sync/atomic" "time" @@ -17,21 +16,6 @@ import ( "github.com/lib/pq" ) -type pgConfig map[string]string - -func (c pgConfig) ConnectionString() string { - s := "" - for k, v := range c { - s += k - s += "='" - s += strings.Replace( - strings.Replace(v, `\`, `\\`, -1), - `'`, `\'`, -1) - s += "' " - } - return s -} - type pgEventSource struct { DataSource string MaxOpenConns int @@ -288,7 +272,7 @@ func (sink *pgEventSink) Stop() { // Ensure this sink cannot fill up and block the // server-side queue (which otherwise could in turn // block our mtx.Lock() here) - for _ = range sink.channel { + for range sink.channel { } }() sink.source.mtx.Lock()