diff --git a/visionipc/visionipc_client.cc b/visionipc/visionipc_client.cc
index fa9e5a4..d46cc0e 100644
--- a/visionipc/visionipc_client.cc
+++ b/visionipc/visionipc_client.cc
@@ -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;
diff --git a/visionipc/visionipc_client.h b/visionipc/visionipc_client.h
index a14695a..4699762 100644
--- a/visionipc/visionipc_client.h
+++ b/visionipc/visionipc_client.h
@@ -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);
 };