chetan

List of Isolators

Side note: all available resource metrics are documented here:

https://github.com/apache/mesos/blob/037a346a205ad7bdba99d771855f8caeea835d4a/include/mesos/mesos.proto#L1015

Filesystem Isolators

These are used for isolating files on disk from both the host system as well as other running tasks.

daniel-j-h

# Instrument binaries, pgo data to /data/pgo, serial make is important to not confuse the pgo generator
env CXXFLAGS='-march=native -fprofile-dir=/data/pgo -fprofile-generate=/data/pgo' cmake .. -DCMAKE_BUILD_TYPE=Release                   
make -j 1

# Run instrumented program, generate and write pgo data
./runIt

# Use profile data and feed into gcc, correct for threading counter noise, serial make is important to not confuse the pgo generator
env CXXFLAGS='-march=native -fprofile-dir=/data/pgo -fprofile-use=/data/pgo -fprofile-correction' cmake .. -DCMAKE_BUILD_TYPE=Release                   
make -j 1

nputnam

...
 NiftySecurityHandlers niftySecurityHandlers = new NiftySecurityHandlers() {

                    @Override
                    public ChannelHandler getAuthenticationHandler() {
                        return noOpHandler;
                    }

                    @Override
                    public ChannelHandler getEncryptionHandler() {

johnynek

/**
 * To get started:
 * git clone https://github.com/twitter/algebird
 * cd algebird
 * ./sbt algebird-core/console
 */

/**
 * Let's get some data. Here is Alice in Wonderland, line by line
 */

jkreps

Producer

Setup
bin/kafka-topics.sh --zookeeper esv4-hcl197.grid.linkedin.com:2181 --create --topic test-rep-one --partitions 6 --replication-factor 1
bin/kafka-topics.sh --zookeeper esv4-hcl197.grid.linkedin.com:2181 --create --topic test --partitions 6 --replication-factor 3

Single thread, no replication

bin/kafka-run-class.sh org.apache.kafka.clients.tools.ProducerPerformance test7 50000000 100 -1 acks=1 bootstrap.servers=esv4-hcl198.grid.linkedin.com:9092 buffer.memory=67108864 batch.size=8196

fanatoly

package com.yieldmo.rtb.util

class LazyMap[A,B](delegate: Map[A,() => B]) extends scala.collection.immutable.Map[A,B]{
  def get(key: A): Option[B] = delegate.get(key).map{ _() }
  def iterator: Iterator[(A,B)] = delegate.iterator.map{ pair => (pair._1, pair._2()) }
  def +[B1 >:B](kv: (A, B1)): Map[A, B1] = new LazyMap[A,B1](delegate + (kv._1 -> (() => kv._2)))
  def -(key: A): Map[A, B] = new LazyMap[A,B](delegate - key)
}

bigs

var lambda = function (str) {
  var res = str.match(/^\s*([a-z]+(?:\s+[a-z]+)*)\s*\->\s*(.+?)\s*$/);
  
  if (!res) {
    throw new Error('Invalid lambda expression');
  }
  
  var args = res[1].replace(/\s{2,}/g, ' ').split(' ')
    , body = 'return ' + res[2] + ';';
  

elyzion

//! A simplistic echo server that allows client to exit using the quit command.

#![crate_id = "echo:0.1pre"]
#![feature(phase)]
#[phase(plugin, link)] extern crate log;


use std::io::{Listener, Acceptor, BufferedStream};
use std::io::net::tcp::TcpListener;

bzg

;; Prevent the cursor from blinking
(blink-cursor-mode 0)
;; Don't use messages that you don't read
(setq initial-scratch-message "")
(setq inhibit-startup-message t)
;; Don't let Emacs hurt your ears
(setq visible-bell t)

;; You need to set `inhibit-startup-echo-area-message' from the
;; customization interface:

emaxerrno

class PartialFunctionBuilder[A, B] {
  import scala.collection.immutable.Vector
 
  // Abbreviate to make code fit
  type PF = PartialFunction[A, B]
 
  private var pfsOption: Option[Vector[PF]] = Some(Vector.empty)
 
  private def mapPfs[C](f: Vector[PF] ⇒ (Option[Vector[PF]], C)): C = {
    pfsOption.fold(throw new IllegalStateException("Already built"))(f) match {