/src/ghostpdl/base/srld.c
Line | Count | Source |
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 | 362 | { |
31 | 362 | stream_RLD_state *const ss = (stream_RLD_state *) st; |
32 | | |
33 | 362 | s_RLD_set_defaults_inline(ss); |
34 | 362 | } |
35 | | |
36 | | /* Initialize */ |
37 | | static int |
38 | | s_RLD_init(stream_state * st) |
39 | 181 | { |
40 | 181 | stream_RLD_state *const ss = (stream_RLD_state *) st; |
41 | | |
42 | 181 | return s_RLD_init_inline(ss); |
43 | 181 | } |
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 | 4.18k | { |
50 | 4.18k | stream_RLD_state *const ss = (stream_RLD_state *) st; |
51 | 4.18k | register const byte *p = pr->ptr; |
52 | 4.18k | register byte *q = pw->ptr; |
53 | 4.18k | const byte *rlimit = pr->limit; |
54 | 4.18k | byte *wlimit = pw->limit; |
55 | 4.18k | int left; |
56 | 4.18k | int status = 0; |
57 | | |
58 | 7.87k | top: |
59 | 7.87k | if ((left = ss->copy_left) > 0) { |
60 | | /* |
61 | | * We suspended because the output buffer was full:; |
62 | | * try again now. |
63 | | */ |
64 | 7.36k | uint avail = wlimit - q; |
65 | 7.36k | int copy_status = 1; |
66 | | |
67 | 7.36k | if (left > avail) |
68 | 3.52k | left = avail; |
69 | 7.36k | if (ss->copy_data >= 0) |
70 | 6.78k | memset(q + 1, ss->copy_data, left); |
71 | 589 | else { |
72 | 589 | avail = rlimit - p; |
73 | 589 | if (left >= avail) { |
74 | 243 | copy_status = 0; |
75 | 243 | left = avail; |
76 | 243 | } |
77 | 589 | memcpy(q + 1, p + 1, left); |
78 | 589 | p += left; |
79 | 589 | } |
80 | 7.36k | q += left; |
81 | 7.36k | if ((ss->copy_left -= left) > 0) { |
82 | 3.76k | status = copy_status; |
83 | 3.76k | goto x; |
84 | 3.76k | } |
85 | 7.36k | } |
86 | 206k | while (p < rlimit) { |
87 | 206k | int b = *++p; |
88 | | |
89 | 206k | if (b < 128) { |
90 | 70.9k | if (++b > rlimit - p || b > wlimit - q) { |
91 | 297 | ss->copy_left = b; |
92 | 297 | ss->copy_data = -1; |
93 | 297 | goto top; |
94 | 297 | } |
95 | 70.6k | memcpy(q + 1, p + 1, b); |
96 | 70.6k | p += b; |
97 | 70.6k | q += b; |
98 | 135k | } else if (b == 128) { /* end of data */ |
99 | 76 | if (ss->EndOfData) { |
100 | 76 | status = EOFC; |
101 | 76 | break; |
102 | 76 | } |
103 | 135k | } else if (p == rlimit) { |
104 | 105 | p--; |
105 | 105 | break; |
106 | 135k | } else if ((b = 257 - b) > wlimit - q) { |
107 | 3.39k | ss->copy_left = b; |
108 | 3.39k | ss->copy_data = *++p; |
109 | 3.39k | goto top; |
110 | 131k | } else { |
111 | 131k | memset(q + 1, *++p, b); |
112 | 131k | q += b; |
113 | 131k | } |
114 | 206k | } |
115 | 4.18k | x: pr->ptr = p; |
116 | 4.18k | pw->ptr = q; |
117 | 4.18k | return status; |
118 | 4.11k | } |
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 | | }; |