ReplicatedCount:                  st.ReplicatedCount,
			Failed:                           st.Failed,
			FailStats:                        st.FailStats,
		}
		if s.Failed.ErrCounts == nil {
			s.Failed.ErrCounts = make(map[string]int)
			maps.Copy(s.Failed.ErrCounts, st.Failed.ErrCounts)
		}
		c.Stats[arn] = &s
	}
	return c
}

    }

    /**
     * Adds a filter to the processing pipeline.
     * After adding a filter, the filter chain is recreated to include the new filter.
     *
     * @param filter the filter to add to the processing pipeline
     */
    public void addFilter(final Filter filter) {
        filterList.add(filter);
        createFilterChain();
    }

    /**

        } catch (final Exception e) {
            throw new StorageException("Failed to delete " + objectName, e);
        }
    }

    /**
     * Retrieves a list of files and directories from the storage system.
     *
     * @param prefix the path prefix to list objects under
     * @return list of file and directory information maps
     */

        final RelatedQuery relatedQuery = getRelatedQuery(body).map(entity -> {
            try {
                relatedQueryService.store(entity);
            } catch (final Exception e) {
                logger.warn("Failed to process a request.", e);
                throwValidationErrorApi(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e)));
            }
            return entity;

            } catch (final CIFSException e) {
                log.error("Failed to create singleton JCIFS context", e);
            }
        }
        return INSTANCE;
    }

    /**
     * This static method registers the SMB URL protocol handler which is
     * required to use SMB URLs with the <code>java.net.URL</code> class. If this
     * method is not called before attempting to create an SMB URL with the

                    elevateWordService.exportCsv(writer);
                } catch (final Exception e) {
                    logger.warn("Failed to process a request.", e);
                    throwValidationErrorApi(messages -> messages.addErrorsFailedToDownloadElevateFile(GLOBAL));
                }
                try (InputStream in = Files.newInputStream(tempFile)) {

        CIFSException expectedException = new CIFSException("Watch operation failed");
        when(watchHandle.watch()).thenThrow(expectedException);

        // Execute and verify
        CIFSException thrown = assertThrows(CIFSException.class, () -> {
            watchHandle.watch();
        });

        assertEquals("Watch operation failed", thrown.getMessage());
        verify(watchHandle, times(1)).watch();
    }

        super(config, SMB2_CHANGE_NOTIFY);
        this.outputBufferLength = config.getNotifyBufferSize();
        this.fileId = fileId;
    }

    /**
     * Set the notification flags
     *
     * @param notifyFlags
     *            the notifyFlags to set
     */
    public void setNotifyFlags(final int notifyFlags) {
        this.notifyFlags = notifyFlags;
    }

        // Default constructor
    }

    /** URL filter for searching failure URLs. */
    //@Maxbytelength(maxbytelength = 1000)
    public String url;

    /** Minimum error count filter for searching failure URLs. */
    //@IntRange(min = 0, max = 2147483647)
    public String errorCountMin;

    /** Maximum error count filter for searching failure URLs. */
    //@IntRange(min = 0, max = 2147483647)

	err := obj.MakeBucket(context.Background(), bucket, MakeBucketOptions{})
	if err != nil {
		// Failed to create newbucket, abort.
		t.Fatalf("%s : %s", instanceType, err.Error())
	}
	// Initiate Multipart Upload on the above created bucket.
	res, err := obj.NewMultipartUpload(context.Background(), bucket, object, opts)
	if err != nil {
		// Failed to create NewMultipartUpload, abort.
		t.Fatalf("%s : %s", instanceType, err.Error())
	}