adriansr

/* stress test a JUnit test
given your test body:
  feature(a) {
  }
  ...
  feature(c) {
  }
  
wrap it:

adriansr

class LoggingScheduledThreadPoolExecutor(nthreads: Int)
    extends ScheduledThreadPoolExecutor(nthreads) {

    private val log = Logger(LoggerFactory.getLogger(classOf[LoggingScheduledThreadPoolExecutor]))

    override def submit[T](task: Runnable, result: T): java.util.concurrent.Future[T] = {
        val queueTime = System.nanoTime()
        log debug s"Submit task $task"

        super.submit(new Runnable {

adriansr

class LoggingScheduledThreadPoolExecutor(nthreads: Int)
    extends ScheduledThreadPoolExecutor(nthreads) {

    private val log = Logger(LoggerFactory.getLogger(classOf[LoggingScheduledThreadPoolExecutor]))

    class CustomTask[T](runnable: AnyRef, task: RunnableScheduledFuture[T])
        extends RunnableScheduledFuture[T] {

        val creationTime = System.nanoTime()

adriansr

package adriansr.test

import scala.util.control.NonFatal

import akka.actor.{Actor, ActorRef, ActorSystem, InvalidActorNameException, Props}

case class Test(name: String, retries: Int, delay: Long)
case class Create(iter: Long, cfg: Test)
case class Remove(iter: Long, actor: ActorRef, cfg: Test)

adriansr

import sys
# Writes the body of a REST resource
# input is a list of <type> <name> variables, one per line:
# i.e:
# String nwDstAddress
# int nwDstLength
# UUID[] inPorts
# [...]

# helloWorld => HELLO_WORLD

adriansr

package main

/*
#include <stdlib.h>
#include <sys/xattr.h>
*/
import "C"

import (
	"fmt"

adriansr

// +build windows

package main

import (
	"encoding/binary"
	"encoding/hex"
	"fmt"
	"syscall"
	"time"

adriansr

#!/bin/bash

die() {
    echo "error: $@" >&2
    exit 1
}

test "$#" -gt 0 || die "Usage: $0 <package identifier>"
test "$(uname -s)" = "Darwin" || die "Must be run under macOS"
test $(id -u) -eq 0 || die "Must be root"

adriansr

import json
import requests

REPO='user/repo'
PULL= # PULL_REQUEST_ID (1234)
USER_TO_DELETE='houndci-bot'
TOKEN=YOUR_GITHUB_API_TOKEN

headers = { 'Authorization': 'token ' + TOKEN }

adriansr

# Anonymize IPTABLES logs for documentation!

import os
import re
import sys


random_macs = set()
macs = {}