List of resetStats() Examples

Examples of resetStats()

Examples of com.sleepycat.je.rep.stream.Protocol.resetStats()

    }


    void resetStats() {
        final Protocol protocol = outputThread.protocol;
        if (protocol != null) {
            protocol.resetStats();
        }
    }


    void setSyncLatch(CountDownLatch syncLatch) {
        this.syncLatch = syncLatch;

View Full Code Here

Examples of com.sleepycat.je.rep.stream.Protocol.resetStats()

    }


    void resetStats() {
        final Protocol protocol = outputThread.protocol;
        if (protocol != null) {
            protocol.resetStats();
        }
    }


    /**
     * Returns the channel between this Feeder and its Replica.

View Full Code Here

Examples of com.sun.appserv.management.j2ee.WebServiceEndpoint.resetStats()

            WebServiceMgr wsm = AMXUtil.getWebServiceMgr();
            Set endpointSet = wsm.getWebServiceEndpointSet(webServiceKey, server);
            if (!endpointSet.isEmpty()){  // should be only one.
                Iterator it = endpointSet.iterator();
                WebServiceEndpoint endpoint = (WebServiceEndpoint) it.next();
                endpoint.resetStats();
            }
        }catch(Exception ex){
            GuiUtil.handleException(handlerCtx, ex);
        }
    }

View Full Code Here

Examples of org.apache.activemq.network.NetworkBridge.resetStats()

                    public ObjectName getMbeanObjectName() {
                        return next.getMbeanObjectName();
                    }


                    public void resetStats(){
                        next.resetStats();
                    }
                };
            }
        };
        nc.setDiscoveryAgent(da);

View Full Code Here

Examples of org.infinispan.util.CountingRpcManager.resetStats()

      final CountingRpcManager rpcManager = replaceRpcManager(cache);


      cache(0).put(key, "v0");


      tm.begin();
      rpcManager.resetStats();
      cache.getAdvancedCache().withFlags(Flag.IGNORE_RETURN_VALUES).put(key, "v1");
      AssertJUnit.assertEquals("Wrong number of gets after put.", 0, rpcManager.clusterGet);


      AssertJUnit.assertEquals("Wrong value read.", "v1", cache.get(key));
      AssertJUnit.assertEquals("Wrong number of gets after read.", 0, rpcManager.clusterGet);

View Full Code Here

Examples of org.infinispan.util.CountingRpcManager.resetStats()

      if (initialized) {
         cache(0).put(key, "v1");
      }


      tm.begin();
      rpcManager.resetStats();
      AssertJUnit.assertEquals("Wrong value read.", initialized ? "v1" : null, cache.get(key));
      AssertJUnit.assertEquals("Wrong number of gets after read.", 1, rpcManager.clusterGet);


      AssertJUnit.assertEquals("Wrong put return value.", initialized ? "v1" : null, cache.put(key, "v2"));
      AssertJUnit.assertEquals("Wrong number of gets after put.", 1, rpcManager.clusterGet);

View Full Code Here

Examples of voldemort.store.slop.SlopStorageEngine.resetStats()

                                + succeededByNode.get(nodeId) + " - Attempted - "
                                + attemptedByNode.get(nodeId));
                    outstanding.put(nodeId,
                                    attemptedByNode.get(nodeId) - succeededByNode.get(nodeId));
                }
                slopStorageEngine.resetStats(outstanding);
                logger.info("Completed streaming slop pusher job which started at " + startTime);
            } else {
                for(int nodeId: succeededByNode.keySet()) {
                    logger.info("Slops to node " + nodeId + " - Succeeded - "
                                + succeededByNode.get(nodeId) + " - Attempted - "

View Full Code Here

Examples of voldemort.store.slop.SlopStorageEngine.resetStats()

            Map<Integer, Long> outstanding = Maps.newHashMapWithExpectedSize(cluster.getNumberOfNodes());
            for(int nodeId: succeededByNode.keySet()) {
                outstanding.put(nodeId, attemptedByNode.get(nodeId) - succeededByNode.get(nodeId));
            }


            slopStorageEngine.resetStats(outstanding);


        } catch(Exception e) {
            logger.error(e, e);
        } finally {
            try {

View Full Code Here

TOP

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.