-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathdelta_8c_source.html
550 lines (550 loc) · 102 KB
/
delta_8c_source.html
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
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
<!-- HTML header for doxygen 1.8.10-->
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://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.9.4"/>
<title>librsync: delta.c 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="doxygen.css" rel="stylesheet" type="text/css" />
</head>
<body>
<div id="top"><!-- do not remove this div, it is closed by doxygen! -->
<!-- ad -->
<script async src="//pagead2.googlesyndication.com/pagead/js/adsbygoogle.js"></script>
<!-- librsync -->
<ins class="adsbygoogle"
style="display:block"
data-ad-client="ca-pub-3547096055927362"
data-ad-slot="8322976738"
data-ad-format="auto"></ins>
<script>
(adsbygoogle = window.adsbygoogle || []).push({});
</script>
<div id="titlearea">
<table cellspacing="0" cellpadding="0">
<tbody>
<tr style="height: 56px;">
<td id="projectalign" style="padding-left: 0.5em;">
<div id="projectname">librsync
 <span id="projectnumber">2.3.4</span>
</div>
</td>
</tr>
</tbody>
</table>
</div>
<!-- end header part -->
<!-- Generated by Doxygen 1.9.4 -->
<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:d3d9a9a6595521f9666a5e94cc830dab83b65699&dn=expat.txt MIT */
$(function() {
initMenu('',false,false,'search.php','Search');
});
/* @license-end */
</script>
<div id="main-nav"></div>
<div id="nav-path" class="navpath">
<ul>
<li class="navelem"><a class="el" href="dir_68267d1309a1af8e8297ef4c3efbcdba.html">src</a></li> </ul>
</div>
</div><!-- top -->
<div class="header">
<div class="headertitle"><div class="title">delta.c</div></div>
</div><!--header-->
<div class="contents">
<a href="delta_8c.html">Go to the documentation of this file.</a><div class="fragment"><div class="line"><a id="l00001" name="l00001"></a><span class="lineno"> 1</span><span class="comment">/*= -*- c-basic-offset: 4; indent-tabs-mode: nil; -*-</span></div>
<div class="line"><a id="l00002" name="l00002"></a><span class="lineno"> 2</span><span class="comment"> *</span></div>
<div class="line"><a id="l00003" name="l00003"></a><span class="lineno"> 3</span><span class="comment"> * librsync -- library for network deltas</span></div>
<div class="line"><a id="l00004" name="l00004"></a><span class="lineno"> 4</span><span class="comment"> *</span></div>
<div class="line"><a id="l00005" name="l00005"></a><span class="lineno"> 5</span><span class="comment"> * Copyright (C) 2000, 2001 by Martin Pool <[email protected]></span></div>
<div class="line"><a id="l00006" name="l00006"></a><span class="lineno"> 6</span><span class="comment"> * Copyright (C) 2003 by Donovan Baarda <[email protected]></span></div>
<div class="line"><a id="l00007" name="l00007"></a><span class="lineno"> 7</span><span class="comment"> *</span></div>
<div class="line"><a id="l00008" name="l00008"></a><span class="lineno"> 8</span><span class="comment"> * This program is free software; you can redistribute it and/or modify</span></div>
<div class="line"><a id="l00009" name="l00009"></a><span class="lineno"> 9</span><span class="comment"> * it under the terms of the GNU Lesser General Public License as published by</span></div>
<div class="line"><a id="l00010" name="l00010"></a><span class="lineno"> 10</span><span class="comment"> * the Free Software Foundation; either version 2.1 of the License, or</span></div>
<div class="line"><a id="l00011" name="l00011"></a><span class="lineno"> 11</span><span class="comment"> * (at your option) any later version.</span></div>
<div class="line"><a id="l00012" name="l00012"></a><span class="lineno"> 12</span><span class="comment"> *</span></div>
<div class="line"><a id="l00013" name="l00013"></a><span class="lineno"> 13</span><span class="comment"> * This program is distributed in the hope that it will be useful,</span></div>
<div class="line"><a id="l00014" name="l00014"></a><span class="lineno"> 14</span><span class="comment"> * but WITHOUT ANY WARRANTY; without even the implied warranty of</span></div>
<div class="line"><a id="l00015" name="l00015"></a><span class="lineno"> 15</span><span class="comment"> * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the</span></div>
<div class="line"><a id="l00016" name="l00016"></a><span class="lineno"> 16</span><span class="comment"> * GNU Lesser General Public License for more details.</span></div>
<div class="line"><a id="l00017" name="l00017"></a><span class="lineno"> 17</span><span class="comment"> *</span></div>
<div class="line"><a id="l00018" name="l00018"></a><span class="lineno"> 18</span><span class="comment"> * You should have received a copy of the GNU Lesser General Public License</span></div>
<div class="line"><a id="l00019" name="l00019"></a><span class="lineno"> 19</span><span class="comment"> * along with this program; if not, write to the Free Software</span></div>
<div class="line"><a id="l00020" name="l00020"></a><span class="lineno"> 20</span><span class="comment"> * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.</span></div>
<div class="line"><a id="l00021" name="l00021"></a><span class="lineno"> 21</span><span class="comment"> */</span></div>
<div class="line"><a id="l00022" name="l00022"></a><span class="lineno"> 22</span> </div>
<div class="line"><a id="l00023" name="l00023"></a><span class="lineno"> 23</span> <span class="comment">/*=</span></div>
<div class="line"><a id="l00024" name="l00024"></a><span class="lineno"> 24</span><span class="comment"> | Let's climb to the TOP of that</span></div>
<div class="line"><a id="l00025" name="l00025"></a><span class="lineno"> 25</span><span class="comment"> | MOUNTAIN and think about STRIP</span></div>
<div class="line"><a id="l00026" name="l00026"></a><span class="lineno"> 26</span><span class="comment"> | MINING!!</span></div>
<div class="line"><a id="l00027" name="l00027"></a><span class="lineno"> 27</span><span class="comment"> */</span></div>
<div class="line"><a id="l00028" name="l00028"></a><span class="lineno"> 28</span><span class="comment"></span> </div>
<div class="line"><a id="l00029" name="l00029"></a><span class="lineno"> 29</span><span class="comment">/** \file delta.c</span></div>
<div class="line"><a id="l00030" name="l00030"></a><span class="lineno"> 30</span><span class="comment"> * Generate in streaming mode an rsync delta given a set of signatures, and a</span></div>
<div class="line"><a id="l00031" name="l00031"></a><span class="lineno"> 31</span><span class="comment"> * new file.</span></div>
<div class="line"><a id="l00032" name="l00032"></a><span class="lineno"> 32</span><span class="comment"> *</span></div>
<div class="line"><a id="l00033" name="l00033"></a><span class="lineno"> 33</span><span class="comment"> * The size of blocks for signature generation is determined by the block size</span></div>
<div class="line"><a id="l00034" name="l00034"></a><span class="lineno"> 34</span><span class="comment"> * in the incoming signature.</span></div>
<div class="line"><a id="l00035" name="l00035"></a><span class="lineno"> 35</span><span class="comment"> *</span></div>
<div class="line"><a id="l00036" name="l00036"></a><span class="lineno"> 36</span><span class="comment"> * To calculate a signature, we need to be able to see at least one block of</span></div>
<div class="line"><a id="l00037" name="l00037"></a><span class="lineno"> 37</span><span class="comment"> * the new file at a time. Once we have that, we calculate its weak signature,</span></div>
<div class="line"><a id="l00038" name="l00038"></a><span class="lineno"> 38</span><span class="comment"> * and see if there is any block in the signature hash table that has the same</span></div>
<div class="line"><a id="l00039" name="l00039"></a><span class="lineno"> 39</span><span class="comment"> * weak sum. If there is one, then we also compute the strong sum of the new</span></div>
<div class="line"><a id="l00040" name="l00040"></a><span class="lineno"> 40</span><span class="comment"> * block, and cross check that. If they're the same, then we can assume we have</span></div>
<div class="line"><a id="l00041" name="l00041"></a><span class="lineno"> 41</span><span class="comment"> * a match.</span></div>
<div class="line"><a id="l00042" name="l00042"></a><span class="lineno"> 42</span><span class="comment"> *</span></div>
<div class="line"><a id="l00043" name="l00043"></a><span class="lineno"> 43</span><span class="comment"> * The final block of the file has to be handled a little differently, because</span></div>
<div class="line"><a id="l00044" name="l00044"></a><span class="lineno"> 44</span><span class="comment"> * it may be a short match. Short blocks in the signature don't include their</span></div>
<div class="line"><a id="l00045" name="l00045"></a><span class="lineno"> 45</span><span class="comment"> * length -- we just allow for the final short block of the file to match any</span></div>
<div class="line"><a id="l00046" name="l00046"></a><span class="lineno"> 46</span><span class="comment"> * block in the signature, and if they have the same checksum we assume they</span></div>
<div class="line"><a id="l00047" name="l00047"></a><span class="lineno"> 47</span><span class="comment"> * must have the same length. Therefore, when we emit a COPY command, we have</span></div>
<div class="line"><a id="l00048" name="l00048"></a><span class="lineno"> 48</span><span class="comment"> * to send it with a length that is the same as the block matched, and not the</span></div>
<div class="line"><a id="l00049" name="l00049"></a><span class="lineno"> 49</span><span class="comment"> * block length from the signature.</span></div>
<div class="line"><a id="l00050" name="l00050"></a><span class="lineno"> 50</span><span class="comment"> *</span></div>
<div class="line"><a id="l00051" name="l00051"></a><span class="lineno"> 51</span><span class="comment"> * Profiling results as of v1.26, 2001-03-18:</span></div>
<div class="line"><a id="l00052" name="l00052"></a><span class="lineno"> 52</span><span class="comment"> *</span></div>
<div class="line"><a id="l00053" name="l00053"></a><span class="lineno"> 53</span><span class="comment"> * If everything matches, then we spend almost all our time in rs_mdfour64 and</span></div>
<div class="line"><a id="l00054" name="l00054"></a><span class="lineno"> 54</span><span class="comment"> * rs_weak_sum, which is unavoidable and therefore a good profile.</span></div>
<div class="line"><a id="l00055" name="l00055"></a><span class="lineno"> 55</span><span class="comment"> *</span></div>
<div class="line"><a id="l00056" name="l00056"></a><span class="lineno"> 56</span><span class="comment"> * If nothing matches, it is not so good.</span></div>
<div class="line"><a id="l00057" name="l00057"></a><span class="lineno"> 57</span><span class="comment"> *</span></div>
<div class="line"><a id="l00058" name="l00058"></a><span class="lineno"> 58</span><span class="comment"> * 2002-06-26: Donovan Baarda</span></div>
<div class="line"><a id="l00059" name="l00059"></a><span class="lineno"> 59</span><span class="comment"> *</span></div>
<div class="line"><a id="l00060" name="l00060"></a><span class="lineno"> 60</span><span class="comment"> * The following is based entirely on pysync. It is much cleaner than the</span></div>
<div class="line"><a id="l00061" name="l00061"></a><span class="lineno"> 61</span><span class="comment"> * previous incarnation of this code. It is slightly complicated because in</span></div>
<div class="line"><a id="l00062" name="l00062"></a><span class="lineno"> 62</span><span class="comment"> * this case the output can block, so the main delta loop needs to stop when</span></div>
<div class="line"><a id="l00063" name="l00063"></a><span class="lineno"> 63</span><span class="comment"> * this happens.</span></div>
<div class="line"><a id="l00064" name="l00064"></a><span class="lineno"> 64</span><span class="comment"> *</span></div>
<div class="line"><a id="l00065" name="l00065"></a><span class="lineno"> 65</span><span class="comment"> * In pysync a 'last' attribute is used to hold the last miss or match for</span></div>
<div class="line"><a id="l00066" name="l00066"></a><span class="lineno"> 66</span><span class="comment"> * extending if possible. In this code, basis_len and scan_pos are used instead</span></div>
<div class="line"><a id="l00067" name="l00067"></a><span class="lineno"> 67</span><span class="comment"> * of 'last'. When basis_len > 0, last is a match. When basis_len = 0 and</span></div>
<div class="line"><a id="l00068" name="l00068"></a><span class="lineno"> 68</span><span class="comment"> * scan_pos is > 0, last is a miss. When both are 0, last is None (ie,</span></div>
<div class="line"><a id="l00069" name="l00069"></a><span class="lineno"> 69</span><span class="comment"> * nothing).</span></div>
<div class="line"><a id="l00070" name="l00070"></a><span class="lineno"> 70</span><span class="comment"> *</span></div>
<div class="line"><a id="l00071" name="l00071"></a><span class="lineno"> 71</span><span class="comment"> * Pysync is also slightly different in that a 'flush' method is available to</span></div>
<div class="line"><a id="l00072" name="l00072"></a><span class="lineno"> 72</span><span class="comment"> * force output of accumulated data. This 'flush' is use to finalise delta</span></div>
<div class="line"><a id="l00073" name="l00073"></a><span class="lineno"> 73</span><span class="comment"> * calculation. In librsync input is terminated with an eof flag on the input</span></div>
<div class="line"><a id="l00074" name="l00074"></a><span class="lineno"> 74</span><span class="comment"> * stream. I have structured this code similar to pysync with a seperate flush</span></div>
<div class="line"><a id="l00075" name="l00075"></a><span class="lineno"> 75</span><span class="comment"> * function that is used when eof is reached. This allows for a flush style API</span></div>
<div class="line"><a id="l00076" name="l00076"></a><span class="lineno"> 76</span><span class="comment"> * if one is ever needed. Note that flush in pysync can be used for more than</span></div>
<div class="line"><a id="l00077" name="l00077"></a><span class="lineno"> 77</span><span class="comment"> * just terminating delta calculation, so a flush based API can in some ways be</span></div>
<div class="line"><a id="l00078" name="l00078"></a><span class="lineno"> 78</span><span class="comment"> * more flexible...</span></div>
<div class="line"><a id="l00079" name="l00079"></a><span class="lineno"> 79</span><span class="comment"> *</span></div>
<div class="line"><a id="l00080" name="l00080"></a><span class="lineno"> 80</span><span class="comment"> * The input data is first scanned, then processed. Scanning identifies input</span></div>
<div class="line"><a id="l00081" name="l00081"></a><span class="lineno"> 81</span><span class="comment"> * data as misses or matches, and emits the instruction stream. Processing the</span></div>
<div class="line"><a id="l00082" name="l00082"></a><span class="lineno"> 82</span><span class="comment"> * data consumes it off the input scoop and outputs the processed miss data</span></div>
<div class="line"><a id="l00083" name="l00083"></a><span class="lineno"> 83</span><span class="comment"> * into the tube.</span></div>
<div class="line"><a id="l00084" name="l00084"></a><span class="lineno"> 84</span><span class="comment"> *</span></div>
<div class="line"><a id="l00085" name="l00085"></a><span class="lineno"> 85</span><span class="comment"> * The scoop contains all data yet to be processed. The scan_pos is an index</span></div>
<div class="line"><a id="l00086" name="l00086"></a><span class="lineno"> 86</span><span class="comment"> * into the scoop that indicates the point scanned to. As data is scanned,</span></div>
<div class="line"><a id="l00087" name="l00087"></a><span class="lineno"> 87</span><span class="comment"> * scan_pos is incremented. As data is processed, it is removed from the scoop</span></div>
<div class="line"><a id="l00088" name="l00088"></a><span class="lineno"> 88</span><span class="comment"> * and scan_pos adjusted. Everything gets complicated because the tube can</span></div>
<div class="line"><a id="l00089" name="l00089"></a><span class="lineno"> 89</span><span class="comment"> * block. When the tube is blocked, no data can be processed. */</span></div>
<div class="line"><a id="l00090" name="l00090"></a><span class="lineno"> 90</span> </div>
<div class="line"><a id="l00091" name="l00091"></a><span class="lineno"> 91</span><span class="preprocessor">#include "config.h"</span> <span class="comment">/* IWYU pragma: keep */</span></div>
<div class="line"><a id="l00092" name="l00092"></a><span class="lineno"> 92</span><span class="preprocessor">#include <assert.h></span></div>
<div class="line"><a id="l00093" name="l00093"></a><span class="lineno"> 93</span><span class="preprocessor">#include <stdlib.h></span></div>
<div class="line"><a id="l00094" name="l00094"></a><span class="lineno"> 94</span><span class="preprocessor">#include "<a class="code" href="librsync_8h.html">librsync.h</a>"</span></div>
<div class="line"><a id="l00095" name="l00095"></a><span class="lineno"> 95</span><span class="preprocessor">#include "<a class="code" href="job_8h.html">job.h</a>"</span></div>
<div class="line"><a id="l00096" name="l00096"></a><span class="lineno"> 96</span><span class="preprocessor">#include "<a class="code" href="sumset_8h.html">sumset.h</a>"</span></div>
<div class="line"><a id="l00097" name="l00097"></a><span class="lineno"> 97</span><span class="preprocessor">#include "<a class="code" href="checksum_8h.html">checksum.h</a>"</span></div>
<div class="line"><a id="l00098" name="l00098"></a><span class="lineno"> 98</span><span class="preprocessor">#include "<a class="code" href="scoop_8h.html">scoop.h</a>"</span></div>
<div class="line"><a id="l00099" name="l00099"></a><span class="lineno"> 99</span><span class="preprocessor">#include "<a class="code" href="emit_8h.html">emit.h</a>"</span></div>
<div class="line"><a id="l00100" name="l00100"></a><span class="lineno"> 100</span><span class="preprocessor">#include "<a class="code" href="trace_8h.html">trace.h</a>"</span></div>
<div class="line"><a id="l00101" name="l00101"></a><span class="lineno"> 101</span><span class="comment"></span> </div>
<div class="line"><a id="l00102" name="l00102"></a><span class="lineno"> 102</span><span class="comment">/** Max length of a miss is 64K including 3 command bytes. */</span></div>
<div class="line"><a id="l00103" name="l00103"></a><span class="lineno"><a class="line" href="delta_8c.html#ad38b7f45cf4177503166b0d00af71cff"> 103</a></span><span class="preprocessor">#define MAX_MISS_LEN (MAX_DELTA_CMD - 3)</span></div>
<div class="line"><a id="l00104" name="l00104"></a><span class="lineno"> 104</span> </div>
<div class="line"><a id="l00105" name="l00105"></a><span class="lineno"> 105</span><span class="keyword">static</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> <a class="code hl_function" href="delta_8c.html#a6a992cf5dc0916678a7094c21b85d5fe">rs_delta_s_scan</a>(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job);</div>
<div class="line"><a id="l00106" name="l00106"></a><span class="lineno"> 106</span><span class="keyword">static</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> rs_delta_s_flush(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job);</div>
<div class="line"><a id="l00107" name="l00107"></a><span class="lineno"> 107</span><span class="keyword">static</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> rs_delta_s_end(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job);</div>
<div class="line"><a id="l00108" name="l00108"></a><span class="lineno"> 108</span><span class="keyword">static</span> <span class="keyword">inline</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> rs_getinput(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job, <span class="keywordtype">size_t</span> block_len);</div>
<div class="line"><a id="l00109" name="l00109"></a><span class="lineno"> 109</span><span class="keyword">static</span> <span class="keyword">inline</span> <span class="keywordtype">int</span> <a class="code hl_function" href="delta_8c.html#a02cb5f8a81c7cb63d2557023c56929e7">rs_findmatch</a>(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job, rs_long_t *match_pos,</div>
<div class="line"><a id="l00110" name="l00110"></a><span class="lineno"> 110</span> <span class="keywordtype">size_t</span> *match_len);</div>
<div class="line"><a id="l00111" name="l00111"></a><span class="lineno"> 111</span><span class="keyword">static</span> <span class="keyword">inline</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> <a class="code hl_function" href="delta_8c.html#acc386d6304337b138b79b5712c15931a">rs_appendmatch</a>(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job, rs_long_t match_pos,</div>
<div class="line"><a id="l00112" name="l00112"></a><span class="lineno"> 112</span> <span class="keywordtype">size_t</span> match_len);</div>
<div class="line"><a id="l00113" name="l00113"></a><span class="lineno"> 113</span><span class="keyword">static</span> <span class="keyword">inline</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> <a class="code hl_function" href="delta_8c.html#a832b35b9afeeb51561f08daf13738571">rs_appendmiss</a>(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job, <span class="keywordtype">size_t</span> miss_len);</div>
<div class="line"><a id="l00114" name="l00114"></a><span class="lineno"> 114</span><span class="keyword">static</span> <span class="keyword">inline</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> <a class="code hl_function" href="delta_8c.html#a8c7bfd74ede4c7fa74eeca10bb5d6679">rs_appendflush</a>(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job);</div>
<div class="line"><a id="l00115" name="l00115"></a><span class="lineno"> 115</span><span class="keyword">static</span> <span class="keyword">inline</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> <a class="code hl_function" href="delta_8c.html#a2e40db810b7290fe6d5fd1be2656e04d">rs_processmatch</a>(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job);</div>
<div class="line"><a id="l00116" name="l00116"></a><span class="lineno"> 116</span><span class="keyword">static</span> <span class="keyword">inline</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> <a class="code hl_function" href="delta_8c.html#a17e651660e2da438be938cfcf4f5d0b7">rs_processmiss</a>(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job);</div>
<div class="line"><a id="l00117" name="l00117"></a><span class="lineno"> 117</span><span class="comment"></span> </div>
<div class="line"><a id="l00118" name="l00118"></a><span class="lineno"> 118</span><span class="comment">/** Get a block of data if possible, and see if it matches.</span></div>
<div class="line"><a id="l00119" name="l00119"></a><span class="lineno"> 119</span><span class="comment"> *</span></div>
<div class="line"><a id="l00120" name="l00120"></a><span class="lineno"> 120</span><span class="comment"> * On each call, we try to process all of the input data available on the scoop</span></div>
<div class="line"><a id="l00121" name="l00121"></a><span class="lineno"> 121</span><span class="comment"> * and input buffer. */</span></div>
<div class="line"><a id="l00122" name="l00122"></a><span class="lineno"><a class="line" href="delta_8c.html#a6a992cf5dc0916678a7094c21b85d5fe"> 122</a></span><span class="keyword">static</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> <a class="code hl_function" href="delta_8c.html#a6a992cf5dc0916678a7094c21b85d5fe">rs_delta_s_scan</a>(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job)</div>
<div class="line"><a id="l00123" name="l00123"></a><span class="lineno"> 123</span>{</div>
<div class="line"><a id="l00124" name="l00124"></a><span class="lineno"> 124</span> <span class="keyword">const</span> <span class="keywordtype">size_t</span> block_len = job-><a class="code hl_variable" href="structrs__job.html#ac8b7a197f196b0eabdd1dd2de0f7852f">signature</a>-><a class="code hl_variable" href="structrs__signature.html#a8df88cba2f5ef197c2dabc72579409e6">block_len</a>;</div>
<div class="line"><a id="l00125" name="l00125"></a><span class="lineno"> 125</span> rs_long_t match_pos;</div>
<div class="line"><a id="l00126" name="l00126"></a><span class="lineno"> 126</span> <span class="keywordtype">size_t</span> match_len;</div>
<div class="line"><a id="l00127" name="l00127"></a><span class="lineno"> 127</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> result;</div>
<div class="line"><a id="l00128" name="l00128"></a><span class="lineno"> 128</span> </div>
<div class="line"><a id="l00129" name="l00129"></a><span class="lineno"> 129</span> <a class="code hl_define" href="job_8h.html#ab715a4b7294c5fe2ae74765477a521dd">rs_job_check</a>(job);</div>
<div class="line"><a id="l00130" name="l00130"></a><span class="lineno"> 130</span> <span class="comment">/* output any pending output from the tube */</span></div>
<div class="line"><a id="l00131" name="l00131"></a><span class="lineno"> 131</span> <span class="keywordflow">if</span> ((result = <a class="code hl_function" href="scoop_8h.html#a5285265e3d220e43b8fd08867d708d9c">rs_tube_catchup</a>(job)) != <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a739063053a289b5c3393d78cc77b41b2">RS_DONE</a>)</div>
<div class="line"><a id="l00132" name="l00132"></a><span class="lineno"> 132</span> <span class="keywordflow">return</span> result;</div>
<div class="line"><a id="l00133" name="l00133"></a><span class="lineno"> 133</span> <span class="comment">/* read the input into the scoop */</span></div>
<div class="line"><a id="l00134" name="l00134"></a><span class="lineno"> 134</span> <span class="keywordflow">if</span> ((result = rs_getinput(job, block_len)) != <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a739063053a289b5c3393d78cc77b41b2">RS_DONE</a>)</div>
<div class="line"><a id="l00135" name="l00135"></a><span class="lineno"> 135</span> <span class="keywordflow">return</span> result;</div>
<div class="line"><a id="l00136" name="l00136"></a><span class="lineno"> 136</span> <span class="comment">/* while output is not blocked and there is a block of data */</span></div>
<div class="line"><a id="l00137" name="l00137"></a><span class="lineno"> 137</span> <span class="keywordflow">while</span> ((result == <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a739063053a289b5c3393d78cc77b41b2">RS_DONE</a>) && ((job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a> + block_len) < job-><a class="code hl_variable" href="structrs__job.html#a9a00375090f27e158987f58987e8e7a0">scan_len</a>)) {</div>
<div class="line"><a id="l00138" name="l00138"></a><span class="lineno"> 138</span> <span class="comment">/* check if this block matches */</span></div>
<div class="line"><a id="l00139" name="l00139"></a><span class="lineno"> 139</span> <span class="keywordflow">if</span> (<a class="code hl_function" href="delta_8c.html#a02cb5f8a81c7cb63d2557023c56929e7">rs_findmatch</a>(job, &match_pos, &match_len)) {</div>
<div class="line"><a id="l00140" name="l00140"></a><span class="lineno"> 140</span> <span class="comment">/* append the match and reset the weak_sum */</span></div>
<div class="line"><a id="l00141" name="l00141"></a><span class="lineno"> 141</span> result = <a class="code hl_function" href="delta_8c.html#acc386d6304337b138b79b5712c15931a">rs_appendmatch</a>(job, match_pos, match_len);</div>
<div class="line"><a id="l00142" name="l00142"></a><span class="lineno"> 142</span> weaksum_reset(&job-><a class="code hl_variable" href="structrs__job.html#aec548f7a84b838c552e304e83c5a1775">weak_sum</a>);</div>
<div class="line"><a id="l00143" name="l00143"></a><span class="lineno"> 143</span> } <span class="keywordflow">else</span> {</div>
<div class="line"><a id="l00144" name="l00144"></a><span class="lineno"> 144</span> <span class="comment">/* rotate the weak_sum and append the miss byte */</span></div>
<div class="line"><a id="l00145" name="l00145"></a><span class="lineno"> 145</span> weaksum_rotate(&job-><a class="code hl_variable" href="structrs__job.html#aec548f7a84b838c552e304e83c5a1775">weak_sum</a>, job-><a class="code hl_variable" href="structrs__job.html#a2dcaea58f56c153083ca05cd2da3d868">scan_buf</a>[job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a>],</div>
<div class="line"><a id="l00146" name="l00146"></a><span class="lineno"> 146</span> job-><a class="code hl_variable" href="structrs__job.html#a2dcaea58f56c153083ca05cd2da3d868">scan_buf</a>[job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a> + block_len]);</div>
<div class="line"><a id="l00147" name="l00147"></a><span class="lineno"> 147</span> result = <a class="code hl_function" href="delta_8c.html#a832b35b9afeeb51561f08daf13738571">rs_appendmiss</a>(job, 1);</div>
<div class="line"><a id="l00148" name="l00148"></a><span class="lineno"> 148</span> }</div>
<div class="line"><a id="l00149" name="l00149"></a><span class="lineno"> 149</span> }</div>
<div class="line"><a id="l00150" name="l00150"></a><span class="lineno"> 150</span> <span class="comment">/* if we completed OK */</span></div>
<div class="line"><a id="l00151" name="l00151"></a><span class="lineno"> 151</span> <span class="keywordflow">if</span> (result == <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a739063053a289b5c3393d78cc77b41b2">RS_DONE</a>) {</div>
<div class="line"><a id="l00152" name="l00152"></a><span class="lineno"> 152</span> <span class="comment">/* if we reached eof, we can flush the last fragment */</span></div>
<div class="line"><a id="l00153" name="l00153"></a><span class="lineno"> 153</span> <span class="keywordflow">if</span> (job->stream-><a class="code hl_variable" href="structrs__buffers__s.html#aa6783da2d894c77178155759cd12d16f">eof_in</a>) {</div>
<div class="line"><a id="l00154" name="l00154"></a><span class="lineno"> 154</span> job-><a class="code hl_variable" href="structrs__job.html#aa789990d61f5eadc6a26aeedf4bec765">statefn</a> = rs_delta_s_flush;</div>
<div class="line"><a id="l00155" name="l00155"></a><span class="lineno"> 155</span> <span class="keywordflow">return</span> <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a5366e53561c2ec9a897470535ea0139c">RS_RUNNING</a>;</div>
<div class="line"><a id="l00156" name="l00156"></a><span class="lineno"> 156</span> } <span class="keywordflow">else</span> {</div>
<div class="line"><a id="l00157" name="l00157"></a><span class="lineno"> 157</span> <span class="comment">/* we are blocked waiting for more data */</span></div>
<div class="line"><a id="l00158" name="l00158"></a><span class="lineno"> 158</span> <span class="keywordflow">return</span> <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253af2d289bbc65678b4b00f56a2e6632957">RS_BLOCKED</a>;</div>
<div class="line"><a id="l00159" name="l00159"></a><span class="lineno"> 159</span> }</div>
<div class="line"><a id="l00160" name="l00160"></a><span class="lineno"> 160</span> }</div>
<div class="line"><a id="l00161" name="l00161"></a><span class="lineno"> 161</span> <span class="keywordflow">return</span> result;</div>
<div class="line"><a id="l00162" name="l00162"></a><span class="lineno"> 162</span>}</div>
<div class="line"><a id="l00163" name="l00163"></a><span class="lineno"> 163</span> </div>
<div class="line"><a id="l00164" name="l00164"></a><span class="lineno"> 164</span><span class="keyword">static</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> rs_delta_s_flush(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job)</div>
<div class="line"><a id="l00165" name="l00165"></a><span class="lineno"> 165</span>{</div>
<div class="line"><a id="l00166" name="l00166"></a><span class="lineno"> 166</span> <span class="keyword">const</span> <span class="keywordtype">size_t</span> block_len = job-><a class="code hl_variable" href="structrs__job.html#ac8b7a197f196b0eabdd1dd2de0f7852f">signature</a>-><a class="code hl_variable" href="structrs__signature.html#a8df88cba2f5ef197c2dabc72579409e6">block_len</a>;</div>
<div class="line"><a id="l00167" name="l00167"></a><span class="lineno"> 167</span> rs_long_t match_pos;</div>
<div class="line"><a id="l00168" name="l00168"></a><span class="lineno"> 168</span> <span class="keywordtype">size_t</span> match_len;</div>
<div class="line"><a id="l00169" name="l00169"></a><span class="lineno"> 169</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> result;</div>
<div class="line"><a id="l00170" name="l00170"></a><span class="lineno"> 170</span> </div>
<div class="line"><a id="l00171" name="l00171"></a><span class="lineno"> 171</span> <a class="code hl_define" href="job_8h.html#ab715a4b7294c5fe2ae74765477a521dd">rs_job_check</a>(job);</div>
<div class="line"><a id="l00172" name="l00172"></a><span class="lineno"> 172</span> <span class="comment">/* output any pending output from the tube */</span></div>
<div class="line"><a id="l00173" name="l00173"></a><span class="lineno"> 173</span> <span class="keywordflow">if</span> ((result = <a class="code hl_function" href="scoop_8h.html#a5285265e3d220e43b8fd08867d708d9c">rs_tube_catchup</a>(job)) != <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a739063053a289b5c3393d78cc77b41b2">RS_DONE</a>)</div>
<div class="line"><a id="l00174" name="l00174"></a><span class="lineno"> 174</span> <span class="keywordflow">return</span> result;</div>
<div class="line"><a id="l00175" name="l00175"></a><span class="lineno"> 175</span> <span class="comment">/* read the input into the scoop */</span></div>
<div class="line"><a id="l00176" name="l00176"></a><span class="lineno"> 176</span> <span class="keywordflow">if</span> ((result = rs_getinput(job, block_len)) != <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a739063053a289b5c3393d78cc77b41b2">RS_DONE</a>)</div>
<div class="line"><a id="l00177" name="l00177"></a><span class="lineno"> 177</span> <span class="keywordflow">return</span> result;</div>
<div class="line"><a id="l00178" name="l00178"></a><span class="lineno"> 178</span> <span class="comment">/* while output is not blocked and there is any remaining data */</span></div>
<div class="line"><a id="l00179" name="l00179"></a><span class="lineno"> 179</span> <span class="keywordflow">while</span> ((result == <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a739063053a289b5c3393d78cc77b41b2">RS_DONE</a>) && (job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a> < job-><a class="code hl_variable" href="structrs__job.html#a9a00375090f27e158987f58987e8e7a0">scan_len</a>)) {</div>
<div class="line"><a id="l00180" name="l00180"></a><span class="lineno"> 180</span> <span class="comment">/* check if this block matches */</span></div>
<div class="line"><a id="l00181" name="l00181"></a><span class="lineno"> 181</span> <span class="keywordflow">if</span> (<a class="code hl_function" href="delta_8c.html#a02cb5f8a81c7cb63d2557023c56929e7">rs_findmatch</a>(job, &match_pos, &match_len)) {</div>
<div class="line"><a id="l00182" name="l00182"></a><span class="lineno"> 182</span> <span class="comment">/* append the match and reset the weak_sum */</span></div>
<div class="line"><a id="l00183" name="l00183"></a><span class="lineno"> 183</span> result = <a class="code hl_function" href="delta_8c.html#acc386d6304337b138b79b5712c15931a">rs_appendmatch</a>(job, match_pos, match_len);</div>
<div class="line"><a id="l00184" name="l00184"></a><span class="lineno"> 184</span> weaksum_reset(&job-><a class="code hl_variable" href="structrs__job.html#aec548f7a84b838c552e304e83c5a1775">weak_sum</a>);</div>
<div class="line"><a id="l00185" name="l00185"></a><span class="lineno"> 185</span> } <span class="keywordflow">else</span> {</div>
<div class="line"><a id="l00186" name="l00186"></a><span class="lineno"> 186</span> <span class="comment">/* rollout from weak_sum and append the miss byte */</span></div>
<div class="line"><a id="l00187" name="l00187"></a><span class="lineno"> 187</span> weaksum_rollout(&job-><a class="code hl_variable" href="structrs__job.html#aec548f7a84b838c552e304e83c5a1775">weak_sum</a>, job-><a class="code hl_variable" href="structrs__job.html#a2dcaea58f56c153083ca05cd2da3d868">scan_buf</a>[job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a>]);</div>
<div class="line"><a id="l00188" name="l00188"></a><span class="lineno"> 188</span> rs_trace(<span class="stringliteral">"block reduced to "</span> FMT_SIZE <span class="stringliteral">""</span>,</div>
<div class="line"><a id="l00189" name="l00189"></a><span class="lineno"> 189</span> weaksum_count(&job-><a class="code hl_variable" href="structrs__job.html#aec548f7a84b838c552e304e83c5a1775">weak_sum</a>));</div>
<div class="line"><a id="l00190" name="l00190"></a><span class="lineno"> 190</span> result = <a class="code hl_function" href="delta_8c.html#a832b35b9afeeb51561f08daf13738571">rs_appendmiss</a>(job, 1);</div>
<div class="line"><a id="l00191" name="l00191"></a><span class="lineno"> 191</span> }</div>
<div class="line"><a id="l00192" name="l00192"></a><span class="lineno"> 192</span> }</div>
<div class="line"><a id="l00193" name="l00193"></a><span class="lineno"> 193</span> <span class="comment">/* if we are not blocked, flush and set end statefn. */</span></div>
<div class="line"><a id="l00194" name="l00194"></a><span class="lineno"> 194</span> <span class="keywordflow">if</span> (result == <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a739063053a289b5c3393d78cc77b41b2">RS_DONE</a>) {</div>
<div class="line"><a id="l00195" name="l00195"></a><span class="lineno"> 195</span> result = <a class="code hl_function" href="delta_8c.html#a8c7bfd74ede4c7fa74eeca10bb5d6679">rs_appendflush</a>(job);</div>
<div class="line"><a id="l00196" name="l00196"></a><span class="lineno"> 196</span> job-><a class="code hl_variable" href="structrs__job.html#aa789990d61f5eadc6a26aeedf4bec765">statefn</a> = rs_delta_s_end;</div>
<div class="line"><a id="l00197" name="l00197"></a><span class="lineno"> 197</span> }</div>
<div class="line"><a id="l00198" name="l00198"></a><span class="lineno"> 198</span> <span class="keywordflow">if</span> (result == <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a739063053a289b5c3393d78cc77b41b2">RS_DONE</a>) {</div>
<div class="line"><a id="l00199" name="l00199"></a><span class="lineno"> 199</span> <span class="keywordflow">return</span> <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a5366e53561c2ec9a897470535ea0139c">RS_RUNNING</a>;</div>
<div class="line"><a id="l00200" name="l00200"></a><span class="lineno"> 200</span> }</div>
<div class="line"><a id="l00201" name="l00201"></a><span class="lineno"> 201</span> <span class="keywordflow">return</span> result;</div>
<div class="line"><a id="l00202" name="l00202"></a><span class="lineno"> 202</span>}</div>
<div class="line"><a id="l00203" name="l00203"></a><span class="lineno"> 203</span> </div>
<div class="line"><a id="l00204" name="l00204"></a><span class="lineno"> 204</span><span class="keyword">static</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> rs_delta_s_end(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job)</div>
<div class="line"><a id="l00205" name="l00205"></a><span class="lineno"> 205</span>{</div>
<div class="line"><a id="l00206" name="l00206"></a><span class="lineno"> 206</span> <a class="code hl_function" href="emit_8h.html#ac985ddc29525e655018bed59c4886ca8">rs_emit_end_cmd</a>(job);</div>
<div class="line"><a id="l00207" name="l00207"></a><span class="lineno"> 207</span> <span class="keywordflow">return</span> <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a739063053a289b5c3393d78cc77b41b2">RS_DONE</a>;</div>
<div class="line"><a id="l00208" name="l00208"></a><span class="lineno"> 208</span>}</div>
<div class="line"><a id="l00209" name="l00209"></a><span class="lineno"> 209</span> </div>
<div class="line"><a id="l00210" name="l00210"></a><span class="lineno"> 210</span><span class="keyword">static</span> <span class="keyword">inline</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> rs_getinput(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job, <span class="keywordtype">size_t</span> block_len)</div>
<div class="line"><a id="l00211" name="l00211"></a><span class="lineno"> 211</span>{</div>
<div class="line"><a id="l00212" name="l00212"></a><span class="lineno"> 212</span> <span class="keywordtype">size_t</span> min_len = block_len + <a class="code hl_define" href="job_8h.html#abdbdf5fbcdaed953e687867db175e4c5">MAX_DELTA_CMD</a>;</div>
<div class="line"><a id="l00213" name="l00213"></a><span class="lineno"> 213</span> </div>
<div class="line"><a id="l00214" name="l00214"></a><span class="lineno"> 214</span> job-><a class="code hl_variable" href="structrs__job.html#a9a00375090f27e158987f58987e8e7a0">scan_len</a> = rs_scoop_avail(job);</div>
<div class="line"><a id="l00215" name="l00215"></a><span class="lineno"> 215</span> <span class="keywordflow">if</span> (job-><a class="code hl_variable" href="structrs__job.html#a9a00375090f27e158987f58987e8e7a0">scan_len</a> < min_len && !job->stream-><a class="code hl_variable" href="structrs__buffers__s.html#aa6783da2d894c77178155759cd12d16f">eof_in</a>)</div>
<div class="line"><a id="l00216" name="l00216"></a><span class="lineno"> 216</span> job-><a class="code hl_variable" href="structrs__job.html#a9a00375090f27e158987f58987e8e7a0">scan_len</a> = min_len;</div>
<div class="line"><a id="l00217" name="l00217"></a><span class="lineno"> 217</span> <span class="keywordflow">return</span> <a class="code hl_function" href="scoop_8c.html#a026b9505478d48f4b9b05fea46c166e1">rs_scoop_readahead</a>(job, job-><a class="code hl_variable" href="structrs__job.html#a9a00375090f27e158987f58987e8e7a0">scan_len</a>, (<span class="keywordtype">void</span> **)&job-><a class="code hl_variable" href="structrs__job.html#a2dcaea58f56c153083ca05cd2da3d868">scan_buf</a>);</div>
<div class="line"><a id="l00218" name="l00218"></a><span class="lineno"> 218</span>}</div>
<div class="line"><a id="l00219" name="l00219"></a><span class="lineno"> 219</span><span class="comment"></span> </div>
<div class="line"><a id="l00220" name="l00220"></a><span class="lineno"> 220</span><span class="comment">/** find a match at scan_pos, returning the match_pos and match_len.</span></div>
<div class="line"><a id="l00221" name="l00221"></a><span class="lineno"> 221</span><span class="comment"> *</span></div>
<div class="line"><a id="l00222" name="l00222"></a><span class="lineno"> 222</span><span class="comment"> * Note that this will calculate weak_sum if required. It will also determine</span></div>
<div class="line"><a id="l00223" name="l00223"></a><span class="lineno"> 223</span><span class="comment"> * the match_len.</span></div>
<div class="line"><a id="l00224" name="l00224"></a><span class="lineno"> 224</span><span class="comment"> *</span></div>
<div class="line"><a id="l00225" name="l00225"></a><span class="lineno"> 225</span><span class="comment"> * This routine could be modified to do xdelta style matches that would extend</span></div>
<div class="line"><a id="l00226" name="l00226"></a><span class="lineno"> 226</span><span class="comment"> * matches past block boundaries by matching backwards and forwards beyond the</span></div>
<div class="line"><a id="l00227" name="l00227"></a><span class="lineno"> 227</span><span class="comment"> * block boundaries. Extending backwards would require decrementing scan_pos as</span></div>
<div class="line"><a id="l00228" name="l00228"></a><span class="lineno"> 228</span><span class="comment"> * appropriate. */</span></div>
<div class="line"><a id="l00229" name="l00229"></a><span class="lineno"><a class="line" href="delta_8c.html#a02cb5f8a81c7cb63d2557023c56929e7"> 229</a></span><span class="keyword">static</span> <span class="keyword">inline</span> <span class="keywordtype">int</span> <a class="code hl_function" href="delta_8c.html#a02cb5f8a81c7cb63d2557023c56929e7">rs_findmatch</a>(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job, rs_long_t *match_pos,</div>
<div class="line"><a id="l00230" name="l00230"></a><span class="lineno"> 230</span> <span class="keywordtype">size_t</span> *match_len)</div>
<div class="line"><a id="l00231" name="l00231"></a><span class="lineno"> 231</span>{</div>
<div class="line"><a id="l00232" name="l00232"></a><span class="lineno"> 232</span> <span class="keyword">const</span> <span class="keywordtype">size_t</span> block_len = job-><a class="code hl_variable" href="structrs__job.html#ac8b7a197f196b0eabdd1dd2de0f7852f">signature</a>-><a class="code hl_variable" href="structrs__signature.html#a8df88cba2f5ef197c2dabc72579409e6">block_len</a>;</div>
<div class="line"><a id="l00233" name="l00233"></a><span class="lineno"> 233</span> </div>
<div class="line"><a id="l00234" name="l00234"></a><span class="lineno"> 234</span> <span class="comment">/* calculate the weak_sum if we don't have one */</span></div>
<div class="line"><a id="l00235" name="l00235"></a><span class="lineno"> 235</span> <span class="keywordflow">if</span> (weaksum_count(&job-><a class="code hl_variable" href="structrs__job.html#aec548f7a84b838c552e304e83c5a1775">weak_sum</a>) == 0) {</div>
<div class="line"><a id="l00236" name="l00236"></a><span class="lineno"> 236</span> <span class="comment">/* set match_len to min(block_len, scan_avail) */</span></div>
<div class="line"><a id="l00237" name="l00237"></a><span class="lineno"> 237</span> *match_len = job-><a class="code hl_variable" href="structrs__job.html#a9a00375090f27e158987f58987e8e7a0">scan_len</a> - job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a>;</div>
<div class="line"><a id="l00238" name="l00238"></a><span class="lineno"> 238</span> <span class="keywordflow">if</span> (*match_len > block_len) {</div>
<div class="line"><a id="l00239" name="l00239"></a><span class="lineno"> 239</span> *match_len = block_len;</div>
<div class="line"><a id="l00240" name="l00240"></a><span class="lineno"> 240</span> }</div>
<div class="line"><a id="l00241" name="l00241"></a><span class="lineno"> 241</span> <span class="comment">/* Update the weak_sum */</span></div>
<div class="line"><a id="l00242" name="l00242"></a><span class="lineno"> 242</span> weaksum_update(&job-><a class="code hl_variable" href="structrs__job.html#aec548f7a84b838c552e304e83c5a1775">weak_sum</a>, job-><a class="code hl_variable" href="structrs__job.html#a2dcaea58f56c153083ca05cd2da3d868">scan_buf</a> + job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a>,</div>
<div class="line"><a id="l00243" name="l00243"></a><span class="lineno"> 243</span> *match_len);</div>
<div class="line"><a id="l00244" name="l00244"></a><span class="lineno"> 244</span> rs_trace(<span class="stringliteral">"calculate weak sum from scratch length "</span> FMT_SIZE <span class="stringliteral">""</span>,</div>
<div class="line"><a id="l00245" name="l00245"></a><span class="lineno"> 245</span> weaksum_count(&job-><a class="code hl_variable" href="structrs__job.html#aec548f7a84b838c552e304e83c5a1775">weak_sum</a>));</div>
<div class="line"><a id="l00246" name="l00246"></a><span class="lineno"> 246</span> } <span class="keywordflow">else</span> {</div>
<div class="line"><a id="l00247" name="l00247"></a><span class="lineno"> 247</span> <span class="comment">/* set the match_len to the weak_sum count */</span></div>
<div class="line"><a id="l00248" name="l00248"></a><span class="lineno"> 248</span> *match_len = weaksum_count(&job-><a class="code hl_variable" href="structrs__job.html#aec548f7a84b838c552e304e83c5a1775">weak_sum</a>);</div>
<div class="line"><a id="l00249" name="l00249"></a><span class="lineno"> 249</span> }</div>
<div class="line"><a id="l00250" name="l00250"></a><span class="lineno"> 250</span> *match_pos =</div>
<div class="line"><a id="l00251" name="l00251"></a><span class="lineno"> 251</span> <a class="code hl_function" href="sumset_8h.html#a6e83fb1697e2326f39fc3ec3c6a0c6ee">rs_signature_find_match</a>(job-><a class="code hl_variable" href="structrs__job.html#ac8b7a197f196b0eabdd1dd2de0f7852f">signature</a>, weaksum_digest(&job-><a class="code hl_variable" href="structrs__job.html#aec548f7a84b838c552e304e83c5a1775">weak_sum</a>),</div>
<div class="line"><a id="l00252" name="l00252"></a><span class="lineno"> 252</span> job-><a class="code hl_variable" href="structrs__job.html#a2dcaea58f56c153083ca05cd2da3d868">scan_buf</a> + job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a>, *match_len);</div>
<div class="line"><a id="l00253" name="l00253"></a><span class="lineno"> 253</span> <span class="keywordflow">return</span> *match_pos != -1;</div>
<div class="line"><a id="l00254" name="l00254"></a><span class="lineno"> 254</span>}</div>
<div class="line"><a id="l00255" name="l00255"></a><span class="lineno"> 255</span><span class="comment"></span> </div>
<div class="line"><a id="l00256" name="l00256"></a><span class="lineno"> 256</span><span class="comment">/** Append a match at match_pos of length match_len to the delta, extending a</span></div>
<div class="line"><a id="l00257" name="l00257"></a><span class="lineno"> 257</span><span class="comment"> * previous match if possible, or flushing any previous miss/match. */</span></div>
<div class="line"><a id="l00258" name="l00258"></a><span class="lineno"><a class="line" href="delta_8c.html#acc386d6304337b138b79b5712c15931a"> 258</a></span><span class="keyword">static</span> <span class="keyword">inline</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> <a class="code hl_function" href="delta_8c.html#acc386d6304337b138b79b5712c15931a">rs_appendmatch</a>(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job, rs_long_t match_pos,</div>
<div class="line"><a id="l00259" name="l00259"></a><span class="lineno"> 259</span> <span class="keywordtype">size_t</span> match_len)</div>
<div class="line"><a id="l00260" name="l00260"></a><span class="lineno"> 260</span>{</div>
<div class="line"><a id="l00261" name="l00261"></a><span class="lineno"> 261</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> result = <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a739063053a289b5c3393d78cc77b41b2">RS_DONE</a>;</div>
<div class="line"><a id="l00262" name="l00262"></a><span class="lineno"> 262</span> </div>
<div class="line"><a id="l00263" name="l00263"></a><span class="lineno"> 263</span> <span class="comment">/* if last was a match that can be extended, extend it */</span></div>
<div class="line"><a id="l00264" name="l00264"></a><span class="lineno"> 264</span> <span class="keywordflow">if</span> (job->basis_len && (job-><a class="code hl_variable" href="structrs__job.html#a207f22dcb5ddd1624af1c9579e06254d">basis_pos</a> + job->basis_len) == match_pos) {</div>
<div class="line"><a id="l00265" name="l00265"></a><span class="lineno"> 265</span> job->basis_len += match_len;</div>
<div class="line"><a id="l00266" name="l00266"></a><span class="lineno"> 266</span> } <span class="keywordflow">else</span> {</div>
<div class="line"><a id="l00267" name="l00267"></a><span class="lineno"> 267</span> <span class="comment">/* else appendflush the last value */</span></div>
<div class="line"><a id="l00268" name="l00268"></a><span class="lineno"> 268</span> result = <a class="code hl_function" href="delta_8c.html#a8c7bfd74ede4c7fa74eeca10bb5d6679">rs_appendflush</a>(job);</div>
<div class="line"><a id="l00269" name="l00269"></a><span class="lineno"> 269</span> <span class="comment">/* make this the new match value */</span></div>
<div class="line"><a id="l00270" name="l00270"></a><span class="lineno"> 270</span> job-><a class="code hl_variable" href="structrs__job.html#a207f22dcb5ddd1624af1c9579e06254d">basis_pos</a> = match_pos;</div>
<div class="line"><a id="l00271" name="l00271"></a><span class="lineno"> 271</span> job->basis_len = match_len;</div>
<div class="line"><a id="l00272" name="l00272"></a><span class="lineno"> 272</span> }</div>
<div class="line"><a id="l00273" name="l00273"></a><span class="lineno"> 273</span> <span class="comment">/* increment scan_pos to point at next unscanned data */</span></div>
<div class="line"><a id="l00274" name="l00274"></a><span class="lineno"> 274</span> job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a> += match_len;</div>
<div class="line"><a id="l00275" name="l00275"></a><span class="lineno"> 275</span> <span class="comment">/* we can only process from the scoop if output is not blocked */</span></div>
<div class="line"><a id="l00276" name="l00276"></a><span class="lineno"> 276</span> <span class="keywordflow">if</span> (result == <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a739063053a289b5c3393d78cc77b41b2">RS_DONE</a>) {</div>
<div class="line"><a id="l00277" name="l00277"></a><span class="lineno"> 277</span> <span class="comment">/* process the match data off the scoop */</span></div>
<div class="line"><a id="l00278" name="l00278"></a><span class="lineno"> 278</span> result = <a class="code hl_function" href="delta_8c.html#a2e40db810b7290fe6d5fd1be2656e04d">rs_processmatch</a>(job);</div>
<div class="line"><a id="l00279" name="l00279"></a><span class="lineno"> 279</span> }</div>
<div class="line"><a id="l00280" name="l00280"></a><span class="lineno"> 280</span> <span class="keywordflow">return</span> result;</div>
<div class="line"><a id="l00281" name="l00281"></a><span class="lineno"> 281</span>}</div>
<div class="line"><a id="l00282" name="l00282"></a><span class="lineno"> 282</span><span class="comment"></span> </div>
<div class="line"><a id="l00283" name="l00283"></a><span class="lineno"> 283</span><span class="comment">/** Append a miss of length miss_len to the delta, extending a previous miss</span></div>
<div class="line"><a id="l00284" name="l00284"></a><span class="lineno"> 284</span><span class="comment"> * if possible, or flushing any previous match.</span></div>
<div class="line"><a id="l00285" name="l00285"></a><span class="lineno"> 285</span><span class="comment"> *</span></div>
<div class="line"><a id="l00286" name="l00286"></a><span class="lineno"> 286</span><span class="comment"> * This also breaks misses up into 32KB segments to avoid accumulating too much</span></div>
<div class="line"><a id="l00287" name="l00287"></a><span class="lineno"> 287</span><span class="comment"> * in memory. */</span></div>
<div class="line"><a id="l00288" name="l00288"></a><span class="lineno"><a class="line" href="delta_8c.html#a832b35b9afeeb51561f08daf13738571"> 288</a></span><span class="keyword">static</span> <span class="keyword">inline</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> <a class="code hl_function" href="delta_8c.html#a832b35b9afeeb51561f08daf13738571">rs_appendmiss</a>(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job, <span class="keywordtype">size_t</span> miss_len)</div>
<div class="line"><a id="l00289" name="l00289"></a><span class="lineno"> 289</span>{</div>
<div class="line"><a id="l00290" name="l00290"></a><span class="lineno"> 290</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> result = <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a739063053a289b5c3393d78cc77b41b2">RS_DONE</a>;</div>
<div class="line"><a id="l00291" name="l00291"></a><span class="lineno"> 291</span> </div>
<div class="line"><a id="l00292" name="l00292"></a><span class="lineno"> 292</span> <span class="comment">/* If last was a match, or MAX_MISS_LEN misses, appendflush it. */</span></div>
<div class="line"><a id="l00293" name="l00293"></a><span class="lineno"> 293</span> <span class="keywordflow">if</span> (job->basis_len || (job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a> >= <a class="code hl_define" href="delta_8c.html#ad38b7f45cf4177503166b0d00af71cff">MAX_MISS_LEN</a>)) {</div>
<div class="line"><a id="l00294" name="l00294"></a><span class="lineno"> 294</span> result = <a class="code hl_function" href="delta_8c.html#a8c7bfd74ede4c7fa74eeca10bb5d6679">rs_appendflush</a>(job);</div>
<div class="line"><a id="l00295" name="l00295"></a><span class="lineno"> 295</span> }</div>
<div class="line"><a id="l00296" name="l00296"></a><span class="lineno"> 296</span> <span class="comment">/* increment scan_pos */</span></div>
<div class="line"><a id="l00297" name="l00297"></a><span class="lineno"> 297</span> job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a> += miss_len;</div>
<div class="line"><a id="l00298" name="l00298"></a><span class="lineno"> 298</span> <span class="keywordflow">return</span> result;</div>
<div class="line"><a id="l00299" name="l00299"></a><span class="lineno"> 299</span>}</div>
<div class="line"><a id="l00300" name="l00300"></a><span class="lineno"> 300</span><span class="comment"></span> </div>
<div class="line"><a id="l00301" name="l00301"></a><span class="lineno"> 301</span><span class="comment">/** Flush any accumulating hit or miss, appending it to the delta. */</span></div>
<div class="line"><a id="l00302" name="l00302"></a><span class="lineno"><a class="line" href="delta_8c.html#a8c7bfd74ede4c7fa74eeca10bb5d6679"> 302</a></span><span class="keyword">static</span> <span class="keyword">inline</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> <a class="code hl_function" href="delta_8c.html#a8c7bfd74ede4c7fa74eeca10bb5d6679">rs_appendflush</a>(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job)</div>
<div class="line"><a id="l00303" name="l00303"></a><span class="lineno"> 303</span>{</div>
<div class="line"><a id="l00304" name="l00304"></a><span class="lineno"> 304</span> <span class="comment">/* if last is a match, emit it and reset last by resetting basis_len */</span></div>
<div class="line"><a id="l00305" name="l00305"></a><span class="lineno"> 305</span> <span class="keywordflow">if</span> (job->basis_len) {</div>
<div class="line"><a id="l00306" name="l00306"></a><span class="lineno"> 306</span> rs_trace(<span class="stringliteral">"matched "</span> FMT_LONG <span class="stringliteral">" bytes at "</span> FMT_LONG <span class="stringliteral">"!"</span>, job->basis_len,</div>
<div class="line"><a id="l00307" name="l00307"></a><span class="lineno"> 307</span> job-><a class="code hl_variable" href="structrs__job.html#a207f22dcb5ddd1624af1c9579e06254d">basis_pos</a>);</div>
<div class="line"><a id="l00308" name="l00308"></a><span class="lineno"> 308</span> <a class="code hl_function" href="emit_8h.html#aa71d2f81497b735136c734bfa08f9c39">rs_emit_copy_cmd</a>(job, job-><a class="code hl_variable" href="structrs__job.html#a207f22dcb5ddd1624af1c9579e06254d">basis_pos</a>, job->basis_len);</div>
<div class="line"><a id="l00309" name="l00309"></a><span class="lineno"> 309</span> job->basis_len = 0;</div>
<div class="line"><a id="l00310" name="l00310"></a><span class="lineno"> 310</span> <span class="keywordflow">return</span> <a class="code hl_function" href="delta_8c.html#a2e40db810b7290fe6d5fd1be2656e04d">rs_processmatch</a>(job);</div>
<div class="line"><a id="l00311" name="l00311"></a><span class="lineno"> 311</span> <span class="comment">/* else if last is a miss, emit and process it */</span></div>
<div class="line"><a id="l00312" name="l00312"></a><span class="lineno"> 312</span> } <span class="keywordflow">else</span> <span class="keywordflow">if</span> (job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a>) {</div>
<div class="line"><a id="l00313" name="l00313"></a><span class="lineno"> 313</span> rs_trace(<span class="stringliteral">"got "</span> FMT_SIZE <span class="stringliteral">" bytes of literal data"</span>, job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a>);</div>
<div class="line"><a id="l00314" name="l00314"></a><span class="lineno"> 314</span> <a class="code hl_function" href="emit_8h.html#af2d201807d83474fa26a6b948864bbaf">rs_emit_literal_cmd</a>(job, (<span class="keywordtype">int</span>)job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a>);</div>
<div class="line"><a id="l00315" name="l00315"></a><span class="lineno"> 315</span> <span class="keywordflow">return</span> <a class="code hl_function" href="delta_8c.html#a17e651660e2da438be938cfcf4f5d0b7">rs_processmiss</a>(job);</div>
<div class="line"><a id="l00316" name="l00316"></a><span class="lineno"> 316</span> }</div>
<div class="line"><a id="l00317" name="l00317"></a><span class="lineno"> 317</span> <span class="comment">/* otherwise, nothing to flush so we are done */</span></div>
<div class="line"><a id="l00318" name="l00318"></a><span class="lineno"> 318</span> <span class="keywordflow">return</span> <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a739063053a289b5c3393d78cc77b41b2">RS_DONE</a>;</div>
<div class="line"><a id="l00319" name="l00319"></a><span class="lineno"> 319</span>}</div>
<div class="line"><a id="l00320" name="l00320"></a><span class="lineno"> 320</span><span class="comment"></span> </div>
<div class="line"><a id="l00321" name="l00321"></a><span class="lineno"> 321</span><span class="comment">/** Process matching data in the scoop.</span></div>
<div class="line"><a id="l00322" name="l00322"></a><span class="lineno"> 322</span><span class="comment"> *</span></div>
<div class="line"><a id="l00323" name="l00323"></a><span class="lineno"> 323</span><span class="comment"> * The scoop contains match data at scan_buf of length scan_pos. This function</span></div>
<div class="line"><a id="l00324" name="l00324"></a><span class="lineno"> 324</span><span class="comment"> * processes that match data, returning RS_DONE if it completes, or RS_BLOCKED</span></div>
<div class="line"><a id="l00325" name="l00325"></a><span class="lineno"> 325</span><span class="comment"> * if it gets blocked. After it completes scan_pos is reset to still point at</span></div>
<div class="line"><a id="l00326" name="l00326"></a><span class="lineno"> 326</span><span class="comment"> * the next unscanned data.</span></div>
<div class="line"><a id="l00327" name="l00327"></a><span class="lineno"> 327</span><span class="comment"> *</span></div>
<div class="line"><a id="l00328" name="l00328"></a><span class="lineno"> 328</span><span class="comment"> * This function currently just removes data from the scoop and adjusts</span></div>
<div class="line"><a id="l00329" name="l00329"></a><span class="lineno"> 329</span><span class="comment"> * scan_pos appropriately. In the future this could be used for something like</span></div>
<div class="line"><a id="l00330" name="l00330"></a><span class="lineno"> 330</span><span class="comment"> * context compressing of miss data. Note that it also calls rs_tube_catchup to</span></div>
<div class="line"><a id="l00331" name="l00331"></a><span class="lineno"> 331</span><span class="comment"> * output any pending output. */</span></div>
<div class="line"><a id="l00332" name="l00332"></a><span class="lineno"><a class="line" href="delta_8c.html#a2e40db810b7290fe6d5fd1be2656e04d"> 332</a></span><span class="keyword">static</span> <span class="keyword">inline</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> <a class="code hl_function" href="delta_8c.html#a2e40db810b7290fe6d5fd1be2656e04d">rs_processmatch</a>(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job)</div>
<div class="line"><a id="l00333" name="l00333"></a><span class="lineno"> 333</span>{</div>
<div class="line"><a id="l00334" name="l00334"></a><span class="lineno"> 334</span> assert(job-><a class="code hl_variable" href="structrs__job.html#a45c8741f03fcfab800c87a5f4114f641">copy_len</a> == 0);</div>
<div class="line"><a id="l00335" name="l00335"></a><span class="lineno"> 335</span> <a class="code hl_function" href="scoop_8c.html#aad3e63ccd707266363d6feeca754a370">rs_scoop_advance</a>(job, job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a>);</div>
<div class="line"><a id="l00336" name="l00336"></a><span class="lineno"> 336</span> job-><a class="code hl_variable" href="structrs__job.html#a2dcaea58f56c153083ca05cd2da3d868">scan_buf</a> += job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a>;</div>
<div class="line"><a id="l00337" name="l00337"></a><span class="lineno"> 337</span> job-><a class="code hl_variable" href="structrs__job.html#a9a00375090f27e158987f58987e8e7a0">scan_len</a> -= job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a>;</div>
<div class="line"><a id="l00338" name="l00338"></a><span class="lineno"> 338</span> job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a> = 0;</div>
<div class="line"><a id="l00339" name="l00339"></a><span class="lineno"> 339</span> <span class="keywordflow">return</span> <a class="code hl_function" href="scoop_8h.html#a5285265e3d220e43b8fd08867d708d9c">rs_tube_catchup</a>(job);</div>
<div class="line"><a id="l00340" name="l00340"></a><span class="lineno"> 340</span>}</div>
<div class="line"><a id="l00341" name="l00341"></a><span class="lineno"> 341</span><span class="comment"></span> </div>
<div class="line"><a id="l00342" name="l00342"></a><span class="lineno"> 342</span><span class="comment">/** Process miss data in the scoop.</span></div>
<div class="line"><a id="l00343" name="l00343"></a><span class="lineno"> 343</span><span class="comment"> *</span></div>
<div class="line"><a id="l00344" name="l00344"></a><span class="lineno"> 344</span><span class="comment"> * The scoop contains miss data at scan_buf of length scan_pos. This function</span></div>
<div class="line"><a id="l00345" name="l00345"></a><span class="lineno"> 345</span><span class="comment"> * processes that miss data, returning RS_DONE if it completes, or RS_BLOCKED</span></div>
<div class="line"><a id="l00346" name="l00346"></a><span class="lineno"> 346</span><span class="comment"> * if it gets blocked. After it completes scan_pos is reset to still point at</span></div>
<div class="line"><a id="l00347" name="l00347"></a><span class="lineno"> 347</span><span class="comment"> * the next unscanned data.</span></div>
<div class="line"><a id="l00348" name="l00348"></a><span class="lineno"> 348</span><span class="comment"> *</span></div>
<div class="line"><a id="l00349" name="l00349"></a><span class="lineno"> 349</span><span class="comment"> * This function uses rs_tube_copy to queue copying from the scoop into output.</span></div>
<div class="line"><a id="l00350" name="l00350"></a><span class="lineno"> 350</span><span class="comment"> * and uses rs_tube_catchup to do the copying. This automaticly removes data</span></div>
<div class="line"><a id="l00351" name="l00351"></a><span class="lineno"> 351</span><span class="comment"> * from the scoop, but this can block. While rs_tube_catchup is blocked,</span></div>
<div class="line"><a id="l00352" name="l00352"></a><span class="lineno"> 352</span><span class="comment"> * scan_pos does not point at legit data, so scanning can also not proceed.</span></div>
<div class="line"><a id="l00353" name="l00353"></a><span class="lineno"> 353</span><span class="comment"> *</span></div>
<div class="line"><a id="l00354" name="l00354"></a><span class="lineno"> 354</span><span class="comment"> * In the future this could do compression of miss data before outputing it. */</span></div>
<div class="line"><a id="l00355" name="l00355"></a><span class="lineno"><a class="line" href="delta_8c.html#a17e651660e2da438be938cfcf4f5d0b7"> 355</a></span><span class="keyword">static</span> <span class="keyword">inline</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> <a class="code hl_function" href="delta_8c.html#a17e651660e2da438be938cfcf4f5d0b7">rs_processmiss</a>(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job)</div>
<div class="line"><a id="l00356" name="l00356"></a><span class="lineno"> 356</span>{</div>
<div class="line"><a id="l00357" name="l00357"></a><span class="lineno"> 357</span> assert(job->write_len > 0);</div>
<div class="line"><a id="l00358" name="l00358"></a><span class="lineno"> 358</span> <a class="code hl_function" href="scoop_8h.html#aa1170d5552b5581630f90d8a66a71adc">rs_tube_copy</a>(job, job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a>);</div>
<div class="line"><a id="l00359" name="l00359"></a><span class="lineno"> 359</span> job-><a class="code hl_variable" href="structrs__job.html#a2dcaea58f56c153083ca05cd2da3d868">scan_buf</a> += job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a>;</div>
<div class="line"><a id="l00360" name="l00360"></a><span class="lineno"> 360</span> job-><a class="code hl_variable" href="structrs__job.html#a9a00375090f27e158987f58987e8e7a0">scan_len</a> -= job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a>;</div>
<div class="line"><a id="l00361" name="l00361"></a><span class="lineno"> 361</span> job-><a class="code hl_variable" href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">scan_pos</a> = 0;</div>
<div class="line"><a id="l00362" name="l00362"></a><span class="lineno"> 362</span> <span class="keywordflow">return</span> <a class="code hl_function" href="scoop_8h.html#a5285265e3d220e43b8fd08867d708d9c">rs_tube_catchup</a>(job);</div>
<div class="line"><a id="l00363" name="l00363"></a><span class="lineno"> 363</span>}</div>
<div class="line"><a id="l00364" name="l00364"></a><span class="lineno"> 364</span><span class="comment"></span> </div>
<div class="line"><a id="l00365" name="l00365"></a><span class="lineno"> 365</span><span class="comment">/** State function that does a slack delta containing only literal data to</span></div>
<div class="line"><a id="l00366" name="l00366"></a><span class="lineno"> 366</span><span class="comment"> * recreate the input. */</span></div>
<div class="line"><a id="l00367" name="l00367"></a><span class="lineno"><a class="line" href="delta_8c.html#a761d7df9081cf4ab4510e1cebc7c604a"> 367</a></span><span class="keyword">static</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> <a class="code hl_function" href="delta_8c.html#a761d7df9081cf4ab4510e1cebc7c604a">rs_delta_s_slack</a>(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job)</div>
<div class="line"><a id="l00368" name="l00368"></a><span class="lineno"> 368</span>{</div>
<div class="line"><a id="l00369" name="l00369"></a><span class="lineno"> 369</span> <span class="keywordtype">size_t</span> avail = rs_scoop_avail(job);</div>
<div class="line"><a id="l00370" name="l00370"></a><span class="lineno"> 370</span> </div>
<div class="line"><a id="l00371" name="l00371"></a><span class="lineno"> 371</span> <span class="keywordflow">if</span> (avail) {</div>
<div class="line"><a id="l00372" name="l00372"></a><span class="lineno"> 372</span> rs_trace(<span class="stringliteral">"emit slack delta for "</span> FMT_SIZE <span class="stringliteral">" available bytes"</span>, avail);</div>
<div class="line"><a id="l00373" name="l00373"></a><span class="lineno"> 373</span> <a class="code hl_function" href="emit_8h.html#af2d201807d83474fa26a6b948864bbaf">rs_emit_literal_cmd</a>(job, (<span class="keywordtype">int</span>)avail);</div>
<div class="line"><a id="l00374" name="l00374"></a><span class="lineno"> 374</span> <a class="code hl_function" href="scoop_8h.html#aa1170d5552b5581630f90d8a66a71adc">rs_tube_copy</a>(job, avail);</div>
<div class="line"><a id="l00375" name="l00375"></a><span class="lineno"> 375</span> <span class="keywordflow">return</span> <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a5366e53561c2ec9a897470535ea0139c">RS_RUNNING</a>;</div>
<div class="line"><a id="l00376" name="l00376"></a><span class="lineno"> 376</span> } <span class="keywordflow">else</span> <span class="keywordflow">if</span> (<a class="code hl_function" href="scoop_8h.html#a6eb10b8ed1aa7f16ddf66e2e1051ff85">rs_scoop_eof</a>(job)) {</div>
<div class="line"><a id="l00377" name="l00377"></a><span class="lineno"> 377</span> job-><a class="code hl_variable" href="structrs__job.html#aa789990d61f5eadc6a26aeedf4bec765">statefn</a> = rs_delta_s_end;</div>
<div class="line"><a id="l00378" name="l00378"></a><span class="lineno"> 378</span> <span class="keywordflow">return</span> <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a5366e53561c2ec9a897470535ea0139c">RS_RUNNING</a>;</div>
<div class="line"><a id="l00379" name="l00379"></a><span class="lineno"> 379</span> }</div>
<div class="line"><a id="l00380" name="l00380"></a><span class="lineno"> 380</span> <span class="keywordflow">return</span> <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253af2d289bbc65678b4b00f56a2e6632957">RS_BLOCKED</a>;</div>
<div class="line"><a id="l00381" name="l00381"></a><span class="lineno"> 381</span>}</div>
<div class="line"><a id="l00382" name="l00382"></a><span class="lineno"> 382</span><span class="comment"></span> </div>
<div class="line"><a id="l00383" name="l00383"></a><span class="lineno"> 383</span><span class="comment">/** State function for writing out the header of the encoding job. */</span></div>
<div class="line"><a id="l00384" name="l00384"></a><span class="lineno"><a class="line" href="delta_8c.html#a8df6a969396ff04b72ebff623ec4c603"> 384</a></span><span class="keyword">static</span> <a class="code hl_enumeration" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a> <a class="code hl_function" href="delta_8c.html#a8df6a969396ff04b72ebff623ec4c603">rs_delta_s_header</a>(<a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job)</div>
<div class="line"><a id="l00385" name="l00385"></a><span class="lineno"> 385</span>{</div>
<div class="line"><a id="l00386" name="l00386"></a><span class="lineno"> 386</span> <a class="code hl_function" href="emit_8h.html#a433db28a03937eff26179bdf6bd50ef4">rs_emit_delta_header</a>(job);</div>
<div class="line"><a id="l00387" name="l00387"></a><span class="lineno"> 387</span> <span class="keywordflow">if</span> (job-><a class="code hl_variable" href="structrs__job.html#ac8b7a197f196b0eabdd1dd2de0f7852f">signature</a>) {</div>
<div class="line"><a id="l00388" name="l00388"></a><span class="lineno"> 388</span> job-><a class="code hl_variable" href="structrs__job.html#aa789990d61f5eadc6a26aeedf4bec765">statefn</a> = <a class="code hl_function" href="delta_8c.html#a6a992cf5dc0916678a7094c21b85d5fe">rs_delta_s_scan</a>;</div>
<div class="line"><a id="l00389" name="l00389"></a><span class="lineno"> 389</span> } <span class="keywordflow">else</span> {</div>
<div class="line"><a id="l00390" name="l00390"></a><span class="lineno"> 390</span> rs_trace(<span class="stringliteral">"no signature provided for delta, using slack deltas"</span>);</div>
<div class="line"><a id="l00391" name="l00391"></a><span class="lineno"> 391</span> job-><a class="code hl_variable" href="structrs__job.html#aa789990d61f5eadc6a26aeedf4bec765">statefn</a> = <a class="code hl_function" href="delta_8c.html#a761d7df9081cf4ab4510e1cebc7c604a">rs_delta_s_slack</a>;</div>
<div class="line"><a id="l00392" name="l00392"></a><span class="lineno"> 392</span> }</div>
<div class="line"><a id="l00393" name="l00393"></a><span class="lineno"> 393</span> <span class="keywordflow">return</span> <a class="code hl_enumvalue" href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a5366e53561c2ec9a897470535ea0139c">RS_RUNNING</a>;</div>
<div class="line"><a id="l00394" name="l00394"></a><span class="lineno"> 394</span>}</div>
<div class="line"><a id="l00395" name="l00395"></a><span class="lineno"> 395</span> </div>
<div class="line"><a id="l00396" name="l00396"></a><span class="lineno"><a class="line" href="delta_8c.html#a59fe8536218632417097d084606bb675"> 396</a></span><a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *<a class="code hl_function" href="delta_8c.html#a59fe8536218632417097d084606bb675">rs_delta_begin</a>(<a class="code hl_struct" href="structrs__signature.html">rs_signature_t</a> *sig)</div>
<div class="line"><a id="l00397" name="l00397"></a><span class="lineno"> 397</span>{</div>
<div class="line"><a id="l00398" name="l00398"></a><span class="lineno"> 398</span> <a class="code hl_struct" href="structrs__job.html">rs_job_t</a> *job;</div>
<div class="line"><a id="l00399" name="l00399"></a><span class="lineno"> 399</span> </div>
<div class="line"><a id="l00400" name="l00400"></a><span class="lineno"> 400</span> job = rs_job_new(<span class="stringliteral">"delta"</span>, <a class="code hl_function" href="delta_8c.html#a8df6a969396ff04b72ebff623ec4c603">rs_delta_s_header</a>);</div>
<div class="line"><a id="l00401" name="l00401"></a><span class="lineno"> 401</span> <span class="comment">/* Caller can pass NULL sig or empty sig for "slack deltas". */</span></div>
<div class="line"><a id="l00402" name="l00402"></a><span class="lineno"> 402</span> <span class="keywordflow">if</span> (sig && sig-><a class="code hl_variable" href="structrs__signature.html#a0d2dd24f39336f0e00036da675d63f99">count</a> > 0) {</div>
<div class="line"><a id="l00403" name="l00403"></a><span class="lineno"> 403</span> <a class="code hl_define" href="sumset_8h.html#afb7830fd2d4deff03b72ceab3936f19e">rs_signature_check</a>(sig);</div>
<div class="line"><a id="l00404" name="l00404"></a><span class="lineno"> 404</span> <span class="comment">/* Caller must have called rs_build_hash_table() by now. */</span></div>
<div class="line"><a id="l00405" name="l00405"></a><span class="lineno"> 405</span> assert(sig-><a class="code hl_variable" href="structrs__signature.html#a83be77fb95b4ab210a1accdf6687058c">hashtable</a>);</div>
<div class="line"><a id="l00406" name="l00406"></a><span class="lineno"> 406</span> job-><a class="code hl_variable" href="structrs__job.html#ac8b7a197f196b0eabdd1dd2de0f7852f">signature</a> = sig;</div>
<div class="line"><a id="l00407" name="l00407"></a><span class="lineno"> 407</span> weaksum_init(&job-><a class="code hl_variable" href="structrs__job.html#aec548f7a84b838c552e304e83c5a1775">weak_sum</a>, <a class="code hl_function" href="sumset_8h.html#ae72598d4e3ca0ce67f46a3818707c3e5">rs_signature_weaksum_kind</a>(sig));</div>
<div class="line"><a id="l00408" name="l00408"></a><span class="lineno"> 408</span> }</div>
<div class="line"><a id="l00409" name="l00409"></a><span class="lineno"> 409</span> <span class="keywordflow">return</span> job;</div>
<div class="line"><a id="l00410" name="l00410"></a><span class="lineno"> 410</span>}</div>
<div class="ttc" id="achecksum_8h_html"><div class="ttname"><a href="checksum_8h.html">checksum.h</a></div><div class="ttdoc">Abstract wrappers around different weaksum and strongsum implementations.</div></div>
<div class="ttc" id="adelta_8c_html_a02cb5f8a81c7cb63d2557023c56929e7"><div class="ttname"><a href="delta_8c.html#a02cb5f8a81c7cb63d2557023c56929e7">rs_findmatch</a></div><div class="ttdeci">static int rs_findmatch(rs_job_t *job, rs_long_t *match_pos, size_t *match_len)</div><div class="ttdoc">find a match at scan_pos, returning the match_pos and match_len.</div><div class="ttdef"><b>Definition:</b> <a href="delta_8c_source.html#l00229">delta.c:229</a></div></div>
<div class="ttc" id="adelta_8c_html_a17e651660e2da438be938cfcf4f5d0b7"><div class="ttname"><a href="delta_8c.html#a17e651660e2da438be938cfcf4f5d0b7">rs_processmiss</a></div><div class="ttdeci">static rs_result rs_processmiss(rs_job_t *job)</div><div class="ttdoc">Process miss data in the scoop.</div><div class="ttdef"><b>Definition:</b> <a href="delta_8c_source.html#l00355">delta.c:355</a></div></div>
<div class="ttc" id="adelta_8c_html_a2e40db810b7290fe6d5fd1be2656e04d"><div class="ttname"><a href="delta_8c.html#a2e40db810b7290fe6d5fd1be2656e04d">rs_processmatch</a></div><div class="ttdeci">static rs_result rs_processmatch(rs_job_t *job)</div><div class="ttdoc">Process matching data in the scoop.</div><div class="ttdef"><b>Definition:</b> <a href="delta_8c_source.html#l00332">delta.c:332</a></div></div>
<div class="ttc" id="adelta_8c_html_a59fe8536218632417097d084606bb675"><div class="ttname"><a href="delta_8c.html#a59fe8536218632417097d084606bb675">rs_delta_begin</a></div><div class="ttdeci">rs_job_t * rs_delta_begin(rs_signature_t *sig)</div><div class="ttdoc">Prepare to compute a streaming delta.</div><div class="ttdef"><b>Definition:</b> <a href="delta_8c_source.html#l00396">delta.c:396</a></div></div>
<div class="ttc" id="adelta_8c_html_a6a992cf5dc0916678a7094c21b85d5fe"><div class="ttname"><a href="delta_8c.html#a6a992cf5dc0916678a7094c21b85d5fe">rs_delta_s_scan</a></div><div class="ttdeci">static rs_result rs_delta_s_scan(rs_job_t *job)</div><div class="ttdoc">Get a block of data if possible, and see if it matches.</div><div class="ttdef"><b>Definition:</b> <a href="delta_8c_source.html#l00122">delta.c:122</a></div></div>
<div class="ttc" id="adelta_8c_html_a761d7df9081cf4ab4510e1cebc7c604a"><div class="ttname"><a href="delta_8c.html#a761d7df9081cf4ab4510e1cebc7c604a">rs_delta_s_slack</a></div><div class="ttdeci">static rs_result rs_delta_s_slack(rs_job_t *job)</div><div class="ttdoc">State function that does a slack delta containing only literal data to recreate the input.</div><div class="ttdef"><b>Definition:</b> <a href="delta_8c_source.html#l00367">delta.c:367</a></div></div>
<div class="ttc" id="adelta_8c_html_a832b35b9afeeb51561f08daf13738571"><div class="ttname"><a href="delta_8c.html#a832b35b9afeeb51561f08daf13738571">rs_appendmiss</a></div><div class="ttdeci">static rs_result rs_appendmiss(rs_job_t *job, size_t miss_len)</div><div class="ttdoc">Append a miss of length miss_len to the delta, extending a previous miss if possible,...</div><div class="ttdef"><b>Definition:</b> <a href="delta_8c_source.html#l00288">delta.c:288</a></div></div>
<div class="ttc" id="adelta_8c_html_a8c7bfd74ede4c7fa74eeca10bb5d6679"><div class="ttname"><a href="delta_8c.html#a8c7bfd74ede4c7fa74eeca10bb5d6679">rs_appendflush</a></div><div class="ttdeci">static rs_result rs_appendflush(rs_job_t *job)</div><div class="ttdoc">Flush any accumulating hit or miss, appending it to the delta.</div><div class="ttdef"><b>Definition:</b> <a href="delta_8c_source.html#l00302">delta.c:302</a></div></div>
<div class="ttc" id="adelta_8c_html_a8df6a969396ff04b72ebff623ec4c603"><div class="ttname"><a href="delta_8c.html#a8df6a969396ff04b72ebff623ec4c603">rs_delta_s_header</a></div><div class="ttdeci">static rs_result rs_delta_s_header(rs_job_t *job)</div><div class="ttdoc">State function for writing out the header of the encoding job.</div><div class="ttdef"><b>Definition:</b> <a href="delta_8c_source.html#l00384">delta.c:384</a></div></div>
<div class="ttc" id="adelta_8c_html_acc386d6304337b138b79b5712c15931a"><div class="ttname"><a href="delta_8c.html#acc386d6304337b138b79b5712c15931a">rs_appendmatch</a></div><div class="ttdeci">static rs_result rs_appendmatch(rs_job_t *job, rs_long_t match_pos, size_t match_len)</div><div class="ttdoc">Append a match at match_pos of length match_len to the delta, extending a previous match if possible,...</div><div class="ttdef"><b>Definition:</b> <a href="delta_8c_source.html#l00258">delta.c:258</a></div></div>
<div class="ttc" id="adelta_8c_html_ad38b7f45cf4177503166b0d00af71cff"><div class="ttname"><a href="delta_8c.html#ad38b7f45cf4177503166b0d00af71cff">MAX_MISS_LEN</a></div><div class="ttdeci">#define MAX_MISS_LEN</div><div class="ttdoc">Max length of a miss is 64K including 3 command bytes.</div><div class="ttdef"><b>Definition:</b> <a href="delta_8c_source.html#l00103">delta.c:103</a></div></div>
<div class="ttc" id="aemit_8h_html"><div class="ttname"><a href="emit_8h.html">emit.h</a></div><div class="ttdoc">encoding output routines.</div></div>
<div class="ttc" id="aemit_8h_html_a433db28a03937eff26179bdf6bd50ef4"><div class="ttname"><a href="emit_8h.html#a433db28a03937eff26179bdf6bd50ef4">rs_emit_delta_header</a></div><div class="ttdeci">void rs_emit_delta_header(rs_job_t *)</div><div class="ttdoc">Write the magic for the start of a delta.</div><div class="ttdef"><b>Definition:</b> <a href="emit_8c_source.html#l00031">emit.c:31</a></div></div>
<div class="ttc" id="aemit_8h_html_aa71d2f81497b735136c734bfa08f9c39"><div class="ttname"><a href="emit_8h.html#aa71d2f81497b735136c734bfa08f9c39">rs_emit_copy_cmd</a></div><div class="ttdeci">void rs_emit_copy_cmd(rs_job_t *job, rs_long_t where, rs_long_t len)</div><div class="ttdoc">Write a COPY command for given offset and length.</div><div class="ttdef"><b>Definition:</b> <a href="emit_8c_source.html#l00066">emit.c:66</a></div></div>
<div class="ttc" id="aemit_8h_html_ac985ddc29525e655018bed59c4886ca8"><div class="ttname"><a href="emit_8h.html#ac985ddc29525e655018bed59c4886ca8">rs_emit_end_cmd</a></div><div class="ttdeci">void rs_emit_end_cmd(rs_job_t *)</div><div class="ttdoc">Write an END command.</div><div class="ttdef"><b>Definition:</b> <a href="emit_8c_source.html#l00105">emit.c:105</a></div></div>
<div class="ttc" id="aemit_8h_html_af2d201807d83474fa26a6b948864bbaf"><div class="ttname"><a href="emit_8h.html#af2d201807d83474fa26a6b948864bbaf">rs_emit_literal_cmd</a></div><div class="ttdeci">void rs_emit_literal_cmd(rs_job_t *, int len)</div><div class="ttdoc">Write a LITERAL command.</div><div class="ttdef"><b>Definition:</b> <a href="emit_8c_source.html#l00037">emit.c:37</a></div></div>
<div class="ttc" id="ajob_8h_html"><div class="ttname"><a href="job_8h.html">job.h</a></div><div class="ttdoc">Generic state-machine interface.</div></div>
<div class="ttc" id="ajob_8h_html_ab715a4b7294c5fe2ae74765477a521dd"><div class="ttname"><a href="job_8h.html#ab715a4b7294c5fe2ae74765477a521dd">rs_job_check</a></div><div class="ttdeci">#define rs_job_check(job)</div><div class="ttdoc">Assert that a job is valid.</div><div class="ttdef"><b>Definition:</b> <a href="job_8h_source.html#l00130">job.h:130</a></div></div>
<div class="ttc" id="ajob_8h_html_abdbdf5fbcdaed953e687867db175e4c5"><div class="ttname"><a href="job_8h.html#abdbdf5fbcdaed953e687867db175e4c5">MAX_DELTA_CMD</a></div><div class="ttdeci">#define MAX_DELTA_CMD</div><div class="ttdoc">Max length of a singled delta command is including command bytes.</div><div class="ttdef"><b>Definition:</b> <a href="job_8h_source.html#l00044">job.h:44</a></div></div>
<div class="ttc" id="alibrsync_8h_html"><div class="ttname"><a href="librsync_8h.html">librsync.h</a></div><div class="ttdoc">Public header for librsync.</div></div>
<div class="ttc" id="alibrsync_8h_html_a7feb858ceba3b8f3cf048d49be108253"><div class="ttname"><a href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253">rs_result</a></div><div class="ttdeci">rs_result</div><div class="ttdoc">Return codes from nonblocking rsync operations.</div><div class="ttdef"><b>Definition:</b> <a href="librsync_8h_source.html#l00180">librsync.h:180</a></div></div>
<div class="ttc" id="alibrsync_8h_html_a7feb858ceba3b8f3cf048d49be108253a5366e53561c2ec9a897470535ea0139c"><div class="ttname"><a href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a5366e53561c2ec9a897470535ea0139c">RS_RUNNING</a></div><div class="ttdeci">@ RS_RUNNING</div><div class="ttdoc">The job is still running, and not yet finished or blocked.</div><div class="ttdef"><b>Definition:</b> <a href="librsync_8h_source.html#l00185">librsync.h:183</a></div></div>
<div class="ttc" id="alibrsync_8h_html_a7feb858ceba3b8f3cf048d49be108253a739063053a289b5c3393d78cc77b41b2"><div class="ttname"><a href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253a739063053a289b5c3393d78cc77b41b2">RS_DONE</a></div><div class="ttdeci">@ RS_DONE</div><div class="ttdoc">Completed successfully.</div><div class="ttdef"><b>Definition:</b> <a href="librsync_8h_source.html#l00181">librsync.h:181</a></div></div>
<div class="ttc" id="alibrsync_8h_html_a7feb858ceba3b8f3cf048d49be108253af2d289bbc65678b4b00f56a2e6632957"><div class="ttname"><a href="librsync_8h.html#a7feb858ceba3b8f3cf048d49be108253af2d289bbc65678b4b00f56a2e6632957">RS_BLOCKED</a></div><div class="ttdeci">@ RS_BLOCKED</div><div class="ttdoc">Blocked waiting for more data.</div><div class="ttdef"><b>Definition:</b> <a href="librsync_8h_source.html#l00182">librsync.h:182</a></div></div>
<div class="ttc" id="ascoop_8c_html_a026b9505478d48f4b9b05fea46c166e1"><div class="ttname"><a href="scoop_8c.html#a026b9505478d48f4b9b05fea46c166e1">rs_scoop_readahead</a></div><div class="ttdeci">rs_result rs_scoop_readahead(rs_job_t *job, size_t len, void **ptr)</div><div class="ttdoc">Read from scoop without advancing.</div><div class="ttdef"><b>Definition:</b> <a href="scoop_8c_source.html#l00148">scoop.c:148</a></div></div>
<div class="ttc" id="ascoop_8c_html_aad3e63ccd707266363d6feeca754a370"><div class="ttname"><a href="scoop_8c.html#aad3e63ccd707266363d6feeca754a370">rs_scoop_advance</a></div><div class="ttdeci">void rs_scoop_advance(rs_job_t *job, size_t len)</div><div class="ttdoc">Advance the input cursor forward len bytes.</div><div class="ttdef"><b>Definition:</b> <a href="scoop_8c_source.html#l00117">scoop.c:117</a></div></div>
<div class="ttc" id="ascoop_8h_html"><div class="ttname"><a href="scoop_8h.html">scoop.h</a></div><div class="ttdoc">Manage librsync streams of IO.</div></div>
<div class="ttc" id="ascoop_8h_html_a5285265e3d220e43b8fd08867d708d9c"><div class="ttname"><a href="scoop_8h.html#a5285265e3d220e43b8fd08867d708d9c">rs_tube_catchup</a></div><div class="ttdeci">rs_result rs_tube_catchup(rs_job_t *job)</div><div class="ttdoc">Put whatever will fit from the tube into the output of the stream.</div><div class="ttdef"><b>Definition:</b> <a href="tube_8c_source.html#l00120">tube.c:120</a></div></div>
<div class="ttc" id="ascoop_8h_html_a6eb10b8ed1aa7f16ddf66e2e1051ff85"><div class="ttname"><a href="scoop_8h.html#a6eb10b8ed1aa7f16ddf66e2e1051ff85">rs_scoop_eof</a></div><div class="ttdeci">static bool rs_scoop_eof(rs_job_t *job)</div><div class="ttdoc">Test if the scoop has reached eof.</div><div class="ttdef"><b>Definition:</b> <a href="scoop_8h_source.html#l00100">scoop.h:100</a></div></div>
<div class="ttc" id="ascoop_8h_html_aa1170d5552b5581630f90d8a66a71adc"><div class="ttname"><a href="scoop_8h.html#aa1170d5552b5581630f90d8a66a71adc">rs_tube_copy</a></div><div class="ttdeci">void rs_tube_copy(rs_job_t *job, size_t len)</div><div class="ttdoc">Queue up a request to copy through len bytes from the input to the output of the stream.</div><div class="ttdef"><b>Definition:</b> <a href="tube_8c_source.html#l00160">tube.c:160</a></div></div>
<div class="ttc" id="astructrs__buffers__s_html_aa6783da2d894c77178155759cd12d16f"><div class="ttname"><a href="structrs__buffers__s.html#aa6783da2d894c77178155759cd12d16f">rs_buffers_s::eof_in</a></div><div class="ttdeci">int eof_in</div><div class="ttdoc">True if there is no more data after this.</div><div class="ttdef"><b>Definition:</b> <a href="librsync_8h_source.html#l00345">librsync.h:345</a></div></div>
<div class="ttc" id="astructrs__job_html"><div class="ttname"><a href="structrs__job.html">rs_job</a></div><div class="ttdoc">The contents of this structure are private.</div><div class="ttdef"><b>Definition:</b> <a href="job_8h_source.html#l00047">job.h:47</a></div></div>
<div class="ttc" id="astructrs__job_html_a207f22dcb5ddd1624af1c9579e06254d"><div class="ttname"><a href="structrs__job.html#a207f22dcb5ddd1624af1c9579e06254d">rs_job::basis_pos</a></div><div class="ttdeci">rs_long_t basis_pos</div><div class="ttdoc">Copy from the basis position.</div><div class="ttdef"><b>Definition:</b> <a href="job_8h_source.html#l00117">job.h:117</a></div></div>
<div class="ttc" id="astructrs__job_html_a2dcaea58f56c153083ca05cd2da3d868"><div class="ttname"><a href="structrs__job.html#a2dcaea58f56c153083ca05cd2da3d868">rs_job::scan_buf</a></div><div class="ttdeci">rs_byte_t * scan_buf</div><div class="ttdoc">The delta scan buffer, where scan_buf[scan_pos..scan_len] is the data yet to be scanned.</div><div class="ttdef"><b>Definition:</b> <a href="job_8h_source.html#l00104">job.h:104</a></div></div>
<div class="ttc" id="astructrs__job_html_a45c8741f03fcfab800c87a5f4114f641"><div class="ttname"><a href="structrs__job.html#a45c8741f03fcfab800c87a5f4114f641">rs_job::copy_len</a></div><div class="ttdeci">size_t copy_len</div><div class="ttdoc">If copy_len is >0, then that much data should be copied through from the input.</div><div class="ttdef"><b>Definition:</b> <a href="job_8h_source.html#l00114">job.h:114</a></div></div>
<div class="ttc" id="astructrs__job_html_a61a23cc737c563e5ef2fe4d8ff103387"><div class="ttname"><a href="structrs__job.html#a61a23cc737c563e5ef2fe4d8ff103387">rs_job::scan_pos</a></div><div class="ttdeci">size_t scan_pos</div><div class="ttdoc">The delta scan position.</div><div class="ttdef"><b>Definition:</b> <a href="job_8h_source.html#l00106">job.h:106</a></div></div>
<div class="ttc" id="astructrs__job_html_a9a00375090f27e158987f58987e8e7a0"><div class="ttname"><a href="structrs__job.html#a9a00375090f27e158987f58987e8e7a0">rs_job::scan_len</a></div><div class="ttdeci">size_t scan_len</div><div class="ttdoc">The delta scan buffer length.</div><div class="ttdef"><b>Definition:</b> <a href="job_8h_source.html#l00105">job.h:105</a></div></div>
<div class="ttc" id="astructrs__job_html_aa789990d61f5eadc6a26aeedf4bec765"><div class="ttname"><a href="structrs__job.html#aa789990d61f5eadc6a26aeedf4bec765">rs_job::statefn</a></div><div class="ttdeci">rs_result(* statefn)(rs_job_t *)</div><div class="ttdoc">Callback for each processing step.</div><div class="ttdef"><b>Definition:</b> <a href="job_8h_source.html#l00056">job.h:56</a></div></div>
<div class="ttc" id="astructrs__job_html_ac8b7a197f196b0eabdd1dd2de0f7852f"><div class="ttname"><a href="structrs__job.html#ac8b7a197f196b0eabdd1dd2de0f7852f">rs_job::signature</a></div><div class="ttdeci">rs_signature_t * signature</div><div class="ttdoc">Pointer to the signature that's being used by the operation.</div><div class="ttdef"><b>Definition:</b> <a href="job_8h_source.html#l00072">job.h:72</a></div></div>
<div class="ttc" id="astructrs__job_html_aec548f7a84b838c552e304e83c5a1775"><div class="ttname"><a href="structrs__job.html#aec548f7a84b838c552e304e83c5a1775">rs_job::weak_sum</a></div><div class="ttdeci">weaksum_t weak_sum</div><div class="ttdoc">The rollsum weak signature accumulator used by delta.c.</div><div class="ttdef"><b>Definition:</b> <a href="job_8h_source.html#l00084">job.h:84</a></div></div>
<div class="ttc" id="astructrs__signature_html"><div class="ttname"><a href="structrs__signature.html">rs_signature</a></div><div class="ttdoc">Signature of a whole file.</div><div class="ttdef"><b>Definition:</b> <a href="sumset_8h_source.html#l00044">sumset.h:44</a></div></div>
<div class="ttc" id="astructrs__signature_html_a0d2dd24f39336f0e00036da675d63f99"><div class="ttname"><a href="structrs__signature.html#a0d2dd24f39336f0e00036da675d63f99">rs_signature::count</a></div><div class="ttdeci">int count</div><div class="ttdoc">Total number of blocks.</div><div class="ttdef"><b>Definition:</b> <a href="sumset_8h_source.html#l00048">sumset.h:48</a></div></div>
<div class="ttc" id="astructrs__signature_html_a83be77fb95b4ab210a1accdf6687058c"><div class="ttname"><a href="structrs__signature.html#a83be77fb95b4ab210a1accdf6687058c">rs_signature::hashtable</a></div><div class="ttdeci">hashtable_t * hashtable</div><div class="ttdoc">The hashtable for finding matches.</div><div class="ttdef"><b>Definition:</b> <a href="sumset_8h_source.html#l00051">sumset.h:51</a></div></div>
<div class="ttc" id="astructrs__signature_html_a8df88cba2f5ef197c2dabc72579409e6"><div class="ttname"><a href="structrs__signature.html#a8df88cba2f5ef197c2dabc72579409e6">rs_signature::block_len</a></div><div class="ttdeci">int block_len</div><div class="ttdoc">The block length.</div><div class="ttdef"><b>Definition:</b> <a href="sumset_8h_source.html#l00046">sumset.h:46</a></div></div>
<div class="ttc" id="asumset_8h_html"><div class="ttname"><a href="sumset_8h.html">sumset.h</a></div><div class="ttdoc">The rs_signature class implementation of a file signature.</div></div>
<div class="ttc" id="asumset_8h_html_a6e83fb1697e2326f39fc3ec3c6a0c6ee"><div class="ttname"><a href="sumset_8h.html#a6e83fb1697e2326f39fc3ec3c6a0c6ee">rs_signature_find_match</a></div><div class="ttdeci">rs_long_t rs_signature_find_match(rs_signature_t *sig, rs_weak_sum_t weak_sum, void const *buf, size_t len)</div><div class="ttdoc">Find a matching block offset in a signature.</div><div class="ttdef"><b>Definition:</b> <a href="sumset_8c_source.html#l00242">sumset.c:242</a></div></div>
<div class="ttc" id="asumset_8h_html_ae72598d4e3ca0ce67f46a3818707c3e5"><div class="ttname"><a href="sumset_8h.html#ae72598d4e3ca0ce67f46a3818707c3e5">rs_signature_weaksum_kind</a></div><div class="ttdeci">static weaksum_kind_t rs_signature_weaksum_kind(rs_signature_t const *sig)</div><div class="ttdoc">Get the weaksum kind for a signature.</div><div class="ttdef"><b>Definition:</b> <a href="sumset_8h_source.html#l00114">sumset.h:114</a></div></div>
<div class="ttc" id="asumset_8h_html_afb7830fd2d4deff03b72ceab3936f19e"><div class="ttname"><a href="sumset_8h.html#afb7830fd2d4deff03b72ceab3936f19e">rs_signature_check</a></div><div class="ttdeci">#define rs_signature_check(sig)</div><div class="ttdoc">Assert that a signature is valid.</div><div class="ttdef"><b>Definition:</b> <a href="sumset_8h_source.html#l00107">sumset.h:107</a></div></div>
<div class="ttc" id="atrace_8h_html"><div class="ttname"><a href="trace_8h.html">trace.h</a></div><div class="ttdoc">logging functions.</div></div>
</div><!-- fragment --></div><!-- contents -->
<!-- HTML footer for doxygen 1.8.10-->
<!-- start footer part -->
<!-- ad -->
<script async src="//pagead2.googlesyndication.com/pagead/js/adsbygoogle.js"></script>
<!-- librsync -->
<ins class="adsbygoogle"
style="display:block"
data-ad-client="ca-pub-3547096055927362"
data-ad-slot="8322976738"
data-ad-format="auto"></ins>
<script>
(adsbygoogle = window.adsbygoogle || []).push({});
</script>
<!-- analytics -->
<script>
(function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
(i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
m=s.getElementsByTagName(o)[0];a.async=1;a.src=g;m.parentNode.insertBefore(a,m)
})(window,document,'script','//www.google-analytics.com/analytics.js','ga');
ga('create', 'UA-71109100-1', 'auto');
ga('send', 'pageview');
</script>
<hr class="footer"/><address class="footer"><small>
Generated on Sun Feb 19 2023 16:26:49 for librsync by  <a href="http://www.doxygen.org/index.html">
<img class="footer" src="doxygen.png" alt="doxygen"/>
</a> 1.9.4
</small></address>
</body>
</html>