final int openBraces = content.length() - content.replace("{", "").length();
            final int closeBraces = content.length() - content.replace("}", "").length();
            assertEquals("Braces should be balanced", openBraces, closeBraces);
        }
    }

    /**
     * Test that InputStream is properly closed even when exception occurs.
     * Verifies try-with-resources cleanup behavior.
     */

                }
                // one extra acquire to keep this open till the stream is released
                return this.handle.acquire();
            }

        }
        log.trace("Pipe already open");
        return this.handle.acquire();
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.SmbPipeHandle#getInput()
     */
    @Override

                                            <la:option value="INFO">INFO</la:option>
                                            <la:option value="DEBUG">DEBUG</la:option>
                                            <la:option value="TRACE">TRACE</la:option>
                                            <la:option value="ALL">ALL</la:option>
                                        </la:select>
                                    </div>

                for (int j = 0; j < 100; j++) {
                    List<DirectoryCacheEntry.FileInfo> children = entry.getChildren();
                    // Just read, don't assert specific counts due to race conditions
                    assertNotNull(children);
                }
            });
            readThreads[i].start();
        }

        // Wait for all threads

        bufferIndex++;
        if (this.wordCount != 0) {
            int n = readParameterWordsWireFormat(buffer, bufferIndex);
            if ((n != this.wordCount * 2) && log.isTraceEnabled()) {
                log.trace("wordCount * 2=" + this.wordCount * 2 + " but readParameterWordsWireFormat returned " + n);
            }
            bufferIndex += this.wordCount * 2;
        }

                        final String msg = buf.toString(Constants.UTF_8);
                        if (StringUtil.isNotBlank(msg)) {
                            if (logger.isTraceEnabled()) {
                                logger.trace(msg);
                            } else if (logger.isDebugEnabled()) {
                                logger.debug(msg);
                            } else if (logger.isWarnEnabled()) {

        assertTrue("Threads did not complete in time", doneLatch.await(5, TimeUnit.SECONDS));

        // All threads should fail with the same IOException (endpoint is blank)
        // But importantly, there should be no race condition errors
        assertEquals(threadCount, failureCount.get());
        assertEquals(0, successCount.get());

        // All exceptions should be about endpoint being blank
        for (Exception e : exceptions) {

    protected boolean ignoreCopyToException = false;
    /** Maximum number of request retries on failure */
    protected int maxRequestRetries = 2;
    /** Whether to trace resource usage for debugging */
    protected boolean traceResourceUsage;
    /** Whether to enforce strict resource lifecycle management */
    protected boolean strictResourceLifecycle;

        log.info("Connection lost, waiting for witness notification before retry");
        
        // Wait briefly for witness notification before retrying
        try {
            Thread.sleep(2000);  // 2 second grace period
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
    
    // Proceed with normal error handling/retry
    super.handleConnectionLoss(error);

        this.skipMaskingForDebugLevel = enable;
        log.info("Skip masking for debug level {}", enable ? "enabled" : "disabled");
    }

    /**
     * Enable or disable stack trace inclusion
     *
     * @param enable true to include stack traces
     */
    public void setIncludeStackTrace(boolean enable) {
        this.includeStackTrace = enable;
    }

    /**