logos-messaging/logos-messaging-go-bindings
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-go-bindings.git synced 2026-01-07 16:33:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

remove log file to solve CI issue

Browse Source
This commit is contained in:
aya 2025-03-24 16:32:08 +02:00
parent d537fbf3d6
commit 8621e63beb
1 changed files with 3 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
waku/stress_test.go
View File

@ -5,7 +5,6 @@ package waku
import ( import (
"fmt" "fmt"
"io"
"os" "os"
"runtime" "runtime"
"testing" "testing"
@ -16,34 +15,17 @@ import (
"github.com/waku-org/waku-go-bindings/waku/common" "github.com/waku-org/waku-go-bindings/waku/common"
"go.uber.org/zap" "go.uber.org/zap"
"go.uber.org/zap/zapcore" "go.uber.org/zap/zapcore"
// "go.uber.org/zap/zapcore"
"google.golang.org/protobuf/proto" "google.golang.org/protobuf/proto"
) )
func TestStressMemoryUsageForThreeNodes(t *testing.T) { func TestStressMemoryUsageForThreeNodes(t *testing.T) {
logFile, err := os.OpenFile("test_logs.log", os.O_CREATE|os.O_WRONLY|os.O_TRUNC, 0666)
require.NoError(t, err)
defer logFile.Close()
multiWriter := io.MultiWriter(os.Stdout, logFile)
encoderCfg := zap.NewProductionEncoderConfig()
encoderCfg.TimeKey = "ts"
encoderCfg.EncodeTime = zapcore.ISO8601TimeEncoder
core := zapcore.NewCore(
zapcore.NewConsoleEncoder(encoderCfg),
zapcore.AddSync(multiWriter),
zap.DebugLevel,
)
customLogger := zap.New(core)
SetLogger(customLogger)
testName := t.Name() testName := t.Name()
var err error
var memStats runtime.MemStats var memStats runtime.MemStats
runtime.ReadMemStats(&memStats) runtime.ReadMemStats(&memStats)
Debug("[%s] Memory usage BEFORE creating nodes: %d KB", testName, memStats.HeapAlloc/1024) Debug("[%s] Memory usage BEFORE creating nodes: %d KB", testName, memStats.HeapAlloc/1024)
node1Cfg := DefaultWakuConfig node1Cfg := DefaultWakuConfig
node1Cfg.TcpPort, node1Cfg.Discv5UdpPort, err = GetFreePortIfNeeded(0, 0) node1Cfg.TcpPort, node1Cfg.Discv5UdpPort, err = GetFreePortIfNeeded(0, 0)
require.NoError(t, err) require.NoError(t, err)
@ -91,21 +73,6 @@ func TestStressMemoryUsageForThreeNodes(t *testing.T) {
} }
func TestStress2Nodes500IterationTearDown(t *testing.T) { func TestStress2Nodes500IterationTearDown(t *testing.T) {
logFile, err := os.OpenFile("test_repeated_start_stop.log", os.O_CREATE|os.O_WRONLY|os.O_TRUNC, 0666)
require.NoError(t, err)
//defer logFile.Close()
multiWriter := io.MultiWriter(os.Stdout, logFile)
encoderCfg := zap.NewProductionEncoderConfig()
encoderCfg.TimeKey = "ts"
encoderCfg.EncodeTime = zapcore.ISO8601TimeEncoder
core := zapcore.NewCore(
zapcore.NewConsoleEncoder(encoderCfg),
zapcore.AddSync(multiWriter),
zap.DebugLevel,
)
customLogger := zap.New(core)
SetLogger(customLogger)
var memStats runtime.MemStats var memStats runtime.MemStats
runtime.ReadMemStats(&memStats) runtime.ReadMemStats(&memStats)