Skip to content

Instantly share code, notes, and snippets.

View shikhar's full-sized avatar
🐒

Shikhar Bhushan shikhar

🐒
View GitHub Profile
commit 51e6c792da5e56723faa78d032ce610b3c3e266c
Author: shikhar <shikhar@schmizz.net>
Date: Mon Jun 2 09:57:48 2014 +0530
missing client param
diff --git a/elasticsearch/src/jepsen/system/elasticsearch.clj b/elasticsearch/src/jepsen/system/elasticsearch.clj
index 2eb53d6..107ddc0 100644
--- a/elasticsearch/src/jepsen/system/elasticsearch.clj
+++ b/elasticsearch/src/jepsen/system/elasticsearch.clj
commit 32e36d85a9f5654dcf5f306088c825d24fb0d770
Author: shikhar <shikhar@schmizz.net>
Date: Fri Jun 6 23:58:35 2014 +0530
eskka testing
diff --git a/elasticsearch/src/jepsen/system/elasticsearch.clj b/elasticsearch/src/jepsen/system/elasticsearch.clj
index 107ddc0..ecf1494 100644
--- a/elasticsearch/src/jepsen/system/elasticsearch.clj
+++ b/elasticsearch/src/jepsen/system/elasticsearch.clj
WARN  jepsen.core - Nemesis crashed evaluating {:time 31911993765, :process :nemesis, :type :info, :f :start}
java.util.concurrent.ExecutionException: java.lang.RuntimeException:

	at java.util.concurrent.FutureTask.report(FutureTask.java:122)
	at java.util.concurrent.FutureTask.get(FutureTask.java:192)
	at clojure.core$deref_future.invoke(core.clj:2180)
	at clojure.core$future_call$reify__6320.deref(core.clj:6417)
	at clojure.core$deref.invoke(core.clj:2200)
	at clojure.core$map$fn__4245.invoke(core.clj:2559)
2014-11-05 18:37:58
Full thread dump Java HotSpot(TM) 64-Bit Server VM (25.5-b02 mixed mode):
"Attach Listener" #168 daemon prio=9 os_prio=0 tid=0x00007f7a5c004000 nid=0x4029 waiting on condition [0x0000000000000000]
java.lang.Thread.State: RUNNABLE
"ForkJoinPool-3-worker-29" #167 daemon prio=5 os_prio=0 tid=0x00007f7950002800 nid=0x3fac waiting on condition [0x00007f79db21f000]
java.lang.Thread.State: TIMED_WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for <0x00000005e4dda6b0> (a scala.concurrent.forkjoin.ForkJoinPool)
2015-05-19 12:47:30
Full thread dump Java HotSpot(TM) 64-Bit Server VM (25.25-b02 mixed mode):
"Attach Listener" #112 daemon prio=9 os_prio=0 tid=0x00007f3414001000 nid=0x3392 waiting on condition [0x0000000000000000]
java.lang.Thread.State: RUNNABLE
"elasticsearch[search44-es1][generic][T#9]" #111 daemon prio=5 os_prio=0 tid=0x00007f3374088800 nid=0x325f waiting on condition [0x00007f33630ef000]
java.lang.Thread.State: TIMED_WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for <0x000000052c37e4b0> (a java.util.concurrent.SynchronousQueue$TransferStack)
import java.io.IOException;
import java.util.SortedSet;
import java.util.concurrent.ConcurrentSkipListSet;
import java.util.concurrent.atomic.AtomicLong;
import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
public class CheckpointTracker {
package com.fivepumpkins.common;
import android.content.res.Resources;
public class ResourceByName {
private final String pkg;
private final Resources res;
public ResourceByName(String pkg, Resources res) {
object TenPinBowling {
/**
* Returns the score for each frame of a 10-pin bowling game.
*
* @param rolls
* List of pins knocked down by each roll
* @return
* List of scores for each frame
*/
import java.time.Clock;
import java.util.concurrent.atomic.AtomicLong;
public class ClockedMonotonicCounter {
// sign_bit_unused | 42_bits_epochTimeMs | 21_bit_counter
private static final int TIME_SHIFT = 21;
private static final int COUNTER_MASK = (1 << TIME_SHIFT) - 1;
All benchmarking was done on a Macbook Pro with a 2.4GHz Intel Core i7, SSD, and 16GB RAM using luceneutil against WIKI_MEDIUM_10M.
baseline = trunk
patched = https://github.com/shikhar/lucene-solr
ser = as is
par = parallelism hacked in to IndexSearcher constructor with a ForkJoinPool <https://gist.github.com/anonymous/7048089>
# ser vs ser