}
			}

			// Any concurrency less than '4' just stick to '4' concurrent
			// operations for now to begin with.
			if concurrency < 4 {
				concurrency = 4
			}

			// if GOMAXPROCS is set to a lower value then choose to use
			// concurrency == GOMAXPROCS instead.
			if runtime.GOMAXPROCS(0) < concurrency {
				concurrency = runtime.GOMAXPROCS(0)
			}
		}

		throughputHighestGet := uint64(0)

  ├─ MaxLengthExceededException
  └─ ChildUrlsException
ExtractException (checked)          # Extraction failures
  └─ UnsupportedExtractException
```

### Thread-Local Storage

```java
// Set (in CrawlerThread)
CrawlingParameterUtil.setCrawlerContext(context);
CrawlingParameterUtil.setUrlQueue(urlQueue);

// Get (anywhere in same thread)
CrawlerContext ctx = CrawlingParameterUtil.getCrawlerContext();

            }
        }

        try {
            // Create SmbFile with cached attributes
            SmbFile file = new SmbFile(filePath, context);
            // Note: We would need to add a method to SmbFile to set cached attributes
            // For now, just return the file object
            return file;
        } catch (Exception e) {
            log.warn("Failed to create SmbFile for {}: {}", filePath, e.getMessage());

        assertThrows(PACDecodingException.class, () -> new KerberosApRequest(seq, new KerberosKey[0]));

        // Verify apOptions is set correctly in a minimal sequence without ticket
        KerberosApRequest req = new KerberosApRequest(buildMinimalApReqSeq(ap), null);
        assertEquals(ap, req.getApOptions());
        assertNull(req.getTicket());
    }

            SmbComNtCancel cancel = constructor.newInstance(mockConfig, testMid);

            // Then
            assertNotNull(cancel);
            assertEquals(testMid, cancel.getMid());

            // Verify command is set correctly
            Field commandField = ServerMessageBlock.class.getDeclaredField("command");
            commandField.setAccessible(true);
            assertEquals(SMB_COM_NT_CANCEL, commandField.getByte(cancel));
        }

        }

        @Test
        void shouldReturnNullWhenInetAddressAndCalledNameIsAlreadySmbServerName() throws UnknownHostException {
            when(mockInetAddress.getHostName()).thenReturn("192.168.1.1"); // This will set calledName to SMBSERVER_NAME
            UniAddress uniAddress = new UniAddress(mockInetAddress);
            uniAddress.firstCalledName(); // Initialize calledName to SMBSERVER_NAME

                parser.setProperty(XMLConstants.ACCESS_EXTERNAL_SCHEMA, StringUtil.EMPTY);
            } catch (final Exception e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Failed to set a property.", e);
                }
            }
            // parse a content
            parser.parse(is, handler);

            return handler.getDataMap();
        } catch (final Exception e) {

```
MINIO_ROOT_USER_FILE=/vault/secrets/my_access_key
MINIO_ROOT_PASSWORD_FILE=/vault/secrets/my_secret_key
```

### Retrieving Container ID

	return target.id
}

// Name - returns the Name of the target.
func (target *RedisTarget) Name() string {
	return target.ID().String()
}

// Store returns any underlying store if set.
func (target *RedisTarget) Store() event.TargetStore {
	return target.store
}

// IsActive - Return true if target is up and active
func (target *RedisTarget) IsActive() (bool, error) {

                0L, // Previous session ID (0 for binding)
                bindingHash // Security buffer contains the binding information
        );

        // Set the session ID of the existing session
        request.setSessionId(getSessionId());

        // CRITICAL: Set the binding flag per MS-SMB2
        request.setSessionBinding(true);

        // The actual transport send would need proper integration