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

[ 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

#ifndef THREAD_POOL
#define THREAD_POOL
#include <pthread.h>
#include <stdlib.h> // malloc
#include <unistd.h> // sleep,usleep
#include "queue.hpp"
#include <assert.h>
#include <sys/resource.h> // rlimit
 
namespace{

kumagi

template<typename obj>
class lf_stack{
private:
	class node{
	public:
		obj data;
		node* next;
		node(const obj& d):data(d),next(NULL){ }
	};
	volatile node *head;

kumagi

#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <assert.h>
#include <unistd.h>
#include <time.h>

class deviding_tag {
private:

kumagi

#ifndef ATOMICS
#define ATOMICS

#if __x86_64__ || _WIN64
#define _64BIT
#define _ptr long long
#else
#define _32BIT
#define _ptr int

kumagi

#!/usr/bin/python
import msgpack
import socket,struct,sys,time

SET=0
GET=1
DELETE=2
FOUND=3
DONE=4
NONE=5

kumagi

#include <stdint.h>

#include <msgpack.hpp>
#include <mp/wavy.h>

#include <fcntl.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>

kumagi

#include <stdint.h>
#include <stdlib.h>
#include <msgpack.hpp>
#include <mp/wavy.h>
#include <fcntl.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>

kumagi

static int OK = 1;

int create_tcpsocket(void){
	int fd = socket(AF_INET,SOCK_STREAM, 0);
	if(fd < 0){
		perror("scocket");
	}
	return fd;
}