- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for getbufvar (0.41 sec)
-
src/main/java/jcifs/smb1/smb1/BufferCache.java
return buf; } } static void getBuffers( SmbComTransaction req, SmbComTransactionResponse rsp ) { synchronized( cache ) { req.txn_buf = getBuffer(); rsp.txn_buf = getBuffer(); } } static public void releaseBuffer( byte[] buf ) { synchronized( cache ) { if (freeBuffers < MAX_BUFFERS) {
Java - Registered: Sun Apr 21 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 2.2K bytes - Viewed (0) -
android/guava/src/com/google/common/io/FileBackedOutputStream.java
@GuardedBy("this") @CheckForNull private File file; /** ByteArrayOutputStream that exposes its internals. */ private static class MemoryOutput extends ByteArrayOutputStream { byte[] getBuffer() { return buf; } int getCount() { return count; } } /** Returns the file holding the data (possibly null). */ @VisibleForTesting @CheckForNull
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 8.2K bytes - Viewed (0) -
src/main/java/jcifs/smb/BufferCacheImpl.java
this.cache = new Object[maxBuffers]; this.bufferSize = maxSize; } /** * {@inheritDoc} * * @see jcifs.BufferCache#getBuffer() */ @Override public byte[] getBuffer () { synchronized ( this.cache ) { byte[] buf; if ( this.freeBuffers > 0 ) { for ( int i = 0; i < this.cache.length; i++ ) {
Java - Registered: Sun Apr 21 00:10:10 GMT 2024 - Last Modified: Sun Jan 24 11:40:34 GMT 2021 - 2.9K bytes - Viewed (0) -
src/main/java/jcifs/BufferCache.java
* * @author mbechler * @internal */ public interface BufferCache { /** * * @return a buffer from the cache, or a new one */ byte[] getBuffer (); /** * Return a buffer to the cache * * @param buf */ void releaseBuffer ( byte[] buf );
Java - Registered: Sun Apr 21 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 1.1K bytes - Viewed (0) -
tensorflow/c/experimental/next_pluggable_device/tensor_pjrt_buffer_util.cc
tensorflow::AsyncValueTensor::FromTensor(tensor); if (av_tensor == nullptr || av_tensor->GetBuffer() == nullptr) { return absl::InternalError("Input tensor does not have PjRtBuffer."); } auto* c_api_buffer = dynamic_cast<xla::PjRtCApiBuffer*>(av_tensor->GetBuffer().get()); if (c_api_buffer == nullptr) { return absl::InternalError(
C++ - Registered: Tue Feb 27 12:39:08 GMT 2024 - Last Modified: Mon Oct 30 19:20:20 GMT 2023 - 3.7K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/io/BaseEncodingBenchmark.java
OutputStream encodingStream = encoding.encoding.encodingStream(target); encodingStream.write(encodingInputs[i & INPUTS_MASK]); encodingStream.close(); tmp += target.getBuffer().length(); } return tmp; } @Benchmark public int decodingStream(int reps) throws IOException { int tmp = 0; byte[] target = new byte[n]; for (int i = 0; i < reps; i++) {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 3.2K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/io/BaseEncodingBenchmark.java
OutputStream encodingStream = encoding.encoding.encodingStream(target); encodingStream.write(encodingInputs[i & INPUTS_MASK]); encodingStream.close(); tmp += target.getBuffer().length(); } return tmp; } @Benchmark public int decodingStream(int reps) throws IOException { int tmp = 0; byte[] target = new byte[n]; for (int i = 0; i < reps; i++) {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 3.2K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/DcerpcHandle.java
if ( this.state == 0 ) { bind(); } byte[] inB = this.transportContext.getBufferCache().getBuffer(); byte[] out = this.transportContext.getBufferCache().getBuffer(); try { NdrBuffer buf = encodeMessage(msg, out); int off = sendFragments(msg, out, buf);
Java - Registered: Sun Apr 21 00:10:10 GMT 2024 - Last Modified: Sun Jun 30 10:11:57 GMT 2019 - 12.9K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
@Override protected void doSend ( Request request ) throws IOException { CommonServerMessageBlock smb = (CommonServerMessageBlock) request; byte[] buffer = this.getContext().getBufferCache().getBuffer(); try { // synchronize around encode and write so that the ordering for SMB1 signing can be maintained synchronized ( this.outLock ) { int n = smb.encode(buffer, 4);
Java - Registered: Sun Apr 21 00:10:10 GMT 2024 - Last Modified: Wed Jan 18 23:47:00 GMT 2023 - 67K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/ndr/NdrBuffer.java
public int getCapacity () { return this.buf.length - this.start; } public int getTailSpace () { return this.buf.length - this.index; } public byte[] getBuffer () { return this.buf; } public int align ( int boundary, byte value ) { int n = align(boundary); int i = n; while ( i > 0 ) {
Java - Registered: Sun Apr 21 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 6.6K bytes - Viewed (0)