- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 312 for blockdev (0.11 sec)
-
pkg/volume/fc/fc_util.go
return "", "" } // Flushes any outstanding I/O to the device func flushDevice(deviceName string, exec utilexec.Interface) { out, err := exec.Command("blockdev", "--flushbufs", deviceName).CombinedOutput() if err != nil { // Ignore the error and continue deleting the device. There is will be no retry on error.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 16 11:12:06 UTC 2022 - 12.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
// after some period of time the runner thread should become blocked on the task because it is // waiting for the slow interrupting thread to complete Thread.interrupt awaitBlockedOnInstanceOf(runner, InterruptibleTask.Blocker.class); Blocker blocker = (Blocker) LockSupport.getBlocker(runner); Thread owner = blocker.getOwner(); assertThat(owner).isSameInstanceAs(interrupter);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
// after some period of time the runner thread should become blocked on the task because it is // waiting for the slow interrupting thread to complete Thread.interrupt awaitBlockedOnInstanceOf(runner, InterruptibleTask.Blocker.class); Blocker blocker = (Blocker) LockSupport.getBlocker(runner); Thread owner = blocker.getOwner(); assertThat(owner).isSameInstanceAs(interrupter);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.6K bytes - Viewed (0) -
src/crypto/tls/quic.go
defer c.handshakeMutex.Lock() // Send on blockedc to notify the QUICConn that the handshake is blocked. // Exported methods of QUICConn wait for the handshake to become blocked // before returning to the user. select { case c.quic.blockedc <- struct{}{}: case <-c.quic.cancelc: return c.sendAlertLocked(alertCloseNotify) } // The QUICConn reads from signalc to notify us that the handshake may
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 17:23:54 UTC 2024 - 15.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Sep 29 21:34:48 UTC 2023 - 9.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/InterruptibleTask.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Sep 29 21:34:48 UTC 2023 - 9.9K bytes - Viewed (0) -
src/cmd/cgo/internal/test/sigprocmask.go
*/ import "C" import ( "os" "os/signal" "syscall" "testing" ) var blocked bool //export IntoGoAndBack func IntoGoAndBack() { // Verify that SIGIO stays blocked on the C thread // even when unblocked for signal.Notify(). signal.Notify(make(chan os.Signal), syscall.SIGIO) blocked = C.CheckBlocked() != 0 } func testSigprocmask(t *testing.T) { if r := C.RunSigThread(); r != 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 12:00:02 UTC 2023 - 808 bytes - Viewed (0) -
src/runtime/lock_sema.go
gp.m.blocked = true if *cgo_yield != nil && ns > 10e6 { ns = 10e6 } if semasleep(ns) >= 0 { gp.m.blocked = false // Acquired semaphore, semawakeup unregistered us. // Done. return true } if *cgo_yield != nil { asmcgocall(*cgo_yield, nil) } gp.m.blocked = false // Interrupted or timed out. Still registered. Semaphore not acquired. ns = deadline - nanotime()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 6.8K bytes - Viewed (0) -
apache-maven/src/assembly/maven/conf/settings.xml
<url>http://my.repository.com/repo/path</url> </mirror> --> <mirror> <id>maven-default-http-blocker</id> <mirrorOf>external:http:*</mirrorOf> <name>Pseudo repository to mirror external repositories initially using HTTP.</name> <url>http://0.0.0.0/</url> <blocked>true</blocked> </mirror> </mirrors> <!-- repositories
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon Jun 19 15:06:01 UTC 2023 - 11K bytes - Viewed (0) -
src/runtime/lock_futex.go
// Sleep for an arbitrary-but-moderate interval to poll libc interceptors. ns = 10e6 } for atomic.Load(key32(&n.key)) == 0 { gp.m.blocked = true futexsleep(key32(&n.key), 0, ns) if *cgo_yield != nil { asmcgocall(*cgo_yield, nil) } gp.m.blocked = false } } // May run with m.p==nil if called from notetsleep, so write barriers // are not allowed. // //go:nosplit
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:34 UTC 2024 - 5.4K bytes - Viewed (0)