Examples of increment()


Examples of com.google.appengine.api.memcache.MemcacheService.increment()

        memcache.setNamespace("News");
        headlines = (List<String>) memcache.get("headlines");

        memcache.put("work_done", 0);

        Long workDone = memcache.increment("work_done", 1);

        Stats stats = memcache.getStatistics();
        int ageOfOldestItemMillis = stats.getMaxTimeWithoutAccess();

        memcache.setErrorHandler(new StrictErrorHandler());
View Full Code Here

Examples of com.gs.collections.impl.Counter.increment()

            public void value(T key, Counter value)
            {
                for (int i = 0; i < value.getCount(); i++)
                {
                    objectIntProcedure.value(key, index.getCount());
                    index.increment();
                }
            }
        });
    }
View Full Code Here

Examples of com.mchange.v2.holders.SynchronizedIntHolder.increment()

            "; Failed close count: " + failedCloseCounter.getValue() +
            "; Total processed by this pool: " + totalOpenedCounter.getValue());
          }
      catch (Exception e)
          {
        failedCloseCounter.increment();

        if (Debug.DEBUG && Debug.TRACE == Debug.TRACE_MAX && logger.isLoggable( MLevel.FINER ))
            logger.log( MLevel.FINER, "Failed to destroy PooledConnection: " + resc +
            ". Currently open Connections: " + connectionCounter.getValue() +
            "; Failed close count: " + failedCloseCounter.getValue() +
View Full Code Here

Examples of com.metamx.common.Granularity.increment()

          config.getSchema().getIOConfig().getSegmentOutputPath(),
          segmentGranularity.toPath(timeBucket)
      );
      for (FileStatus fileStatus : FSSpideringIterator.spiderIterable(fs, new Path(bucketOutput))) {
        if (fileStatus.getModificationTime() > mTime) {
          bucketsToRun.add(new Interval(timeBucket, segmentGranularity.increment(timeBucket)));
          break;
        }
      }

      if (bucketsToRun.size() >= maxBuckets) {
View Full Code Here

Examples of com.netflix.curator.framework.recipes.atomic.DistributedAtomicLong.increment()

    public long nextUid(MailboxSession session, Mailbox mailbox) throws MailboxException {
        if (client.isStarted()) {
            DistributedAtomicLong uid = new DistributedAtomicLong(client, pathForMailbox(mailbox), retryPolicy);
            AtomicValue<Long> value = null;
            try {
                uid.increment();
                value = uid.get();
            } catch (Exception e) {
                throw new MailboxException("Exception incrementing UID for session " + session, e);
            } finally {
                if (value != null && value.succeeded()) {
View Full Code Here

Examples of com.netflix.servo.monitor.BasicCounter.increment()

        for (int i = 1; i < 5; ++i) {
            long now = 20000L + i * 60000L;
            long stepBoundary = i * 60000L;
            manualClock.set(now);
            basicCounter.increment(i);
            stepCounter.increment(i);
            gauge.set((long) i);
            List<Metric> metrics = getValue(monitors, manualClock);
            toRateMetricTransform.update(metrics);

View Full Code Here

Examples of com.netflix.servo.monitor.StepCounter.increment()

        for (int i = 1; i < 5; ++i) {
            long now = 20000L + i * 60000L;
            long stepBoundary = i * 60000L;
            manualClock.set(now);
            basicCounter.increment(i);
            stepCounter.increment(i);
            gauge.set((long) i);
            List<Metric> metrics = getValue(monitors, manualClock);
            toRateMetricTransform.update(metrics);

            List<Metric> o = observer.getObservations().get(0);
View Full Code Here

Examples of com.openkm.kea.util.Counter.increment()

        String phrase = it.next();
        Counter counter = (Counter) m_KEAFilter.m_Dictionary.get(phrase);
        if (counter == null) {
          m_KEAFilter.m_Dictionary.put(phrase, new Counter());
        } else {
          counter.increment();
        }
      }
    }
  }
View Full Code Here

Examples of com.orientechnologies.common.types.OModifiableInteger.increment()

        if (change == null)
          result = treeValue;
        else
          result = change.applyTo(treeValue);

        size.increment(result);
        return true;
      }
    });

    for (OSBTreeRidBag.Change change : notAppliedChanges.values()) {
View Full Code Here

Examples of com.orientechnologies.orient.core.version.ORecordVersion.increment()

  }

  public void testUpdateOneSmallRecordVersionIsMinusTwo() throws IOException {
    byte[] smallRecord = new byte[] { 1, 2, 3, 4, 5, 6, 7, 8, 9, 0 };
    ORecordVersion recordVersion = OVersionFactory.instance().createVersion();
    recordVersion.increment();
    recordVersion.increment();

    OPhysicalPosition physicalPosition = paginatedCluster.createRecord(smallRecord, recordVersion, (byte) 1);
    Assert.assertEquals(physicalPosition.clusterPosition, OClusterPositionFactory.INSTANCE.valueOf(0));
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.