1 /***************************************************************************
3 * Open \______ \ ____ ____ | | _\_ |__ _______ ___
4 * Source | _// _ \_/ ___\| |/ /| __ \ / _ \ \/ /
5 * Jukebox | | ( <_> ) \___| < | \_\ ( <_> > < <
6 * Firmware |____|_ /\____/ \___ >__|_ \|___ /\____/__/\_ \
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
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
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.
73 #include "string-extra.h"
75 #include "ata_idle_notify.h"
85 #include "applimits.h"
89 #include "filefuncs.h"
95 #include "filetypes.h"
96 #ifdef HAVE_LCD_BITMAP
104 #include "rbunicode.h"
105 #include "root_menu.h"
107 #define PLAYLIST_CONTROL_FILE_VERSION 2
110 Each playlist index has a flag associated with it which identifies what
111 type of track it is. These flags are stored in the 4 high order bits of
114 NOTE: This limits the playlist file size to a max of 256M.
118 01 = Track was prepended into playlist
119 10 = Track was inserted into playlist
120 11 = Track was appended into playlist
125 0 = Track entry is valid
126 1 = Track does not exist on disk and should be skipped
128 #define PLAYLIST_SEEK_MASK 0x0FFFFFFF
129 #define PLAYLIST_INSERT_TYPE_MASK 0xC0000000
130 #define PLAYLIST_QUEUE_MASK 0x20000000
132 #define PLAYLIST_INSERT_TYPE_PREPEND 0x40000000
133 #define PLAYLIST_INSERT_TYPE_INSERT 0x80000000
134 #define PLAYLIST_INSERT_TYPE_APPEND 0xC0000000
136 #define PLAYLIST_QUEUED 0x20000000
137 #define PLAYLIST_SKIPPED 0x10000000
139 struct directory_search_context
{
140 struct playlist_info
* playlist
;
146 static struct playlist_info current_playlist
;
148 static void empty_playlist(struct playlist_info
* playlist
, bool resume
);
149 static void new_playlist(struct playlist_info
* playlist
, const char *dir
,
151 static void create_control(struct playlist_info
* playlist
);
152 static int check_control(struct playlist_info
* playlist
);
153 static int recreate_control(struct playlist_info
* playlist
);
154 static void update_playlist_filename(struct playlist_info
* playlist
,
155 const char *dir
, const char *file
);
156 static int add_indices_to_playlist(struct playlist_info
* playlist
,
157 char* buffer
, size_t buflen
);
158 static int add_track_to_playlist(struct playlist_info
* playlist
,
159 const char *filename
, int position
,
160 bool queue
, int seek_pos
);
161 static int directory_search_callback(char* filename
, void* context
);
162 static int remove_track_from_playlist(struct playlist_info
* playlist
,
163 int position
, bool write
);
164 static int randomise_playlist(struct playlist_info
* playlist
,
165 unsigned int seed
, bool start_current
,
167 static int sort_playlist(struct playlist_info
* playlist
, bool start_current
,
169 static int get_next_index(const struct playlist_info
* playlist
, int steps
,
171 static void find_and_set_playlist_index(struct playlist_info
* playlist
,
173 static int compare(const void* p1
, const void* p2
);
174 static int get_filename(struct playlist_info
* playlist
, int index
, int seek
,
175 bool control_file
, char *buf
, int buf_length
);
176 static int get_next_directory(char *dir
);
177 static int get_next_dir(char *dir
, bool is_forward
, bool recursion
);
178 static int get_previous_directory(char *dir
);
179 static int check_subdir_for_music(char *dir
, const char *subdir
, bool recurse
);
180 static int format_track_path(char *dest
, char *src
, int buf_length
, int max
,
182 static void display_playlist_count(int count
, const unsigned char *fmt
,
184 static void display_buffer_full(void);
185 static int flush_cached_control(struct playlist_info
* playlist
);
186 static int update_control(struct playlist_info
* playlist
,
187 enum playlist_command command
, int i1
, int i2
,
188 const char* s1
, const char* s2
, void* data
);
189 static void sync_control(struct playlist_info
* playlist
, bool force
);
190 static int rotate_index(const struct playlist_info
* playlist
, int index
);
193 #define PLAYLIST_LOAD_POINTERS 1
195 static struct event_queue playlist_queue SHAREDBSS_ATTR
;
196 static long playlist_stack
[(DEFAULT_STACK_SIZE
+ 0x800)/sizeof(long)];
197 static const char playlist_thread_name
[] = "playlist cachectrl";
200 static struct mutex current_playlist_mutex SHAREDBSS_ATTR
;
201 static struct mutex created_playlist_mutex SHAREDBSS_ATTR
;
203 /* Check if the filename suggests M3U or M3U8 format. */
204 static bool is_m3u8(const char* filename
)
206 int len
= strlen(filename
);
208 /* Default to M3U8 unless explicitly told otherwise. */
209 return !(len
> 4 && strcasecmp(&filename
[len
- 4], ".m3u") == 0);
213 /* Convert a filename in an M3U playlist to UTF-8.
215 * buf - the filename to convert; can contain more than one line from the
217 * buf_len - amount of buf that is used.
218 * buf_max - total size of buf.
219 * temp - temporary conversion buffer, at least buf_max bytes.
221 * Returns the length of the converted filename.
223 static int convert_m3u(char* buf
, int buf_len
, int buf_max
, char* temp
)
229 while ((buf
[i
] != '\n') && (buf
[i
] != '\r') && (i
< buf_len
))
234 /* Work back killing white space. */
235 while ((i
> 0) && isspace(buf
[i
- 1]))
243 /* Convert char by char, so as to not overflow temp (iso_decode should
244 * preferably handle this). No more than 4 bytes should be generated for
247 for (i
= 0; i
< buf_len
&& dest
< (temp
+ buf_max
- 4); i
++)
249 dest
= iso_decode(&buf
[i
], dest
, -1, 1);
258 * remove any files and indices associated with the playlist
260 static void empty_playlist(struct playlist_info
* playlist
, bool resume
)
262 playlist
->filename
[0] = '\0';
263 playlist
->utf8
= true;
265 if(playlist
->fd
>= 0)
266 /* If there is an already open playlist, close it. */
270 if(playlist
->control_fd
>= 0)
271 close(playlist
->control_fd
);
272 playlist
->control_fd
= -1;
273 playlist
->control_created
= false;
275 playlist
->in_ram
= false;
277 if (playlist
->buffer
)
278 playlist
->buffer
[0] = 0;
280 playlist
->buffer_end_pos
= 0;
283 playlist
->first_index
= 0;
284 playlist
->amount
= 0;
285 playlist
->last_insert_pos
= -1;
287 playlist
->shuffle_modified
= false;
288 playlist
->deleted
= false;
289 playlist
->num_inserted_tracks
= 0;
290 playlist
->started
= false;
292 playlist
->num_cached
= 0;
293 playlist
->pending_control_sync
= false;
295 if (!resume
&& playlist
->current
)
297 /* start with fresh playlist control file when starting new
299 create_control(playlist
);
304 * Initialize a new playlist for viewing/editing/playing. dir is the
305 * directory where the playlist is located and file is the filename.
307 static void new_playlist(struct playlist_info
* playlist
, const char *dir
,
310 const char *fileused
= file
;
311 const char *dirused
= dir
;
312 empty_playlist(playlist
, false);
318 if (dirused
&& playlist
->current
) /* !current cannot be in_ram */
319 playlist
->in_ram
= true;
321 dirused
= ""; /* empty playlist */
324 update_playlist_filename(playlist
, dirused
, fileused
);
326 if (playlist
->control_fd
>= 0)
328 update_control(playlist
, PLAYLIST_COMMAND_PLAYLIST
,
329 PLAYLIST_CONTROL_FILE_VERSION
, -1, dirused
, fileused
, NULL
);
330 sync_control(playlist
, false);
335 * create control file for playlist
337 static void create_control(struct playlist_info
* playlist
)
339 playlist
->control_fd
= open(playlist
->control_filename
,
340 O_CREAT
|O_RDWR
|O_TRUNC
, 0666);
341 if (playlist
->control_fd
< 0)
343 if (check_rockboxdir())
345 cond_talk_ids_fq(LANG_PLAYLIST_CONTROL_ACCESS_ERROR
);
346 splashf(HZ
*2, (unsigned char *)"%s (%d)",
347 str(LANG_PLAYLIST_CONTROL_ACCESS_ERROR
),
348 playlist
->control_fd
);
350 playlist
->control_created
= false;
354 playlist
->control_created
= true;
359 * validate the control file. This may include creating/initializing it if
362 static int check_control(struct playlist_info
* playlist
)
364 if (!playlist
->control_created
)
366 create_control(playlist
);
368 if (playlist
->control_fd
>= 0)
370 char* dir
= playlist
->filename
;
371 char* file
= playlist
->filename
+playlist
->dirlen
;
372 char c
= playlist
->filename
[playlist
->dirlen
-1];
374 playlist
->filename
[playlist
->dirlen
-1] = '\0';
376 update_control(playlist
, PLAYLIST_COMMAND_PLAYLIST
,
377 PLAYLIST_CONTROL_FILE_VERSION
, -1, dir
, file
, NULL
);
378 sync_control(playlist
, false);
379 playlist
->filename
[playlist
->dirlen
-1] = c
;
383 if (playlist
->control_fd
< 0)
390 * recreate the control file based on current playlist entries
392 static int recreate_control(struct playlist_info
* playlist
)
394 char temp_file
[MAX_PATH
+1];
399 if(playlist
->control_fd
>= 0)
401 char* dir
= playlist
->filename
;
402 char* file
= playlist
->filename
+playlist
->dirlen
;
403 char c
= playlist
->filename
[playlist
->dirlen
-1];
405 close(playlist
->control_fd
);
407 snprintf(temp_file
, sizeof(temp_file
), "%s_temp",
408 playlist
->control_filename
);
410 if (rename(playlist
->control_filename
, temp_file
) < 0)
413 temp_fd
= open(temp_file
, O_RDONLY
);
417 playlist
->control_fd
= open(playlist
->control_filename
,
418 O_CREAT
|O_RDWR
|O_TRUNC
, 0666);
419 if (playlist
->control_fd
< 0)
422 playlist
->filename
[playlist
->dirlen
-1] = '\0';
424 /* cannot call update_control() because of mutex */
425 result
= fdprintf(playlist
->control_fd
, "P:%d:%s:%s\n",
426 PLAYLIST_CONTROL_FILE_VERSION
, dir
, file
);
428 playlist
->filename
[playlist
->dirlen
-1] = c
;
438 playlist
->shuffle_modified
= false;
439 playlist
->deleted
= false;
440 playlist
->num_inserted_tracks
= 0;
442 for (i
=0; i
<playlist
->amount
; i
++)
444 if (playlist
->indices
[i
] & PLAYLIST_INSERT_TYPE_MASK
)
446 bool queue
= playlist
->indices
[i
] & PLAYLIST_QUEUE_MASK
;
447 char inserted_file
[MAX_PATH
+1];
449 lseek(temp_fd
, playlist
->indices
[i
] & PLAYLIST_SEEK_MASK
,
451 read_line(temp_fd
, inserted_file
, sizeof(inserted_file
));
453 result
= fdprintf(playlist
->control_fd
, "%c:%d:%d:",
454 queue
?'Q':'A', i
, playlist
->last_insert_pos
);
457 /* save the position in file where name is written */
458 int seek_pos
= lseek(playlist
->control_fd
, 0, SEEK_CUR
);
460 result
= fdprintf(playlist
->control_fd
, "%s\n",
463 playlist
->indices
[i
] =
464 (playlist
->indices
[i
] & ~PLAYLIST_SEEK_MASK
) | seek_pos
;
470 playlist
->num_inserted_tracks
++;
476 fsync(playlist
->control_fd
);
485 * store directory and name of playlist file
487 static void update_playlist_filename(struct playlist_info
* playlist
,
488 const char *dir
, const char *file
)
491 int dirlen
= strlen(dir
);
493 playlist
->utf8
= is_m3u8(file
);
495 /* If the dir does not end in trailing slash, we use a separator.
496 Otherwise we don't. */
497 if('/' != dir
[dirlen
-1])
503 playlist
->dirlen
= dirlen
;
505 snprintf(playlist
->filename
, sizeof(playlist
->filename
),
506 "%s%s%s", dir
, sep
, file
);
510 * calculate track offsets within a playlist file
512 static int add_indices_to_playlist(struct playlist_info
* playlist
,
513 char* buffer
, size_t buflen
)
517 unsigned int count
= 0;
522 if(-1 == playlist
->fd
)
523 playlist
->fd
= open_utf8(playlist
->filename
, O_RDONLY
);
525 return -1; /* failure */
526 if((i
= lseek(playlist
->fd
, 0, SEEK_CUR
)) > 0)
527 playlist
->utf8
= true; /* Override any earlier indication. */
529 splash(0, ID2P(LANG_WAIT
));
533 /* use mp3 buffer for maximum load speed */
535 #if CONFIG_CODEC != SWCODEC
536 talk_buffer_steal(); /* we use the mp3 buffer, need to tell */
537 buflen
= (audiobufend
- audiobuf
);
538 buffer
= (char *)audiobuf
;
540 buffer
= (char *)audio_get_buffer(false, &buflen
);
548 nread
= read(playlist
->fd
, buffer
, buflen
);
549 /* Terminate on EOF */
553 p
= (unsigned char *)buffer
;
555 for(count
=0; count
< nread
; count
++,p
++) {
557 /* Are we on a new line? */
558 if((*p
== '\n') || (*p
== '\r'))
568 if ( playlist
->amount
>= playlist
->max_playlist_size
) {
569 display_buffer_full();
574 /* Store a new entry */
575 playlist
->indices
[ playlist
->amount
] = i
+count
;
577 if (playlist
->filenames
)
578 playlist
->filenames
[ playlist
->amount
] = NULL
;
590 queue_post(&playlist_queue
, PLAYLIST_LOAD_POINTERS
, 0);
597 * Utility function to create a new playlist, fill it with the next or
598 * previous directory, shuffle it if needed, and start playback.
599 * If play_last is true and direction zero or negative, start playing
600 * the last file in the directory, otherwise start playing the first.
602 static int create_and_play_dir(int direction
, bool play_last
)
604 char dir
[MAX_PATH
+ 1];
609 res
= get_next_directory(dir
);
611 res
= get_previous_directory(dir
);
615 if (playlist_create(dir
, NULL
) != -1)
617 ft_build_playlist(tree_get_context(), 0);
619 if (global_settings
.playlist_shuffle
)
620 playlist_shuffle(current_tick
, -1);
622 if (play_last
&& direction
<= 0)
623 index
= current_playlist
.amount
- 1;
627 #if (CONFIG_CODEC != SWCODEC)
628 playlist_start(index
, 0);
632 /* we've overwritten the dircache when getting the next/previous dir,
633 so the tree browser context will need to be reloaded */
641 * Removes all tracks, from the playlist, leaving the presently playing
644 int playlist_remove_all_tracks(struct playlist_info
*playlist
)
648 if (playlist
== NULL
)
649 playlist
= ¤t_playlist
;
651 while (playlist
->index
> 0)
652 if ((result
= remove_track_from_playlist(playlist
, 0, true)) < 0)
655 while (playlist
->amount
> 1)
656 if ((result
= remove_track_from_playlist(playlist
, 1, true)) < 0)
659 if (playlist
->amount
== 1) {
660 playlist
->indices
[0] |= PLAYLIST_QUEUED
;
668 * Add track to playlist at specified position. There are seven special
669 * positions that can be specified:
670 * PLAYLIST_PREPEND - Add track at beginning of playlist
671 * PLAYLIST_INSERT - Add track after current song. NOTE: If
672 * there are already inserted tracks then track
673 * is added to the end of the insertion list
674 * PLAYLIST_INSERT_FIRST - Add track immediately after current song, no
675 * matter what other tracks have been inserted
676 * PLAYLIST_INSERT_LAST - Add track to end of playlist
677 * PLAYLIST_INSERT_SHUFFLED - Add track at some random point between the
678 * current playing track and end of playlist
679 * PLAYLIST_INSERT_LAST_SHUFFLED - Add tracks in random order to the end of
681 * PLAYLIST_REPLACE - Erase current playlist, Cue the current track
682 * and inster this track at the end.
684 static int add_track_to_playlist(struct playlist_info
* playlist
,
685 const char *filename
, int position
,
686 bool queue
, int seek_pos
)
688 int insert_position
, orig_position
;
689 unsigned long flags
= PLAYLIST_INSERT_TYPE_INSERT
;
692 insert_position
= orig_position
= position
;
694 if (playlist
->amount
>= playlist
->max_playlist_size
)
696 display_buffer_full();
702 case PLAYLIST_PREPEND
:
703 position
= insert_position
= playlist
->first_index
;
705 case PLAYLIST_INSERT
:
706 /* if there are already inserted tracks then add track to end of
707 insertion list else add after current playing track */
708 if (playlist
->last_insert_pos
>= 0 &&
709 playlist
->last_insert_pos
< playlist
->amount
&&
710 (playlist
->indices
[playlist
->last_insert_pos
]&
711 PLAYLIST_INSERT_TYPE_MASK
) == PLAYLIST_INSERT_TYPE_INSERT
)
712 position
= insert_position
= playlist
->last_insert_pos
+1;
713 else if (playlist
->amount
> 0)
714 position
= insert_position
= playlist
->index
+ 1;
716 position
= insert_position
= 0;
718 playlist
->last_insert_pos
= position
;
720 case PLAYLIST_INSERT_FIRST
:
721 if (playlist
->amount
> 0)
722 position
= insert_position
= playlist
->index
+ 1;
724 position
= insert_position
= 0;
726 playlist
->last_insert_pos
= position
;
728 case PLAYLIST_INSERT_LAST
:
729 if (playlist
->first_index
> 0)
730 position
= insert_position
= playlist
->first_index
;
732 position
= insert_position
= playlist
->amount
;
734 playlist
->last_insert_pos
= position
;
736 case PLAYLIST_INSERT_SHUFFLED
:
738 if (playlist
->started
)
741 int n
= playlist
->amount
-
742 rotate_index(playlist
, playlist
->index
);
749 position
= playlist
->index
+ offset
+ 1;
750 if (position
>= playlist
->amount
)
751 position
-= playlist
->amount
;
753 insert_position
= position
;
756 position
= insert_position
= (rand() % (playlist
->amount
+1));
759 case PLAYLIST_INSERT_LAST_SHUFFLED
:
761 position
= insert_position
= playlist
->last_shuffled_start
+
762 rand() % (playlist
->amount
- playlist
->last_shuffled_start
+ 1);
765 case PLAYLIST_REPLACE
:
766 if (playlist_remove_all_tracks(playlist
) < 0)
769 playlist
->last_insert_pos
= position
= insert_position
= playlist
->index
+ 1;
774 flags
|= PLAYLIST_QUEUED
;
776 /* shift indices so that track can be added */
777 for (i
=playlist
->amount
; i
>insert_position
; i
--)
779 playlist
->indices
[i
] = playlist
->indices
[i
-1];
781 if (playlist
->filenames
)
782 playlist
->filenames
[i
] = playlist
->filenames
[i
-1];
786 /* update stored indices if needed */
788 if (orig_position
< 0)
790 if (playlist
->amount
> 0 && insert_position
<= playlist
->index
&&
794 if (playlist
->amount
> 0 && insert_position
<= playlist
->first_index
&&
795 orig_position
!= PLAYLIST_PREPEND
&& playlist
->started
)
796 playlist
->first_index
++;
799 if (insert_position
< playlist
->last_insert_pos
||
800 (insert_position
== playlist
->last_insert_pos
&& position
< 0))
801 playlist
->last_insert_pos
++;
803 if (seek_pos
< 0 && playlist
->control_fd
>= 0)
805 int result
= update_control(playlist
,
806 (queue
?PLAYLIST_COMMAND_QUEUE
:PLAYLIST_COMMAND_ADD
), position
,
807 playlist
->last_insert_pos
, filename
, NULL
, &seek_pos
);
813 playlist
->indices
[insert_position
] = flags
| seek_pos
;
816 if (playlist
->filenames
)
817 playlist
->filenames
[insert_position
] = NULL
;
821 playlist
->num_inserted_tracks
++;
823 return insert_position
;
827 * Callback for playlist_directory_tracksearch to insert track into
830 static int directory_search_callback(char* filename
, void* context
)
832 struct directory_search_context
* c
=
833 (struct directory_search_context
*) context
;
836 insert_pos
= add_track_to_playlist(c
->playlist
, filename
, c
->position
,
844 /* Make sure tracks are inserted in correct order if user requests
846 if (c
->position
== PLAYLIST_INSERT_FIRST
|| c
->position
>= 0)
847 c
->position
= insert_pos
+ 1;
849 if (((c
->count
)%PLAYLIST_DISPLAY_COUNT
) == 0)
851 unsigned char* count_str
;
854 count_str
= ID2P(LANG_PLAYLIST_QUEUE_COUNT
);
856 count_str
= ID2P(LANG_PLAYLIST_INSERT_COUNT
);
858 display_playlist_count(c
->count
, count_str
, false);
860 if ((c
->count
) == PLAYLIST_DISPLAY_COUNT
&&
861 (audio_status() & AUDIO_STATUS_PLAY
) &&
862 c
->playlist
->started
)
863 audio_flush_and_reload_tracks();
870 * remove track at specified position
872 static int remove_track_from_playlist(struct playlist_info
* playlist
,
873 int position
, bool write
)
878 if (playlist
->amount
<= 0)
881 inserted
= playlist
->indices
[position
] & PLAYLIST_INSERT_TYPE_MASK
;
883 /* shift indices now that track has been removed */
884 for (i
=position
; i
<playlist
->amount
; i
++)
886 playlist
->indices
[i
] = playlist
->indices
[i
+1];
888 if (playlist
->filenames
)
889 playlist
->filenames
[i
] = playlist
->filenames
[i
+1];
896 playlist
->num_inserted_tracks
--;
898 playlist
->deleted
= true;
900 /* update stored indices if needed */
901 if (position
< playlist
->index
)
904 if (position
< playlist
->first_index
)
906 playlist
->first_index
--;
909 if (position
<= playlist
->last_insert_pos
)
910 playlist
->last_insert_pos
--;
912 if (write
&& playlist
->control_fd
>= 0)
914 int result
= update_control(playlist
, PLAYLIST_COMMAND_DELETE
,
915 position
, -1, NULL
, NULL
, NULL
);
920 sync_control(playlist
, false);
927 * randomly rearrange the array of indices for the playlist. If start_current
928 * is true then update the index to the new index of the current playing track
930 static int randomise_playlist(struct playlist_info
* playlist
,
931 unsigned int seed
, bool start_current
,
937 unsigned int current
= playlist
->indices
[playlist
->index
];
939 /* seed 0 is used to identify sorted playlist for resume purposes */
943 /* seed with the given seed */
946 /* randomise entire indices list */
947 for(count
= playlist
->amount
- 1; count
>= 0; count
--)
949 /* the rand is from 0 to RAND_MAX, so adjust to our value range */
950 candidate
= rand() % (count
+ 1);
952 /* now swap the values at the 'count' and 'candidate' positions */
953 store
= playlist
->indices
[candidate
];
954 playlist
->indices
[candidate
] = playlist
->indices
[count
];
955 playlist
->indices
[count
] = store
;
957 if (playlist
->filenames
)
959 store
= (long)playlist
->filenames
[candidate
];
960 playlist
->filenames
[candidate
] = playlist
->filenames
[count
];
961 playlist
->filenames
[count
] = (struct dircache_entry
*)store
;
967 find_and_set_playlist_index(playlist
, current
);
969 /* indices have been moved so last insert position is no longer valid */
970 playlist
->last_insert_pos
= -1;
972 playlist
->seed
= seed
;
973 if (playlist
->num_inserted_tracks
> 0 || playlist
->deleted
)
974 playlist
->shuffle_modified
= true;
978 update_control(playlist
, PLAYLIST_COMMAND_SHUFFLE
, seed
,
979 playlist
->first_index
, NULL
, NULL
, NULL
);
986 * Sort the array of indices for the playlist. If start_current is true then
987 * set the index to the new index of the current song.
988 * Also while going to unshuffled mode set the first_index to 0.
990 static int sort_playlist(struct playlist_info
* playlist
, bool start_current
,
993 unsigned int current
= playlist
->indices
[playlist
->index
];
995 if (playlist
->amount
> 0)
996 qsort(playlist
->indices
, playlist
->amount
,
997 sizeof(playlist
->indices
[0]), compare
);
1000 /** We need to re-check the song names from disk because qsort can't
1001 * sort two arrays at once :/
1002 * FIXME: Please implement a better way to do this. */
1003 memset(playlist
->filenames
, 0, playlist
->max_playlist_size
* sizeof(int));
1004 queue_post(&playlist_queue
, PLAYLIST_LOAD_POINTERS
, 0);
1008 find_and_set_playlist_index(playlist
, current
);
1010 /* indices have been moved so last insert position is no longer valid */
1011 playlist
->last_insert_pos
= -1;
1013 if (!playlist
->num_inserted_tracks
&& !playlist
->deleted
)
1014 playlist
->shuffle_modified
= false;
1015 if (write
&& playlist
->control_fd
>= 0)
1017 playlist
->first_index
= 0;
1018 update_control(playlist
, PLAYLIST_COMMAND_UNSHUFFLE
,
1019 playlist
->first_index
, -1, NULL
, NULL
, NULL
);
1025 /* Calculate how many steps we have to really step when skipping entries
1028 static int calculate_step_count(const struct playlist_info
*playlist
, int steps
)
1030 int i
, count
, direction
;
1032 int stepped_count
= 0;
1045 index
= playlist
->index
;
1048 /* Boundary check */
1050 index
+= playlist
->amount
;
1051 if (index
>= playlist
->amount
)
1052 index
-= playlist
->amount
;
1054 /* Check if we found a bad entry. */
1055 if (playlist
->indices
[index
] & PLAYLIST_SKIPPED
)
1058 /* Are all entries bad? */
1059 if (stepped_count
++ > playlist
->amount
)
1066 } while (i
<= count
);
1071 /* Marks the index of the track to be skipped that is "steps" away from
1072 * current playing track.
1074 void playlist_skip_entry(struct playlist_info
*playlist
, int steps
)
1078 if (playlist
== NULL
)
1079 playlist
= ¤t_playlist
;
1081 /* need to account for already skipped tracks */
1082 steps
= calculate_step_count(playlist
, steps
);
1084 index
= playlist
->index
+ steps
;
1086 index
+= playlist
->amount
;
1087 else if (index
>= playlist
->amount
)
1088 index
-= playlist
->amount
;
1090 playlist
->indices
[index
] |= PLAYLIST_SKIPPED
;
1094 * returns the index of the track that is "steps" away from current playing
1097 static int get_next_index(const struct playlist_info
* playlist
, int steps
,
1100 int current_index
= playlist
->index
;
1101 int next_index
= -1;
1103 if (playlist
->amount
<= 0)
1106 if (repeat_mode
== -1)
1107 repeat_mode
= global_settings
.repeat_mode
;
1109 if (repeat_mode
== REPEAT_SHUFFLE
&& playlist
->amount
<= 1)
1110 repeat_mode
= REPEAT_ALL
;
1112 steps
= calculate_step_count(playlist
, steps
);
1113 switch (repeat_mode
)
1115 case REPEAT_SHUFFLE
:
1116 /* Treat repeat shuffle just like repeat off. At end of playlist,
1117 play will be resumed in playlist_next() */
1120 current_index
= rotate_index(playlist
, current_index
);
1121 next_index
= current_index
+steps
;
1122 if ((next_index
< 0) || (next_index
>= playlist
->amount
))
1125 next_index
= (next_index
+playlist
->first_index
) %
1132 #ifdef AB_REPEAT_ENABLE
1135 next_index
= current_index
;
1141 next_index
= (current_index
+steps
) % playlist
->amount
;
1142 while (next_index
< 0)
1143 next_index
+= playlist
->amount
;
1145 if (steps
>= playlist
->amount
)
1152 /* second time around so skip the queued files */
1153 for (i
=0; i
<playlist
->amount
; i
++)
1155 if (playlist
->indices
[index
] & PLAYLIST_QUEUE_MASK
)
1156 index
= (index
+1) % playlist
->amount
;
1168 /* No luck if the whole playlist was bad. */
1169 if (playlist
->indices
[next_index
] & PLAYLIST_SKIPPED
)
1176 * Search for the seek track and set appropriate indices. Used after shuffle
1177 * to make sure the current index is still pointing to correct track.
1179 static void find_and_set_playlist_index(struct playlist_info
* playlist
,
1184 /* Set the index to the current song */
1185 for (i
=0; i
<playlist
->amount
; i
++)
1187 if (playlist
->indices
[i
] == seek
)
1189 playlist
->index
= playlist
->first_index
= i
;
1197 * used to sort track indices. Sort order is as follows:
1198 * 1. Prepended tracks (in prepend order)
1199 * 2. Playlist/directory tracks (in playlist order)
1200 * 3. Inserted/Appended tracks (in insert order)
1202 static int compare(const void* p1
, const void* p2
)
1204 unsigned long* e1
= (unsigned long*) p1
;
1205 unsigned long* e2
= (unsigned long*) p2
;
1206 unsigned long flags1
= *e1
& PLAYLIST_INSERT_TYPE_MASK
;
1207 unsigned long flags2
= *e2
& PLAYLIST_INSERT_TYPE_MASK
;
1209 if (flags1
== flags2
)
1210 return (*e1
& PLAYLIST_SEEK_MASK
) - (*e2
& PLAYLIST_SEEK_MASK
);
1211 else if (flags1
== PLAYLIST_INSERT_TYPE_PREPEND
||
1212 flags2
== PLAYLIST_INSERT_TYPE_APPEND
)
1214 else if (flags1
== PLAYLIST_INSERT_TYPE_APPEND
||
1215 flags2
== PLAYLIST_INSERT_TYPE_PREPEND
)
1217 else if (flags1
&& flags2
)
1218 return (*e1
& PLAYLIST_SEEK_MASK
) - (*e2
& PLAYLIST_SEEK_MASK
);
1223 #ifdef HAVE_DIRCACHE
1225 * Thread to update filename pointers to dircache on background
1226 * without affecting playlist load up performance. This thread also flushes
1227 * any pending control commands when the disk spins up.
1229 static void playlist_flush_callback(void *param
)
1232 struct playlist_info
*playlist
;
1233 playlist
= ¤t_playlist
;
1234 if (playlist
->control_fd
>= 0)
1236 if (playlist
->num_cached
> 0)
1238 mutex_lock(playlist
->control_mutex
);
1239 flush_cached_control(playlist
);
1240 mutex_unlock(playlist
->control_mutex
);
1242 sync_control(playlist
, true);
1246 static void playlist_thread(void)
1248 struct queue_event ev
;
1249 bool dirty_pointers
= false;
1250 static char tmp
[MAX_PATH
+1];
1252 struct playlist_info
*playlist
;
1259 #ifdef HAVE_DISK_STORAGE
1260 if (global_settings
.disk_spindown
> 1 &&
1261 global_settings
.disk_spindown
<= 5)
1262 sleep_time
= global_settings
.disk_spindown
- 1;
1267 queue_wait_w_tmo(&playlist_queue
, &ev
, HZ
*sleep_time
);
1271 case PLAYLIST_LOAD_POINTERS
:
1272 dirty_pointers
= true;
1275 /* Start the background scanning after either the disk spindown
1276 timeout or 5s, whichever is less */
1278 playlist
= ¤t_playlist
;
1279 if (playlist
->control_fd
>= 0)
1281 if (playlist
->num_cached
> 0)
1282 register_storage_idle_func(playlist_flush_callback
);
1285 if (!dirty_pointers
)
1288 if (!dircache_is_enabled() || !playlist
->filenames
1289 || playlist
->amount
<= 0)
1292 #ifdef HAVE_ADJUSTABLE_CPU_FREQ
1295 for (index
= 0; index
< playlist
->amount
1296 && queue_empty(&playlist_queue
); index
++)
1298 /* Process only pointers that are not already loaded. */
1299 if (playlist
->filenames
[index
])
1302 control_file
= playlist
->indices
[index
] & PLAYLIST_INSERT_TYPE_MASK
;
1303 seek
= playlist
->indices
[index
] & PLAYLIST_SEEK_MASK
;
1305 /* Load the filename from playlist file. */
1306 if (get_filename(playlist
, index
, seek
, control_file
, tmp
,
1310 /* Set the dircache entry pointer. */
1311 playlist
->filenames
[index
] = dircache_get_entry_ptr(tmp
);
1313 /* And be on background so user doesn't notice any delays. */
1317 #ifdef HAVE_ADJUSTABLE_CPU_FREQ
1320 dirty_pointers
= false;
1323 #if (CONFIG_PLATFORM & PLATFORM_NATIVE)
1324 case SYS_USB_CONNECTED
:
1325 usb_acknowledge(SYS_USB_CONNECTED_ACK
);
1326 usb_wait_for_disconnect(&playlist_queue
);
1335 * gets pathname for track at seek index
1337 static int get_filename(struct playlist_info
* playlist
, int index
, int seek
,
1338 bool control_file
, char *buf
, int buf_length
)
1342 char tmp_buf
[MAX_PATH
+1];
1343 char dir_buf
[MAX_PATH
+1];
1344 bool utf8
= playlist
->utf8
;
1346 if (buf_length
> MAX_PATH
+1)
1347 buf_length
= MAX_PATH
+1;
1349 #ifdef HAVE_DIRCACHE
1350 if (dircache_is_enabled() && playlist
->filenames
)
1352 if (playlist
->filenames
[index
] != NULL
)
1354 dircache_copy_path(playlist
->filenames
[index
], tmp_buf
, sizeof(tmp_buf
)-1);
1355 max
= strlen(tmp_buf
);
1362 if (playlist
->in_ram
&& !control_file
&& max
< 0)
1364 max
= strlcpy(tmp_buf
, &playlist
->buffer
[seek
], sizeof(tmp_buf
));
1368 mutex_lock(playlist
->control_mutex
);
1372 fd
= playlist
->control_fd
;
1377 if(-1 == playlist
->fd
)
1378 playlist
->fd
= open(playlist
->filename
, O_RDONLY
);
1386 if (lseek(fd
, seek
, SEEK_SET
) != seek
)
1390 max
= read(fd
, tmp_buf
, MIN((size_t) buf_length
, sizeof(tmp_buf
)));
1392 if ((max
> 0) && !utf8
)
1394 /* Use dir_buf as a temporary buffer. Note that dir_buf must
1395 * be as large as tmp_buf.
1397 max
= convert_m3u(tmp_buf
, max
, sizeof(tmp_buf
), dir_buf
);
1402 mutex_unlock(playlist
->control_mutex
);
1407 splash(HZ
*2, ID2P(LANG_PLAYLIST_CONTROL_ACCESS_ERROR
));
1409 splash(HZ
*2, ID2P(LANG_PLAYLIST_ACCESS_ERROR
));
1415 strlcpy(dir_buf
, playlist
->filename
, playlist
->dirlen
);
1417 return (format_track_path(buf
, tmp_buf
, buf_length
, max
, dir_buf
));
1420 static int get_next_directory(char *dir
){
1421 return get_next_dir(dir
,true,false);
1424 static int get_previous_directory(char *dir
){
1425 return get_next_dir(dir
,false,false);
1429 * search through all the directories (starting with the current) to find
1430 * one that has tracks to play
1432 static int get_next_dir(char *dir
, bool is_forward
, bool recursion
)
1434 struct playlist_info
* playlist
= ¤t_playlist
;
1436 char *start_dir
= NULL
;
1439 struct tree_context
* tc
= tree_get_context();
1440 int saved_dirfilter
= *(tc
->dirfilter
);
1442 /* process random folder advance */
1443 if (global_settings
.next_folder
== FOLDER_ADVANCE_RANDOM
)
1445 int fd
= open(ROCKBOX_DIR
"/folder_advance_list.dat", O_RDONLY
);
1448 char buffer
[MAX_PATH
];
1449 int folder_count
= 0;
1450 srand(current_tick
);
1451 *(tc
->dirfilter
) = SHOW_MUSIC
;
1452 tc
->sort_dir
= global_settings
.sort_dir
;
1453 read(fd
,&folder_count
,sizeof(int));
1458 i
= rand()%folder_count
;
1459 lseek(fd
,sizeof(int) + (MAX_PATH
*i
),SEEK_SET
);
1460 read(fd
,buffer
,MAX_PATH
);
1461 if (check_subdir_for_music(buffer
, "", false) ==0)
1467 *(tc
->dirfilter
) = saved_dirfilter
;
1468 tc
->sort_dir
= global_settings
.sort_dir
;
1474 /* not random folder advance (or random folder advance unavailable) */
1477 /* start with root */
1482 /* start with current directory */
1483 strlcpy(dir
, playlist
->filename
, playlist
->dirlen
);
1486 /* use the tree browser dircache to load files */
1487 *(tc
->dirfilter
) = SHOW_ALL
;
1489 /* set up sorting/direction */
1490 tc
->sort_dir
= global_settings
.sort_dir
;
1493 static const char sortpairs
[] =
1495 [SORT_ALPHA
] = SORT_ALPHA_REVERSED
,
1496 [SORT_DATE
] = SORT_DATE_REVERSED
,
1497 [SORT_TYPE
] = SORT_TYPE_REVERSED
,
1498 [SORT_ALPHA_REVERSED
] = SORT_ALPHA
,
1499 [SORT_DATE_REVERSED
] = SORT_DATE
,
1500 [SORT_TYPE_REVERSED
] = SORT_TYPE
,
1503 if ((unsigned)tc
->sort_dir
< sizeof(sortpairs
))
1504 tc
->sort_dir
= sortpairs
[tc
->sort_dir
];
1509 struct entry
*files
;
1513 if (ft_load(tc
, (dir
[0]=='\0')?"/":dir
) < 0)
1520 files
= (struct entry
*) tc
->dircache
;
1521 num_files
= tc
->filesindir
;
1523 for (i
=0; i
<num_files
; i
++)
1526 if (action_userabort(TIMEOUT_NOBLOCK
))
1533 if (files
[i
].attr
& ATTR_DIRECTORY
)
1537 result
= check_subdir_for_music(dir
, files
[i
].name
, true);
1544 else if (!strcmp(start_dir
, files
[i
].name
))
1551 /* move down to parent directory. current directory name is
1552 stored as the starting point for the search in parent */
1553 start_dir
= strrchr(dir
, '/');
1564 /* restore dirfilter */
1565 *(tc
->dirfilter
) = saved_dirfilter
;
1566 tc
->sort_dir
= global_settings
.sort_dir
;
1568 /* special case if nothing found: try start searching again from root */
1569 if (result
== -1 && !recursion
){
1570 result
= get_next_dir(dir
, is_forward
, true);
1577 * Checks if there are any music files in the dir or any of its
1578 * subdirectories. May be called recursively.
1580 static int check_subdir_for_music(char *dir
, const char *subdir
, bool recurse
)
1583 int dirlen
= strlen(dir
);
1586 struct entry
*files
;
1587 bool has_music
= false;
1588 bool has_subdir
= false;
1589 struct tree_context
* tc
= tree_get_context();
1591 snprintf(dir
+dirlen
, MAX_PATH
-dirlen
, "/%s", subdir
);
1593 if (ft_load(tc
, dir
) < 0)
1598 files
= (struct entry
*) tc
->dircache
;
1599 num_files
= tc
->filesindir
;
1601 for (i
=0; i
<num_files
; i
++)
1603 if (files
[i
].attr
& ATTR_DIRECTORY
)
1605 else if ((files
[i
].attr
& FILE_ATTR_MASK
) == FILE_ATTR_AUDIO
)
1615 if (has_subdir
&& recurse
)
1617 for (i
=0; i
<num_files
; i
++)
1619 if (action_userabort(TIMEOUT_NOBLOCK
))
1625 if (files
[i
].attr
& ATTR_DIRECTORY
)
1627 result
= check_subdir_for_music(dir
, files
[i
].name
, true);
1645 /* we now need to reload our current directory */
1646 if(ft_load(tc
, dir
) < 0)
1647 splash(HZ
*2, ID2P(LANG_PLAYLIST_DIRECTORY_ACCESS_ERROR
));
1653 * Returns absolute path of track
1655 static int format_track_path(char *dest
, char *src
, int buf_length
, int max
,
1662 /* Look for the end of the string */
1669 /* Now work back killing white space */
1671 ((src
[i
-1] == ' ') ||
1672 (src
[i
-1] == '\t')))
1675 /* Zero-terminate the file name */
1678 /* replace backslashes with forward slashes */
1679 for ( j
=0; j
<i
; j
++ )
1680 if ( src
[j
] == '\\' )
1685 strlcpy(dest
, src
, buf_length
);
1689 /* handle dos style drive letter */
1691 strlcpy(dest
, &src
[2], buf_length
);
1692 else if (!strncmp(src
, "../", 3))
1694 /* handle relative paths */
1696 while(!strncmp(&src
[i
], "../", 3))
1698 for (j
=0; j
<i
/3; j
++) {
1699 temp_ptr
= strrchr(dir
, '/');
1705 snprintf(dest
, buf_length
, "%s/%s", dir
, &src
[i
]);
1707 else if ( '.' == src
[0] && '/' == src
[1] ) {
1708 snprintf(dest
, buf_length
, "%s/%s", dir
, &src
[2]);
1711 snprintf(dest
, buf_length
, "%s/%s", dir
, src
);
1719 * Display splash message showing progress of playlist/directory insertion or
1722 static void display_playlist_count(int count
, const unsigned char *fmt
,
1725 static long talked_tick
= 0;
1726 long id
= P2ID(fmt
);
1727 if(global_settings
.talk_menu
&& id
>=0)
1729 if(final
|| (count
&& (talked_tick
== 0
1730 || TIME_AFTER(current_tick
, talked_tick
+5*HZ
))))
1732 talked_tick
= current_tick
;
1733 talk_number(count
, false);
1739 splashf(0, fmt
, count
, str(LANG_OFF_ABORT
));
1743 * Display buffer full message
1745 static void display_buffer_full(void)
1747 splash(HZ
*2, ID2P(LANG_PLAYLIST_BUFFER_FULL
));
1751 * Flush any cached control commands to disk. Called when playlist is being
1752 * modified. Returns 0 on success and -1 on failure.
1754 static int flush_cached_control(struct playlist_info
* playlist
)
1759 if (!playlist
->num_cached
)
1762 lseek(playlist
->control_fd
, 0, SEEK_END
);
1764 for (i
=0; i
<playlist
->num_cached
; i
++)
1766 struct playlist_control_cache
* cache
=
1767 &(playlist
->control_cache
[i
]);
1769 switch (cache
->command
)
1771 case PLAYLIST_COMMAND_PLAYLIST
:
1772 result
= fdprintf(playlist
->control_fd
, "P:%d:%s:%s\n",
1773 cache
->i1
, cache
->s1
, cache
->s2
);
1775 case PLAYLIST_COMMAND_ADD
:
1776 case PLAYLIST_COMMAND_QUEUE
:
1777 result
= fdprintf(playlist
->control_fd
, "%c:%d:%d:",
1778 (cache
->command
== PLAYLIST_COMMAND_ADD
)?'A':'Q',
1779 cache
->i1
, cache
->i2
);
1782 /* save the position in file where name is written */
1783 int* seek_pos
= (int *)cache
->data
;
1784 *seek_pos
= lseek(playlist
->control_fd
, 0, SEEK_CUR
);
1785 result
= fdprintf(playlist
->control_fd
, "%s\n",
1789 case PLAYLIST_COMMAND_DELETE
:
1790 result
= fdprintf(playlist
->control_fd
, "D:%d\n", cache
->i1
);
1792 case PLAYLIST_COMMAND_SHUFFLE
:
1793 result
= fdprintf(playlist
->control_fd
, "S:%d:%d\n",
1794 cache
->i1
, cache
->i2
);
1796 case PLAYLIST_COMMAND_UNSHUFFLE
:
1797 result
= fdprintf(playlist
->control_fd
, "U:%d\n", cache
->i1
);
1799 case PLAYLIST_COMMAND_RESET
:
1800 result
= fdprintf(playlist
->control_fd
, "R\n");
1812 playlist
->num_cached
= 0;
1813 playlist
->pending_control_sync
= true;
1820 splash(HZ
*2, ID2P(LANG_PLAYLIST_CONTROL_UPDATE_ERROR
));
1827 * Update control data with new command. Depending on the command, it may be
1828 * cached or flushed to disk.
1830 static int update_control(struct playlist_info
* playlist
,
1831 enum playlist_command command
, int i1
, int i2
,
1832 const char* s1
, const char* s2
, void* data
)
1835 struct playlist_control_cache
* cache
;
1838 mutex_lock(playlist
->control_mutex
);
1840 cache
= &(playlist
->control_cache
[playlist
->num_cached
++]);
1842 cache
->command
= command
;
1851 case PLAYLIST_COMMAND_PLAYLIST
:
1852 case PLAYLIST_COMMAND_ADD
:
1853 case PLAYLIST_COMMAND_QUEUE
:
1854 #ifndef HAVE_DIRCACHE
1855 case PLAYLIST_COMMAND_DELETE
:
1856 case PLAYLIST_COMMAND_RESET
:
1860 case PLAYLIST_COMMAND_SHUFFLE
:
1861 case PLAYLIST_COMMAND_UNSHUFFLE
:
1863 /* only flush when needed */
1867 if (flush
|| playlist
->num_cached
== PLAYLIST_MAX_CACHE
)
1868 result
= flush_cached_control(playlist
);
1870 mutex_unlock(playlist
->control_mutex
);
1876 * sync control file to disk
1878 static void sync_control(struct playlist_info
* playlist
, bool force
)
1880 #ifdef HAVE_DIRCACHE
1881 if (playlist
->started
&& force
)
1885 if (playlist
->started
)
1888 if (playlist
->pending_control_sync
)
1890 mutex_lock(playlist
->control_mutex
);
1891 fsync(playlist
->control_fd
);
1892 playlist
->pending_control_sync
= false;
1893 mutex_unlock(playlist
->control_mutex
);
1899 * Rotate indices such that first_index is index 0
1901 static int rotate_index(const struct playlist_info
* playlist
, int index
)
1903 index
-= playlist
->first_index
;
1905 index
+= playlist
->amount
;
1911 * Initialize playlist entries at startup
1913 void playlist_init(void)
1915 struct playlist_info
* playlist
= ¤t_playlist
;
1917 mutex_init(¤t_playlist_mutex
);
1918 mutex_init(&created_playlist_mutex
);
1920 playlist
->current
= true;
1921 strlcpy(playlist
->control_filename
, PLAYLIST_CONTROL_FILE
,
1922 sizeof(playlist
->control_filename
));
1924 playlist
->control_fd
= -1;
1925 playlist
->max_playlist_size
= global_settings
.max_files_in_playlist
;
1926 playlist
->indices
= buffer_alloc(
1927 playlist
->max_playlist_size
* sizeof(int));
1928 playlist
->buffer_size
=
1929 AVERAGE_FILENAME_LENGTH
* global_settings
.max_files_in_dir
;
1930 playlist
->buffer
= buffer_alloc(playlist
->buffer_size
);
1931 playlist
->control_mutex
= ¤t_playlist_mutex
;
1933 empty_playlist(playlist
, true);
1935 #ifdef HAVE_DIRCACHE
1936 playlist
->filenames
= buffer_alloc(
1937 playlist
->max_playlist_size
* sizeof(int));
1938 memset(playlist
->filenames
, 0,
1939 playlist
->max_playlist_size
* sizeof(int));
1940 create_thread(playlist_thread
, playlist_stack
, sizeof(playlist_stack
),
1941 0, playlist_thread_name
IF_PRIO(, PRIORITY_BACKGROUND
)
1943 queue_init(&playlist_queue
, true);
1948 * Clean playlist at shutdown
1950 void playlist_shutdown(void)
1952 struct playlist_info
* playlist
= ¤t_playlist
;
1954 if (playlist
->control_fd
>= 0)
1956 mutex_lock(playlist
->control_mutex
);
1958 if (playlist
->num_cached
> 0)
1959 flush_cached_control(playlist
);
1961 close(playlist
->control_fd
);
1963 mutex_unlock(playlist
->control_mutex
);
1968 * Create new playlist
1970 int playlist_create(const char *dir
, const char *file
)
1972 struct playlist_info
* playlist
= ¤t_playlist
;
1974 new_playlist(playlist
, dir
, file
);
1977 /* load the playlist file */
1978 add_indices_to_playlist(playlist
, NULL
, 0);
1983 #define PLAYLIST_COMMAND_SIZE (MAX_PATH+12)
1986 * Restore the playlist state based on control file commands. Called to
1987 * resume playback after shutdown.
1989 int playlist_resume(void)
1991 struct playlist_info
* playlist
= ¤t_playlist
;
1996 int control_file_size
= 0;
2000 /* use mp3 buffer for maximum load speed */
2001 #if CONFIG_CODEC != SWCODEC
2002 talk_buffer_steal(); /* we use the mp3 buffer, need to tell */
2003 buflen
= (audiobufend
- audiobuf
);
2004 buffer
= (char *)audiobuf
;
2006 buffer
= (char *)audio_get_buffer(false, &buflen
);
2009 empty_playlist(playlist
, true);
2011 splash(0, ID2P(LANG_WAIT
));
2012 playlist
->control_fd
= open(playlist
->control_filename
, O_RDWR
);
2013 if (playlist
->control_fd
< 0)
2015 splash(HZ
*2, ID2P(LANG_PLAYLIST_CONTROL_ACCESS_ERROR
));
2018 playlist
->control_created
= true;
2020 control_file_size
= filesize(playlist
->control_fd
);
2021 if (control_file_size
<= 0)
2023 splash(HZ
*2, ID2P(LANG_PLAYLIST_CONTROL_ACCESS_ERROR
));
2027 /* read a small amount first to get the header */
2028 nread
= read(playlist
->control_fd
, buffer
,
2029 PLAYLIST_COMMAND_SIZE
<buflen
?PLAYLIST_COMMAND_SIZE
:buflen
);
2032 splash(HZ
*2, ID2P(LANG_PLAYLIST_CONTROL_ACCESS_ERROR
));
2036 playlist
->started
= true;
2042 enum playlist_command current_command
= PLAYLIST_COMMAND_COMMENT
;
2043 int last_newline
= 0;
2045 bool newline
= true;
2046 bool exit_loop
= false;
2051 unsigned long last_tick
= current_tick
;
2052 bool useraborted
= false;
2054 for(count
=0; count
<nread
&& !exit_loop
&& !useraborted
; count
++,p
++)
2056 /* So a splash while we are loading. */
2057 if (TIME_AFTER(current_tick
, last_tick
+ HZ
/4))
2059 splashf(0, str(LANG_LOADING_PERCENT
),
2060 (total_read
+count
)*100/control_file_size
,
2061 str(LANG_OFF_ABORT
));
2062 if (action_userabort(TIMEOUT_NOBLOCK
))
2067 last_tick
= current_tick
;
2070 /* Are we on a new line? */
2071 if((*p
== '\n') || (*p
== '\r'))
2075 /* save last_newline in case we need to load more data */
2076 last_newline
= count
;
2078 switch (current_command
)
2080 case PLAYLIST_COMMAND_PLAYLIST
:
2082 /* str1=version str2=dir str3=file */
2098 version
= atoi(str1
);
2100 if (version
!= PLAYLIST_CONTROL_FILE_VERSION
)
2103 update_playlist_filename(playlist
, str2
, str3
);
2105 if (str3
[0] != '\0')
2107 /* NOTE: add_indices_to_playlist() overwrites the
2108 audiobuf so we need to reload control file
2110 add_indices_to_playlist(playlist
, NULL
, 0);
2112 else if (str2
[0] != '\0')
2114 playlist
->in_ram
= true;
2115 resume_directory(str2
);
2118 /* load the rest of the data */
2124 case PLAYLIST_COMMAND_ADD
:
2125 case PLAYLIST_COMMAND_QUEUE
:
2127 /* str1=position str2=last_position str3=file */
2128 int position
, last_position
;
2131 if (!str1
|| !str2
|| !str3
)
2138 position
= atoi(str1
);
2139 last_position
= atoi(str2
);
2141 queue
= (current_command
== PLAYLIST_COMMAND_ADD
)?
2144 /* seek position is based on str3's position in
2146 if (add_track_to_playlist(playlist
, str3
, position
,
2147 queue
, total_read
+(str3
-buffer
)) < 0)
2150 playlist
->last_insert_pos
= last_position
;
2154 case PLAYLIST_COMMAND_DELETE
:
2166 position
= atoi(str1
);
2168 if (remove_track_from_playlist(playlist
, position
,
2174 case PLAYLIST_COMMAND_SHUFFLE
:
2176 /* str1=seed str2=first_index */
2188 /* Always sort list before shuffling */
2189 sort_playlist(playlist
, false, false);
2193 playlist
->first_index
= atoi(str2
);
2195 if (randomise_playlist(playlist
, seed
, false,
2201 case PLAYLIST_COMMAND_UNSHUFFLE
:
2203 /* str1=first_index */
2211 playlist
->first_index
= atoi(str1
);
2213 if (sort_playlist(playlist
, false, false) < 0)
2219 case PLAYLIST_COMMAND_RESET
:
2221 playlist
->last_insert_pos
= -1;
2224 case PLAYLIST_COMMAND_COMMENT
:
2231 /* to ignore any extra newlines */
2232 current_command
= PLAYLIST_COMMAND_COMMENT
;
2238 /* first non-comment line must always specify playlist */
2239 if (first
&& *p
!= 'P' && *p
!= '#')
2249 /* playlist can only be specified once */
2257 current_command
= PLAYLIST_COMMAND_PLAYLIST
;
2260 current_command
= PLAYLIST_COMMAND_ADD
;
2263 current_command
= PLAYLIST_COMMAND_QUEUE
;
2266 current_command
= PLAYLIST_COMMAND_DELETE
;
2269 current_command
= PLAYLIST_COMMAND_SHUFFLE
;
2272 current_command
= PLAYLIST_COMMAND_UNSHUFFLE
;
2275 current_command
= PLAYLIST_COMMAND_RESET
;
2278 current_command
= PLAYLIST_COMMAND_COMMENT
;
2291 else if(current_command
!= PLAYLIST_COMMAND_COMMENT
)
2293 /* all control file strings are separated with a colon.
2294 Replace the colon with 0 to get proper strings that can be
2295 used by commands above */
2301 if ((count
+1) < nread
)
2315 /* allow last string to contain colons */
2326 splash(HZ
*2, ID2P(LANG_PLAYLIST_CONTROL_INVALID
));
2332 splash(HZ
*2, ID2P(LANG_CANCEL
));
2335 if (!newline
|| (exit_loop
&& count
<nread
))
2337 if ((total_read
+ count
) >= control_file_size
)
2339 /* no newline at end of control file */
2340 splash(HZ
*2, ID2P(LANG_PLAYLIST_CONTROL_INVALID
));
2344 /* We didn't end on a newline or we exited loop prematurely.
2345 Either way, re-read the remainder. */
2346 count
= last_newline
;
2347 lseek(playlist
->control_fd
, total_read
+count
, SEEK_SET
);
2350 total_read
+= count
;
2353 /* still looking for header */
2354 nread
= read(playlist
->control_fd
, buffer
,
2355 PLAYLIST_COMMAND_SIZE
<buflen
?PLAYLIST_COMMAND_SIZE
:buflen
);
2357 nread
= read(playlist
->control_fd
, buffer
, buflen
);
2359 /* Terminate on EOF */
2366 #ifdef HAVE_DIRCACHE
2367 queue_post(&playlist_queue
, PLAYLIST_LOAD_POINTERS
, 0);
2374 * Add track to in_ram playlist. Used when playing directories.
2376 int playlist_add(const char *filename
)
2378 struct playlist_info
* playlist
= ¤t_playlist
;
2379 int len
= strlen(filename
);
2381 if((len
+1 > playlist
->buffer_size
- playlist
->buffer_end_pos
) ||
2382 (playlist
->amount
>= playlist
->max_playlist_size
))
2384 display_buffer_full();
2388 playlist
->indices
[playlist
->amount
] = playlist
->buffer_end_pos
;
2389 #ifdef HAVE_DIRCACHE
2390 playlist
->filenames
[playlist
->amount
] = NULL
;
2394 strcpy(&playlist
->buffer
[playlist
->buffer_end_pos
], filename
);
2395 playlist
->buffer_end_pos
+= len
;
2396 playlist
->buffer
[playlist
->buffer_end_pos
++] = '\0';
2401 /* shuffle newly created playlist using random seed. */
2402 int playlist_shuffle(int random_seed
, int start_index
)
2404 struct playlist_info
* playlist
= ¤t_playlist
;
2406 bool start_current
= false;
2408 if (start_index
>= 0 && global_settings
.play_selected
)
2410 /* store the seek position before the shuffle */
2411 playlist
->index
= playlist
->first_index
= start_index
;
2412 start_current
= true;
2415 randomise_playlist(playlist
, random_seed
, start_current
, true);
2417 return playlist
->index
;
2420 /* start playing current playlist at specified index/offset */
2421 void playlist_start(int start_index
, int offset
)
2423 struct playlist_info
* playlist
= ¤t_playlist
;
2425 /* Cancel FM radio selection as previous music. For cases where we start
2426 playback without going to the WPS, such as playlist insert.. or
2427 playlist catalog. */
2428 previous_music_is_wps();
2430 playlist
->index
= start_index
;
2432 #if CONFIG_CODEC != SWCODEC
2433 talk_buffer_steal(); /* will use the mp3 buffer */
2436 playlist
->started
= true;
2437 sync_control(playlist
, false);
2441 /* Returns false if 'steps' is out of bounds, else true */
2442 bool playlist_check(int steps
)
2444 struct playlist_info
* playlist
= ¤t_playlist
;
2446 /* always allow folder navigation */
2447 if (global_settings
.next_folder
&& playlist
->in_ram
)
2450 int index
= get_next_index(playlist
, steps
, -1);
2452 if (index
< 0 && steps
>= 0 && global_settings
.repeat_mode
== REPEAT_SHUFFLE
)
2453 index
= get_next_index(playlist
, steps
, REPEAT_ALL
);
2455 return (index
>= 0);
2458 /* get trackname of track that is "steps" away from current playing track.
2459 NULL is used to identify end of playlist */
2460 const char* playlist_peek(int steps
, char* buf
, size_t buf_size
)
2462 struct playlist_info
* playlist
= ¤t_playlist
;
2468 index
= get_next_index(playlist
, steps
, -1);
2472 control_file
= playlist
->indices
[index
] & PLAYLIST_INSERT_TYPE_MASK
;
2473 seek
= playlist
->indices
[index
] & PLAYLIST_SEEK_MASK
;
2475 if (get_filename(playlist
, index
, seek
, control_file
, buf
,
2481 if (!playlist
->in_ram
|| control_file
)
2483 /* remove bogus dirs from beginning of path
2484 (workaround for buggy playlist creation tools) */
2487 if (file_exists(temp_ptr
))
2490 temp_ptr
= strchr(temp_ptr
+1, '/');
2495 /* Even though this is an invalid file, we still need to pass a
2496 file name to the caller because NULL is used to indicate end
2506 * Update indices as track has changed
2508 int playlist_next(int steps
)
2510 struct playlist_info
* playlist
= ¤t_playlist
;
2514 #ifdef AB_REPEAT_ENABLE
2515 && (global_settings
.repeat_mode
!= REPEAT_AB
)
2517 && (global_settings
.repeat_mode
!= REPEAT_ONE
) )
2521 /* We need to delete all the queued songs */
2522 for (i
=0, j
=steps
; i
<j
; i
++)
2524 index
= get_next_index(playlist
, i
, -1);
2526 if (playlist
->indices
[index
] & PLAYLIST_QUEUE_MASK
)
2528 remove_track_from_playlist(playlist
, index
, true);
2529 steps
--; /* one less track */
2534 index
= get_next_index(playlist
, steps
, -1);
2538 /* end of playlist... or is it */
2539 if (global_settings
.repeat_mode
== REPEAT_SHUFFLE
&&
2540 playlist
->amount
> 1)
2542 /* Repeat shuffle mode. Re-shuffle playlist and resume play */
2543 playlist
->first_index
= 0;
2544 sort_playlist(playlist
, false, false);
2545 randomise_playlist(playlist
, current_tick
, false, true);
2546 #if CONFIG_CODEC != SWCODEC
2547 playlist_start(0, 0);
2549 playlist
->index
= 0;
2552 else if (playlist
->in_ram
&& global_settings
.next_folder
)
2554 index
= create_and_play_dir(steps
, true);
2558 playlist
->index
= index
;
2565 playlist
->index
= index
;
2567 if (playlist
->last_insert_pos
>= 0 && steps
> 0)
2569 /* check to see if we've gone beyond the last inserted track */
2570 int cur
= rotate_index(playlist
, index
);
2571 int last_pos
= rotate_index(playlist
, playlist
->last_insert_pos
);
2575 /* reset last inserted track */
2576 playlist
->last_insert_pos
= -1;
2578 if (playlist
->control_fd
>= 0)
2580 int result
= update_control(playlist
, PLAYLIST_COMMAND_RESET
,
2581 -1, -1, NULL
, NULL
, NULL
);
2586 sync_control(playlist
, false);
2594 /* try playing next or previous folder */
2595 bool playlist_next_dir(int direction
)
2597 /* not to mess up real playlists */
2598 if(!current_playlist
.in_ram
)
2601 return create_and_play_dir(direction
, false) >= 0;
2604 /* Get resume info for current playing song. If return value is -1 then
2605 settings shouldn't be saved. */
2606 int playlist_get_resume_info(int *resume_index
)
2608 struct playlist_info
* playlist
= ¤t_playlist
;
2610 *resume_index
= playlist
->index
;
2615 /* Update resume info for current playing song. Returns -1 on error. */
2616 int playlist_update_resume_info(const struct mp3entry
* id3
)
2618 struct playlist_info
* playlist
= ¤t_playlist
;
2622 if (global_status
.resume_index
!= playlist
->index
||
2623 global_status
.resume_offset
!= id3
->offset
)
2625 global_status
.resume_index
= playlist
->index
;
2626 global_status
.resume_offset
= id3
->offset
;
2632 global_status
.resume_index
= -1;
2633 global_status
.resume_offset
= -1;
2640 /* Returns index of current playing track for display purposes. This value
2641 should not be used for resume purposes as it doesn't represent the actual
2642 index into the playlist */
2643 int playlist_get_display_index(void)
2645 struct playlist_info
* playlist
= ¤t_playlist
;
2647 /* first_index should always be index 0 for display purposes */
2648 int index
= rotate_index(playlist
, playlist
->index
);
2653 /* returns number of tracks in current playlist */
2654 int playlist_amount(void)
2656 return playlist_amount_ex(NULL
);
2658 /* set playlist->last_shuffle_start to playlist->amount for
2659 PLAYLIST_INSERT_LAST_SHUFFLED command purposes*/
2660 void playlist_set_last_shuffled_start(void)
2662 struct playlist_info
* playlist
= ¤t_playlist
;
2663 playlist
->last_shuffled_start
= playlist
->amount
;
2666 * Create a new playlist If playlist is not NULL then we're loading a
2667 * playlist off disk for viewing/editing. The index_buffer is used to store
2668 * playlist indices (required for and only used if !current playlist). The
2669 * temp_buffer (if not NULL) is used as a scratchpad when loading indices.
2671 int playlist_create_ex(struct playlist_info
* playlist
,
2672 const char* dir
, const char* file
,
2673 void* index_buffer
, int index_buffer_size
,
2674 void* temp_buffer
, int temp_buffer_size
)
2677 playlist
= ¤t_playlist
;
2680 /* Initialize playlist structure */
2681 int r
= rand() % 10;
2682 playlist
->current
= false;
2684 /* Use random name for control file */
2685 snprintf(playlist
->control_filename
, sizeof(playlist
->control_filename
),
2686 "%s.%d", PLAYLIST_CONTROL_FILE
, r
);
2688 playlist
->control_fd
= -1;
2692 int num_indices
= index_buffer_size
/ sizeof(int);
2694 #ifdef HAVE_DIRCACHE
2697 if (num_indices
> global_settings
.max_files_in_playlist
)
2698 num_indices
= global_settings
.max_files_in_playlist
;
2700 playlist
->max_playlist_size
= num_indices
;
2701 playlist
->indices
= index_buffer
;
2702 #ifdef HAVE_DIRCACHE
2703 playlist
->filenames
= (const struct dircache_entry
**)
2704 &playlist
->indices
[num_indices
];
2709 playlist
->max_playlist_size
= current_playlist
.max_playlist_size
;
2710 playlist
->indices
= current_playlist
.indices
;
2711 #ifdef HAVE_DIRCACHE
2712 playlist
->filenames
= current_playlist
.filenames
;
2716 playlist
->buffer_size
= 0;
2717 playlist
->buffer
= NULL
;
2718 playlist
->control_mutex
= &created_playlist_mutex
;
2721 new_playlist(playlist
, dir
, file
);
2724 /* load the playlist file */
2725 add_indices_to_playlist(playlist
, temp_buffer
, temp_buffer_size
);
2731 * Set the specified playlist as the current.
2732 * NOTE: You will get undefined behaviour if something is already playing so
2733 * remember to stop before calling this. Also, this call will
2734 * effectively close your playlist, making it unusable.
2736 int playlist_set_current(struct playlist_info
* playlist
)
2738 if (!playlist
|| (check_control(playlist
) < 0))
2741 empty_playlist(¤t_playlist
, false);
2743 strlcpy(current_playlist
.filename
, playlist
->filename
,
2744 sizeof(current_playlist
.filename
));
2746 current_playlist
.utf8
= playlist
->utf8
;
2747 current_playlist
.fd
= playlist
->fd
;
2749 close(playlist
->control_fd
);
2750 close(current_playlist
.control_fd
);
2751 remove(current_playlist
.control_filename
);
2752 if (rename(playlist
->control_filename
,
2753 current_playlist
.control_filename
) < 0)
2755 current_playlist
.control_fd
= open(current_playlist
.control_filename
,
2757 if (current_playlist
.control_fd
< 0)
2759 current_playlist
.control_created
= true;
2761 current_playlist
.dirlen
= playlist
->dirlen
;
2763 if (playlist
->indices
&& playlist
->indices
!= current_playlist
.indices
)
2765 memcpy(current_playlist
.indices
, playlist
->indices
,
2766 playlist
->max_playlist_size
*sizeof(int));
2767 #ifdef HAVE_DIRCACHE
2768 memcpy(current_playlist
.filenames
, playlist
->filenames
,
2769 playlist
->max_playlist_size
*sizeof(int));
2773 current_playlist
.first_index
= playlist
->first_index
;
2774 current_playlist
.amount
= playlist
->amount
;
2775 current_playlist
.last_insert_pos
= playlist
->last_insert_pos
;
2776 current_playlist
.seed
= playlist
->seed
;
2777 current_playlist
.shuffle_modified
= playlist
->shuffle_modified
;
2778 current_playlist
.deleted
= playlist
->deleted
;
2779 current_playlist
.num_inserted_tracks
= playlist
->num_inserted_tracks
;
2781 memcpy(current_playlist
.control_cache
, playlist
->control_cache
,
2782 sizeof(current_playlist
.control_cache
));
2783 current_playlist
.num_cached
= playlist
->num_cached
;
2784 current_playlist
.pending_control_sync
= playlist
->pending_control_sync
;
2788 struct playlist_info
*playlist_get_current(void)
2790 return ¤t_playlist
;
2793 * Close files and delete control file for non-current playlist.
2795 void playlist_close(struct playlist_info
* playlist
)
2800 if (playlist
->fd
>= 0)
2801 close(playlist
->fd
);
2803 if (playlist
->control_fd
>= 0)
2804 close(playlist
->control_fd
);
2806 if (playlist
->control_created
)
2807 remove(playlist
->control_filename
);
2810 void playlist_sync(struct playlist_info
* playlist
)
2813 playlist
= ¤t_playlist
;
2815 sync_control(playlist
, false);
2816 if ((audio_status() & AUDIO_STATUS_PLAY
) && playlist
->started
)
2817 audio_flush_and_reload_tracks();
2819 #ifdef HAVE_DIRCACHE
2820 queue_post(&playlist_queue
, PLAYLIST_LOAD_POINTERS
, 0);
2825 * Insert track into playlist at specified position (or one of the special
2826 * positions). Returns position where track was inserted or -1 if error.
2828 int playlist_insert_track(struct playlist_info
* playlist
, const char *filename
,
2829 int position
, bool queue
, bool sync
)
2834 playlist
= ¤t_playlist
;
2836 if (check_control(playlist
) < 0)
2838 splash(HZ
*2, ID2P(LANG_PLAYLIST_CONTROL_ACCESS_ERROR
));
2842 result
= add_track_to_playlist(playlist
, filename
, position
, queue
, -1);
2844 /* Check if we want manually sync later. For example when adding
2845 * bunch of files from tagcache, syncing after every file wouldn't be
2846 * a good thing to do. */
2847 if (sync
&& result
>= 0)
2848 playlist_sync(playlist
);
2854 * Insert all tracks from specified directory into playlist.
2856 int playlist_insert_directory(struct playlist_info
* playlist
,
2857 const char *dirname
, int position
, bool queue
,
2861 unsigned char *count_str
;
2862 struct directory_search_context context
;
2865 playlist
= ¤t_playlist
;
2867 if (check_control(playlist
) < 0)
2869 splash(HZ
*2, ID2P(LANG_PLAYLIST_CONTROL_ACCESS_ERROR
));
2873 if (position
== PLAYLIST_REPLACE
)
2875 if (playlist_remove_all_tracks(playlist
) == 0)
2876 position
= PLAYLIST_INSERT_LAST
;
2882 count_str
= ID2P(LANG_PLAYLIST_QUEUE_COUNT
);
2884 count_str
= ID2P(LANG_PLAYLIST_INSERT_COUNT
);
2886 display_playlist_count(0, count_str
, false);
2888 context
.playlist
= playlist
;
2889 context
.position
= position
;
2890 context
.queue
= queue
;
2895 result
= playlist_directory_tracksearch(dirname
, recurse
,
2896 directory_search_callback
, &context
);
2898 sync_control(playlist
, false);
2902 display_playlist_count(context
.count
, count_str
, true);
2904 if ((audio_status() & AUDIO_STATUS_PLAY
) && playlist
->started
)
2905 audio_flush_and_reload_tracks();
2907 #ifdef HAVE_DIRCACHE
2908 queue_post(&playlist_queue
, PLAYLIST_LOAD_POINTERS
, 0);
2915 * Insert all tracks from specified playlist into dynamic playlist.
2917 int playlist_insert_playlist(struct playlist_info
* playlist
, const char *filename
,
2918 int position
, bool queue
)
2924 unsigned char *count_str
;
2925 char temp_buf
[MAX_PATH
+1];
2926 char trackname
[MAX_PATH
+1];
2929 bool utf8
= is_m3u8(filename
);
2932 playlist
= ¤t_playlist
;
2934 if (check_control(playlist
) < 0)
2936 splash(HZ
*2, ID2P(LANG_PLAYLIST_CONTROL_ACCESS_ERROR
));
2940 fd
= open_utf8(filename
, O_RDONLY
);
2943 splash(HZ
*2, ID2P(LANG_PLAYLIST_ACCESS_ERROR
));
2947 /* we need the directory name for formatting purposes */
2950 temp_ptr
= strrchr(filename
+1,'/');
2957 count_str
= ID2P(LANG_PLAYLIST_QUEUE_COUNT
);
2959 count_str
= ID2P(LANG_PLAYLIST_INSERT_COUNT
);
2961 display_playlist_count(count
, count_str
, false);
2963 if (position
== PLAYLIST_REPLACE
)
2965 if (playlist_remove_all_tracks(playlist
) == 0)
2966 position
= PLAYLIST_INSERT_LAST
;
2972 while ((max
= read_line(fd
, temp_buf
, sizeof(temp_buf
))) > 0)
2975 if (action_userabort(TIMEOUT_NOBLOCK
))
2978 if (temp_buf
[0] != '#' && temp_buf
[0] != '\0')
2984 /* Use trackname as a temporay buffer. Note that trackname must
2985 * be as large as temp_buf.
2987 max
= convert_m3u(temp_buf
, max
, sizeof(temp_buf
), trackname
);
2990 /* we need to format so that relative paths are correctly
2992 if (format_track_path(trackname
, temp_buf
, sizeof(trackname
), max
,
2999 insert_pos
= add_track_to_playlist(playlist
, trackname
, position
,
3008 /* Make sure tracks are inserted in correct order if user
3009 requests INSERT_FIRST */
3010 if (position
== PLAYLIST_INSERT_FIRST
|| position
>= 0)
3011 position
= insert_pos
+ 1;
3015 if ((count
%PLAYLIST_DISPLAY_COUNT
) == 0)
3017 display_playlist_count(count
, count_str
, false);
3019 if (count
== PLAYLIST_DISPLAY_COUNT
&&
3020 (audio_status() & AUDIO_STATUS_PLAY
) &&
3022 audio_flush_and_reload_tracks();
3026 /* let the other threads work */
3035 sync_control(playlist
, false);
3039 display_playlist_count(count
, count_str
, true);
3041 if ((audio_status() & AUDIO_STATUS_PLAY
) && playlist
->started
)
3042 audio_flush_and_reload_tracks();
3044 #ifdef HAVE_DIRCACHE
3045 queue_post(&playlist_queue
, PLAYLIST_LOAD_POINTERS
, 0);
3052 * Delete track at specified index. If index is PLAYLIST_DELETE_CURRENT then
3053 * we want to delete the current playing track.
3055 int playlist_delete(struct playlist_info
* playlist
, int index
)
3060 playlist
= ¤t_playlist
;
3062 if (check_control(playlist
) < 0)
3064 splash(HZ
*2, ID2P(LANG_PLAYLIST_CONTROL_ACCESS_ERROR
));
3068 if (index
== PLAYLIST_DELETE_CURRENT
)
3069 index
= playlist
->index
;
3071 result
= remove_track_from_playlist(playlist
, index
, true);
3073 if (result
!= -1 && (audio_status() & AUDIO_STATUS_PLAY
) &&
3075 audio_flush_and_reload_tracks();
3081 * Move track at index to new_index. Tracks between the two are shifted
3082 * appropriately. Returns 0 on success and -1 on failure.
3084 int playlist_move(struct playlist_info
* playlist
, int index
, int new_index
)
3090 bool current
= false;
3092 char filename
[MAX_PATH
];
3095 playlist
= ¤t_playlist
;
3097 if (check_control(playlist
) < 0)
3099 splash(HZ
*2, ID2P(LANG_PLAYLIST_CONTROL_ACCESS_ERROR
));
3103 if (index
== new_index
)
3106 if (index
== playlist
->index
)
3107 /* Moving the current track */
3110 control_file
= playlist
->indices
[index
] & PLAYLIST_INSERT_TYPE_MASK
;
3111 queue
= playlist
->indices
[index
] & PLAYLIST_QUEUE_MASK
;
3112 seek
= playlist
->indices
[index
] & PLAYLIST_SEEK_MASK
;
3114 if (get_filename(playlist
, index
, seek
, control_file
, filename
,
3115 sizeof(filename
)) < 0)
3118 /* We want to insert the track at the position that was specified by
3119 new_index. This may be different then new_index because of the
3120 shifting that will occur after the delete.
3121 We calculate this before we do the remove as it depends on the
3122 size of the playlist before the track removal */
3123 r
= rotate_index(playlist
, new_index
);
3125 /* Delete track from original position */
3126 result
= remove_track_from_playlist(playlist
, index
, true);
3132 new_index
= PLAYLIST_PREPEND
;
3133 else if (r
== playlist
->amount
)
3135 new_index
= PLAYLIST_INSERT_LAST
;
3137 /* Calculate index of desired position */
3138 new_index
= (r
+playlist
->first_index
)%playlist
->amount
;
3140 result
= add_track_to_playlist(playlist
, filename
, new_index
, queue
,
3147 /* Moved the current track */
3150 case PLAYLIST_PREPEND
:
3151 playlist
->index
= playlist
->first_index
;
3153 case PLAYLIST_INSERT_LAST
:
3154 playlist
->index
= playlist
->first_index
- 1;
3155 if (playlist
->index
< 0)
3156 playlist
->index
+= playlist
->amount
;
3159 playlist
->index
= new_index
;
3164 if ((audio_status() & AUDIO_STATUS_PLAY
) && playlist
->started
)
3165 audio_flush_and_reload_tracks();
3169 #ifdef HAVE_DIRCACHE
3170 queue_post(&playlist_queue
, PLAYLIST_LOAD_POINTERS
, 0);
3176 /* shuffle currently playing playlist */
3177 int playlist_randomise(struct playlist_info
* playlist
, unsigned int seed
,
3183 playlist
= ¤t_playlist
;
3185 check_control(playlist
);
3187 result
= randomise_playlist(playlist
, seed
, start_current
, true);
3189 if (result
!= -1 && (audio_status() & AUDIO_STATUS_PLAY
) &&
3191 audio_flush_and_reload_tracks();
3196 /* sort currently playing playlist */
3197 int playlist_sort(struct playlist_info
* playlist
, bool start_current
)
3202 playlist
= ¤t_playlist
;
3204 check_control(playlist
);
3206 result
= sort_playlist(playlist
, start_current
, true);
3208 if (result
!= -1 && (audio_status() & AUDIO_STATUS_PLAY
) &&
3210 audio_flush_and_reload_tracks();
3215 /* returns true if playlist has been modified */
3216 bool playlist_modified(const struct playlist_info
* playlist
)
3219 playlist
= ¤t_playlist
;
3221 if (playlist
->shuffle_modified
||
3222 playlist
->deleted
||
3223 playlist
->num_inserted_tracks
> 0)
3229 /* returns index of first track in playlist */
3230 int playlist_get_first_index(const struct playlist_info
* playlist
)
3233 playlist
= ¤t_playlist
;
3235 return playlist
->first_index
;
3238 /* returns shuffle seed of playlist */
3239 int playlist_get_seed(const struct playlist_info
* playlist
)
3242 playlist
= ¤t_playlist
;
3244 return playlist
->seed
;
3247 /* returns number of tracks in playlist (includes queued/inserted tracks) */
3248 int playlist_amount_ex(const struct playlist_info
* playlist
)
3251 playlist
= ¤t_playlist
;
3253 return playlist
->amount
;
3256 /* returns full path of playlist (minus extension) */
3257 char *playlist_name(const struct playlist_info
* playlist
, char *buf
,
3263 playlist
= ¤t_playlist
;
3265 strlcpy(buf
, playlist
->filename
+playlist
->dirlen
, buf_size
);
3270 /* Remove extension */
3271 sep
= strrchr(buf
, '.');
3278 /* returns the playlist filename */
3279 char *playlist_get_name(const struct playlist_info
* playlist
, char *buf
,
3283 playlist
= ¤t_playlist
;
3285 strlcpy(buf
, playlist
->filename
, buf_size
);
3293 /* Fills info structure with information about track at specified index.
3294 Returns 0 on success and -1 on failure */
3295 int playlist_get_track_info(struct playlist_info
* playlist
, int index
,
3296 struct playlist_track_info
* info
)
3302 playlist
= ¤t_playlist
;
3304 if (index
< 0 || index
>= playlist
->amount
)
3307 control_file
= playlist
->indices
[index
] & PLAYLIST_INSERT_TYPE_MASK
;
3308 seek
= playlist
->indices
[index
] & PLAYLIST_SEEK_MASK
;
3310 if (get_filename(playlist
, index
, seek
, control_file
, info
->filename
,
3311 sizeof(info
->filename
)) < 0)
3318 if (playlist
->indices
[index
] & PLAYLIST_QUEUE_MASK
)
3319 info
->attr
|= PLAYLIST_ATTR_QUEUED
;
3321 info
->attr
|= PLAYLIST_ATTR_INSERTED
;
3325 if (playlist
->indices
[index
] & PLAYLIST_SKIPPED
)
3326 info
->attr
|= PLAYLIST_ATTR_SKIPPED
;
3328 info
->index
= index
;
3329 info
->display_index
= rotate_index(playlist
, index
) + 1;
3334 /* save the current dynamic playlist to specified file */
3335 int playlist_save(struct playlist_info
* playlist
, char *filename
)
3340 char path
[MAX_PATH
+1];
3341 char tmp_buf
[MAX_PATH
+1];
3343 bool overwrite_current
= false;
3344 int* index_buf
= NULL
;
3347 playlist
= ¤t_playlist
;
3349 if (playlist
->amount
<= 0)
3352 /* use current working directory as base for pathname */
3353 if (format_track_path(path
, filename
, sizeof(tmp_buf
),
3354 strlen(filename
)+1, getcwd(NULL
, -1)) < 0)
3357 if (!strncmp(playlist
->filename
, path
, strlen(path
)))
3359 /* Attempting to overwrite current playlist file.*/
3361 if (playlist
->buffer_size
< (int)(playlist
->amount
* sizeof(int)))
3363 /* not enough buffer space to store updated indices */
3364 splash(HZ
*2, ID2P(LANG_PLAYLIST_ACCESS_ERROR
));
3368 /* in_ram buffer is unused for m3u files so we'll use for storing
3370 index_buf
= (int*)playlist
->buffer
;
3372 /* use temporary pathname */
3373 snprintf(path
, sizeof(path
), "%s_temp", playlist
->filename
);
3374 overwrite_current
= true;
3379 fd
= open_utf8(path
, O_CREAT
|O_WRONLY
|O_TRUNC
);
3383 /* some applications require a BOM to read the file properly */
3384 fd
= open(path
, O_CREAT
|O_WRONLY
|O_TRUNC
, 0666);
3388 splash(HZ
*2, ID2P(LANG_PLAYLIST_ACCESS_ERROR
));
3392 display_playlist_count(count
, ID2P(LANG_PLAYLIST_SAVE_COUNT
), false);
3396 index
= playlist
->first_index
;
3397 for (i
=0; i
<playlist
->amount
; i
++)
3404 if (action_userabort(TIMEOUT_NOBLOCK
))
3410 control_file
= playlist
->indices
[index
] & PLAYLIST_INSERT_TYPE_MASK
;
3411 queue
= playlist
->indices
[index
] & PLAYLIST_QUEUE_MASK
;
3412 seek
= playlist
->indices
[index
] & PLAYLIST_SEEK_MASK
;
3414 /* Don't save queued files */
3417 if (get_filename(playlist
, index
, seek
, control_file
, tmp_buf
,
3424 if (overwrite_current
)
3425 index_buf
[count
] = lseek(fd
, 0, SEEK_CUR
);
3427 if (fdprintf(fd
, "%s\n", tmp_buf
) < 0)
3429 splash(HZ
*2, ID2P(LANG_PLAYLIST_ACCESS_ERROR
));
3436 if ((count
% PLAYLIST_DISPLAY_COUNT
) == 0)
3437 display_playlist_count(count
, ID2P(LANG_PLAYLIST_SAVE_COUNT
),
3443 index
= (index
+1)%playlist
->amount
;
3446 display_playlist_count(count
, ID2P(LANG_PLAYLIST_SAVE_COUNT
), true);
3450 if (overwrite_current
&& result
>= 0)
3454 mutex_lock(playlist
->control_mutex
);
3456 /* Replace the current playlist with the new one and update indices */
3457 close(playlist
->fd
);
3458 if (remove(playlist
->filename
) >= 0)
3460 if (rename(path
, playlist
->filename
) >= 0)
3462 playlist
->fd
= open_utf8(playlist
->filename
, O_RDONLY
);
3463 if (playlist
->fd
>= 0)
3465 index
= playlist
->first_index
;
3466 for (i
=0, count
=0; i
<playlist
->amount
; i
++)
3468 if (!(playlist
->indices
[index
] & PLAYLIST_QUEUE_MASK
))
3470 playlist
->indices
[index
] = index_buf
[count
];
3473 index
= (index
+1)%playlist
->amount
;
3476 /* we need to recreate control because inserted tracks are
3477 now part of the playlist and shuffle has been
3479 result
= recreate_control(playlist
);
3484 mutex_unlock(playlist
->control_mutex
);
3494 * Search specified directory for tracks and notify via callback. May be
3495 * called recursively.
3497 int playlist_directory_tracksearch(const char* dirname
, bool recurse
,
3498 int (*callback
)(char*, void*),
3501 char buf
[MAX_PATH
+1];
3505 struct entry
*files
;
3506 struct tree_context
* tc
= tree_get_context();
3507 int old_dirfilter
= *(tc
->dirfilter
);
3512 /* use the tree browser dircache to load files */
3513 *(tc
->dirfilter
) = SHOW_ALL
;
3515 if (ft_load(tc
, dirname
) < 0)
3517 splash(HZ
*2, ID2P(LANG_PLAYLIST_DIRECTORY_ACCESS_ERROR
));
3518 *(tc
->dirfilter
) = old_dirfilter
;
3522 files
= (struct entry
*) tc
->dircache
;
3523 num_files
= tc
->filesindir
;
3525 /* we've overwritten the dircache so tree browser will need to be
3529 for (i
=0; i
<num_files
; i
++)
3532 if (action_userabort(TIMEOUT_NOBLOCK
))
3538 if (files
[i
].attr
& ATTR_DIRECTORY
)
3542 /* recursively add directories */
3543 snprintf(buf
, sizeof(buf
), "%s/%s",
3544 dirname
[1]? dirname
: "", files
[i
].name
);
3545 result
= playlist_directory_tracksearch(buf
, recurse
,
3550 /* we now need to reload our current directory */
3551 if(ft_load(tc
, dirname
) < 0)
3557 files
= (struct entry
*) tc
->dircache
;
3558 num_files
= tc
->filesindir
;
3568 else if ((files
[i
].attr
& FILE_ATTR_MASK
) == FILE_ATTR_AUDIO
)
3570 snprintf(buf
, sizeof(buf
), "%s/%s",
3571 dirname
[1]? dirname
: "", files
[i
].name
);
3573 if (callback(buf
, context
) != 0)
3579 /* let the other threads work */
3584 /* restore dirfilter */
3585 *(tc
->dirfilter
) = old_dirfilter
;