325 lines
54 KiB
HTML
325 lines
54 KiB
HTML
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "https://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
|
|
<html xmlns="http://www.w3.org/1999/xhtml">
|
|
<head>
|
|
<meta http-equiv="Content-Type" content="text/xhtml;charset=UTF-8"/>
|
|
<meta http-equiv="X-UA-Compatible" content="IE=9"/>
|
|
<meta name="generator" content="Doxygen 1.8.17"/>
|
|
<meta name="viewport" content="width=device-width, initial-scale=1"/>
|
|
<title>GRPC C++: include/grpcpp/support/proto_buffer_reader.h Source File</title>
|
|
<link href="tabs.css" rel="stylesheet" type="text/css"/>
|
|
<script type="text/javascript" src="jquery.js"></script>
|
|
<script type="text/javascript" src="dynsections.js"></script>
|
|
<link href="search/search.css" rel="stylesheet" type="text/css"/>
|
|
<script type="text/javascript" src="search/searchdata.js"></script>
|
|
<script type="text/javascript" src="search/search.js"></script>
|
|
<link href="doxygen.css" rel="stylesheet" type="text/css" />
|
|
</head>
|
|
<body>
|
|
<div id="top"><!-- do not remove this div, it is closed by doxygen! -->
|
|
<div id="titlearea">
|
|
<table cellspacing="0" cellpadding="0">
|
|
<tbody>
|
|
<tr style="height: 56px;">
|
|
<td id="projectalign" style="padding-left: 0.5em;">
|
|
<div id="projectname">GRPC C++
|
|
 <span id="projectnumber">1.64.0</span>
|
|
</div>
|
|
</td>
|
|
</tr>
|
|
</tbody>
|
|
</table>
|
|
</div>
|
|
<!-- end header part -->
|
|
<!-- Generated by Doxygen 1.8.17 -->
|
|
<script type="text/javascript">
|
|
/* @license magnet:?xt=urn:btih:cf05388f2679ee054f2beb29a391d25f4e673ac3&dn=gpl-2.0.txt GPL-v2 */
|
|
var searchBox = new SearchBox("searchBox", "search",false,'Search');
|
|
/* @license-end */
|
|
</script>
|
|
<script type="text/javascript" src="menudata.js"></script>
|
|
<script type="text/javascript" src="menu.js"></script>
|
|
<script type="text/javascript">
|
|
/* @license magnet:?xt=urn:btih:cf05388f2679ee054f2beb29a391d25f4e673ac3&dn=gpl-2.0.txt GPL-v2 */
|
|
$(function() {
|
|
initMenu('',true,false,'search.php','Search');
|
|
$(document).ready(function() { init_search(); });
|
|
});
|
|
/* @license-end */</script>
|
|
<div id="main-nav"></div>
|
|
<!-- window showing the filter options -->
|
|
<div id="MSearchSelectWindow"
|
|
onmouseover="return searchBox.OnSearchSelectShow()"
|
|
onmouseout="return searchBox.OnSearchSelectHide()"
|
|
onkeydown="return searchBox.OnSearchSelectKey(event)">
|
|
</div>
|
|
|
|
<!-- iframe showing the search results (closed by default) -->
|
|
<div id="MSearchResultsWindow">
|
|
<iframe src="javascript:void(0)" frameborder="0"
|
|
name="MSearchResults" id="MSearchResults">
|
|
</iframe>
|
|
</div>
|
|
|
|
<div id="nav-path" class="navpath">
|
|
<ul>
|
|
<li class="navelem"><a class="el" href="dir_d44c64559bbebec7f509842c48db8b23.html">include</a></li><li class="navelem"><a class="el" href="dir_412f9a3d5dfcba8716486cd870ef4586.html">grpcpp</a></li><li class="navelem"><a class="el" href="dir_fee4103ebae22d88b7497e325cc77366.html">support</a></li> </ul>
|
|
</div>
|
|
</div><!-- top -->
|
|
<div class="header">
|
|
<div class="headertitle">
|
|
<div class="title">proto_buffer_reader.h</div> </div>
|
|
</div><!--header-->
|
|
<div class="contents">
|
|
<a href="support_2proto__buffer__reader_8h.html">Go to the documentation of this file.</a><div class="fragment"><div class="line"><a name="l00001"></a><span class="lineno"> 1</span> <span class="comment">//</span></div>
|
|
<div class="line"><a name="l00002"></a><span class="lineno"> 2</span> <span class="comment">//</span></div>
|
|
<div class="line"><a name="l00003"></a><span class="lineno"> 3</span> <span class="comment">// Copyright 2018 gRPC authors.</span></div>
|
|
<div class="line"><a name="l00004"></a><span class="lineno"> 4</span> <span class="comment">//</span></div>
|
|
<div class="line"><a name="l00005"></a><span class="lineno"> 5</span> <span class="comment">// Licensed under the Apache License, Version 2.0 (the "License");</span></div>
|
|
<div class="line"><a name="l00006"></a><span class="lineno"> 6</span> <span class="comment">// you may not use this file except in compliance with the License.</span></div>
|
|
<div class="line"><a name="l00007"></a><span class="lineno"> 7</span> <span class="comment">// You may obtain a copy of the License at</span></div>
|
|
<div class="line"><a name="l00008"></a><span class="lineno"> 8</span> <span class="comment">//</span></div>
|
|
<div class="line"><a name="l00009"></a><span class="lineno"> 9</span> <span class="comment">// http://www.apache.org/licenses/LICENSE-2.0</span></div>
|
|
<div class="line"><a name="l00010"></a><span class="lineno"> 10</span> <span class="comment">//</span></div>
|
|
<div class="line"><a name="l00011"></a><span class="lineno"> 11</span> <span class="comment">// Unless required by applicable law or agreed to in writing, software</span></div>
|
|
<div class="line"><a name="l00012"></a><span class="lineno"> 12</span> <span class="comment">// distributed under the License is distributed on an "AS IS" BASIS,</span></div>
|
|
<div class="line"><a name="l00013"></a><span class="lineno"> 13</span> <span class="comment">// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</span></div>
|
|
<div class="line"><a name="l00014"></a><span class="lineno"> 14</span> <span class="comment">// See the License for the specific language governing permissions and</span></div>
|
|
<div class="line"><a name="l00015"></a><span class="lineno"> 15</span> <span class="comment">// limitations under the License.</span></div>
|
|
<div class="line"><a name="l00016"></a><span class="lineno"> 16</span> <span class="comment">//</span></div>
|
|
<div class="line"><a name="l00017"></a><span class="lineno"> 17</span> <span class="comment">//</span></div>
|
|
<div class="line"><a name="l00018"></a><span class="lineno"> 18</span>  </div>
|
|
<div class="line"><a name="l00019"></a><span class="lineno"> 19</span> <span class="preprocessor">#ifndef GRPCPP_SUPPORT_PROTO_BUFFER_READER_H</span></div>
|
|
<div class="line"><a name="l00020"></a><span class="lineno"> 20</span> <span class="preprocessor">#define GRPCPP_SUPPORT_PROTO_BUFFER_READER_H</span></div>
|
|
<div class="line"><a name="l00021"></a><span class="lineno"> 21</span>  </div>
|
|
<div class="line"><a name="l00022"></a><span class="lineno"> 22</span> <span class="preprocessor">#include <type_traits></span></div>
|
|
<div class="line"><a name="l00023"></a><span class="lineno"> 23</span>  </div>
|
|
<div class="line"><a name="l00024"></a><span class="lineno"> 24</span> <span class="preprocessor">#include "absl/log/check.h"</span></div>
|
|
<div class="line"><a name="l00025"></a><span class="lineno"> 25</span> <span class="preprocessor">#include "absl/strings/cord.h"</span></div>
|
|
<div class="line"><a name="l00026"></a><span class="lineno"> 26</span>  </div>
|
|
<div class="line"><a name="l00027"></a><span class="lineno"> 27</span> <span class="preprocessor">#include <<a class="code" href="grpc_2byte__buffer_8h.html">grpc/byte_buffer.h</a>></span></div>
|
|
<div class="line"><a name="l00028"></a><span class="lineno"> 28</span> <span class="preprocessor">#include <<a class="code" href="byte__buffer__reader_8h.html">grpc/byte_buffer_reader.h</a>></span></div>
|
|
<div class="line"><a name="l00029"></a><span class="lineno"> 29</span> <span class="preprocessor">#include <<a class="code" href="grpc__types_8h.html">grpc/impl/grpc_types.h</a>></span></div>
|
|
<div class="line"><a name="l00030"></a><span class="lineno"> 30</span> <span class="preprocessor">#include <<a class="code" href="grpc_2slice_8h.html">grpc/slice.h</a>></span></div>
|
|
<div class="line"><a name="l00031"></a><span class="lineno"> 31</span> <span class="preprocessor">#include <<a class="code" href="support_2log_8h.html">grpc/support/log.h</a>></span></div>
|
|
<div class="line"><a name="l00032"></a><span class="lineno"> 32</span> <span class="preprocessor">#include <<a class="code" href="grpcpp_2impl_2codegen_2config__protobuf_8h.html">grpcpp/impl/codegen/config_protobuf.h</a>></span></div>
|
|
<div class="line"><a name="l00033"></a><span class="lineno"> 33</span> <span class="preprocessor">#include <<a class="code" href="grpcpp_2impl_2serialization__traits_8h.html">grpcpp/impl/serialization_traits.h</a>></span></div>
|
|
<div class="line"><a name="l00034"></a><span class="lineno"> 34</span> <span class="preprocessor">#include <<a class="code" href="grpcpp_2support_2byte__buffer_8h.html">grpcpp/support/byte_buffer.h</a>></span></div>
|
|
<div class="line"><a name="l00035"></a><span class="lineno"> 35</span> <span class="preprocessor">#include <<a class="code" href="grpcpp_2support_2status_8h.html">grpcpp/support/status.h</a>></span></div>
|
|
<div class="line"><a name="l00036"></a><span class="lineno"> 36</span>  </div>
|
|
<div class="line"><a name="l00039"></a><span class="lineno"> 39</span>  </div>
|
|
<div class="line"><a name="l00040"></a><span class="lineno"> 40</span> <span class="keyword">namespace </span><a class="code" href="namespacegrpc.html">grpc</a> {</div>
|
|
<div class="line"><a name="l00041"></a><span class="lineno"> 41</span>  </div>
|
|
<div class="line"><a name="l00048"></a><span class="lineno"><a class="line" href="classgrpc_1_1_proto_buffer_reader.html"> 48</a></span> <span class="keyword">class </span><a class="code" href="classgrpc_1_1_proto_buffer_reader.html">ProtoBufferReader</a> : <span class="keyword">public</span> <a class="code" href="namespacegrpc_1_1protobuf_1_1io.html#ae16bb38d6b730de308f0be4eb43931b4">grpc::protobuf::io::ZeroCopyInputStream</a> {</div>
|
|
<div class="line"><a name="l00049"></a><span class="lineno"> 49</span>  <span class="keyword">public</span>:</div>
|
|
<div class="line"><a name="l00052"></a><span class="lineno"><a class="line" href="classgrpc_1_1_proto_buffer_reader.html#aa00588464b3586ea57b8d4f20b526934"> 52</a></span>  <span class="keyword">explicit</span> <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#aa00588464b3586ea57b8d4f20b526934">ProtoBufferReader</a>(<a class="code" href="classgrpc_1_1_byte_buffer.html">ByteBuffer</a>* buffer)</div>
|
|
<div class="line"><a name="l00053"></a><span class="lineno"> 53</span>  : byte_count_(0), backup_count_(0), status_() {</div>
|
|
<div class="line"><a name="l00056"></a><span class="lineno"> 56</span>  <span class="keywordflow">if</span> (!buffer-><a class="code" href="classgrpc_1_1_byte_buffer.html#aea6bcd0d3c70fc14158df68c59dc82d4">Valid</a>() ||</div>
|
|
<div class="line"><a name="l00057"></a><span class="lineno"> 57</span>  !<a class="code" href="grpc_2byte__buffer_8h.html#affd8fb29176a60c44fe704983fa87406">grpc_byte_buffer_reader_init</a>(&reader_, buffer->c_buffer())) {</div>
|
|
<div class="line"><a name="l00058"></a><span class="lineno"> 58</span>  status_ = <a class="code" href="namespacegrpc_1_1protobuf_1_1util.html#ad372120c6db3d26bf54ab69b6f595fe4">Status</a>(<a class="code" href="namespacegrpc.html#aff1730578c90160528f6a8d67ef5c43ba0ae30536146394965fd8ad64c2d414f3">StatusCode::INTERNAL</a>,</div>
|
|
<div class="line"><a name="l00059"></a><span class="lineno"> 59</span>  <span class="stringliteral">"Couldn't initialize byte buffer reader"</span>);</div>
|
|
<div class="line"><a name="l00060"></a><span class="lineno"> 60</span>  }</div>
|
|
<div class="line"><a name="l00061"></a><span class="lineno"> 61</span>  }</div>
|
|
<div class="line"><a name="l00062"></a><span class="lineno"> 62</span>  </div>
|
|
<div class="line"><a name="l00063"></a><span class="lineno"><a class="line" href="classgrpc_1_1_proto_buffer_reader.html#a8b97402d4707d6bd8b4910961aa8a757"> 63</a></span>  <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a8b97402d4707d6bd8b4910961aa8a757">~ProtoBufferReader</a>()<span class="keyword"> override </span>{</div>
|
|
<div class="line"><a name="l00064"></a><span class="lineno"> 64</span>  <span class="keywordflow">if</span> (status_.<a class="code" href="classgrpc_1_1_status.html#ab80672b5665c32dc0937a0d58a3ce192">ok</a>()) {</div>
|
|
<div class="line"><a name="l00065"></a><span class="lineno"> 65</span>  <a class="code" href="grpc_2byte__buffer_8h.html#ae28a4ce16b0d8ddd506f1df3fcb3c619">grpc_byte_buffer_reader_destroy</a>(&reader_);</div>
|
|
<div class="line"><a name="l00066"></a><span class="lineno"> 66</span>  }</div>
|
|
<div class="line"><a name="l00067"></a><span class="lineno"> 67</span>  }</div>
|
|
<div class="line"><a name="l00068"></a><span class="lineno"> 68</span>  </div>
|
|
<div class="line"><a name="l00071"></a><span class="lineno"><a class="line" href="classgrpc_1_1_proto_buffer_reader.html#a5535d30e741c8a081a0fec40620b37e8"> 71</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a5535d30e741c8a081a0fec40620b37e8">Next</a>(<span class="keyword">const</span> <span class="keywordtype">void</span>** data, <span class="keywordtype">int</span>* size)<span class="keyword"> override </span>{</div>
|
|
<div class="line"><a name="l00072"></a><span class="lineno"> 72</span>  <span class="keywordflow">if</span> (!status_.<a class="code" href="classgrpc_1_1_status.html#ab80672b5665c32dc0937a0d58a3ce192">ok</a>()) {</div>
|
|
<div class="line"><a name="l00073"></a><span class="lineno"> 73</span>  <span class="keywordflow">return</span> <span class="keyword">false</span>;</div>
|
|
<div class="line"><a name="l00074"></a><span class="lineno"> 74</span>  }</div>
|
|
<div class="line"><a name="l00076"></a><span class="lineno"> 76</span>  <span class="keywordflow">if</span> (backup_count_ > 0) {</div>
|
|
<div class="line"><a name="l00077"></a><span class="lineno"> 77</span>  *data = <a class="code" href="slice__type_8h.html#a8a15783c251cdeb18c3f8b0ad41d0352">GRPC_SLICE_START_PTR</a>(*slice_) + <a class="code" href="slice__type_8h.html#ae965fb2ee1a646253cdbd49d82b0b6c5">GRPC_SLICE_LENGTH</a>(*slice_) -</div>
|
|
<div class="line"><a name="l00078"></a><span class="lineno"> 78</span>  backup_count_;</div>
|
|
<div class="line"><a name="l00079"></a><span class="lineno"> 79</span>  CHECK_LE(backup_count_, INT_MAX);</div>
|
|
<div class="line"><a name="l00080"></a><span class="lineno"> 80</span>  *size = <span class="keyword">static_cast<</span><span class="keywordtype">int</span><span class="keyword">></span>(backup_count_);</div>
|
|
<div class="line"><a name="l00081"></a><span class="lineno"> 81</span>  backup_count_ = 0;</div>
|
|
<div class="line"><a name="l00082"></a><span class="lineno"> 82</span>  <span class="keywordflow">return</span> <span class="keyword">true</span>;</div>
|
|
<div class="line"><a name="l00083"></a><span class="lineno"> 83</span>  }</div>
|
|
<div class="line"><a name="l00085"></a><span class="lineno"> 85</span>  <span class="keywordflow">if</span> (!<a class="code" href="grpc_2byte__buffer_8h.html#a52e8989121500cd583bd25ca9f3ff359">grpc_byte_buffer_reader_peek</a>(&reader_, &slice_)) {</div>
|
|
<div class="line"><a name="l00086"></a><span class="lineno"> 86</span>  <span class="keywordflow">return</span> <span class="keyword">false</span>;</div>
|
|
<div class="line"><a name="l00087"></a><span class="lineno"> 87</span>  }</div>
|
|
<div class="line"><a name="l00088"></a><span class="lineno"> 88</span>  *data = <a class="code" href="slice__type_8h.html#a8a15783c251cdeb18c3f8b0ad41d0352">GRPC_SLICE_START_PTR</a>(*slice_);</div>
|
|
<div class="line"><a name="l00089"></a><span class="lineno"> 89</span>  <span class="comment">// On win x64, int is only 32bit</span></div>
|
|
<div class="line"><a name="l00090"></a><span class="lineno"> 90</span>  CHECK_LE(<a class="code" href="slice__type_8h.html#ae965fb2ee1a646253cdbd49d82b0b6c5">GRPC_SLICE_LENGTH</a>(*slice_), <span class="keyword">static_cast<</span><span class="keywordtype">size_t</span><span class="keyword">></span>(INT_MAX));</div>
|
|
<div class="line"><a name="l00091"></a><span class="lineno"> 91</span>  byte_count_ += * size = <span class="keyword">static_cast<</span><span class="keywordtype">int</span><span class="keyword">></span>(<a class="code" href="slice__type_8h.html#ae965fb2ee1a646253cdbd49d82b0b6c5">GRPC_SLICE_LENGTH</a>(*slice_));</div>
|
|
<div class="line"><a name="l00092"></a><span class="lineno"> 92</span>  <span class="keywordflow">return</span> <span class="keyword">true</span>;</div>
|
|
<div class="line"><a name="l00093"></a><span class="lineno"> 93</span>  }</div>
|
|
<div class="line"><a name="l00094"></a><span class="lineno"> 94</span>  </div>
|
|
<div class="line"><a name="l00096"></a><span class="lineno"><a class="line" href="classgrpc_1_1_proto_buffer_reader.html#a50b5c353ac2d915b09e68bf9c1f7136e"> 96</a></span>  <a class="code" href="classgrpc_1_1_status.html">Status</a> <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a50b5c353ac2d915b09e68bf9c1f7136e">status</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> status_; }</div>
|
|
<div class="line"><a name="l00097"></a><span class="lineno"> 97</span>  </div>
|
|
<div class="line"><a name="l00101"></a><span class="lineno"><a class="line" href="classgrpc_1_1_proto_buffer_reader.html#adb77905f9cecd961c6066dc78d93a60c"> 101</a></span>  <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#adb77905f9cecd961c6066dc78d93a60c">BackUp</a>(<span class="keywordtype">int</span> count)<span class="keyword"> override </span>{</div>
|
|
<div class="line"><a name="l00102"></a><span class="lineno"> 102</span>  CHECK_LE(count, <span class="keyword">static_cast<</span><span class="keywordtype">int</span><span class="keyword">></span>(<a class="code" href="slice__type_8h.html#ae965fb2ee1a646253cdbd49d82b0b6c5">GRPC_SLICE_LENGTH</a>(*slice_)));</div>
|
|
<div class="line"><a name="l00103"></a><span class="lineno"> 103</span>  backup_count_ = count;</div>
|
|
<div class="line"><a name="l00104"></a><span class="lineno"> 104</span>  }</div>
|
|
<div class="line"><a name="l00105"></a><span class="lineno"> 105</span>  </div>
|
|
<div class="line"><a name="l00108"></a><span class="lineno"><a class="line" href="classgrpc_1_1_proto_buffer_reader.html#a6f9fdfde9953f08b5ca247e6e1b2f02b"> 108</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a6f9fdfde9953f08b5ca247e6e1b2f02b">Skip</a>(<span class="keywordtype">int</span> count)<span class="keyword"> override </span>{</div>
|
|
<div class="line"><a name="l00109"></a><span class="lineno"> 109</span>  <span class="keyword">const</span> <span class="keywordtype">void</span>* data;</div>
|
|
<div class="line"><a name="l00110"></a><span class="lineno"> 110</span>  <span class="keywordtype">int</span> size;</div>
|
|
<div class="line"><a name="l00111"></a><span class="lineno"> 111</span>  <span class="keywordflow">while</span> (<a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a5535d30e741c8a081a0fec40620b37e8">Next</a>(&data, &size)) {</div>
|
|
<div class="line"><a name="l00112"></a><span class="lineno"> 112</span>  <span class="keywordflow">if</span> (size >= count) {</div>
|
|
<div class="line"><a name="l00113"></a><span class="lineno"> 113</span>  <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#adb77905f9cecd961c6066dc78d93a60c">BackUp</a>(size - count);</div>
|
|
<div class="line"><a name="l00114"></a><span class="lineno"> 114</span>  <span class="keywordflow">return</span> <span class="keyword">true</span>;</div>
|
|
<div class="line"><a name="l00115"></a><span class="lineno"> 115</span>  }</div>
|
|
<div class="line"><a name="l00116"></a><span class="lineno"> 116</span>  <span class="comment">// size < count;</span></div>
|
|
<div class="line"><a name="l00117"></a><span class="lineno"> 117</span>  count -= size;</div>
|
|
<div class="line"><a name="l00118"></a><span class="lineno"> 118</span>  }</div>
|
|
<div class="line"><a name="l00119"></a><span class="lineno"> 119</span>  <span class="comment">// error or we have too large count;</span></div>
|
|
<div class="line"><a name="l00120"></a><span class="lineno"> 120</span>  <span class="keywordflow">return</span> <span class="keyword">false</span>;</div>
|
|
<div class="line"><a name="l00121"></a><span class="lineno"> 121</span>  }</div>
|
|
<div class="line"><a name="l00122"></a><span class="lineno"> 122</span>  </div>
|
|
<div class="line"><a name="l00124"></a><span class="lineno"><a class="line" href="classgrpc_1_1_proto_buffer_reader.html#a98601902abf9a69f2072e81aa65f67a0"> 124</a></span>  int64_t <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a98601902abf9a69f2072e81aa65f67a0">ByteCount</a>()<span class="keyword"> const override </span>{ <span class="keywordflow">return</span> byte_count_ - backup_count_; }</div>
|
|
<div class="line"><a name="l00125"></a><span class="lineno"> 125</span>  </div>
|
|
<div class="line"><a name="l00126"></a><span class="lineno"> 126</span> <span class="preprocessor">#ifdef GRPC_PROTOBUF_CORD_SUPPORT_ENABLED</span></div>
|
|
<div class="line"><a name="l00127"></a><span class="lineno"> 127</span>  <span class="comment">// (override is conditionally omitted here to support old Protobuf which</span></div>
|
|
<div class="line"><a name="l00129"></a><span class="lineno"> 129</span>  <span class="comment">// doesn't have ReadCord method)</span></div>
|
|
<div class="line"><a name="l00130"></a><span class="lineno"> 130</span>  <span class="comment">// NOLINTBEGIN(modernize-use-override,</span></div>
|
|
<div class="line"><a name="l00131"></a><span class="lineno"> 131</span>  <span class="comment">// clang-diagnostic-inconsistent-missing-override)</span></div>
|
|
<div class="line"><a name="l00132"></a><span class="lineno"> 132</span>  <span class="keyword">virtual</span> <span class="keywordtype">bool</span> ReadCord(absl::Cord* cord, <span class="keywordtype">int</span> count)</div>
|
|
<div class="line"><a name="l00133"></a><span class="lineno"> 133</span> <span class="preprocessor">#if GOOGLE_PROTOBUF_VERSION >= 4022000</span></div>
|
|
<div class="line"><a name="l00134"></a><span class="lineno"> 134</span>  <span class="keyword">override</span></div>
|
|
<div class="line"><a name="l00135"></a><span class="lineno"> 135</span> <span class="preprocessor">#endif</span></div>
|
|
<div class="line"><a name="l00136"></a><span class="lineno"> 136</span>  <span class="comment">// NOLINTEND(modernize-use-override,</span></div>
|
|
<div class="line"><a name="l00137"></a><span class="lineno"> 137</span>  <span class="comment">// clang-diagnostic-inconsistent-missing-override)</span></div>
|
|
<div class="line"><a name="l00138"></a><span class="lineno"> 138</span>  {</div>
|
|
<div class="line"><a name="l00139"></a><span class="lineno"> 139</span>  <span class="keywordflow">if</span> (!<a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a50b5c353ac2d915b09e68bf9c1f7136e">status</a>().ok()) {</div>
|
|
<div class="line"><a name="l00140"></a><span class="lineno"> 140</span>  <span class="keywordflow">return</span> <span class="keyword">false</span>;</div>
|
|
<div class="line"><a name="l00141"></a><span class="lineno"> 141</span>  }</div>
|
|
<div class="line"><a name="l00142"></a><span class="lineno"> 142</span>  <span class="comment">// check for backed up data</span></div>
|
|
<div class="line"><a name="l00143"></a><span class="lineno"> 143</span>  <span class="keywordflow">if</span> (<a class="code" href="classgrpc_1_1_proto_buffer_reader.html#ac9dad34d4b14195b85d5cd019ba5d7d1">backup_count</a>() > 0) {</div>
|
|
<div class="line"><a name="l00144"></a><span class="lineno"> 144</span>  <span class="keywordflow">if</span> (<a class="code" href="classgrpc_1_1_proto_buffer_reader.html#ac9dad34d4b14195b85d5cd019ba5d7d1">backup_count</a>() <= count) {</div>
|
|
<div class="line"><a name="l00145"></a><span class="lineno"> 145</span>  cord->Append(MakeCordFromSlice(<a class="code" href="grpc_2slice_8h.html#a5aedc925ae6e2bae484fe82383fac025">grpc_slice_split_tail</a>(</div>
|
|
<div class="line"><a name="l00146"></a><span class="lineno"> 146</span>  <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a0874823748781629e0b2bde470d78bf3">slice</a>(), <a class="code" href="slice__type_8h.html#ae965fb2ee1a646253cdbd49d82b0b6c5">GRPC_SLICE_LENGTH</a>(*<a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a0874823748781629e0b2bde470d78bf3">slice</a>()) - <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#ac9dad34d4b14195b85d5cd019ba5d7d1">backup_count</a>())));</div>
|
|
<div class="line"><a name="l00147"></a><span class="lineno"> 147</span>  } <span class="keywordflow">else</span> {</div>
|
|
<div class="line"><a name="l00148"></a><span class="lineno"> 148</span>  cord->Append(MakeCordFromSlice(<a class="code" href="grpc_2slice_8h.html#ac334a6c6ad0a729fd4fe521df9f5ecc5">grpc_slice_sub</a>(</div>
|
|
<div class="line"><a name="l00149"></a><span class="lineno"> 149</span>  *<a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a0874823748781629e0b2bde470d78bf3">slice</a>(), <a class="code" href="slice__type_8h.html#ae965fb2ee1a646253cdbd49d82b0b6c5">GRPC_SLICE_LENGTH</a>(*<a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a0874823748781629e0b2bde470d78bf3">slice</a>()) - <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#ac9dad34d4b14195b85d5cd019ba5d7d1">backup_count</a>(),</div>
|
|
<div class="line"><a name="l00150"></a><span class="lineno"> 150</span>  <a class="code" href="slice__type_8h.html#ae965fb2ee1a646253cdbd49d82b0b6c5">GRPC_SLICE_LENGTH</a>(*<a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a0874823748781629e0b2bde470d78bf3">slice</a>()) - <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#ac9dad34d4b14195b85d5cd019ba5d7d1">backup_count</a>() + count)));</div>
|
|
<div class="line"><a name="l00151"></a><span class="lineno"> 151</span>  }</div>
|
|
<div class="line"><a name="l00152"></a><span class="lineno"> 152</span>  int64_t take = (std::min)(<a class="code" href="classgrpc_1_1_proto_buffer_reader.html#ac9dad34d4b14195b85d5cd019ba5d7d1">backup_count</a>(), <span class="keyword">static_cast<</span>int64_t<span class="keyword">></span>(count));</div>
|
|
<div class="line"><a name="l00153"></a><span class="lineno"> 153</span>  <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a56f59bca6804e19d0f780c80ccbca031">set_backup_count</a>(<a class="code" href="classgrpc_1_1_proto_buffer_reader.html#ac9dad34d4b14195b85d5cd019ba5d7d1">backup_count</a>() - take);</div>
|
|
<div class="line"><a name="l00154"></a><span class="lineno"> 154</span>  <span class="comment">// This cast is safe as the size of a serialized protobuf message</span></div>
|
|
<div class="line"><a name="l00155"></a><span class="lineno"> 155</span>  <span class="comment">// should be smaller than 2GiB.</span></div>
|
|
<div class="line"><a name="l00156"></a><span class="lineno"> 156</span>  <span class="comment">// (https://protobuf.dev/programming-guides/encoding/#size-limit)</span></div>
|
|
<div class="line"><a name="l00157"></a><span class="lineno"> 157</span>  count -= <span class="keyword">static_cast<</span><span class="keywordtype">int</span><span class="keyword">></span>(take);</div>
|
|
<div class="line"><a name="l00158"></a><span class="lineno"> 158</span>  <span class="keywordflow">if</span> (count == 0) {</div>
|
|
<div class="line"><a name="l00159"></a><span class="lineno"> 159</span>  <span class="keywordflow">return</span> <span class="keyword">true</span>;</div>
|
|
<div class="line"><a name="l00160"></a><span class="lineno"> 160</span>  }</div>
|
|
<div class="line"><a name="l00161"></a><span class="lineno"> 161</span>  }</div>
|
|
<div class="line"><a name="l00162"></a><span class="lineno"> 162</span>  <span class="keywordflow">while</span> (count > 0) {</div>
|
|
<div class="line"><a name="l00163"></a><span class="lineno"> 163</span>  <span class="keywordflow">if</span> (!<a class="code" href="grpc_2byte__buffer_8h.html#a52e8989121500cd583bd25ca9f3ff359">grpc_byte_buffer_reader_peek</a>(<a class="code" href="classgrpc_1_1_proto_buffer_reader.html#aa50ef34b08b9cb338dc26db6be108748">reader</a>(), <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a0a79dd8c63deb9cb1837d531229a7577">mutable_slice_ptr</a>())) {</div>
|
|
<div class="line"><a name="l00164"></a><span class="lineno"> 164</span>  <span class="keywordflow">return</span> <span class="keyword">false</span>;</div>
|
|
<div class="line"><a name="l00165"></a><span class="lineno"> 165</span>  }</div>
|
|
<div class="line"><a name="l00166"></a><span class="lineno"> 166</span>  uint64_t slice_length = <a class="code" href="slice__type_8h.html#ae965fb2ee1a646253cdbd49d82b0b6c5">GRPC_SLICE_LENGTH</a>(*<a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a0874823748781629e0b2bde470d78bf3">slice</a>());</div>
|
|
<div class="line"><a name="l00167"></a><span class="lineno"> 167</span>  <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a9fa8b889f80d4bf56f6915ad9245ac3b">set_byte_count</a>(<a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a98601902abf9a69f2072e81aa65f67a0">ByteCount</a>() + slice_length);</div>
|
|
<div class="line"><a name="l00168"></a><span class="lineno"> 168</span>  <span class="keywordflow">if</span> (slice_length <= <span class="keyword">static_cast<</span>uint64_t<span class="keyword">></span>(count)) {</div>
|
|
<div class="line"><a name="l00169"></a><span class="lineno"> 169</span>  cord->Append(MakeCordFromSlice(<a class="code" href="grpc_2slice_8h.html#aaf6dd367abbe7883973588f411928c6e">grpc_slice_ref</a>(*<a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a0874823748781629e0b2bde470d78bf3">slice</a>())));</div>
|
|
<div class="line"><a name="l00170"></a><span class="lineno"> 170</span>  <span class="comment">// This cast is safe as above.</span></div>
|
|
<div class="line"><a name="l00171"></a><span class="lineno"> 171</span>  count -= <span class="keyword">static_cast<</span><span class="keywordtype">int</span><span class="keyword">></span>(slice_length);</div>
|
|
<div class="line"><a name="l00172"></a><span class="lineno"> 172</span>  } <span class="keywordflow">else</span> {</div>
|
|
<div class="line"><a name="l00173"></a><span class="lineno"> 173</span>  cord->Append(MakeCordFromSlice(<a class="code" href="grpc_2slice_8h.html#ac630cdfb54ff37e0490c3ebe9efd585e">grpc_slice_split_head</a>(<a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a0874823748781629e0b2bde470d78bf3">slice</a>(), count)));</div>
|
|
<div class="line"><a name="l00174"></a><span class="lineno"> 174</span>  <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a56f59bca6804e19d0f780c80ccbca031">set_backup_count</a>(slice_length - count);</div>
|
|
<div class="line"><a name="l00175"></a><span class="lineno"> 175</span>  <span class="keywordflow">return</span> <span class="keyword">true</span>;</div>
|
|
<div class="line"><a name="l00176"></a><span class="lineno"> 176</span>  }</div>
|
|
<div class="line"><a name="l00177"></a><span class="lineno"> 177</span>  }</div>
|
|
<div class="line"><a name="l00178"></a><span class="lineno"> 178</span>  CHECK_EQ(count, 0);</div>
|
|
<div class="line"><a name="l00179"></a><span class="lineno"> 179</span>  <span class="keywordflow">return</span> <span class="keyword">true</span>;</div>
|
|
<div class="line"><a name="l00180"></a><span class="lineno"> 180</span>  }</div>
|
|
<div class="line"><a name="l00181"></a><span class="lineno"> 181</span> <span class="preprocessor">#endif // GRPC_PROTOBUF_CORD_SUPPORT_ENABLED</span></div>
|
|
<div class="line"><a name="l00182"></a><span class="lineno"> 182</span>  </div>
|
|
<div class="line"><a name="l00183"></a><span class="lineno"> 183</span>  <span class="comment">// These protected members are needed to support internal optimizations.</span></div>
|
|
<div class="line"><a name="l00184"></a><span class="lineno"> 184</span>  <span class="comment">// they expose internal bits of grpc core that are NOT stable. If you have</span></div>
|
|
<div class="line"><a name="l00185"></a><span class="lineno"> 185</span>  <span class="comment">// a use case needs to use one of these functions, please send an email to</span></div>
|
|
<div class="line"><a name="l00186"></a><span class="lineno"> 186</span>  <span class="comment">// https://groups.google.com/forum/#!forum/grpc-io.</span></div>
|
|
<div class="line"><a name="l00187"></a><span class="lineno"> 187</span>  <span class="keyword">protected</span>:</div>
|
|
<div class="line"><a name="l00188"></a><span class="lineno"><a class="line" href="classgrpc_1_1_proto_buffer_reader.html#a9fa8b889f80d4bf56f6915ad9245ac3b"> 188</a></span>  <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a9fa8b889f80d4bf56f6915ad9245ac3b">set_byte_count</a>(int64_t byte_count) { byte_count_ = byte_count; }</div>
|
|
<div class="line"><a name="l00189"></a><span class="lineno"><a class="line" href="classgrpc_1_1_proto_buffer_reader.html#ac9dad34d4b14195b85d5cd019ba5d7d1"> 189</a></span>  int64_t <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#ac9dad34d4b14195b85d5cd019ba5d7d1">backup_count</a>() { <span class="keywordflow">return</span> backup_count_; }</div>
|
|
<div class="line"><a name="l00190"></a><span class="lineno"><a class="line" href="classgrpc_1_1_proto_buffer_reader.html#a56f59bca6804e19d0f780c80ccbca031"> 190</a></span>  <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a56f59bca6804e19d0f780c80ccbca031">set_backup_count</a>(int64_t <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#ac9dad34d4b14195b85d5cd019ba5d7d1">backup_count</a>) { backup_count_ = <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#ac9dad34d4b14195b85d5cd019ba5d7d1">backup_count</a>; }</div>
|
|
<div class="line"><a name="l00191"></a><span class="lineno"><a class="line" href="classgrpc_1_1_proto_buffer_reader.html#aa50ef34b08b9cb338dc26db6be108748"> 191</a></span>  <a class="code" href="structgrpc__byte__buffer__reader.html">grpc_byte_buffer_reader</a>* <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#aa50ef34b08b9cb338dc26db6be108748">reader</a>() { <span class="keywordflow">return</span> &reader_; }</div>
|
|
<div class="line"><a name="l00192"></a><span class="lineno"><a class="line" href="classgrpc_1_1_proto_buffer_reader.html#a0874823748781629e0b2bde470d78bf3"> 192</a></span>  <a class="code" href="structgrpc__slice.html">grpc_slice</a>* <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a0874823748781629e0b2bde470d78bf3">slice</a>() { <span class="keywordflow">return</span> slice_; }</div>
|
|
<div class="line"><a name="l00193"></a><span class="lineno"><a class="line" href="classgrpc_1_1_proto_buffer_reader.html#a0a79dd8c63deb9cb1837d531229a7577"> 193</a></span>  <a class="code" href="structgrpc__slice.html">grpc_slice</a>** <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a0a79dd8c63deb9cb1837d531229a7577">mutable_slice_ptr</a>() { <span class="keywordflow">return</span> &slice_; }</div>
|
|
<div class="line"><a name="l00194"></a><span class="lineno"> 194</span>  </div>
|
|
<div class="line"><a name="l00195"></a><span class="lineno"> 195</span>  <span class="keyword">private</span>:</div>
|
|
<div class="line"><a name="l00196"></a><span class="lineno"> 196</span> <span class="preprocessor">#ifdef GRPC_PROTOBUF_CORD_SUPPORT_ENABLED</span></div>
|
|
<div class="line"><a name="l00197"></a><span class="lineno"> 197</span>  <span class="comment">// This function takes ownership of slice and return a newly created Cord off</span></div>
|
|
<div class="line"><a name="l00198"></a><span class="lineno"> 198</span>  <span class="comment">// of it.</span></div>
|
|
<div class="line"><a name="l00199"></a><span class="lineno"> 199</span>  <span class="keyword">static</span> absl::Cord MakeCordFromSlice(<a class="code" href="structgrpc__slice.html">grpc_slice</a> <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a0874823748781629e0b2bde470d78bf3">slice</a>) {</div>
|
|
<div class="line"><a name="l00200"></a><span class="lineno"> 200</span>  <span class="comment">// slice_for_cord is created to keep inlined data of the given slice</span></div>
|
|
<div class="line"><a name="l00201"></a><span class="lineno"> 201</span>  <a class="code" href="structgrpc__slice.html">grpc_slice</a>* slice_for_cord = <span class="keyword">new</span> <a class="code" href="slice__type_8h.html#a2a5f8eaa5d8784bfec46ac983644dca2">grpc_slice</a>;</div>
|
|
<div class="line"><a name="l00202"></a><span class="lineno"> 202</span>  *slice_for_cord = <a class="code" href="classgrpc_1_1_proto_buffer_reader.html#a0874823748781629e0b2bde470d78bf3">slice</a>;</div>
|
|
<div class="line"><a name="l00203"></a><span class="lineno"> 203</span>  <span class="keywordflow">return</span> absl::MakeCordFromExternal(</div>
|
|
<div class="line"><a name="l00204"></a><span class="lineno"> 204</span>  absl::string_view(</div>
|
|
<div class="line"><a name="l00205"></a><span class="lineno"> 205</span>  <span class="keyword">reinterpret_cast<</span><span class="keywordtype">char</span>*<span class="keyword">></span>(<a class="code" href="slice__type_8h.html#a8a15783c251cdeb18c3f8b0ad41d0352">GRPC_SLICE_START_PTR</a>(*slice_for_cord)),</div>
|
|
<div class="line"><a name="l00206"></a><span class="lineno"> 206</span>  <a class="code" href="slice__type_8h.html#ae965fb2ee1a646253cdbd49d82b0b6c5">GRPC_SLICE_LENGTH</a>(*slice_for_cord)),</div>
|
|
<div class="line"><a name="l00207"></a><span class="lineno"> 207</span>  [slice_for_cord](absl::string_view <span class="comment">/* view */</span>) {</div>
|
|
<div class="line"><a name="l00208"></a><span class="lineno"> 208</span>  <a class="code" href="grpc_2slice_8h.html#ac9952d98910886ca44ac416d547d0e08">grpc_slice_unref</a>(*slice_for_cord);</div>
|
|
<div class="line"><a name="l00209"></a><span class="lineno"> 209</span>  <span class="keyword">delete</span> slice_for_cord;</div>
|
|
<div class="line"><a name="l00210"></a><span class="lineno"> 210</span>  });</div>
|
|
<div class="line"><a name="l00211"></a><span class="lineno"> 211</span>  }</div>
|
|
<div class="line"><a name="l00212"></a><span class="lineno"> 212</span> <span class="preprocessor">#endif // GRPC_PROTOBUF_CORD_SUPPORT_ENABLED</span></div>
|
|
<div class="line"><a name="l00213"></a><span class="lineno"> 213</span>  </div>
|
|
<div class="line"><a name="l00214"></a><span class="lineno"> 214</span>  int64_t byte_count_; </div>
|
|
<div class="line"><a name="l00215"></a><span class="lineno"> 215</span>  int64_t backup_count_; </div>
|
|
<div class="line"><a name="l00216"></a><span class="lineno"> 216</span>  <a class="code" href="structgrpc__byte__buffer__reader.html">grpc_byte_buffer_reader</a> reader_; </div>
|
|
<div class="line"><a name="l00217"></a><span class="lineno"> 217</span>  <a class="code" href="structgrpc__slice.html">grpc_slice</a>* slice_; </div>
|
|
<div class="line"><a name="l00219"></a><span class="lineno"> 219</span>  <a class="code" href="namespacegrpc_1_1protobuf_1_1util.html#ad372120c6db3d26bf54ab69b6f595fe4">Status</a> status_; </div>
|
|
<div class="line"><a name="l00220"></a><span class="lineno"> 220</span> };</div>
|
|
<div class="line"><a name="l00221"></a><span class="lineno"> 221</span>  </div>
|
|
<div class="line"><a name="l00222"></a><span class="lineno"> 222</span> } <span class="comment">// namespace grpc</span></div>
|
|
<div class="line"><a name="l00223"></a><span class="lineno"> 223</span>  </div>
|
|
<div class="line"><a name="l00224"></a><span class="lineno"> 224</span> <span class="preprocessor">#endif // GRPCPP_SUPPORT_PROTO_BUFFER_READER_H</span></div>
|
|
</div><!-- fragment --></div><!-- contents -->
|
|
<div class="ttc" id="aslice__type_8h_html_a8a15783c251cdeb18c3f8b0ad41d0352"><div class="ttname"><a href="slice__type_8h.html#a8a15783c251cdeb18c3f8b0ad41d0352">GRPC_SLICE_START_PTR</a></div><div class="ttdeci">#define GRPC_SLICE_START_PTR(slice)</div><div class="ttdef"><b>Definition:</b> slice_type.h:99</div></div>
|
|
<div class="ttc" id="anamespacegrpc_html"><div class="ttname"><a href="namespacegrpc.html">grpc</a></div><div class="ttdoc">An Alarm posts the user-provided tag to its associated completion queue or invokes the user-provided ...</div><div class="ttdef"><b>Definition:</b> alarm.h:33</div></div>
|
|
<div class="ttc" id="aclassgrpc_1_1_proto_buffer_reader_html_a8b97402d4707d6bd8b4910961aa8a757"><div class="ttname"><a href="classgrpc_1_1_proto_buffer_reader.html#a8b97402d4707d6bd8b4910961aa8a757">grpc::ProtoBufferReader::~ProtoBufferReader</a></div><div class="ttdeci">~ProtoBufferReader() override</div><div class="ttdef"><b>Definition:</b> proto_buffer_reader.h:63</div></div>
|
|
<div class="ttc" id="aclassgrpc_1_1_proto_buffer_reader_html_aa00588464b3586ea57b8d4f20b526934"><div class="ttname"><a href="classgrpc_1_1_proto_buffer_reader.html#aa00588464b3586ea57b8d4f20b526934">grpc::ProtoBufferReader::ProtoBufferReader</a></div><div class="ttdeci">ProtoBufferReader(ByteBuffer *buffer)</div><div class="ttdoc">Constructs buffer reader from buffer.</div><div class="ttdef"><b>Definition:</b> proto_buffer_reader.h:52</div></div>
|
|
<div class="ttc" id="anamespacegrpc_1_1protobuf_1_1io_html_ae16bb38d6b730de308f0be4eb43931b4"><div class="ttname"><a href="namespacegrpc_1_1protobuf_1_1io.html#ae16bb38d6b730de308f0be4eb43931b4">grpc::protobuf::io::ZeroCopyInputStream</a></div><div class="ttdeci">::google::protobuf::io::ZeroCopyInputStream ZeroCopyInputStream</div><div class="ttdef"><b>Definition:</b> config_protobuf.h:114</div></div>
|
|
<div class="ttc" id="agrpcpp_2support_2status_8h_html"><div class="ttname"><a href="grpcpp_2support_2status_8h.html">status.h</a></div></div>
|
|
<div class="ttc" id="aclassgrpc_1_1_proto_buffer_reader_html_ac9dad34d4b14195b85d5cd019ba5d7d1"><div class="ttname"><a href="classgrpc_1_1_proto_buffer_reader.html#ac9dad34d4b14195b85d5cd019ba5d7d1">grpc::ProtoBufferReader::backup_count</a></div><div class="ttdeci">int64_t backup_count()</div><div class="ttdef"><b>Definition:</b> proto_buffer_reader.h:189</div></div>
|
|
<div class="ttc" id="aclassgrpc_1_1_status_html_ab80672b5665c32dc0937a0d58a3ce192"><div class="ttname"><a href="classgrpc_1_1_status.html#ab80672b5665c32dc0937a0d58a3ce192">grpc::Status::ok</a></div><div class="ttdeci">bool ok() const</div><div class="ttdoc">Is the status OK?</div><div class="ttdef"><b>Definition:</b> status.h:125</div></div>
|
|
<div class="ttc" id="aclassgrpc_1_1_proto_buffer_reader_html_adb77905f9cecd961c6066dc78d93a60c"><div class="ttname"><a href="classgrpc_1_1_proto_buffer_reader.html#adb77905f9cecd961c6066dc78d93a60c">grpc::ProtoBufferReader::BackUp</a></div><div class="ttdeci">void BackUp(int count) override</div><div class="ttdoc">The proto library calls this to indicate that we should back up count bytes that have already been re...</div><div class="ttdef"><b>Definition:</b> proto_buffer_reader.h:101</div></div>
|
|
<div class="ttc" id="aslice__type_8h_html_a2a5f8eaa5d8784bfec46ac983644dca2"><div class="ttname"><a href="slice__type_8h.html#a2a5f8eaa5d8784bfec46ac983644dca2">grpc_slice</a></div><div class="ttdeci">struct grpc_slice grpc_slice</div><div class="ttdef"><b>Definition:</b> slice_type.h:28</div></div>
|
|
<div class="ttc" id="abyte__buffer__reader_8h_html"><div class="ttname"><a href="byte__buffer__reader_8h.html">byte_buffer_reader.h</a></div></div>
|
|
<div class="ttc" id="agrpc__types_8h_html"><div class="ttname"><a href="grpc__types_8h.html">grpc_types.h</a></div></div>
|
|
<div class="ttc" id="agrpc_2slice_8h_html_aaf6dd367abbe7883973588f411928c6e"><div class="ttname"><a href="grpc_2slice_8h.html#aaf6dd367abbe7883973588f411928c6e">grpc_slice_ref</a></div><div class="ttdeci">GPRAPI grpc_slice grpc_slice_ref(grpc_slice s)</div><div class="ttdoc">Increment the refcount of s.</div></div>
|
|
<div class="ttc" id="aclassgrpc_1_1_status_html"><div class="ttname"><a href="classgrpc_1_1_status.html">grpc::Status</a></div><div class="ttdoc">Did it work? If it didn't, why?</div><div class="ttdef"><b>Definition:</b> status.h:34</div></div>
|
|
<div class="ttc" id="aclassgrpc_1_1_proto_buffer_reader_html_aa50ef34b08b9cb338dc26db6be108748"><div class="ttname"><a href="classgrpc_1_1_proto_buffer_reader.html#aa50ef34b08b9cb338dc26db6be108748">grpc::ProtoBufferReader::reader</a></div><div class="ttdeci">grpc_byte_buffer_reader * reader()</div><div class="ttdef"><b>Definition:</b> proto_buffer_reader.h:191</div></div>
|
|
<div class="ttc" id="asupport_2log_8h_html"><div class="ttname"><a href="support_2log_8h.html">log.h</a></div></div>
|
|
<div class="ttc" id="aclassgrpc_1_1_proto_buffer_reader_html_a98601902abf9a69f2072e81aa65f67a0"><div class="ttname"><a href="classgrpc_1_1_proto_buffer_reader.html#a98601902abf9a69f2072e81aa65f67a0">grpc::ProtoBufferReader::ByteCount</a></div><div class="ttdeci">int64_t ByteCount() const override</div><div class="ttdoc">Returns the total number of bytes read since this object was created.</div><div class="ttdef"><b>Definition:</b> proto_buffer_reader.h:124</div></div>
|
|
<div class="ttc" id="aclassgrpc_1_1_proto_buffer_reader_html_a6f9fdfde9953f08b5ca247e6e1b2f02b"><div class="ttname"><a href="classgrpc_1_1_proto_buffer_reader.html#a6f9fdfde9953f08b5ca247e6e1b2f02b">grpc::ProtoBufferReader::Skip</a></div><div class="ttdeci">bool Skip(int count) override</div><div class="ttdoc">The proto library calls this to skip over count bytes.</div><div class="ttdef"><b>Definition:</b> proto_buffer_reader.h:108</div></div>
|
|
<div class="ttc" id="aclassgrpc_1_1_byte_buffer_html"><div class="ttname"><a href="classgrpc_1_1_byte_buffer.html">grpc::ByteBuffer</a></div><div class="ttdoc">A sequence of bytes.</div><div class="ttdef"><b>Definition:</b> byte_buffer.h:60</div></div>
|
|
<div class="ttc" id="aclassgrpc_1_1_proto_buffer_reader_html"><div class="ttname"><a href="classgrpc_1_1_proto_buffer_reader.html">grpc::ProtoBufferReader</a></div><div class="ttdoc">This is a specialization of the protobuf class ZeroCopyInputStream The principle is to get one chunk ...</div><div class="ttdef"><b>Definition:</b> proto_buffer_reader.h:48</div></div>
|
|
<div class="ttc" id="astructgrpc__slice_html"><div class="ttname"><a href="structgrpc__slice.html">grpc_slice</a></div><div class="ttdoc">A grpc_slice s, if initialized, represents the byte range s.bytes[0..s.length-1].</div><div class="ttdef"><b>Definition:</b> slice_type.h:63</div></div>
|
|
<div class="ttc" id="aclassgrpc_1_1_proto_buffer_reader_html_a9fa8b889f80d4bf56f6915ad9245ac3b"><div class="ttname"><a href="classgrpc_1_1_proto_buffer_reader.html#a9fa8b889f80d4bf56f6915ad9245ac3b">grpc::ProtoBufferReader::set_byte_count</a></div><div class="ttdeci">void set_byte_count(int64_t byte_count)</div><div class="ttdef"><b>Definition:</b> proto_buffer_reader.h:188</div></div>
|
|
<div class="ttc" id="agrpc_2byte__buffer_8h_html_ae28a4ce16b0d8ddd506f1df3fcb3c619"><div class="ttname"><a href="grpc_2byte__buffer_8h.html#ae28a4ce16b0d8ddd506f1df3fcb3c619">grpc_byte_buffer_reader_destroy</a></div><div class="ttdeci">GRPCAPI void grpc_byte_buffer_reader_destroy(grpc_byte_buffer_reader *reader)</div><div class="ttdoc">Cleanup and destroy reader.</div></div>
|
|
<div class="ttc" id="aclassgrpc_1_1_proto_buffer_reader_html_a0a79dd8c63deb9cb1837d531229a7577"><div class="ttname"><a href="classgrpc_1_1_proto_buffer_reader.html#a0a79dd8c63deb9cb1837d531229a7577">grpc::ProtoBufferReader::mutable_slice_ptr</a></div><div class="ttdeci">grpc_slice ** mutable_slice_ptr()</div><div class="ttdef"><b>Definition:</b> proto_buffer_reader.h:193</div></div>
|
|
<div class="ttc" id="agrpc_2slice_8h_html_ac334a6c6ad0a729fd4fe521df9f5ecc5"><div class="ttname"><a href="grpc_2slice_8h.html#ac334a6c6ad0a729fd4fe521df9f5ecc5">grpc_slice_sub</a></div><div class="ttdeci">GPRAPI grpc_slice grpc_slice_sub(grpc_slice s, size_t begin, size_t end)</div><div class="ttdoc">Return a result slice derived from s, which shares a ref count with s, where result....</div></div>
|
|
<div class="ttc" id="agrpc_2slice_8h_html_ac630cdfb54ff37e0490c3ebe9efd585e"><div class="ttname"><a href="grpc_2slice_8h.html#ac630cdfb54ff37e0490c3ebe9efd585e">grpc_slice_split_head</a></div><div class="ttdeci">GPRAPI grpc_slice grpc_slice_split_head(grpc_slice *s, size_t split)</div><div class="ttdoc">Splits s into two: modifies s to be s[split:s.length], and returns a new slice, sharing a refcount wi...</div></div>
|
|
<div class="ttc" id="agrpc_2byte__buffer_8h_html"><div class="ttname"><a href="grpc_2byte__buffer_8h.html">byte_buffer.h</a></div></div>
|
|
<div class="ttc" id="aclassgrpc_1_1_proto_buffer_reader_html_a50b5c353ac2d915b09e68bf9c1f7136e"><div class="ttname"><a href="classgrpc_1_1_proto_buffer_reader.html#a50b5c353ac2d915b09e68bf9c1f7136e">grpc::ProtoBufferReader::status</a></div><div class="ttdeci">Status status() const</div><div class="ttdoc">Returns the status of the buffer reader.</div><div class="ttdef"><b>Definition:</b> proto_buffer_reader.h:96</div></div>
|
|
<div class="ttc" id="agrpcpp_2impl_2serialization__traits_8h_html"><div class="ttname"><a href="grpcpp_2impl_2serialization__traits_8h.html">serialization_traits.h</a></div></div>
|
|
<div class="ttc" id="agrpcpp_2impl_2codegen_2config__protobuf_8h_html"><div class="ttname"><a href="grpcpp_2impl_2codegen_2config__protobuf_8h.html">config_protobuf.h</a></div></div>
|
|
<div class="ttc" id="agrpc_2slice_8h_html"><div class="ttname"><a href="grpc_2slice_8h.html">slice.h</a></div></div>
|
|
<div class="ttc" id="agrpc_2slice_8h_html_a5aedc925ae6e2bae484fe82383fac025"><div class="ttname"><a href="grpc_2slice_8h.html#a5aedc925ae6e2bae484fe82383fac025">grpc_slice_split_tail</a></div><div class="ttdeci">GPRAPI grpc_slice grpc_slice_split_tail(grpc_slice *s, size_t split)</div><div class="ttdoc">Splits s into two: modifies s to be s[0:split], and returns a new slice, sharing a refcount with s,...</div></div>
|
|
<div class="ttc" id="agrpcpp_2support_2byte__buffer_8h_html"><div class="ttname"><a href="grpcpp_2support_2byte__buffer_8h.html">byte_buffer.h</a></div></div>
|
|
<div class="ttc" id="agrpc_2byte__buffer_8h_html_a52e8989121500cd583bd25ca9f3ff359"><div class="ttname"><a href="grpc_2byte__buffer_8h.html#a52e8989121500cd583bd25ca9f3ff359">grpc_byte_buffer_reader_peek</a></div><div class="ttdeci">GRPCAPI int grpc_byte_buffer_reader_peek(grpc_byte_buffer_reader *reader, grpc_slice **slice)</div><div class="ttdoc">EXPERIMENTAL API - This function may be removed and changed, in the future.</div></div>
|
|
<div class="ttc" id="agrpc_2byte__buffer_8h_html_affd8fb29176a60c44fe704983fa87406"><div class="ttname"><a href="grpc_2byte__buffer_8h.html#affd8fb29176a60c44fe704983fa87406">grpc_byte_buffer_reader_init</a></div><div class="ttdeci">GRPCAPI int grpc_byte_buffer_reader_init(grpc_byte_buffer_reader *reader, grpc_byte_buffer *buffer)</div><div class="ttdoc">Initialize reader to read over buffer.</div></div>
|
|
<div class="ttc" id="agrpc_2slice_8h_html_ac9952d98910886ca44ac416d547d0e08"><div class="ttname"><a href="grpc_2slice_8h.html#ac9952d98910886ca44ac416d547d0e08">grpc_slice_unref</a></div><div class="ttdeci">GPRAPI void grpc_slice_unref(grpc_slice s)</div><div class="ttdoc">Decrement the ref count of s.</div></div>
|
|
<div class="ttc" id="aclassgrpc_1_1_byte_buffer_html_aea6bcd0d3c70fc14158df68c59dc82d4"><div class="ttname"><a href="classgrpc_1_1_byte_buffer.html#aea6bcd0d3c70fc14158df68c59dc82d4">grpc::ByteBuffer::Valid</a></div><div class="ttdeci">bool Valid() const</div><div class="ttdoc">Is this ByteBuffer valid?</div><div class="ttdef"><b>Definition:</b> byte_buffer.h:159</div></div>
|
|
<div class="ttc" id="aslice__type_8h_html_ae965fb2ee1a646253cdbd49d82b0b6c5"><div class="ttname"><a href="slice__type_8h.html#ae965fb2ee1a646253cdbd49d82b0b6c5">GRPC_SLICE_LENGTH</a></div><div class="ttdeci">#define GRPC_SLICE_LENGTH(slice)</div><div class="ttdef"><b>Definition:</b> slice_type.h:102</div></div>
|
|
<div class="ttc" id="anamespacegrpc_1_1protobuf_1_1util_html_ad372120c6db3d26bf54ab69b6f595fe4"><div class="ttname"><a href="namespacegrpc_1_1protobuf_1_1util.html#ad372120c6db3d26bf54ab69b6f595fe4">grpc::protobuf::util::Status</a></div><div class="ttdeci">::absl::Status Status</div><div class="ttdef"><b>Definition:</b> config_protobuf.h:106</div></div>
|
|
<div class="ttc" id="aclassgrpc_1_1_proto_buffer_reader_html_a0874823748781629e0b2bde470d78bf3"><div class="ttname"><a href="classgrpc_1_1_proto_buffer_reader.html#a0874823748781629e0b2bde470d78bf3">grpc::ProtoBufferReader::slice</a></div><div class="ttdeci">grpc_slice * slice()</div><div class="ttdef"><b>Definition:</b> proto_buffer_reader.h:192</div></div>
|
|
<div class="ttc" id="astructgrpc__byte__buffer__reader_html"><div class="ttname"><a href="structgrpc__byte__buffer__reader.html">grpc_byte_buffer_reader</a></div><div class="ttdef"><b>Definition:</b> byte_buffer_reader.h:30</div></div>
|
|
<div class="ttc" id="aclassgrpc_1_1_proto_buffer_reader_html_a5535d30e741c8a081a0fec40620b37e8"><div class="ttname"><a href="classgrpc_1_1_proto_buffer_reader.html#a5535d30e741c8a081a0fec40620b37e8">grpc::ProtoBufferReader::Next</a></div><div class="ttdeci">bool Next(const void **data, int *size) override</div><div class="ttdoc">Give the proto library a chunk of data from the stream.</div><div class="ttdef"><b>Definition:</b> proto_buffer_reader.h:71</div></div>
|
|
<div class="ttc" id="aclassgrpc_1_1_proto_buffer_reader_html_a56f59bca6804e19d0f780c80ccbca031"><div class="ttname"><a href="classgrpc_1_1_proto_buffer_reader.html#a56f59bca6804e19d0f780c80ccbca031">grpc::ProtoBufferReader::set_backup_count</a></div><div class="ttdeci">void set_backup_count(int64_t backup_count)</div><div class="ttdef"><b>Definition:</b> proto_buffer_reader.h:190</div></div>
|
|
<div class="ttc" id="anamespacegrpc_html_aff1730578c90160528f6a8d67ef5c43ba0ae30536146394965fd8ad64c2d414f3"><div class="ttname"><a href="namespacegrpc.html#aff1730578c90160528f6a8d67ef5c43ba0ae30536146394965fd8ad64c2d414f3">grpc::INTERNAL</a></div><div class="ttdeci">@ INTERNAL</div><div class="ttdoc">Internal errors.</div><div class="ttdef"><b>Definition:</b> status_code_enum.h:121</div></div>
|
|
<!-- start footer part -->
|
|
<hr class="footer"/><address class="footer"><small>
|
|
Generated on Fri May 17 2024 01:17:16 for GRPC C++ by  <a href="http://www.doxygen.org/index.html">
|
|
<img class="footer" src="doxygen.png" alt="doxygen"/>
|
|
</a> 1.8.17
|
|
</small></address>
|
|
</body>
|
|
</html>
|