ioe = (TransportException) root;
            root = ioe.getCause();
        }
        if (root instanceof InterruptedException) {
            ioe = new InterruptedIOException(root.getMessage());
            ioe.initCause(root);
        }
        return ioe;
    }

    /**
     * Closes this input stream and releases any system resources associated with the stream.
     *

                    } catch (RuntimeException e) {
                        if (log.isDebugEnabled()) {
                            log.debug("Failed to add lease context for {}, continuing without leases: {}", uncPath, e.getMessage());
                        }
                    }
                }

                // Enable persistent handles if available, with fallback for compatibility

      if (!isPermitted(exception)) {
        String message =
            "Exception "
                + exception.getClass().getSimpleName()
                + " was thrown; expected "
                + getMessage();
        throw new AssertionError(message, exception);
      }
    }

    @GwtIncompatible @J2ktIncompatible private static final long serialVersionUID = 0;
  }

     *
     * @param key the message key
     * @param defaultValue the default value to return if message not found
     * @return localized message or default value
     */
    public static String getMessage(final String key, final String defaultValue) {
        final Locale locale = LaRequestUtil.getOptionalRequest().map(HttpServletRequest::getLocale).orElse(Locale.ROOT);

            IllegalArgumentException exception =
                    assertThrows(IllegalArgumentException.class, () -> request.writeBytesWireFormat(smallBuffer, 0));

            assertTrue(exception.getMessage().contains("Data exceeds buffer size"));
        }

        @Test
        @DisplayName("Should write data at correct offset in buffer")
        void testDataOffsetCalculation() {

            if (this.negotiated == null) {
                connect(this.transportContext.getConfig().getResponseTimeout());
            }
        } catch (final IOException ioe) {
            throw new SmbException(ioe.getMessage(), ioe);
        }
        final SmbNegotiationResponse r = this.negotiated;
        if (r == null) {
            throw new SmbException("Connection did not complete, failed to get negotiation response");
        }

                    return;
                }
                try {
                    transport.wait();
                } catch (final InterruptedException ie) {
                    throw new SmbException(ie.getMessage(), ie);
                }
            }
            connectionState = 1; // trying ...

            try {
                transport.connect();

                /*

                            try {
                                return "<<< " + new String(bytes, 0, len, encoding);
                            } catch (final Exception e) {
                                return "<<< <" + e.getMessage() + ">";
                            }
                        });
                        dfos.write(bytes, 0, length);
                    }
                    length = bis.read(bytes);
                }

        SMBProtocolDecodingException exception =
                assertThrows(SMBProtocolDecodingException.class, () -> response.readBytesWireFormat(buffer, 0));
        assertEquals("Expected structureSize = 9", exception.getMessage());
    }

    @Test
    @DisplayName("Should handle empty notification list")
    void testEmptyNotificationList() throws Exception {
        // Given
        byte[] buffer = new byte[256];

                    }
                    this.style = sb.toString();
                }
            } catch (final IOException ioe) {
                throw new ServletException(ioe.getMessage());
            }

            this.enableBasic = Config.getBoolean(p, "jcifs.http.enableBasic", false);
            this.insecureBasic = Config.getBoolean(p, "jcifs.http.insecureBasic", false);