/*
(non-Javadoc)

@see
io.joynr.messaging.bounceproxy.controller.directory.BounceProxyDirectory
#getAssignableBounceProxies()
431010
@Override
    public List<BounceProxyRecord> getAssignableBounceProxies() {
        return directory.values()
                        .stream()
                        .filter(Objects::nonNull)
                        .filter(r -> r.getStatus().isAssignable())
                        .collect(Collectors.toList());
    }
23857
public JsDestinationAddress getProxyHandlerDestAddr() {
        if (TraceComponent.isAnyTracingEnabled()
            && tc.isEntryEnabled()) {
            SibTr.entry(tc, "getProxyHandlerDestAddr");
            SibTr.exit(tc, "getProxyHandlerDestAddr", _proxyHandlerDestAddr);
        }
        return _proxyHandlerDestAddr;
    }
857161
function isActionAllowedInSignalingState(action, type, signalingState) {
  return {
    offer: {
      setLocalDescription: ['stable', 'have-local-offer'],
      setRemoteDescription: ['stable', 'have-remote-offer']
    },
    answer: {
      setLocalDescription: ['have-remote-offer', 'have-local-pranswer'],
      setRemoteDescription: ['have-local-offer', 'have-remote-pranswer']
    }
  }[type][action].indexOf(signalingState) !== -1;
}
14542
public Observable<ServiceResponse<List<String>>> listDomainsWithServiceResponseAsync() {
        if (this.client.endpoint() == null) {
            throw new IllegalArgumentException("Parameter this.client.endpoint() is required and cannot be null.");
        }
        String parameterizedHost = Joiner.on(", ").join("{Endpoint}", this.client.endpoint());
        return service.listDomains(this.client.acceptLanguage(), parameterizedHost, this.client.userAgent())
            .flatMap(new Func1<Response<ResponseBody>, Observable<ServiceResponse<List<String>>>>() {
                @Override
                public Observable<ServiceResponse<List<String>>> call(Response<ResponseBody> response) {
                    try {
                        ServiceResponse<List<String>> clientResponse = listDomainsDelegate(response);
                        return Observable.just(clientResponse);
                    } catch (Throwable t) {
                        return Observable.error(t);
                    }
                }
            });
    }
335842
public ArrayList<Transition> possibleNextStates(Automaton source) {
        ArrayList<Transition> r = possibleTransitions.get(source);
        if (r == null) {
            throw new UnsupportedOperationException(
                    "Not transitions registered from " + source.getName()
                    + ", automaton " + this.getName());
        }
        ArrayList<Transition> activatedTransitions = new ArrayList<Transition>();
        for (Transition t : r) {
            if (t.evaluate()) {
                activatedTransitions.add(t);
            }
        }
        ;
        return activatedTransitions;

    }
52640
private void resolveProxyKeyUsage() {

    boolean[] keyUsages = proxyCredential.getCertificate().getKeyUsage();

    if (keyUsages != null) {
      int index = 0;

      for (boolean key : keyUsages) {

        if (key)
          proxyKeyUsageList.add(keyUsagesValues[index]);
        index++;

      }
    }

  }
1173477
@Override
    public byte[] getSigningKey () throws SmbException {
        /*
         * The kerberos session key is not accessible via the JGSS API. IBM and
         * Oracle both implement a similar API to make an ExtendedGSSContext
         * available. That API is accessed via reflection to make this independent
         * of the runtime JRE
         */
        if ( EXT_GSS_CONTEXT_CLASS == null || INQUIRE_SEC_CONTEXT == null || INQUIRE_TYPE_SESSION_KEY == null ) {
            throw new SmbException("ExtendedGSSContext support not available from JRE");
        }
        else if ( EXT_GSS_CONTEXT_CLASS.isAssignableFrom(this.gssContext.getClass()) ) {
            try {
                Key k = (Key) INQUIRE_SEC_CONTEXT.invoke(this.gssContext, new Object[] {
                    INQUIRE_TYPE_SESSION_KEY
                });
                return k.getEncoded();
            }
            catch (
                IllegalAccessException |
                IllegalArgumentException |
                InvocationTargetException ex ) {
                throw new SmbException("Failed to query Kerberos session key from ExtendedGSSContext", ex);
            }
        }
        throw new SmbException("ExtendedGSSContext is not implemented by GSSContext");
    }
1085106
@Override
    public boolean isOverrideOfQOSByProducerAllowed()
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "isOverrideOfQOSByProducerAllowed");

        ExtendedBoolean aliasIsProducerQOSOverrideEnabled = _definition.isOverrideOfQOSByProducerAllowed();
        boolean isProducerQOSOverrideEnabled = false;

        // A reliability of NONE signals use target value.
        if (aliasIsProducerQOSOverrideEnabled.equals(ExtendedBoolean.NONE))
        {
            isProducerQOSOverrideEnabled = getTarget().isOverrideOfQOSByProducerAllowed();
        }
        else if (aliasIsProducerQOSOverrideEnabled.equals(ExtendedBoolean.FALSE))
        {
            isProducerQOSOverrideEnabled = false;
        }
        else
        {
            isProducerQOSOverrideEnabled = true;
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "isOverrideOfQOSByProducerAllowed",
                       Boolean.valueOf(isProducerQOSOverrideEnabled));

        return isProducerQOSOverrideEnabled;
    }
946161
@Builder(builderClassName = "ProxiedFileSystemFromKeytab", builderMethodName = "fromKeytab")
  private static FileSystem getProxiedFileSystemUsingKeytab(@NonNull final String userNameToProxyAs,
      final String superUserName, final Path superUserKeytabLocation, final URI fsURI, final Configuration conf,
      FileSystem referenceFS) throws IOException, ExecutionException {
    Preconditions.checkNotNull(userNameToProxyAs, "Must provide a user name to proxy as.");
    Preconditions.checkNotNull(superUserName, "Must provide a super user name.");
    Preconditions.checkNotNull(superUserKeytabLocation, "Must provide a keytab location.");
    URI actualURI = resolveUri(fsURI, conf, referenceFS);
    Configuration actualConfiguration = resolveConfiguration(conf, referenceFS);

    return USER_NAME_TO_FILESYSTEM_CACHE.get(getFileSystemKey(actualURI, userNameToProxyAs, referenceFS),
        new CreateProxiedFileSystemFromKeytab(userNameToProxyAs, superUserName, superUserKeytabLocation, actualURI,
            actualConfiguration, referenceFS));
  }
596322
protected void passivateProxy( Object pProperties )
    {
        if ( pProperties == null )
        {
            return;
        }
        @SuppressWarnings( "unchecked" )
        final List<String> properties = (List<String>) pProperties;
        for ( Iterator<String> iter = properties.iterator(); iter.hasNext(); )
        {
            final String key = iter.next();
            final String value = iter.next();
            setProperty( null, key, value );
        }
    }
186610
@Override
    public ProxyTuple randomProxy(){
        synchronized (this.proxys){
            if (this.proxys.size() == 0) {
                return null;
            }
            Map.Entry<String,Integer> entity = this.proxys.entrySet().stream().collect(Collectors.toList()).get(random.nextInt(proxys.size()));
            return new ProxyTuple(entity.getKey(), entity.getValue());
        }
    }
903258
@Override
    public List<String> listEndpoints() {
        Collection<PauseableComponent> pauseableComponents = pauseableComponentController.getPauseableComponents();
        ArrayList<String> endpoints = new ArrayList<String>();
        // get the name of each endpoint
        for (PauseableComponent pauseableComponent : pauseableComponents) {
            endpoints.add(pauseableComponent.getName());
        }
        return endpoints;
    }
748113
public com.google.api.ads.adwords.axis.v201809.rm.UserIdentifier[] getUserIdentifiers() {
        return userIdentifiers;
    }
965304
public List<ProxyBranch> createProxyBranches(List<? extends URI> targets) {
		ArrayList<ProxyBranch> list = new ArrayList<ProxyBranch>();
		for(URI target: targets)
		{
			if(target == null) {
				throw new NullPointerException("URI can't be null");
			}
			if(!JainSipUtils.checkScheme(target.toString())) {
				throw new IllegalArgumentException("Scheme " + target.getScheme() + " is not supported");
			}
			if(logger.isDebugEnabled()) {
				logger.debug("createProxyBranches with proxyTimerService=" + proxyTimerService);
			}
			
			ProxyBranchImpl branch = new ProxyBranchImpl(target, this);
			branch.setRecordRoute(recordRoutingEnabled);
			branch.setRecurse(recurse);
			list.add(branch);
			this.proxyBranches.put(target, branch);
		}
		return list;
	}
582850
public Observable<ServiceResponse<Page<ApplicationGatewaySslPredefinedPolicyInner>>> listAvailableSslPredefinedPoliciesWithServiceResponseAsync() {
        return listAvailableSslPredefinedPoliciesSinglePageAsync()
            .concatMap(new Func1<ServiceResponse<Page<ApplicationGatewaySslPredefinedPolicyInner>>, Observable<ServiceResponse<Page<ApplicationGatewaySslPredefinedPolicyInner>>>>() {
                @Override
                public Observable<ServiceResponse<Page<ApplicationGatewaySslPredefinedPolicyInner>>> call(ServiceResponse<Page<ApplicationGatewaySslPredefinedPolicyInner>> page) {
                    String nextPageLink = page.body().nextPageLink();
                    if (nextPageLink == null) {
                        return Observable.just(page);
                    }
                    return Observable.just(page).concatWith(listAvailableSslPredefinedPoliciesNextWithServiceResponseAsync(nextPageLink));
                }
            });
    }
225691
public synchronized ListenableFuture<PagesSpatialIndex> createPagesSpatialIndex()
    {
        activeProbeOperators.retain();

        if (pagesSpatialIndex != null) {
            return immediateFuture(pagesSpatialIndex.get());
        }

        SettableFuture<PagesSpatialIndex> future = SettableFuture.create();
        pagesSpatialIndexFutures.add(future);
        return future;
    }
1176859
List<ConnectRequestProxyListener> getConnectRequestProxyListeners() {
        if (connectRequestProxyListeners == null) {
            return Collections.emptyList();
        }
        return Collections.unmodifiableList(connectRequestProxyListeners);
    }