Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 19 of 19 for releaseBuffer (2.08 sec)

  1. src/test/java/jcifs/smb/CriticalPerformanceTest.java

                            // Test release performance
                            long releaseStart = System.nanoTime();
                            BufferCache.releaseBuffer(buffer);
                            long releaseEnd = System.nanoTime();
                            totalReleaseTime.addAndGet(releaseEnd - releaseStart);
                            releases.incrementAndGet();
                        }
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 15.3K bytes
    - Viewed (0)
  2. src/test/java/jcifs/internal/smb1/trans/SmbComTransactionResponseTest.java

            response.setBuffer(buffer);
    
            byte[] released = response.releaseBuffer();
            assertSame(buffer, released);
            assertEquals(0x42, released[0]);
            assertEquals(0x43, released[1]);
    
            // After release, getting buffer again should return null
            assertNull(response.releaseBuffer());
        }
    
        @Test
        @DisplayName("Test subCommand getter and setter")
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 13.4K bytes
    - Viewed (0)
  3. docs/smb3-features/05-rdma-smb-direct-design.md

                
                // Notify waiting thread
                request.setResponse(response);
                
            } finally {
                readRegion.close();
                bufferManager.releaseBuffer(readBuffer);
            }
        }
        
        private void handleRdmaWrite(Smb2WriteRequest request) throws IOException {
            // Register write data buffer for RDMA
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  4. src/main/java/jcifs/internal/smb1/trans/SmbComTransactionResponse.java

        public void setBuffer(final byte[] buffer) {
            this.txn_buf = buffer;
        }
    
        /**
         * Releases and returns the transaction buffer
         * @return the txn_buf
         */
        public byte[] releaseBuffer() {
            final byte[] buf = this.txn_buf;
            this.txn_buf = null;
            return buf;
        }
    
        /**
         * Gets the transaction subcommand
         * @return the subCommand
         */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 12.3K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb2/rdma/RdmaBufferManager.java

         *
         * For direct buffers, we rely on GC. A more sophisticated
         * implementation could maintain a buffer pool here as well.
         *
         * @param buffer buffer to release
         */
        public void releaseBuffer(ByteBuffer buffer) {
            // For direct buffers, we rely on GC
            // Could implement a more sophisticated buffer pool here
        }
    
        /**
         * Clean up all pooled regions
         *
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  6. src/test/java/jcifs/internal/smb2/rdma/RdmaBufferManagerTest.java

        @Test
        public void testReleaseBuffer() {
            ByteBuffer buffer = bufferManager.allocateBuffer(1024);
    
            // Release should not throw exception
            assertDoesNotThrow(() -> bufferManager.releaseBuffer(buffer));
        }
    
        @Test
        public void testStatistics() throws Exception {
            long initialAllocated = bufferManager.getTotalAllocated();
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/dcerpc/DcerpcHandle.java

                    off += stub_frag_len;
                }
    
                buf = new NdrBuffer(stub, 0);
                msg.decode(buf);
            } finally {
                jcifs.smb1.smb1.BufferCache.releaseBuffer(stub);
            }
    
            de = msg.getResult();
            if (de != null) {
                throw de;
            }
        }
    
        /**
         * Sets the security provider for this handle
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb1/trans/SmbComTransaction.java

        public void setBuffer(final byte[] buffer) {
            this.txn_buf = buffer;
        }
    
        /**
         * Releases and returns the transaction buffer
         * @return the txn_buf
         */
        public byte[] releaseBuffer() {
            final byte[] buf = this.txn_buf;
            this.txn_buf = null;
            return buf;
        }
    
        /**
         * Gets the transaction subcommand
         * @return the subCommand
         */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 17.3K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb1/smb1/SmbTransport.java

                                response_map.remove(req);
                            }
                        }
                    } finally {
                        BufferCache.releaseBuffer(req.txn_buf);
                        BufferCache.releaseBuffer(resp.txn_buf);
                    }
    
                } else {
                    response.command = request.command;
                    super.sendrecv(request, response, RESPONSE_TIMEOUT);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 31.8K bytes
    - Viewed (0)
Back to top