- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 43 for isync (0.05 sec)
-
internal/grid/connection.go
id: o.id, ctx: o.ctx, outgoing: xsync.NewMapOfPresized[uint64, *muxClient](1000), inStream: xsync.NewMapOfPresized[uint64, *muxServer](1000), outQueue: make(chan []byte, defaultOutQueue), dialer: o.dial, side: ws.StateServerSide, connChange: &sync.Cond{L: &sync.Mutex{}}, handlers: o.handlers, auth: o.auth,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
cni/pkg/log/uds_test.go
istiolog.Warn("warn log") istiolog.Error("error log") istiolog.WithLabels("key", 2).Infof("with labels") // This will error because stdout cannot sync, but the UDS part should sync // Ideally we would fail if the UDS part fails but the error library makes it kind of tricky _ = istiolog.Sync() // Restore os stdout. os.Stdout = stdout assert.NoError(t, istiolog.Configure(loggingOptions)) assert.NoError(t, w.Close())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:28 UTC 2024 - 4.1K bytes - Viewed (0) -
src/time/tick_test.go
drainAsync := func() { if synctimerchan { // sync timers must have the right semantics without draining: // there are no stale values. return } // async timers can send one stale value (then the timer is disabled). drain1() if isTicker { // async tickers can send two stale values: there may be one // sitting in the channel buffer, and there may also be one
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
src/os/pidfd_linux.go
// v5.3: pidfd_open syscall, clone3 syscall; // v5.4: P_PIDFD idtype support for waitid syscall; // v5.6: pidfd_getfd syscall. package os import ( "errors" "internal/syscall/unix" "sync" "syscall" "unsafe" ) func ensurePidfd(sysAttr *syscall.SysProcAttr) *syscall.SysProcAttr { if !pidfdWorks() { return sysAttr } var pidfd int if sysAttr == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 18:08:44 UTC 2024 - 4.2K bytes - Viewed (0) -
samples/bookinfo/src/productpage/productpage.py
return response # a helper function for asyncio.gather, does not return a value async def getProductReviewsIgnoreResponse(product_id, headers): getProductReviews(product_id, headers) # flood reviews with unnecessary requests to demonstrate Istio rate limiting, asynchoronously async def floodReviewsAsynchronously(product_id, headers): # the response is disregarded
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 14:35:54 UTC 2024 - 14.6K bytes - Viewed (0) -
src/syscall/rlimit.go
// Copyright 2022 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. //go:build unix package syscall import ( "sync/atomic" ) // origRlimitNofile, if non-nil, is the original soft RLIMIT_NOFILE. var origRlimitNofile atomic.Pointer[Rlimit] // Some systems set an artificially low soft limit on open file count, for compatibility
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:57 UTC 2024 - 1.6K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java
public void process(Consumer<TransferEvent> consumer) { consumer.accept(event); } public void waitForProcessed() throws InterruptedException { // nothing, is async } } private static class BlockingExchange extends Exchange { private final CountDownLatch latch = new CountDownLatch(1); private BlockingExchange(TransferEvent event) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 20:50:56 UTC 2024 - 8.4K bytes - Viewed (0) -
docs/en/docs/release-notes.md
* Fix typos in Async docs. PR [#1423](https://github.com/tiangolo/fastapi/pull/1423). ## 0.54.2 * Add translation to Spanish for [Concurrency and async / await - Concurrencia y async / await](https://fastapi.tiangolo.com/es/async/). PR [#1290](https://github.com/tiangolo/fastapi/pull/1290) by [@alvaropernas](https://github.com/alvaropernas).
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Fri Jun 14 15:07:37 UTC 2024 - 395.4K bytes - Viewed (0) -
pkg/kube/krt/informer.go
// Note: runExistingState is NOT respected here. // Informer doesn't expose a way to do that. However, due to the runtime model of informers, this isn't a dealbreaker; // the handlers are all called async, so we don't end up with the same deadlocks we would have in the other collection types. // While this is quite kludgy, this is an internal interface so its not too bad. if !i.eventHandlers.Insert(f) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 11:01:46 UTC 2024 - 6.1K bytes - Viewed (0) -
cmd/storage-rest-server.go
write(block) if canWrite { w.(http.Flusher).Flush() } } } }() return &h } var poolBuf8k = sync.Pool{ New: func() interface{} { b := make([]byte, 8192) return &b }, } var poolBuf128k = sync.Pool{ New: func() interface{} { b := make([]byte, 128<<10) return b }, } // waitForHTTPStream will wait for responses where
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 44.8K bytes - Viewed (0)