jac18281828

import socket
import select
import sys

__EPOLL_TIMEOUT = 1.0
__BUFFER_SZ = 8192
yeti_request ="GET /bap HTTP/1.1\r\nConnection: keep-alive\r\nContent-Length: 0\r\n\r\n"
epoll  = None
socket_set = {}

jac18281828

#include <algorithm>
#include <functional>
#include <iomanip>
#include <iostream>

#include "percentile.h"

using namespace std;
using namespace stat;

jac18281828

import sys

for buffer in sys.stdin.read():
  for ch in buffer:
    if (ord(ch) < 128):
      sys.stdout.write(ch)

jac18281828

public class Murmur2 {

    public static final int BYTE_BITMASK = 0xff;
    public static int MURMUR2_SEED1 = 0xe17a1465;
    public static int MURMUR2_SEED2 = 0x9747b28c;
    public static int MURMUR2_SEED3 = MURMUR2_SEED1*7;

    private int defaultSeed = MURMUR2_SEED1;

    public Murmur2(final int defaultSeed){

jac18281828

import sun.misc.Contended;

import java.security.NoSuchAlgorithmException;
import java.security.SecureRandom;
import java.util.Random;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.RecursiveAction;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.LongAccumulator;

jac18281828

#pragma once

#include <stdatomic.h>
#include <atomic>
#include <sys/types.h>

#define PAUSE asm volatile("pause\n": : :"memory");

class seq_lock {
private:

jac18281828

package com.covemarkets;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import java.security.InvalidKeyException;
import java.security.KeyPair;
import java.security.KeyPairGenerator;
import java.security.NoSuchAlgorithmException;
import java.security.NoSuchProviderException;

jac18281828

#!/usr/bin/env /bin/bash

# SHA 256 based on openssl
# 
# sha256 similar to the classic "md5sum" command line
#

if [[ ${#} -gt 0 ]]
then
    # iterate over all arguments

jac18281828

import com.salesforce.kafka.test.AbstractKafkaTestResource;
import com.salesforce.kafka.test.KafkaCluster;
import com.salesforce.kafka.test.KafkaTestCluster;
import com.salesforce.kafka.test.junit4.SharedKafkaTestResource;
import org.junit.Ignore;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Profile;
import org.springframework.stereotype.Service;

jac18281828

import org.junit.Ignore;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class StringPerformerTest {

    private static final Logger log = LoggerFactory.getLogger(StringPerformerTest.class);

    private static final String S1 = "table";