Method callbackEvent

examples/TinyAudio/RtAudio.cpp:1716–2022

}

bool RtApiCore ::callbackEvent(AudioDeviceID deviceId,
							   const AudioBufferList *inBufferList,
							   const AudioBufferList *outBufferList)
{
	if (stream_.state == STREAM_STOPPED || stream_.state == STREAM_STOPPING) return SUCCESS;
	if (stream_.state == STREAM_CLOSED)
	{
		errorText_ = "RtApiCore::callbackEvent(): the stream is closed ... this shouldn't happen!";
		error(RtAudioError::WARNING);
		return FAILURE;
	}

	CallbackInfo *info = (CallbackInfo *)&stream_.callbackInfo;
	CoreHandle *handle = (CoreHandle *)stream_.apiHandle;

	// Check if we were draining the stream and signal is finished.
	if (handle->drainCounter > 3)
	{
		ThreadHandle threadId;

		stream_.state = STREAM_STOPPING;
		if (handle->internalDrain == true)
			pthread_create(&threadId, NULL, coreStopStream, info);
		else  // external call to stopStream()
			pthread_cond_signal(&handle->condition);
		return SUCCESS;
	}

	AudioDeviceID outputDevice = handle->id[0];

	// Invoke user callback to get fresh output data UNLESS we are
	// draining stream or duplex mode AND the input/output devices are
	// different AND this function is called for the input device.
	if (handle->drainCounter == 0 && (stream_.mode != DUPLEX || deviceId == outputDevice))
	{
		RtAudioCallback callback = (RtAudioCallback)info->callback;
		double streamTime = getStreamTime();
		RtAudioStreamStatus status = 0;
		if (stream_.mode != INPUT && handle->xrun[0] == true)
		{
			status |= RTAUDIO_OUTPUT_UNDERFLOW;
			handle->xrun[0] = false;
		}
		if (stream_.mode != OUTPUT && handle->xrun[1] == true)
		{
			status |= RTAUDIO_INPUT_OVERFLOW;
			handle->xrun[1] = false;
		}

		int cbReturnValue = callback(stream_.userBuffer[0], stream_.userBuffer[1],
									 stream_.bufferSize, streamTime, status, info->userData);
		if (cbReturnValue == 2)
		{
			stream_.state = STREAM_STOPPING;
			handle->drainCounter = 2;
			abortStream();
			return SUCCESS;
		}