tests: Fixes integration_runner to not load opcache if already

Author: mfulb

daemon/cmd/integration_runner/main.go

@@ -362,15 +362,8 @@ func main() {
 		ctx.Settings["newrelic.loglevel"] = *flagLoglevel
 	}
 
-	if false == *flagOpcacheOff {
-		// PHP Modules common to all tests
-		ctx.Settings["zend_extension"] = "opcache.so"
-
-		// PHP INI values common to all tests
-		// These settings can be overwritten by adding new values to the INI block
-		ctx.Settings["opcache.enable"] = "1"
-		ctx.Settings["opcache.enable_cli"] = "1"
-	}
+	ctx.OPCacheModuleLoaded = integration.GetOPCacheModuleLoaded(*flagPHP, *flagCGI)
+	ctx.UseOPCache = !*flagOpcacheOff
 
 	// If the user provided a custom agent extension, use it.
 	if len(*flagAgent) > 0 {

daemon/internal/newrelic/integration/context.go

@@ -18,6 +18,8 @@ type Context struct {
 	Env      map[string]string // environment variables to pass to each test
 	Settings map[string]string // settings to pass to each test
 	Timeout  time.Duration     // maximum test duration
+	OPCacheModuleLoaded map[string]bool // map of PHP and CGI to OPcache default loaded status
+	UseOPCache bool // whether to use OPcache in tests
 }
 
 func NewContext(php, cgi string) *Context {

daemon/internal/newrelic/integration/transaction.go

@@ -46,9 +46,22 @@ func PhpTx(src Script, env, settings map[string]string, ctx *Context) (Tx, error
 	// Note: file path must be relative to the working directory.
 	var txn Tx
 
-	args := phpArgs(nil, filepath.Base(src.Name()), false, settings)
+	// Make a copy of settings to avoid mutating the original map
+	phpSettings := make(map[string]string, len(settings))
+	for k, v := range settings {
+		phpSettings[k] = v
+	}
+	if ctx.UseOPCache {
+		if !ctx.OPCacheModuleLoaded[ctx.PHP] {
+			phpSettings["zend_extension"] = "opcache.so"
+		}
+		phpSettings["opcache.enable"] = "1"
+		phpSettings["opcache.enable_cli"] = "1"
+	}
+
+	args := phpArgs(nil, filepath.Base(src.Name()), false, phpSettings)
 
-	if ctx.Valgrind != "" && settings["newrelic.appname"] != "skipif" {
+	if ctx.Valgrind != "" && phpSettings["newrelic.appname"] != "skipif" {
 		txn = &ValgrindCLI{
 			CLI: CLI{
 				Path: ctx.PHP,
@@ -106,14 +119,27 @@ func CgiTx(src Script, env, settings map[string]string, headers http.Header, ctx
 		return nil, fmt.Errorf("unable to create cgi request: %v", err)
 	}
 
+	// Make a copy of settings to avoid mutating the original map
+	cgiSettings := make(map[string]string, len(settings))
+	for k, v := range settings {
+		cgiSettings[k] = v
+	}
+	if ctx.UseOPCache {
+		if !ctx.OPCacheModuleLoaded[ctx.CGI] {
+			cgiSettings["zend_extension"] = "opcache.so"
+		}
+		cgiSettings["opcache.enable"] = "1"
+		cgiSettings["opcache.enable_cli"] = "1"
+	}
+
 	if ctx.Valgrind != "" {
 		tx := &ValgrindCGI{
 			CGI: CGI{
 				request: req,
 				handler: &cgi.Handler{
 					Path: ctx.CGI,
 					Dir:  src.Dir(),
-					Args: phpArgs(nil, "", false, settings),
+					Args: phpArgs(nil, "", false, cgiSettings),
 				},
 			},
 			Valgrind: ctx.Valgrind,
@@ -144,7 +170,7 @@ func CgiTx(src Script, env, settings map[string]string, headers http.Header, ctx
 			handler: &cgi.Handler{
 				Path: ctx.CGI,
 				Dir:  src.Dir(),
-				Args: phpArgs(nil, "", false, settings),
+				Args: phpArgs(nil, "", false, cgiSettings),
 			},
 		}
 		tx.handler.Env = append(tx.handler.Env,

daemon/internal/newrelic/integration/util.go

@@ -6,7 +6,9 @@
 package integration
 
 import (
+	"bytes"
 	"fmt"
+	"os"
 	"os/exec"
 )
 
@@ -31,3 +33,29 @@ func GetAgentVersion(agent_extension string) string {
 	}
 	return string(output)
 }
+
+func IsOPcacheLoaded(php_executable string) bool {
+	fmt.Printf("Checking if OPcache is loaded using %s\n", php_executable)
+	cmd := exec.Command(php_executable, "-m")
+
+	output, err := cmd.Output()
+
+	if err != nil {
+		fmt.Printf("Failed to check if OPcache is loaded: %v\n", err)
+		os.Exit(1)
+	}
+
+	// Check if "Zend OPcache" is in the output
+	return bytes.Contains(output, []byte("Zend OPcache"))
+}
+
+func GetOPCacheModuleLoaded(php, cgi string) map[string]bool {
+	result := make(map[string]bool)
+
+	result[php] = IsOPcacheLoaded(php)
+	result[cgi] = IsOPcacheLoaded(cgi)	
+
+	fmt.Printf("OPcache loaded status: %+v\n", result)
+
+	return result
+}