- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,077 for kAsync (0.09 sec)
-
internal/dsync/dsync-server_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package dsync import ( "fmt" "io" "net/http" "net/http/httptest" "sync" "sync/atomic" "time" "github.com/minio/mux" ) const numberOfNodes = 5 var ( ds *Dsync nodes = make([]*httptest.Server, numberOfNodes) // list of node IP addrs or hostname with ports.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jan 23 16:46:37 UTC 2023 - 8.3K bytes - Viewed (0) -
internal/dsync/dsync-client_test.go
// GNU Affero General Public License for more details. // // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package dsync import ( "bytes" "context" "errors" "net/http" "net/url" "time" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/rest" )
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 20 17:36:09 UTC 2022 - 4.4K bytes - Viewed (0) -
pkg/controller/deployment/sync.go
if err != nil { return err } allRSs := append(oldRSs, newRS) return dc.syncDeploymentStatus(ctx, allRSs, newRS, d) } // sync is responsible for reconciling deployments on scaling events or when they // are paused. func (dc *DeploymentController) sync(ctx context.Context, d *apps.Deployment, rsList []*apps.ReplicaSet) error { newRS, oldRSs, err := dc.getAllReplicaSetsAndSyncRevision(ctx, d, rsList, false)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 23:39:52 UTC 2023 - 24.5K bytes - Viewed (0) -
internal/dsync/dsync.go
// You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package dsync // Dsync represents dsync client object which is initialized with // authenticated clients, used to initiate lock REST calls. type Dsync struct { // List of rest client objects, one per lock server. GetLockers func() ([]NetLocker, string) // Timeouts to apply. Timeouts Timeouts
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Mar 01 19:14:28 UTC 2022 - 1K bytes - Viewed (0) -
docs/fr/docs/async.md
Vous avez donc compris que `await` peut seulement être utilisé dans des fonctions définies avec `async def`. Mais en même temps, les fonctions définies avec `async def` doivent être appelées avec `await` et donc dans des fonctions définies elles aussi avec `async def`. Vous avez donc remarqué ce paradoxe d'oeuf et de la poule, comment appelle-t-on la première fonction `async` ?
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sun Mar 31 23:52:53 UTC 2024 - 24K bytes - Viewed (0) -
docs/ja/docs/async.md
``` ### より発展的な技術詳細 `await` は `async def` で定義された関数内でのみ使用できることがわかったかと思います。 しかし同時に、`async def` で定義された関数は「awaitされる」必要があります。なので、`async def` を持つ関数は、`async def` で定義された関数内でのみ呼び出せます。 では、このニワトリと卵の問題について、最初の `async` 関数をどのように呼び出すのでしょうか? **FastAPI**を使用している場合、その「最初の」関数が*path operation 関数*であり、FastAPIが正しく実行する方法を知っているので、心配する必要はありません。
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 27.8K bytes - Viewed (0) -
docs/zh/docs/async.md
return burgers ``` ### 更多技术细节 您可能已经注意到,`await` 只能在 `async def` 定义的函数内部使用。 但与此同时,必须"等待"通过 `async def` 定义的函数。因此,带 `async def` 的函数也只能在 `async def` 定义的函数内部调用。 那么,这关于先有鸡还是先有蛋的问题,如何调用第一个 `async` 函数? 如果您使用 **FastAPI**,你不必担心这一点,因为"第一个"函数将是你的路径操作函数,FastAPI 将知道如何做正确的事情。 但如果您想在没有 FastAPI 的情况下使用 `async` / `await`,则可以这样做。 ### 编写自己的异步代码
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 21.1K bytes - Viewed (0) -
src/internal/pkgbits/sync.go
// SyncMarker is an enum type that represents markers that may be // written to export data to ensure the reader and writer stay // synchronized. type SyncMarker int //go:generate stringer -type=SyncMarker -trimprefix=Sync const ( _ SyncMarker = iota // Public markers (known to go/types importers). // Low-level coding markers. SyncEOF SyncBool SyncInt64 SyncUint64 SyncString SyncValue SyncVal
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Aug 04 17:12:28 UTC 2022 - 2.4K bytes - Viewed (0) -
src/cmd/go/internal/workcmd/sync.go
// go work sync package workcmd import ( "cmd/go/internal/base" "cmd/go/internal/gover" "cmd/go/internal/imports" "cmd/go/internal/modload" "cmd/go/internal/toolchain" "context" "golang.org/x/mod/module" ) var cmdSync = &base.Command{ UsageLine: "go work sync", Short: "sync workspace build list to modules", Long: `Sync syncs the workspace's build list back to the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Jun 03 21:13:11 UTC 2023 - 4.6K bytes - Viewed (0) -
src/internal/runtime/atomic/atomic_ppc64x.s
TEXT ·Load(SB),NOSPLIT|NOFRAME,$-8-12 MOVD ptr+0(FP), R3 SYNC MOVWZ 0(R3), R3 CMPW R3, R3, CR7 BC 4, 30, 1(PC) // bne- cr7,0x4 ISYNC MOVW R3, ret+8(FP) RET // uint8 ·Load8(uint8 volatile* ptr) TEXT ·Load8(SB),NOSPLIT|NOFRAME,$-8-9 MOVD ptr+0(FP), R3 SYNC MOVBZ 0(R3), R3 CMP R3, R3, CR7 BC 4, 30, 1(PC) // bne- cr7,0x4 ISYNC MOVB R3, ret+8(FP) RET
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 7.5K bytes - Viewed (0)