<commit_before>#include <stdio.h>
#include <stdlib.h>
#include "athread.h"

#define MAX 5


// tags
#define REMOTE_SERVICE_ID 1
#define REMOTE_SERVICE_ID_2 2
#define MAXY 3000


void *remote_th(void *in) {
	double *result = malloc(sizeof(double));
	int i, j, f;
	
	printf("remote_th --- athread_remote_rank == %d\n", athread_remote_rank);
	*result = *(double *) in;
	*result += 10;
	
	for (i=0; i < MAXY; i++)
		for (j=0; j < MAXY; j++)
			for (f=0; f < MAXY; f++);
	
	return (void *) result;
}

void *remote_th_2(void *in) {
	double *result = malloc(sizeof(double));
	int i, j, f;
	
	printf("remote_th_2 --- athread_remote_rank == %d\n", athread_remote_rank);
	*result = *(double *) in;
	*result += 12;
	
	for (i=0; i < MAXY; i++)
		for (j=0; j < MAXY; j++)
			for (f=0; f < MAXY; f++);
	
	
	return (void *) result;
}


int main(int argc, char *argv[]) {
	athread_t remote_thread;
	athread_attr_t remote_thread_attr;
	
	athread_t remote_thread_2;
	athread_attr_t remote_thread_attr_2;
	
	
	double *input_value = malloc(sizeof(double));
	double *result = malloc(sizeof(double));
	
	MPI_Init(&argc, &argv);
	MPI_Comm_rank(MPI_COMM_WORLD, &athread_remote_rank);  
  MPI_Comm_size(MPI_COMM_WORLD, &athread_remote_size);

	aInit(&argc, &argv);
	
	// create remote threads and let ir runn.. too..
	*input_value = 10;
	
	// register service
	athread_remote_register_service(REMOTE_SERVICE_ID, remote_th);<commit_msg>removing something<commit_after>#include <stdio.h>
#include <stdlib.h>
#include "athread.h"

#define MAX 5


// tags
#define REMOTE_SERVICE_ID 1
#define REMOTE_SERVICE_ID_2 2
#define MAXY 3000


void *remote_th(void *in) {
	double *result = malloc(sizeof(double));
	int i, j, f;
	
	printf("remote_th --- athread_remote_rank == %d\n", athread_remote_rank);
	return (void *) result;
}

void *remote_th_2(void *in) {
	double *result = malloc(sizeof(double));
	int i, j, f;
	return (void *) result;
}

int main(int argc, char *argv[]) {
	athread_t remote_thread;
	athread_attr_t remote_thread_attr;
	
	athread_t remote_thread_2;
	athread_attr_t remote_thread_attr_2;
	
	
	double *input_value = malloc(sizeof(double));
	double *result = malloc(sizeof(double));
	
	MPI_Init(&argc, &argv);
	MPI_Comm_rank(MPI_COMM_WORLD, &athread_remote_rank);  
  MPI_Comm_size(MPI_COMM_WORLD, &athread_remote_size);

	aInit(&argc, &argv);
	
	// create remote threads and let ir runn.. too..
	*input_value = 10;
	
	// register service
	athread_remote_register_service(REMOTE_SERVICE_ID, remote_th);
{'fraction_non_alphanumeric': 0.14366197183098592, 'fraction_numerical': 0.01488933601609658, 'mean_word_length': 4.75462962962963, 'pattern_counts': {'":': 0, '<': 13, '<?xml version=': 0, '>': 7, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '1261187', 'n_tokens_mistral': 1063, 'n_tokens_neox': 972, 'n_words': 224}