mirror of
https://github.com/WinampDesktop/winamp.git
synced 2024-09-24 15:54:12 +00:00
55 lines
1.6 KiB
C++
55 lines
1.6 KiB
C++
#pragma once
|
|
#ifndef protocol_HTTPSource_H_
|
|
#define protocol_HTTPSource_H_
|
|
|
|
#include "threadedRunner.h"
|
|
#include <map>
|
|
|
|
class streamData;
|
|
|
|
/*
|
|
Runnable object that handles the shoutcast source (broadcaster)
|
|
protocol
|
|
*/
|
|
|
|
class protocol_HTTPSource : public runnable
|
|
{
|
|
private:
|
|
const u_short m_srcPort;
|
|
short unsigned int m_remainderSize;
|
|
bool m_denied; // used to prevent source disconnected messages e.g. for failed passwords
|
|
// is a padding hole around here...
|
|
__uint8 * m_remainder;
|
|
const uniString::utf8 m_srcAddr;
|
|
uniString::utf8 m_srcLogString;
|
|
uniString::utf8 m_srcUserID;
|
|
int m_srcStreamID;
|
|
int m_outBufferSize;
|
|
const uniString::utf8::value_type *m_outBuffer; // for outgoing text lines
|
|
uniString::utf8 m_lineBuffer; // received ICY header line
|
|
httpHeaderMap_t m_headers; // the received source headers
|
|
streamData *m_streamData; // associated stream object
|
|
|
|
typedef void (protocol_HTTPSource::*state_t)();
|
|
|
|
state_t m_state;
|
|
state_t m_nextState;
|
|
|
|
void state_ConfirmPassword() throw(std::exception);
|
|
void state_SendBuffer() throw(std::exception);
|
|
void state_GetLine() throw(std::exception);
|
|
void state_AnalyzeHeaders() throw(std::exception);
|
|
void state_CloseConnection() throw(std::exception);
|
|
void state_GetStreamData() throw(std::exception);
|
|
|
|
protected:
|
|
virtual void timeSlice() throw(std::exception);
|
|
virtual uniString::utf8 name() const throw() { return "protocol_HTTPSource"; }
|
|
|
|
public:
|
|
protocol_HTTPSource (microConnection &mc, const string &firstLine) throw(std::exception);
|
|
|
|
virtual ~protocol_HTTPSource() throw();
|
|
};
|
|
|
|
#endif
|