- Sort Score
- Num 10 results
- Language All
Results 381 - 390 of 769 for differ (0.37 seconds)
-
cmd/erasure-multipart-conditional_test.go
func TestNewMultipartUploadConditionalWithReadQuorumFailure(t *testing.T) { ctx := context.Background() obj, fsDirs, err := prepareErasure16(ctx) if err != nil { t.Fatal(err) } defer obj.Shutdown(context.Background()) defer removeRoots(fsDirs) z := obj.(*erasureServerPools) xl := z.serverPools[0].sets[0] bucket := "test-bucket" object := "test-object"
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 6.9K bytes - Click Count (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt
import mockwebserver3.SocketEffect import mockwebserver3.SocketEffect.CloseSocket import mockwebserver3.SocketEffect.CloseStream import mockwebserver3.SocketEffect.ShutdownConnection import okio.Buffer import okio.ByteString internal fun Dispatcher.wrap(): mockwebserver3.Dispatcher { if (this is QueueDispatcher) return this.delegate val delegate = this return object : mockwebserver3.Dispatcher() {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Jul 03 13:16:34 GMT 2025 - 4.1K bytes - Click Count (1) -
internal/store/queuestore_test.go
return queueStore, nil } // Tear down queue store. func tearDownQueueStore() error { return os.RemoveAll(queueDir) } // TestQueueStorePut - tests for store.Put func TestQueueStorePut(t *testing.T) { defer func() { if err := tearDownQueueStore(); err != nil { t.Fatal("Failed to tear down store ", err) } }() store, err := setUpQueueStore(queueDir, 100) if err != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 10.2K bytes - Click Count (0) -
okhttp/okhttp3.pro
# JSR 305 annotations are for embedding nullability information. -dontwarn javax.annotation.** # Animal Sniffer compileOnly dependency to ensure APIs are compatible with older versions of Java. -dontwarn org.codehaus.mojo.animal_sniffer.* # OkHttp platform used only on JVM and when Conscrypt and other security providers are available. # May be used with robolectric or deliberate use of Bouncy Castle on Android -dontwarn okhttp3.internal.platform.**
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Jul 19 13:25:00 GMT 2025 - 512 bytes - Click Count (0) -
cmd/generic-handlers.go
} defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r)) writeErrorResponse(r.Context(), w, errorCodes.ToAPIErr(ErrUnsupportedMetadata), r.URL) return } if isHTTPHeaderSizeTooLarge(r.Header) { if ok { tc.FuncName = "handler.ValidRequest" tc.ResponseRecorder.LogErrBody = true }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 20.7K bytes - Click Count (1) -
docs/de/docs/how-to/index.md
# How-To – Rezepte { #how-to-recipes } Hier finden Sie verschiedene Rezepte und „How-To“-Anleitungen zu **verschiedenen Themen**. Die meisten dieser Ideen sind mehr oder weniger **unabhängig**, und in den meisten Fällen müssen Sie diese nur studieren, wenn sie direkt auf **Ihr Projekt** anwendbar sind. Wenn etwas für Ihr Projekt interessant und nützlich erscheint, lesen Sie es, andernfalls überspringen Sie es einfach. /// tip | TippCreated: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Sep 20 15:10:09 GMT 2025 - 654 bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/BasePublicSuffixList.kt
import java.io.IOException import java.io.InterruptedIOException import java.util.concurrent.CountDownLatch import java.util.concurrent.atomic.AtomicBoolean import okio.ByteString import okio.Source import okio.buffer internal abstract class BasePublicSuffixList : PublicSuffixList { /** True after we've attempted to read the list for the first time. */ private val listRead = AtomicBoolean(false)Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Mon Jul 28 07:33:49 GMT 2025 - 3.6K bytes - Click Count (0) -
okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/MappingTables.kt
import kotlin.streams.toList import okio.Buffer /** Index [table] for compactness as specified by `IdnaMappingTable`. */ fun buildIdnaMappingTableData(table: SimpleIdnaMappingTable): IdnaMappingTableData { val simplified = mergeAdjacentRanges(table.mappings) val withoutSectionSpans = withoutSectionSpans(simplified) val sections = sections(withoutSectionSpans) val rangesBuffer = Buffer() val mappingsBuffer = StringBuilder()
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 8.3K bytes - Click Count (0) -
cmd/ilm-config.go
} func (c *ilmConfig) getExpirationWorkers() int { c.mu.RLock() defer c.mu.RUnlock() return c.cfg.ExpirationWorkers } func (c *ilmConfig) getTransitionWorkers() int { c.mu.RLock() defer c.mu.RUnlock() return c.cfg.TransitionWorkers } func (c *ilmConfig) update(cfg ilm.Config) { c.mu.Lock() defer c.mu.Unlock() c.cfg = cfg
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Mar 05 02:50:24 GMT 2024 - 1.3K bytes - Click Count (0) -
logger/slog_test.go
//go:build go1.21 package logger import ( "bytes" "context" "log/slog" "strings" "testing" "time" ) func TestSlogLogger(t *testing.T) { buf := &bytes.Buffer{} handler := slog.NewTextHandler(buf, &slog.HandlerOptions{AddSource: true}) logger := NewSlogLogger(slog.New(handler), Config{LogLevel: Info}) logger.Trace(context.Background(), time.Now(), func() (string, int64) { return "select count(*) from users", 0
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Thu Oct 30 10:56:26 GMT 2025 - 782 bytes - Click Count (0)