simbo1905

package com.github.simbo1905.chronicle;

import java.util.ArrayList;
import java.util.List;

import com.higherfrequencytrading.chronicle.Chronicle;
import com.higherfrequencytrading.chronicle.datamodel.DataStore;
import com.higherfrequencytrading.chronicle.datamodel.ListWrapper;
import com.higherfrequencytrading.chronicle.datamodel.ModelMode;
import com.higherfrequencytrading.chronicle.impl.IndexedChronicle;

simbo1905

package dumbconsumer;

import java.io.IOException;
import java.util.List;
import java.util.Map;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

simbo1905

object SessionDemo {
  def main(args: Array[String]) {
    import scala.concurrent.duration._

    val timeoutSeconds = 10

    def usage() {
      System.out.println(s"|timoutSeconds: ${timeoutSeconds}")
      System.out.println(s"|commands:")
      System.out.println(s"|+ <key> <value> // add a value under a key")

simbo1905

public class Runner01 {

	static class Array1 {

		private Object delegate;

		private Object allocate(Object delegate, int[] is, int pos) {
			if (pos < is.length) {
				delegate = new Object[is[pos]];

simbo1905

import java.security.Key;
import java.util.Properties;

import javax.crypto.Cipher;
import javax.crypto.spec.SecretKeySpec;
import javax.persistence.AttributeConverter;
import javax.persistence.Converter;

import org.slf4j.Logger;

simbo1905

   // test case
         import scala.pickling.Defaults._
        import scala.pickling.shareNothing._
        import scala.pickling.binary._

          val p = PrepareAck(Identifier(1, ProposalNumber(2, 3), 4L), 5, Progress(ProposalNumber(6,7),Identifier(8,ProposalNumber(9,10),11L)), 12, 13, None)

          val b = p.pickle.value

          val pp = b.unpickle[PrepareAck]

simbo1905

package com.github.simbo1905.trex.internals

import java.nio.ByteBuffer

import akka.util.ByteString


object Pickle {

  import scala.pickling.Defaults._

simbo1905

    @Override
    protected void configure(HttpSecurity http) throws Exception {
        http
            .authorizeRequests()
				.antMatchers("/", "/favicon.ico", "/resources/**", "/signup",
						"/register", "/public")
				.permitAll()
                .anyRequest().authenticated()
                .and()
            .formLogin()

simbo1905

Adapted from https://github.com/zmarcantel/docker-cassandra to install CQLSH the Python based Cassandra CLI

Documented at https://simbo1905.wordpress.com/2017/02/24/cassandra-for-shared-media-libraries/

start three nodes

docker run -d --name "cass0" zmarcantel/cassandra
docker run -d --name cass1 --link cass0:cass0 zmarcantel/cassandra
docker run -d --name cass2 --link cass0:cass0 --link cass1:cass1 zmarcantel/cassandra

simbo1905

      def perms(positions: List[Int]) = {
        val x: Set[List[Int]] = positions.permutations.map(_.take(2)).toSet

        val y = x filter {
          case a :: b :: Nil =>
            (a, b) match {
              case (a: Int, b: Int) if a < b => true
              case _ => false
            }
          case _ => false