import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
@Nonnull
@ReturnsMutableCopy
private static ICommonsList <Node> _getAllReferences (@Nullable final Node aUserMessage)
{
  final ICommonsList <Node> aDSRefs = new CommonsArrayList <> ();
  Node aNext = XMLHelper.getFirstChildElementOfName (aUserMessage, "Envelope");
  aNext = XMLHelper.getFirstChildElementOfName (aNext, "Header");
  aNext = XMLHelper.getFirstChildElementOfName (aNext, CAS4.WSSE_NS, "Security");
  aNext = XMLHelper.getFirstChildElementOfName (aNext, CAS4.DS_NS, "Signature");
  aNext = XMLHelper.getFirstChildElementOfName (aNext, CAS4.DS_NS, "SignedInfo");
  if (aNext != null)
  {
    new ChildElementIterator (aNext).findAll (XMLHelper.filterElementWithNamespaceAndLocalName (CAS4.DS_NS,
                                                                                                "Reference"),
                                              aDSRefs::add);
  }
  return aDSRefs;
}
 

import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
/**
 * Stop the indexer work queue immediately.
 *
 * @return The list of all remaining objects in the queue. Never
 *         <code>null</code>.
 */
@Nonnull
@ReturnsMutableCopy
public ICommonsList <IIndexerWorkItem> stop ()
{
  // don't take any more actions
  m_aImmediateCollector.stopQueuingNewObjects ();

  // Get all remaining objects and save them for late reuse
  final ICommonsList <IIndexerWorkItem> aRemainingItems = m_aImmediateCollector.drainQueue ();

  // Shutdown the thread pool afterwards
  ExecutorServiceHelper.shutdownAndWaitUntilAllTasksAreFinished (m_aSenderThreadPool);

  return aRemainingItems;
}
 

import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
@Nonnull
@ReturnsMutableCopy
public ICommonsList <IReIndexWorkItem> getAndRemoveAllEntries (@Nonnull final Predicate <? super IReIndexWorkItem> aFilter)
{
  ValueEnforcer.notNull (aFilter, "Filter");
  final ICommonsList <IReIndexWorkItem> aCopyOfAll = getAll ();
  final ICommonsList <IReIndexWorkItem> ret = new CommonsArrayList <> ();
  m_aRWLock.writeLocked ( () -> {
    // Operate on a copy for removal!
    for (final IReIndexWorkItem aWorkItem : aCopyOfAll)
      if (aFilter.test (aWorkItem))
      {
        ret.add (aWorkItem);
        internalDeleteItem (aWorkItem.getID ());
      }
  });
  return ret;
}
 

import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
/**
 * Get all {@link PDStoredDocument} objects matching the provided query. This
 * is a specialization of {@link #searchAllDocuments(Query, Consumer)}.
 *
 * @param aQuery
 *        The query to be executed. May not be <code>null</code>.
 * @return A non-<code>null</code> but maybe empty list of matching documents
 * @see #searchAllDocuments(Query, Consumer)
 */
@Nonnull
@ReturnsMutableCopy
public ICommonsList <PDStoredDocument> getAllDocuments (@Nonnull final Query aQuery)
{
  final ICommonsList <PDStoredDocument> aTargetList = new CommonsArrayList <> ();
  try
  {
    searchAllDocuments (aQuery, aTargetList::add);
  }
  catch (final IOException ex)
  {
    s_aLogger.error ("Error searching for documents with query " + aQuery, ex);
  }
  return aTargetList;
}
 

import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
@Nonnull
@ReturnsMutableCopy
public ICommonsSortedSet <IParticipantIdentifier> getAllContainedParticipantIDs ()
{
  final ICommonsSortedSet <IParticipantIdentifier> aTargetSet = new CommonsTreeSet <> ();
  final Query aQuery = PDQueryManager.andNotDeleted (new MatchAllDocsQuery ());
  try
  {
    final ObjIntConsumer <Document> aConsumer = (aDoc,
                                                 nDocID) -> aTargetSet.add (PDField.PARTICIPANT_ID.getDocValue (aDoc));
    final Collector aCollector = new AllDocumentsCollector (m_aLucene, aConsumer);
    searchAtomic (aQuery, aCollector);
  }
  catch (final IOException ex)
  {
    s_aLogger.error ("Error searching for documents with query " + aQuery, ex);
  }
  return aTargetSet;
}
 

import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
/**
 * Get an array that contains all elements, except for the passed elements.
 *
 * @param <ELEMENTTYPE>
 *        Array element type
 * @param aArray
 *        The source array. May be <code>null</code>.
 * @param aElementsToRemove
 *        The elements to skip.
 * @return <code>null</code> if the passed array is <code>null</code>. The
 *         original array, if no elements need to be skipped. A non-
 *         <code>null</code> copy of the array without the passed elements
 *         otherwise.
 */
@Nullable
@ReturnsMutableCopy
@SafeVarargs
public static <ELEMENTTYPE> ELEMENTTYPE [] getAllExcept (@Nullable final ELEMENTTYPE [] aArray,
                                                         @Nullable final ELEMENTTYPE... aElementsToRemove)
{
  if (isEmpty (aArray) || isEmpty (aElementsToRemove))
    return aArray;

  final ELEMENTTYPE [] tmp = getCopy (aArray);
  int nDst = 0;
  for (int nSrc = 0; nSrc < tmp.length; ++nSrc)
    if (!contains (aElementsToRemove, tmp[nSrc]))
      tmp[nDst++] = tmp[nSrc];
  return getCopy (tmp, 0, nDst);
}
 

import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
/**
 * Return the upper triangular factor
 *
 * @return R
 */
@Nonnull
@ReturnsMutableCopy
public Matrix getR ()
{
  final Matrix aNewMatrix = new Matrix (m_nCols, m_nCols);
  final double [] [] aNewArray = aNewMatrix.internalGetArray ();
  for (int nRow = 0; nRow < m_nCols; nRow++)
  {
    final double [] aDstRow = aNewArray[nRow];
    for (int j = 0; j < m_nCols; j++)
    {
      if (nRow < j)
        aDstRow[j] = m_aQR[nRow][j];
      else
        if (nRow == j)
          aDstRow[j] = m_aRdiag[nRow];
        else
          aDstRow[j] = 0.0;
    }
  }
  return aNewMatrix;
}
 

import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
/**
 * Get a submatrix.
 *
 * @param aRows
 *        Array of row indices.
 * @param aCols
 *        Array of column indices.
 * @return Matrix(aRows(:),aCols(:))
 * @exception ArrayIndexOutOfBoundsException
 *            Submatrix indices
 */
@Nonnull
@ReturnsMutableCopy
public Matrix getMatrix (@Nonnull final int [] aRows, @Nonnull final int [] aCols)
{
  final Matrix aNewMatrix = new Matrix (aRows.length, aCols.length);
  final double [] [] aNewArray = aNewMatrix.internalGetArray ();
  for (int nRow = 0; nRow < aRows.length; nRow++)
  {
    final int nRowIndex = aRows[nRow];
    final double [] aSrcRow = m_aData[nRowIndex];
    final double [] aDstRow = aNewArray[nRow];
    for (int nCol = 0; nCol < aCols.length; nCol++)
      aDstRow[nCol] = aSrcRow[aCols[nCol]];
  }
  return aNewMatrix;
}
 

import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
/**
 * Get a new array that combines the passed two arrays, maintaining the order.
 *
 * @param aHeadArray
 *        The first array. May be <code>null</code>.
 * @param aTailArray
 *        The second array. May be <code>null</code>.
 * @return <code>null</code> if both array parameters are <code>null</code> -
 *         a non-<code>null</code> array with all elements in the correct
 *         order otherwise.
 */
@Nonnull
@ReturnsMutableCopy
public static boolean [] getConcatenated (@Nullable final boolean [] aHeadArray,
                                          @Nullable final boolean... aTailArray)
{
  // If first array is invalid, simply
  if (isEmpty (aHeadArray))
    return getCopy (aTailArray);
  if (isEmpty (aTailArray))
    return getCopy (aHeadArray);

  // Start concatenating
  final boolean [] ret = new boolean [aHeadArray.length + aTailArray.length];
  System.arraycopy (aHeadArray, 0, ret, 0, aHeadArray.length);
  System.arraycopy (aTailArray, 0, ret, aHeadArray.length, aTailArray.length);
  return ret;
}
 

import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
/**
 * Decode the string with the default encoding (US-ASCII is the preferred
 * one).
 *
 * @param sEncoded
 *        The encoded string.
 * @param nOptions
 *        Decoding options.
 * @return <code>null</code> if decoding failed.
 */
@Nullable
@ReturnsMutableCopy
public static byte [] safeDecode (@Nullable final String sEncoded, final int nOptions)
{
  if (sEncoded != null)
    try
    {
      return decode (sEncoded, nOptions);
    }
    catch (final Exception ex)
    {
      // fall through
    }
  return null;
}
 

import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
/**
 * Delete all duplicate items that were created before the provided time.
 *
 * @param aRefDT
 *        The reference date time to compare to. May not be <code>null</code>.
 * @return A non-<code>null</code> list of all evicted message IDs.
 */
@Nonnull
@ReturnsMutableCopy
public ICommonsList <String> evictAllItemsBefore (@Nonnull final LocalDateTime aRefDT)
{
  final ICommonsList <String> aEvictItems = getAllMapped (x -> x.getDateTime ().isBefore (aRefDT),
                                                          IAS4DuplicateItem::getMessageID);
  if (aEvictItems.isNotEmpty ())
    m_aRWLock.writeLocked ( () -> {
      for (final String sItemID : aEvictItems)
        internalDeleteItem (sItemID);
    });
  return aEvictItems;
}
 

import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
/**
 * Try to match the Attachment Id. Otherwise, add all Attachments.
 *
 * @param sID
 *        Attachment ID to search
 * @return Never <code>null</code>.
 */
@Nonnull
@ReturnsMutableCopy
private ICommonsList <Attachment> _getAttachmentsToAdd (@Nullable final String sID)
{
  if (m_aAttachmentMap.containsKey (sID))
    return new CommonsArrayList <> (m_aAttachmentMap.get (sID));

  return new CommonsArrayList <> (m_aAttachmentMap.values ());
}
 

import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
@Nonnull
@ReturnsMutableCopy
public static Ebms3Description createEbms3Description (@Nonnull final Locale aLocale, @Nonnull final String sText)
{
  ValueEnforcer.notNull (aLocale, "Locale");
  ValueEnforcer.notNull (sText, "Text");

  final Ebms3Description aDesc = new Ebms3Description ();
  aDesc.setLang (aLocale.getLanguage ());
  aDesc.setValue (sText);
  return aDesc;
}
 

import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
/**
 * Get all attributes of the passed element as a map with a lowercase
 * attribute name.
 *
 * @param aElement
 *        The source element to extract the attributes from. May not be
 *        <code>null</code>.
 * @return A new map and never <code>null</code> but maybe empty.
 */
@Nonnull
@ReturnsMutableCopy
public static StringMap getAllAttrsWithLowercaseName (@Nonnull final IMicroElement aElement)
{
  ValueEnforcer.notNull (aElement, "Element");

  final StringMap ret = new StringMap ();
  aElement.forAllAttributes ( (ns, name, value) -> ret.putIn (name.toLowerCase (Locale.US), value));
  return ret;
}
 

import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
@Nonnull
@ReturnsMutableCopy
public static StringMap getAllAttrsWithLowercaseNameWithRequired (@Nonnull final IMicroElement aElement,
                                                                  @Nonnull final String... aRequiredAttributes)
{
  final StringMap aAttributes = getAllAttrsWithLowercaseName (aElement);
  for (final String sRequiredAttribute : aRequiredAttributes)
    if (!aAttributes.containsKey (sRequiredAttribute))
      throw new IllegalStateException (aElement.getTagName () +
                                       " is missing required attribute '" +
                                       sRequiredAttribute +
                                       "'");
  return aAttributes;
}
 

import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
/**
 * @param aNode
 *        Start node. May not be <code>null</code>.
 * @param sNodeName
 *        The element name to be queried relative to the start node.
 * @param sNodeKeyName
 *        The attribute name of the key.
 * @param sNodeValueName
 *        The attribute name of the value.
 * @return The non-<code>null</code> {@link Map}. @ In case a node is missing
 *         a key or value attribute.
 */
@Nonnull
@ReturnsMutableCopy
public static ICommonsOrderedMap <String, String> mapAttributeNodes (@Nonnull final IMicroElement aNode,
                                                                     @Nonnull final String sNodeName,
                                                                     @Nonnull final String sNodeKeyName,
                                                                     @Nonnull final String sNodeValueName)
{
  ValueEnforcer.notNull (aNode, "Node");
  ValueEnforcer.notNull (sNodeName, "NodeName");
  ValueEnforcer.notNull (sNodeKeyName, "NodeKeyName");
  ValueEnforcer.notNull (sNodeValueName, "NodeValueName");

  final ICommonsOrderedMap <String, String> ret = new CommonsLinkedHashMap <> ();
  int nIndex = 0;
  for (final IMicroElement eChild : aNode.getAllChildElements (sNodeName))
  {
    final String sName = eChild.getAttributeValue (sNodeKeyName);
    if (sName == null)
      throw new IllegalStateException (sNodeName +
                                       "[" +
                                       nIndex +
                                       "] does not have key attribute '" +
                                       sNodeKeyName +
                                       "'");

    final String sValue = eChild.getAttributeValue (sNodeValueName);
    if (sValue == null)
      throw new IllegalStateException (sNodeName +
                                       "[" +
                                       nIndex +
                                       "] does not have value attribute '" +
                                       sNodeValueName +
                                       "'");

    ret.put (sName, sValue);
    ++nIndex;
  }
  return ret;
}
 

import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
@Nonnull
@ReturnsMutableCopy
private ICommonsOrderedMap <String, PModePayloadProfile> _generatePModePayloadProfile ()
{
  final PModePayloadProfile aPModePayloadProfile = new PModePayloadProfile ("name",
                                                                            new MimeType (EMimeContentType.EXAMPLE,
                                                                                          "example"),
                                                                            "xsdfilename",
                                                                            20001,
                                                                            EMandatory.MANDATORY);
  final ICommonsOrderedMap <String, PModePayloadProfile> aPModePayloadProfiles = new CommonsLinkedHashMap<> ();
  aPModePayloadProfiles.put (aPModePayloadProfile.getName (), aPModePayloadProfile);
  return aPModePayloadProfiles;
}
 

import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
@Nonnull
@ReturnsMutableCopy
private ICommonsOrderedMap <String, PModeProperty> _generatePModeProperties ()
{
  final PModeProperty aPModeProperty = new PModeProperty ("name",
                                                          "description",
                                                          PModeProperty.DATA_TYPE_STRING,
                                                          EMandatory.MANDATORY);
  final ICommonsOrderedMap <String, PModeProperty> aPModeProperties = new CommonsLinkedHashMap<> ();
  aPModeProperties.put (aPModeProperty.getName (), aPModeProperty);
  return aPModeProperties;
}
 

import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
/**
 * @return A list of all registered receiver handlers. Never <code>null</code>
 *         but maybe empty.
 */
@Nonnull
@ReturnsMutableCopy
public static ICommonsList <IAS4ServletPullRequestProcessorSPI> getAllProcessors ()
{
  return s_aRWLock.readLocked ( () -> s_aProcessors.getClone ());
}
 

import com.helger.commons.annotation.ReturnsMutableCopy; //导入依赖的package包/类
/**
 * @return A list of all registered receiver handlers. Never <code>null</code>
 *         but maybe empty.
 */
@Nonnull
@ReturnsMutableCopy
public static ICommonsList <IAS4ServletMessageProcessorSPI> getAllProcessors ()
{
  return s_aRWLock.readLocked ( () -> s_aProcessors.getClone ());
}