Build has been canceled!

15613307699

Committed 12 Jun 2025 02:27PM UTC coverage: 61.1% (+0.2%) from 60.871%

Build # 15613307699

Build Type

push

github

Committed by

web-flow

Commit Message

Add thread barrier (#69)

* thread barrier definition

* define thread barrier dispatcher

* renameing

* refactor and node definition + serializer

* Constructor update

* integration analog to dispatcher registration

* add dispatcher test

* default dispatcher simplification

* simplify test

* Public symbol definition

Run Details

64 of 95 new or added lines in 11 files covered. (67.37%)

4 existing lines in 2 files now uncovered.

6641 of 10869 relevant lines covered (61.1%)

99.73 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

75.0

/src/serializer/library_node_serializer_registry.cpp

#include "sdfg/serializer/library_node_serializer_registry.h"

#include <string>

#include "sdfg/data_flow/library_node.h"
#include "sdfg/serializer/library_nodes/barrier_local_node_serializer.h"

namespace sdfg {
namespace serializer {

void LibraryNodeSerializerRegistry::register_library_node_serializer(
    std::string_view library_node_code, LibraryNodeSerializerFn fn) {
    std::lock_guard<std::mutex> lock(mutex_);
    if (factory_map_.find(library_node_code) != factory_map_.end()) {
        throw std::runtime_error(
            "Library node serializer already registered for library node code: " +
            std::string(library_node_code));
    }
    factory_map_[library_node_code] = std::move(fn);
}

LibraryNodeSerializerFn LibraryNodeSerializerRegistry::get_library_node_serializer(
    std::string_view library_node_code) {
    auto it = factory_map_.find(library_node_code);
    if (it != factory_map_.end()) {
        return it->second;
    }
    return nullptr;
}

size_t LibraryNodeSerializerRegistry::size() const { return factory_map_.size(); }

void register_default_serializers() {
    LibraryNodeSerializerRegistry::instance().register_library_node_serializer(
        data_flow::BARRIER_LOCAL.value(),
        []() { return std::make_unique<serializer::BarrierLocalNodeSerializer>(); });
    // Add more serializers as needed
}

}  // namespace serializer
}  // namespace sdfg

1	#include "sdfg/serializer/library_node_serializer_registry.h"
2
3	#include <string>
4
5	#include "sdfg/data_flow/library_node.h"
6	#include "sdfg/serializer/library_nodes/barrier_local_node_serializer.h"
7
8	namespace sdfg {
9	namespace serializer {
10
11	void LibraryNodeSerializerRegistry::register_library_node_serializer(	2✔
12	std::string_view library_node_code, LibraryNodeSerializerFn fn) {
13	std::lock_guard<std::mutex> lock(mutex_);	2✔
14	if (factory_map_.find(library_node_code) != factory_map_.end()) {	2✔
NEW 15	throw std::runtime_error(	×
NEW 16	"Library node serializer already registered for library node code: " +	×
NEW 17	std::string(library_node_code));	×
18	}
19	factory_map_[library_node_code] = std::move(fn);	2✔
20	}	2✔
21
22	LibraryNodeSerializerFn LibraryNodeSerializerRegistry::get_library_node_serializer(	1✔
23	std::string_view library_node_code) {
24	auto it = factory_map_.find(library_node_code);	1✔
25	if (it != factory_map_.end()) {	1✔
26	return it->second;	1✔
27	}
NEW 28	return nullptr;	×
29	}	1✔
30
NEW 31	size_t LibraryNodeSerializerRegistry::size() const { return factory_map_.size(); }	×
32
33	void register_default_serializers() {	2✔
34	LibraryNodeSerializerRegistry::instance().register_library_node_serializer(	4✔
35	data_flow::BARRIER_LOCAL.value(),	2✔
36	[]() { return std::make_unique<serializer::BarrierLocalNodeSerializer>(); });	3✔
37	// Add more serializers as needed
38	}	2✔
39
40	} // namespace serializer
41	} // namespace sdfg

daisytuner / sdfglib / 15613307699

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous