diff options
author | Elliot Kroo <kroo@appjet.com> | 2010-03-11 15:21:30 -0800 |
---|---|---|
committer | Elliot Kroo <kroo@appjet.com> | 2010-03-11 15:21:30 -0800 |
commit | 98e2821b38a775737e42a2479a6bc65107210859 (patch) | |
tree | 55939a8ba1dce4f4e48ebb13b658061d62bf1b9a /trunk/infrastructure/net.appjet.ajstdlib/timer.scala | |
parent | c1894c8e0a52f4e3d2f89fa92f0066bbf0fcf1b1 (diff) | |
download | etherpad-98e2821b38a775737e42a2479a6bc65107210859.tar.gz etherpad-98e2821b38a775737e42a2479a6bc65107210859.tar.xz etherpad-98e2821b38a775737e42a2479a6bc65107210859.zip |
reorganizing the first level of folders (trunk/branch folders are not the git way :)
Diffstat (limited to 'trunk/infrastructure/net.appjet.ajstdlib/timer.scala')
-rw-r--r-- | trunk/infrastructure/net.appjet.ajstdlib/timer.scala | 85 |
1 files changed, 0 insertions, 85 deletions
diff --git a/trunk/infrastructure/net.appjet.ajstdlib/timer.scala b/trunk/infrastructure/net.appjet.ajstdlib/timer.scala deleted file mode 100644 index dac8fb6..0000000 --- a/trunk/infrastructure/net.appjet.ajstdlib/timer.scala +++ /dev/null @@ -1,85 +0,0 @@ -/** - * Copyright 2009 Google Inc. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS-IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package net.appjet.ajstdlib; - -import scala.collection.mutable.{HashMap,ListBuffer}; -import java.util.concurrent.locks.ReentrantLock; - -object timer { - - var _timings = new HashMap[String,ListBuffer[double]]; - var _lock = new ReentrantLock; - var _callstack = new ThreadLocal[ListBuffer[String]]; - - def start(opname: String) = { - var _localcallstack = _callstack.get(); - if (_localcallstack == null) { - _callstack.set(new ListBuffer[String]); - _localcallstack = _callstack.get(); - } - _localcallstack += opname; - var _oplabel = _localcallstack.mkString("."); - val startTime: long = System.nanoTime(); - - new { - def done() { - val elapsedTimeMs: double = (System.nanoTime() - startTime) / 1.0e6; - - _lock.lock(); - try { - var times = _timings.getOrElse(_oplabel, new ListBuffer[double]); - /* - if (times.size > 100000) { - times = new ListBuffer[double]; - }*/ - times += elapsedTimeMs; - _timings.put(_oplabel, times); - _localcallstack.remove(_localcallstack.length-1); - } finally { - _lock.unlock(); - } - } - } - } - - def getOpNames(): Array[String] = { - _lock.lock(); - try { - return _timings.keys.toList.toArray; - } finally { - _lock.unlock(); - } - } - - def getStats(opname: String): Array[double] = { - _lock.lock(); - - try { - var times:ListBuffer[double] = _timings(opname); - var total = times.foldRight(0.0)(_ + _); - return Array(times.size, total, (total / times.size)); - } finally { - _lock.unlock(); - } - } - - def reset() { - _lock.lock(); - _timings = new HashMap[String,ListBuffer[double]]; - _lock.unlock(); - } -} |