}

    /** The DCERPC error code */
    private int error;

    DcerpcException(final int error) {
        super(getMessageByDcerpcError(error));
        this.error = error;
    }

    /**
     * Constructs a DcerpcException with the specified message
     *
     * @param msg
     *            the error message
     */
    public DcerpcException(final String msg) {

// be called, so we do not need to Wait() here.
func (w *writerAt) TransferError(err error) {
	_ = w.w.CloseWithError(err)
	_ = w.r.CloseWithError(err)
	w.err = err
}

func (w *writerAt) Close() (err error) {
	switch {
	case len(w.buffer) > 0:
		err = errors.New("some file segments were not flushed from the queue")
		_ = w.w.CloseWithError(err)
	case w.err != nil:
		// No need to close here since both pipes were

	if err := checkListObjsArgs(ctx, bucket, prefix, keyMarker); err != nil {
		return err
	}
	if uploadIDMarker != "" {
		if HasSuffix(keyMarker, SlashSeparator) {
			return InvalidUploadIDKeyCombination{
				UploadIDMarker: uploadIDMarker,
				KeyMarker:      keyMarker,
			}
		}
		_, err := base64.RawURLEncoding.DecodeString(uploadIDMarker)
		if err != nil {

    /**
     * Log level constant for warning messages.
     */
    public static final String WARN = "WARN";

    /**
     * Log level constant for error messages.
     */
    public static final String ERROR = "ERROR";

    /** The log level for this exception, defaults to INFO */
    private String logLevel = INFO;

    /**

    @Test
    @DisplayName("getErrorString for name service error with known code")
    void testNameServiceKnown() {
        String expected = "ERR_NAM_SRVC/FMT_ERR: Format ErrorUnknown error code: 1";
        assertEquals(expected, NbtException.getErrorString(NbtException.ERR_NAM_SRVC, NbtException.FMT_ERR));
    }

    @Test
    @DisplayName("getErrorString for name service error with unknown code")
    void testNameServiceUnknown() {

			}
			r.err = err
			return err
		}

		var err error
		var meta metaCacheEntry
		if meta.name, err = r.mr.ReadString(); err != nil {
			if err == io.EOF {
				err = io.ErrUnexpectedEOF
			}
			r.err = err
			return err
		}
		if meta.metadata, err = r.mr.ReadBytes(metaDataPoolGet()); err != nil {
			if err == io.EOF {
				err = io.ErrUnexpectedEOF
			}
			r.err = err

			continue
		}
		if isErrReadQuorum(pool.Err) || pool.Err == nil {
			errs = append(errs, poolErrs{Err: pool.Err, Index: pool.Index})
		}
	}
	return errs
}

func (z *erasureServerPools) getPoolIdxExistingWithOpts(ctx context.Context, bucket, object string, opts ObjectOptions) (idx int, err error) {
	pinfo, _, err := z.getPoolInfoExistingWithOpts(ctx, bucket, object, opts)
	if err != nil {
		return -1, err
	}

// UnmarshalYAML to parse humanized byte values
func (s *BatchJobSize) UnmarshalYAML(unmarshal func(any) error) error {
	var batchExpireSz string
	err := unmarshal(&batchExpireSz)
	if err != nil {
		return err
	}
	sz, err := humanize.ParseBytes(batchExpireSz)
	if err != nil {
		return err
	}
	*s = BatchJobSize(sz)
	return nil

    }

    @Test
    @DisplayName("Should identify error status codes")
    void testErrorStatusIdentification() {
        // Given
        int[] errorStatuses =
                { NtStatus.NT_STATUS_ACCESS_DENIED, NtStatus.NT_STATUS_OBJECT_NAME_NOT_FOUND, NtStatus.NT_STATUS_SHARING_VIOLATION };

        // When/Then - All error codes should have high bit set (0xC prefix)
        for (int status : errorStatuses) {

 * and localization purposes, as well as detailed error information. The message code
 * can be used by the UI layer to display appropriate error messages to users.
 */
public class SsoMessageException extends FessSystemException {

    private static final long serialVersionUID = 1L;

    /** The message code for internationalized error messages. */
    private final transient VaMessenger<FessMessages> messageCode;