16 çekirdek destekli İşlemci Test Programı (v09a-1.@EczaNet-Xeon2689-14.971sn.) (8. sayfa)

 
  // Author Emre Demir 
  #include <stdio.h> 
  #include <string.h> 
  #include <mpi.h> 
  #include <arpa/inet.h> 
  #include <netinet/in.h> 
  #include <unistd.h> 
  #include <netdb.h> 
  #include <time.h> 
   
  #define BASE 24 
  //gelen sayinin kuvvetini alir. Ilk parametre base ikincisi kuvvet 
  double power(int a, int b){ 
  	int i; 
  	double res=1; 
  	for(i=0; i<b;i++){ 
  		res *= a;	 
  	} 
  	return res; 
  } 
  //O anki zamanı kullanarak random sayi ureten fonksiyon. 
  float gen_rand(void) 
  { 
  	unsigned int iseed = (unsigned int)time(NULL); 
  	srand (iseed); 
     	int n; 
     	n=rand(); 
  	n = n%10;                           //0-10 araliginda random sayi uretilir.        
          int temp = rand(); 
  	temp = temp%100000; 
  	float fTemp = (float)temp/100000;  // 0.0 0.99999 araliğinda random sayi uretir. 
  	fTemp = fTemp + (float) n;         //temp ve n toplarak tam bir float sayi elde edilir.		 
  	return fTemp; 
  } 
   
  int main( int argc, char* argv[] ) 
  { 
  	int		my_rank; 
      	int 		p;	 
      	int 		source;	 
      	int 		dest;	 
      	int 		tag = 0; 
  	MPI_Status	status;	 
     	int err; 
  	int i; 
          err = MPI_Init( &argc, &argv ); 
  	MPI_Comm_rank(MPI_COMM_WORLD, &my_rank); 
  	MPI_Comm_size(MPI_COMM_WORLD, &p); 
   
  	if(my_rank==0){ /* my_rank == 0 */		 
  		printf("Bu Programda CPU Verileri Sirali Yazilmaz \nIslemini Ilk Bitiren CPU'nun verileri Ilk Yazilir.\n");		 
  		double compute_t1, compute_t2, overall_t1, overall_t2,compute_res, overall_res;		 
  		char str[256];                           //Kullanicidan alinan kuvvet degerini tutar 
  		printf ("Kuvveti Girin: "); 
  		gets ( str ); 
  		i = atoi ( str);                         //i degiskeninde alinan kuvvet degirini tutar 
  		int k;		 
  		overall_t1= MPI_Wtime();		 
  		for(k=1; k<p; k++){	                 // Her işlemciye kuvvet degirini yollar.  
  			MPI_Send(&i, 1, MPI_INT, k, 3,   // Burda Broadcast'de kullanilabilirdi cok fazla işlemcili sistemlerde	 
  						MPI_COMM_WORLD); 
  		}					 
  		double g= 10.0; 
  		double b = power(g,i); 
  		double j; 
  		b= BASE*b/p;                             //kac adet sayı toplanacak, burda hesaplanıyor. 
  		float master_inter_res; 
  		float master_med_res; 
  		float inter_res[3]; 
  		float final_res=0;			//genel toplamı tutar. 
  		float final_med=0;			//genel ortalamayı tutar. 
  		int wh_cpu; 
  		compute_t1 = MPI_Wtime();               //sadece hesaplama suresinin bulunması icin zaman baslangıcı.	 
  		for(j=0.0; j<b; j++){			//Boylece master hesaplamaya ne kadar sure  
  			master_inter_res+= gen_rand();  //Haberlesmeye ne kadar sure ayrdı gorulebilir. 
  		} 
  		master_med_res = master_inter_res / (float)b; 
  		compute_t2 = MPI_Wtime();               //hesaplama suresinin zaman bitisi 
  		compute_res= compute_t2 - compute_t1; 
  		for (source = 1; source < p; source++) {//CPU'lardan sonucların alınması işlemi.			 
  			MPI_Recv(&wh_cpu,1,MPI_INT,MPI_ANY_SOURCE, 2, MPI_COMM_WORLD, &status);// Sonuclar sirali degil, 
  											       // bitirme suresi erken olana göre alinir. 
  											       // Bu nedenden isi bitirenin CPU ran'ik alinir ilk. 
  			MPI_Recv(&inter_res,3, MPI_FLOAT, wh_cpu, tag,			       // Bu ranka gore o islemciden sonuc alinir. 
  						MPI_COMM_WORLD, &status); 
  			printf("CPU Derecesi: %d \n", wh_cpu); // Verilerin ekrana yazdirilmasi  
  			printf("CPU'da Toplanan Sayi Adedi: %f \nCPU Ara Toplam Degeri: %f \nCPU Ara Degerinin Ortalaması: %f \nCPU Çalışma Suresi: %f 	\n\n",b, inter_res[0] ,inter_res[1], inter_res[2] ); 
  			final_res += inter_res[0]; 
  			final_med += inter_res[1];  
  		} 
  		final_res +=master_inter_res; 
  		final_med +=master_med_res; 
  		final_med = final_med /p; 
  		overall_t2 = MPI_Wtime(); 
  		overall_res = overall_t2 - overall_t1; 
  		printf("CPU Derecesi: 0 \n"); // master'ın sonuclarinin ekrana yazdirimi. 
  		printf("CPU'da Toplanan Sayi Adedi: %f \nCPU Ara Toplam Degeri: %f \nCPU Ara Degerinin Ortalaması: %f \nCPU'nun Hesaplama Yapmaya Harcadigi Sure: %f \n\n",b, master_inter_res ,master_med_res, compute_res ); 
  		printf("Toplanan Sayi Adedi: %f\n",b*p); 
  		printf("Genel Toplam Sonucu: %f\n",final_res); 
  		printf("Genel Toplamin Ortalamasi: %f\n",final_med); 
  		printf("Toplam Calisma Suresi: %f\n", overall_res); 
  	} 
  	 
  	else if(my_rank != 0) { 
  		MPI_Recv(&i,1,MPI_INT,0, 3, MPI_COMM_WORLD, &status);			 
  		double t1,t2; 
  		t1 = MPI_Wtime();		 
  		float inter_res[3]; 
  		double g= 10.0; 
  		double b = power(g,i); 
  		double j; 
  		b= BASE*b/p; 
  		dest = 0; 
  		inter_res[0]=0; 
  		inter_res[1]=0; 
  		inter_res[2]=0; 
  		for(j=0.0; j<b; j++){ 
  			inter_res[0] += gen_rand(); 
  		} 
  		inter_res[1]=inter_res[0]/(float)b; 
  		t2=MPI_Wtime(); 
  		inter_res[2] = (float)(t2-t1); 
  		 
  		MPI_Send(&my_rank, 1, MPI_INT, dest, 2, 
  					MPI_COMM_WORLD); // iletisime gececek CPU'nun rank'ini yollaması		 
  		MPI_Send(&inter_res, 3, MPI_FLOAT, dest, tag, 
  					MPI_COMM_WORLD); // Ardindan verileri yollamasi. 
  	}  
   
  	/* Shut down MPI */ 
      err = MPI_Finalize(); 
      return 0; 
  }