Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 547 for sock (0.09 sec)

  1. build-logic/documentation/src/test/groovy/gradlebuild/docs/dsl/docbook/JavadocConverterTest.groovy

    import gradlebuild.docs.dsl.source.model.MethodMetaData
    
    class JavadocConverterTest extends XmlSpecification {
        final ClassMetaData classMetaData = Mock()
        final JavadocLinkConverter linkConverter = Mock()
        final GenerationListener listener = Mock()
        final JavadocConverter parser = new JavadocConverter(document, linkConverter)
    
        def respectsLineIndentation() {
            _ * classMetaData.rawCommentText >> '''
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Dec 09 08:14:05 UTC 2020
    - 14.2K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ForwardingObjectTester.java

                  public T apply(Object delegate) {
                    T mock = mock(forwarderClass, CALLS_REAL_METHODS);
                    try {
                      T stubber = doReturn(delegate).when(mock);
                      DELEGATE_METHOD.invoke(stubber);
                    } catch (Exception e) {
                      throw new RuntimeException(e);
                    }
                    return mock;
                  }
                });
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Jan 05 19:41:03 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  3. internal/lock/lock_windows.go

    		}
    	}
    
    	return &LockedFile{File: f}, nil
    }
    
    // TryLockedOpenFile - tries a new write lock, functionality
    // it is similar to LockedOpenFile with with syscall.LOCK_EX
    // mode but along with syscall.LOCK_NB such that the function
    // doesn't wait forever but instead returns if it cannot
    // acquire a write lock.
    func TryLockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 18 18:08:15 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/TestThread.java

     * test with reference to the same "lock-like object", and then their interactions with that object
     * are choreographed via the various methods on this class.
     *
     * <p>A "lock-like object" is really any object that may be used for concurrency control. If the
     * {@link #callAndAssertBlocks} method is ever called in a test, the lock-like object must have a
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  5. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt

      /** The timestamp of the last taken event, used to measure elapsed time between events. */
      private var lastTimestampNs: Long? = null
    
      /** Confirm that the thread does not hold a lock on `lock` during the callback. */
      fun forbidLock(lock: Any) {
        forbiddenLocks.add(lock)
      }
    
      /**
       * Removes recorded events up to (and including) an event is found whose class equals [eventClass]
       * and returns it.
       */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9K bytes
    - Viewed (0)
  6. guava-testlib/src/com/google/common/testing/TestLogHandler.java

    public class TestLogHandler extends Handler {
      private final Object lock = new Object();
    
      /** We will keep a private list of all logged records */
      @GuardedBy("lock")
      private final List<LogRecord> list = new ArrayList<>();
    
      /** Adds the most recently logged record to our list. */
      @Override
      public void publish(@Nullable LogRecord record) {
        synchronized (lock) {
          if (record != null) {
            list.add(record);
          }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 21 20:53:25 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  7. cni/pkg/iptables/iptables_e2e_test.go

    		// Put a new file we have permission to access over xtables.lock
    		xtables := filepath.Join(t.TempDir(), "xtables.lock")
    		_, err := os.Create(xtables)
    		assert.NoError(t, err)
    		_ = os.Mkdir("/run", 0o777)
    		_ = mountns.BindMount(xtables, "/run/xtables.lock")
    	})
    }
    
    func iptablesSave(t *testing.T) string {
    	res, err := exec.Command("iptables-save").CombinedOutput()
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 15 15:39:28 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  8. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultUpdateCheckManager.java

                    return;
                }
    
                FileChannel channel = null;
                FileLock lock = null;
                try {
                    Properties props = new Properties();
    
                    channel = new RandomAccessFile(touchfile, "rw").getChannel();
                    lock = channel.lock();
    
                    if (touchfile.canRead()) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb1/smb1/TransactNamedPipeInputStream.java

        private boolean dcePipe;
    
        Object lock;
    
        TransactNamedPipeInputStream( SmbNamedPipe pipe ) throws SmbException,
                    MalformedURLException, UnknownHostException {
            super( pipe, ( pipe.pipeType & 0xFFFF00FF ) | SmbFile.O_EXCL );
            this.dcePipe = ( pipe.pipeType & SmbNamedPipe.PIPE_TYPE_DCE_TRANSACT ) != SmbNamedPipe.PIPE_TYPE_DCE_TRANSACT;
            lock = new Object();
        }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 4.6K bytes
    - Viewed (0)
  10. android/guava-testlib/src/com/google/common/testing/TestLogHandler.java

    public class TestLogHandler extends Handler {
      private final Object lock = new Object();
    
      /** We will keep a private list of all logged records */
      @GuardedBy("lock")
      private final List<LogRecord> list = new ArrayList<>();
    
      /** Adds the most recently logged record to our list. */
      @Override
      public void publish(@Nullable LogRecord record) {
        synchronized (lock) {
          if (record != null) {
            list.add(record);
          }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 21 20:53:25 UTC 2024
    - 2.8K bytes
    - Viewed (0)
Back to top