} catch (Exception e) { // sneaky checked exception
            AssertionError error =
                new AssertionFailedError("Serialization failed on return value of " + factory);
            error.initCause(e.getCause());
            throw error;
          } catch (AssertionFailedError e) {
            AssertionError error =
                new AssertionFailedError(

            }
        }

        return "0x" + Hexdump.toHexString(errcode, 8);
    }

    private int error;
    private Throwable rootCause;

    DcerpcException(int error) {
        super(getMessageByDcerpcError(error));
        this.error = error;
    }
    public DcerpcException(String msg) {
        super(msg);
    }
    public DcerpcException(String msg, Throwable rootCause) {

   * reader each time it is called.
   *
   * <p>The caller is responsible for ensuring that the returned reader is closed.
   *
   * @throws IOException if an I/O error occurs while opening the reader
   */
  public abstract Reader openStream() throws IOException;

  /**
   * Opens a new {@link BufferedReader} for reading from this source. This method returns a new,

    Object newValue = new Object();
    valueRef.set(newValue);
    assertSame(newValue, cache.getUnchecked(new Object()));
  }

  public void testGetUnchecked_error() {
    final Error cause = new Error();
    final AtomicReference<Object> valueRef = new AtomicReference<>();
    LoadingCache<Object, Object> cache =
        new AbstractLoadingCache<Object, Object>() {
          @Override

    static final int[] WINERR_CODES = {
        ERROR_SUCCESS,
        ERROR_ACCESS_DENIED,
        ERROR_REQ_NOT_ACCEP,
        ERROR_BAD_PIPE,
        ERROR_PIPE_BUSY,
        ERROR_NO_DATA,
        ERROR_PIPE_NOT_CONNECTED,
        ERROR_MORE_DATA,
        ERROR_NO_BROWSER_SERVERS_FOUND,
    };

    static final String[] WINERR_MESSAGES = {
        "The operation completed successfully.",

    public static final int DCERPC_FAULT_CONTEXT_MISMATCH = 0x1C00001A;
    public static final int DCERPC_FAULT_OP_RNG_ERROR     = 0x1C010002;
    public static final int DCERPC_FAULT_UNK_IF           = 0x1C010003;
    public static final int DCERPC_FAULT_PROTO_ERROR      = 0x1c01000b;

    static final int[] DCERPC_FAULT_CODES = {
        DCERPC_FAULT_OTHER, 
        DCERPC_FAULT_ACCESS_DENIED,

      assertThat(actualStats.mean()).isWithin(ALLOWED_ERROR).of(expectedStats.mean());
      assertThat(actualStats.populationVariance()).isWithin(0.0).of(0.0);
      assertThat(actualStats.min()).isWithin(ALLOWED_ERROR).of(expectedStats.min());
      assertThat(actualStats.max()).isWithin(ALLOWED_ERROR).of(expectedStats.max());
    } else {
      assertThat(actualStats.mean()).isWithin(ALLOWED_ERROR).of(expectedStats.mean());

    listener.assertException(EXCEPTION);
  }

  public void testFutureGetThrowsWrappedError() throws Exception {
    Error error = new Error();
    inputFuture.setException(error);
    // Verify that get throws an ExecutionException, caused by an Error, when
    // the callback is called.
    listener.assertException(error);
  }

  public void testAddListenerAfterCallback() throws Throwable {
    inputFuture.set(VALID_INPUT_DATA);

    boolean errorNotThrown = false;
    try {
      SerializableTester.reserializeAndAssert(orig);
      errorNotThrown = true;
    } catch (AssertionFailedError error) {
      // expected
      assertContains("must be Object#equals to", error.getMessage());
    }
    assertFalse(errorNotThrown);
  }

  public void testClassWhichIsAlwaysEqualButHasDifferentHashcodes() {

                log.error("Multiple preauth negotiate contexts");
                return false;
            }
        }

        if ( !foundPreauth ) {
            log.error("Missing preauth negotiate context");
            return false;
        }
        if ( !foundEnc && ( caps & Smb2Constants.SMB2_GLOBAL_CAP_ENCRYPTION ) != 0 ) {
            log.error("Missing encryption negotiate context");