interval_intersection.hpp
Go to the documentation of this file.
1 /**********************************************************************
2  *
3  * Software License Agreement (BSD License)
4  *
5  * Copyright (c) 2009, Willow Garage, Inc.
6  * All rights reserved.
7  *
8  * Redistribution and use in source and binary forms, with or without
9  * modification, are permitted provided that the following conditions
10  * are met:
11  *
12  * * Redistributions of source code must retain the above copyright
13  * notice, this list of conditions and the following disclaimer.
14  * * Redistributions in binary form must reproduce the above
15  * copyright notice, this list of conditions and the following
16  * disclaimer in the documentation and/or other materials provided
17  * with the distribution.
18  * * Neither the name of the Willow Garage nor the names of its
19  * contributors may be used to endorse or promote products derived
20  * from this software without specific prior written permission.
21  *
22  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
23  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
24  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
25  * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
26  * COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
27  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
28  * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
29  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
30  * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
31  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
32  * ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
33  * POSSIBILITY OF SUCH DAMAGE.
34  *********************************************************************/
35 
36 #include <vector>
37 #include <deque>
38 
39 #include <boost/function.hpp>
40 #include <boost/thread/mutex.hpp>
41 #include "calibration_msgs/Interval.h"
42 #include "calibration_msgs/IntervalStatus.h"
43 
44 using namespace std;
45 
47 {
61 public:
62  IntervalIntersector(boost::function<void (const calibration_msgs::Interval&)> output_callback);
64 
65  boost::function<void (const calibration_msgs::IntervalConstPtr&)> getNewInputStream();
66 
67  calibration_msgs::IntervalStatus get_status();
68 
69 private:
76  void inputCallback(const calibration_msgs::IntervalConstPtr& interval_ptr, size_t i);
77  void process_queues();
78 
79  struct queue_stat {
80  int count;
81  int nil_count;
82  };
83 
84  vector<deque<calibration_msgs::IntervalConstPtr> > queues;
85  vector<boost::shared_ptr<queue_stat> > queue_stats;
86  vector<boost::shared_ptr<boost::mutex> > mutexes; // Protects the individual queues
87  boost::mutex processing_mutex; // Protects the consumption of elements from the set of queues
88  size_t max_queue_size; // must be greater than 0, or all messages will be dropped
89  boost::function<void (const calibration_msgs::Interval&)> output_callback_; // Call this function on each output interval
90 
91 
92 }; // end class
93 
94 }
vector< boost::shared_ptr< queue_stat > > queue_stats
vector< deque< calibration_msgs::IntervalConstPtr > > queues
vector< boost::shared_ptr< boost::mutex > > mutexes
boost::function< void(const calibration_msgs::Interval &)> output_callback_


interval_intersection
Author(s): Romain Thibaux
autogenerated on Thu Jun 6 2019 19:17:22