- Sort Score
- Result 10 results
- Languages All
Results 191 - 200 of 388 for keep (0.03 sec)
-
src/main/java/jcifs/Configuration.java
*/ int getTransactionBufferSize (); /** * * Property <tt>jcifs.smb.maxBuffers</tt> (int, default 16) * * @return number of buffers to keep in cache */ int getBufferCacheSize (); /** * * Property <tt>jcifs.smb.client.listCount</tt> (int, default 200) *
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Thu Jan 05 13:06:39 UTC 2023 - 18K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
) { lock.withLock { val oldLimit = allocationLimit allocationLimit = settings.getMaxConcurrentStreams() if (allocationLimit < oldLimit) { // We might need new connections to keep policies satisfied connectionPool.scheduleOpener(route.address) } else if (allocationLimit > oldLimit) { // We might no longer need some connections connectionPool.scheduleCloser() }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 15.4K bytes - Viewed (0) -
cmd/metacache-server-pool.go
go func(o listPathOptions) { err := z.listMerged(listCtx, o, inCh) if err != nil { meta.setErr(err.Error()) } o.debugln("listAndSave: listing", o.ID, "finished with ", err) }(*o) // Keep track of when we return since we no longer have to send entries to output. var funcReturned bool var funcReturnedMu sync.Mutex defer func() { funcReturnedMu.Lock() funcReturned = true funcReturnedMu.Unlock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 12.7K bytes - Viewed (0) -
internal/kms/config.go
} conf.RootCAs, err = certs.GetRootCAs(env.Get(EnvKESServerCA, caDir)) if err != nil { return nil, err } client := kes.NewClientWithConfig("", conf) client.Endpoints = endpoints // Keep the default key in the KES cache to prevent availability issues // when MinIO restarts go func() { timer := time.NewTicker(10 * time.Second) defer timer.Stop() defaultKey := env.Get(EnvKESDefaultKey, "")
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 11:46:39 UTC 2024 - 14.2K bytes - Viewed (0) -
src/cmd/asm/internal/lex/input.go
tok := in.Stack.Next() if tok != scanner.Ident { in.expectText("expected identifier after '#'") } if !in.enabled() { // Can only start including again if we are at #else or #endif but also // need to keep track of nested #if[n]defs. // We let #line through because it might affect errors. switch in.Stack.Text() { case "else", "endif", "ifdef", "ifndef", "line": // Press on. default: return false }
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Sep 06 13:17:27 UTC 2024 - 12.5K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableSortedMap.java
} @Override ImmutableSortedSet<K> createKeySet() { // the keySet() of the delegate is only a Set and TreeMap.navigatableKeySet // is not available in GWT yet. To keep the code simple and code size more, // we make a copy here, instead of creating a view of it. // // TODO: revisit if it's unbearably slow or when GWT supports // TreeMap.navigatbleKeySet().
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Feb 27 19:19:19 UTC 2024 - 16.4K bytes - Viewed (0) -
lib/wasm/wasm_exec.js
this.mem.setUint32(offset, ptr, true); this.mem.setUint32(offset + 4, 0, true); offset += 8; }); // The linker guarantees global data starts from at least wasmMinDataAddr. // Keep in sync with cmd/link/internal/ld/data.go:wasmMinDataAddr. const wasmMinDataAddr = 4096 + 8192; if (offset >= wasmMinDataAddr) { throw new Error("total length of command line and environment variables exceeds limit");
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Aug 30 19:15:21 UTC 2024 - 16.5K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/AbstractIteratorTester.java
// in a recursive loop. Sneaky. if (level == stimuli.length) { // We've filled the array. compareResultsForThisListOfStimuli(); } else { // Keep recursing to fill the array. for (Stimulus<E, ? super I> stimulus : getStimulusValues()) { stimuli[level] = stimulus; recurse(level + 1); } } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 20.6K bytes - Viewed (0) -
docs/bucket/notifications/README.md
username (string) MQTT username password (string) MQTT password qos (number) set the quality of service priority, defaults to '0' keep_alive_interval (duration) keep-alive interval for MQTT connections in s,m,h,d reconnect_interval (duration) reconnect interval for MQTT connections in s,m,h,d queue_dir (path) staging dir for undelivered messages e.g. '/home/events'
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 84K bytes - Viewed (0) -
docs/en/docs/tutorial/bigger-applications.md
``` ## `APIRouter` Let's say the file dedicated to handling just users is the submodule at `/app/routers/users.py`. You want to have the *path operations* related to your users separated from the rest of the code, to keep it organized. But it's still part of the same **FastAPI** application/web API (it's part of the same "Python Package"). You can create the *path operations* for that module using `APIRouter`. ### Import `APIRouter`
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 18.4K bytes - Viewed (0)