kumagi

void msd_first_parallel_radix_sort(const std::vector<uint64_t>::iterator& begin,
                                   const std::vector<uint64_t>::iterator& end) {
  const auto size = std::distance(begin, end);
  const int nthreads = cpu_num();  // number of threads
  constexpr size_t bytes = sizeof(uint64_t);
  constexpr size_t nbuckets = 256;
  constexpr int kOutBuff = 8;

  std::vector<std::array<uint64_t, nbuckets> > offsets(nthreads);

kumagi

#include <string>
#include <iostream>
#include <log4cxx/logger.h>
#include <log4cxx/propertyconfigurator.h>
#include <log4cxx/helpers/exception.h>
#include <log4cxx/helpers/properties.h>
#include <assert.h>

log4cxx::LoggerPtr logger_ __attribute__((init_priority(10)));

kumagi

#include <algorithm>
#include <iostream>
#include <sstream>
#include <random>
#include "radix_sort.hpp"

#include <chrono>

kumagi

//
// Created by kumagi on 16/01/13.
//

#ifndef BETASORT_RADIX_SORT_HPP
#define BETASORT_RADIX_SORT_HPP

#define _GNU_SOURCE 1
#include <sched.h>
#include <assert.h>

kumagi

#define _GNU_SOURCE 1
#include <sched.h>  // sched_setaffinity
#include <stdint.h>
#include <stdio.h>
#include <limits.h>
#include <stdlib.h>
#include <stdint.h>
#include <pthread.h>
#include <assert.h>
#include <sys/time.h>

kumagi

#define _GNU_SOURCE 1
#include <sched.h>  // sched_setaffinity
#include <stdint.h>
#include <stdio.h>
#include <limits.h>
#include <stdlib.h>
#include <stdint.h>
#include <pthread.h>
#include <assert.h>
#include <sys/time.h>

kumagi

#!/usr/bin/env python
from __future__ import print_function
from flask import Flask, render_template, Response
import socket
from contextlib import closing
from threading import Thread
from time import sleep

PORT = 4444

kumagi

[ RUN      ] clustering_test_instance/clustering_test.get_k_center/3
../jubatus/core/driver/clustering_test.cpp:184: Failure
Expected: (min_diff * 0.8) < (squared_diff), actual: 5.17922e+10 vs 0
[  FAILED  ] clustering_test_instance/clustering_test.get_k_center/3, where GetParam() = ("compressive_gmm", "gmm") (3 ms)

[ RUN      ] clustering_test_instance/clustering_test.get_k_center/3
../jubatus/core/driver/clustering_test.cpp:184: Failure
Expected: (min_diff * 0.8) < (squared_diff), actual: 5.17922e+10 vs 1.53427e+10
[  FAILED  ] clustering_test_instance/clustering_test.get_k_center/3, where GetParam() = ("compressive_gmm", "gmm") (6 ms)

kumagi

Running main() from gtest_main.cc
[==========] Running 36 tests from 2 test cases.
[----------] Global test environment set-up.
[----------] 32 tests from clustering_test_instance/clustering_test
[ RUN      ] clustering_test_instance/clustering_test.get_revision/0
[       OK ] clustering_test_instance/clustering_test.get_revision/0 (7 ms)
[ RUN      ] clustering_test_instance/clustering_test.get_revision/1
[       OK ] clustering_test_instance/clustering_test.get_revision/1 (6 ms)
[ RUN      ] clustering_test_instance/clustering_test.get_revision/2
[       OK ] clustering_test_instance/clustering_test.get_revision/2 (46 ms)

kumagi

{
  "converter" : {
    "string_filter_types": {},
    "string_filter_rules":[],
    "num_filter_types": {},
    "num_filter_rules": [],
    "string_types": {},
    "string_rules":[
      {"key" : "*", "type" : "str", "sample_weight":"bin", "global_weight" : "bin"}
    ],