1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
|
/***************************************************************************
encoder.h - description
-------------------
begin : Thu May 05 2005
copyright : (C) 2005 by Martin Witte
email : witte@kawo1.rwth-aachen.de
***************************************************************************/
/***************************************************************************
* *
* This program is free software; you can redistribute it and/or modify *
* it under the terms of the GNU General Public License as published by *
* the Free Software Foundation; either version 2 of the License, or *
* (at your option) any later version. *
* *
***************************************************************************/
#ifndef KRADIO_RECORDING_ENCODER_H
#define KRADIO_RECORDING_ENCODER_H
#ifdef HAVE_CONFIG_H
#include <config.h>
#endif
#include <tqobject.h>
#include <tqstring.h>
#include <tqthread.h>
#include "../../src/include/radiostation.h"
#include "../../src/include/multibuffer.h"
#include "../../src/include/sound_metadata.h"
#include "../../src/include/soundstreamid.h"
#include "recording-config.h"
class BufferSoundMetaData : public SoundMetaData
{
public:
BufferSoundMetaData()
: SoundMetaData(0, 0, 0, KURL()), m_BufferPosition(0) {}
BufferSoundMetaData(const SoundMetaData &md, size_t bufferpos)
: SoundMetaData(md), m_BufferPosition(bufferpos) {}
BufferSoundMetaData(TQ_INT64 pos, time_t rel, time_t abs, const KURL &url, size_t bufferpos)
: SoundMetaData(pos, rel, abs, url), m_BufferPosition(bufferpos) {}
size_t bufferPosition() const { return m_BufferPosition; }
protected:
size_t m_BufferPosition;
};
class RecordingEncoding : public TQThread
{
public:
RecordingEncoding(TQObject *tqparent, SoundStreamID id, const RecordingConfig &cfg, const RadioStation *rs, const TQString &filename);
virtual ~RecordingEncoding();
void run();
char *lockInputBuffer(size_t &bufferSize); // bytes we whish to write, returns number of bytes available
void unlockInputBuffer(size_t bufferSize, const SoundMetaData &md); // bytes we actually wrote
bool error() const { return m_error; }
const TQString &errorString() const { return m_errorString; }
void setDone();
bool IsDone() { return m_done; }
virtual bool openOutput(const TQString &outputFile) = 0;
virtual void closeOutput() = 0;
TQ_UINT64 encodedSize() const { return m_encodedSize; }
const RecordingConfig &config() const { return m_config; }
protected:
virtual void encode(const char *_buffer, size_t buffer_size, char *&export_buffer, size_t &export_buffer_size) = 0;
TQObject *m_parent;
RecordingConfig m_config;
RadioStation *m_RadioStation;
SoundStreamID m_SoundStreamID;
bool m_error;
TQString m_errorString;
bool m_done;
MultiBuffer m_InputBuffers;
TQPtrList<BufferSoundMetaData>
**m_buffersMetaData;
TQ_UINT64 m_encodedSize;
time_t m_InputStartTime;
TQ_UINT64 m_InputStartPosition;
KURL m_outputURL;
};
#endif
|
