Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 345 for blockdev (0.13 sec)

  1. 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)
  2. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/model/BlockDoc.groovy

    import org.w3c.dom.Element
    import gradlebuild.docs.dsl.source.model.TypeMetaData
    
    class BlockDoc implements DslElementDoc {
        private final MethodDoc blockMethod
        private final PropertyDoc blockProperty
        private final TypeMetaData type
        private boolean multiValued
    
        BlockDoc(MethodDoc blockMethod, PropertyDoc blockProperty, TypeMetaData type, boolean multiValued) {
            this.blockMethod = blockMethod
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Dec 09 08:14:05 UTC 2020
    - 2.2K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

        //            (__)\       )\/\
        //                ||----w |
        //                ||     ||
        Runnable state = get();
        Blocker blocker = null;
        while (state instanceof Blocker || state == PARKED) {
          if (state instanceof Blocker) {
            blocker = (Blocker) state;
          }
          spinCount++;
          if (spinCount > MAX_BUSY_WAIT_SPINS) {
            /*
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Sep 29 21:34:48 UTC 2023
    - 9.9K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/InterruptibleTask.java

        //            (__)\       )\/\
        //                ||----w |
        //                ||     ||
        Runnable state = get();
        Blocker blocker = null;
        while (state instanceof Blocker || state == PARKED) {
          if (state instanceof Blocker) {
            blocker = (Blocker) state;
          }
          spinCount++;
          if (spinCount > MAX_BUSY_WAIT_SPINS) {
            /*
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Sep 29 21:34:48 UTC 2023
    - 9.9K bytes
    - Viewed (0)
  8. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/BlockDetailRenderer.java

            this.listener = listener;
        }
    
        public void renderTo(BlockDoc blockDoc, Element parent) {
            Document document = parent.getOwnerDocument();
    
            Element section = document.createElement("section");
            parent.appendChild(section);
            section.setAttribute("id", blockDoc.getId());
            section.setAttribute("role", "detail");
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Dec 09 08:14:05 UTC 2020
    - 3.7K bytes
    - Viewed (0)
  9. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/BlockTableRenderer.java

                td.appendChild(link);
                link.setAttribute("linkend", blockDoc.getId());
                Element literal = document.createElement("literal");
                link.appendChild(literal);
                literal.appendChild(document.createTextNode(blockDoc.getName()));
    
                td = document.createElement("td");
                tr.appendChild(td);
                if (blockDoc.isDeprecated()) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Dec 09 08:14:05 UTC 2020
    - 2.8K bytes
    - Viewed (0)
  10. plugin/pkg/admission/eventratelimit/admission_test.go

    				newEventRequest().withNamespace("B").blocked(),
    				newEventRequest().withNamespace("A").blocked(),
    				// This should clear out namespace B from the lru cache
    				newEventRequest().withNamespace("C"),
    				newEventRequest().withNamespace("A").blocked(),
    				newEventRequest().withNamespace("B"),
    			},
    		},
    		{
    			name:                     "event blocked by source+object limits",
    			serverBurst:              100,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 17 13:19:08 UTC 2021
    - 15.6K bytes
    - Viewed (0)
Back to top