module executor

import sync

// is_owner_thread reports whether the caller is currently inside an active owner pump.
pub fn (e &Executor) is_owner_thread() bool {
	e.mutex.lock()
	is_owner := e.owner_active && e.owner_thread_id == sync.thread_id()
	e.mutex.unlock()
	return is_owner
}

// assert_owner_thread returns an error when called outside the active owner pump.
pub fn (e &Executor) assert_owner_thread() ! {
	if !e.is_owner_thread() {
		return error(err_not_owner_thread)
	}
}

fn (mut e Executor) begin_owner_pump(long_running bool) ! {
	e.mutex.lock()
	if e.stopped && long_running {
		e.mutex.unlock()
		return error(err_executor_stopped)
	}
	if e.pumping {
		e.mutex.unlock()
		return error(err_owner_pump_running)
	}
	e.pumping = true
	e.run_active = long_running
	e.owner_active = true
	e.owner_thread_id = sync.thread_id()
	e.mutex.unlock()
}

fn (mut e Executor) end_owner_pump() {
	e.mutex.lock()
	e.pumping = false
	e.run_active = false
	e.owner_active = false
	e.owner_thread_id = 0
	e.mutex.unlock()
}