github-actions[bot]
f9fcc7adab
date: 2026-06-28T09:48:35 master commit: da6313dbe95b3f24bb5d8018b0e5f950f5823ca7
41 lines
1.1 KiB
C++
41 lines
1.1 KiB
C++
#pragma once
|
|
#include <vector>
|
|
#include <string>
|
|
#include <thread>
|
|
#include <atomic>
|
|
#include <map>
|
|
|
|
#include "msgq/ipc.h"
|
|
#include "msgq/visionipc/visionbuf.h"
|
|
|
|
std::string get_endpoint_name(std::string name, VisionStreamType type);
|
|
std::string get_ipc_path(const std::string &name);
|
|
|
|
class VisionIpcServer {
|
|
private:
|
|
uint64_t server_id;
|
|
|
|
std::atomic<bool> should_exit = false;
|
|
std::string name;
|
|
std::thread listener_thread;
|
|
|
|
std::map<VisionStreamType, std::atomic<size_t> > cur_idx;
|
|
std::map<VisionStreamType, std::vector<VisionBuf*> > buffers;
|
|
|
|
Context * msg_ctx;
|
|
std::map<VisionStreamType, PubSocket*> sockets;
|
|
|
|
void listener(void);
|
|
|
|
public:
|
|
VisionIpcServer(std::string name);
|
|
~VisionIpcServer();
|
|
|
|
VisionBuf * get_buffer(VisionStreamType type, int idx = -1);
|
|
|
|
void create_buffers(VisionStreamType type, size_t num_buffers, size_t width, size_t height);
|
|
void create_buffers_with_sizes(VisionStreamType type, size_t num_buffers, size_t width, size_t height, size_t size, size_t stride, size_t uv_offset);
|
|
void send(VisionBuf * buf, VisionIpcBufExtra * extra, bool sync=true);
|
|
void start_listener();
|
|
};
|