Ignore:
Timestamp:
05/26/15 16:13:47 (9 years ago)
Author:
rlacroix
Message:

Add basic infrastructure for servers to clients communication.

Location:
XIOS/trunk/src/interface/c
Files:
2 edited

Legend:

Unmodified
Added
Removed

  • XIOS/trunk/src/interface/c/iccalendar.cpp

    r591 r597  
    1313    CTimer::get("XIOS").resume(); 
    1414    xios::CContext* context = CContext::getCurrent(); 
    15     if (!context->hasServer) context->client->checkBuffers(); 
     15    if (!context->hasServer) context->checkBuffersAndListen(); 
    1616    context->updateCalendar(step); 
    1717    context->sendUpdateCalendar(step); 

  • XIOS/trunk/src/interface/c/icdata.cpp

    r593 r597  
    373373      CTimer::get("XIOS send field").resume(); 
    374374      CContext* context = CContext::getCurrent(); 
    375       if (!context->hasServer) context->client->checkBuffers(); 
     375      if (!context->hasServer) context->checkBuffersAndListen(); 
    376376      CArray<double, 1> data(data_k8, shape(data_Xsize), neverDeleteData); 
    377377      CField::get(fieldid_str)->setData(data); 
    … …  
    389389 
    390390      CContext* context = CContext::getCurrent(); 
    391       if (!context->hasServer) context->client->checkBuffers(); 
     391      if (!context->hasServer) context->checkBuffersAndListen(); 
    392392 
    393393      CArray<double, 1> data(data_k8, shape(data_Xsize), neverDeleteData); 
    … …  
    407407 
    408408      CContext* context = CContext::getCurrent(); 
    409       if (!context->hasServer) context->client->checkBuffers(); 
     409      if (!context->hasServer) context->checkBuffersAndListen(); 
    410410 
    411411      CArray<double, 2>data(data_k8, shape(data_Xsize, data_Ysize), neverDeleteData); 
    … …  
    425425 
    426426      CContext* context = CContext::getCurrent(); 
    427       if (!context->hasServer) context->client->checkBuffers(); 
     427      if (!context->hasServer) context->checkBuffersAndListen(); 
    428428 
    429429      CArray<double, 3>data(data_k8, shape(data_Xsize, data_Ysize, data_Zsize), neverDeleteData); 
    … …  
    442442      CTimer::get("XIOS send field").resume(); 
    443443      CContext* context = CContext::getCurrent(); 
    444       if (!context->hasServer) context->client->checkBuffers(); 
     444      if (!context->hasServer) context->checkBuffersAndListen(); 
    445445 
    446446      CArray<float, 1> data_tmp(data_k4, shape(data_Xsize), neverDeleteData); 
    … …  
    461461 
    462462      CContext* context = CContext::getCurrent(); 
    463       if (!context->hasServer) context->client->checkBuffers(); 
     463      if (!context->hasServer) context->checkBuffersAndListen(); 
    464464 
    465465      CArray<float, 1> data_tmp(data_k4, shape(data_Xsize), neverDeleteData); 
    … …  
    481481 
    482482      CContext* context = CContext::getCurrent(); 
    483       if (!context->hasServer) context->client->checkBuffers(); 
     483      if (!context->hasServer) context->checkBuffersAndListen(); 
    484484 
    485485      CArray<float, 2> data_tmp(data_k4, shape(data_Xsize, data_Ysize), neverDeleteData); 
    … …  
    501501 
    502502      CContext* context = CContext::getCurrent(); 
    503       if (!context->hasServer) context->client->checkBuffers(); 
     503      if (!context->hasServer) context->checkBuffersAndListen(); 
    504504 
    505505      CArray<float, 3> data_tmp(data_k4, shape(data_Xsize, data_Ysize, data_Zsize), neverDeleteData); 
    … …  
    523523 
    524524      CContext* context = CContext::getCurrent(); 
    525       if (!context->hasServer) context->client->checkBuffers(); 
     525      if (!context->hasServer) context->checkBuffersAndListen(); 
    526526 
    527527      CArray<double, 1> data(data_k8, shape(data_Xsize), neverDeleteData); 
    … …  
    541541 
    542542      CContext* context = CContext::getCurrent(); 
    543       if (!context->hasServer) context->client->checkBuffers(); 
     543      if (!context->hasServer) context->checkBuffersAndListen(); 
    544544 
    545545      CArray<double, 2>data(data_k8, shape(data_Xsize, data_Ysize), neverDeleteData); 
    … …  
    559559 
    560560      CContext* context = CContext::getCurrent(); 
    561       if (!context->hasServer) context->client->checkBuffers(); 
     561      if (!context->hasServer) context->checkBuffersAndListen(); 
    562562 
    563563      CArray<double, 3>data(data_k8, shape(data_Xsize, data_Ysize, data_Zsize), neverDeleteData); 
    … …  
    577577 
    578578      CContext* context = CContext::getCurrent(); 
    579       if (!context->hasServer) context->client->checkBuffers(); 
     579      if (!context->hasServer) context->checkBuffersAndListen(); 
    580580 
    581581      CArray<double, 1> data(data_Xsize); 
    … …  
    597597 
    598598      CContext* context = CContext::getCurrent(); 
    599       if (!context->hasServer) context->client->checkBuffers(); 
     599      if (!context->hasServer) context->checkBuffersAndListen(); 
    600600 
    601601      CArray<double, 2> data(data_Xsize, data_Ysize); 
    … …  
    617617 
    618618      CContext* context = CContext::getCurrent(); 
    619       if (!context->hasServer) context->client->checkBuffers(); 
     619      if (!context->hasServer) context->checkBuffersAndListen(); 
    620620 
    621621      CArray<double, 3> data(data_Xsize, data_Ysize, data_Zsize); 
Note: See TracChangeset for help on using the changeset viewer.