From 94c52bd15e64830db905522294a1975ed7a1cc39 Mon Sep 17 00:00:00 2001
From: deva <deva>
Date: Wed, 5 Oct 2005 14:42:38 +0000
Subject: *** empty log message ***
---
src/file.cc | 4 +-
src/file.h | 3 +-
src/mov_encoder_writer.cc | 6 +-
src/mov_encoder_writer.h | 2 +
src/multicast.cc | 51 +++++++++++++----
src/multicast.h | 5 +-
src/multiplexer.cc | 135 ++++++++++++++++++++++++++++++++++++++------
src/multiplexer.h | 15 ++++-
src/threadsafe_queue_fifo.h | 2 -
9 files changed, 187 insertions(+), 36 deletions(-)
(limited to 'src')
diff --git a/src/file.cc b/src/file.cc
index 9188e6e..c3fad30 100644
--- a/src/file.cc
+++ b/src/file.cc
@@ -126,7 +126,7 @@ int File::Write(void* data, int size)
return w;
}
-
+/*
int File::Write(char* data, int size)
{
return Write((void*)data, size);
@@ -219,7 +219,7 @@ int File::Write(unsigned short int val)
return Write((char*)&val, sizeof(val));
}
-
+*/
int File::createPath(char* path)
{
// struct stat stats;
diff --git a/src/file.h b/src/file.h
index 561a39f..36be4d2 100644
--- a/src/file.h
+++ b/src/file.h
@@ -40,6 +40,7 @@ public:
~File();
int Write(void* data, int size);
+ /*
int Write(char* data, int size);
int Write(unsigned long long int val);
@@ -50,7 +51,7 @@ public:
int Write(unsigned int val);
int Write(short int val);
int Write(unsigned short int val);
-
+ */
private:
Info* info;
diff --git a/src/mov_encoder_writer.cc b/src/mov_encoder_writer.cc
index 732f9ba..572a81e 100644
--- a/src/mov_encoder_writer.cc
+++ b/src/mov_encoder_writer.cc
@@ -81,6 +81,8 @@ MovEncoderWriter::MovEncoderWriter(const char* cpr,
file = new File(fname, "mpg", info);
+ multicast = new Multicast(info);
+
video_queue = video_q;
audio_queue = audio_q;
@@ -91,6 +93,7 @@ MovEncoderWriter::~MovEncoderWriter()
{
info->info("~MovEncoderWriter");
delete file;
+ delete multicast;
}
@@ -98,7 +101,8 @@ void MovEncoderWriter::thread_main()
{
info->info("MovEncoderWriter::run");
- Multiplexer multiplexer(file, info, &running,
+ Multiplexer multiplexer(file, multicast,
+ info, &running,
video_queue,
audio_queue);
multiplexer.multiplex();
diff --git a/src/mov_encoder_writer.h b/src/mov_encoder_writer.h
index 3146bf8..00d5262 100644
--- a/src/mov_encoder_writer.h
+++ b/src/mov_encoder_writer.h
@@ -31,6 +31,7 @@
#include "frame.h"
#include "thread.h"
#include "file.h"
+#include "multicast.h"
#include "info.h"
#include "threadsafe_queue_priority.h"
@@ -57,6 +58,7 @@ private:
Info *info;
File *file;
+ Multicast *multicast;
ThreadSafeQueuePriority *video_queue;
ThreadSafeQueuePriority *audio_queue;
diff --git a/src/multicast.cc b/src/multicast.cc
index 0cf1b87..b64bfde 100644
--- a/src/multicast.cc
+++ b/src/multicast.cc
@@ -35,8 +35,18 @@
Multicast::Multicast(Info *i)
{
- char addr[] = "192.168.0.10";
- int port = 666;
+ /*
+ Multicast adresses:
+ 224.0.0.1 All systems on this subnet
+ 224.0.0.2 All routers on this subnet
+ 224.0.0.5 OSPF routers
+ 224.0.0.6 OSPF designated routers
+ 224.0.0.12 DHCP server/relay agent
+ */
+
+ // Multicast to all systems on this subnet
+ char addr[] = "224.0.0.1";
+ int port = 1234;
info = i;
if(!UDPOpen(addr, port)) info->error("Error creating socket %s:%d", addr, port);
@@ -46,16 +56,33 @@ Multicast::~Multicast()
{
}
-void Multicast::Write(char* buf, int size)
+void Multicast::Write(void* buf, int size)
{
- if(write(sock, buf, size) != size) info->error("Error Writing to socket.");
+ // char addr[] = "192.168.0.10";
+ // int port = 1234;
+
+ if(write(sock, buf, size) != size) {
+ info->error("Error Writing to socket.");
+ // if(!UDPOpen(addr, port)) info->error("Error creating socket %s:%d", addr, port);
+ }
}
+#define USE_MULTICAST
+
+bool Multicast::is_address_multicast(unsigned long address)
+{
+ if((address & 255) >= 224 && (address & 255) <= 239) {
+ info->info("Address is multicast.");
+ return true;
+ }
+ info->info("Address is NOT multicast.");
+ return false;
+}
/*
* open UDP socket
*/
-bool Multicast::UDPOpen(char * address, int port)
+bool Multicast::UDPOpen(char *address, int port)
{
int enable = 1L;
struct sockaddr_in stAddr;
@@ -68,25 +95,27 @@ bool Multicast::UDPOpen(char * address, int port)
if((host = gethostbyname(address)) == NULL) return false;
stAddr.sin_addr = *((struct in_addr *) host->h_addr_list[0]);
- /* Create a UDP socket */
+ // Create a UDP socket
if((sock = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
return false;
- /* Allow multiple instance of the client to share the same address and port */ if(setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (char *) &enable, sizeof(unsigned long int)) < 0) return false;
+ // Allow multiple instance of the client to share the same address and port
+ if(setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (char *) &enable, sizeof(unsigned long int)) < 0)
+ return false;
#ifdef USE_MULTICAST
- /* If the address is multicast, register to the multicast group */
+ // If the address is multicast, register to the multicast group
if(is_address_multicast(stAddr.sin_addr.s_addr))
{
struct ip_mreq stMreq;
- /* Bind the socket to port */
+ // Bind the socket to port
stLclAddr.sin_family = AF_INET;
stLclAddr.sin_addr.s_addr = htonl(INADDR_ANY);
stLclAddr.sin_port = stAddr.sin_port;
if(bind(sock, (struct sockaddr*) & stLclAddr, sizeof(stLclAddr)) < 0) return false;
- /* Register to a multicast address */
+ // Register to a multicast address
stMreq.imr_multiaddr.s_addr = stAddr.sin_addr.s_addr;
stMreq.imr_interface.s_addr = INADDR_ANY;
if(setsockopt(sock, IPPROTO_IP, IP_ADD_MEMBERSHIP, (char *) & stMreq, sizeof(stMreq)) < 0)
@@ -95,7 +124,7 @@ bool Multicast::UDPOpen(char * address, int port)
else
#endif
{
- /* Bind the socket to port */
+ // Bind the socket to port
stLclAddr.sin_family = AF_INET;
stLclAddr.sin_addr.s_addr = htonl(INADDR_ANY);
stLclAddr.sin_port = htons(0);
diff --git a/src/multicast.h b/src/multicast.h
index f0a4979..50727a5 100644
--- a/src/multicast.h
+++ b/src/multicast.h
@@ -35,12 +35,13 @@ public:
Multicast(Info *info);
~Multicast();
- void Write(char* buf, int size);
+ void Write(void* buf, int size);
private:
Info *info;
- bool UDPOpen(char * address, int port);
+ bool is_address_multicast(unsigned long address);
+ bool UDPOpen(char *address, int port);
int sock;
};
diff --git a/src/multiplexer.cc b/src/multiplexer.cc
index 0b54bf8..096ff86 100644
--- a/src/multiplexer.cc
+++ b/src/multiplexer.cc
@@ -68,12 +68,13 @@ static double picture_rate_index[16] = {
RESERVED, RESERVED, RESERVED, RESERVED, RESERVED, RESERVED, RESERVED
};
*/
-Multiplexer::Multiplexer(File *f, Info *i, volatile bool *r,
+Multiplexer::Multiplexer(File *f, Multicast *m, Info *i, volatile bool *r,
ThreadSafeQueuePriority *video_q,
ThreadSafeQueuePriority *audio_q)
{
running = r;
file = f;
+ multicast = m;
info = i;
frame[TYPE_VIDEO] = NULL;
@@ -98,10 +99,112 @@ Multiplexer::~Multiplexer()
{
}
+int Multiplexer::Write(void* data, int size)
+{
+ int ret;
+
+ multicast->Write(data, size);
+ ret = file->Write(data, size);
+
+ return ret;
+}
+
+int Multiplexer::Write(char* data, int size)
+{
+ return Write((void*)data, size);
+}
+
+int Multiplexer::Write(unsigned long long int val)
+{
+ int res;
+ int written = 0;
+ unsigned long int *h_u = (unsigned long int *)&val;
+ unsigned long int *h_l = (unsigned long int *)(((char*)&val) + sizeof(unsigned long int));
+
+ *h_u = htonl(*h_u);
+ *h_l = htonl(*h_l);
+
+ if((res = Write((void*)h_l, sizeof(*h_l))) < 0) {
+ return res;
+ }
+ written += res;
+
+ if((res = Write((void*)h_u, sizeof(*h_u))) < 0) {
+ return res;
+ }
+ written += res;
+
+ return written;
+}
+
+int Multiplexer::Write(long long int val)
+{
+ int res;
+ int written = 0;
+ unsigned long int *h_u = (unsigned long int *)&val;
+ unsigned long int *h_l = (unsigned long int *)(((char*)&val) + sizeof(unsigned long int));
+
+ *h_u = htonl(*h_u);
+ *h_l = htonl(*h_l);
+
+ if((res = Write((void*)h_l, sizeof(*h_l))) < 0) {
+ return res;
+ }
+ written += res;
+
+ if((res = Write((void*)h_u, sizeof(*h_u))) < 0) {
+ return res;
+ }
+ written += res;
+
+ return written;
+}
+
+int Multiplexer::Write(long int val)
+{
+ val = htonl(val);
+
+ return Write((char*)&val, sizeof(val));
+}
+
+int Multiplexer::Write(unsigned long int val)
+{
+ val = htonl(val);
+
+ return Write((char*)&val, sizeof(val));
+}
+
+int Multiplexer::Write(int val)
+{
+ val = htonl(val);
+
+ return Write((char*)&val, sizeof(val));
+}
+
+int Multiplexer::Write(unsigned int val)
+{
+ val = htonl(val);
+
+ return Write((char*)&val, sizeof(val));
+}
+
+int Multiplexer::Write(short int val)
+{
+ val = htons(val);
+
+ return Write((char*)&val, sizeof(val));
+}
+
+int Multiplexer::Write(unsigned short int val)
+{
+ val = htons(val);
+
+ return Write((char*)&val, sizeof(val));
+}
Frame *Multiplexer::getFrame(StreamType type)
{
- info->info("Get %s Frame", type==TYPE_AUDIO?"Audio\0":"Video\0");
+ // info->info("Get %s Frame", type==TYPE_AUDIO?"Audio\0":"Video\0");
read[type] = 0;
@@ -155,13 +258,13 @@ bool Multiplexer::packet(StreamType type)
unsigned short int framesize = read_stream(buf, PACKET_SIZE, type);
- file->Write((void*)ISO11172_1::packet_start_code_prefix, SIZEOF(ISO11172_1::packet_start_code_prefix));
+ Write((void*)ISO11172_1::packet_start_code_prefix, SIZEOF(ISO11172_1::packet_start_code_prefix));
switch(type) {
case TYPE_VIDEO:
- file->Write((void*)ISO11172_1::stream_id_video1, SIZEOF(ISO11172_1::stream_id_video1));
+ Write((void*)ISO11172_1::stream_id_video1, SIZEOF(ISO11172_1::stream_id_video1));
break;
case TYPE_AUDIO:
- file->Write((void*)ISO11172_1::stream_id_audio1, SIZEOF(ISO11172_1::stream_id_audio1));
+ Write((void*)ISO11172_1::stream_id_audio1, SIZEOF(ISO11172_1::stream_id_audio1));
break;
}
@@ -173,9 +276,9 @@ bool Multiplexer::packet(StreamType type)
header.system_clock_reference1 = TIMECODE32_30(SCR);
header.system_clock_reference2 = TIMECODE29_15(SCR);
header.system_clock_reference3 = TIMECODE14_0(SCR);
- file->Write(*((unsigned long long int*)&header));
+ Write(*((unsigned long long int*)&header));
- file->Write(buf, framesize);
+ Write(buf, framesize);
if(framesize != PACKET_SIZE) return false;
@@ -229,7 +332,7 @@ void Multiplexer::system_header()
// info->info("\t\t[System Header]");
// system_header_start_code (32 bits)
- file->Write((void*)ISO11172_1::system_header_start_code, SIZEOF(ISO11172_1::system_header_start_code));
+ Write((void*)ISO11172_1::system_header_start_code, SIZEOF(ISO11172_1::system_header_start_code));
ISO11172_1::system_header header;
@@ -246,21 +349,21 @@ void Multiplexer::system_header()
header.system_video_clock_flag = 1; // FIXME: What excactly is this??
header.video_bound = 1; // Only 1 video stream
header.reserved_byte = 0xFF; // Must be 0xFF
- file->Write(*((unsigned long long int*)&header));
+ Write(*((unsigned long long int*)&header));
ISO11172_1::stream_description audio_stream_description;
audio_stream_description.stream_id = 0xC0;
audio_stream_description.market_bits = 0x3;
audio_stream_description.STD_buffer_bound_scale = 0; // Must be 0 for audio streams
audio_stream_description.STD_buffer_size_bound = 32; // Buffer must be 32 * 128 bytes
- file->Write(*((unsigned long int*)&audio_stream_description));
+ Write(*((unsigned long int*)&audio_stream_description));
ISO11172_1::stream_description video_stream_description;
video_stream_description.stream_id = 0xE3;
video_stream_description.market_bits = 0x3;
video_stream_description.STD_buffer_bound_scale = 1; // Must be 1 for video streams
video_stream_description.STD_buffer_size_bound = 46; // Buffer must be 32 * 1024 bytes
- file->Write(*((unsigned long int*)&video_stream_description));
+ Write(*((unsigned long int*)&video_stream_description));
}
/**
@@ -270,7 +373,7 @@ bool Multiplexer::pack()
{
// info->info("\t[Pack");
- file->Write((void*)ISO11172_1::pack_start_code, SIZEOF(ISO11172_1::pack_start_code));
+ Write((void*)ISO11172_1::pack_start_code, SIZEOF(ISO11172_1::pack_start_code));
ISO11172_1::pack_header header;
// Set marker bits to 1
@@ -320,7 +423,7 @@ bool Multiplexer::pack()
(unsigned long long int)header.system_clock_reference3
);
*/
- file->Write(*((unsigned long long int*)&header));
+ Write(*((unsigned long long int*)&header));
if(write_system_header % SYSTEM_HEADER_FREQUENCY == 0) system_header();
// Count this up here, we want a system header in pack 0, 5, ... NOT 4, 9, ...
@@ -345,7 +448,7 @@ void Multiplexer::iso11172_stream()
// info->info("]");
// info->info("[iso11172_end_code]");
- file->Write((void*)ISO11172_1::end_code, SIZEOF(ISO11172_1::end_code));
+ Write((void*)ISO11172_1::end_code, SIZEOF(ISO11172_1::end_code));
/*
info->info("false && false = %d", false && false);
@@ -354,7 +457,7 @@ void Multiplexer::iso11172_stream()
*/
}
-//#define BYPASS TYPE_VIDEO
+#define BYPASS TYPE_VIDEO
//#define BYPASS TYPE_AUDIO
void Multiplexer::multiplex()
{
@@ -365,7 +468,7 @@ void Multiplexer::multiplex()
do {
frmsz = read_stream(buf, sizeof(buf), BYPASS);
info->info("Wrote %d bytes", frmsz);
- file->Write(buf, frmsz);
+ Write(buf, frmsz);
} while(frmsz == sizeof(buf));
return;
diff --git a/src/multiplexer.h b/src/multiplexer.h
index 2604ddc..9959009 100644
--- a/src/multiplexer.h
+++ b/src/multiplexer.h
@@ -33,6 +33,7 @@
#include "iso11172-3.h"
#include "file.h"
+#include "multicast.h"
#include "info.h"
#include "frame.h"
@@ -68,7 +69,7 @@ typedef enum {
class Multiplexer {
public:
- Multiplexer(File *file, Info *info, volatile bool *running,
+ Multiplexer(File *file, Multicast *m, Info *info, volatile bool *running,
ThreadSafeQueuePriority *video_queue,
ThreadSafeQueuePriority *audio_queue);
~Multiplexer();
@@ -76,6 +77,17 @@ public:
void multiplex();
private:
+ int Write(void* data, int size);
+ int Write(char* data, int size);
+ int Write(unsigned long long int val);
+ int Write(long long int val);
+ int Write(long int val);
+ int Write(unsigned long int val);
+ int Write(int val);
+ int Write(unsigned int val);
+ int Write(short int val);
+ int Write(unsigned short int val);
+
unsigned long long int SCR;
double written[NUM_TYPES];
@@ -109,6 +121,7 @@ private:
unsigned int read[NUM_TYPES];
File *file;
+ Multicast *multicast;
Info *info;
volatile bool *running;
diff --git a/src/threadsafe_queue_fifo.h b/src/threadsafe_queue_fifo.h
index 84b2fbb..30f6645 100644
--- a/src/threadsafe_queue_fifo.h
+++ b/src/threadsafe_queue_fifo.h
@@ -77,6 +77,4 @@ private:
std::queue<T> queue;
};
-
-
#endif/*__MIAV_THREADSAFE_QUEUE_FIFO_H__*/
--
cgit v1.2.3