X-Git-Url: https://hackdaworld.org/gitweb/?p=physik%2Fnlsop.git;a=blobdiff_plain;f=nlsop_server.c;h=ea4579164d0de297e6b3f790aca0746399fb819c;hp=7f24e8cf3410ec72d626d94ea5a0be991731da56;hb=9ba8efd9cd20fa8047c4583dbadb18308401894a;hpb=0fbb254a433dd25b5938be009d0835e2c6b17184 diff --git a/nlsop_server.c b/nlsop_server.c index 7f24e8c..ea45791 100644 --- a/nlsop_server.c +++ b/nlsop_server.c @@ -112,6 +112,8 @@ int add_node(t_net *net,t_event *event,t_list *c_list,t_list *g_list) { /* if we have a new node - care for it! */ event_math(net->connection[channel].fd,event,READ,ADD); + printf("\n"); + return 1; } @@ -205,6 +207,9 @@ int add_job(t_net *net,int chan,t_list *jl) { job.step=0; list_add_element(jl,&job,sizeof(t_job)); + + printf("job added: b=%f | c=%f | s=%f ...\n", + job.info.b,job.info.c,job.info.s); return 1; } @@ -262,12 +267,14 @@ int handle_node(t_net *net,t_event *event, c->status=IDLE; /* delete job entry */ list_del_current(job); + printf("job ended, saved and removed from list.\n"); } if(data==DC_OK) { save_job(net,i,j,DC_OK); /* inc progress state */ j->progress+=1; + printf("job at next level, saved.\n"); } if(data==DC_QUIT) { @@ -279,6 +286,7 @@ int handle_node(t_net *net,t_event *event, list_del_current(c_list); /* change job state */ j->status=IN_QUEUE; + printf("client terminating, job queued, client removed.\n"); } } @@ -308,6 +316,8 @@ int handle_node(t_net *net,t_event *event, } } } + + printf("\n"); return 1; } @@ -330,6 +340,8 @@ int distribute_jobs(t_event *event,void *allineed) { g_list=(t_list *)addr[2]; job=(t_list *)addr[3]; + printf("d: distributing jobs ...\n"); + count_j=list_count(job); count_c=list_count(c_list);