genode/repos/dde_linux/src/lib/legacy/wifi/init.cc

/*
 * \brief  Linux wireless stack
 * \author Josef Soentgen
 * \date   2014-03-03
 */

/*
 * Copyright (C) 2014-2017 Genode Labs GmbH
 *
 * This file is distributed under the terms of the GNU General Public License
 * version 2.
 */

/* Genode includes */
#include <base/env.h>
#include <base/blockade.h>

/* local includes */
#include <firmware_list.h>
#include <lx.h>

#include <lx_emul.h>

#include <legacy/lx_kit/malloc.h>
#include <legacy/lx_kit/env.h>
#include <legacy/lx_kit/irq.h>
#include <legacy/lx_kit/work.h>
#include <legacy/lx_kit/timer.h>
#include <legacy/lx_kit/pci.h>


/*********************
 ** RFKILL handling **
 *********************/

#include <linux/rfkill.h>

extern "C" void rfkill_switch_all(enum rfkill_type type, bool blocked);
extern "C" bool rfkill_get_any(enum rfkill_type type);

#include <wifi/rfkill.h>

bool wifi_get_rfkill(void)
{
	return rfkill_get_any(RFKILL_TYPE_WLAN);
}


static Lx::Task *_lx_task       = nullptr;
static bool      _lx_init_done  = false;
static bool      _switch_rfkill = false;
static bool      _new_blocked   = false;
static Genode::Signal_context_capability _rfkill_sig_ctx;


void wifi_set_rfkill(bool blocked)
{
	bool const cur = wifi_get_rfkill();

	_switch_rfkill = blocked != cur;
	if (_lx_init_done && _switch_rfkill) {
		_new_blocked = blocked;

		_lx_task->unblock();
		Lx::scheduler().schedule();
	}
}


extern "C" unsigned int wifi_ifindex(void)
{
	return 1;
}


extern "C" char const wifi_ifname(void)
{
	return "wlan0";
}


/**************************
 ** socketcall poll hack **
 **************************/

void wifi_kick_socketcall()
{
	/*
	 * Kicking is going to unblock the socketcall task that
	 * probably is waiting in poll_all().
	 */
	Lx::socket_kick();
}


/*****************************
 ** Initialization handling **
 *****************************/

extern "C" void core_netlink_proto_init(void);
extern "C" void core_sock_init(void);
extern "C" void module_packet_init(void);
extern "C" void subsys_genl_init(void);
extern "C" void subsys_rfkill_init(void);
extern "C" void fs_cfg80211_init(void);
extern "C" void subsys_ieee80211_init(void);
extern "C" int module_iwl_drv_init(void);
extern "C" void subsys_cryptomgr_init(void);
extern "C" void module_crypto_ccm_module_init(void);
extern "C" void module_crypto_ctr_module_init(void);
extern "C" void module_aes_init(void);
extern "C" void module_arc4_init(void);
// extern "C" void module_chainiv_module_init(void);
extern "C" void module_krng_mod_init(void);
extern "C" void subsys_leds_init(void);

extern "C" unsigned int *module_param_11n_disable;

struct workqueue_struct *system_power_efficient_wq;
struct workqueue_struct *system_wq;

struct pernet_operations loopback_net_ops;

struct net init_net;
LIST_HEAD(net_namespace_list);


static Genode::Blockade *_wpa_blockade;


static void run_linux(void *args)
{
	system_power_efficient_wq = alloc_workqueue("system_power_efficient_wq", 0, 0);
	system_wq                 = alloc_workqueue("system_wq", 0, 0);

	core_sock_init();
	core_netlink_proto_init();
	module_packet_init();
	subsys_genl_init();
	subsys_rfkill_init();
	subsys_leds_init();
	fs_cfg80211_init();
	subsys_ieee80211_init();

	subsys_cryptomgr_init();
	module_crypto_ccm_module_init();
	module_crypto_ctr_module_init();
	module_aes_init();
	module_arc4_init();

	try {
		int const err = module_iwl_drv_init();
		if (err) { throw -1; }
	} catch (...) {
		Genode::Env &env = *(Genode::Env*)args;

		env.parent().exit(1);
		Genode::sleep_forever();
	}

	_wpa_blockade->wakeup();

	_lx_init_done = true;

	while (1) {
		Lx::scheduler().current()->block_and_schedule();

		if (!_switch_rfkill) { continue; }

		Genode::log("RFKILL: ", _new_blocked ? "BLOCKED" : "UNBLOCKED");
		rfkill_switch_all(RFKILL_TYPE_WLAN, _new_blocked);

		if (!_new_blocked) {
			try {
				bool const ok = Lx::open_device();
				if (!ok) { throw -1; }

			} catch (...) {
				Genode::Env &env = *(Genode::Env*)args;

				env.parent().exit(1);
				Genode::sleep_forever();
			}
		}

		/* notify front end */
		Genode::Signal_transmitter(_rfkill_sig_ctx).submit();
	}
}


unsigned long jiffies;


void wifi_init(Genode::Env                       &env,
               Genode::Blockade                  &blockade,
               bool                               disable_11n,
               Genode::Signal_context_capability  rfkill)
{
	Lx_kit::construct_env(env);

	LX_MUTEX_INIT(crypto_default_rng_lock);
	LX_MUTEX_INIT(fanout_mutex);
	LX_MUTEX_INIT(genl_mutex);
	LX_MUTEX_INIT(proto_list_mutex);
	LX_MUTEX_INIT(rate_ctrl_mutex);
	LX_MUTEX_INIT(reg_regdb_apply_mutex);
	LX_MUTEX_INIT(rfkill_global_mutex);
	LX_MUTEX_INIT(rtnl_mutex);

	_wpa_blockade = &blockade;

	INIT_LIST_HEAD(&init_net.dev_base_head);
	/* add init_net namespace to namespace list */
	list_add_tail_rcu(&init_net.list, &net_namespace_list);

	Lx::scheduler(&env);

	Lx::timer(&env, &env.ep(), &Lx_kit::env().heap(), &jiffies);

	Lx::Irq::irq(&env.ep(), &Lx_kit::env().heap());
	Lx::Work::work_queue(&Lx_kit::env().heap());

	Lx::socket_init(env.ep(), Lx_kit::env().heap());
	Lx::nic_init(env, Lx_kit::env().heap());

	Lx::pci_init(env, env.ram(), Lx_kit::env().heap());
	Lx::malloc_init(env, Lx_kit::env().heap());

	/* set IWL_DISABLE_HT_ALL if disable 11n is requested */
	if (disable_11n) {
		Genode::log("Disable 11n mode");
		*module_param_11n_disable = 1;
	}

	_rfkill_sig_ctx = rfkill;

	/* Linux task (handles the initialization only currently) */
	static Lx::Task linux(run_linux, &env, "linux",
	                      Lx::Task::PRIORITY_0, Lx::scheduler());
	
	_lx_task = &linux;

	/* give all task a first kick before returning */
	Lx::scheduler().schedule();
}