blob: 3bd3e691cc75884028ae03b30414fe5bc99c176a (
plain)
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
|
/*
reads input data
Copyright (C) 1999 Martin Vogt
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU Library General Public License as published by
the Free Software Foundation.
For more information look at the file COPYRIGHT in this package
*/
#ifndef __BUFFERINPUTSTREAM_H
#define __BUFFERINPUTSTREAM_H
#include "../util/abstract/abs_thread.h"
#include "inputStream.h"
class SimpleRingBuffer;
class BufferInputStream : public InputStream {
SimpleRingBuffer* ringBuffer;
int leof;
long bytePos;
int fillgrade;
int lLock;
abs_thread_mutex_t writeInMut;
public:
BufferInputStream(int size,int minlinSize,const char* name);
~BufferInputStream();
int open(const char* name);
void close();
int isOpen();
int eof();
void setBlocking(int lblock);
int read(char* ptr,int size);
// reads from a buffer
int write(char* ptr,int len,TimeStamp* stamp);
// this method directy read from another inputstream (faster);
int write(InputStream* ptr,int len,TimeStamp* stamp);
int seek(long bytePos);
long getByteLength();
long getBytePosition();
void setBytePosition(long bytePos);
int getFillgrade();
int getSize();
int getFreeRead();
int getFreeSpace();
void clear();
// remote read extension
// Note you _need_ to call always both methods
// readRemote and forwardReadPtr even if bytes==0!!!
// (we hold a resizeLock during this operation)
int readRemote(char** ptr,int size);
void forwardReadPtr(int bytes);
void setCanWaitForData(int lBlock);
// this method is only safe to call by the writer in the buffer
// a reader never should call this (segfault possible)
void resizeBuffer(int changeSize);
// for pause/play over loopback
int getHold();
void setHold(int lLock);
private:
void lockBuffer();
void unlockBuffer();
};
#endif
|
