- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,351 for routine (0.54 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/routine.go
return t } // WithRoutine returns an http.Handler that executes preparation of long running requests (i.e. watches) // in a separate Goroutine and then serves the long running request in the main Goroutine. Doing so allows // freeing stack memory used in preparation Goroutine for better memory efficiency. func WithRoutine(handler http.Handler, longRunning request.LongRunningRequestCheck) http.Handler {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 10:22:16 UTC 2024 - 1.9K bytes - Viewed (0) -
cmd/leak-detect_test.go
// ignore the testing go routine. // since the tests will be invoking the leaktest it would contain the test go routine. if strings.HasPrefix(stack, "testing.RunTests") { continue } // Ignore the following go routines. // testing and run time go routines should be ignored, only the application generated go routines should be taken into account. if isIgnoredStackFn(stack) { continue } gs = append(gs, g)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 5.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/buffered/buffered.go
// Execute the real processing in a goroutine to keep it from blocking. // This lets the batching routine continue draining the queue immediately. b.delegateBackend.ProcessEvents(events...) }() } else { func() { defer runtime.HandleCrash() // Execute the real processing in a goroutine to keep it from blocking. // This lets the batching routine continue draining the queue immediately.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 9.1K bytes - Viewed (0) -
src/sync/cond_test.go
func BenchmarkCond32(b *testing.B) { benchmarkCond(b, 32) } func benchmarkCond(b *testing.B, waiters int) { c := NewCond(&Mutex{}) done := make(chan bool) id := 0 for routine := 0; routine < waiters+1; routine++ { go func() { for i := 0; i < b.N; i++ { c.L.Lock() if id == -1 { c.L.Unlock() break } id++ if id == waiters+1 { id = 0
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 22 18:52:42 UTC 2023 - 5K bytes - Viewed (0) -
cmd/admin-heal-ops.go
h.mutex.Unlock() return nil } // healSequenceStart - this is the top-level background heal // routine. It launches another go-routine that actually traverses // on-disk data, checks and heals according to the selected // settings. This go-routine itself, (1) monitors the traversal // routine for completion, and (2) listens for external stop // signals. When either event happens, it sets the finish status for
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 09 18:04:41 UTC 2024 - 25.1K bytes - Viewed (0) -
src/runtime/mmap.go
package runtime import "unsafe" // mmap calls the mmap system call. It is implemented in assembly. // We only pass the lower 32 bits of file offset to the // assembly routine; the higher bits (if required), should be provided // by the assembly routine as 0. // The err result is an OS error code such as ENOMEM. func mmap(addr unsafe.Pointer, n uintptr, prot, flags, fd int32, off uint32) (p unsafe.Pointer, err int)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Aug 25 20:58:13 UTC 2023 - 844 bytes - Viewed (0) -
pkg/util/goroutinemap/goroutinemap.go
See the License for the specific language governing permissions and limitations under the License. */ /* Package goroutinemap implements a data structure for managing go routines by name. It prevents the creation of new go routines if an existing go routine with the same name exists. */ package goroutinemap import ( "fmt" "sync" k8sRuntime "k8s.io/apimachinery/pkg/util/runtime" "k8s.io/klog/v2"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 16 11:54:27 UTC 2020 - 6.8K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/test/kotlin/org/gradle/internal/cc/impl/TrackingDynamicLookupRoutineTest.kt
} fun shouldTrackContext(action: DynamicLookupRoutine.() -> Unit) { val tracker = mock<DynamicCallContextTracker>() val routine = TrackingDynamicLookupRoutine(tracker) action(routine) verify(tracker, times(1)).enterDynamicCall(receiver) verify(tracker, times(1)).leaveDynamicCall(receiver) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 2K bytes - Viewed (0) -
src/runtime/asm.s
// license that can be found in the LICENSE file. #include "textflag.h" #ifndef GOARCH_amd64 TEXT ·sigpanic0(SB),NOSPLIT,$0-0 JMP ·sigpanic<ABIInternal>(SB) #endif // See map.go comment on the need for this routine. TEXT ·mapinitnoop<ABIInternal>(SB),NOSPLIT,$0-0
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 21:49:14 UTC 2024 - 386 bytes - Viewed (0) -
src/runtime/os_openbsd_syscall2.go
// mmap calls the mmap system call. It is implemented in assembly. // We only pass the lower 32 bits of file offset to the // assembly routine; the higher bits (if required), should be provided // by the assembly routine as 0. // The err result is an OS error code such as ENOMEM. func mmap(addr unsafe.Pointer, n uintptr, prot, flags, fd int32, off uint32) (p unsafe.Pointer, err int)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 2.5K bytes - Viewed (0)