gerritjvv

(require '[clojure.walk :refer [postwalk]])

(defn mapvals [f m]
  (let [v-f (fn [v]

       (cond 
            (map? v) v 
            (coll? v) (into (empty v) (map f) v)
            :else (f v)))
            

gerritjvv

 (defn in? [vs ls]
   (boolean (some (partial (set vs)) ls)))

 (in? [1 2] [3 4 2 5]) => false
 (in? [1 2] [3 1 4 2 5]) => true


(defn in? [v ls]
  (loop [[x & rs] ls]
    (if-not x

gerritjvv

# The aim is to support e.g
# URL="dburl" variables and then override at will when PROD_URL is available.

switch_prod.sh

for v in $(env | awk '/PROD_/ {gsub(/PROD_/,""); print $1}'); do
 eval "export $v"
done

gerritjvv

;; deps:
;;                 [com.cognitect.aws/api "0.8.352"]
;;                 [com.cognitect.aws/endpoints "1.1.11.632"]
;;                 [com.cognitect.aws/sqs "742.2.519.0"]
;;                 [mount "0.1.16"]
;;                 [cheshire "5.8.1"]

(require '[cognitect.aws.client.api :as aws])
(require '[mount.core :as mount)

gerritjvv

=== RUN   TestNaiveTimesEncryptGCM
Run 0. Did 1000000 iterations in 2.481178232s
Run 1. Did 1000000 iterations in 2.495653698s
Run 2. Did 1000000 iterations in 2.554544033s
Run 3. Did 1000000 iterations in 2.735187669s
Run 4. Did 1000000 iterations in 2.468231834s
Run 5. Did 1000000 iterations in 2.508428888s
Run 6. Did 1000000 iterations in 2.515230338s
Run 7. Did 1000000 iterations in 2.757054756s
Run 8. Did 1000000 iterations in 2.807702375s

gerritjvv

Vanilla Java JCE

Benchmark                       Mode  Cnt      Score      Error  Units
AesJce.enc_aes128CbcHmacSha256  thrpt  200  40722.671 ±  739.025  ops/s
AesJce.enc_aes256CbcHmacSha512  thrpt  200  39288.300 ±  979.722  ops/s
AesJce.enc_aes128GCM            thrpt  200  75599.381 ± 1197.385  ops/s

AesJce.dec_aes128CbcHmacSha256  thrpt  200  49830.138 ± 1040.007  ops/s
AesJce.dec_aes256CbcHmacSha512  thrpt  200  51758.272 ±  839.378  ops/s
AesJce.dec_aes128GCM            thrpt  200  76144.372 ± 2626.274  ops/s

gerritjvv

public static Map<String, Object> argumentsAsMap(String[] args){
        Map<String, Object> m = new HashMap<>();

        for(int i = 0; i < args.length; i++){
            String lbl = args[i].trim();

            if(lbl.startsWith("-")  && i+1 < args.length && !args[i+1].trim().startsWith("-")) {
                m.put(removePrefixes(lbl), args[i+1].trim());
                i++;
            } else {

gerritjvv

import posixpath
import argparse
import urllib
import os

from SimpleHTTPServer import SimpleHTTPRequestHandler
from BaseHTTPServer import HTTPServer


class RootedHTTPServer(HTTPServer):

gerritjvv

(defrecord MyItem [a b c])

(apply ->MyItem ["1" "2" "3"])
;; #user.MyItem{:a "1", :b "2", :c "3"}

(map #(apply ->MyItem %) [ [1 2 3] [4 5 6] [7 8 9]])
;;(#user.MyItem{:a 1, :b 2, :c 3} #user.MyItem{:a 4, :b 5, :c 6} #user.MyItem{:a 7, :b 8, :c 9})

gerritjvv

(ns
  ^{:doc "Concurrent keyed pool implementation using ConcurrentHashMap and ConcurrentLinkedQueue"}
  kafka-clj.pool-impl
  (:use criterium.core)
  (:import (java.util.concurrent ConcurrentLinkedQueue ConcurrentHashMap Semaphore ExecutorService Executors TimeUnit)))

;; add [criterium "0.4.4"] to you're project.clj file
;; then use  run-test-cc and run-test-a
;;
;; Results for both ConcurrentLinkedQueue + Semaphore and for atom + vector access is the same