diff options
Diffstat (limited to 'Src/Plugins/Input/in_mp3/giofile.h')
| -rw-r--r-- | Src/Plugins/Input/in_mp3/giofile.h | 306 |
1 files changed, 306 insertions, 0 deletions
diff --git a/Src/Plugins/Input/in_mp3/giofile.h b/Src/Plugins/Input/in_mp3/giofile.h new file mode 100644 index 00000000..121d77c9 --- /dev/null +++ b/Src/Plugins/Input/in_mp3/giofile.h @@ -0,0 +1,306 @@ + +/***************************************************************************\ + * + * (C) copyright Fraunhofer - IIS (1998) + * All Rights Reserved + * + * filename: giofile.h + * project : MPEG Decoder + * author : Martin Sieler + * date : 1998-02-11 + * contents/description: HEADER - file I/O class for MPEG Decoder + * + * +\***************************************************************************/ + +#ifndef _GIOFILE_H +#define _GIOFILE_H + +/* ------------------------ includes --------------------------------------*/ +#include <windows.h> + +#include "CVbriHeader.h" +#include "jnetlib/jnetlib.h" + +#include "../vlb/dataio.h" +#include "ID3v2.h" +#include "LAMEInfo.h" +#include "../nu/RingBuffer.h" +#include "../apev2/tag.h" +#include "ifc_mpeg_stream_reader.h" + +/*-------------------------- defines --------------------------------------*/ + +/*-------------------------------------------------------------------------*/ + +class CGioFile : public DataIOControl, public ifc_mpeg_stream_reader +{ +public: + CGioFile(); + virtual ~CGioFile(); + + int Open(const wchar_t *pszName, int maxbufsizek); + int Close(); + int Read(void *pBuffer, int cbToRead, int *pcbRead); + int Peek(void *pBuffer, int cbToRead, int *pcbRead); + + //dataiocontrol interface + int IO(void *buf, int size, int count) + { + int l=0; + Read(buf,count,&l); + return l; + } + int Seek(long offset, int origin) + { + return 0; + } + //int Close() { return 0; } + int EndOf(void) + { + return IsEof(); + } + int DICGetLastError() + { + return DATA_IO_ERROR_NONE; + } + int DICGetDirection() + { + return DATA_IO_READ; + } + + unsigned int GetAvgVBRBitrate(void) + { + if (m_vbr_ms && m_vbr_frames) + { + if (m_vbr_bytes && encodingMethod != ENCODING_METHOD_CBR) + return (unsigned int)(m_vbr_bytes * 8 / m_vbr_ms); + else + return (unsigned int)(mpeg_length * 8 / m_vbr_ms); + } + return 0; + } + bool IsEof() const; + bool lengthVerified; + bool isSeekReset() + { + + if (m_is_stream && m_seek_reset && m_is_stream_seek) + { + m_seek_reset = false; + m_is_stream_seek = false; + return true; + } + else + return false; + } + + bool IsStreamSeekable() + { + return m_is_stream_seekable; + } + + int GetHeaderOffset(); + + int PercentAvailable() + { + if (!m_is_stream) return 0; + if (!recvbuffersize) return 0; + if (!m_connection) return 0; + if (constate != 5) return 0; + uint64_t bytes_100 = jnl_connection_receive_bytes_available(m_connection)*100; + bytes_100 /= recvbuffersize; + return (int)bytes_100; + } + + int RunStream() + { + if (m_is_stream && m_connection) + { + if (constate != 5) Read(NULL,0,NULL); + else jnl_connection_run(m_connection, -1, -1, NULL, NULL); + int p=jnl_connection_get_state(m_connection); + if (p==JNL_CONNECTION_STATE_ERROR|| + p==JNL_CONNECTION_STATE_CLOSED) + return 2; + return 1; + } + return 0; + } + int IsStream() + { + return m_is_stream; + } + void GetStreamInfo(wchar_t *, size_t len); + + DWORD GetContentLength(void) const; + DWORD GetCurrentPosition(void) const; + void SetCurrentPosition(long dwPos, int How); + + enum { GIO_FILE_BEGIN, GIO_FILE_CURRENT, GIO_FILE_END }; + + uint64_t mpeg_length; /* length of valid audio data */ + uint64_t mpeg_position; /* starting position of first valid decodable non-header MPEG frame */ + uint64_t file_position; /* position within the MPEG data that we've read so far */ + + uint64_t m_vbr_bytes; + int m_vbr_frames, m_vbr_ms; + int encodingMethod; + uint64_t m_vbr_samples; + int prepad, postpad; + void Seek(int posms, int br); + bool IsSeekable(); + + unsigned char id3v1_data[128]; + + char stream_url[256]; + char stream_name[256]; + char stream_genre[256]; + char stream_current_title[256]; + + char *m_content_type; + int uvox_last_message; + char *uvox_3901; + char *uvox_3902; + + typedef struct { + char *uvox_stream_artwork; + int uvox_stream_artwork_len; + int uvox_stream_artwork_type; + char *uvox_playing_artwork; + int uvox_playing_artwork_len; + int uvox_playing_artwork_type; + } UVOX_ARTWORK; + UVOX_ARTWORK uvox_artwork; + + ID3v2 info; + float GetGain(); + unsigned char m_vbr_toc[100]; + int m_vbr_frame_len; + int m_vbr_flag; + CVbriHeader *m_vbr_hdr; + + FILETIME last_write_time; + + void *GetID3v1() + { + if (m_id3v1_len == 128) + return id3v1_data; + else + return 0; + } + + void *GetID3v2(uint32_t *len) + { + if (stream_id3v2_buf) + { + *len = stream_id3v2_read; + return stream_id3v2_buf; + } + else + return 0; + } + + void *GetLyrics3(uint32_t *len) + { + if (lyrics3_data) + { + *len = lyrics3_size; + return lyrics3_data; + } + else + return 0; + } + + void *GetAPEv2(uint32_t *len) + { + if (apev2_data) + { + *len = m_apev2_len; + return apev2_data; + } + return 0; + } + +protected: + void ReadiTunesGaps(); +private: + /* ID3v2 */ + int m_id3v1_len; + + /* ID3v2 */ + uint32_t stream_id3v2_read; + char *stream_id3v2_buf; + int m_id3v2_len; + + /* Lyrics3 */ + uint32_t lyrics3_size; + char *lyrics3_data; + + /* APEv2 */ + uint32_t m_apev2_len; + char *apev2_data; + APEv2::Tag apev2; + + int m_is_stream; + jnl_dns_t m_dns; + jnl_connection_t m_connection; + char last_full_url[4096]; + int is_stream_seek; + char *host; + char *proxy_host; + char *req; + unsigned short port; + char *lpinfo; + char *proxy_lp; + char *request; + int constate; + char save_filename[256]; + char server_name[128]; + int recvbuffersize; + + int64_t stream_bytes_read; + int64_t stream_metabytes_read; + unsigned int timeout_start; + char force_lpinfo[256]; + unsigned char *m_full_buffer; + int is_uvox; + int uvox_stream_data_len; + int uvox_message_cnt, uvox_desyncs; + int uvox_sid,uvox_maxbr, uvox_avgbr,uvox_maxmsg; + + unsigned char *uvox_stream_data; + + char *uvox_meta[2][32]; + int meta_interval,meta_pos; + uint64_t m_full_buffer_pos/*,m_full_buffer_len*/; + char stream_title_save[580]; + char last_title_sent[256]; + + RingBuffer peekBuffer; + //unsigned char m_peekbuf[8192]; + //int m_peekbuf_used; + bool no_peek_hack; + + int doConnect(const char *str, int start_offset); + void processMetaData(char *data, int lent, int msgId = 0); + + int m_redircnt; + int m_auth_tries; + + HANDLE hFile; + bool fEof; + + + char dlg_realm[256]; + static INT_PTR CALLBACK httpDlgProc(HWND hwndDlg, UINT uMsg, WPARAM wParam,LPARAM lParam); + int m_http_response; + bool m_seek_reset; + bool m_is_stream_seek; + bool m_is_stream_seekable; + bool m_useaproxy; + RECVS_DISPATCH; +}; + +/*-------------------------------------------------------------------------*/ +#endif |