mawei/msgq
1
0
Fork 0
mirror of https://github.com/commaai/msgq.git synced 2026-06-13 00:14:32 +08:00
Code Issues Packages Projects Releases Wiki Activity

visionipc add timeout param

Browse Source
This commit is contained in:
Willem Melching
2021-01-19 14:45:59 +01:00
parent bbf05d546a
commit 610fa77bc4
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
visionipc/visionipc_client.cc
View File

@@ -72,8 +72,8 @@ bool VisionIpcClient::connect(bool blocking){
return true;
}
VisionBuf * VisionIpcClient::recv(VisionIpcBufExtra * extra){
auto p = poller->poll(100);
VisionBuf * VisionIpcClient::recv(VisionIpcBufExtra * extra, const int timeout_ms){
auto p = poller->poll(timeout_ms);
if (!p.size()){
return nullptr;

2
visionipc/visionipc_client.h
View File

@@ -27,6 +27,6 @@ public:
VisionBuf buffers[VISIONIPC_MAX_FDS];
VisionIpcClient(std::string name, VisionStreamType type, bool conflate, cl_device_id device_id=nullptr, cl_context ctx=nullptr);
~VisionIpcClient();
VisionBuf * recv(VisionIpcBufExtra * extra=nullptr);
VisionBuf * recv(VisionIpcBufExtra * extra=nullptr, const int timeout_ms=100);
bool connect(bool blocking=true);
};