liveMedia/MP3StreamState.cpp File Reference

#include "MP3StreamState.hh"
#include "GroupsockHelper.hh"

Include dependency graph for MP3StreamState.cpp:

Go to the source code of this file.

Defines
#define	MILLION   1000000
#define	HDRCMPMASK   0xfffffd00
#define	XING_FRAMES_FLAG   0x0001
#define	XING_BYTES_FLAG   0x0002
#define	XING_TOC_FLAG   0x0004
#define	XING_VBR_SCALE_FLAG   0x0008
Functions
static Boolean	socketIsReadable (int socket)
static void	checkFunc (void *)
static void	waitUntilSocketIsReadable (UsageEnvironment &env, int socket)
Variables
static char	watchVariable

---

Define Documentation

#define HDRCMPMASK   0xfffffd00

Definition at line 223 of file MP3StreamState.cpp.

Referenced by MP3StreamState::findNextFrame().

#define MILLION   1000000

Definition at line 28 of file MP3StreamState.cpp.

#define XING_BYTES_FLAG   0x0002

Definition at line 423 of file MP3StreamState.cpp.

Referenced by MP3StreamState::checkForXingHeader().

#define XING_FRAMES_FLAG   0x0001

Definition at line 422 of file MP3StreamState.cpp.

Referenced by MP3StreamState::checkForXingHeader().

#define XING_TOC_FLAG   0x0004

Definition at line 424 of file MP3StreamState.cpp.

Referenced by MP3StreamState::checkForXingHeader().

#define XING_VBR_SCALE_FLAG   0x0008

Definition at line 425 of file MP3StreamState.cpp.

---

Function Documentation

static void checkFunc

(

void *

)

[static]

Definition at line 383 of file MP3StreamState.cpp.

References watchVariable.

Referenced by waitUntilSocketIsReadable().

                                            {
  watchVariable = ~0;
}

static Boolean socketIsReadable

(

int

socket

)

[static]

Definition at line 369 of file MP3StreamState.cpp.

References NULL.

Referenced by waitUntilSocketIsReadable().

                                            {
  const unsigned numFds = socket+1;
  fd_set rd_set;
  FD_ZERO(&rd_set);
  FD_SET((unsigned)socket, &rd_set);
  struct timeval timeout;
  timeout.tv_sec = timeout.tv_usec = 0;

  int result = select(numFds, &rd_set, NULL, NULL, &timeout);
  return result != 0; // not > 0, because windows can return -1 for file sockets
}

static void waitUntilSocketIsReadable	(	UsageEnvironment &	env,
		int	socket
	)			[static]

Definition at line 387 of file MP3StreamState.cpp.

References checkFunc(), TaskScheduler::doEventLoop(), env, NULL, TaskScheduler::scheduleDelayedTask(), socketIsReadable(), UsageEnvironment::taskScheduler(), and watchVariable.

Referenced by MP3StreamState::readFromStream().

                                                                         {
  while (!socketIsReadable(socket)) {
    // Delay a short period of time before checking again.
    unsigned usecsToDelay = 1000; // 1 ms
    env.taskScheduler().scheduleDelayedTask(usecsToDelay,
                                            (TaskFunc*)checkFunc, (void*)NULL);
    watchVariable = 0;
    env.taskScheduler().doEventLoop(&watchVariable);
        // This allows other tasks to run while we're waiting:
  }
}

---

Variable Documentation

char watchVariable [static]

Definition at line 381 of file MP3StreamState.cpp.

Referenced by checkFunc(), and waitUntilSocketIsReadable().

---