This job view page is being replaced by Spyglass soon. Check out the new job view.
PRwojtek-t: [WIP] Pf remove goroutine
ResultFAILURE
Tests 2 failed / 40 succeeded
Started2021-07-30 10:46
Elapsed49m39s
Revision9efa19b035d59dea4302960fb853310be5d6c86b
Refs 104010

Test Failures


verify gofmt 17s

make verify WHAT=gofmt
diff -u ./staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go.orig ./staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go
--- ./staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go.orig	2021-07-30 11:05:50.426573256 +0000
+++ ./staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go	2021-07-30 11:05:50.426573256 +0000
@@ -291,31 +291,31 @@
 	// of well-counted goroutines. We Are Told that every
 	// request's context's Done channel gets closed by the time
 	// the request is done being processed.
-/*	doneCh := ctx.Done()
+	/*	doneCh := ctx.Done()
 
-	// Retrieve the queueset configuration name while we have the lock
-	// and use it in the goroutine below.
-	configName := qs.qCfg.Name
+		// Retrieve the queueset configuration name while we have the lock
+		// and use it in the goroutine below.
+		configName := qs.qCfg.Name
 
-	if doneCh != nil {
-		klog.Errorf("EEEEEEEEEEEEEE")
-		panic("EEEEEE")
-		qs.preCreateOrUnblockGoroutine()
-		go func() {
-//			defer runtime.HandleCrash()
-			qs.goroutineDoneOrBlocked()
-			_ = <-doneCh
-			// Whatever goroutine unblocked the preceding receive MUST
-			// have already either (a) incremented qs.counter or (b)
-			// known that said counter is not actually counting or (c)
-			// known that the count does not need to be accurate.
-			// BTW, the count only needs to be accurate in a test that
-			// uses FakeEventClock::Run().
-			klog.V(6).Infof("QS(%s): Context of request %q %#+v %#+v is Done", configName, fsName, descr1, descr2)
-			qs.cancelWait(req)
-			qs.goroutineDoneOrBlocked()
-		}()
-	}*/
+		if doneCh != nil {
+			klog.Errorf("EEEEEEEEEEEEEE")
+			panic("EEEEEE")
+			qs.preCreateOrUnblockGoroutine()
+			go func() {
+	//			defer runtime.HandleCrash()
+				qs.goroutineDoneOrBlocked()
+				_ = <-doneCh
+				// Whatever goroutine unblocked the preceding receive MUST
+				// have already either (a) incremented qs.counter or (b)
+				// known that said counter is not actually counting or (c)
+				// known that the count does not need to be accurate.
+				// BTW, the count only needs to be accurate in a test that
+				// uses FakeEventClock::Run().
+				klog.V(6).Infof("QS(%s): Context of request %q %#+v %#+v is Done", configName, fsName, descr1, descr2)
+				qs.cancelWait(req)
+				qs.goroutineDoneOrBlocked()
+			}()
+		}*/
 	return req, false
 }
 
diff -u ./staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/promise/promise.go.orig ./staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/promise/promise.go
--- ./staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/promise/promise.go.orig	2021-07-30 11:05:50.430573397 +0000
+++ ./staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/promise/promise.go	2021-07-30 11:05:50.430573397 +0000
@@ -37,8 +37,8 @@
 	waitingCount  int32                    // number of goroutines idle due to this being unset
 
 	// Should be access via atomic.
-	isSet         int32
-	value         interface{}
+	isSet int32
+	value interface{}
 }
 
 var _ WriteOnce = &promise{}
@@ -46,7 +46,7 @@
 // NewCountingWriteOnce makes a new promise.LockingWriteOnce
 func NewCountingWriteOnce(activeCounter counter.GoRoutineCounter) WriteOnce {
 	return &promise{
-		doneCh:       make(chan struct{}),
+		doneCh:        make(chan struct{}),
 		activeCounter: activeCounter,
 	}
 }
@@ -98,11 +98,11 @@
 }
 
 type simplePromise struct {
-	doneCh        chan struct{}
+	doneCh chan struct{}
 
 	// Should be access via atomic.
-	isSet         int32
-	value         interface{}
+	isSet int32
+	value interface{}
 }
 
 var _ WriteOnce = &simplePromise{}

Run ./hack/update-gofmt.sh
				
				Click to see stdout/stderrfrom junit_verify.xml

Filter through log files | View test history on testgrid


verify staticcheck 5m55s

make verify WHAT=staticcheck
Errors from staticcheck:
vendor/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/promise/promise_test.go:32:21: too many arguments (compile)
vendor/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/promise/promise_test.go:32:28: too many arguments (compile)
vendor/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/promise/promise_test.go:40:16: wr.Get undefined (type WriteOnce has no field or method Get) (compile)
vendor/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/promise/promise_test.go:84:16: wr.Get undefined (type WriteOnce has no field or method Get) (compile)
vendor/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/promise/promise_test.go:117:16: wr.Get undefined (type WriteOnce has no field or method Get) (compile)
vendor/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go:874:21: func (*queueSet).preCreateOrUnblockGoroutine is unused (U1000)

Please review the above warnings. You can test via:
  hack/verify-staticcheck.sh <failing package>
If the above warnings do not make sense, you can exempt the line or file. See:
  https://staticcheck.io/docs/#ignoring-problems
				
				Click to see stdout/stderrfrom junit_verify.xml

Filter through log files | View test history on testgrid


Show 40 Passed Tests