localGetDistributedStatistics

@param address the logical address
@return The value
328902
public DistributedWorkManagerStatisticsValues localGetDistributedStatistics(Address address)
   {
      if (trace)
         log.tracef("LOCAL_GET_DISTRIBUTED_STATISTICS(%s)", address);

      DistributedWorkManager dwm = workManagerCoordinator.resolveDistributedWorkManager(address);

      if (dwm != null)
      {
         DistributedWorkManagerStatisticsValues values =
            new DistributedWorkManagerStatisticsValues(dwm.getDistributedStatistics().getWorkSuccessful(),
                                                       dwm.getDistributedStatistics().getWorkFailed(),
                                                       dwm.getDistributedStatistics().getDoWorkAccepted(),
                                                       dwm.getDistributedStatistics().getDoWorkRejected(),
                                                       dwm.getDistributedStatistics().getScheduleWorkAccepted(),
                                                       dwm.getDistributedStatistics().getScheduleWorkRejected(),
                                                       dwm.getDistributedStatistics().getStartWorkAccepted(),
                                                       dwm.getDistributedStatistics().getStartWorkRejected());

         return values;
      }

      return null;
   }
290650
Address getLocalAddress()
   {
      if (localAddress == null)
         localAddress = new Address(getId(), getName(), transport != null ? transport.getId() : null);

      return localAddress;
   }
1294584
public long localGetShortRunningFree(Address address)
   {
      if (trace)
         log.tracef("LOCAL_GET_SHORTRUNNING_FREE(%s)", address);

      WorkManager wm = workManagerCoordinator.resolveWorkManager(address);

      if (wm != null)
      {
         StatisticsExecutor executor = wm.getShortRunningThreadPool();
         if (executor != null)
            return executor.getNumberOfFreeThreads();
      }

      return 0L;
   }
1016068
public static Predicate<InetAddress> ofExact(InetAddress address) {
        requireNonNull(address, "address");
        if (address instanceof Inet4Address) {
            return ofCidr(address, 32);
        }
        if (address instanceof Inet6Address) {
            return ofCidr(address, 128);
        }
        throw new IllegalArgumentException("Invalid InetAddress type: " + address.getClass().getName());
    }
1218026
public static PathAddress parseCLIStyleAddress(String address) throws IllegalArgumentException {
        try {
            return PathAddress.parseCLIStyleAddress(address);
        } catch (NoSuchMethodError _nsme) {
            // jboss-as doesn't have parseCLIStyleAddress
            // Ignore the error and use the provided alternative
            return _parseCLIStyleAddress(address);
        }
    }
814129
public long getId(final Address address) throws IOException {
    return retryRPC(() -> mClient
        .getMasterId(GetMasterIdPRequest.newBuilder().setMasterAddress(address.toProto()).build())
        .getMasterId());
  }
87778
@Override
    public Table<AllocationStatus, Integer, Long> getAllocationStatistics() {
        Table<AllocationStatus, Integer, Long> table = HashBasedTable.create();
        table.put(AllocationStatus.HOST, 0, zeroUseCounter.get());
        for (Integer deviceId : configuration.getAvailableDevices()) {
            table.put(AllocationStatus.DEVICE, deviceId, getAllocatedDeviceMemory(deviceId));
        }
        return table;
    }
499409
public Iterable<DUser> queryByAddress1(java.lang.String address1) {
    return queryByField(null, DUserMapper.Field.ADDRESS1.getFieldName(), address1);
  }
1217389
@GET
    @Path("/{localeCode}")
    @Produces(MediaType.APPLICATION_JSON)
    @RequiresPermissions(I18nPermissions.LOCALE_READ)
    public Response getSupportedLocale(@PathParam("localeCode") String localeCode) {
        WebAssertions.assertNotNull(localeCode, "The locale should not be null");
        LocaleRepresentation locale = supportedLocaleFinder.findSupportedLocale(localeCode);
        if (locale != null) {
			return Response.ok(locale).build();
		}
        return Response.status(Response.Status.NOT_FOUND).build();
    }
1277976
public static DestinationAddressAttribute createDestinationAddressAttribute(
			TransportAddress address) {
		DestinationAddressAttribute attribute = new DestinationAddressAttribute();

		attribute.setAddress(address);

		return attribute;
	}
135455
public Optional<CacheStatistics> getStatistics(String cacheName) {

        javax.cache.Cache cache = cacheManager.getCache(cacheName);

        if (cache == null) {
            return Optional.empty();
        }

        if (((CompleteConfiguration) cache.getConfiguration(CompleteConfiguration.class)).isStatisticsEnabled() && cache instanceof ICache) {
            com.hazelcast.cache.CacheStatistics stats = ((ICache) cache).getLocalCacheStatistics();
            CacheStatistics statistics = new CacheStatistics(
                    stats.getCacheHits(),
                    stats.getCacheMisses(),
                    stats.getCacheHitPercentage(),
                    stats.getCacheMissPercentage(),
                    stats.getCacheGets(),
                    stats.getCachePuts(),
                    stats.getCacheRemovals(),
                    stats.getCacheEvictions(),
                    stats.getAverageGetTime(),
                    stats.getAveragePutTime(),
                    stats.getAverageRemoveTime());

            return Optional.of(statistics);
        }

        return Optional.empty();
    }
365968
public static String toAddressString(InetSocketAddress address) {
        if (address == null) {
            return StringUtils.EMPTY;
        } else {
            return toIpString(address) + ":" + address.getPort();
        }
    }
998683
private Address allocateAddress(final Definition definition, final Address maybeAddress) {
    final Address address = maybeAddress != null ?
            maybeAddress : world.addressFactory().uniqueWith(definition.actorName());
    return address;
  }
710622
@Override
	public double getAverage(RandomVariable probabilities) {
		if(isDeterministic()) {
			return valueIfNonStochastic;
		}
		if(size() == 0) {
			return Double.NaN;
		}

		return this.cache().mult(probabilities).getRealizationsStream().sum();
	}
178553
public function getIsoStateByMagentoRegion(DataObject $address)
    {
        $map      = $this->getIsoToMagentoMapping();
        $sIsoCode = null;

        if ($address->getData('country_id') && $address->getData('region_code')) {
            $sIsoCode = $address->getData('country_id') . "-" . $address->getData('region_code');
        }

        if (isset($map[$address->getData('country_id')])) {
            foreach ($map[$address->getData('country_id')] as $isoCode => $mageCode) {
                if ($mageCode === $address->getData('region_code')) {
                    $sIsoCode = $address->getData('country_id') . "-" . $isoCode;
                    break;
                }
            }
        }

        return $sIsoCode;
    }
1046159
public VariableElement getLocalVariable(int index)
    {
        int idx = 0;
        for (VariableElement lv : localVariables)
        {
            if (idx == index)
            {
                return lv;
            }
            if (Typ.isCategory2(lv.asType()))
            {
                idx += 2;
            }
            else
            {
                idx++;
            }
        }
        throw new IllegalArgumentException("local variable at index "+index+" not found");
    }
648888
public byte getByte(final long index)
    {
        if (SHOULD_BOUNDS_CHECK)
        {
            boundsCheck(index);
        }

        return UNSAFE.getByte(null, addressOffset + index);
    }