media-add-ons/mixer/AudioMixer.cpp

103 	fCore(new MixerCore(this)),
131 		fCore->Settings()->SetSettingsFile(path.Path());
147 	fCore->Lock();
148 	fCore->Stop();
149 	fCore->Unlock();
154 	delete fCore;
157 	DEBUG_ONLY(fCore = 0; fBufferGroup = 0; fWeb = 0);
164 	fCore->Lock();
165 	fCore->SetOutputAttenuation(fCore->Settings()->AttenuateOutput() ? 0.708 : 1.0);
166 	fCore->Unlock();
244 	fCore->Lock();
245 	MixerOutput *output = fCore->Output();
248 	fCore->Unlock();
278 	fCore->Lock();
280 	input = fCore->Input(*cookie - 1);
282 		fCore->Unlock();
287 	fCore->Unlock();
351 	fCore->Lock();
352 	fCore->BufferReceived(buffer, lateness);
353 	fCore->Unlock();
410 		MixerOutput *output = fCore->Output();
423 	fCore->Lock();
426 	out_input->destination.id = fCore->CreateInputID();
439 	input = fCore->AddInput(*out_input);
441 	fCore->Settings()->LoadConnectionSettings(input);
443 	fCore->Unlock();
468 	fCore->Lock();
470 	if (!fCore->RemoveInput(where.id)) {
474 	fCore->Unlock();
492 	if (fCore->Settings()->RefuseInputFormatChange()) {
503 	fCore->Lock();
504 	fCore->InputFormatChanged(consumer.id, format.u.raw_audio);
505 	fCore->Unlock();
575 	if (fCore->Settings()->RefuseOutputFormatChange()) {
580 	fCore->Lock();
584 	MixerOutput *output = fCore->Output();
639 	fCore->SetTimingInfo(TimeSource(), fDownstreamLatency);
642 	fCore->OutputFormatChanged(io_format->u.raw_audio);
650 		fCore->SetOutputBufferGroup(fBufferGroup);
654 	fCore->Unlock();
667 	fCore->Lock();
668 	MixerOutput *output = fCore->Output();
680 	fCore->Unlock();
710 	fCore->Lock();
716 	fCore->SetOutputBufferGroup(newGroup);
719 	fCore->Unlock();
766 	fCore->Lock();
767 	fCore->SetTimingInfo(TimeSource(), fDownstreamLatency);
769 	fCore->Unlock();
803 	fCore->Lock();
806 	if (fCore->Output() != 0) {
807 		fCore->Unlock();
875 	fCore->EnableOutput(false);
876 	fCore->AddOutput(output);
878 	fCore->Unlock();
889 	fCore->Lock();
891 	if (fCore->Output() == 0) {
892 		fCore->Unlock();
896 	fCore->Unlock();
902 		fCore->Lock();
903 		fCore->RemoveOutput();
904 		fCore->Unlock();
937 	fCore->Lock();
950 	ASSERT(fCore->Output() != 0);
953 	ASSERT(fCore->Output()->MediaOutput().source.id == 0);
954 	ASSERT(fCore->Output()->MediaOutput().source.port == ControlPort());
959 	fCore->Output()->MediaOutput().destination = dest;
961 	fCore->EnableOutput(true);
962 	fCore->SetTimingInfo(TimeSource(), fDownstreamLatency);
963 	fCore->SetOutputBufferGroup(fBufferGroup);
965 	fCore->Settings()->LoadConnectionSettings(fCore->Output());
967 	fCore->Unlock();
976 	fCore->Lock();
979 	MixerOutput* output = fCore->Output();
985 		fCore->Unlock();
995 	fCore->Stop();
997 	fCore->RemoveOutput();
1002 	fCore->SetOutputBufferGroup(0);
1004 	fCore->Unlock();
1020 	if (what == fCore->Output()->MediaOutput().source
1053 	fCore->Lock();
1054 	fCore->EnableOutput(enabled);
1055 	fCore->Unlock();
1076 	fCore->Lock();
1077 	fCore->SetTimingInfo(timeSource, fDownstreamLatency);
1078 	fCore->Unlock();
1098 				fCore->Lock();
1099 				fCore->Start();
1100 				fCore->Unlock();
1112 			fCore->Lock();
1113 			fCore->Stop();
1114 			fCore->Unlock();
1125 			fCore->Process();
1145 	fCore->Lock();
1148 	for (int i = 0; (input = fCore->Input(i)) != 0; i++) {
1158 	fCore->Unlock();
1176 	fCore->Lock();
1177 	uint32 size = fCore->Output()->MediaOutput().format.u.raw_audio.buffer_size;
1178 	fCore->Unlock();
1254 	fCore->Lock();
1259 				static_cast<int32 *>(value)[0] = fCore->Settings()->AttenuateOutput();
1263 				static_cast<int32 *>(value)[0] = fCore->Settings()->UseBalanceControl();
1267 				static_cast<int32 *>(value)[0] = fCore->Settings()->AllowOutputChannelRemapping();
1271 				static_cast<int32 *>(value)[0] = fCore->Settings()->AllowInputChannelRemapping();
1275 				static_cast<int32 *>(value)[0] = fCore->Settings()->InputGainControls();
1279 				static_cast<int32 *>(value)[0] = fCore->Settings()->ResamplingAlgorithm();
1283 				static_cast<int32 *>(value)[0] = fCore->Settings()->RefuseOutputFormatChange();
1287 				static_cast<int32 *>(value)[0] = fCore->Settings()->RefuseInputFormatChange();
1294 		MixerOutput *output = fCore->Output();
1306 			if (fCore->Settings()->UseBalanceControl() && output->GetOutputChannelCount() == 2 && 1 /*channel mask is stereo */) {
1365 		for (int i = 0; (input = fCore->Input(i)); i++)
1379 			if (fCore->Settings()->InputGainControls() == 0) {
1381 				if (fCore->Settings()->UseBalanceControl() && input->GetInputChannelCount() == 2 && 1 /*channel mask is stereo */) {
1397 				if (fCore->Settings()->UseBalanceControl() && input->GetMixerChannelCount() == 2 && 1 /*channel mask is stereo */) {
1414 			if (fCore->Settings()->InputGainControls() == 0) {
1444 	fCore->Unlock();
1447 	fCore->Unlock();
1459 	fCore->Lock();
1465 				fCore->Settings()->SetAttenuateOutput(static_cast<const int32 *>(value)[0]);
1467 				fCore->SetOutputAttenuation((static_cast<const int32 *>(value)[0]) ? 0.708 : 1.0);
1472 				fCore->Settings()->SetUseBalanceControl(static_cast<const int32 *>(value)[0]);
1478 				fCore->Settings()->SetAllowOutputChannelRemapping(static_cast<const int32 *>(value)[0]);
1484 				fCore->Settings()->SetAllowInputChannelRemapping(static_cast<const int32 *>(value)[0]);
1492 				fCore->Settings()->SetInputGainControls(static_cast<const int32 *>(value)[0]);
1498 				fCore->Settings()->SetResamplingAlgorithm(static_cast<const int32 *>(value)[0]);
1499 				fCore->UpdateResamplingAlgorithm();
1504 				fCore->Settings()->SetRefuseOutputFormatChange(static_cast<const int32 *>(value)[0]);
1509 				fCore->Settings()->SetRefuseInputFormatChange(static_cast<const int32 *>(value)[0]);
1516 		MixerOutput *output = fCore->Output();
1527 			if (fCore->Settings()->UseBalanceControl()
1587 		fCore->Settings()->SaveConnectionSettings(output);
1590 		for (int i = 0; (input = fCore->Input(i)); i++)
1603 			if (fCore->Settings()->InputGainControls() == 0) {
1605 				if (fCore->Settings()->UseBalanceControl() && input->GetInputChannelCount() == 2 && 1 /*channel mask is stereo */) {
1624 				if (fCore->Settings()->UseBalanceControl() && input->GetMixerChannelCount() == 2 && 1 /*channel mask is stereo */) {
1644 			if (fCore->Settings()->InputGainControls() == 0) {
1692 		fCore->Settings()->SaveConnectionSettings(input);
1698 	fCore->Unlock();
1707 	fCore->Lock();
1722 	out = fCore->Output();
1734 		if (fCore->Settings()->UseBalanceControl()
1754 	for (int i = 0; (in = fCore->Input(i)); i++) {
1764 		if (fCore->Settings()->InputGainControls() == 0) {
1766 			if (fCore->Settings()->UseBalanceControl()
1784 			if (fCore->Settings()->UseBalanceControl()
1805 	if (fCore->Settings()->AllowOutputChannelRemapping()) {
1838 	if (fCore->Settings()->AllowInputChannelRemapping()) {
1844 		for (int i = 0; (in = fCore->Input(i)); i++) {
1901 	fCore->Unlock();