- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 284 for Synchronized (0.21 sec)
-
src/main/java/jcifs/dcerpc/msrpc/LsaPolicyHandle.java
handle.sendrecv(rpc); if (rpc.retval != 0) { throw new SmbException(rpc.retval, false); } this.opened = true; } @Override public synchronized void close() throws IOException { if (this.opened) { this.opened = false; final MsrpcLsarClose rpc = new MsrpcLsarClose(this); this.handle.sendrecv(rpc);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.3K bytes - Viewed (0) -
src/main/java/jcifs/http/Handler.java
* * @param factory * The URL stream handler factory. */ public static void setURLStreamHandlerFactory(final URLStreamHandlerFactory factory) { synchronized (PROTOCOL_HANDLERS) { if (Handler.factory != null) { throw new IllegalStateException("URLStreamHandlerFactory already set."); } PROTOCOL_HANDLERS.clear();
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 6.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ingest/IngestFactory.java
* The ingester is inserted into the collection and the array is re-sorted by priority. * This method is thread-safe. * * @param ingester the ingester to add */ public synchronized void add(final Ingester ingester) { if (logger.isDebugEnabled()) { logger.debug("Loaded {}", ingester.getClass().getSimpleName()); }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 2.4K bytes - Viewed (0) -
src/main/java/jcifs/netbios/Lmhosts.java
* @param tc the CIFS context * @return resolved name, null if not found */ public synchronized NbtAddress getByName(final String host, final CIFSContext tc) { return getByName(new Name(tc.getConfig(), host, 0x20, null), tc); } synchronized NbtAddress getByName(final Name name, final CIFSContext tc) { NbtAddress result = null; try {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 6.3K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/msrpc/SamrAliasHandle.java
handle.sendrecv(rpc); if (rpc.retval != 0) { throw new SmbException(rpc.retval, false); } this.opened = true; } @Override public synchronized void close() throws IOException { if (this.opened) { this.opened = false; final MsrpcSamrCloseHandle rpc = new MsrpcSamrCloseHandle(this); this.handle.sendrecv(rpc);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.5K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/msrpc/SamrPolicyHandle.java
} final MsrpcSamrConnect2 rpc2 = new MsrpcSamrConnect2(server, access, this); handle.sendrecv(rpc2); } this.opened = true; } @Override public synchronized void close() throws IOException { if (this.opened) { this.opened = false; final samr.SamrCloseHandle rpc = new MsrpcSamrCloseHandle(this); this.handle.sendrecv(rpc);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.7K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/DefaultArtifactFilterManager.java
this.delegates = delegates; this.coreArtifacts = coreExports.getExportedArtifacts(); } private synchronized Set<String> getExcludedArtifacts() { if (excludedArtifacts == null) { excludedArtifacts = new LinkedHashSet<>(coreArtifacts); } return excludedArtifacts; } /**
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Fri Jun 06 14:28:57 UTC 2025 - 3.1K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/features/FeatureUtil.java
*/ public static TesterRequirements getTesterRequirements(Class<?> testerClass) throws ConflictingRequirementsException { synchronized (classTesterRequirementsCache) { TesterRequirements requirements = classTesterRequirementsCache.get(testerClass); if (requirements == null) { requirements = buildTesterRequirements(testerClass);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 14:50:24 UTC 2024 - 12.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java
import org.jspecify.annotations.Nullable; /** * Tests for {@link Synchronized#deque} and {@link Queues#synchronizedDeque}. * * @author Kurt Alfred Kluever */ @NullUnmarked public class SynchronizedDequeTest extends TestCase { protected Deque<String> create() { TestDeque<String> inner = new TestDeque<>(); Deque<String> outer = Synchronized.deque(inner, inner.mutex);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 7.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImpl.java
dataMap.put(fessConfig.getIndexFieldDocId(), systemHelper.generateDocId(dataMap)); } ComponentUtil.getLanguageHelper().updateDocument(dataMap); synchronized (docList) { docList.add(ingest(paramMap, dataMap)); final long contentSize = indexingHelper.calculateDocumentSize(dataMap); docList.addContentSize(contentSize);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 10.3K bytes - Viewed (0)