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
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
|
/*
* FILE: codec_state.c
* PROGRAM: RAT
* AUTHOR: Orion Hodson
*
* Copyright (c) 1995-2001 University College London
* All rights reserved.
*/
#ifndef HIDE_SOURCE_STRINGS
static const char cvsid[] =
"$Id: codec_state.c,v 1.7 2001/01/08 20:29:57 ucaccsp Exp $";
#endif /* HIDE_SOURCE_STRINGS */
#include "config_unix.h"
#include "config_win32.h"
#include "debug.h"
#include "memory.h"
#include "audio_types.h"
#include "codec_types.h"
#include "codec.h"
#include "codec_state.h"
#define CODEC_STORE_UNIT_SIZE 3
typedef struct s_codec_state_store {
codec_state **buffer;
int used;
int allocated;
codec_mode mode;
} codec_state_store_t;
int
codec_state_store_create(codec_state_store_t **s, codec_mode m)
{
codec_state_store_t *css;
css = (codec_state_store_t*)xmalloc(sizeof(codec_state_store_t));
if (css) {
css->buffer = (codec_state**)xmalloc(CODEC_STORE_UNIT_SIZE * sizeof(codec_state*));
css->used = 0;
css->allocated = CODEC_STORE_UNIT_SIZE;
css->mode = m;
*s = css;
return TRUE;
}
return FALSE;
}
static int
codec_state_store_expand(codec_state_store_t *css)
{
int i;
codec_state **buffer;
/* This should very very rarely get called */
buffer = (codec_state**)xmalloc((css->allocated + CODEC_STORE_UNIT_SIZE) * sizeof(codec_state*));
memset(buffer + CODEC_STORE_UNIT_SIZE*sizeof(codec_state*), 0,
CODEC_STORE_UNIT_SIZE*sizeof(codec_state*));
for(i = 0; i < css->allocated; i++) {
buffer[i] = css->buffer[i];
}
xmemchk();
xfree(css->buffer);
css->buffer = buffer;
css->allocated += CODEC_STORE_UNIT_SIZE;
return TRUE;
}
codec_state *
codec_state_store_get(codec_state_store_t *css, codec_id_t id)
{
codec_state *s;
int i;
for(i = 0; i < css->used; i++) {
if (css->buffer[i]->id == id) {
return css->buffer[i];
}
}
/* Did not find state */
switch (css->mode) {
case ENCODER:
codec_encoder_create(id, &s);
break;
case DECODER:
codec_decoder_create(id, &s);
break;
}
if (css->used == css->allocated) {
codec_state_store_expand(css);
debug_msg("Expanding storage for participant states.\n");
}
css->buffer[css->used] = s;
css->used++;
return s;
}
void
codec_state_store_destroy(codec_state_store_t **css)
{
int i;
switch((*css)->mode) {
case ENCODER:
for(i = 0; i < (*css)->used; i++) {
codec_encoder_destroy(&(*css)->buffer[i]);
}
break;
case DECODER:
for(i = 0; i < (*css)->used; i++) {
codec_decoder_destroy(&(*css)->buffer[i]);
}
break;
}
xfree((*css)->buffer);
xfree(*css);
*css = NULL;
}
void
codec_state_store_remove (codec_state_store_t *css,
codec_id_t id)
{
int new_idx, old_idx;
for(new_idx = old_idx = 0; old_idx < css->used; old_idx++) {
if (css->buffer[old_idx]->id == id) {
switch(css->mode) {
case ENCODER:
codec_encoder_destroy(&css->buffer[old_idx]);
break;
case DECODER:
codec_decoder_destroy(&css->buffer[old_idx]);
break;
}
css->used --;
} else {
/* These are not the droids we are looking for... */
new_idx++;
}
}
}
|
