60
60
void mcl::ConnectionSurfaceMap::with_stream_do(
61
mf::BufferStreamId stream_id, std::function<void(BufferReceiver*)> const& exec) const
61
mf::BufferStreamId stream_id, std::function<void(ClientBufferStream*)> const& exec) const
63
63
std::shared_lock<decltype(guard)> lk(guard);
64
64
auto const it = streams.find(stream_id);
79
void mcl::ConnectionSurfaceMap::with_all_streams_do(std::function<void(BufferReceiver*)> const& fn) const
79
void mcl::ConnectionSurfaceMap::with_all_streams_do(std::function<void(ClientBufferStream*)> const& fn) const
81
81
std::shared_lock<decltype(guard)> lk(guard);
82
82
for(auto const& stream : streams)
86
86
void mcl::ConnectionSurfaceMap::insert(
87
mf::BufferStreamId stream_id, std::shared_ptr<BufferReceiver> const& stream)
87
mf::BufferStreamId stream_id, std::shared_ptr<ClientBufferStream> const& stream)
89
89
std::lock_guard<decltype(guard)> lk(guard);
90
90
streams[stream_id] = stream;
93
void mcl::ConnectionSurfaceMap::insert(
94
mf::BufferStreamId stream_id, std::shared_ptr<MirPresentationChain> const& chain)
96
std::lock_guard<decltype(stream_guard)> lk(stream_guard);
97
chains[stream_id] = chain;
93
100
void mcl::ConnectionSurfaceMap::erase(mf::BufferStreamId stream_id)
95
102
std::lock_guard<decltype(guard)> lk(guard);
96
streams.erase(stream_id);
103
auto stream_it = streams.find(stream_id);
104
auto chain_it = chains.find(stream_id);
105
if (stream_it != streams.end())
106
streams.erase(stream_it);
107
if (chain_it != chains.end())
108
chains.erase(chain_it);
99
void mcl::ConnectionSurfaceMap::insert(int buffer_id, std::shared_ptr<mcl::Buffer> const& buffer)
111
void mcl::ConnectionSurfaceMap::insert(int buffer_id, std::shared_ptr<mcl::MirBuffer> const& buffer)
101
113
std::lock_guard<decltype(guard)> lk(guard);
102
114
buffers[buffer_id] = buffer;
108
120
buffers.erase(buffer_id);
111
std::shared_ptr<mcl::Buffer> mcl::ConnectionSurfaceMap::buffer(int buffer_id) const
123
std::shared_ptr<mcl::MirBuffer> mcl::ConnectionSurfaceMap::buffer(int buffer_id) const
113
125
std::shared_lock<decltype(guard)> lk(guard);
114
126
auto const it = buffers.find(buffer_id);