tsiry-sandratraina.com
A modern Music Player Daemon based on Rockbox open source high quality audio player
libadwaita
audio
rust
zig
deno
mpris
rockbox
mpd
1/***************************************************************************
2 * __________ __ ___.
3 * Open \______ \ ____ ____ | | _\_ |__ _______ ___
4 * Source | _// _ \_/ ___\| |/ /| __ \ / _ \ \/ /
5 * Jukebox | | ( <_> ) \___| < | \_\ ( <_> > < <
6 * Firmware |____|_ /\____/ \___ >__|_ \|___ /\____/__/\_ \
7 * \/ \/ \/ \/ \/
8 * $Id$
9 *
10 * Copyright (C) 2002 Gilles Roux
11 * 2003 Garrett Derner
12 * 2010 Yoshihisa Uchida
13 *
14 * This program is free software; you can redistribute it and/or
15 * modify it under the terms of the GNU General Public License
16 * as published by the Free Software Foundation; either version 2
17 * of the License, or (at your option) any later version.
18 *
19 * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
20 * KIND, either express or implied.
21 *
22 ****************************************************************************/
23#include "plugin.h"
24#include "tv_preferences.h"
25#include "tv_reader.h"
26
27#if PLUGIN_BUFFER_SIZE < 0x10000
28#define TV_MIN_BLOCK_SIZE 0x800
29#else
30#define TV_MIN_BLOCK_SIZE 0x1000
31#endif
32
33/* UTF-8 BOM */
34#define BOM "\xef\xbb\xbf"
35#define BOM_SIZE 3
36
37static int fd = -1;
38
39static off_t file_pos;
40static off_t start_file_pos;
41
42static off_t file_size;
43
44static unsigned char *reader_buffer;
45static ssize_t buffer_size;
46static ssize_t block_size;
47
48static ssize_t buf_pos;
49static ssize_t read_size;
50
51off_t tv_get_file_size(void)
52{
53 return file_size;
54}
55
56bool tv_is_eof(void)
57{
58 return (file_pos + buf_pos >= file_size);
59}
60
61off_t tv_get_current_file_pos(void)
62{
63 return file_pos + buf_pos;
64}
65
66const unsigned char *tv_get_buffer(ssize_t *bufsize)
67{
68 *bufsize = read_size - buf_pos;
69 return reader_buffer + buf_pos;
70}
71
72static ssize_t tv_read(unsigned char *buf, ssize_t reqsize)
73{
74 if (buf - reader_buffer + reqsize > buffer_size)
75 reqsize = buffer_size - (buf - reader_buffer);
76
77 return rb->read(fd, buf, reqsize);
78}
79
80void tv_seek(off_t offset, int whence)
81{
82 ssize_t size;
83
84 switch (whence)
85 {
86 case SEEK_SET:
87 if (offset >= file_pos && offset < file_pos + read_size)
88 {
89 buf_pos = offset - file_pos;
90 return;
91 }
92 file_pos = offset;
93 break;
94
95 case SEEK_CUR:
96 buf_pos += offset;
97 if (buf_pos >= 0 && buf_pos < read_size)
98 {
99 if (buf_pos > block_size)
100 {
101 buf_pos -= block_size;
102 file_pos += block_size;
103 size = read_size - block_size;
104 rb->memcpy(reader_buffer, reader_buffer + block_size, size);
105 read_size = tv_read(reader_buffer + block_size, block_size);
106 if (read_size < 0)
107 read_size = 0;
108
109 read_size += size;
110 }
111 return;
112 }
113 file_pos += buf_pos;
114 break;
115
116 default:
117 return;
118 break;
119 }
120
121 if (whence == SEEK_SET)
122 {
123 if (file_pos < 0)
124 file_pos = 0;
125 else if (file_pos > file_size)
126 file_pos = file_size;
127
128 rb->lseek(fd, file_pos + start_file_pos, SEEK_SET);
129 buf_pos = 0;
130 read_size = tv_read(reader_buffer, buffer_size);
131 }
132}
133
134static int tv_change_preferences(const struct tv_preferences *oldp)
135{
136 bool change_file = false;
137
138 /* open the new file */
139 if (oldp == NULL || rb->strcmp(oldp->file_name, preferences->file_name))
140 {
141 if (fd >= 0)
142 rb->close(fd);
143
144 fd = rb->open(preferences->file_name, O_RDONLY);
145 if (fd < 0)
146 return TV_CALLBACK_ERROR;
147
148 file_size = rb->filesize(fd);
149 change_file = true;
150 }
151
152 /*
153 * When a file is UTF-8 file with BOM, if encoding is UTF-8,
154 * then file size decreases only BOM_SIZE.
155 */
156 if (change_file || oldp->encoding != preferences->encoding)
157 {
158 int old_start_file_pos = start_file_pos;
159 int delta_start_file_pos;
160 off_t cur_file_pos = file_pos + buf_pos;
161
162 file_pos = 0;
163 buf_pos = 0;
164 read_size = 0;
165 start_file_pos = 0;
166
167 if (preferences->encoding == UTF_8)
168 {
169 unsigned char bom[BOM_SIZE];
170
171 rb->lseek(fd, 0, SEEK_SET);
172 rb->read(fd, bom, BOM_SIZE);
173 if (rb->memcmp(bom, BOM, BOM_SIZE) == 0)
174 start_file_pos = BOM_SIZE;
175 }
176
177 delta_start_file_pos = old_start_file_pos - start_file_pos;
178 file_size += delta_start_file_pos;
179 tv_seek(cur_file_pos + delta_start_file_pos, SEEK_SET);
180 }
181
182 return TV_CALLBACK_OK;
183}
184
185bool tv_init_reader(unsigned char **buf, size_t *size)
186{
187 if (*size < 2 * TV_MIN_BLOCK_SIZE)
188 return false;
189
190 block_size = *size / 2;
191 buffer_size = 2 * block_size;
192 reader_buffer = *buf;
193
194 *buf += buffer_size;
195 *size -= buffer_size;
196
197 tv_add_preferences_change_listner(tv_change_preferences);
198
199 return true;
200}
201
202void tv_finalize_reader(void)
203{
204 if (fd >= 0)
205 rb->close(fd);
206}