Function TestInMemoryAuditLog_ConcurrentWrites

pkg/security/audit_test.go:296–324

(t *testing.T)

}

func TestInMemoryAuditLog_ConcurrentWrites(t *testing.T) {
	auditLog := NewInMemoryAuditLog(nil)
	defer func() { _ = auditLog.Close() }()

	// 并发写入事件
	done := make(chan bool)
	for i := range 10 {
		go func(id int) {
			event := AuditEvent{
				Type:    AuditTypeUserLogin,
				UserID:  "user" + string(rune('0'+id)),
				Message: "Concurrent login",
			}
			_ = auditLog.LogEvent(event)
			done <- true
		}(i)
	}

	// 等待所有操作完成
	for range 10 {
		<-done
	}

	// 使用GetStatus而不是直接访问events字段
	status := auditLog.GetStatus()
	if status.TotalEvents != 10 {
		t.Errorf("expected 10 events, got %d", status.TotalEvents)
	}
}