MCPcopy Create free account
hub / github.com/brainflow-dev/brainflow / delete_streamer

Method delete_streamer

src/board_controller/board.cpp:330–371  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

328}
329
330int Board::delete_streamer (const char *streamer_params, int preset)
331{
332 if (streamers.find (preset) == streamers.end ())
333 {
334 safe_logger (spdlog::level::err, "no such streaming preset");
335 return (int)BrainFlowExitCodes::INVALID_ARGUMENTS_ERROR;
336 }
337 std::string streamer_type = "";
338 std::string streamer_dest = "";
339 std::string streamer_mods = "";
340 int res = parse_streamer_params (streamer_params, streamer_type, streamer_dest, streamer_mods);
341 if (res != (int)BrainFlowExitCodes::STATUS_OK)
342 {
343 return res;
344 }
345
346 std::vector<Streamer *>::iterator it = streamers[preset].begin ();
347 res = (int)BrainFlowExitCodes::INVALID_ARGUMENTS_ERROR;
348 while (it != streamers[preset].end ())
349 {
350 if ((*it)->check_equals (streamer_type, streamer_dest, streamer_mods))
351 {
352 lock.lock ();
353 delete *it;
354 it = streamers[preset].erase (it);
355 lock.unlock ();
356 res = (int)BrainFlowExitCodes::STATUS_OK;
357 safe_logger (spdlog::level::info, "streamer {} removed", streamer_params);
358 break;
359 }
360 else
361 {
362 it++;
363 }
364 }
365
366 if (res != (int)BrainFlowExitCodes::STATUS_OK)
367 {
368 safe_logger (spdlog::level::err, "no such streamer found");
369 }
370 return res;
371}
372
373int Board::parse_streamer_params (const char *streamer_params, std::string &streamer_type,
374 std::string &streamer_dest, std::string &streamer_mods)

Callers

nothing calls this directly

Calls 3

check_equalsMethod · 0.80
lockMethod · 0.45
unlockMethod · 0.45

Tested by

no test coverage detected