unsigned char dc;
int get_data_and_calc(t_event *event,void *allineed);
+int nop(t_event *event,void *allineed);
int usage(char *prog)
{
c=gd3_l->max_x*gd3_l->max_y*gd3_l->max_z;
- network_send(gnet->connection[0].fd,&dc,1);
- /*
- network_send(gnet->connection[0].fd,(unsigned char *)gd3_l,
- sizeof(d3_lattice));
- network_send(gnet->connection[0].fd,(unsigned char *)gmy_info,sizeof(info));
- */
- network_send(gnet->connection[0].fd,gd3_l->status,c*sizeof(unsigned char));
- network_send(gnet->connection[0].fd,(unsigned char *)gd3_l->extra,
- c*sizeof(int));
- network_send(gnet->connection[0].fd,(unsigned char *)gi,sizeof(int));
-
+ network_send_chan(gnet,0,&dc,1);
+ network_send_chan(gnet,0,(unsigned char *)gd3_l,sizeof(d3_lattice));
+ network_send_chan(gnet,0,(unsigned char *)gmy_info,sizeof(info));
+ network_send_chan(gnet,0,gd3_l->status,c*sizeof(unsigned char));
+ network_send_chan(gnet,0,(unsigned char *)gd3_l->extra,c*sizeof(int));
+ network_send_chan(gnet,0,(unsigned char *)gi,sizeof(int));
}
gnet=&net;
/* default values */
- strcpy(server_ip,"");
+ strcpy(server_ip,"137.250.82.105");
strcpy(p_file,IMP_PROFILE);
strcpy(n_e_file,NEL_PROFILE);
strcpy(r_file,"");
/* wait for job */
event_math(net.connection[0].fd,&event,READ,ADD);
- event_start(&event,NULL,get_data_and_calc,NULL);
+ printf("idle, waiting for jobs ...\n");
+ event_start(&event,NULL,get_data_and_calc,nop);
+
+ return 1;
+}
+
+int nop(t_event *event,void *allineed) {
+
+ printf("\ni did a nop :)\n");
return 1;
}
u32 x_c,y_c,z_c;
int i,j;
int c_step;
- unsigned char data[256];
+ unsigned char data;
t_net *net;
gmy_info=&my_info;
gi=&i;
dc=0;
+
+ printf("got a new job ...\n");
/* get info (+data) */
- network_receive(net->connection[0].fd,data,1);
- if(data[0]==NLSOP_NJOB || data[0]==NLSOP_CJOB) {
+ network_receive(net->connection[0].fd,&data,sizeof(unsigned char));
+ if(data==NLSOP_NJOB || data==NLSOP_CJOB) {
network_receive(net->connection[0].fd,(unsigned char *)&d3_l,
sizeof(d3_lattice));
network_receive(net->connection[0].fd,(unsigned char *)&my_info,
printf("extra malloc failed\n");
return -1;
}
- if(data[0]==NLSOP_CJOB) {
+ if(data==NLSOP_CJOB) {
+ data=DATA_OK;
network_receive(net->connection[0].fd,d3_l.status,
j*sizeof(unsigned char));
+ network_send(net->connection[0].fd,&data,sizeof(unsigned char));
network_receive(net->connection[0].fd,(unsigned char *)d3_l.extra,
j*sizeof(int));
+ network_send(net->connection[0].fd,&data,sizeof(unsigned char));
network_receive(net->connection[0].fd,(unsigned char *)&c_step,
sizeof(int));
+ network_send(net->connection[0].fd,&data,sizeof(unsigned char));
}
}
+ else {
+ printf("unknown instruction, restarting ...\n");
+ return -1;
+ }
+
+ printf("starting simulation with following parameters:\n");
+ printf("b = %f | c = %f | s = %f\n",my_info.b,my_info.c,my_info.s);
+ printf("diff every %d steps | diff rate = %f\n",my_info.diff_rate,
+ my_info.dr_ac);
+ printf("current step: %d | total steps: %d\n",c_step,my_info.steps);
+ printf("...\n");
/* care for signals */
dc=DC_QUIT;
dc=DC_QUIT;
/* shutdown/free/close everything now ... */
+ free(d3_l.status);
+ free(d3_l.extra);
+ free(c_profile);
+ free(n_e_loss);
+ free(nel_z);
return 1;
}