Multiscale Universal Interface  2.0
A Concurrent Framework for Coupling Heterogeneous Solvers
reader_variable.h
Go to the documentation of this file.
1 /*****************************************************************************
2 * Multiscale Universal Interface Code Coupling Library *
3 * *
4 * Copyright (C) 2019 Y. H. Tang, S. Kudo, X. Bian, Z. Li, G. E. Karniadakis *
5 * *
6 * This software is jointly licensed under the Apache License, Version 2.0 *
7 * and the GNU General Public License version 3, you may use it according *
8 * to either. *
9 * *
10 * ** Apache License, version 2.0 ** *
11 * *
12 * Licensed under the Apache License, Version 2.0 (the "License"); *
13 * you may not use this file except in compliance with the License. *
14 * You may obtain a copy of the License at *
15 * *
16 * http://www.apache.org/licenses/LICENSE-2.0 *
17 * *
18 * Unless required by applicable law or agreed to in writing, software *
19 * distributed under the License is distributed on an "AS IS" BASIS, *
20 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. *
21 * See the License for the specific language governing permissions and *
22 * limitations under the License. *
23 * *
24 * ** GNU General Public License, version 3 ** *
25 * *
26 * This program is free software: you can redistribute it and/or modify *
27 * it under the terms of the GNU General Public License as published by *
28 * the Free Software Foundation, either version 3 of the License, or *
29 * (at your option) any later version. *
30 * *
31 * This program is distributed in the hope that it will be useful, *
32 * but WITHOUT ANY WARRANTY; without even the implied warranty of *
33 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
34 * GNU General Public License for more details. *
35 * *
36 * You should have received a copy of the GNU General Public License *
37 * along with this program. If not, see <http://www.gnu.org/licenses/>. *
38 *****************************************************************************/
39 
48 #ifndef READER_VARIABLE_H_
49 #define READER_VARIABLE_H_
50 
51 #include <tuple>
52 #include <functional>
53 #include <utility>
54 #include "message.h"
55 #include "../../storage/stream.h"
56 #include "../../storage/stream_tuple.h"
57 #include "../../storage/stream_string.h"
58 
59 namespace mui
60 {
61 
62 // parse message as variables and pass them to f as arguments of it
63 template<typename... Args>
65  typedef std::function<void(Args...)> function_type;
66  typedef std::tuple<typename std::remove_reference<Args>::type...> tuple_type;
67 
68  reader_variables() = default;
69  reader_variables( function_type f ) : f_(std::move(f)) {}
70  void operator()( const message& msg ){
71  // parse msg as tuple of variables
72  auto stream = make_istream(msg.data());
73  tuple_type t;
74  stream >> t;
75  // split tuple before applying
76  apply(t, typename make_index_sequence<sizeof...(Args)>::type());
77  }
78 private:
79  template<std::size_t... indexes>
80  void apply( tuple_type& t, index_sequence<indexes...> ){
81  f_(std::get<indexes>(std::move(t))...);
82  }
83  function_type f_;
84 };
85 
86 }
87 
88 
89 #endif /* READER_VARIABLE_H_ */
Structure to contain and manipulate data from internal data to MPI message.
Definition: comm.h:54
iitr_stream< ConstInputIterator > make_istream(ConstInputIterator begin)
Definition: stream.h:118
Definition: stream_tuple.h:60
Definition: stream_tuple.h:64
Definition: message.h:61
const char * data() const
Definition: message.h:94
Definition: reader_variable.h:64
std::function< void(Args...)> function_type
Definition: reader_variable.h:65
reader_variables(function_type f)
Definition: reader_variable.h:69
void operator()(const message &msg)
Definition: reader_variable.h:70
std::tuple< typename std::remove_reference< Args >::type... > tuple_type
Definition: reader_variable.h:66
reader_variables()=default