No flags found
Use flags to group coverage reports by test type, project and/or folders.
Then setup custom commit statuses and notifications for each flag.
e.g., #unittest #integration
#production #enterprise
#frontend #backend
9eb59c4
... +1 ...
957e5a4
Use flags to group coverage reports by test type, project and/or folders.
Then setup custom commit statuses and notifications for each flag.
e.g., #unittest #integration
#production #enterprise
#frontend #backend
257 | 257 | return 0; |
|
258 | 258 | } |
|
259 | 259 | } |
|
260 | - | auto sz = socket_.send(asio::buffer(buffer, dataLength)); |
|
261 | - | assert(sz == dataLength); |
|
262 | - | return sz; |
|
260 | + | ||
261 | + | size_t sz,sent_size; |
|
262 | + | int p=0,count=0; |
|
263 | + | sent_size=dataLength; |
|
264 | + | while (count++ < 5 && (sz = socket_.send(asio::buffer((void *)((char *)buffer+p), sent_size))) != sent_size) { |
|
265 | + | sent_size-=sz; p+=sz; |
|
266 | + | // std::cerr << "DEBUG partial buffer sent" << std::endl; |
|
267 | + | } |
|
268 | + | if(count < 5 ) return dataLength; |
|
269 | + | else { std::cerr << "TcpConnection send terminated " << std:: endl; return 0; } |
|
270 | + | ||
271 | + | // assert(sz == dataLength); |
|
272 | + | // return sz; |
|
263 | 273 | } |
|
264 | 274 | ||
265 | 275 | size_t TcpConnection::send(const std::string& dataString) |
|
266 | 276 | { |
|
277 | + | size_t sz; |
|
278 | + | sz = send(&dataString[0],dataString.size()); |
|
279 | + | return sz; |
|
280 | + | /* |
|
267 | 281 | if (!isConnected()) { |
|
268 | 282 | if (!waitUntilConnected(300ms)) { |
|
269 | 283 | std::cerr << "connection timeout waiting again" << std::endl; |
276 | 290 | auto sz = socket_.send(asio::buffer(dataString)); |
|
277 | 291 | assert(sz == dataString.size()); |
|
278 | 292 | return sz; |
|
293 | + | */ |
|
279 | 294 | } |
|
280 | 295 | ||
281 | 296 | size_t TcpConnection::receive(void* buffer, size_t maxDataSize) |
Learn more Showing 11 files with coverage changes found.
src/helics/network/ipc/IpcQueueHelper.cpp
src/helics/core/FederateState.hpp
src/helics/network/zmq/ZmqCommsSS.cpp
src/helics/network/NetworkCommsInterface.cpp
src/helics/network/CommsInterface.cpp
src/helics/core/CoreBroker.cpp
src/helics/core/CommonCore.cpp
src/helics/core/TimeCoordinator.cpp
src/helics/core/ActionMessage.cpp
src/helics/network/tcp/TcpHelperClasses.cpp
src/helics/network/zmq/ZmqComms.cpp
Files | Coverage |
---|---|
src/helics | -0.01% 76.92% |
Project Totals (210 files) | 76.92% |
957e5a4
b70ff64
9eb59c4