Package org.jboss.dna.common.statistic

Examples of org.jboss.dna.common.statistic.Stopwatch.start()

68
69
70
71
72
73
74
75
76
77
78
        for (int i = 0; i != 3; ++i) {
            super.numberOfConnections = 0;
            Stopwatch sw = new Stopwatch();

            // Get the root ...
            sw.start();
            Node<JcrNodePayload, JcrPropertyPayload> root = cache.findNode(null, path("/"));
            root.getPath();
            root.getPayload(); // forces a load
            sw.stop();
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
        for (int i = 0; i != 3; ++i) {
            super.numberOfConnections = 0;
            Stopwatch sw = new Stopwatch();

            // Get the root ...
            sw.start();
            Node<JcrNodePayload, JcrPropertyPayload> root = cache.findNode(null, path("/"));
            root.getPath();
            root.getPayload(); // forces a load
            sw.stop();
View Full Code Here
110
111
112
113
114
115
116
117
118
119
120
        for (int i = 0; i != 3; ++i) {
            Stopwatch sw = new Stopwatch();
            super.numberOfConnections = 0;

            // Get the root ...
            sw.start();
            Node<JcrNodePayload, JcrPropertyPayload> root = cache.findNode(null, path("/"));
            root.getPath();
            root.getPayload(); // forces a load
            sw.stop();
View Full Code Here
69
70
71
72
73
74
75
76
77
78
79
                         Request request ) throws RepositorySourceException {
        Logger logger = context.getLogger(getClass());
        Stopwatch sw = null;
        if (logger.isTraceEnabled()) {
            sw = new Stopwatch();
            sw.start();
        }

        // Do any commands update/write?
        PathRequestProcessor processor = repository.createRequestProcessor(context, source);
        PathRepositoryTransaction txn = processor.getTransaction();
View Full Code Here
97
98
99
100
101
102
103
104
105
106
107
                         Request request ) throws RepositorySourceException {
        Logger logger = context.getLogger(getClass());
        Stopwatch sw = null;
        if (logger.isTraceEnabled()) {
            sw = new Stopwatch();
            sw.start();
        }
        // Do any commands update/write?
        RepositoryContext repositoryContext = this.source.getRepositoryContext();
        Observer observer = repositoryContext != null ? repositoryContext.getObserver() : null;
        RequestProcessor processor = new MapRequestProcessor(context, this.repository, observer, source.areUpdatesAllowed());
View Full Code Here
96
97
98
99
100
101
102
103
104
105
106
                         Request request ) throws RepositorySourceException {
        Logger logger = context.getLogger(getClass());
        Stopwatch sw = null;
        if (logger.isTraceEnabled()) {
            sw = new Stopwatch();
            sw.start();
        }
        // Do any commands update/write?
        RequestProcessor processor = new MapRequestProcessor(context, this.repository, this.source.getRepositoryContext());

        Lock lock = request.isReadOnly() ? repository.getLock().readLock() : repository.getLock().writeLock();
View Full Code Here
559
560
561
562
563
564
565
566
567
568
569
            // Perform second batch ...
            batch = graph.batch();
            totalNumberCreated += createChildren(batch, initialPath, "secondBranch", 2, numberOfPropertiesPerNode, 2, null);
            Stopwatch sw = new Stopwatch();
            sw.start();
            batch.execute();
            sw.stop();
            System.out.println("     final " + getTotalAndAverageDuration(sw, totalNumberCreated));
            assertThat(totalNumberCreated, is(totalNumber + calculateTotalNumberOfNodesInTree(2, 2, false)));
        }
View Full Code Here
551
552
553
554
555
556
557
558
559
560
561
                   "dnaxml:processingInstructionContent=" + data);
    }

    protected void parse( String relativePathToXmlFile ) throws IOException, SAXException {
        Stopwatch sw = new Stopwatch();
        sw.start();
        InputStream stream = getClass().getClassLoader().getResourceAsStream(relativePathToXmlFile);
        try {
            XMLReader reader = XMLReaderFactory.createXMLReader();
            reader.setContentHandler(handler);
            reader.setErrorHandler(handler);
View Full Code Here
163
164
165
166
167
168
169
170
171
172
173
        request.freeze();
        assertThat(request.hasIncompleteRequests(), is(true));
        CountDownLatch latch = request.getLatch();
        assertThat(latch.getCount(), is(3L));
        Stopwatch sw = new Stopwatch();
        sw.start();
        new Thread(new CountDownRunnable(latch, 100L)).start();
        request.await(); // this blocks until the latch reaches 0
        assertThat(latch.getCount(), is(0L));
        sw.stop();
        assertThat(sw.getTotalDuration().getDurationInMilliseconds().intValue() >= 250, is(true));
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.