edge_disjoint_paths_driver.h File Reference

#include "c_types/pgr_edge_t.h"
#include "c_types/general_path_element_t.h"

Include dependency graph for edge_disjoint_paths_driver.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
void	do_pgr_edge_disjoint_paths (pgr_edge_t *data_edges, size_t total_tuples, int64_t *source_vertices, size_t size_source_verticesArr, int64_t *sink_vertices, size_t size_sink_verticesArr, bool directed, General_path_element_t **return_tuples, size_t *return_count, char **log_msg, char **notice_msg, char **err_msg)

Function Documentation

void do_pgr_edge_disjoint_paths	(	pgr_edge_t *	data_edges,
		size_t	total_tuples,
		int64_t *	source_vertices,
		size_t	size_source_verticesArr,
		int64_t *	sink_vertices,
		size_t	size_sink_verticesArr,
		bool	directed,
		General_path_element_t **	return_tuples,
		size_t *	return_count,
		char **	log_msg,
		char **	notice_msg,
		char **	err_msg
	)

Definition at line 66 of file edge_disjoint_paths_driver.cpp.

References General_path_element_t::agg_cost, pgr_alloc(), pgr_free(), pgr_msg(), single_execution(), and AssertFailedException::what().

Referenced by process().

                    {
    std::ostringstream log;
    std::ostringstream notice;
    std::ostringstream err;
    try {
        std::set<int64_t> set_source_vertices(
                sources, sources + size_source_verticesArr);
        std::set<int64_t> set_sink_vertices(
                sinks, sinks + size_sink_verticesArr);
        std::vector<pgr_edge_t> edges(
                data_edges, data_edges + total_edges);


        std::vector<General_path_element_t> paths;
        for (const auto &s : set_source_vertices) {
            for (const auto &t : set_sink_vertices) {
                auto path = single_execution(
                        edges,
                        s,
                        t,
                        directed);
                paths.insert(paths.end(), path.begin(), path.end());
            }
        }

        if (paths.empty()) {
            *return_tuples = nullptr;
            *return_count = 0;
            return;
        }

        /*
         * Initializing the cost
         */
        for (auto &r : paths) {
            r.agg_cost = r.cost = 0;
        }

        /*
         * Calculating the cost
         */
        auto found = paths.size();
        for (const auto &e : edges) {
            for (auto &r : paths) {
                if (r.edge == e.id) {
                    r.cost = (r.node == e.source) ?
                        e.cost : e.reverse_cost;
                    --found;
                }
            }
            if (found == 0) break;
        }

        /*
         * Calculating the agg_cost
         */
        auto prev = paths[0];
        for (auto &r : paths) {
            if (r.seq == 1) {
                r.agg_cost = 0;
            } else {
                r.agg_cost = prev.agg_cost + prev.cost;
            }
            prev = r;
        }

        /*
         * Numbering the paths
         */
        int path_id(0);
        for (auto &r : paths) {
            r.start_id = path_id;
            if (r.edge == -1) ++path_id;
        }


        (*return_tuples) = pgr_alloc(paths.size(), (*return_tuples));
        for (size_t i = 0; i < paths.size(); ++i) {
            (*return_tuples)[i] = paths[i];
        }
        *return_count = paths.size();


        *log_msg = log.str().empty()?
            *log_msg :
            pgr_msg(log.str().c_str());
        *notice_msg = notice.str().empty()?
            *notice_msg :
            pgr_msg(notice.str().c_str());
    } catch (AssertFailedException &except) {
        (*return_tuples) = pgr_free(*return_tuples);
        (*return_count) = 0;
        err << except.what();
        *err_msg = pgr_msg(err.str().c_str());
        *log_msg = pgr_msg(log.str().c_str());
    } catch (std::exception &except) {
        (*return_tuples) = pgr_free(*return_tuples);
        (*return_count) = 0;
        err << except.what();
        *err_msg = pgr_msg(err.str().c_str());
        *log_msg = pgr_msg(log.str().c_str());
    } catch(...) {
        (*return_tuples) = pgr_free(*return_tuples);
        (*return_count) = 0;
        err << "Caught unknown exception!";
        *err_msg = pgr_msg(err.str().c_str());
        *log_msg = pgr_msg(log.str().c_str());
    }
}

Here is the call graph for this function:

Here is the caller graph for this function: