stevenschlansker

import java.nio.ByteBuffer;
import java.nio.ByteOrder;
import java.nio.FloatBuffer;
import java.util.Random;

import org.openjdk.jmh.annotations.GenerateMicroBenchmark;
import org.openjdk.jmh.annotations.State;

import io.airlift.slice.Slice;

stevenschlansker

public class ForgettingExecutor
{
    private ForgettingExecutor() { }

    public static <T> Future<T> submit(ExecutorService executor, Callable<T> callable)
    {
        return executor.submit(new ForgettingCallable<>(new AtomicReference<>(callable)));
    }

    private static class ForgettingCallable<T> implements Callable<T>

stevenschlansker

import java.util.Collections;
import java.util.UUID;

import com.google.inject.AbstractModule;
import com.google.inject.Guice;
import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.ProvisionException;

import org.junit.Test;

stevenschlansker

http://www.hootjudkins.com/furniture/dining/chairs/solid-oak-zahara-side-chair
http://www.hootjudkins.com/furniture/dining/chairs/solid-cherry-fergus-county-side-chair-coffee-finish
http://www.hootjudkins.com/furniture/dining/chairs/solid-alder-bistro-side-chair-antique-cherry-finish
http://www.hootjudkins.com/furniture/dining/chairs/solid-parawood-san-remo-side-chair-cinnamon-and-espresso-finish

stevenschlansker

import org.apache.http.client.params.ClientPNames;
import org.apache.http.params.HttpParams;

@SuppressWarnings("deprecation")
class AllowRedirectHttpParams implements HttpParams
{
    private final HttpParams delegate;

    AllowRedirectHttpParams(HttpParams delegate)
    {

stevenschlansker

diff --git a/graph/pull.go b/graph/pull.go
index 716a27c..29eb232 100644
--- a/graph/pull.go
+++ b/graph/pull.go
@@ -158,7 +158,7 @@ func (s *TagStore) CmdPull(job *engine.Job) engine.Status {
                }
        }
 
-       if err = s.pullRepository(r, job.Stdout, localName, remoteName, tag, sf, job.GetenvBool("parallel"), mirrors); err != nil {
+       if err = s.pullRepository(r, job.Stdout, localName, remoteName, tag, sf, job.GetenvBool("parallel"), s.mirrors); err != nil {

stevenschlansker

#!/bin/bash
# Shamelessly stolen from https://gist.github.com/eduardocardoso/82a629882ddb02ab3677

set -o errexit

echo "Removing exited docker containers..."
docker ps -a -f status=exited -q | xargs -r docker rm -v

echo "Removing untagged images..."
docker images --no-trunc | grep "<none>" | awk '{print $3}' | xargs -r docker rmi

stevenschlansker

import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.sql.Array;
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Collection;

import com.google.common.base.Functions;

stevenschlansker

socket(PF_NETLINK, SOCK_RAW, 0)         = 78
bind(78, {sa_family=AF_NETLINK, pid=0, groups=00000000}, 12) = 0
getsockname(78, {sa_family=AF_NETLINK, pid=-1328743, groups=00000000}, [12]) = 0
sendto(78, "\24\0\0\0\26\0\1\3O\206\4V\0\0\0\0\0\0\0\0", 20, 0, {sa_family=AF_NETLINK, pid=0, groups=00000000}, 12) = 20
poll([{fd=78, events=POLLIN}], 1, 1000) = 1 ([{fd=78, revents=POLLIN}])
recvmsg(78, {msg_name(12)={sa_family=AF_NETLINK, pid=0, groups=00000000}, msg_iov(1)=[{"L\0\0\0\24\0\2\0O\206\4V\231\271\353\377\2\10\200\376\1\0\0\0\10\0\1\0\177\0\0\1"..., 4096}], msg_controllen=0, msg_flags=0}, 0) = 156
poll([{fd=78, events=POLLIN}], 1, 1000) = 1 ([{fd=78, revents=POLLIN}])
recvmsg(78, {msg_name(12)={sa_family=AF_NETLINK, pid=0, groups=00000000}, msg_iov(1)=[{"H\0\0\0\24\0\2\0O\206\4V\231\271\353\377\n\200\200\376\1\0\0\0\24\0\1\0\0\0\0\0"..., 4096}], msg_controllen=0, msg_flags=0}, 0) = 144
poll([{fd=78, events=POLLIN}], 1, 1000) = 1 ([{fd=78, revents=POLLIN}])
recvmsg(78, {msg_name(12)={sa_family=AF_NETLINK, pi

stevenschlansker

2015-10-05T17:36:34.160Z WARN <> [qtp671959170-3326] org.eclipse.jetty.server.HttpChannel - //mesos-slave2-qa-sf.qasql.opentable.com:31564/announcement
org.jboss.resteasy.spi.UnhandledException: RESTEASY003770: Response is committed, can't handle exception
at org.jboss.resteasy.core.SynchronousDispatcher.writeException(SynchronousDispatcher.java:164) ~[discovery-server-0.11.3-jar-with-dependencies.jar:0.11.3]
at org.jboss.resteasy.core.SynchronousDispatcher.writeResponse(SynchronousDispatcher.java:452) ~[discovery-server-0.11.3-jar-with-dependencies.jar:0.11.3]
at org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:396) ~[discovery-server-0.11.3-jar-with-dependencies.jar:0.11.3]
at org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:199) ~[discovery-server-0.11.3-jar-with-dependencies.jar:0.11.3]
at org.jboss.resteasy.plugins.server.servlet.ServletContainerDispatcher.service(ServletContainerDispatcher.java:221) ~[discovery-server-0.11.3-jar-with-dependen