- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 587 for batch (0.13 sec)
-
src/main/java/jcifs/config/BaseConfiguration.java
public class BaseConfiguration implements Configuration { private static final Logger log = LoggerFactory.getLogger(BaseConfiguration.class); private static final Map<String, Integer> DEFAULT_BATCH_LIMITS = new HashMap<>(); static { DEFAULT_BATCH_LIMITS.put("TreeConnectAndX.QueryInformation", 0); } private final Map<String, Integer> batchLimits = new HashMap<>(); protected int localPid = -1;
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Thu Jan 05 13:06:39 GMT 2023 - 20.4K bytes - Viewed (1) -
src/main/java/jcifs/smb1/smb1/AndXServerMessageBlock.java
dst[dstIndex++] = (byte)( byteCount & 0xFF ); dst[dstIndex++] = (byte)(( byteCount >> 8 ) & 0xFF ); dstIndex += byteCount; /* Normally, without intervention everything would batch * with everything else. If the below clause evaluates true * the andx command will not be written and therefore the * response will not read a batched command and therefore
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 11.3K bytes - Viewed (0) -
src/test/java/jcifs/tests/ConcurrencyTest.java
create2.chain(new Smb2CloseRequest(sess.getConfig(), Smb2Constants.UNSPECIFIED_FILEID)); synchronized ( lock ) { lock.notify(); } tree.send(create2); } catch ( Exception e ) {
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Nov 14 17:40:50 GMT 2021 - 17.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/AndXServerMessageBlock.java
dst[ dstIndex++ ] = (byte) ( ( this.byteCount >> 8 ) & 0xFF ); dstIndex += this.byteCount; /* * Normally, without intervention everything would batch * with everything else. If the below clause evaluates true * the andx command will not be written and therefore the * response will not read a batched command and therefore
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Mon Nov 28 10:56:27 GMT 2022 - 14.3K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/EventBus.java
* <li>It doesn't offer a way to wait for multiple events before taking action. For example, it * doesn't offer a way to wait for multiple producers to all report that they're "ready," nor * does it offer a way to batch multiple events from a single producer together. * <li>It doesn't support backpressure and other features needed for resilience. * <li>It doesn't provide much control of threading. * <li>It doesn't offer much monitoring.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Aug 25 16:37:57 GMT 2021 - 12.8K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/create/Smb2CreateRequest.java
/** * */ public static final byte SMB2_OPLOCK_LEVEL_EXCLUSIVE = 0x8; /** * */ public static final byte SMB2_OPLOCK_LEVEL_BATCH = 0x9; /** * */ public static final byte SMB2_OPLOCK_LEVEL_LEASE = (byte) 0xFF; /** * */ public static final int SMB2_IMPERSONATION_LEVEL_ANONYMOUS = 0x0; /**
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sat Jun 01 09:52:11 GMT 2019 - 14.3K bytes - Viewed (0) -
src/main/java/jcifs/Configuration.java
* * @return whether to ignore exceptions that occur during file copy */ boolean isIgnoreCopyToException (); /** * @param cmd * @return the batch limit for the given command */ int getBatchLimit ( String cmd ); /** * * Property <tt>jcifs.smb.client.notify_buf_size</tt> (int, default 1024) *
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Thu Jan 05 13:06:39 GMT 2023 - 18K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
/** Invokes {@code latch.}{@link CountDownLatch#await() await()} uninterruptibly. */ @J2ktIncompatible @GwtIncompatible // concurrency public static void awaitUninterruptibly(CountDownLatch latch) { boolean interrupted = false; try { while (true) { try { latch.await(); return; } catch (InterruptedException e) { interrupted = true;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 14.4K bytes - Viewed (0) -
build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java
CountDownLatch latch = new CountDownLatch(2); ByteArrayOutputStream stdout = connectStream(process.getInputStream(), latch); ByteArrayOutputStream stderr = connectStream(process.getErrorStream(), latch); process.waitFor(1, TimeUnit.MINUTES); latch.await(1, TimeUnit.MINUTES);
Java - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Fri Apr 26 09:46:00 GMT 2024 - 11.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TestThread.java
try { result = invokeMethod(request.methodName, request.arguments); } catch (ThreadDeath death) { return; } catch (InvocationTargetException exception) { responseQueue.put(new Response(request.methodName, null, exception.getTargetException())); continue; } catch (Throwable throwable) { responseQueue.put(new Response(request.methodName, null, throwable));
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Apr 26 20:07:17 GMT 2023 - 10.9K bytes - Viewed (0)