- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,515 for batch (0.16 sec)
-
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/smb1/com/SmbComOpenAndX.java
// flags (not the same as flags constructor argument) static final int FLAGS_RETURN_ADDITIONAL_INFO = 0x01; static final int FLAGS_REQUEST_OPLOCK = 0x02; static final int FLAGS_REQUEST_BATCH_OPLOCK = 0x04; // Access Mode Encoding for desiredAccess static final int SHARING_COMPATIBILITY = 0x00; static final int SHARING_DENY_READ_WRITE_EXECUTE = 0x10; static final int SHARING_DENY_WRITE = 0x20;
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 7K 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) -
guava/src/com/google/common/cache/LocalCache.java
result = map; success = true; } catch (UnsupportedLoadingOperationException e) { success = true; throw e; } catch (InterruptedException e) { Thread.currentThread().interrupt(); throw new ExecutionException(e); } catch (RuntimeException e) { throw new UncheckedExecutionException(e); } catch (Exception e) { throw new ExecutionException(e);
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 150.3K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/LocalCache.java
result = map; success = true; } catch (UnsupportedLoadingOperationException e) { success = true; throw e; } catch (InterruptedException e) { Thread.currentThread().interrupt(); throw new ExecutionException(e); } catch (RuntimeException e) { throw new UncheckedExecutionException(e); } catch (Exception e) { throw new ExecutionException(e);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 144.7K 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) -
src/test/java/jcifs/tests/WatchTest.java
try ( SmbWatchHandle w = this.base.watch(FileNotifyInformation.FILE_NOTIFY_CHANGE_FILE_NAME, false) ) { setupWatch(w); try ( SmbResource cr = new SmbFile(this.base, "created") ) { cr.createNewFile(); assertNotified(w, FileNotifyInformation.FILE_ACTION_ADDED, "created", null); } } catch ( TimeoutException e ) {
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 8.4K bytes - Viewed (0)