- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 59 for bicycle (0.2 sec)
-
internal/grid/grid_test.go
(*resp)[k] = v } return resp, nil } // Return error h2 := NewSingleHandler[*MSS, *MSS](handlerTest2, NewMSS, NewMSS) handler2 := func(req *MSS) (resp *MSS, err *RemoteErr) { defer req.Recycle() r := RemoteErr(req.Get("err")) return nil, &r } errFatal(h1.Register(local, handler1)) errFatal(h2.Register(local, handler2)) errFatal(h1.Register(remote, handler1))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/AbstractImmutableSetTest.java
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Mar 07 18:34:03 GMT 2024 - 18.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/AbstractImmutableSetTest.java
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Mar 07 18:34:03 GMT 2024 - 18.7K bytes - Viewed (0) -
cmd/config-current.go
errs = append(errs, fmt.Errorf("Unable to apply scanner config: %w", err)) } else { // update dynamic scanner values. scannerIdleMode.Store(scannerCfg.IdleMode) scannerCycle.Store(scannerCfg.Cycle) scannerExcessObjectVersions.Store(scannerCfg.ExcessVersions) scannerExcessFolders.Store(scannerCfg.ExcessFolders) configLogIf(ctx, scannerSleeper.Update(scannerCfg.Delay, scannerCfg.MaxWait)) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 30.8K bytes - Viewed (0) -
cmd/iam-store.go
// were changes to the in-memory cache we should wait for the next // cycle until we can safely update the in-memory cache. // // An in-memory cache must be replaced only if we know for sure that the // values loaded from disk are not stale. They might be stale if the // cached.updatedAt is more recent than the refresh cycle began. if cache.updatedAt.Before(loadedAt) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/storage-rest-server.go
} // RenameDataInlineHandler - renames a meta object and data dir to destination. func (s *storageRESTServer) RenameDataInlineHandler(p *RenameDataInlineHandlerParams) (*RenameDataResp, *grid.RemoteErr) { defer p.Recycle() return s.RenameDataHandler(&p.RenameDataHandlerParams) } // RenameFileHandler - rename a file from source to destination
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
cmd/peer-rest-server.go
// ListenHandler sends http trace messages back to peer rest client func (s *peerRESTServer) ListenHandler(ctx context.Context, v *grid.URLValues, out chan<- *grid.Bytes) *grid.RemoteErr { values := v.Values() defer v.Recycle() var prefix string if len(values[peerRESTListenPrefix]) > 1 { return grid.NewRemoteErrString("invalid request (peerRESTListenPrefix)") } globalAPIConfig.getRequestsPoolCapacity()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
src/cmd/api/main_test.go
name := fromPath if canonical, ok := w.importMap[fromDir][fromPath]; ok { name = canonical } pkg := w.imported[name] if pkg != nil { if pkg == &importing { log.Fatalf("cycle importing package %q", name) } return pkg, nil } w.imported[name] = &importing // Determine package files. dir := w.importDir[name] if dir == "" {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Apr 09 20:48:51 GMT 2024 - 31.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
*/ fun dispatcher(dispatcher: Dispatcher) = apply { this.dispatcher = dispatcher } /** * Sets the connection pool used to recycle HTTP and HTTPS connections. * * If unset, a new connection pool will be used. */ fun connectionPool(connectionPool: ConnectionPool) = apply { this.connectionPool = connectionPool
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/diagnostics/KtFirDataClassConverters.kt
firDiagnostic as KtPsiDiagnostic, token, ) } add(FirErrors.CYCLE_IN_ANNOTATION_PARAMETER.errorFactory) { firDiagnostic -> CycleInAnnotationParameterErrorImpl( firDiagnostic as KtPsiDiagnostic, token, ) } add(FirErrors.CYCLE_IN_ANNOTATION_PARAMETER.warningFactory) { firDiagnostic -> CycleInAnnotationParameterWarningImpl(
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Wed Apr 24 09:49:26 GMT 2024 - 208.3K bytes - Viewed (0)