#define DEFAULT_DEVICE "default"
static void update_usage(struct userdata *u) {
- pa_module_set_used(u->module,
- (u->sink ? pa_idxset_size(u->sink->inputs) : 0) +
- (u->sink ? pa_idxset_size(u->sink->monitor_source->outputs) : 0));
+ pa_module_set_used(u->module, u->sink ? pa_sink_used_by(u->sink) : 0);
}
static void clear_up(struct userdata *u) {
#define DEFAULT_DEVICE "default"
static void update_usage(struct userdata *u) {
- pa_module_set_used(u->module,
- (u->source ? pa_idxset_size(u->source->outputs) : 0));
+ pa_module_set_used(u->module, u->source ? pa_source_used_by(u->source) : 0);
}
static void clear_up(struct userdata *u) {
static void clear_up(struct userdata *u);
static void update_usage(struct userdata *u) {
- pa_module_set_used(u->module,
- (u->sink ? pa_idxset_size(u->sink->inputs) : 0) +
- (u->sink ? pa_idxset_size(u->sink->monitor_source->outputs) : 0));
+ pa_module_set_used(u->module, u->sink ? pa_sink_used_by(u->sink) : 0);
}
-
static void adjust_rates(struct userdata *u) {
struct output *o;
pa_usec_t max_sink_latency = 0, min_total_latency = (pa_usec_t) -1, target_latency;
u->write_index = u->write_length = 0;
}
} else if (u->state == STATE_RUNNING) {
- pa_module_set_used(u->module, pa_idxset_size(u->sink->inputs) + pa_idxset_size(u->sink->monitor_source->outputs));
+ pa_module_set_used(u->module, pa_sink_used_by(u->sink));
if (!u->memchunk.length)
if (pa_sink_render(u->sink, 8192, &u->memchunk) < 0)
#define DEFAULT_FRAGSIZE 1024
static void update_usage(struct userdata *u) {
- pa_module_set_used(u->module,
- (u->sink ? pa_idxset_size(u->sink->inputs) : 0) +
- (u->sink ? pa_idxset_size(u->sink->monitor_source->outputs) : 0) +
- (u->source ? pa_idxset_size(u->source->outputs) : 0));
+ pa_module_set_used(u->module,
+ (u->sink ? pa_sink_used_by(u->sink) : 0) +
+ (u->source ? pa_source_used_by(u->source) : 0));
}
static void clear_up(struct userdata *u) {
#define DEFAULT_DEVICE "/dev/dsp"
static void update_usage(struct userdata *u) {
- pa_module_set_used(u->module,
- (u->sink ? pa_idxset_size(u->sink->inputs) : 0) +
- (u->sink ? pa_idxset_size(u->sink->monitor_source->outputs) : 0) +
- (u->source ? pa_idxset_size(u->source->outputs) : 0));
+ pa_module_set_used(u->module,
+ (u->sink ? pa_sink_used_by(u->sink) : 0) +
+ (u->source ? pa_source_used_by(u->source) : 0));
}
static void clear_up(struct userdata *u) {
if (!pa_iochannel_is_writable(u->io))
return;
- pa_module_set_used(u->module, pa_idxset_size(u->sink->inputs) + pa_idxset_size(u->sink->monitor_source->outputs));
+ pa_module_set_used(u->module, pa_sink_used_by(u->sink));
if (!u->memchunk.length)
if (pa_sink_render(u->sink, PIPE_BUF, &u->memchunk) < 0)
static void update_usage(struct userdata *u) {
pa_module_set_used(u->module,
- (u->sink ? pa_idxset_size(u->sink->inputs) : 0) +
- (u->sink ? pa_idxset_size(u->sink->monitor_source->outputs) : 0) +
- (u->source ? pa_idxset_size(u->source->outputs) : 0));
+ (u->sink ? pa_sink_used_by(u->sink) : 0) +
+ (u->source ? pa_source_used_by(u->source) : 0));
}
static void do_write(struct userdata *u) {
static void update_usage(struct userdata *u) {
pa_module_set_used(u->module,
- (u->sink ? pa_idxset_size(u->sink->inputs) : 0) +
- (u->sink ? pa_idxset_size(u->sink->monitor_source->outputs) : 0) +
- (u->source ? pa_idxset_size(u->source->outputs) : 0));
+ (u->sink ? pa_sink_used_by(u->sink) : 0) +
+ (u->source ? pa_source_used_by(u->source) : 0));
}
static void do_write(struct userdata *u)