LINUX.ORG.RU

Сообщения SeredaOleg

 

Помогите разобраться с sendmsg & recvmsg.

Пишу программу на массивно параллельной системе с расделенной памятью. Суть программы решение системы из 4 уравнений гармонических колебаний. Клиент работает нормально и дорабатывает правильно, вся соль в том, как потом передать массивы данных с 4 процессоров на сервер. Не могу понять почему функции sendmsg & recvmsg не работают.Прилагаю код.(Mpi не предлагать)

Клиент:

#include <sys/types.h>
#include <sys/socket.h>
#include <sys/uio.h>
#include <resolv.h>
#include <netinet/in.h>
#include <stdlib.h>
#include <string.h>

int sock;
struct sockaddr_in addr;
/////////////////////////
union num
{
	double val;
	char st[8];
}value;
double points;
double z11,z22,x11,x22;
double z1=0,z2=0,x1=0,x2=0;
double omega1,omega2;
double i;
char buffer[9];
//////////////////////
char buf_msg[3333][9];
struct msghdr msg;
struct iovec io[3333];
/////////////////////////
int main(int argc, char *argv[])
{
    char adrout1[13]="10.148.0.254";
    char adrout2[13]="10.148.0.";
    char buf[80];
    int bytes_read;
    int nd=0,j;
    int pointer=0;
	int fails;
	////////////////////
	z11=0;
	z22=0;
	omega1=atof(argv[1]);
	x11=atof(argv[2]);
	omega2=atof(argv[3]);
	x22=atof(argv[4]);
	points=atof(argv[5]);
	nd=atoi(argv[6]);
	switch(nd)
	{
	case 1:
		strcat(adrout2,"2");
		break;
	case 2:
		strcat(adrout2,"1");
		break;
	case 3:
		strcat(adrout2,"5");
		break;
	case 5:
		strcat(adrout2,"3");
		break;
	}
	/////////////////
    sock = socket(AF_INET, SOCK_DGRAM, 0);
    if(sock < 0)
    {
        perror("socket");
        exit(1);
    }
    addr.sin_family = AF_INET;
    addr.sin_port = htons(3426);
    addr.sin_addr.s_addr = htonl(INADDR_ANY);
    if(bind(sock, (struct sockaddr *)&addr, sizeof(addr)) < 0)
    {
        perror("bind");
        exit(2);
    }
	////////////////////////////////////
    bzero(&msg,sizeof(msg));
    msg.msg_name="10.148.0.254";
    msg.msg_namelen=sizeof("10.148.0.254");
    while(buf[0]!='G' && buf[1]!='o')
    {
	bytes_read = recvfrom(sock, buf, 1024, 0, NULL, NULL);
    }
	
    for(i=0.3,pointer=0;i<=points;i+=0.3,pointer++)
		switch(nd)
		{
		case 1:
			if(i!=0.3)
			{
				bytes_read = recvfrom(sock, buf, 1024, 0, NULL, NULL);
				buf[bytes_read]='\0';
				strncpy(value.st,buf+1,8);
				x11=value.val;
			}
			z1=z11+0.1*x11;
			z11=z1;
			value.val=z11;
			buffer[0]='1';
			strncpy(buffer+1,value.st,8);
			buffer[9]='\0';
			addr.sin_family = AF_INET;
    			addr.sin_port = htons(3426);
			inet_aton("10.148.0.2",&addr.sin_addr);//10.148.0.254
			sendto(sock, buffer, 9, 0, (struct sockaddr *)&addr, sizeof(addr));
			io[pointer].iov_base=buf_msg[pointer];
			sprintf(buf_msg[pointer],buffer);
			io[pointer].iov_len=strlen(buffer);
			break;
		case 2:
			if(i!=0.3)
			{
				bytes_read = recvfrom(sock, buf, 1024, 0, NULL, NULL);
				buf[bytes_read]='\0';
				strncpy(value.st,buf+1,8);
				z11=value.val;
			}
			x1=x11-0.1*omega1*omega1*z11;
			x11=x1;
			value.val=x11;
			buffer[0]='2';
			strncpy(buffer+1,value.st,8);
			buffer[9]='\0';
			addr.sin_family = AF_INET;
    			addr.sin_port = htons(3426);
    			inet_aton("10.148.0.1",&addr.sin_addr);//10.148.0.254
			sendto(sock, buffer, 9, 0, (struct sockaddr *)&addr, sizeof(addr));			
			io[pointer].iov_base=buf_msg[pointer];
			sprintf(buf_msg[pointer],buffer);
			io[pointer].iov_len=strlen(buffer);
			break;
		case 3:
			if(i!=0.3)
			{
				bytes_read = recvfrom(sock, buf, 1024, 0, NULL, NULL);
				buf[bytes_read]='\0';
				strncpy(value.st,buf+1,8);
				x22=value.val;
			}
			z2=z22+0.1*x22;
			z22=z2;
			value.val=z22;
			buffer[0]='3';
			strncpy(buffer+1,value.st,8);
			buffer[9]='\0';
			addr.sin_family = AF_INET;
    			addr.sin_port = htons(3426);
    			inet_aton("10.148.0.5",&addr.sin_addr);//10.148.0.254
			sendto(sock, buffer, 9, 0, (struct sockaddr *)&addr, sizeof(addr));
			io[pointer].iov_base=buf_msg[pointer];
			sprintf(buf_msg[pointer],buffer);
			io[pointer].iov_len=strlen(buffer);
			break;
		case 5:
			if(i!=0.3)
			{
				bytes_read = recvfrom(sock, buf, 1024, 0, NULL, NULL);
				buf[bytes_read]='\0';
				strncpy(value.st,buf+1,8);
				z22=value.val;
			}
			x2=x22-0.1*omega2*omega2*z22;
			x22=x2;
			value.val=x22;
			buffer[0]='4';
			strncpy(buffer+1,value.st,8);
			buffer[9]='\0';
			addr.sin_family = AF_INET;
    			addr.sin_port = htons(3426);
    			inet_aton("10.148.0.3",&addr.sin_addr);//10.148.0.254
			sendto(sock, buffer, 9, 0, (struct sockaddr *)&addr, sizeof(addr));
			io[pointer].iov_base=buf_msg[pointer];
			sprintf(buf_msg[pointer],buffer);
			io[pointer].iov_len=strlen(buffer);
			break;
		}

    msg.msg_iov=io;
    msg.msg_iovlen=pointer;
    inet_aton("10.148.0.254",&addr.sin_addr);
    sendmsg(sock,&msg,0);
    close(sock);

    return 0;
}

Сервер:

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>

union num
{
	double val;
	char st[8];
}value;
double omega1,omega2;
double z1=0,x1=0,z2=0,x2=0;
double points;
//////////////////////////////////////////
struct iovec io[3333];
struct msghdr msg;
char buf_msg[3333][10];
//////////////////////////////////////////
void strst(char *st,int val)
{
	int i;
	for(i=0;i<strlen(st);i++)
		st[i]=val;
}
int parallel()
{
	char msg1[]="nohup ssh node";
	char msg2[]=" 'nohup ./c.exe ";
	char msg3[]="&' > node";
	char msg4[]=".t&";
	char res1[30],res2[80],res3[30];
	char sym[20];
	char o[2];
	int i=0,op=4;
	int fails=0,fl;
	for(i=1;i<=op+fails;i++)
	{
		strst(res2,0);
		strst(res1,0);
		strst(res3,0);
		sprintf(o,"%d",i);
		strcat(res1,"scp c.exe node");
		strcat(res1,o);
		strcat(res1,":");
		fl=system(res1);
		printf("%s\n",res1);
		if(fl==256)
		{	
			fails++;
			strcat(res3,"ssh node");
			strcat(res3,o);
			strcat(res3," 'exit'");
			system(res3);
			goto nd;
		}
		sprintf(sym,"%2.1f %2.1f %2.1f %2.1f %2.1f %d",omega1,x1,omega2,x2,points,i);
		strcat(res2,msg1);
		strcat(res2,o);
		strcat(res2,msg2);
		strcat(res2,sym);
		strcat(res2,msg3);
		strcat(res2,o);
		strcat(res2,msg4);
		system(res2);
		printf("%s\n",res2);
		strcat(res3,"ssh node");
		strcat(res3,o);
		strcat(res3," 'exit'");
		system(res3);
nd:
		printf("%s\n",res3);

	}
	return fails;
}
int main(int argc, char *argv[])
{
    int sock;
    struct sockaddr_in addr;
    char buf[1024];
    int bytes_read;
    FILE *pFile;
    int f=0;
    int i,j;
    double p;
    char msg1[]="Go";
    char fname[20];
	//char msg2[]="End";
///////////////////////////////
	if(argc!=6)
	{
		printf("Error! You must input all parameters!!! Example:\n./p.exe [omega 1] [start value 1] [omega 2] [start value 2] [number of points]\n");
		return 0;
	} 
	z1=0;
	z2=0;
	omega1=atof(argv[1]);
	x1=atof(argv[2]);
	omega2=atof(argv[3]);
	x2=atof(argv[4]);
	points=atof(argv[5]);
////////////////////////////////
    sock = socket(AF_INET, SOCK_DGRAM, 0);
    if(sock < 0)
    {
        perror("socket");
        exit(1);
    }
    
    addr.sin_family = AF_INET;
    addr.sin_port = htons(3426);
    addr.sin_addr.s_addr = htonl(INADDR_ANY);
    if(bind(sock, (struct sockaddr *)&addr, sizeof(addr)) < 0)
    {
        perror("bind");
        exit(2);
    }
    f=parallel();
    printf("OK\n");
    for(j=0;j<points/0.3;j++)
    {
	io[j].iov_base=buf_msg[i];
	io[j].iov_len=sizeof(buf_msg[i]);
    }
/////////////////////////////
    setsockopt(sock,SOL_SOCKET,SO_BROADCAST,(char *)&i,sizeof(i));
    addr.sin_family = AF_INET;
    addr.sin_port = htons(3426);
    inet_aton("10.148.0.255",&addr.sin_addr);
	bytes_read=sendto(sock, msg1, sizeof(msg1), 0,
           (struct sockaddr *)&addr, sizeof(addr));
    if(bytes_read==-1)
    {
    	perror("sendto");
	exit(3);
    }
    printf("Broadcast message was sended!!!\n");
    
///////////////////////
    i=0;
    while(buf[0]!='G' && buf[1]!='o')
        bytes_read = recvfrom(sock, buf, 1024, 0, NULL, NULL);
///////////////////////
	printf("start!\n");
       msg.msg_iov=io;
	msg.msg_iovlen=(int)points/0.3;
	for(i=0;i<=4;i++)
	{
		switch(i)
		{
		case 0:
			msg.msg_name=NULL;
			msg.msg_namelen=0;
			sprintf(fname,"output z1.txt");
			pFile=fopen(fname,"w"); 
			fprintf(pFile,"i\tz1\n");
			fprintf(pFile,"%4.1f\t%.5f\n",i,z1);
			break;
		case 1:
			msg.msg_name=NULL;
			msg.msg_namelen=0;
			sprintf(fname,"output x1.txt");
			pFile=fopen(fname,"w"); 
			fprintf(pFile,"i\tx1\n");
			fprintf(pFile,"%4.1f\t%.5f\n",i,x1);
			break;
		case 2:
			msg.msg_name=NULL;
			msg.msg_namelen=0;
			sprintf(fname,"output z2.txt");
			pFile=fopen(fname,"w"); 
			fprintf(pFile,"i\tz2\n");
			fprintf(pFile,"%4.1f\t%.5f\n",i,z2);
			break;
		case 3:
			msg.msg_name=NULL;
			msg.msg_namelen=0;
			sprintf(fname,"output x2.txt");
			pFile=fopen(fname,"w"); 
			fprintf(pFile,"i\tx2\n");
			fprintf(pFile,"%4.1f\t%.5f\n",i,x2);
			break;
		}	
		recvmsg(sock,&msg,0);
		for(p=0.3,j=0;p<=points;p+=0.3,j++)
		{
			fprintf(pFile,"%4.1f\t%s\n",p,msg.msg_iov[j]);
		}
		fclose(pFile);
	}
	//close(sock);    
    return 0;
}
SeredaOleg
()
6 комментариев

Вопрос по работе с сетью.

Доброй ночи. Пишу программу по работе с сетью и столкнулся со следующей проблемой. Программа работает через UDP сокеты(так нужно). Как сделать, чтобы сервер принимал сообщение с 4х разных айпи в порядке их прибывания, чтоб успевал их обработать. Нужно просто записать эти сообщения в файл. Программа считает решение уравнения гармонических колебаний по методу эйлера(4 уравнения решаются каждое на своем компьютере), поэтому 4 решения приходят в ряд по отношению к изменению аргумента в системе.

SeredaOleg
()
6 комментариев

Сокеты передача сообщений между компьютерами. Помогите найти ошибку.

Доброго времени суток. Небольшое предисловие: есть кластерная система на 93 noda , подробнее можно тут http://neclus.donntu.edu.ua/ . Yеобходимо передать сообщения с одного компьютера на другой по сети. Написал 2 программы: первая - «родитель», запускает на 2х нодах программки, которые получают через командную строку свои параметры которые я хочу переслать на сервер. вторая - «потомок», которая запускается на нодах и пересылает полученные через командную строку данные на сервер. Возникла проблема не могу обменять сообщения, в чем проблема, может вы подскажите. Листинги ниже. Одновременная отсылка собщений с потомков обязательна. РОДИТЕЛЬ(сервер) 

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <stdlib.h>

void parallel()
{
	system("scp c.exe node1:");
	system("nohup ssh -X node1 './c.exe node1'&");
	system("scp c.exe node2:");
	system("nohup ssh -X  node2 './c.exe node2'&");
}
int main()
{
    int sock;
    struct sockaddr_in addr;
    char buf[1024];
    int bytes_read;
	char start[3]="Go";
	int i=0;

	parallel();
    printf("START\n");
    sock = socket(AF_INET, SOCK_DGRAM, 0);
    if(sock < 0)
    {
        perror("socket");
        exit(1);
    }
   i=1;
   //BROADCAST ENABLE
   setsockopt(sock,SOL_SOCKET,SO_BROADCAST,(char*)&i,sizeof(i));
	//рассылка широковечащельного сообщения для запуска.
	addr.sin_family = AF_INET;
    addr.sin_port = htons(3425);
    addr.sin_addr.s_addr=htonl(INADDR_BROADCAST);
    sendto(sock, start, sizeof(start), 0, (struct sockaddr *)&addr, sizeof(addr));
    i=0;
   //привязка к порту 3425 для 10.148.0.254
    addr.sin_family = AF_INET;
    addr.sin_port = htons(3425);
     inet_aton("10.148.0.254",&addr.sin_addr);//10.148.0.254
    if(bind(sock, (struct sockaddr *)&addr, sizeof(addr)) < 0)
    {
        perror("bind");
        exit(2);
    }
    while(i!=2)//прием сообщений от двух процессов, должно прийти node1 И node2
    {
        bytes_read = recvfrom(sock, buf, 1024, 0, NULL, NULL);
        buf[bytes_read] = '\0';
        printf(buf);
		i++;
    }
    close(sock);
    return 0;
}

ПОТОМОК 

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
int main(int argc, char *argv[])
{
    int sock;
    struct sockaddr_in addr;
    char buf[3];
    int bytes_read;
    char addrr[]="10.148.0.";
	char start[80];
	char ad;
	int i=0;
	
	strcpy(start,argv[1]);
	sock = socket(AF_INET, SOCK_DGRAM, 0);
    if(sock < 0)
    {
        perror("socket");
        exit(1);
    }
    bzero(&addr,sizeof(addr));
	//привязка к порту 3425 для любого адреса
    i=1;
    setsockopt(sock,SOL_SOCKET,SO_BROADCAST,(char*)&i,sizeof(i));
    addr.sin_family = AF_INET;
    addr.sin_port = htons(3425);
    strcat(addrr,&start[4]);
    inet_aton(addrr,&addr.sin_addr);
    if(bind(sock, (struct sockaddr *)&addr, sizeof(addr)) < 0)
    {
        perror("bind");
        exit(2);
    }
    while(buf[0]!='G' && buf[1]!='o')
    {
        bytes_read = recvfrom(sock, buf, 3, 0, NULL, NULL);
        buf[bytes_read] = '\0';
	 printf(buf);
     }
    addr.sin_family = AF_INET;
    addr.sin_port = htons(3425);
    inet_aton("10.148.0.254",&addr.sin_addr);
    sendto(sock, start, sizeof(start), 0, (struct sockaddr *)&addr, sizeof(addr));
    close(sock);
    return 0;
}

адреса нодов соответственно 10.148.0.1-10.148.0.93, сервер 10.148.0.254, с него идет запуск и на него принимаю.

 

SeredaOleg
()
2 комментария

Запуск приложений на удаленном компьтере.

Подскажите пожалуйста, есть ли возможность подключиться к удаленному компьютеру запустить там программу и отключиться от него оставив программу выполняться? При этом вернуться в свою командную строку и продолжить работу. Сразу скажу, это нужно сделать программно.

SeredaOleg
()
9 комментариев

Вопрос по работе с сокетами

Начинаю разбираться в написании сетевых приложений и возник вопрос. Например, есть два компьютера(далее передатчик и приемник) между которыми нужно передать асинхронно данные, простую строку или число. Нужно ли в коде передатчика в таком случае использовать функцию connect, а в приемнике listen? Если нет, то почему?

SeredaOleg
()
9 комментариев

Вопрос по параллельному программирвоанию на кластере с Linux

Пишу магистерскую работу на кластере МРР архитектуры и столкнулся с проблемой: можно ли как то с одной рабочей станции(сервера) разослать на другие, предположим 2 станции(2 процессора), одну и туже программу для выполнения. Одно условие нельзя пользоваться MPI(mpirun) и ему подобными интерфейсами, работа с сокетами разрешается.Кластер работает на Linux.

 , , мрр

SeredaOleg
()
52 комментария (стр. 2)

RSS подписка на новые темы