use lib display text to display help messages (FS#10099).
[kugel-rb.git] / apps / playlist.c
blob1d291cf6d012ca60f893b58f611f2fa989555b09
1 /***************************************************************************
2 * __________ __ ___.
3 * Open \______ \ ____ ____ | | _\_ |__ _______ ___
4 * Source | _// _ \_/ ___\| |/ /| __ \ / _ \ \/ /
5 * Jukebox | | ( <_> ) \___| < | \_\ ( <_> > < <
6 * Firmware |____|_ /\____/ \___ >__|_ \|___ /\____/__/\_ \
7 * \/ \/ \/ \/ \/
8 * $Id$
10 * Copyright (C) 2002 by wavey@wavey.org
12 * This program is free software; you can redistribute it and/or
13 * modify it under the terms of the GNU General Public License
14 * as published by the Free Software Foundation; either version 2
15 * of the License, or (at your option) any later version.
17 * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
18 * KIND, either express or implied.
20 ****************************************************************************/
23 Dynamic playlist design (based on design originally proposed by ricII)
25 There are two files associated with a dynamic playlist:
26 1. Playlist file : This file contains the initial songs in the playlist.
27 The file is created by the user and stored on the hard
28 drive. NOTE: If we are playing the contents of a
29 directory, there will be no playlist file.
30 2. Control file : This file is automatically created when a playlist is
31 started and contains all the commands done to it.
33 The first non-comment line in a control file must begin with
34 "P:VERSION:DIR:FILE" where VERSION is the playlist control file version,
35 DIR is the directory where the playlist is located and FILE is the
36 playlist filename. For dirplay, FILE will be empty. An empty playlist
37 will have both entries as null.
39 Control file commands:
40 a. Add track (A:<position>:<last position>:<path to track>)
41 - Insert a track at the specified position in the current
42 playlist. Last position is used to specify where last insertion
43 occurred.
44 b. Queue track (Q:<position>:<last position>:<path to track>)
45 - Queue a track at the specified position in the current
46 playlist. Queued tracks differ from added tracks in that they
47 are deleted from the playlist as soon as they are played and
48 they are not saved to disk as part of the playlist.
49 c. Delete track (D:<position>)
50 - Delete track from specified position in the current playlist.
51 d. Shuffle playlist (S:<seed>:<index>)
52 - Shuffle entire playlist with specified seed. The index
53 identifies the first index in the newly shuffled playlist
54 (needed for repeat mode).
55 e. Unshuffle playlist (U:<index>)
56 - Unshuffle entire playlist. The index identifies the first index
57 in the newly unshuffled playlist.
58 f. Reset last insert position (R)
59 - Needed so that insertions work properly after resume
61 Resume:
62 The only resume info that needs to be saved is the current index in the
63 playlist and the position in the track. When resuming, all the commands
64 in the control file will be reapplied so that the playlist indices are
65 exactly the same as before shutdown. To avoid unnecessary disk
66 accesses, the shuffle mode settings are also saved in settings and only
67 flushed to disk when required.
70 #include <stdio.h>
71 #include <stdlib.h>
72 #include <string.h>
73 #include <ctype.h>
74 #include "playlist.h"
75 #include "ata_idle_notify.h"
76 #include "file.h"
77 #include "action.h"
78 #include "dir.h"
79 #include "sprintf.h"
80 #include "debug.h"
81 #include "audio.h"
82 #include "lcd.h"
83 #include "kernel.h"
84 #include "settings.h"
85 #include "status.h"
86 #include "applimits.h"
87 #include "screens.h"
88 #include "buffer.h"
89 #include "misc.h"
90 #include "button.h"
91 #include "filetree.h"
92 #include "abrepeat.h"
93 #include "thread.h"
94 #include "usb.h"
95 #include "filetypes.h"
96 #ifdef HAVE_LCD_BITMAP
97 #include "icons.h"
98 #endif
99 #include "system.h"
101 #include "lang.h"
102 #include "talk.h"
103 #include "splash.h"
104 #include "rbunicode.h"
105 #include "root_menu.h"
107 #define PLAYLIST_CONTROL_FILE ROCKBOX_DIR "/.playlist_control"
108 #define PLAYLIST_CONTROL_FILE_VERSION 2
111 Each playlist index has a flag associated with it which identifies what
112 type of track it is. These flags are stored in the 4 high order bits of
113 the index.
115 NOTE: This limits the playlist file size to a max of 256M.
117 Bits 31-30:
118 00 = Playlist track
119 01 = Track was prepended into playlist
120 10 = Track was inserted into playlist
121 11 = Track was appended into playlist
122 Bit 29:
123 0 = Added track
124 1 = Queued track
125 Bit 28:
126 0 = Track entry is valid
127 1 = Track does not exist on disk and should be skipped
129 #define PLAYLIST_SEEK_MASK 0x0FFFFFFF
130 #define PLAYLIST_INSERT_TYPE_MASK 0xC0000000
131 #define PLAYLIST_QUEUE_MASK 0x20000000
133 #define PLAYLIST_INSERT_TYPE_PREPEND 0x40000000
134 #define PLAYLIST_INSERT_TYPE_INSERT 0x80000000
135 #define PLAYLIST_INSERT_TYPE_APPEND 0xC0000000
137 #define PLAYLIST_QUEUED 0x20000000
138 #define PLAYLIST_SKIPPED 0x10000000
140 struct directory_search_context {
141 struct playlist_info* playlist;
142 int position;
143 bool queue;
144 int count;
147 static struct playlist_info current_playlist;
148 static char now_playing[MAX_PATH+1];
150 static void empty_playlist(struct playlist_info* playlist, bool resume);
151 static void new_playlist(struct playlist_info* playlist, const char *dir,
152 const char *file);
153 static void create_control(struct playlist_info* playlist);
154 static int check_control(struct playlist_info* playlist);
155 static int recreate_control(struct playlist_info* playlist);
156 static void update_playlist_filename(struct playlist_info* playlist,
157 const char *dir, const char *file);
158 static int add_indices_to_playlist(struct playlist_info* playlist,
159 char* buffer, size_t buflen);
160 static int add_track_to_playlist(struct playlist_info* playlist,
161 const char *filename, int position,
162 bool queue, int seek_pos);
163 static int directory_search_callback(char* filename, void* context);
164 static int remove_track_from_playlist(struct playlist_info* playlist,
165 int position, bool write);
166 static int randomise_playlist(struct playlist_info* playlist,
167 unsigned int seed, bool start_current,
168 bool write);
169 static int sort_playlist(struct playlist_info* playlist, bool start_current,
170 bool write);
171 static int get_next_index(const struct playlist_info* playlist, int steps,
172 int repeat_mode);
173 static void find_and_set_playlist_index(struct playlist_info* playlist,
174 unsigned int seek);
175 static int compare(const void* p1, const void* p2);
176 static int get_filename(struct playlist_info* playlist, int index, int seek,
177 bool control_file, char *buf, int buf_length);
178 static int get_next_directory(char *dir);
179 static int get_next_dir(char *dir, bool is_forward, bool recursion);
180 static int get_previous_directory(char *dir);
181 static int check_subdir_for_music(char *dir, const char *subdir, bool recurse);
182 static int format_track_path(char *dest, char *src, int buf_length, int max,
183 const char *dir);
184 static void display_playlist_count(int count, const unsigned char *fmt,
185 bool final);
186 static void display_buffer_full(void);
187 static int flush_cached_control(struct playlist_info* playlist);
188 static int update_control(struct playlist_info* playlist,
189 enum playlist_command command, int i1, int i2,
190 const char* s1, const char* s2, void* data);
191 static void sync_control(struct playlist_info* playlist, bool force);
192 static int rotate_index(const struct playlist_info* playlist, int index);
194 #ifdef HAVE_DIRCACHE
195 #define PLAYLIST_LOAD_POINTERS 1
197 static struct event_queue playlist_queue;
198 static long playlist_stack[(DEFAULT_STACK_SIZE + 0x800)/sizeof(long)];
199 static const char playlist_thread_name[] = "playlist cachectrl";
200 #endif
202 /* Check if the filename suggests M3U or M3U8 format. */
203 static bool is_m3u8(const char* filename)
205 int len = strlen(filename);
207 /* Default to M3U8 unless explicitly told otherwise. */
208 return !(len > 4 && strcasecmp(&filename[len - 4], ".m3u") == 0);
212 /* Convert a filename in an M3U playlist to UTF-8.
214 * buf - the filename to convert; can contain more than one line from the
215 * playlist.
216 * buf_len - amount of buf that is used.
217 * buf_max - total size of buf.
218 * temp - temporary conversion buffer, at least buf_max bytes.
220 * Returns the length of the converted filename.
222 static int convert_m3u(char* buf, int buf_len, int buf_max, char* temp)
224 int i = 0;
225 char* dest;
227 /* Locate EOL. */
228 while ((buf[i] != '\n') && (buf[i] != '\r') && (i < buf_len))
230 i++;
233 /* Work back killing white space. */
234 while ((i > 0) && isspace(buf[i - 1]))
236 i--;
239 buf_len = i;
240 dest = temp;
242 /* Convert char by char, so as to not overflow temp (iso_decode should
243 * preferably handle this). No more than 4 bytes should be generated for
244 * each input char.
246 for (i = 0; i < buf_len && dest < (temp + buf_max - 4); i++)
248 dest = iso_decode(&buf[i], dest, -1, 1);
251 *dest = 0;
252 strcpy(buf, temp);
253 return dest - temp;
257 * remove any files and indices associated with the playlist
259 static void empty_playlist(struct playlist_info* playlist, bool resume)
261 playlist->filename[0] = '\0';
262 playlist->utf8 = true;
264 if(playlist->fd >= 0)
265 /* If there is an already open playlist, close it. */
266 close(playlist->fd);
267 playlist->fd = -1;
269 if(playlist->control_fd >= 0)
270 close(playlist->control_fd);
271 playlist->control_fd = -1;
272 playlist->control_created = false;
274 playlist->in_ram = false;
276 if (playlist->buffer)
277 playlist->buffer[0] = 0;
279 playlist->buffer_end_pos = 0;
281 playlist->index = 0;
282 playlist->first_index = 0;
283 playlist->amount = 0;
284 playlist->last_insert_pos = -1;
285 playlist->seed = 0;
286 playlist->shuffle_modified = false;
287 playlist->deleted = false;
288 playlist->num_inserted_tracks = 0;
289 playlist->started = false;
291 playlist->num_cached = 0;
292 playlist->pending_control_sync = false;
294 if (!resume && playlist->current)
296 /* start with fresh playlist control file when starting new
297 playlist */
298 create_control(playlist);
303 * Initialize a new playlist for viewing/editing/playing. dir is the
304 * directory where the playlist is located and file is the filename.
306 static void new_playlist(struct playlist_info* playlist, const char *dir,
307 const char *file)
309 const char *fileused = file;
310 const char *dirused = dir;
311 empty_playlist(playlist, false);
313 if (!fileused)
315 fileused = "";
317 if (dirused && playlist->current) /* !current cannot be in_ram */
318 playlist->in_ram = true;
319 else
320 dirused = ""; /* empty playlist */
323 update_playlist_filename(playlist, dirused, fileused);
325 if (playlist->control_fd >= 0)
327 update_control(playlist, PLAYLIST_COMMAND_PLAYLIST,
328 PLAYLIST_CONTROL_FILE_VERSION, -1, dirused, fileused, NULL);
329 sync_control(playlist, false);
334 * create control file for playlist
336 static void create_control(struct playlist_info* playlist)
338 playlist->control_fd = open(playlist->control_filename,
339 O_CREAT|O_RDWR|O_TRUNC);
340 if (playlist->control_fd < 0)
342 if (check_rockboxdir())
344 cond_talk_ids_fq(LANG_PLAYLIST_CONTROL_ACCESS_ERROR);
345 splashf(HZ*2, (unsigned char *)"%s (%d)",
346 str(LANG_PLAYLIST_CONTROL_ACCESS_ERROR),
347 playlist->control_fd);
349 playlist->control_created = false;
351 else
353 playlist->control_created = true;
358 * validate the control file. This may include creating/initializing it if
359 * necessary;
361 static int check_control(struct playlist_info* playlist)
363 if (!playlist->control_created)
365 create_control(playlist);
367 if (playlist->control_fd >= 0)
369 char* dir = playlist->filename;
370 char* file = playlist->filename+playlist->dirlen;
371 char c = playlist->filename[playlist->dirlen-1];
373 playlist->filename[playlist->dirlen-1] = '\0';
375 update_control(playlist, PLAYLIST_COMMAND_PLAYLIST,
376 PLAYLIST_CONTROL_FILE_VERSION, -1, dir, file, NULL);
377 sync_control(playlist, false);
378 playlist->filename[playlist->dirlen-1] = c;
382 if (playlist->control_fd < 0)
383 return -1;
385 return 0;
389 * recreate the control file based on current playlist entries
391 static int recreate_control(struct playlist_info* playlist)
393 char temp_file[MAX_PATH+1];
394 int temp_fd = -1;
395 int i;
396 int result = 0;
398 if(playlist->control_fd >= 0)
400 char* dir = playlist->filename;
401 char* file = playlist->filename+playlist->dirlen;
402 char c = playlist->filename[playlist->dirlen-1];
404 close(playlist->control_fd);
406 snprintf(temp_file, sizeof(temp_file), "%s_temp",
407 playlist->control_filename);
409 if (rename(playlist->control_filename, temp_file) < 0)
410 return -1;
412 temp_fd = open(temp_file, O_RDONLY);
413 if (temp_fd < 0)
414 return -1;
416 playlist->control_fd = open(playlist->control_filename,
417 O_CREAT|O_RDWR|O_TRUNC);
418 if (playlist->control_fd < 0)
419 return -1;
421 playlist->filename[playlist->dirlen-1] = '\0';
423 /* cannot call update_control() because of mutex */
424 result = fdprintf(playlist->control_fd, "P:%d:%s:%s\n",
425 PLAYLIST_CONTROL_FILE_VERSION, dir, file);
427 playlist->filename[playlist->dirlen-1] = c;
429 if (result < 0)
431 close(temp_fd);
432 return result;
436 playlist->seed = 0;
437 playlist->shuffle_modified = false;
438 playlist->deleted = false;
439 playlist->num_inserted_tracks = 0;
441 for (i=0; i<playlist->amount; i++)
443 if (playlist->indices[i] & PLAYLIST_INSERT_TYPE_MASK)
445 bool queue = playlist->indices[i] & PLAYLIST_QUEUE_MASK;
446 char inserted_file[MAX_PATH+1];
448 lseek(temp_fd, playlist->indices[i] & PLAYLIST_SEEK_MASK,
449 SEEK_SET);
450 read_line(temp_fd, inserted_file, sizeof(inserted_file));
452 result = fdprintf(playlist->control_fd, "%c:%d:%d:",
453 queue?'Q':'A', i, playlist->last_insert_pos);
454 if (result > 0)
456 /* save the position in file where name is written */
457 int seek_pos = lseek(playlist->control_fd, 0, SEEK_CUR);
459 result = fdprintf(playlist->control_fd, "%s\n",
460 inserted_file);
462 playlist->indices[i] =
463 (playlist->indices[i] & ~PLAYLIST_SEEK_MASK) | seek_pos;
466 if (result < 0)
467 break;
469 playlist->num_inserted_tracks++;
473 close(temp_fd);
474 remove(temp_file);
475 fsync(playlist->control_fd);
477 if (result < 0)
478 return result;
480 return 0;
484 * store directory and name of playlist file
486 static void update_playlist_filename(struct playlist_info* playlist,
487 const char *dir, const char *file)
489 char *sep="";
490 int dirlen = strlen(dir);
492 playlist->utf8 = is_m3u8(file);
494 /* If the dir does not end in trailing slash, we use a separator.
495 Otherwise we don't. */
496 if('/' != dir[dirlen-1])
498 sep="/";
499 dirlen++;
502 playlist->dirlen = dirlen;
504 snprintf(playlist->filename, sizeof(playlist->filename),
505 "%s%s%s", dir, sep, file);
509 * calculate track offsets within a playlist file
511 static int add_indices_to_playlist(struct playlist_info* playlist,
512 char* buffer, size_t buflen)
514 unsigned int nread;
515 unsigned int i = 0;
516 unsigned int count = 0;
517 bool store_index;
518 unsigned char *p;
519 int result = 0;
521 if(-1 == playlist->fd)
522 playlist->fd = open_utf8(playlist->filename, O_RDONLY);
523 if(playlist->fd < 0)
524 return -1; /* failure */
525 if((i = lseek(playlist->fd, 0, SEEK_CUR)) > 0)
526 playlist->utf8 = true; /* Override any earlier indication. */
528 splash(0, ID2P(LANG_WAIT));
530 if (!buffer)
532 /* use mp3 buffer for maximum load speed */
533 audio_stop();
534 #if CONFIG_CODEC != SWCODEC
535 talk_buffer_steal(); /* we use the mp3 buffer, need to tell */
536 buflen = (audiobufend - audiobuf);
537 buffer = (char *)audiobuf;
538 #else
539 buffer = (char *)audio_get_buffer(false, &buflen);
540 #endif
543 store_index = true;
545 while(1)
547 nread = read(playlist->fd, buffer, buflen);
548 /* Terminate on EOF */
549 if(nread <= 0)
550 break;
552 p = (unsigned char *)buffer;
554 for(count=0; count < nread; count++,p++) {
556 /* Are we on a new line? */
557 if((*p == '\n') || (*p == '\r'))
559 store_index = true;
561 else if(store_index)
563 store_index = false;
565 if(*p != '#')
567 if ( playlist->amount >= playlist->max_playlist_size ) {
568 display_buffer_full();
569 result = -1;
570 goto exit;
573 /* Store a new entry */
574 playlist->indices[ playlist->amount ] = i+count;
575 #ifdef HAVE_DIRCACHE
576 if (playlist->filenames)
577 playlist->filenames[ playlist->amount ] = NULL;
578 #endif
579 playlist->amount++;
584 i+= count;
587 exit:
588 #ifdef HAVE_DIRCACHE
589 queue_post(&playlist_queue, PLAYLIST_LOAD_POINTERS, 0);
590 #endif
592 return result;
596 * Utility function to create a new playlist, fill it with the next or
597 * previous directory, shuffle it if needed, and start playback.
598 * If play_last is true and direction zero or negative, start playing
599 * the last file in the directory, otherwise start playing the first.
601 static int create_and_play_dir(int direction, bool play_last)
603 char dir[MAX_PATH + 1];
604 int res;
605 int index = -1;
607 if(direction > 0)
608 res = get_next_directory(dir);
609 else
610 res = get_previous_directory(dir);
612 if (!res)
614 if (playlist_create(dir, NULL) != -1)
616 ft_build_playlist(tree_get_context(), 0);
618 if (global_settings.playlist_shuffle)
619 playlist_shuffle(current_tick, -1);
621 if (play_last && direction <= 0)
622 index = current_playlist.amount - 1;
623 else
624 index = 0;
626 #if (CONFIG_CODEC != SWCODEC)
627 playlist_start(index, 0);
628 #endif
631 /* we've overwritten the dircache when getting the next/previous dir,
632 so the tree browser context will need to be reloaded */
633 reload_directory();
636 return index;
640 * Removes all tracks, from the playlist, leaving the presently playing
641 * track queued.
643 int playlist_remove_all_tracks(struct playlist_info *playlist)
645 int result;
647 if (playlist == NULL)
648 playlist = &current_playlist;
650 while (playlist->index > 0)
651 if ((result = remove_track_from_playlist(playlist, 0, true)) < 0)
652 return result;
654 while (playlist->amount > 1)
655 if ((result = remove_track_from_playlist(playlist, 1, true)) < 0)
656 return result;
658 if (playlist->amount == 1) {
659 playlist->indices[0] |= PLAYLIST_QUEUED;
662 return 0;
667 * Add track to playlist at specified position. There are five special
668 * positions that can be specified:
669 * PLAYLIST_PREPEND - Add track at beginning of playlist
670 * PLAYLIST_INSERT - Add track after current song. NOTE: If
671 * there are already inserted tracks then track
672 * is added to the end of the insertion list
673 * PLAYLIST_INSERT_FIRST - Add track immediately after current song, no
674 * matter what other tracks have been inserted
675 * PLAYLIST_INSERT_LAST - Add track to end of playlist
676 * PLAYLIST_INSERT_SHUFFLED - Add track at some random point between the
677 * current playing track and end of playlist
678 * PLAYLIST_REPLACE - Erase current playlist, Cue the current track
679 * and inster this track at the end.
681 static int add_track_to_playlist(struct playlist_info* playlist,
682 const char *filename, int position,
683 bool queue, int seek_pos)
685 int insert_position, orig_position;
686 unsigned long flags = PLAYLIST_INSERT_TYPE_INSERT;
687 int i;
689 insert_position = orig_position = position;
691 if (playlist->amount >= playlist->max_playlist_size)
693 display_buffer_full();
694 return -1;
697 switch (position)
699 case PLAYLIST_PREPEND:
700 position = insert_position = playlist->first_index;
701 break;
702 case PLAYLIST_INSERT:
703 /* if there are already inserted tracks then add track to end of
704 insertion list else add after current playing track */
705 if (playlist->last_insert_pos >= 0 &&
706 playlist->last_insert_pos < playlist->amount &&
707 (playlist->indices[playlist->last_insert_pos]&
708 PLAYLIST_INSERT_TYPE_MASK) == PLAYLIST_INSERT_TYPE_INSERT)
709 position = insert_position = playlist->last_insert_pos+1;
710 else if (playlist->amount > 0)
711 position = insert_position = playlist->index + 1;
712 else
713 position = insert_position = 0;
715 playlist->last_insert_pos = position;
716 break;
717 case PLAYLIST_INSERT_FIRST:
718 if (playlist->amount > 0)
719 position = insert_position = playlist->index + 1;
720 else
721 position = insert_position = 0;
723 playlist->last_insert_pos = position;
724 break;
725 case PLAYLIST_INSERT_LAST:
726 if (playlist->first_index > 0)
727 position = insert_position = playlist->first_index;
728 else
729 position = insert_position = playlist->amount;
731 playlist->last_insert_pos = position;
732 break;
733 case PLAYLIST_INSERT_SHUFFLED:
735 if (playlist->started)
737 int offset;
738 int n = playlist->amount -
739 rotate_index(playlist, playlist->index);
741 if (n > 0)
742 offset = rand() % n;
743 else
744 offset = 0;
746 position = playlist->index + offset + 1;
747 if (position >= playlist->amount)
748 position -= playlist->amount;
750 insert_position = position;
752 else
753 position = insert_position = (rand() % (playlist->amount+1));
754 break;
756 case PLAYLIST_REPLACE:
757 if (playlist_remove_all_tracks(playlist) < 0)
758 return -1;
760 playlist->last_insert_pos = position = insert_position = playlist->index + 1;
761 break;
764 if (queue)
765 flags |= PLAYLIST_QUEUED;
767 /* shift indices so that track can be added */
768 for (i=playlist->amount; i>insert_position; i--)
770 playlist->indices[i] = playlist->indices[i-1];
771 #ifdef HAVE_DIRCACHE
772 if (playlist->filenames)
773 playlist->filenames[i] = playlist->filenames[i-1];
774 #endif
777 /* update stored indices if needed */
778 if (playlist->amount > 0 && insert_position <= playlist->index &&
779 playlist->started)
780 playlist->index++;
782 if (playlist->amount > 0 && insert_position <= playlist->first_index &&
783 orig_position != PLAYLIST_PREPEND && playlist->started)
785 playlist->first_index++;
789 if (insert_position < playlist->last_insert_pos ||
790 (insert_position == playlist->last_insert_pos && position < 0))
791 playlist->last_insert_pos++;
793 if (seek_pos < 0 && playlist->control_fd >= 0)
795 int result = update_control(playlist,
796 (queue?PLAYLIST_COMMAND_QUEUE:PLAYLIST_COMMAND_ADD), position,
797 playlist->last_insert_pos, filename, NULL, &seek_pos);
799 if (result < 0)
800 return result;
803 playlist->indices[insert_position] = flags | seek_pos;
805 #ifdef HAVE_DIRCACHE
806 if (playlist->filenames)
807 playlist->filenames[insert_position] = NULL;
808 #endif
810 playlist->amount++;
811 playlist->num_inserted_tracks++;
813 return insert_position;
817 * Callback for playlist_directory_tracksearch to insert track into
818 * playlist.
820 static int directory_search_callback(char* filename, void* context)
822 struct directory_search_context* c =
823 (struct directory_search_context*) context;
824 int insert_pos;
826 insert_pos = add_track_to_playlist(c->playlist, filename, c->position,
827 c->queue, -1);
829 if (insert_pos < 0)
830 return -1;
832 (c->count)++;
834 /* Make sure tracks are inserted in correct order if user requests
835 INSERT_FIRST */
836 if (c->position == PLAYLIST_INSERT_FIRST || c->position >= 0)
837 c->position = insert_pos + 1;
839 if (((c->count)%PLAYLIST_DISPLAY_COUNT) == 0)
841 unsigned char* count_str;
843 if (c->queue)
844 count_str = ID2P(LANG_PLAYLIST_QUEUE_COUNT);
845 else
846 count_str = ID2P(LANG_PLAYLIST_INSERT_COUNT);
848 display_playlist_count(c->count, count_str, false);
850 if ((c->count) == PLAYLIST_DISPLAY_COUNT &&
851 (audio_status() & AUDIO_STATUS_PLAY) &&
852 c->playlist->started)
853 audio_flush_and_reload_tracks();
856 return 0;
860 * remove track at specified position
862 static int remove_track_from_playlist(struct playlist_info* playlist,
863 int position, bool write)
865 int i;
866 bool inserted;
868 if (playlist->amount <= 0)
869 return -1;
871 inserted = playlist->indices[position] & PLAYLIST_INSERT_TYPE_MASK;
873 /* shift indices now that track has been removed */
874 for (i=position; i<playlist->amount; i++)
876 playlist->indices[i] = playlist->indices[i+1];
877 #ifdef HAVE_DIRCACHE
878 if (playlist->filenames)
879 playlist->filenames[i] = playlist->filenames[i+1];
880 #endif
883 playlist->amount--;
885 if (inserted)
886 playlist->num_inserted_tracks--;
887 else
888 playlist->deleted = true;
890 /* update stored indices if needed */
891 if (position < playlist->index)
892 playlist->index--;
894 if (position < playlist->first_index)
896 playlist->first_index--;
899 if (position <= playlist->last_insert_pos)
900 playlist->last_insert_pos--;
902 if (write && playlist->control_fd >= 0)
904 int result = update_control(playlist, PLAYLIST_COMMAND_DELETE,
905 position, -1, NULL, NULL, NULL);
907 if (result < 0)
908 return result;
910 sync_control(playlist, false);
913 return 0;
917 * randomly rearrange the array of indices for the playlist. If start_current
918 * is true then update the index to the new index of the current playing track
920 static int randomise_playlist(struct playlist_info* playlist,
921 unsigned int seed, bool start_current,
922 bool write)
924 int count;
925 int candidate;
926 long store;
927 unsigned int current = playlist->indices[playlist->index];
929 /* seed 0 is used to identify sorted playlist for resume purposes */
930 if (seed == 0)
931 seed = 1;
933 /* seed with the given seed */
934 srand(seed);
936 /* randomise entire indices list */
937 for(count = playlist->amount - 1; count >= 0; count--)
939 /* the rand is from 0 to RAND_MAX, so adjust to our value range */
940 candidate = rand() % (count + 1);
942 /* now swap the values at the 'count' and 'candidate' positions */
943 store = playlist->indices[candidate];
944 playlist->indices[candidate] = playlist->indices[count];
945 playlist->indices[count] = store;
946 #ifdef HAVE_DIRCACHE
947 if (playlist->filenames)
949 store = (long)playlist->filenames[candidate];
950 playlist->filenames[candidate] = playlist->filenames[count];
951 playlist->filenames[count] = (struct dircache_entry *)store;
953 #endif
956 if (start_current)
957 find_and_set_playlist_index(playlist, current);
959 /* indices have been moved so last insert position is no longer valid */
960 playlist->last_insert_pos = -1;
962 playlist->seed = seed;
963 if (playlist->num_inserted_tracks > 0 || playlist->deleted)
964 playlist->shuffle_modified = true;
966 if (write)
968 update_control(playlist, PLAYLIST_COMMAND_SHUFFLE, seed,
969 playlist->first_index, NULL, NULL, NULL);
972 return 0;
976 * Sort the array of indices for the playlist. If start_current is true then
977 * set the index to the new index of the current song.
979 static int sort_playlist(struct playlist_info* playlist, bool start_current,
980 bool write)
982 unsigned int current = playlist->indices[playlist->index];
984 if (playlist->amount > 0)
985 qsort(playlist->indices, playlist->amount,
986 sizeof(playlist->indices[0]), compare);
988 #ifdef HAVE_DIRCACHE
989 /** We need to re-check the song names from disk because qsort can't
990 * sort two arrays at once :/
991 * FIXME: Please implement a better way to do this. */
992 memset(playlist->filenames, 0, playlist->max_playlist_size * sizeof(int));
993 queue_post(&playlist_queue, PLAYLIST_LOAD_POINTERS, 0);
994 #endif
996 if (start_current)
997 find_and_set_playlist_index(playlist, current);
999 /* indices have been moved so last insert position is no longer valid */
1000 playlist->last_insert_pos = -1;
1002 if (!playlist->num_inserted_tracks && !playlist->deleted)
1003 playlist->shuffle_modified = false;
1004 if (write && playlist->control_fd >= 0)
1006 update_control(playlist, PLAYLIST_COMMAND_UNSHUFFLE,
1007 playlist->first_index, -1, NULL, NULL, NULL);
1010 return 0;
1013 /* Calculate how many steps we have to really step when skipping entries
1014 * marked as bad.
1016 static int calculate_step_count(const struct playlist_info *playlist, int steps)
1018 int i, count, direction;
1019 int index;
1020 int stepped_count = 0;
1022 if (steps < 0)
1024 direction = -1;
1025 count = -steps;
1027 else
1029 direction = 1;
1030 count = steps;
1033 index = playlist->index;
1034 i = 0;
1035 do {
1036 /* Boundary check */
1037 if (index < 0)
1038 index += playlist->amount;
1039 if (index >= playlist->amount)
1040 index -= playlist->amount;
1042 /* Check if we found a bad entry. */
1043 if (playlist->indices[index] & PLAYLIST_SKIPPED)
1045 steps += direction;
1046 /* Are all entries bad? */
1047 if (stepped_count++ > playlist->amount)
1048 break ;
1050 else
1051 i++;
1053 index += direction;
1054 } while (i <= count);
1056 return steps;
1059 /* Marks the index of the track to be skipped that is "steps" away from
1060 * current playing track.
1062 void playlist_skip_entry(struct playlist_info *playlist, int steps)
1064 int index;
1066 if (playlist == NULL)
1067 playlist = &current_playlist;
1069 /* need to account for already skipped tracks */
1070 steps = calculate_step_count(playlist, steps);
1072 index = playlist->index + steps;
1073 if (index < 0)
1074 index += playlist->amount;
1075 else if (index >= playlist->amount)
1076 index -= playlist->amount;
1078 playlist->indices[index] |= PLAYLIST_SKIPPED;
1082 * returns the index of the track that is "steps" away from current playing
1083 * track.
1085 static int get_next_index(const struct playlist_info* playlist, int steps,
1086 int repeat_mode)
1088 int current_index = playlist->index;
1089 int next_index = -1;
1091 if (playlist->amount <= 0)
1092 return -1;
1094 if (repeat_mode == -1)
1095 repeat_mode = global_settings.repeat_mode;
1097 if (repeat_mode == REPEAT_SHUFFLE && playlist->amount <= 1)
1098 repeat_mode = REPEAT_ALL;
1100 steps = calculate_step_count(playlist, steps);
1101 switch (repeat_mode)
1103 case REPEAT_SHUFFLE:
1104 /* Treat repeat shuffle just like repeat off. At end of playlist,
1105 play will be resumed in playlist_next() */
1106 case REPEAT_OFF:
1108 current_index = rotate_index(playlist, current_index);
1109 next_index = current_index+steps;
1110 if ((next_index < 0) || (next_index >= playlist->amount))
1111 next_index = -1;
1112 else
1113 next_index = (next_index+playlist->first_index) %
1114 playlist->amount;
1116 break;
1119 case REPEAT_ONE:
1120 #ifdef AB_REPEAT_ENABLE
1121 case REPEAT_AB:
1122 #endif
1123 next_index = current_index;
1124 break;
1126 case REPEAT_ALL:
1127 default:
1129 next_index = (current_index+steps) % playlist->amount;
1130 while (next_index < 0)
1131 next_index += playlist->amount;
1133 if (steps >= playlist->amount)
1135 int i, index;
1137 index = next_index;
1138 next_index = -1;
1140 /* second time around so skip the queued files */
1141 for (i=0; i<playlist->amount; i++)
1143 if (playlist->indices[index] & PLAYLIST_QUEUE_MASK)
1144 index = (index+1) % playlist->amount;
1145 else
1147 next_index = index;
1148 break;
1152 break;
1156 /* No luck if the whole playlist was bad. */
1157 if (playlist->indices[next_index] & PLAYLIST_SKIPPED)
1158 return -1;
1160 return next_index;
1164 * Search for the seek track and set appropriate indices. Used after shuffle
1165 * to make sure the current index is still pointing to correct track.
1167 static void find_and_set_playlist_index(struct playlist_info* playlist,
1168 unsigned int seek)
1170 int i;
1172 /* Set the index to the current song */
1173 for (i=0; i<playlist->amount; i++)
1175 if (playlist->indices[i] == seek)
1177 playlist->index = playlist->first_index = i;
1179 break;
1185 * used to sort track indices. Sort order is as follows:
1186 * 1. Prepended tracks (in prepend order)
1187 * 2. Playlist/directory tracks (in playlist order)
1188 * 3. Inserted/Appended tracks (in insert order)
1190 static int compare(const void* p1, const void* p2)
1192 unsigned long* e1 = (unsigned long*) p1;
1193 unsigned long* e2 = (unsigned long*) p2;
1194 unsigned long flags1 = *e1 & PLAYLIST_INSERT_TYPE_MASK;
1195 unsigned long flags2 = *e2 & PLAYLIST_INSERT_TYPE_MASK;
1197 if (flags1 == flags2)
1198 return (*e1 & PLAYLIST_SEEK_MASK) - (*e2 & PLAYLIST_SEEK_MASK);
1199 else if (flags1 == PLAYLIST_INSERT_TYPE_PREPEND ||
1200 flags2 == PLAYLIST_INSERT_TYPE_APPEND)
1201 return -1;
1202 else if (flags1 == PLAYLIST_INSERT_TYPE_APPEND ||
1203 flags2 == PLAYLIST_INSERT_TYPE_PREPEND)
1204 return 1;
1205 else if (flags1 && flags2)
1206 return (*e1 & PLAYLIST_SEEK_MASK) - (*e2 & PLAYLIST_SEEK_MASK);
1207 else
1208 return *e1 - *e2;
1211 #ifdef HAVE_DIRCACHE
1213 * Thread to update filename pointers to dircache on background
1214 * without affecting playlist load up performance. This thread also flushes
1215 * any pending control commands when the disk spins up.
1217 static bool playlist_flush_callback(void)
1219 struct playlist_info *playlist;
1220 playlist = &current_playlist;
1221 if (playlist->control_fd >= 0)
1223 if (playlist->num_cached > 0)
1225 mutex_lock(&playlist->control_mutex);
1226 flush_cached_control(playlist);
1227 mutex_unlock(&playlist->control_mutex);
1229 sync_control(playlist, true);
1231 return true;
1234 static void playlist_thread(void)
1236 struct queue_event ev;
1237 bool dirty_pointers = false;
1238 static char tmp[MAX_PATH+1];
1240 struct playlist_info *playlist;
1241 int index;
1242 int seek;
1243 bool control_file;
1245 int sleep_time = 5;
1247 #ifdef HAVE_DISK_STORAGE
1248 if (global_settings.disk_spindown > 1 &&
1249 global_settings.disk_spindown <= 5)
1250 sleep_time = global_settings.disk_spindown - 1;
1251 #endif
1253 while (1)
1255 queue_wait_w_tmo(&playlist_queue, &ev, HZ*sleep_time);
1257 switch (ev.id)
1259 case PLAYLIST_LOAD_POINTERS:
1260 dirty_pointers = true;
1261 break ;
1263 /* Start the background scanning after either the disk spindown
1264 timeout or 5s, whichever is less */
1265 case SYS_TIMEOUT:
1266 playlist = &current_playlist;
1267 if (playlist->control_fd >= 0)
1269 if (playlist->num_cached > 0)
1270 register_storage_idle_func(playlist_flush_callback);
1273 if (!dirty_pointers)
1274 break ;
1276 if (!dircache_is_enabled() || !playlist->filenames
1277 || playlist->amount <= 0)
1278 break ;
1280 #ifdef HAVE_ADJUSTABLE_CPU_FREQ
1281 cpu_boost(true);
1282 #endif
1283 for (index = 0; index < playlist->amount
1284 && queue_empty(&playlist_queue); index++)
1286 /* Process only pointers that are not already loaded. */
1287 if (playlist->filenames[index])
1288 continue ;
1290 control_file = playlist->indices[index] & PLAYLIST_INSERT_TYPE_MASK;
1291 seek = playlist->indices[index] & PLAYLIST_SEEK_MASK;
1293 /* Load the filename from playlist file. */
1294 if (get_filename(playlist, index, seek, control_file, tmp,
1295 sizeof(tmp)) < 0)
1296 break ;
1298 /* Set the dircache entry pointer. */
1299 playlist->filenames[index] = dircache_get_entry_ptr(tmp);
1301 /* And be on background so user doesn't notice any delays. */
1302 yield();
1305 #ifdef HAVE_ADJUSTABLE_CPU_FREQ
1306 cpu_boost(false);
1307 #endif
1308 dirty_pointers = false;
1309 break ;
1311 #ifndef SIMULATOR
1312 case SYS_USB_CONNECTED:
1313 usb_acknowledge(SYS_USB_CONNECTED_ACK);
1314 usb_wait_for_disconnect(&playlist_queue);
1315 break ;
1316 #endif
1320 #endif
1323 * gets pathname for track at seek index
1325 static int get_filename(struct playlist_info* playlist, int index, int seek,
1326 bool control_file, char *buf, int buf_length)
1328 int fd;
1329 int max = -1;
1330 char tmp_buf[MAX_PATH+1];
1331 char dir_buf[MAX_PATH+1];
1332 bool utf8 = playlist->utf8;
1334 if (buf_length > MAX_PATH+1)
1335 buf_length = MAX_PATH+1;
1337 #ifdef HAVE_DIRCACHE
1338 if (dircache_is_enabled() && playlist->filenames)
1340 if (playlist->filenames[index] != NULL)
1342 dircache_copy_path(playlist->filenames[index], tmp_buf, sizeof(tmp_buf)-1);
1343 max = strlen(tmp_buf) + 1;
1346 #else
1347 (void)index;
1348 #endif
1350 if (playlist->in_ram && !control_file && max < 0)
1352 strncpy(tmp_buf, &playlist->buffer[seek], sizeof(tmp_buf));
1353 tmp_buf[MAX_PATH] = '\0';
1354 max = strlen(tmp_buf) + 1;
1356 else if (max < 0)
1358 mutex_lock(&playlist->control_mutex);
1360 if (control_file)
1362 fd = playlist->control_fd;
1363 utf8 = true;
1365 else
1367 if(-1 == playlist->fd)
1368 playlist->fd = open(playlist->filename, O_RDONLY);
1370 fd = playlist->fd;
1373 if(-1 != fd)
1376 if (lseek(fd, seek, SEEK_SET) != seek)
1377 max = -1;
1378 else
1380 max = read(fd, tmp_buf, MIN((size_t) buf_length, sizeof(tmp_buf)));
1382 if ((max > 0) && !utf8)
1384 /* Use dir_buf as a temporary buffer. Note that dir_buf must
1385 * be as large as tmp_buf.
1387 max = convert_m3u(tmp_buf, max, sizeof(tmp_buf), dir_buf);
1392 mutex_unlock(&playlist->control_mutex);
1394 if (max < 0)
1396 if (control_file)
1397 splash(HZ*2, ID2P(LANG_PLAYLIST_CONTROL_ACCESS_ERROR));
1398 else
1399 splash(HZ*2, ID2P(LANG_PLAYLIST_ACCESS_ERROR));
1401 return max;
1405 strncpy(dir_buf, playlist->filename, playlist->dirlen-1);
1406 dir_buf[playlist->dirlen-1] = 0;
1408 return (format_track_path(buf, tmp_buf, buf_length, max, dir_buf));
1411 static int get_next_directory(char *dir){
1412 return get_next_dir(dir,true,false);
1415 static int get_previous_directory(char *dir){
1416 return get_next_dir(dir,false,false);
1420 * search through all the directories (starting with the current) to find
1421 * one that has tracks to play
1423 static int get_next_dir(char *dir, bool is_forward, bool recursion)
1425 struct playlist_info* playlist = &current_playlist;
1426 int result = -1;
1427 char *start_dir = NULL;
1428 bool exit = false;
1429 int i;
1430 struct tree_context* tc = tree_get_context();
1431 int saved_dirfilter = *(tc->dirfilter);
1433 /* process random folder advance */
1434 if (global_settings.next_folder == FOLDER_ADVANCE_RANDOM)
1436 int fd = open(ROCKBOX_DIR "/folder_advance_list.dat", O_RDONLY);
1437 if (fd >= 0)
1439 char buffer[MAX_PATH];
1440 int folder_count = 0;
1441 srand(current_tick);
1442 *(tc->dirfilter) = SHOW_MUSIC;
1443 tc->sort_dir = global_settings.sort_dir;
1444 read(fd,&folder_count,sizeof(int));
1445 if (!folder_count)
1446 exit = true;
1447 while (!exit)
1449 i = rand()%folder_count;
1450 lseek(fd,sizeof(int) + (MAX_PATH*i),SEEK_SET);
1451 read(fd,buffer,MAX_PATH);
1452 if (check_subdir_for_music(buffer, "", false) ==0)
1453 exit = true;
1455 if (folder_count)
1456 strcpy(dir,buffer);
1457 close(fd);
1458 *(tc->dirfilter) = saved_dirfilter;
1459 tc->sort_dir = global_settings.sort_dir;
1460 reload_directory();
1461 return 0;
1465 /* not random folder advance (or random folder advance unavailable) */
1466 if (recursion)
1468 /* start with root */
1469 dir[0] = '\0';
1471 else
1473 /* start with current directory */
1474 strncpy(dir, playlist->filename, playlist->dirlen-1);
1475 dir[playlist->dirlen-1] = '\0';
1478 /* use the tree browser dircache to load files */
1479 *(tc->dirfilter) = SHOW_ALL;
1481 /* set up sorting/direction */
1482 tc->sort_dir = global_settings.sort_dir;
1483 if (!is_forward)
1485 static const char sortpairs[] =
1487 [SORT_ALPHA] = SORT_ALPHA_REVERSED,
1488 [SORT_DATE] = SORT_DATE_REVERSED,
1489 [SORT_TYPE] = SORT_TYPE_REVERSED,
1490 [SORT_ALPHA_REVERSED] = SORT_ALPHA,
1491 [SORT_DATE_REVERSED] = SORT_DATE,
1492 [SORT_TYPE_REVERSED] = SORT_TYPE,
1495 if ((unsigned)tc->sort_dir < sizeof(sortpairs))
1496 tc->sort_dir = sortpairs[tc->sort_dir];
1499 while (!exit)
1501 struct entry *files;
1502 int num_files = 0;
1503 int i;
1505 if (ft_load(tc, (dir[0]=='\0')?"/":dir) < 0)
1507 exit = true;
1508 result = -1;
1509 break;
1512 files = (struct entry*) tc->dircache;
1513 num_files = tc->filesindir;
1515 for (i=0; i<num_files; i++)
1517 /* user abort */
1518 if (action_userabort(TIMEOUT_NOBLOCK))
1520 result = -1;
1521 exit = true;
1522 break;
1525 if (files[i].attr & ATTR_DIRECTORY)
1527 if (!start_dir)
1529 result = check_subdir_for_music(dir, files[i].name, true);
1530 if (result != -1)
1532 exit = true;
1533 break;
1536 else if (!strcmp(start_dir, files[i].name))
1537 start_dir = NULL;
1541 if (!exit)
1543 /* move down to parent directory. current directory name is
1544 stored as the starting point for the search in parent */
1545 start_dir = strrchr(dir, '/');
1546 if (start_dir)
1548 *start_dir = '\0';
1549 start_dir++;
1551 else
1552 break;
1556 /* restore dirfilter */
1557 *(tc->dirfilter) = saved_dirfilter;
1558 tc->sort_dir = global_settings.sort_dir;
1560 /* special case if nothing found: try start searching again from root */
1561 if (result == -1 && !recursion){
1562 result = get_next_dir(dir, is_forward, true);
1565 return result;
1569 * Checks if there are any music files in the dir or any of its
1570 * subdirectories. May be called recursively.
1572 static int check_subdir_for_music(char *dir, const char *subdir, bool recurse)
1574 int result = -1;
1575 int dirlen = strlen(dir);
1576 int num_files = 0;
1577 int i;
1578 struct entry *files;
1579 bool has_music = false;
1580 bool has_subdir = false;
1581 struct tree_context* tc = tree_get_context();
1583 snprintf(dir+dirlen, MAX_PATH-dirlen, "/%s", subdir);
1585 if (ft_load(tc, dir) < 0)
1587 return -2;
1590 files = (struct entry*) tc->dircache;
1591 num_files = tc->filesindir;
1593 for (i=0; i<num_files; i++)
1595 if (files[i].attr & ATTR_DIRECTORY)
1596 has_subdir = true;
1597 else if ((files[i].attr & FILE_ATTR_MASK) == FILE_ATTR_AUDIO)
1599 has_music = true;
1600 break;
1604 if (has_music)
1605 return 0;
1607 if (has_subdir && recurse)
1609 for (i=0; i<num_files; i++)
1611 if (action_userabort(TIMEOUT_NOBLOCK))
1613 result = -2;
1614 break;
1617 if (files[i].attr & ATTR_DIRECTORY)
1619 result = check_subdir_for_music(dir, files[i].name, true);
1620 if (!result)
1621 break;
1626 if (result < 0)
1628 if (dirlen)
1630 dir[dirlen] = '\0';
1632 else
1634 strcpy(dir, "/");
1637 /* we now need to reload our current directory */
1638 if(ft_load(tc, dir) < 0)
1639 splash(HZ*2, ID2P(LANG_PLAYLIST_DIRECTORY_ACCESS_ERROR));
1641 return result;
1645 * Returns absolute path of track
1647 static int format_track_path(char *dest, char *src, int buf_length, int max,
1648 const char *dir)
1650 int i = 0;
1651 int j;
1652 char *temp_ptr;
1654 /* Zero-terminate the file name */
1655 while((src[i] != '\n') &&
1656 (src[i] != '\r') &&
1657 (i < max))
1658 i++;
1660 /* Now work back killing white space */
1661 while((src[i-1] == ' ') ||
1662 (src[i-1] == '\t'))
1663 i--;
1665 src[i]=0;
1667 /* replace backslashes with forward slashes */
1668 for ( j=0; j<i; j++ )
1669 if ( src[j] == '\\' )
1670 src[j] = '/';
1672 if('/' == src[0])
1674 strncpy(dest, src, buf_length);
1676 else
1678 /* handle dos style drive letter */
1679 if (':' == src[1])
1680 strncpy(dest, &src[2], buf_length);
1681 else if (!strncmp(src, "../", 3))
1683 /* handle relative paths */
1684 i=3;
1685 while(!strncmp(&src[i], "../", 3))
1686 i += 3;
1687 for (j=0; j<i/3; j++) {
1688 temp_ptr = strrchr(dir, '/');
1689 if (temp_ptr)
1690 *temp_ptr = '\0';
1691 else
1692 break;
1694 snprintf(dest, buf_length, "%s/%s", dir, &src[i]);
1696 else if ( '.' == src[0] && '/' == src[1] ) {
1697 snprintf(dest, buf_length, "%s/%s", dir, &src[2]);
1699 else {
1700 snprintf(dest, buf_length, "%s/%s", dir, src);
1704 return 0;
1708 * Display splash message showing progress of playlist/directory insertion or
1709 * save.
1711 static void display_playlist_count(int count, const unsigned char *fmt,
1712 bool final)
1714 static long talked_tick = 0;
1715 long id = P2ID(fmt);
1716 if(global_settings.talk_menu && id>=0)
1718 if(final || (count && (talked_tick == 0
1719 || TIME_AFTER(current_tick, talked_tick+5*HZ))))
1721 talked_tick = current_tick;
1722 talk_number(count, false);
1723 talk_id(id, true);
1726 fmt = P2STR(fmt);
1728 splashf(0, fmt, count, str(LANG_OFF_ABORT));
1732 * Display buffer full message
1734 static void display_buffer_full(void)
1736 splash(HZ*2, ID2P(LANG_PLAYLIST_BUFFER_FULL));
1740 * Flush any cached control commands to disk. Called when playlist is being
1741 * modified. Returns 0 on success and -1 on failure.
1743 static int flush_cached_control(struct playlist_info* playlist)
1745 int result = 0;
1746 int i;
1748 if (!playlist->num_cached)
1749 return 0;
1751 lseek(playlist->control_fd, 0, SEEK_END);
1753 for (i=0; i<playlist->num_cached; i++)
1755 struct playlist_control_cache* cache =
1756 &(playlist->control_cache[i]);
1758 switch (cache->command)
1760 case PLAYLIST_COMMAND_PLAYLIST:
1761 result = fdprintf(playlist->control_fd, "P:%d:%s:%s\n",
1762 cache->i1, cache->s1, cache->s2);
1763 break;
1764 case PLAYLIST_COMMAND_ADD:
1765 case PLAYLIST_COMMAND_QUEUE:
1766 result = fdprintf(playlist->control_fd, "%c:%d:%d:",
1767 (cache->command == PLAYLIST_COMMAND_ADD)?'A':'Q',
1768 cache->i1, cache->i2);
1769 if (result > 0)
1771 /* save the position in file where name is written */
1772 int* seek_pos = (int *)cache->data;
1773 *seek_pos = lseek(playlist->control_fd, 0, SEEK_CUR);
1774 result = fdprintf(playlist->control_fd, "%s\n",
1775 cache->s1);
1777 break;
1778 case PLAYLIST_COMMAND_DELETE:
1779 result = fdprintf(playlist->control_fd, "D:%d\n", cache->i1);
1780 break;
1781 case PLAYLIST_COMMAND_SHUFFLE:
1782 result = fdprintf(playlist->control_fd, "S:%d:%d\n",
1783 cache->i1, cache->i2);
1784 break;
1785 case PLAYLIST_COMMAND_UNSHUFFLE:
1786 result = fdprintf(playlist->control_fd, "U:%d\n", cache->i1);
1787 break;
1788 case PLAYLIST_COMMAND_RESET:
1789 result = fdprintf(playlist->control_fd, "R\n");
1790 break;
1791 default:
1792 break;
1795 if (result <= 0)
1796 break;
1799 if (result > 0)
1801 playlist->num_cached = 0;
1802 playlist->pending_control_sync = true;
1804 result = 0;
1806 else
1808 result = -1;
1809 splash(HZ*2, ID2P(LANG_PLAYLIST_CONTROL_UPDATE_ERROR));
1812 return result;
1816 * Update control data with new command. Depending on the command, it may be
1817 * cached or flushed to disk.
1819 static int update_control(struct playlist_info* playlist,
1820 enum playlist_command command, int i1, int i2,
1821 const char* s1, const char* s2, void* data)
1823 int result = 0;
1824 struct playlist_control_cache* cache;
1825 bool flush = false;
1827 mutex_lock(&playlist->control_mutex);
1829 cache = &(playlist->control_cache[playlist->num_cached++]);
1831 cache->command = command;
1832 cache->i1 = i1;
1833 cache->i2 = i2;
1834 cache->s1 = s1;
1835 cache->s2 = s2;
1836 cache->data = data;
1838 switch (command)
1840 case PLAYLIST_COMMAND_PLAYLIST:
1841 case PLAYLIST_COMMAND_ADD:
1842 case PLAYLIST_COMMAND_QUEUE:
1843 #ifndef HAVE_DIRCACHE
1844 case PLAYLIST_COMMAND_DELETE:
1845 case PLAYLIST_COMMAND_RESET:
1846 #endif
1847 flush = true;
1848 break;
1849 case PLAYLIST_COMMAND_SHUFFLE:
1850 case PLAYLIST_COMMAND_UNSHUFFLE:
1851 default:
1852 /* only flush when needed */
1853 break;
1856 if (flush || playlist->num_cached == PLAYLIST_MAX_CACHE)
1857 result = flush_cached_control(playlist);
1859 mutex_unlock(&playlist->control_mutex);
1861 return result;
1865 * sync control file to disk
1867 static void sync_control(struct playlist_info* playlist, bool force)
1869 #ifdef HAVE_DIRCACHE
1870 if (playlist->started && force)
1871 #else
1872 (void) force;
1874 if (playlist->started)
1875 #endif
1877 if (playlist->pending_control_sync)
1879 mutex_lock(&playlist->control_mutex);
1880 fsync(playlist->control_fd);
1881 playlist->pending_control_sync = false;
1882 mutex_unlock(&playlist->control_mutex);
1888 * Rotate indices such that first_index is index 0
1890 static int rotate_index(const struct playlist_info* playlist, int index)
1892 index -= playlist->first_index;
1893 if (index < 0)
1894 index += playlist->amount;
1896 return index;
1900 * Initialize playlist entries at startup
1902 void playlist_init(void)
1904 struct playlist_info* playlist = &current_playlist;
1906 playlist->current = true;
1907 strncpy(playlist->control_filename, PLAYLIST_CONTROL_FILE,
1908 sizeof(playlist->control_filename));
1909 playlist->fd = -1;
1910 playlist->control_fd = -1;
1911 playlist->max_playlist_size = global_settings.max_files_in_playlist;
1912 playlist->indices = buffer_alloc(
1913 playlist->max_playlist_size * sizeof(int));
1914 playlist->buffer_size =
1915 AVERAGE_FILENAME_LENGTH * global_settings.max_files_in_dir;
1916 playlist->buffer = buffer_alloc(playlist->buffer_size);
1917 mutex_init(&playlist->control_mutex);
1918 empty_playlist(playlist, true);
1920 #ifdef HAVE_DIRCACHE
1921 playlist->filenames = buffer_alloc(
1922 playlist->max_playlist_size * sizeof(int));
1923 memset(playlist->filenames, 0,
1924 playlist->max_playlist_size * sizeof(int));
1925 create_thread(playlist_thread, playlist_stack, sizeof(playlist_stack),
1926 0, playlist_thread_name IF_PRIO(, PRIORITY_BACKGROUND)
1927 IF_COP(, CPU));
1928 queue_init(&playlist_queue, true);
1929 #endif
1933 * Clean playlist at shutdown
1935 void playlist_shutdown(void)
1937 struct playlist_info* playlist = &current_playlist;
1939 if (playlist->control_fd >= 0)
1941 mutex_lock(&playlist->control_mutex);
1943 if (playlist->num_cached > 0)
1944 flush_cached_control(playlist);
1946 close(playlist->control_fd);
1948 mutex_unlock(&playlist->control_mutex);
1953 * Create new playlist
1955 int playlist_create(const char *dir, const char *file)
1957 struct playlist_info* playlist = &current_playlist;
1959 new_playlist(playlist, dir, file);
1961 if (file)
1962 /* load the playlist file */
1963 add_indices_to_playlist(playlist, NULL, 0);
1965 return 0;
1968 #define PLAYLIST_COMMAND_SIZE (MAX_PATH+12)
1971 * Restore the playlist state based on control file commands. Called to
1972 * resume playback after shutdown.
1974 int playlist_resume(void)
1976 struct playlist_info* playlist = &current_playlist;
1977 char *buffer;
1978 size_t buflen;
1979 int nread;
1980 int total_read = 0;
1981 int control_file_size = 0;
1982 bool first = true;
1983 bool sorted = true;
1985 /* use mp3 buffer for maximum load speed */
1986 #if CONFIG_CODEC != SWCODEC
1987 talk_buffer_steal(); /* we use the mp3 buffer, need to tell */
1988 buflen = (audiobufend - audiobuf);
1989 buffer = (char *)audiobuf;
1990 #else
1991 buffer = (char *)audio_get_buffer(false, &buflen);
1992 #endif
1994 empty_playlist(playlist, true);
1996 splash(0, ID2P(LANG_WAIT));
1997 playlist->control_fd = open(playlist->control_filename, O_RDWR);
1998 if (playlist->control_fd < 0)
2000 splash(HZ*2, ID2P(LANG_PLAYLIST_CONTROL_ACCESS_ERROR));
2001 return -1;
2003 playlist->control_created = true;
2005 control_file_size = filesize(playlist->control_fd);
2006 if (control_file_size <= 0)
2008 splash(HZ*2, ID2P(LANG_PLAYLIST_CONTROL_ACCESS_ERROR));
2009 return -1;
2012 /* read a small amount first to get the header */
2013 nread = read(playlist->control_fd, buffer,
2014 PLAYLIST_COMMAND_SIZE<buflen?PLAYLIST_COMMAND_SIZE:buflen);
2015 if(nread <= 0)
2017 splash(HZ*2, ID2P(LANG_PLAYLIST_CONTROL_ACCESS_ERROR));
2018 return -1;
2021 playlist->started = true;
2023 while (1)
2025 int result = 0;
2026 int count;
2027 enum playlist_command current_command = PLAYLIST_COMMAND_COMMENT;
2028 int last_newline = 0;
2029 int str_count = -1;
2030 bool newline = true;
2031 bool exit_loop = false;
2032 char *p = buffer;
2033 char *str1 = NULL;
2034 char *str2 = NULL;
2035 char *str3 = NULL;
2036 unsigned long last_tick = current_tick;
2037 bool useraborted = false;
2039 for(count=0; count<nread && !exit_loop && !useraborted; count++,p++)
2041 /* So a splash while we are loading. */
2042 if (TIME_AFTER(current_tick, last_tick + HZ/4))
2044 splashf(0, str(LANG_LOADING_PERCENT),
2045 (total_read+count)*100/control_file_size,
2046 str(LANG_OFF_ABORT));
2047 if (action_userabort(TIMEOUT_NOBLOCK))
2049 useraborted = true;
2050 break;
2052 last_tick = current_tick;
2055 /* Are we on a new line? */
2056 if((*p == '\n') || (*p == '\r'))
2058 *p = '\0';
2060 /* save last_newline in case we need to load more data */
2061 last_newline = count;
2063 switch (current_command)
2065 case PLAYLIST_COMMAND_PLAYLIST:
2067 /* str1=version str2=dir str3=file */
2068 int version;
2070 if (!str1)
2072 result = -1;
2073 exit_loop = true;
2074 break;
2077 if (!str2)
2078 str2 = "";
2080 if (!str3)
2081 str3 = "";
2083 version = atoi(str1);
2085 if (version != PLAYLIST_CONTROL_FILE_VERSION)
2086 return -1;
2088 update_playlist_filename(playlist, str2, str3);
2090 if (str3[0] != '\0')
2092 /* NOTE: add_indices_to_playlist() overwrites the
2093 audiobuf so we need to reload control file
2094 data */
2095 add_indices_to_playlist(playlist, NULL, 0);
2097 else if (str2[0] != '\0')
2099 playlist->in_ram = true;
2100 resume_directory(str2);
2103 /* load the rest of the data */
2104 first = false;
2105 exit_loop = true;
2107 break;
2109 case PLAYLIST_COMMAND_ADD:
2110 case PLAYLIST_COMMAND_QUEUE:
2112 /* str1=position str2=last_position str3=file */
2113 int position, last_position;
2114 bool queue;
2116 if (!str1 || !str2 || !str3)
2118 result = -1;
2119 exit_loop = true;
2120 break;
2123 position = atoi(str1);
2124 last_position = atoi(str2);
2126 queue = (current_command == PLAYLIST_COMMAND_ADD)?
2127 false:true;
2129 /* seek position is based on str3's position in
2130 buffer */
2131 if (add_track_to_playlist(playlist, str3, position,
2132 queue, total_read+(str3-buffer)) < 0)
2133 return -1;
2135 playlist->last_insert_pos = last_position;
2137 break;
2139 case PLAYLIST_COMMAND_DELETE:
2141 /* str1=position */
2142 int position;
2144 if (!str1)
2146 result = -1;
2147 exit_loop = true;
2148 break;
2151 position = atoi(str1);
2153 if (remove_track_from_playlist(playlist, position,
2154 false) < 0)
2155 return -1;
2157 break;
2159 case PLAYLIST_COMMAND_SHUFFLE:
2161 /* str1=seed str2=first_index */
2162 int seed;
2164 if (!str1 || !str2)
2166 result = -1;
2167 exit_loop = true;
2168 break;
2171 if (!sorted)
2173 /* Always sort list before shuffling */
2174 sort_playlist(playlist, false, false);
2177 seed = atoi(str1);
2178 playlist->first_index = atoi(str2);
2180 if (randomise_playlist(playlist, seed, false,
2181 false) < 0)
2182 return -1;
2183 sorted = false;
2184 break;
2186 case PLAYLIST_COMMAND_UNSHUFFLE:
2188 /* str1=first_index */
2189 if (!str1)
2191 result = -1;
2192 exit_loop = true;
2193 break;
2196 playlist->first_index = atoi(str1);
2198 if (sort_playlist(playlist, false, false) < 0)
2199 return -1;
2201 sorted = true;
2202 break;
2204 case PLAYLIST_COMMAND_RESET:
2206 playlist->last_insert_pos = -1;
2207 break;
2209 case PLAYLIST_COMMAND_COMMENT:
2210 default:
2211 break;
2214 newline = true;
2216 /* to ignore any extra newlines */
2217 current_command = PLAYLIST_COMMAND_COMMENT;
2219 else if(newline)
2221 newline = false;
2223 /* first non-comment line must always specify playlist */
2224 if (first && *p != 'P' && *p != '#')
2226 result = -1;
2227 exit_loop = true;
2228 break;
2231 switch (*p)
2233 case 'P':
2234 /* playlist can only be specified once */
2235 if (!first)
2237 result = -1;
2238 exit_loop = true;
2239 break;
2242 current_command = PLAYLIST_COMMAND_PLAYLIST;
2243 break;
2244 case 'A':
2245 current_command = PLAYLIST_COMMAND_ADD;
2246 break;
2247 case 'Q':
2248 current_command = PLAYLIST_COMMAND_QUEUE;
2249 break;
2250 case 'D':
2251 current_command = PLAYLIST_COMMAND_DELETE;
2252 break;
2253 case 'S':
2254 current_command = PLAYLIST_COMMAND_SHUFFLE;
2255 break;
2256 case 'U':
2257 current_command = PLAYLIST_COMMAND_UNSHUFFLE;
2258 break;
2259 case 'R':
2260 current_command = PLAYLIST_COMMAND_RESET;
2261 break;
2262 case '#':
2263 current_command = PLAYLIST_COMMAND_COMMENT;
2264 break;
2265 default:
2266 result = -1;
2267 exit_loop = true;
2268 break;
2271 str_count = -1;
2272 str1 = NULL;
2273 str2 = NULL;
2274 str3 = NULL;
2276 else if(current_command != PLAYLIST_COMMAND_COMMENT)
2278 /* all control file strings are separated with a colon.
2279 Replace the colon with 0 to get proper strings that can be
2280 used by commands above */
2281 if (*p == ':')
2283 *p = '\0';
2284 str_count++;
2286 if ((count+1) < nread)
2288 switch (str_count)
2290 case 0:
2291 str1 = p+1;
2292 break;
2293 case 1:
2294 str2 = p+1;
2295 break;
2296 case 2:
2297 str3 = p+1;
2298 break;
2299 default:
2300 /* allow last string to contain colons */
2301 *p = ':';
2302 break;
2309 if (result < 0)
2311 splash(HZ*2, ID2P(LANG_PLAYLIST_CONTROL_INVALID));
2312 return result;
2315 if (useraborted)
2317 splash(HZ*2, ID2P(LANG_CANCEL));
2318 return -1;
2320 if (!newline || (exit_loop && count<nread))
2322 if ((total_read + count) >= control_file_size)
2324 /* no newline at end of control file */
2325 splash(HZ*2, ID2P(LANG_PLAYLIST_CONTROL_INVALID));
2326 return -1;
2329 /* We didn't end on a newline or we exited loop prematurely.
2330 Either way, re-read the remainder. */
2331 count = last_newline;
2332 lseek(playlist->control_fd, total_read+count, SEEK_SET);
2335 total_read += count;
2337 if (first)
2338 /* still looking for header */
2339 nread = read(playlist->control_fd, buffer,
2340 PLAYLIST_COMMAND_SIZE<buflen?PLAYLIST_COMMAND_SIZE:buflen);
2341 else
2342 nread = read(playlist->control_fd, buffer, buflen);
2344 /* Terminate on EOF */
2345 if(nread <= 0)
2347 break;
2351 #ifdef HAVE_DIRCACHE
2352 queue_post(&playlist_queue, PLAYLIST_LOAD_POINTERS, 0);
2353 #endif
2355 return 0;
2359 * Add track to in_ram playlist. Used when playing directories.
2361 int playlist_add(const char *filename)
2363 struct playlist_info* playlist = &current_playlist;
2364 int len = strlen(filename);
2366 if((len+1 > playlist->buffer_size - playlist->buffer_end_pos) ||
2367 (playlist->amount >= playlist->max_playlist_size))
2369 display_buffer_full();
2370 return -1;
2373 playlist->indices[playlist->amount] = playlist->buffer_end_pos;
2374 #ifdef HAVE_DIRCACHE
2375 playlist->filenames[playlist->amount] = NULL;
2376 #endif
2377 playlist->amount++;
2379 strcpy(&playlist->buffer[playlist->buffer_end_pos], filename);
2380 playlist->buffer_end_pos += len;
2381 playlist->buffer[playlist->buffer_end_pos++] = '\0';
2383 return 0;
2386 /* shuffle newly created playlist using random seed. */
2387 int playlist_shuffle(int random_seed, int start_index)
2389 struct playlist_info* playlist = &current_playlist;
2391 unsigned int seek_pos = 0;
2392 bool start_current = false;
2394 if (start_index >= 0 && global_settings.play_selected)
2396 /* store the seek position before the shuffle */
2397 seek_pos = playlist->indices[start_index];
2398 playlist->index = playlist->first_index = start_index;
2399 start_current = true;
2402 randomise_playlist(playlist, random_seed, start_current, true);
2404 return playlist->index;
2407 /* start playing current playlist at specified index/offset */
2408 void playlist_start(int start_index, int offset)
2410 struct playlist_info* playlist = &current_playlist;
2412 /* Cancel FM radio selection as previous music. For cases where we start
2413 playback without going to the WPS, such as playlist insert.. or
2414 playlist catalog. */
2415 previous_music_is_wps();
2417 playlist->index = start_index;
2419 #if CONFIG_CODEC != SWCODEC
2420 talk_buffer_steal(); /* will use the mp3 buffer */
2421 #endif
2423 playlist->started = true;
2424 sync_control(playlist, false);
2425 audio_play(offset);
2428 /* Returns false if 'steps' is out of bounds, else true */
2429 bool playlist_check(int steps)
2431 struct playlist_info* playlist = &current_playlist;
2433 /* always allow folder navigation */
2434 if (global_settings.next_folder && playlist->in_ram)
2435 return true;
2437 int index = get_next_index(playlist, steps, -1);
2439 if (index < 0 && steps >= 0 && global_settings.repeat_mode == REPEAT_SHUFFLE)
2440 index = get_next_index(playlist, steps, REPEAT_ALL);
2442 return (index >= 0);
2445 /* get trackname of track that is "steps" away from current playing track.
2446 NULL is used to identify end of playlist */
2447 char* playlist_peek(int steps)
2449 struct playlist_info* playlist = &current_playlist;
2450 int seek;
2451 char *temp_ptr;
2452 int index;
2453 bool control_file;
2455 index = get_next_index(playlist, steps, -1);
2456 if (index < 0)
2457 return NULL;
2459 control_file = playlist->indices[index] & PLAYLIST_INSERT_TYPE_MASK;
2460 seek = playlist->indices[index] & PLAYLIST_SEEK_MASK;
2462 if (get_filename(playlist, index, seek, control_file, now_playing,
2463 MAX_PATH+1) < 0)
2464 return NULL;
2466 temp_ptr = now_playing;
2468 if (!playlist->in_ram || control_file)
2470 /* remove bogus dirs from beginning of path
2471 (workaround for buggy playlist creation tools) */
2472 while (temp_ptr)
2474 if (file_exists(temp_ptr))
2475 break;
2477 temp_ptr = strchr(temp_ptr+1, '/');
2480 if (!temp_ptr)
2482 /* Even though this is an invalid file, we still need to pass a
2483 file name to the caller because NULL is used to indicate end
2484 of playlist */
2485 return now_playing;
2489 return temp_ptr;
2493 * Update indices as track has changed
2495 int playlist_next(int steps)
2497 struct playlist_info* playlist = &current_playlist;
2498 int index;
2500 if ( (steps > 0)
2501 #ifdef AB_REPEAT_ENABLE
2502 && (global_settings.repeat_mode != REPEAT_AB)
2503 #endif
2504 && (global_settings.repeat_mode != REPEAT_ONE) )
2506 int i, j;
2508 /* We need to delete all the queued songs */
2509 for (i=0, j=steps; i<j; i++)
2511 index = get_next_index(playlist, i, -1);
2513 if (playlist->indices[index] & PLAYLIST_QUEUE_MASK)
2515 remove_track_from_playlist(playlist, index, true);
2516 steps--; /* one less track */
2521 index = get_next_index(playlist, steps, -1);
2523 if (index < 0)
2525 /* end of playlist... or is it */
2526 if (global_settings.repeat_mode == REPEAT_SHUFFLE &&
2527 playlist->amount > 1)
2529 /* Repeat shuffle mode. Re-shuffle playlist and resume play */
2530 playlist->first_index = 0;
2531 sort_playlist(playlist, false, false);
2532 randomise_playlist(playlist, current_tick, false, true);
2533 #if CONFIG_CODEC != SWCODEC
2534 playlist_start(0, 0);
2535 #endif
2536 playlist->index = 0;
2537 index = 0;
2539 else if (playlist->in_ram && global_settings.next_folder)
2541 index = create_and_play_dir(steps, true);
2543 if (index >= 0)
2545 playlist->index = index;
2549 return index;
2552 playlist->index = index;
2554 if (playlist->last_insert_pos >= 0 && steps > 0)
2556 /* check to see if we've gone beyond the last inserted track */
2557 int cur = rotate_index(playlist, index);
2558 int last_pos = rotate_index(playlist, playlist->last_insert_pos);
2560 if (cur > last_pos)
2562 /* reset last inserted track */
2563 playlist->last_insert_pos = -1;
2565 if (playlist->control_fd >= 0)
2567 int result = update_control(playlist, PLAYLIST_COMMAND_RESET,
2568 -1, -1, NULL, NULL, NULL);
2570 if (result < 0)
2571 return result;
2573 sync_control(playlist, false);
2578 return index;
2581 /* try playing next or previous folder */
2582 bool playlist_next_dir(int direction)
2584 /* not to mess up real playlists */
2585 if(!current_playlist.in_ram)
2586 return false;
2588 return create_and_play_dir(direction, false) >= 0;
2591 /* Get resume info for current playing song. If return value is -1 then
2592 settings shouldn't be saved. */
2593 int playlist_get_resume_info(int *resume_index)
2595 struct playlist_info* playlist = &current_playlist;
2597 *resume_index = playlist->index;
2599 return 0;
2602 /* Update resume info for current playing song. Returns -1 on error. */
2603 int playlist_update_resume_info(const struct mp3entry* id3)
2605 struct playlist_info* playlist = &current_playlist;
2607 if (id3)
2609 if (global_status.resume_index != playlist->index ||
2610 global_status.resume_offset != id3->offset)
2612 global_status.resume_index = playlist->index;
2613 global_status.resume_offset = id3->offset;
2614 status_save();
2617 else
2619 global_status.resume_index = -1;
2620 global_status.resume_offset = -1;
2621 status_save();
2624 return 0;
2627 /* Returns index of current playing track for display purposes. This value
2628 should not be used for resume purposes as it doesn't represent the actual
2629 index into the playlist */
2630 int playlist_get_display_index(void)
2632 struct playlist_info* playlist = &current_playlist;
2634 /* first_index should always be index 0 for display purposes */
2635 int index = rotate_index(playlist, playlist->index);
2637 return (index+1);
2640 /* returns number of tracks in current playlist */
2641 int playlist_amount(void)
2643 return playlist_amount_ex(NULL);
2647 * Create a new playlist If playlist is not NULL then we're loading a
2648 * playlist off disk for viewing/editing. The index_buffer is used to store
2649 * playlist indices (required for and only used if !current playlist). The
2650 * temp_buffer (if not NULL) is used as a scratchpad when loading indices.
2652 int playlist_create_ex(struct playlist_info* playlist,
2653 const char* dir, const char* file,
2654 void* index_buffer, int index_buffer_size,
2655 void* temp_buffer, int temp_buffer_size)
2657 if (!playlist)
2658 playlist = &current_playlist;
2659 else
2661 /* Initialize playlist structure */
2662 int r = rand() % 10;
2663 playlist->current = false;
2665 /* Use random name for control file */
2666 snprintf(playlist->control_filename, sizeof(playlist->control_filename),
2667 "%s.%d", PLAYLIST_CONTROL_FILE, r);
2668 playlist->fd = -1;
2669 playlist->control_fd = -1;
2671 if (index_buffer)
2673 int num_indices = index_buffer_size / sizeof(int);
2675 #ifdef HAVE_DIRCACHE
2676 num_indices /= 2;
2677 #endif
2678 if (num_indices > global_settings.max_files_in_playlist)
2679 num_indices = global_settings.max_files_in_playlist;
2681 playlist->max_playlist_size = num_indices;
2682 playlist->indices = index_buffer;
2683 #ifdef HAVE_DIRCACHE
2684 playlist->filenames = (const struct dircache_entry **)
2685 &playlist->indices[num_indices];
2686 #endif
2688 else
2690 playlist->max_playlist_size = current_playlist.max_playlist_size;
2691 playlist->indices = current_playlist.indices;
2692 #ifdef HAVE_DIRCACHE
2693 playlist->filenames = current_playlist.filenames;
2694 #endif
2697 playlist->buffer_size = 0;
2698 playlist->buffer = NULL;
2699 mutex_init(&playlist->control_mutex);
2702 new_playlist(playlist, dir, file);
2704 if (file)
2705 /* load the playlist file */
2706 add_indices_to_playlist(playlist, temp_buffer, temp_buffer_size);
2708 return 0;
2712 * Set the specified playlist as the current.
2713 * NOTE: You will get undefined behaviour if something is already playing so
2714 * remember to stop before calling this. Also, this call will
2715 * effectively close your playlist, making it unusable.
2717 int playlist_set_current(struct playlist_info* playlist)
2719 if (!playlist || (check_control(playlist) < 0))
2720 return -1;
2722 empty_playlist(&current_playlist, false);
2724 strncpy(current_playlist.filename, playlist->filename,
2725 sizeof(current_playlist.filename));
2727 current_playlist.utf8 = playlist->utf8;
2728 current_playlist.fd = playlist->fd;
2730 close(playlist->control_fd);
2731 close(current_playlist.control_fd);
2732 remove(current_playlist.control_filename);
2733 if (rename(playlist->control_filename,
2734 current_playlist.control_filename) < 0)
2735 return -1;
2736 current_playlist.control_fd = open(current_playlist.control_filename,
2737 O_RDWR);
2738 if (current_playlist.control_fd < 0)
2739 return -1;
2740 current_playlist.control_created = true;
2742 current_playlist.dirlen = playlist->dirlen;
2744 if (playlist->indices && playlist->indices != current_playlist.indices)
2746 memcpy(current_playlist.indices, playlist->indices,
2747 playlist->max_playlist_size*sizeof(int));
2748 #ifdef HAVE_DIRCACHE
2749 memcpy(current_playlist.filenames, playlist->filenames,
2750 playlist->max_playlist_size*sizeof(int));
2751 #endif
2754 current_playlist.first_index = playlist->first_index;
2755 current_playlist.amount = playlist->amount;
2756 current_playlist.last_insert_pos = playlist->last_insert_pos;
2757 current_playlist.seed = playlist->seed;
2758 current_playlist.shuffle_modified = playlist->shuffle_modified;
2759 current_playlist.deleted = playlist->deleted;
2760 current_playlist.num_inserted_tracks = playlist->num_inserted_tracks;
2762 memcpy(current_playlist.control_cache, playlist->control_cache,
2763 sizeof(current_playlist.control_cache));
2764 current_playlist.num_cached = playlist->num_cached;
2765 current_playlist.pending_control_sync = playlist->pending_control_sync;
2767 return 0;
2771 * Close files and delete control file for non-current playlist.
2773 void playlist_close(struct playlist_info* playlist)
2775 if (!playlist)
2776 return;
2778 if (playlist->fd >= 0)
2779 close(playlist->fd);
2781 if (playlist->control_fd >= 0)
2782 close(playlist->control_fd);
2784 if (playlist->control_created)
2785 remove(playlist->control_filename);
2788 void playlist_sync(struct playlist_info* playlist)
2790 if (!playlist)
2791 playlist = &current_playlist;
2793 sync_control(playlist, false);
2794 if ((audio_status() & AUDIO_STATUS_PLAY) && playlist->started)
2795 audio_flush_and_reload_tracks();
2797 #ifdef HAVE_DIRCACHE
2798 queue_post(&playlist_queue, PLAYLIST_LOAD_POINTERS, 0);
2799 #endif
2803 * Insert track into playlist at specified position (or one of the special
2804 * positions). Returns position where track was inserted or -1 if error.
2806 int playlist_insert_track(struct playlist_info* playlist, const char *filename,
2807 int position, bool queue, bool sync)
2809 int result;
2811 if (!playlist)
2812 playlist = &current_playlist;
2814 if (check_control(playlist) < 0)
2816 splash(HZ*2, ID2P(LANG_PLAYLIST_CONTROL_ACCESS_ERROR));
2817 return -1;
2820 result = add_track_to_playlist(playlist, filename, position, queue, -1);
2822 /* Check if we want manually sync later. For example when adding
2823 * bunch of files from tagcache, syncing after every file wouldn't be
2824 * a good thing to do. */
2825 if (sync && result >= 0)
2826 playlist_sync(playlist);
2828 return result;
2832 * Insert all tracks from specified directory into playlist.
2834 int playlist_insert_directory(struct playlist_info* playlist,
2835 const char *dirname, int position, bool queue,
2836 bool recurse)
2838 int result;
2839 unsigned char *count_str;
2840 struct directory_search_context context;
2842 if (!playlist)
2843 playlist = &current_playlist;
2845 if (check_control(playlist) < 0)
2847 splash(HZ*2, ID2P(LANG_PLAYLIST_CONTROL_ACCESS_ERROR));
2848 return -1;
2851 if (position == PLAYLIST_REPLACE)
2853 if (playlist_remove_all_tracks(playlist) == 0)
2854 position = PLAYLIST_INSERT_LAST;
2855 else
2856 return -1;
2859 if (queue)
2860 count_str = ID2P(LANG_PLAYLIST_QUEUE_COUNT);
2861 else
2862 count_str = ID2P(LANG_PLAYLIST_INSERT_COUNT);
2864 display_playlist_count(0, count_str, false);
2866 context.playlist = playlist;
2867 context.position = position;
2868 context.queue = queue;
2869 context.count = 0;
2871 cpu_boost(true);
2873 result = playlist_directory_tracksearch(dirname, recurse,
2874 directory_search_callback, &context);
2876 sync_control(playlist, false);
2878 cpu_boost(false);
2880 display_playlist_count(context.count, count_str, true);
2882 if ((audio_status() & AUDIO_STATUS_PLAY) && playlist->started)
2883 audio_flush_and_reload_tracks();
2885 #ifdef HAVE_DIRCACHE
2886 queue_post(&playlist_queue, PLAYLIST_LOAD_POINTERS, 0);
2887 #endif
2889 return result;
2893 * Insert all tracks from specified playlist into dynamic playlist.
2895 int playlist_insert_playlist(struct playlist_info* playlist, const char *filename,
2896 int position, bool queue)
2898 int fd;
2899 int max;
2900 char *temp_ptr;
2901 const char *dir;
2902 unsigned char *count_str;
2903 char temp_buf[MAX_PATH+1];
2904 char trackname[MAX_PATH+1];
2905 int count = 0;
2906 int result = 0;
2907 bool utf8 = is_m3u8(filename);
2909 if (!playlist)
2910 playlist = &current_playlist;
2912 if (check_control(playlist) < 0)
2914 splash(HZ*2, ID2P(LANG_PLAYLIST_CONTROL_ACCESS_ERROR));
2915 return -1;
2918 fd = open_utf8(filename, O_RDONLY);
2919 if (fd < 0)
2921 splash(HZ*2, ID2P(LANG_PLAYLIST_ACCESS_ERROR));
2922 return -1;
2925 /* we need the directory name for formatting purposes */
2926 dir = filename;
2928 temp_ptr = strrchr(filename+1,'/');
2929 if (temp_ptr)
2930 *temp_ptr = 0;
2931 else
2932 dir = "/";
2934 if (queue)
2935 count_str = ID2P(LANG_PLAYLIST_QUEUE_COUNT);
2936 else
2937 count_str = ID2P(LANG_PLAYLIST_INSERT_COUNT);
2939 display_playlist_count(count, count_str, false);
2941 if (position == PLAYLIST_REPLACE)
2943 if (playlist_remove_all_tracks(playlist) == 0)
2944 position = PLAYLIST_INSERT_LAST;
2945 else return -1;
2948 cpu_boost(true);
2950 while ((max = read_line(fd, temp_buf, sizeof(temp_buf))) > 0)
2952 /* user abort */
2953 if (action_userabort(TIMEOUT_NOBLOCK))
2954 break;
2956 if (temp_buf[0] != '#' && temp_buf[0] != '\0')
2958 int insert_pos;
2960 if (!utf8)
2962 /* Use trackname as a temporay buffer. Note that trackname must
2963 * be as large as temp_buf.
2965 max = convert_m3u(temp_buf, max, sizeof(temp_buf), trackname);
2968 /* we need to format so that relative paths are correctly
2969 handled */
2970 if (format_track_path(trackname, temp_buf, sizeof(trackname), max,
2971 dir) < 0)
2973 result = -1;
2974 break;
2977 insert_pos = add_track_to_playlist(playlist, trackname, position,
2978 queue, -1);
2980 if (insert_pos < 0)
2982 result = -1;
2983 break;
2986 /* Make sure tracks are inserted in correct order if user
2987 requests INSERT_FIRST */
2988 if (position == PLAYLIST_INSERT_FIRST || position >= 0)
2989 position = insert_pos + 1;
2991 count++;
2993 if ((count%PLAYLIST_DISPLAY_COUNT) == 0)
2995 display_playlist_count(count, count_str, false);
2997 if (count == PLAYLIST_DISPLAY_COUNT &&
2998 (audio_status() & AUDIO_STATUS_PLAY) &&
2999 playlist->started)
3000 audio_flush_and_reload_tracks();
3004 /* let the other threads work */
3005 yield();
3008 close(fd);
3010 if (temp_ptr)
3011 *temp_ptr = '/';
3013 sync_control(playlist, false);
3015 cpu_boost(false);
3017 display_playlist_count(count, count_str, true);
3019 if ((audio_status() & AUDIO_STATUS_PLAY) && playlist->started)
3020 audio_flush_and_reload_tracks();
3022 #ifdef HAVE_DIRCACHE
3023 queue_post(&playlist_queue, PLAYLIST_LOAD_POINTERS, 0);
3024 #endif
3026 return result;
3030 * Delete track at specified index. If index is PLAYLIST_DELETE_CURRENT then
3031 * we want to delete the current playing track.
3033 int playlist_delete(struct playlist_info* playlist, int index)
3035 int result = 0;
3037 if (!playlist)
3038 playlist = &current_playlist;
3040 if (check_control(playlist) < 0)
3042 splash(HZ*2, ID2P(LANG_PLAYLIST_CONTROL_ACCESS_ERROR));
3043 return -1;
3046 if (index == PLAYLIST_DELETE_CURRENT)
3047 index = playlist->index;
3049 result = remove_track_from_playlist(playlist, index, true);
3051 if (result != -1 && (audio_status() & AUDIO_STATUS_PLAY) &&
3052 playlist->started)
3053 audio_flush_and_reload_tracks();
3055 return result;
3059 * Move track at index to new_index. Tracks between the two are shifted
3060 * appropriately. Returns 0 on success and -1 on failure.
3062 int playlist_move(struct playlist_info* playlist, int index, int new_index)
3064 int result;
3065 int seek;
3066 bool control_file;
3067 bool queue;
3068 bool current = false;
3069 int r;
3070 char filename[MAX_PATH];
3072 if (!playlist)
3073 playlist = &current_playlist;
3075 if (check_control(playlist) < 0)
3077 splash(HZ*2, ID2P(LANG_PLAYLIST_CONTROL_ACCESS_ERROR));
3078 return -1;
3081 if (index == new_index)
3082 return -1;
3084 if (index == playlist->index)
3085 /* Moving the current track */
3086 current = true;
3088 control_file = playlist->indices[index] & PLAYLIST_INSERT_TYPE_MASK;
3089 queue = playlist->indices[index] & PLAYLIST_QUEUE_MASK;
3090 seek = playlist->indices[index] & PLAYLIST_SEEK_MASK;
3092 if (get_filename(playlist, index, seek, control_file, filename,
3093 sizeof(filename)) < 0)
3094 return -1;
3096 /* We want to insert the track at the position that was specified by
3097 new_index. This may be different then new_index because of the
3098 shifting that will occur after the delete.
3099 We calculate this before we do the remove as it depends on the
3100 size of the playlist before the track removal */
3101 r = rotate_index(playlist, new_index);
3103 /* Delete track from original position */
3104 result = remove_track_from_playlist(playlist, index, true);
3106 if (result != -1)
3108 if (r == 0)
3109 /* First index */
3110 new_index = PLAYLIST_PREPEND;
3111 else if (r == playlist->amount)
3112 /* Append */
3113 new_index = PLAYLIST_INSERT_LAST;
3114 else
3115 /* Calculate index of desired position */
3116 new_index = (r+playlist->first_index)%playlist->amount;
3118 result = add_track_to_playlist(playlist, filename, new_index, queue,
3119 -1);
3121 if (result != -1)
3123 if (current)
3125 /* Moved the current track */
3126 switch (new_index)
3128 case PLAYLIST_PREPEND:
3129 playlist->index = playlist->first_index;
3130 break;
3131 case PLAYLIST_INSERT_LAST:
3132 playlist->index = playlist->first_index - 1;
3133 if (playlist->index < 0)
3134 playlist->index += playlist->amount;
3135 break;
3136 default:
3137 playlist->index = new_index;
3138 break;
3142 if ((audio_status() & AUDIO_STATUS_PLAY) && playlist->started)
3143 audio_flush_and_reload_tracks();
3147 #ifdef HAVE_DIRCACHE
3148 queue_post(&playlist_queue, PLAYLIST_LOAD_POINTERS, 0);
3149 #endif
3151 return result;
3154 /* shuffle currently playing playlist */
3155 int playlist_randomise(struct playlist_info* playlist, unsigned int seed,
3156 bool start_current)
3158 int result;
3160 if (!playlist)
3161 playlist = &current_playlist;
3163 check_control(playlist);
3165 result = randomise_playlist(playlist, seed, start_current, true);
3167 if (result != -1 && (audio_status() & AUDIO_STATUS_PLAY) &&
3168 playlist->started)
3169 audio_flush_and_reload_tracks();
3171 return result;
3174 /* sort currently playing playlist */
3175 int playlist_sort(struct playlist_info* playlist, bool start_current)
3177 int result;
3179 if (!playlist)
3180 playlist = &current_playlist;
3182 check_control(playlist);
3184 result = sort_playlist(playlist, start_current, true);
3186 if (result != -1 && (audio_status() & AUDIO_STATUS_PLAY) &&
3187 playlist->started)
3188 audio_flush_and_reload_tracks();
3190 return result;
3193 /* returns true if playlist has been modified */
3194 bool playlist_modified(const struct playlist_info* playlist)
3196 if (!playlist)
3197 playlist = &current_playlist;
3199 if (playlist->shuffle_modified ||
3200 playlist->deleted ||
3201 playlist->num_inserted_tracks > 0)
3202 return true;
3204 return false;
3207 /* returns index of first track in playlist */
3208 int playlist_get_first_index(const struct playlist_info* playlist)
3210 if (!playlist)
3211 playlist = &current_playlist;
3213 return playlist->first_index;
3216 /* returns shuffle seed of playlist */
3217 int playlist_get_seed(const struct playlist_info* playlist)
3219 if (!playlist)
3220 playlist = &current_playlist;
3222 return playlist->seed;
3225 /* returns number of tracks in playlist (includes queued/inserted tracks) */
3226 int playlist_amount_ex(const struct playlist_info* playlist)
3228 if (!playlist)
3229 playlist = &current_playlist;
3231 return playlist->amount;
3234 /* returns full path of playlist (minus extension) */
3235 char *playlist_name(const struct playlist_info* playlist, char *buf,
3236 int buf_size)
3238 char *sep;
3240 if (!playlist)
3241 playlist = &current_playlist;
3243 strncpy(buf, playlist->filename+playlist->dirlen, buf_size);
3245 if (!buf[0])
3246 return NULL;
3248 /* Remove extension */
3249 sep = strrchr(buf, '.');
3250 if (sep)
3251 *sep = 0;
3253 return buf;
3256 /* returns the playlist filename */
3257 char *playlist_get_name(const struct playlist_info* playlist, char *buf,
3258 int buf_size)
3260 if (!playlist)
3261 playlist = &current_playlist;
3263 strncpy(buf, playlist->filename, buf_size);
3265 if (!buf[0])
3266 return NULL;
3268 return buf;
3271 /* Fills info structure with information about track at specified index.
3272 Returns 0 on success and -1 on failure */
3273 int playlist_get_track_info(struct playlist_info* playlist, int index,
3274 struct playlist_track_info* info)
3276 int seek;
3277 bool control_file;
3279 if (!playlist)
3280 playlist = &current_playlist;
3282 if (index < 0 || index >= playlist->amount)
3283 return -1;
3285 control_file = playlist->indices[index] & PLAYLIST_INSERT_TYPE_MASK;
3286 seek = playlist->indices[index] & PLAYLIST_SEEK_MASK;
3288 if (get_filename(playlist, index, seek, control_file, info->filename,
3289 sizeof(info->filename)) < 0)
3290 return -1;
3292 info->attr = 0;
3294 if (control_file)
3296 if (playlist->indices[index] & PLAYLIST_QUEUE_MASK)
3297 info->attr |= PLAYLIST_ATTR_QUEUED;
3298 else
3299 info->attr |= PLAYLIST_ATTR_INSERTED;
3303 if (playlist->indices[index] & PLAYLIST_SKIPPED)
3304 info->attr |= PLAYLIST_ATTR_SKIPPED;
3306 info->index = index;
3307 info->display_index = rotate_index(playlist, index) + 1;
3309 return 0;
3312 /* save the current dynamic playlist to specified file */
3313 int playlist_save(struct playlist_info* playlist, char *filename)
3315 int fd;
3316 int i, index;
3317 int count = 0;
3318 char path[MAX_PATH+1];
3319 char tmp_buf[MAX_PATH+1];
3320 int result = 0;
3321 bool overwrite_current = false;
3322 int* index_buf = NULL;
3324 if (!playlist)
3325 playlist = &current_playlist;
3327 if (playlist->amount <= 0)
3328 return -1;
3330 /* use current working directory as base for pathname */
3331 if (format_track_path(path, filename, sizeof(tmp_buf),
3332 strlen(filename)+1, getcwd(NULL, -1)) < 0)
3333 return -1;
3335 if (!strncmp(playlist->filename, path, strlen(path)))
3337 /* Attempting to overwrite current playlist file.*/
3339 if (playlist->buffer_size < (int)(playlist->amount * sizeof(int)))
3341 /* not enough buffer space to store updated indices */
3342 splash(HZ*2, ID2P(LANG_PLAYLIST_ACCESS_ERROR));
3343 return -1;
3346 /* in_ram buffer is unused for m3u files so we'll use for storing
3347 updated indices */
3348 index_buf = (int*)playlist->buffer;
3350 /* use temporary pathname */
3351 snprintf(path, sizeof(path), "%s_temp", playlist->filename);
3352 overwrite_current = true;
3355 if (is_m3u8(path))
3357 fd = open_utf8(path, O_CREAT|O_WRONLY|O_TRUNC);
3359 else
3361 /* some applications require a BOM to read the file properly */
3362 fd = open(path, O_CREAT|O_WRONLY|O_TRUNC);
3364 if (fd < 0)
3366 splash(HZ*2, ID2P(LANG_PLAYLIST_ACCESS_ERROR));
3367 return -1;
3370 display_playlist_count(count, ID2P(LANG_PLAYLIST_SAVE_COUNT), false);
3372 cpu_boost(true);
3374 index = playlist->first_index;
3375 for (i=0; i<playlist->amount; i++)
3377 bool control_file;
3378 bool queue;
3379 int seek;
3381 /* user abort */
3382 if (action_userabort(TIMEOUT_NOBLOCK))
3384 result = -1;
3385 break;
3388 control_file = playlist->indices[index] & PLAYLIST_INSERT_TYPE_MASK;
3389 queue = playlist->indices[index] & PLAYLIST_QUEUE_MASK;
3390 seek = playlist->indices[index] & PLAYLIST_SEEK_MASK;
3392 /* Don't save queued files */
3393 if (!queue)
3395 if (get_filename(playlist, index, seek, control_file, tmp_buf,
3396 MAX_PATH+1) < 0)
3398 result = -1;
3399 break;
3402 if (overwrite_current)
3403 index_buf[count] = lseek(fd, 0, SEEK_CUR);
3405 if (fdprintf(fd, "%s\n", tmp_buf) < 0)
3407 splash(HZ*2, ID2P(LANG_PLAYLIST_ACCESS_ERROR));
3408 result = -1;
3409 break;
3412 count++;
3414 if ((count % PLAYLIST_DISPLAY_COUNT) == 0)
3415 display_playlist_count(count, ID2P(LANG_PLAYLIST_SAVE_COUNT),
3416 false);
3418 yield();
3421 index = (index+1)%playlist->amount;
3424 display_playlist_count(count, ID2P(LANG_PLAYLIST_SAVE_COUNT), true);
3426 close(fd);
3428 if (overwrite_current && result >= 0)
3430 result = -1;
3432 mutex_lock(&playlist->control_mutex);
3434 /* Replace the current playlist with the new one and update indices */
3435 close(playlist->fd);
3436 if (remove(playlist->filename) >= 0)
3438 if (rename(path, playlist->filename) >= 0)
3440 playlist->fd = open_utf8(playlist->filename, O_RDONLY);
3441 if (playlist->fd >= 0)
3443 index = playlist->first_index;
3444 for (i=0, count=0; i<playlist->amount; i++)
3446 if (!(playlist->indices[index] & PLAYLIST_QUEUE_MASK))
3448 playlist->indices[index] = index_buf[count];
3449 count++;
3451 index = (index+1)%playlist->amount;
3454 /* we need to recreate control because inserted tracks are
3455 now part of the playlist and shuffle has been
3456 invalidated */
3457 result = recreate_control(playlist);
3462 mutex_unlock(&playlist->control_mutex);
3466 cpu_boost(false);
3468 return result;
3472 * Search specified directory for tracks and notify via callback. May be
3473 * called recursively.
3475 int playlist_directory_tracksearch(const char* dirname, bool recurse,
3476 int (*callback)(char*, void*),
3477 void* context)
3479 char buf[MAX_PATH+1];
3480 int result = 0;
3481 int num_files = 0;
3482 int i;
3483 struct entry *files;
3484 struct tree_context* tc = tree_get_context();
3485 int old_dirfilter = *(tc->dirfilter);
3487 if (!callback)
3488 return -1;
3490 /* use the tree browser dircache to load files */
3491 *(tc->dirfilter) = SHOW_ALL;
3493 if (ft_load(tc, dirname) < 0)
3495 splash(HZ*2, ID2P(LANG_PLAYLIST_DIRECTORY_ACCESS_ERROR));
3496 *(tc->dirfilter) = old_dirfilter;
3497 return -1;
3500 files = (struct entry*) tc->dircache;
3501 num_files = tc->filesindir;
3503 /* we've overwritten the dircache so tree browser will need to be
3504 reloaded */
3505 reload_directory();
3507 for (i=0; i<num_files; i++)
3509 /* user abort */
3510 if (action_userabort(TIMEOUT_NOBLOCK))
3512 result = -1;
3513 break;
3516 if (files[i].attr & ATTR_DIRECTORY)
3518 if (recurse)
3520 /* recursively add directories */
3521 snprintf(buf, sizeof(buf), "%s/%s", dirname, files[i].name);
3522 result = playlist_directory_tracksearch(buf, recurse,
3523 callback, context);
3524 if (result < 0)
3525 break;
3527 /* we now need to reload our current directory */
3528 if(ft_load(tc, dirname) < 0)
3530 result = -1;
3531 break;
3534 files = (struct entry*) tc->dircache;
3535 num_files = tc->filesindir;
3536 if (!num_files)
3538 result = -1;
3539 break;
3542 else
3543 continue;
3545 else if ((files[i].attr & FILE_ATTR_MASK) == FILE_ATTR_AUDIO)
3547 snprintf(buf, sizeof(buf), "%s/%s", dirname, files[i].name);
3549 if (callback(buf, context) != 0)
3551 result = -1;
3552 break;
3555 /* let the other threads work */
3556 yield();
3560 /* restore dirfilter */
3561 *(tc->dirfilter) = old_dirfilter;
3563 return result;