Stop the stopwatch.
This method ends a new timing session, allowing the time to be retrieved.
529530531532533534535536537538539
stopWatch.stop(); sink.publishReadTiming(region, column, stopWatch.getTime()); } else { stopWatch.start(); rs = table.getScanner(scan); stopWatch.stop(); sink.publishReadTiming(region, column, stopWatch.getTime()); } } catch (Exception e) { sink.publishReadFailure(region, column, e); } finally {
620621622623624625626627628629630
// Can't do a get on empty start row so do a Scan of first element if any instead. if(startKey.length > 0) { get = new Get(startKey); stopWatch.start(); table.get(get); stopWatch.stop(); } else { scan = new Scan(); scan.setCaching(1); scan.setMaxResultSize(1L); stopWatch.start();
627628629630631632633634635636637
scan = new Scan(); scan.setCaching(1); scan.setMaxResultSize(1L); stopWatch.start(); table.getScanner(scan); stopWatch.stop(); } this.getSink().publishReadTiming(tableName, serverName, stopWatch.getTime()); } catch (TableNotFoundException tnfe) { // This is ignored because it doesn't imply that the regionserver is dead } catch (TableNotEnabledException tnee) {
267268269270271272273274275276277
ResultScanner scanner = null; try { stopWatch.start(); scanner = table.getScanner(scan); scanner.next(); stopWatch.stop(); sink.publishReadTiming(region, column, stopWatch.getTime()); } catch (Exception e) { sink.publishReadFailure(region, column, e); } finally { if (scanner != null) scanner.close();
280281282283284285286287288289290
Get get = new Get(region.getStartKey()); get.addFamily(column.getName()); try { stopWatch.start(); table.get(get); stopWatch.stop(); sink.publishReadTiming(region, column, stopWatch.getTime()); } catch (Exception e) { sink.publishReadFailure(region, column, e); } }
628629630631632633634635636637638
commentAuthorEmail, commentAuthorURL, change.toString(), null ); sw.stop(); log.debug("Akismet request done in: "+sw); if( isSpam ) {
288289290291292293294295296297298
} serializeToDisk(); } sw.stop(); log.info( "Cross reference scan done in "+sw ); WikiEventUtils.addWikiEventListener(m_engine.getPageManager(), WikiPageEvent.PAGE_DELETED, this); }
332333334335336337338339340341342
in.close(); m_unmutableReferredBy = Collections.unmodifiableMap( m_referredBy ); m_unmutableRefersTo = Collections.unmodifiableMap( m_refersTo ); sw.stop(); log.debug("Read serialized data successfully in "+sw); } finally { if( in != null ) in.close();
366367368369370371372373374375376
out.writeObject( m_refersTo ); out.writeObject( m_referredBy ); out.close(); sw.stop(); log.debug("serialization done - took "+sw); } catch( IOException e ) {
464465466467468469470471472473474
log.debug(" attr: "+key+"="+value); } in.close(); sw.stop(); log.debug("Read serialized data for "+name+" successfully in "+sw); p.setHasMetadata(); } catch( NoSuchAlgorithmException e ) {