final List<String> docIds = new ArrayList<>();
        for (final SearchHit hit : hits) {
            final Map<String, Object> source = hit.getSourceAsMap();
            events.add(new LogNotificationEvent(((Number) source.get("timestamp")).longValue(), (String) source.get("level"),
                    (String) source.get("loggerName"), (String) source.get("message"), (String) source.get("throwable")));

        this.checkoutDir = checkoutDir;
    }

    TaskProvider<LoggedExec> bwcTask(String name, Action<LoggedExec> configuration) {
        return createRunBwcGradleTask(project, name, configuration);
    }

    private TaskProvider<LoggedExec> createRunBwcGradleTask(Project project, String name, Action<LoggedExec> configAction) {
        return project.getTasks().register(name, LoggedExec.class, loggedExec -> {

    /**
     * Internal: for testing only
     *
     * @param dr the DFS referral data to process
     * @param reqPath the requested path to resolve
     * @return resolved unc path
     */
    String handleDFSReferral(DfsReferralData dr, String reqPath);

   * ArrayBasedUnicodeEscaper instances.
   *
   * @param replacements a map of characters to their escaped representations
   */
  public static ArrayBasedEscaperMap create(Map<Character, String> replacements) {
    return new ArrayBasedEscaperMap(createReplacementArray(replacements));
  }

  // The underlying replacement array we can share between multiple escaper
  // instances.

    private SmbFileHandleImpl handle;
    private SmbPipeOutputStream output;
    private SmbPipeInputStream input;

    private final String uncPath;

    private SmbTreeHandleImpl treeHandle;

    private final int sharing = SmbConstants.DEFAULT_SHARING;

    /**
     * @param pipe
     */
    public SmbPipeHandleImpl(final SmbNamedPipe pipe) {
        this.pipe = pipe;

import (
	"context"
	"fmt"
	"net/http"
	"strings"
	"time"

	"github.com/minio/madmin-go/v3"
	"github.com/minio/minio/internal/disk"
	"github.com/minio/minio/internal/net"
	c "github.com/shirou/gopsutil/v3/cpu"
	"github.com/shirou/gopsutil/v3/load"
)

type collectMetricsOpts struct {
	hosts map[string]struct{}
	disks map[string]struct{}
	jobID string
	depID string
}

}

type UserWithPermissionControl struct {
	ID    uint
	Name  string `gorm:"-"`
	Name2 string `gorm:"->"`
	Name3 string `gorm:"<-"`
	Name4 string `gorm:"<-:create"`
	Name5 string `gorm:"<-:update"`
	Name6 string `gorm:"<-:create,update"`
	Name7 string `gorm:"->:false;<-:create,update"`
	Name8 string `gorm:"->;-:migration"`
}

func TestParseFieldWithPermission(t *testing.T) {

    // Lease configuration properties
    public static final String USE_LEASES = "jcifs.smb.client.useLeases";
    public static final String LEASE_TIMEOUT = "jcifs.smb.client.leaseTimeout";
    public static final String MAX_LEASES = "jcifs.smb.client.maxLeases";
    public static final String LEASE_VERSION = "jcifs.smb.client.leaseVersion";
    
    public boolean isUseLeases() {

     * @return the processed document map after applying all ingesters
     */
    protected Map<String, Object> ingest(final AccessResult<String> accessResult, final Map<String, Object> map) {
        if (ingestFactory == null) {
            return map;
        }
        Map<String, Object> target = map;
        for (final Ingester ingester : ingestFactory.getIngesters()) {
            try {

        @DisplayName("getName should return resource name")
        void testGetName() throws CIFSException {
            // Given
            String expectedName = "test.txt";
            when(mockResource.getName()).thenReturn(expectedName);

            // When
            String name = mockResource.getName();

            // Then
            assertEquals(expectedName, name, "Should return correct name");
        }