Function SlowLog_New

src/slow_log/slow_log.c:126–145

}

SlowLog *SlowLog_New(void) {
	SlowLog *slowlog = rm_malloc(sizeof(SlowLog));

	// Redis main thread + writer threads + reader threads.
	int thread_count = ThreadPools_ThreadCount() + 1;

	slowlog->count    = thread_count;
	slowlog->locks    = rm_malloc(sizeof(pthread_mutex_t) * thread_count);
	slowlog->lookup   = rm_malloc(sizeof(rax*) * thread_count);
	slowlog->min_heap = rm_malloc(sizeof(heap_t*) * thread_count);

	for(int i = 0; i < thread_count; i++) {
		slowlog->lookup[i] = raxNew();
		slowlog->min_heap[i] = Heap_new(_slowlog_elem_compare, NULL);
		int res = pthread_mutex_init(slowlog->locks + i, NULL);
		ASSERT(res == 0);
	}

	return slowlog;
}

void SlowLog_Add
(