- Sort Score
- Num 10 results
- Language All
Results 341 - 350 of 453 for blocks (0.05 seconds)
-
cmd/metacache-manager.go
func (m *metacacheManager) deleteBucketCache(bucket string) { m.init.Do(m.initManager) m.mu.Lock() b, ok := m.buckets[bucket] if !ok { m.mu.Unlock() return } delete(m.buckets, bucket) m.mu.Unlock() // Since deletes may take some time we try to do it without // holding lock to m all the time. b.mu.Lock() defer b.mu.Unlock() for k, v := range b.caches {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 5.2K bytes - Click Count (0) -
internal/disk/stat_openbsd.go
s := syscall.Statfs_t{} err = syscall.Statfs(path, &s) if err != nil { return Info{}, err } reservedBlocks := uint64(s.F_bfree) - uint64(s.F_bavail) info = Info{ Total: uint64(s.F_bsize) * (uint64(s.F_blocks) - reservedBlocks), Free: uint64(s.F_bsize) * uint64(s.F_bavail), Files: uint64(s.F_files), Ffree: uint64(s.F_ffree), FSType: getFSType(s.F_fstypename[:]), } if info.Free > info.Total {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 1.8K bytes - Click Count (0) -
src/cmd/asm/internal/lex/slice.go
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Thu Jun 29 22:49:50 GMT 2023 - 1.6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ThreadInterruptTest.kt
private lateinit var server: MockWebServer private lateinit var client: OkHttpClient @BeforeEach fun setUp() { // Sockets on some platforms can have large buffers that mean writes do not block when // required. These socket factories explicitly set the buffer sizes on sockets created. server = MockWebServer() server.serverSocketFactory = object : DelegatingServerSocketFactory(getDefault()) {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 18:33:48 GMT 2025 - 6.4K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/EvictingQueue.java
* * <p>An evicting queue must be configured with a maximum size. Each time an element is added to a * full queue, the queue automatically removes its head element. This is different from conventional * bounded queues, which either block or reject new elements when full. * * <p>This class is not thread-safe, and does not accept null elements. * * @author Kurt Alfred Kluever * @since 15.0 */ @GwtCompatible
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Feb 13 17:34:21 GMT 2025 - 4.6K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/DefaultLifecyclePluginAnalyzer.java
this.defaultLifeCycles = requireNonNull(defaultLifeCycles); } // These methods deal with construction intact Plugin object that look like they come from a standard // <plugin/> block in a Maven POM. We have to do some wiggling to pull the sources of information // together and this really shows the problem of constructing a sensible default configuration, but
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Sat Apr 05 11:52:05 GMT 2025 - 9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
headers.value(i) == "trailers" ) { result.add(Header(name, headers.value(i))) } } return result } /** Returns headers for a name value block containing an HTTP/2 response. */ fun readHttp2HeadersList( headerBlock: Headers, protocol: Protocol, ): Response.Builder { var statusLine: StatusLine? = null
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Jul 29 21:11:09 GMT 2025 - 7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt
@BeforeEach fun setUp() { if (connectionType == H2) { platform.assumeHttp2Support() } // Sockets on some platforms can have large buffers that mean writes do not block when // required. These socket factories explicitly set the buffer sizes on sockets created. server = MockWebServer() server.serverSocketFactory =
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 9.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
} throw new RejectedExecutionException(); } }; SequentialExecutor executor = new SequentialExecutor(delegate); ExecutorService blocked = newCachedThreadPool(); Future<?> first = blocked.submit( new Runnable() { @Override public void run() { executor.execute(Runnables.doNothing()); }Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 11.4K bytes - Click Count (0) -
doc/godebug.md
distribution that disables transparent huge pages altogether. Go 1.22 added contention on runtime-internal locks to the [`mutex` profile](/pkg/runtime/pprof#Profile). Contention on these locks is always reported at `runtime._LostContendedRuntimeLock`. Complete stack traces of runtime locks can be enabled with the [`runtimecontentionstacks` setting](/pkg/runtime#hdr-Environment_Variables). These stack traces have
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Wed Dec 03 00:18:09 GMT 2025 - 24.7K bytes - Click Count (0)