Skip to content

Commit

Permalink
Style fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
Numerio committed Jun 4, 2016
1 parent f76e95b commit d004f81
Show file tree
Hide file tree
Showing 5 changed files with 62 additions and 60 deletions.
6 changes: 4 additions & 2 deletions src/add-ons/media/plugins/http_streamer/HTTPStreamerPlugin.h
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,8 @@

#include "StreamerPlugin.h"

class HTTPStreamer : public Streamer {
class HTTPStreamer : public Streamer
{
public:
HTTPStreamer();
virtual ~HTTPStreamer();
Expand All @@ -17,7 +18,8 @@ class HTTPStreamer : public Streamer {
};


class HTTPStreamerPlugin : public StreamerPlugin {
class HTTPStreamerPlugin : public StreamerPlugin
{
public:
virtual Streamer* NewStreamer();
};
Expand Down
8 changes: 4 additions & 4 deletions src/add-ons/media/plugins/rtsp_streamer/Jamfile
Original file line number Diff line number Diff line change
Expand Up @@ -12,10 +12,10 @@ for architectureObject in [ MultiArchSubDirSetup ] {
UseBuildFeatureHeaders live555 ;

Includes [ FGristFiles
rtsp.cpp
RTSPStreamerPlugin.cpp
RTSPMediaIO.cpp ]
: [ BuildFeatureAttribute live555 : headers ] ;
rtsp.cpp
RTSPStreamerPlugin.cpp
RTSPMediaIO.cpp ]
: [ BuildFeatureAttribute live555 : headers ] ;

Addon [ MultiArchDefaultGristFiles rtsp_streamer ] :
RTSPStreamerPlugin.cpp
Expand Down
53 changes: 27 additions & 26 deletions src/add-ons/media/plugins/rtsp_streamer/RTSPMediaIO.h
Original file line number Diff line number Diff line change
Expand Up @@ -15,53 +15,54 @@
class RTSPMediaIO : public BAdapterIO
{
public:
RTSPMediaIO(BUrl* ourUrl);
virtual ~RTSPMediaIO();
RTSPMediaIO(BUrl* ourUrl);
virtual ~RTSPMediaIO();

status_t InitCheck() const;
status_t InitCheck() const;

virtual ssize_t WriteAt(off_t position, const void* buffer,
size_t size);
virtual ssize_t WriteAt(off_t position,
const void* buffer,
size_t size);
private:
BUrl* fUrl;
BUrl* fUrl;

TaskScheduler* fScheduler;
UsageEnvironment* fEnv;
char loopWatchVariable;
TaskScheduler* fScheduler;
UsageEnvironment* fEnv;
char loopWatchVariable;

status_t fInitErr;
status_t fInitErr;
};


class HaikuRTSPClient : public RTSPClient
{
public:
HaikuRTSPClient(UsageEnvironment& env,
char const* rtspURL,
portNumBits tunnelOverHTTPPortNum,
BInputAdapter* fInputAdapter);
HaikuRTSPClient(UsageEnvironment& env,
char const* rtspURL,
portNumBits tunnelOverHTTPPortNum,
BInputAdapter* fInputAdapter);

BInputAdapter* GetInputAdapter() const;
BInputAdapter* GetInputAdapter() const;

status_t WaitForInit(bigtime_t timeout);
status_t WaitForInit(bigtime_t timeout);

void NotifyError();
void NotifySucces();
void NotifyError();
void NotifySucces();

protected:
virtual ~HaikuRTSPClient();
virtual ~HaikuRTSPClient();

public:

MediaSubsessionIterator* iter;
MediaSession* session;
MediaSubsession* subsession;
TaskToken streamTimerTask;
double duration;
MediaSubsessionIterator* iter;
MediaSession* session;
MediaSubsession* subsession;
TaskToken streamTimerTask;
double duration;

private:
BInputAdapter* fInputAdapter;
port_id fInitPort;
BInputAdapter* fInputAdapter;
port_id fInitPort;
};

#endif
3 changes: 2 additions & 1 deletion src/add-ons/media/plugins/rtsp_streamer/RTSPStreamerPlugin.h
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,8 @@

#include "StreamerPlugin.h"

class RTSPStreamer : public Streamer {
class RTSPStreamer : public Streamer
{
public:
RTSPStreamer();
virtual ~RTSPStreamer();
Expand Down
52 changes: 25 additions & 27 deletions src/add-ons/media/plugins/rtsp_streamer/rtsp.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -43,39 +43,39 @@ UsageEnvironment& operator<<(UsageEnvironment& env,
class AdapterSink : public MediaSink
{
public:
static AdapterSink* createNew(UsageEnvironment& env,
MediaSubsession& subsession,
BInputAdapter* inputAdapter,
char const* streamId = NULL);
static AdapterSink* createNew(UsageEnvironment& env,
MediaSubsession& subsession,
BInputAdapter* inputAdapter,
char const* streamId = NULL);

private:
AdapterSink(UsageEnvironment& env,
MediaSubsession& subsession,
char const* streamId,
BInputAdapter* inputAdapter);
AdapterSink(UsageEnvironment& env,
MediaSubsession& subsession,
char const* streamId,
BInputAdapter* inputAdapter);

virtual ~AdapterSink();
virtual ~AdapterSink();

static void afterGettingFrame(void* clientData,
unsigned frameSize,
unsigned numTruncatedBytes,
struct timeval presentationTime,
unsigned durationInMicroseconds);
static void afterGettingFrame(void* clientData,
unsigned frameSize,
unsigned numTruncatedBytes,
struct timeval presentationTime,
unsigned durationInMicroseconds);

void afterGettingFrame(unsigned frameSize,
unsigned numTruncatedBytes,
struct timeval presentationTime,
unsigned durationInMicroseconds);
void afterGettingFrame(unsigned frameSize,
unsigned numTruncatedBytes,
struct timeval presentationTime,
unsigned durationInMicroseconds);

private:
// redefined virtual functions:
virtual Boolean continuePlaying();
virtual Boolean continuePlaying();

private:
BInputAdapter* fInputAdapter;
u_int8_t* fReceiveBuffer;
MediaSubsession& fSubsession;
char* fStreamId;
BInputAdapter* fInputAdapter;
u_int8_t* fReceiveBuffer;
MediaSubsession& fSubsession;
char* fStreamId;
};

// Implementation of the RTSP 'response handlers':
Expand Down Expand Up @@ -174,8 +174,7 @@ void setupNextSubsession(RTSPClient* rtspClient)
// so send an appropriate "PLAY" command:
rtspClient->sendPlayCommand(*client->session, continueAfterPLAY,
client->session->absStartTime(), client->session->absEndTime());
}
else {
} else {
client->duration = client->session->playEndTime()
- client->session->playStartTime();
rtspClient->sendPlayCommand(*client->session, continueAfterPLAY);
Expand All @@ -201,8 +200,7 @@ void continueAfterSETUP(RTSPClient* rtspClient,
<< *client->subsession << "\" subsession (";
if (client->subsession->rtcpIsMuxed()) {
env << "client port " << client->subsession->clientPortNum();
}
else {
} else {
env << "client ports " << client->subsession->clientPortNum()
<< "-" << client->subsession->clientPortNum() + 1;
}
Expand Down

0 comments on commit d004f81

Please sign in to comment.