- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 547 for sock (0.09 sec)
-
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) -
android/guava-tests/test/com/google/common/util/concurrent/ForwardingObjectTester.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Jan 05 19:41:03 UTC 2023 - 2.5K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)