/src/ghostpdl/base/srld.c
Line | Count | Source (jump to first uncovered line) |
1 | | /* Copyright (C) 2001-2023 Artifex Software, Inc. |
2 | | All Rights Reserved. |
3 | | |
4 | | This software is provided AS-IS with no warranty, either express or |
5 | | implied. |
6 | | |
7 | | This software is distributed under license and may not be copied, |
8 | | modified or distributed except as expressly authorized under the terms |
9 | | of the license contained in the file LICENSE in this distribution. |
10 | | |
11 | | Refer to licensing information at http://www.artifex.com or contact |
12 | | Artifex Software, Inc., 39 Mesa Street, Suite 108A, San Francisco, |
13 | | CA 94129, USA, for further information. |
14 | | */ |
15 | | |
16 | | |
17 | | /* RunLengthDecode filter */ |
18 | | #include "stdio_.h" /* includes std.h */ |
19 | | #include "memory_.h" |
20 | | #include "strimpl.h" |
21 | | #include "srlx.h" |
22 | | |
23 | | /* ------ RunLengthDecode ------ */ |
24 | | |
25 | | private_st_RLD_state(); |
26 | | |
27 | | /* Set defaults */ |
28 | | static void |
29 | | s_RLD_set_defaults(stream_state * st) |
30 | 1 | { |
31 | 1 | stream_RLD_state *const ss = (stream_RLD_state *) st; |
32 | | |
33 | 1 | s_RLD_set_defaults_inline(ss); |
34 | 1 | } |
35 | | |
36 | | /* Initialize */ |
37 | | static int |
38 | | s_RLD_init(stream_state * st) |
39 | 1 | { |
40 | 1 | stream_RLD_state *const ss = (stream_RLD_state *) st; |
41 | | |
42 | 1 | return s_RLD_init_inline(ss); |
43 | 1 | } |
44 | | |
45 | | /* Refill the buffer */ |
46 | | static int |
47 | | s_RLD_process(stream_state * st, stream_cursor_read * pr, |
48 | | stream_cursor_write * pw, bool last) |
49 | 93 | { |
50 | 93 | stream_RLD_state *const ss = (stream_RLD_state *) st; |
51 | 93 | register const byte *p = pr->ptr; |
52 | 93 | register byte *q = pw->ptr; |
53 | 93 | const byte *rlimit = pr->limit; |
54 | 93 | byte *wlimit = pw->limit; |
55 | 93 | int left; |
56 | 93 | int status = 0; |
57 | | |
58 | 183 | top: |
59 | 183 | if ((left = ss->copy_left) > 0) { |
60 | | /* |
61 | | * We suspended because the output buffer was full:; |
62 | | * try again now. |
63 | | */ |
64 | 180 | uint avail = wlimit - q; |
65 | 180 | int copy_status = 1; |
66 | | |
67 | 180 | if (left > avail) |
68 | 90 | left = avail; |
69 | 180 | if (ss->copy_data >= 0) |
70 | 180 | memset(q + 1, ss->copy_data, left); |
71 | 0 | else { |
72 | 0 | avail = rlimit - p; |
73 | 0 | if (left >= avail) { |
74 | 0 | copy_status = 0; |
75 | 0 | left = avail; |
76 | 0 | } |
77 | 0 | memcpy(q + 1, p + 1, left); |
78 | 0 | p += left; |
79 | 0 | } |
80 | 180 | q += left; |
81 | 180 | if ((ss->copy_left -= left) > 0) { |
82 | 90 | status = copy_status; |
83 | 90 | goto x; |
84 | 90 | } |
85 | 180 | } |
86 | 1.46k | while (p < rlimit) { |
87 | 1.46k | int b = *++p; |
88 | | |
89 | 1.46k | if (b < 128) { |
90 | 0 | if (++b > rlimit - p || b > wlimit - q) { |
91 | 0 | ss->copy_left = b; |
92 | 0 | ss->copy_data = -1; |
93 | 0 | goto top; |
94 | 0 | } |
95 | 0 | memcpy(q + 1, p + 1, b); |
96 | 0 | p += b; |
97 | 0 | q += b; |
98 | 1.46k | } else if (b == 128) { /* end of data */ |
99 | 1 | if (ss->EndOfData) { |
100 | 1 | status = EOFC; |
101 | 1 | break; |
102 | 1 | } |
103 | 1.46k | } else if (p == rlimit) { |
104 | 1 | p--; |
105 | 1 | break; |
106 | 1.46k | } else if ((b = 257 - b) > wlimit - q) { |
107 | 90 | ss->copy_left = b; |
108 | 90 | ss->copy_data = *++p; |
109 | 90 | goto top; |
110 | 1.37k | } else { |
111 | 1.37k | memset(q + 1, *++p, b); |
112 | 1.37k | q += b; |
113 | 1.37k | } |
114 | 1.46k | } |
115 | 93 | x: pr->ptr = p; |
116 | 93 | pw->ptr = q; |
117 | 93 | return status; |
118 | 93 | } |
119 | | |
120 | | /* Stream template */ |
121 | | const stream_template s_RLD_template = { |
122 | | &st_RLD_state, s_RLD_init, s_RLD_process, 1, 1, NULL, |
123 | | s_RLD_set_defaults |
124 | | }; |