RhodeCode

    TEMPLATE_DIGRAPH_TYPEDEFS(GR);

    typedef std::vector<int> IntVector;

    typedef std::vector<Value> ValueVector;

    typedef std::vector<Cost> CostVector;

  private:

    {

    private:

      int _node_num;

      const IntVector &_first_out;

      const IntVector &_target;

      const CostVector &_cost;

      const ValueVector &_res_cap;

    public:

      ResidualDijkstra(CapacityScaling& cs) :

      {}

      int run(int s, Value delta = 1) {

        RangeMap<int> heap_cross_ref(_node_num, Heap::PRE_HEAP);

          _proc_nodes.push_back(u);

          heap.pop();

          // Traverse outgoing residual arcs

            if (_res_cap[a] < delta) continue;

            v = _target[a];

            switch (heap.state(v)) {

              case Heap::PRE_HEAP:

        _sum_supply += _supply[i];

      }

      if (_sum_supply > 0) return INFEASIBLE;

      for (int i = 0; i != _root; ++i) {

        _pi[i] = 0;

        _excess[i] = _supply[i];

      }

      // Remove non-zero lower bounds

      if (_have_lower) {

        for (int i = 0; i != _root; ++i) {

            if (_forward[j]) {

              Value c = _lower[j];

              if (c >= 0) {

              } else {

              }

              _excess[i] -= c;

              _excess[_target[j]] += c;

            } else {

        }

      }

      // Handle negative costs

          }

        }

      }

      if (_sum_supply < 0) {

        _pi[_root] = 0;

        _excess[_root] = -_sum_supply;

        for (int a = _first_out[_root]; a != _res_arc_num; ++a) {

          _cost[a] = 0;

        }

      } else {

        _pi[_root] = 0;

        _excess[_root] = 0;

        for (int a = _first_out[_root]; a != _res_arc_num; ++a) {

          _res_cap[a] = 1;

          _cost[a] = 0;

        }

      }

      // Initialize delta value

      if (_factor > 1) {

        // With scaling

        Value max_sup = 0, max_dem = 0;

        for (int i = 0; i != _node_num; ++i) {

        }

        Value max_cap = 0;

        for (int j = 0; j != _res_arc_num; ++j) {

          if (_res_cap[j] > max_cap) max_cap = _res_cap[j];

        pt = startWithoutScaling();

      // Handle non-zero lower bounds

      if (_have_lower) {

          if (!_forward[j]) _res_cap[j] += _lower[j];

        }

      }

      int s, t;

      ResidualDijkstra _dijkstra(*this);

      while (true) {

        // Saturate all arcs not satisfying the optimality condition

        for (int u = 0; u != _node_num; ++u) {

            int v = _target[a];

            Cost c = _cost[a] + _pi[u] - _pi[v];

            Value rc = _res_cap[a];

            if (c < 0 && rc >= _delta) {

        // Find excess nodes and deficit nodes

        _excess_nodes.clear();

        _deficit_nodes.clear();

        for (int u = 0; u != _node_num; ++u) {

        }

        int next_node = 0, next_def_node = 0;

        // Find augmenting shortest paths

    TEMPLATE_DIGRAPH_TYPEDEFS(GR);

    typedef std::vector<int> IntVector;

    typedef std::vector<Value> ValueVector;

    typedef std::vector<Cost> CostVector;

    // State constants for arcs

    IntVector _rev_thread;

    IntVector _succ_num;

    IntVector _last_succ;

    IntVector _dirty_revs;

    int _root;

    // Temporary data used in the current pivot iteration

    int in_arc, join, u_in, v_in, u_out, v_out;

    int first, second, right, last;

    int stem, par_stem, new_stem;

    Value delta;

  public:

    /// \brief Constant for infinite upper bounds (capacities).

      // References to the NetworkSimplex class

      const IntVector  &_source;

      const IntVector  &_target;

      const CostVector &_cost;

      const CostVector &_pi;

      int &_in_arc;

      int _search_arc_num;

      // References to the NetworkSimplex class

      const IntVector  &_source;

      const IntVector  &_target;

      const CostVector &_cost;

      const CostVector &_pi;

      int &_in_arc;

      int _search_arc_num;

      // References to the NetworkSimplex class

      const IntVector  &_source;

      const IntVector  &_target;

      const CostVector &_cost;

      const CostVector &_pi;

      int &_in_arc;

      int _search_arc_num;

      // References to the NetworkSimplex class

      const IntVector  &_source;

      const IntVector  &_target;

      const CostVector &_cost;

      const CostVector &_pi;

      int &_in_arc;

      int _search_arc_num;

      // References to the NetworkSimplex class

      const IntVector  &_source;

      const IntVector  &_target;

      const CostVector &_cost;

      const CostVector &_pi;

      int &_in_arc;

      int _search_arc_num;

    /// In special cases, it could lead to better overall performance,

    /// but it is usually slower. Therefore it is disabled by default.

    NetworkSimplex(const GR& graph, bool arc_mixing = false) :

      _graph(graph), _node_id(graph), _arc_id(graph),

      INF(std::numeric_limits<Value>::has_infinity ?

    {

      // Check the value types

      LEMON_ASSERT(std::numeric_limits<Value>::is_signed,

        "The flow type of NetworkSimplex must be signed");

      if (_have_lower) {

        for (int i = 0; i != _arc_num; ++i) {

          Value c = _lower[i];

          if (c >= 0) {

          } else {

          }

          _supply[_source[i]] -= c;

          _supply[_target[i]] += c;

        }

      // Search the cycle along the path form the first node to the root

      for (int u = first; u != join; u = _parent[u]) {

        e = _pred[u];

        d = _forward[u] ?

        if (d < delta) {

          delta = d;

          u_out = u;

          result = 1;

      // Search the cycle along the path form the second node to the root

      for (int u = second; u != join; u = _parent[u]) {

        e = _pred[u];

        d = _forward[u] ? 

        if (d <= delta) {

          delta = d;

          u_out = u;

          result = 2;

      // Execute the Network Simplex algorithm

      while (pivot.findEnteringArc()) {

        findJoinNode();

        bool change = findLeavingArc();

        changeFlow(change);

        if (change) {

          updateTreeStructure();

          updatePotential();