[Ingest Manager] Use local temp instead of system one (#21883) (#21905)

[Ingest Manager] Use local temp instead of system one (#21883)
elastic · Oct 21, 2020 · 2869ca6 · 2869ca6
1 parent 7117015
commit 2869ca6
Show file tree

Hide file tree

Showing 4 changed files with 24 additions and 3 deletions.
diff --git a/x-pack/elastic-agent/CHANGELOG.next.asciidoc b/x-pack/elastic-agent/CHANGELOG.next.asciidoc
@@ -16,6 +16,7 @@
 - Include inputs in action store actions {pull}21298[21298]
 - Fix issue where inputs without processors defined would panic {pull}21628[21628]
 - Partial extracted beat result in failure to spawn beat {issue}21718[21718]
+- Use local temp instead of system one {pull}21883[21883]
 - Fix issue with named pipes on Windows 7 {pull}21931[21931]
 - Rename monitoring index from `elastic.agent` to `elastic_agent` {pull}21932[21932]
 - Fix missing elastic_agent event data {pull}21994[21994]

diff --git a/x-pack/elastic-agent/pkg/agent/application/paths/paths.go b/x-pack/elastic-agent/pkg/agent/application/paths/paths.go
@@ -10,14 +10,20 @@ import (
 	"os"
 	"path/filepath"
 	"strings"
+	"sync"
 
 	"github.com/elastic/beats/v7/x-pack/elastic-agent/pkg/release"
 )
 
+const (
+	tempSubdir = "tmp"
+)
+
 var (
 	topPath    string
 	configPath string
 	logsPath   string
+	tmpCreator sync.Once
 )
 
 func init() {
@@ -37,6 +43,16 @@ func Top() string {
 	return topPath
 }
 
+// TempDir returns agent temp dir located within data dir.
+func TempDir() string {
+	tmpDir := filepath.Join(Data(), tempSubdir)
+	tmpCreator.Do(func() {
+		// create tempdir as it probably don't exists
+		os.MkdirAll(tmpDir, 0750)
+	})
+	return tmpDir
+}
+
 // Home returns a directory where binary lives
 func Home() string {
 	return versionedHome(topPath)

diff --git a/x-pack/elastic-agent/pkg/artifact/install/atomic/atomic_installer.go b/x-pack/elastic-agent/pkg/artifact/install/atomic/atomic_installer.go
@@ -9,6 +9,8 @@ import (
 	"io/ioutil"
 	"os"
 	"path/filepath"
+
+	"github.com/elastic/beats/v7/x-pack/elastic-agent/pkg/agent/application/paths"
 )
 
 type embeddedInstaller interface {
@@ -31,7 +33,7 @@ func NewInstaller(i embeddedInstaller) (*Installer, error) {
 // Install performs installation of program in a specific version.
 func (i *Installer) Install(ctx context.Context, programName, version, installDir string) error {
 	// tar installer uses Dir of installDir to determine location of unpack
-	tempDir, err := ioutil.TempDir(os.TempDir(), "elastic-agent-install")
+	tempDir, err := ioutil.TempDir(paths.TempDir(), "elastic-agent-install")
 	if err != nil {
 		return err
 	}

diff --git a/x-pack/elastic-agent/pkg/artifact/install/atomic/atomic_installer_test.go b/x-pack/elastic-agent/pkg/artifact/install/atomic/atomic_installer_test.go
@@ -14,6 +14,8 @@ import (
 	"testing"
 
 	"github.com/stretchr/testify/assert"
+
+	"github.com/elastic/beats/v7/x-pack/elastic-agent/pkg/agent/application/paths"
 )
 
 func TestOKInstall(t *testing.T) {
@@ -25,7 +27,7 @@ func TestOKInstall(t *testing.T) {
 	assert.NoError(t, err)
 
 	ctx := context.Background()
-	installDir := filepath.Join(os.TempDir(), "install_dir")
+	installDir := filepath.Join(paths.TempDir(), "install_dir")
 
 	wg.Add(1)
 	go func() {
@@ -59,7 +61,7 @@ func TestContextCancelledInstall(t *testing.T) {
 	assert.NoError(t, err)
 
 	ctx, cancel := context.WithCancel(context.Background())
-	installDir := filepath.Join(os.TempDir(), "install_dir")
+	installDir := filepath.Join(paths.TempDir(), "install_dir")
 
 	wg.Add(1)
 	go func() {