<commit_before>/****************************
#function : FDFShutdown
#author   : <NAME>
#date     : 2013
 *****************************/

#include <stdlib.h>
#include <assert.h>
#include <unistd.h>
#include "fdf.h"
#include <string.h>
#include <pthread.h>
#include <semaphore.h>

#define MAX_ITERATION  32

FILE                           *fp             = NULL;
static struct FDF_state        *fdf_state      = NULL;
static struct FDF_thread_state *fdf_thrd_state1 = NULL;

FDF_cguid_t                    cguid[MAX_ITERATION] = {0};


static FDF_status_t
pre_env()
{
	FDF_status_t ret = FDF_FAILURE;

	FDFSetProperty("SDF_REFORMAT", "1");
	FDFSetProperty("FDF_BTREE_PARALLEL_FLUSH", "1");
	FDFSetProperty("FDF_BTREE_SYNC_THREADS", "64");


	ret = FDFInit(&fdf_state);

	if (FDF_SUCCESS != ret)	{
		fprintf(fp, "FDF initialization failed!\n");
	} else {
		fprintf(fp, "FDF initialization succeed!\n");

		ret = FDFInitPerThreadState(fdf_state, &fdf_thrd_state1);
		if( FDF_SUCCESS == ret) {
			fprintf(fp, "FDF thread initialization succeed!\n");
		}
	}
	return ret;<commit_msg>#0000: Test fails due to more paraallel flush threads TESTS_RAN: Unit test<commit_after>/****************************
#function : FDFShutdown
#author   : <NAME>
#date     : 2013
 *****************************/

#include <stdlib.h>
#include <assert.h>
#include <unistd.h>
#include "fdf.h"
#include <string.h>
#include <pthread.h>
#include <semaphore.h>

#define MAX_ITERATION  32

FILE                           *fp             = NULL;
static struct FDF_state        *fdf_state      = NULL;
static struct FDF_thread_state *fdf_thrd_state1 = NULL;

FDF_cguid_t                    cguid[MAX_ITERATION] = {0};


static FDF_status_t
pre_env()
{
	FDF_status_t ret = FDF_FAILURE;

	FDFSetProperty("SDF_REFORMAT", "1");
	FDFSetProperty("FDF_BTREE_PARALLEL_FLUSH", "1");
	FDFSetProperty("FDF_BTREE_SYNC_THREADS", "2");


	ret = FDFInit(&fdf_state);

	if (FDF_SUCCESS != ret)	{
		fprintf(fp, "FDF initialization failed!\n");
	} else {
		fprintf(fp, "FDF initialization succeed!\n");

		ret = FDFInitPerThreadState(fdf_state, &fdf_thrd_state1);
		if( FDF_SUCCESS == ret) {
			fprintf(fp, "FDF thread initialization succeed!\n");
		}
	}
	return ret;
{'fraction_non_alphanumeric': 0.17570009033423667, 'fraction_numerical': 0.013098464317976514, 'mean_word_length': 3.900442477876106, 'pattern_counts': {'":': 0, '<': 17, '<?xml version=': 0, '>': 17, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 4, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '2984694', 'n_tokens_mistral': 857, 'n_tokens_neox': 818, 'n_words': 168}