-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathZmqMessageTemplateImpl_8hpp-source.html
More file actions
122 lines (112 loc) · 7.88 KB
/
ZmqMessageTemplateImpl_8hpp-source.html
File metadata and controls
122 lines (112 loc) · 7.88 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
<html>
<head>
<meta name="keywords" content="0MQ, ZeroMQ, C++, multipart, message, library, open source, ZmqMessage" />
<meta name="description" content="ZmqMessage is free open source C++ library for sending and receiving ZeroMQ multipart messages"/>
<meta name="google-site-verification" content="0EvtpfjffSrc0fDV9ubKQVfq3IV55KY5d59hXHg9M34" />
<title>ZmqMessage: include/zmqmessage/ZmqMessageTemplateImpl.hpp Source File</title>
<link href="doxygen.css" rel="stylesheet" type="text/css">
<style>
/* must override a few items to get the style background color */
</style>
<script type="text/javascript">
var _gaq = _gaq || [];
_gaq.push(['_setAccount', 'UA-25607292-1']);
_gaq.push(['_trackPageview']);
(function() {
var ga = document.createElement('script'); ga.type = 'text/javascript'; ga.async = true;
ga.src = ('https:' == document.location.protocol ? 'https://ssl' : 'http://www') + '.google-analytics.com/ga.js';
var s = document.getElementsByTagName('script')[0]; s.parentNode.insertBefore(ga, s);
})();
</script>
</head>
<body>
<table class="zm_headbar">
<tr>
<td>
<span><a href="index.html">Overview</a></span>
<span><a href="zm_tutorial.html">Tutorial</a></span>
<span><a href="namespaceZmqMessage.html">API reference</a></span>
<span><a href="examples.html">Examples</a></span>
<span><a href="zm_build.html">Build</a></span>
<span><a href="https://github.com/zmqmessage/zmqmessage/">Download</a></span>
</td>
<td align="right" class="zm_greynote">ZmqMessage 0.1 - 21 Oct 2011</td>
</tr></table>
<hr style="height: 3px;">
<!-- Generated by Doxygen 1.4.7 -->
<h1>include/zmqmessage/ZmqMessageTemplateImpl.hpp</h1><a href="ZmqMessageTemplateImpl_8hpp.html">Go to the documentation of this file.</a><div class="fragment"><pre class="fragment"><a name="l00001"></a>00001
<a name="l00011"></a>00011 <span class="preprocessor">#include <functional></span>
<a name="l00012"></a>00012 <span class="preprocessor">#include <algorithm></span>
<a name="l00013"></a>00013
<a name="l00014"></a>00014 <span class="preprocessor">#include "<a class="code" href="TypeCheck_8hpp.html">zmqmessage/TypeCheck.hpp</a>"</span>
<a name="l00015"></a>00015
<a name="l00016"></a>00016 <span class="preprocessor">#ifndef ZMQMESSAGE_ZMQMESSAGETEMPLATEIMPL_HPP_</span>
<a name="l00017"></a>00017 <span class="preprocessor"></span><span class="preprocessor">#define ZMQMESSAGE_ZMQMESSAGETEMPLATEIMPL_HPP_</span>
<a name="l00018"></a>00018 <span class="preprocessor"></span>
<a name="l00020"></a>00020 <span class="comment">// definition of templates</span>
<a name="l00022"></a>00022 <span class="comment"></span>
<a name="l00023"></a>00023 <span class="keyword">namespace </span>ZmqMessage
<a name="l00024"></a>00024 {
<a name="l00025"></a>00025 <span class="keyword">template</span> <<span class="keyword">typename</span> T>
<a name="l00026"></a>00026 <span class="keywordtype">void</span>
<a name="l00027"></a>00027 Multipart::iterator<T>::set_cur()
<a name="l00028"></a>00028 {
<a name="l00029"></a>00029 <span class="keywordflow">if</span> (end())
<a name="l00030"></a>00030 {
<a name="l00031"></a>00031 <span class="keywordflow">return</span>;
<a name="l00032"></a>00032 }
<a name="l00033"></a>00033 <span class="keywordflow">if</span> (messages_[idx_] == 0)
<a name="l00034"></a>00034 {
<a name="l00035"></a>00035 cur_ = T();
<a name="l00036"></a>00036 <span class="keywordflow">return</span>;
<a name="l00037"></a>00037 }
<a name="l00038"></a>00038
<a name="l00039"></a>00039 <a class="code" href="namespaceZmqMessage.html#06c86c0cd57a00985048ef9b94b60729">get</a>(*(messages_[idx_]), cur_, binary_mode_);
<a name="l00040"></a>00040 }
<a name="l00041"></a>00041
<a name="l00042"></a>00042 <span class="keyword">template</span> <<span class="keyword">class</span> RoutingPolicy>
<a name="l00043"></a>00043 <span class="keyword">template</span> <<span class="keyword">typename</span> T>
<a name="l00044"></a>00044 Incoming<RoutingPolicy>&
<a name="l00045"></a><a class="code" href="classZmqMessage_1_1Incoming.html#2589167d16f5167c9b623177ac758bc4">00045</a> <a class="code" href="zserialize_8cpp.html#2003f48e44e50b1bb407aa687cb0d702">Incoming<RoutingPolicy>::operator>> </a>(T& t) <span class="keywordflow">throw</span>(<a class="code" href="classNoSuchPartError.html">NoSuchPartError</a>)
<a name="l00046"></a>00046 {
<a name="l00047"></a>00047 check_has_part(cur_extract_idx_);
<a name="l00048"></a>00048 <a class="code" href="namespaceZmqMessage.html#06c86c0cd57a00985048ef9b94b60729">get</a>(*(parts_[cur_extract_idx_++]), t, binary_mode_);
<a name="l00049"></a>00049 <span class="keywordflow">return</span> *<span class="keyword">this</span>;
<a name="l00050"></a>00050 }
<a name="l00051"></a>00051
<a name="l00052"></a>00052 <span class="keyword">template</span> <<span class="keyword">typename</span> T>
<a name="l00053"></a>00053 <a class="code" href="classZmqMessage_1_1Sink.html">Sink</a>&
<a name="l00054"></a><a class="code" href="classZmqMessage_1_1Sink.html#719c8dc843ef3fd7f939c8203a7a48c0">00054</a> <a class="code" href="zserialize_8cpp.html#bd928ecc2a13a7d0f595df82c74ac6ad">Sink::operator<< </a>(<span class="keyword">const</span> T& t) <span class="keywordflow">throw</span> (<a class="code" href="namespaceZmqMessage.html#b6d56fe86e2309d7182d41d2e0f3c76a">ZmqErrorType</a>)
<a name="l00055"></a>00055 {
<a name="l00056"></a>00056 MsgPtr msg(<span class="keyword">new</span> zmq::message_t);
<a name="l00057"></a>00057 <span class="keywordtype">bool</span> binary_mode = options_ & <a class="code" href="structZmqMessage_1_1OutOptions.html#7e32e290737ff0f3183b00c172bb291a">OutOptions::BINARY_MODE</a>;
<a name="l00058"></a>00058 <a class="code" href="namespaceZmqMessage.html#8d9fb5d43437f57a05635350f1abe1d1">init_msg</a>(t, *msg, binary_mode);
<a name="l00059"></a>00059 send_owned(msg.release());
<a name="l00060"></a>00060 <span class="keywordflow">return</span> *<span class="keyword">this</span>;
<a name="l00061"></a>00061 }
<a name="l00062"></a>00062
<a name="l00063"></a>00063 <span class="keyword">template</span> <<span class="keyword">class</span> OccupationAccumulator>
<a name="l00064"></a>00064 <span class="keywordtype">void</span>
<a name="l00065"></a><a class="code" href="classZmqMessage_1_1Sink.html#1ef6eee3938ecb86bc3cedb9297f8e4c">00065</a> <a class="code" href="classZmqMessage_1_1Sink.html#4446da06ade4c29686f7795b5dd1f256">Sink::relay_from</a>(
<a name="l00066"></a>00066 zmq::socket_t& relay_src, OccupationAccumulator acc)
<a name="l00067"></a>00067 <span class="keywordflow">throw</span> (<a class="code" href="namespaceZmqMessage.html#b6d56fe86e2309d7182d41d2e0f3c76a">ZmqErrorType</a>)
<a name="l00068"></a>00068 {
<a name="l00069"></a>00069 <span class="keywordflow">while</span> (<a class="code" href="namespaceZmqMessage.html#5a279539ebc2d608ad3dca51c9d041d1">has_more</a>(relay_src))
<a name="l00070"></a>00070 {
<a name="l00071"></a>00071 MsgPtr cur_part(<span class="keyword">new</span> zmq::message_t);
<a name="l00072"></a>00072 <a class="code" href="namespaceZmqMessage.html#939d571192cd3787f2c4c390aeb8ef99">recv_msg</a>(relay_src, *cur_part);
<a name="l00073"></a>00073 size_t sz = cur_part->size();
<a name="l00074"></a>00074 acc(sz);
<a name="l00075"></a>00075 send_owned(cur_part.release());
<a name="l00076"></a>00076 }
<a name="l00077"></a>00077 }
<a name="l00078"></a>00078 }
<a name="l00079"></a>00079
<a name="l00080"></a>00080 <span class="preprocessor">#endif </span><span class="comment">/* ZMQMESSAGE_ZMQMESSAGETEMPLATEIMPL_HPP_ */</span>
</pre></div>
<hr style="height: 3px;">
<div class="zm_greynote">
ZmqMessage 0.1 — open source software, <a href="mailto:support@zmqmessage.org">support@zmqmessage.org</a>
</div>
</body>
</html>