From 1838734b4d95d6f8042c9466bf34d917d03bcbbd Mon Sep 17 00:00:00 2001
From: Blake Rouse <blake.rouse@elastic.co>
Date: Mon, 27 Jan 2020 14:00:13 -0500
Subject: [PATCH] Fix issue where default go logger is not discarded when
 either * or stdout is selected. (#15708)

* Disable default logger when stdlog or the default all selector is not enabled.

* Fix issue where default go logger is not discarded when either * or stdout is selected. Fix #10251.

* Change logic to always discard unless in debug and when all or stdlog is selected. Add more tests.

* Fix comments.

* Add changelog entry.
---
 CHANGELOG.next.asciidoc   |  2 ++
 libbeat/logp/core.go      | 17 ++++++++++++-----
 libbeat/logp/core_test.go | 30 ++++++++++++++++++++++++++++++
 3 files changed, 44 insertions(+), 5 deletions(-)

diff --git a/CHANGELOG.next.asciidoc b/CHANGELOG.next.asciidoc
index fd1d3f08c43..70c10476eb4 100644
--- a/CHANGELOG.next.asciidoc
+++ b/CHANGELOG.next.asciidoc
@@ -46,6 +46,8 @@ https://github.com/elastic/beats/compare/v7.0.0-alpha2...master[Check the HEAD d
 - Do not load dashboards where not available. {pull}15802[15802]
 - Fix issue where TLS settings would be ignored when a forward proxy was in use. {pull}15516{15516}
 - Update replicaset group to apps/v1 {pull}15854[15802]
+- Fix issue where default go logger is not discarded when either * or stdout is selected. {issue}10251[10251] {pull}15708[15708]
+
 
 *Auditbeat*
 
diff --git a/libbeat/logp/core.go b/libbeat/logp/core.go
index 8e5fa6e7c8b..5dd990714f4 100644
--- a/libbeat/logp/core.go
+++ b/libbeat/logp/core.go
@@ -37,7 +37,8 @@ import (
 )
 
 var (
-	_log unsafe.Pointer // Pointer to a coreLogger. Access via atomic.LoadPointer.
+	_log          unsafe.Pointer // Pointer to a coreLogger. Access via atomic.LoadPointer.
+	_defaultGoLog = golog.Writer()
 )
 
 func init() {
@@ -86,6 +87,10 @@ func Configure(cfg Config) error {
 		return errors.Wrap(err, "failed to build log output")
 	}
 
+	// Default logger is always discard, debug level below will
+	// possibly re-enable it.
+	golog.SetOutput(ioutil.Discard)
+
 	// Enabled selectors when debug is enabled.
 	selectors := make(map[string]struct{}, len(cfg.Selectors))
 	if cfg.Level.Enabled(DebugLevel) && len(cfg.Selectors) > 0 {
@@ -98,10 +103,12 @@ func Configure(cfg Config) error {
 			selectors["*"] = struct{}{}
 		}
 
-		if _, enabled := selectors["stdlog"]; !enabled {
-			// Disable standard logging by default (this is sometimes used by
-			// libraries and we don't want their spam).
-			golog.SetOutput(ioutil.Discard)
+		// Re-enable the default go logger output when either stdlog
+		// or all selector is enabled.
+		_, stdlogEnabled := selectors["stdlog"]
+		_, allEnabled := selectors["*"]
+		if stdlogEnabled || allEnabled {
+			golog.SetOutput(_defaultGoLog)
 		}
 
 		sink = selectiveWrapper(sink, selectors)
diff --git a/libbeat/logp/core_test.go b/libbeat/logp/core_test.go
index 236a4e49b13..9ebe0bb38de 100644
--- a/libbeat/logp/core_test.go
+++ b/libbeat/logp/core_test.go
@@ -18,6 +18,8 @@
 package logp
 
 import (
+	"io/ioutil"
+	golog "log"
 	"testing"
 
 	"github.com/stretchr/testify/assert"
@@ -116,3 +118,31 @@ func TestL(t *testing.T) {
 		assert.Equal(t, "warning 1", log.Message)
 	}
 }
+
+func TestDebugAllStdoutEnablesDefaultGoLogger(t *testing.T) {
+	DevelopmentSetup(WithSelectors("*"))
+	assert.Equal(t, _defaultGoLog, golog.Writer())
+
+	DevelopmentSetup(WithSelectors("stdlog"))
+	assert.Equal(t, _defaultGoLog, golog.Writer())
+
+	DevelopmentSetup(WithSelectors("*", "stdlog"))
+	assert.Equal(t, _defaultGoLog, golog.Writer())
+
+	DevelopmentSetup(WithSelectors("other"))
+	assert.Equal(t, ioutil.Discard, golog.Writer())
+}
+
+func TestNotDebugAllStdoutDisablesDefaultGoLogger(t *testing.T) {
+	DevelopmentSetup(WithSelectors("*"), WithLevel(InfoLevel))
+	assert.Equal(t, ioutil.Discard, golog.Writer())
+
+	DevelopmentSetup(WithSelectors("stdlog"), WithLevel(InfoLevel))
+	assert.Equal(t, ioutil.Discard, golog.Writer())
+
+	DevelopmentSetup(WithSelectors("*", "stdlog"), WithLevel(InfoLevel))
+	assert.Equal(t, ioutil.Discard, golog.Writer())
+
+	DevelopmentSetup(WithSelectors("other"), WithLevel(InfoLevel))
+	assert.Equal(t, ioutil.Discard, golog.Writer())
+}