| 1 | #include <stdint.h> |
| 2 | #include <stddef.h> |
| 3 | #ifdef _OPENMP |
| 4 | #include <omp.h> |
| 5 | #endif |
| 6 | |
| 7 | #include "../include/libbase64.h" |
| 8 | #include "codecs.h" |
| 9 | #include "tables.h" |
| 10 | |
| 11 | // These static function pointers are initialized once when the library is |
| 12 | // first used, and remain in use for the remaining lifetime of the program. |
| 13 | // The idea being that CPU features don't change at runtime. |
| 14 | static struct codec codec = { NULL, NULL }; |
| 15 | |
| 16 | const uint8_t |
| 17 | base64_table_enc[] = |
| 18 | "ABCDEFGHIJKLMNOPQRSTUVWXYZ" |
| 19 | "abcdefghijklmnopqrstuvwxyz" |
| 20 | "0123456789+/" ; |
| 21 | |
| 22 | // In the lookup table below, note that the value for '=' (character 61) is |
| 23 | // 254, not 255. This character is used for in-band signaling of the end of |
| 24 | // the datastream, and we will use that later. The characters A-Z, a-z, 0-9 |
| 25 | // and + / are mapped to their "decoded" values. The other bytes all map to |
| 26 | // the value 255, which flags them as "invalid input". |
| 27 | |
| 28 | const uint8_t |
| 29 | base64_table_dec[] = |
| 30 | { |
| 31 | 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, // 0..15 |
| 32 | 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, // 16..31 |
| 33 | 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 62, 255, 255, 255, 63, // 32..47 |
| 34 | 52, 53, 54, 55, 56, 57, 58, 59, 60, 61, 255, 255, 255, 254, 255, 255, // 48..63 |
| 35 | 255, 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, // 64..79 |
| 36 | 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 255, 255, 255, 255, 255, // 80..95 |
| 37 | 255, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38, 39, 40, // 96..111 |
| 38 | 41, 42, 43, 44, 45, 46, 47, 48, 49, 50, 51, 255, 255, 255, 255, 255, // 112..127 |
| 39 | 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, // 128..143 |
| 40 | 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, |
| 41 | 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, |
| 42 | 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, |
| 43 | 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, |
| 44 | 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, |
| 45 | 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, |
| 46 | 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, |
| 47 | }; |
| 48 | |
| 49 | void |
| 50 | base64_stream_encode_init (struct base64_state *state, int flags) |
| 51 | { |
| 52 | // If any of the codec flags are set, redo choice: |
| 53 | if (codec.enc == NULL || flags & 0xFF) { |
| 54 | codec_choose(&codec, flags); |
| 55 | } |
| 56 | state->eof = 0; |
| 57 | state->bytes = 0; |
| 58 | state->carry = 0; |
| 59 | state->flags = flags; |
| 60 | } |
| 61 | |
| 62 | void |
| 63 | base64_stream_encode |
| 64 | ( struct base64_state *state |
| 65 | , const char *src |
| 66 | , size_t srclen |
| 67 | , char *out |
| 68 | , size_t *outlen |
| 69 | ) |
| 70 | { |
| 71 | codec.enc(state, src, srclen, out, outlen); |
| 72 | } |
| 73 | |
| 74 | void |
| 75 | base64_stream_encode_final |
| 76 | ( struct base64_state *state |
| 77 | , char *out |
| 78 | , size_t *outlen |
| 79 | ) |
| 80 | { |
| 81 | uint8_t *o = (uint8_t *)out; |
| 82 | |
| 83 | if (state->bytes == 1) { |
| 84 | *o++ = base64_table_enc[state->carry]; |
| 85 | *o++ = '='; |
| 86 | *o++ = '='; |
| 87 | *outlen = 3; |
| 88 | return; |
| 89 | } |
| 90 | if (state->bytes == 2) { |
| 91 | *o++ = base64_table_enc[state->carry]; |
| 92 | *o++ = '='; |
| 93 | *outlen = 2; |
| 94 | return; |
| 95 | } |
| 96 | *outlen = 0; |
| 97 | } |
| 98 | |
| 99 | void |
| 100 | base64_stream_decode_init (struct base64_state *state, int flags) |
| 101 | { |
| 102 | // If any of the codec flags are set, redo choice: |
| 103 | if (codec.dec == NULL || flags & 0xFF) { |
| 104 | codec_choose(&codec, flags); |
| 105 | } |
| 106 | state->eof = 0; |
| 107 | state->bytes = 0; |
| 108 | state->carry = 0; |
| 109 | state->flags = flags; |
| 110 | } |
| 111 | |
| 112 | int |
| 113 | base64_stream_decode |
| 114 | ( struct base64_state *state |
| 115 | , const char *src |
| 116 | , size_t srclen |
| 117 | , char *out |
| 118 | , size_t *outlen |
| 119 | ) |
| 120 | { |
| 121 | return codec.dec(state, src, srclen, out, outlen); |
| 122 | } |
| 123 | |
| 124 | #ifdef _OPENMP |
| 125 | |
| 126 | // Due to the overhead of initializing OpenMP and creating a team of |
| 127 | // threads, we require the data length to be larger than a threshold: |
| 128 | #define OMP_THRESHOLD 20000 |
| 129 | |
| 130 | // Conditionally include OpenMP-accelerated codec implementations: |
| 131 | #include "lib_openmp.c" |
| 132 | #endif |
| 133 | |
| 134 | void |
| 135 | base64_encode |
| 136 | ( const char *src |
| 137 | , size_t srclen |
| 138 | , char *out |
| 139 | , size_t *outlen |
| 140 | , int flags |
| 141 | ) |
| 142 | { |
| 143 | size_t s; |
| 144 | size_t t; |
| 145 | struct base64_state state; |
| 146 | |
| 147 | #ifdef _OPENMP |
| 148 | if (srclen >= OMP_THRESHOLD) { |
| 149 | base64_encode_openmp(src, srclen, out, outlen, flags); |
| 150 | return; |
| 151 | } |
| 152 | #endif |
| 153 | |
| 154 | // Init the stream reader: |
| 155 | base64_stream_encode_init(&state, flags); |
| 156 | |
| 157 | // Feed the whole string to the stream reader: |
| 158 | base64_stream_encode(&state, src, srclen, out, &s); |
| 159 | |
| 160 | // Finalize the stream by writing trailer if any: |
| 161 | base64_stream_encode_final(&state, out + s, &t); |
| 162 | |
| 163 | // Final output length is stream length plus tail: |
| 164 | *outlen = s + t; |
| 165 | } |
| 166 | |
| 167 | int |
| 168 | base64_decode |
| 169 | ( const char *src |
| 170 | , size_t srclen |
| 171 | , char *out |
| 172 | , size_t *outlen |
| 173 | , int flags |
| 174 | ) |
| 175 | { |
| 176 | int ret; |
| 177 | struct base64_state state; |
| 178 | |
| 179 | #ifdef _OPENMP |
| 180 | if (srclen >= OMP_THRESHOLD) { |
| 181 | return base64_decode_openmp(src, srclen, out, outlen, flags); |
| 182 | } |
| 183 | #endif |
| 184 | |
| 185 | // Init the stream reader: |
| 186 | base64_stream_decode_init(&state, flags); |
| 187 | |
| 188 | // Feed the whole string to the stream reader: |
| 189 | ret = base64_stream_decode(&state, src, srclen, out, outlen); |
| 190 | |
| 191 | // If when decoding a whole block, we're still waiting for input then fail: |
| 192 | if (ret && (state.bytes == 0)) { |
| 193 | return ret; |
| 194 | } |
| 195 | return 0; |
| 196 | } |
| 197 | |