void getUserDomain_fallbackToSuper() {
            Kerb5Authenticator auth = new Kerb5Authenticator(null, "DOM", "u", "p");
            // No explicit realm or subject -> returns super.getUserDomain()
            assertEquals("DOM", auth.getUserDomain());
        }
    }

    @Test
    @DisplayName("Protected setSubject: updates subject used by getters")

			if err := tx.Session(&gorm.Session{FullSaveAssociations: true}).Save(owner).Error; err != nil {
				return err
			}
			if err := tx.Preload("Token").First(&newOwner, owner.ID).Error; err != nil {
				return err
			}
			return nil
		}); err != nil {
			return nil, err
		}
		return &newOwner, nil
	}

	owner := TokenOwner{
		Name:  "user",
		Token: Token{Content: "token"},
	}

    Map<K, V> map = new LinkedHashMap<>();
    for (Entry<K, V> entry : entries) {
      map.put(entry.getKey(), entry.getValue());
    }
    getMap().putAll(map);
  }

  /**
   * Returns the {@link Method} instance for {@link #testPutAll_nullKeyUnsupported()} so that tests
   * can suppress it with {@code FeatureSpecificTestSuiteBuilder.suppressing()} until <a

            this.dis.skip(mask - shift);
        }
    }

    /**
     * Returns the number of bytes available to read.
     * @return the number of available bytes
     * @throws IOException if an I/O error occurs
     */
    public int available() throws IOException {
        return this.dis.available();
    }

    /**
     * Reads bytes into the specified array.

        assertNotNull(decrypted);
        // With dummy data, we can't verify the content, just that it decrypts without error
        // and returns a result of the expected size.
        assertEquals(data.length - 24, decrypted.length);
    }

    /**
     * Test decrypt with an unsupported encryption type.
     */
    @Test

        } else if (!pkgs.contains("jcifs.smb1")) {
            System.setProperty("java.protocol.handler.pkgs", pkgs + "|jcifs.smb1");
        }
    }

    @Test
    @DisplayName("getDefaultPort returns SMB default port 445")
    void testGetDefaultPort() {
        // Act
        int port = handler.getDefaultPort();

        // Assert
        assertEquals(445, port);

func isVeeamSOSAPIObject(object string) bool {
	switch object {
	case systemXMLObject, capacityXMLObject:
		return true
	default:
		return false
	}
}

// isVeeamClient - returns true if the request is from Veeam client.
func isVeeamClient(ctx context.Context) bool {
	ri := logger.GetReqInfo(ctx)
	return ri != nil && strings.Contains(ri.UserAgent, veeamAgentSubstr)
}

                return mock(HttpURLConnection.class);
            }
        };

        // Create mock HTTPS handler
        URLStreamHandler httpsHandler = new URLStreamHandler() {
            @Override
            protected URLConnection openConnection(URL u) throws IOException {
                return mock(HttpURLConnection.class);
            }
        };

  abstract void setCountCheckReturnValue(E element, int count);

  /**
   * Call the {@code setCount()} method under test, but do not check its return value. Callers
   * should use this method over {@link #setCountCheckReturnValue(Object, int)} when they expect
   * {@code setCount()} to throw an exception, as checking the return value could produce an

      this.value = checkNotNull(value, "value");
    }

    @Override
    public R getRowKey() {
      return row;
    }

    @Override
    public C getColumnKey() {
      return column;
    }

    @Override
    public V getValue() {
      return value;
    }

    void merge(V value, BinaryOperator<V> mergeFunction) {
      checkNotNull(value, "value");