/*
 * oFono - Open Source Telephony
 * Copyright (C) 2008-2012  Intel Corporation
 *
 * SPDX-License-Identifier: GPL-2.0-only
 */

#ifdef HAVE_CONFIG_H
#include <config.h>
#endif

#include <errno.h>
#include <fcntl.h>
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <net/if.h>
#include <sys/stat.h>

#define OFONO_API_SUBJECT_TO_CHANGE
#include <ofono/plugin.h>
#include <ofono/modem.h>
#include <ofono/call-barring.h>
#include <ofono/call-forwarding.h>
#include <ofono/call-settings.h>
#include <ofono/devinfo.h>
#include <ofono/netreg.h>
#include <ofono/netmon.h>
#include <ofono/phonebook.h>
#include <ofono/voicecall.h>
#include <ofono/sim.h>
#include <ofono/stk.h>
#include <ofono/sms.h>
#include <ofono/ussd.h>
#include <ofono/gprs.h>
#include <ofono/gprs-context.h>
#include <ofono/lte.h>
#include <ofono/radio-settings.h>
#include <ofono/location-reporting.h>
#include <ofono/log.h>
#include <ofono/message-waiting.h>

#include <ell/ell.h>

#include <drivers/qmimodem/qmi.h>
#include <drivers/qmimodem/dms.h>
#include <drivers/qmimodem/wda.h>
#include <drivers/qmimodem/util.h>
#include <drivers/qmimodem/common.h>
#include "src/rmnet.h"

#define GOBI_DMS	(1 << 0)
#define GOBI_NAS	(1 << 1)
#define GOBI_WMS	(1 << 2)
#define GOBI_WDS	(1 << 3)
#define GOBI_PDS	(1 << 4)
#define GOBI_UIM	(1 << 5)
#define GOBI_VOICE	(1 << 6)
#define GOBI_WDA	(1 << 7)

#define MAX_CONTEXTS 4
#define DEFAULT_MTU 1400
#define RMNET_MAX_MTU 16384
#define DEFAULT_DL_DATAGRAMS 32

#define QMI_WWAN_RAW_IP "/sys/class/net/%s/qmi/raw_ip"
#define QMI_WWAN_PASS_THROUGH "/sys/class/net/%s/qmi/pass_through"

enum wda_data_format {
	WDA_DATA_FORMAT_UNKNOWN = 0,
	WDA_DATA_FORMAT_RMNET_QMAP5,
	WDA_DATA_FORMAT_RAW_IP,
	WDA_DATA_FORMAT_802_3,	/* Last, most compatible legacy fallback */
};

struct service_request {
	struct qmi_service **member;
	uint32_t service_type;
};

struct gobi_data {
	struct qmi_qmux_device *device;
	struct qmi_service *dms;
	struct qmi_service *wda;
	struct qmi_service *nas;
	struct qmi_service *wds;
	struct qmi_service *wms;
	struct qmi_service *voice;
	struct qmi_service *pds;
	struct qmi_service *uim;
	struct {
		struct qmi_service *wds_ipv4;
		struct qmi_service *wds_ipv6;
	} context_services[MAX_CONTEXTS];
	struct rmnet_ifinfo rmnet_interfaces[MAX_CONTEXTS];
	uint8_t n_premux;
	int rmnet_id;
	struct service_request service_requests[8 + MAX_CONTEXTS * 2];
	int cur_service_request;
	int num_service_requests;
	unsigned long features;
	unsigned int discover_attempts;
	uint8_t oper_mode;
	int main_net_ifindex;
	char main_net_name[IFNAMSIZ];
	uint8_t interface_number;
	uint32_t max_aggregation_size;
	uint32_t set_powered_id;
	uint32_t set_mtu_id;
	enum wda_data_format data_format;
	bool no_pass_through : 1;
};

static void gobi_debug(const char *str, void *user_data)
{
	const char *prefix = user_data;

	ofono_debug("%s%s", prefix, str);
}

static void gobi_io_debug(const char *str, void *user_data)
{
	const char *prefix = user_data;

	ofono_debug("%s%s", prefix, str);
}

static bool wda_get_data_format(struct gobi_data *data,
				struct qmi_wda_data_format *out_format)
{
	if (data->data_format == WDA_DATA_FORMAT_UNKNOWN ||
			data->data_format > WDA_DATA_FORMAT_802_3)
		return false;

	memset(out_format, 0, sizeof(struct qmi_wda_data_format));

	if (data->data_format == WDA_DATA_FORMAT_802_3) {
		out_format->ll_protocol = QMI_WDA_DATA_LINK_PROTOCOL_802_3;
		return true;
	}

	/* For everything except 802.3, use RAW_IP */
	out_format->ll_protocol = QMI_WDA_DATA_LINK_PROTOCOL_RAW_IP;

	if (data->data_format == WDA_DATA_FORMAT_RAW_IP)
		goto done;

	out_format->dl_max_datagrams = DEFAULT_DL_DATAGRAMS;
	out_format->dl_max_size = data->max_aggregation_size;

	if (data->data_format == WDA_DATA_FORMAT_RMNET_QMAP5) {
		out_format->ul_aggregation_protocol =
					QMI_WDA_AGGREGATION_PROTOCOL_QMAPV5;
		out_format->dl_aggregation_protocol =
					QMI_WDA_AGGREGATION_PROTOCOL_QMAPV5;
	}
done:
	return true;
}

static int wda_data_format_to_mtu(enum wda_data_format format, uint32_t *out_mtu)
{
	uint32_t mtu;

	switch (format) {
	case WDA_DATA_FORMAT_802_3:
	case WDA_DATA_FORMAT_RAW_IP:
		mtu = DEFAULT_MTU;
		break;
	case WDA_DATA_FORMAT_RMNET_QMAP5:
		mtu = RMNET_MAX_MTU;
		break;
	default:
		return -ENOTSUP;
	}

	if (out_mtu)
		*out_mtu = mtu;

	return 0;
}

static int qmi_wwan_set_raw_ip(const char *interface, char value)
{
	return l_sysctl_set_char(value, QMI_WWAN_RAW_IP, interface);
}

static int qmi_wwan_set_pass_through(const char *interface, char value)
{
	return l_sysctl_set_char(value, QMI_WWAN_PASS_THROUGH, interface);
}

/*
 * Probe the modem.  The following modem properties are expected to be set
 * in order to initialize the driver properly:
 *
 * NetworkInterface
 *   The string that contains the 'main' network device.  This is typically
 *   'wwanX' on upstream linux systems.
 *
 * NetworkInterfaceIndex
 *   The index of the main interface given by NetworkInterface
 *
 * InterfaceNumber
 *   The USB interface number of the network interface
 *
 * NetworkInterfaceKernelDriver
 *   The kernel driver that is being used by the main network device.  Only
 *   'qmi_wwan' is supported.
 *
 * Bus
 *   The bus of the modem.  Values can be "usb"
 */
static int gobi_probe(struct ofono_modem *modem)
{
	struct gobi_data *data;
	const char *if_driver;
	const char *ifname;
	uint8_t interface_number;
	int ifindex;
	const char *bus;
	struct stat st;
	_auto_(l_free) char *pass_through = NULL;
	bool no_pass_through = false;

	DBG("%p", modem);

	if_driver = ofono_modem_get_string(modem,
						"NetworkInterfaceKernelDriver");
	ifname = ofono_modem_get_string(modem, "NetworkInterface");
	ifindex = ofono_modem_get_integer(modem, "NetworkInterfaceIndex");
	bus = ofono_modem_get_string(modem, "Bus");

	DBG("net: %s[%s](%d) %s", ifname, if_driver, ifindex, bus);

	if (!if_driver || !ifname || !ifindex || !bus)
		return -EPROTO;

	if (!L_IN_STRSET(if_driver, "qmi_wwan"))
		return -ENOTSUP;

	if (!L_IN_STRSET(bus, "usb"))
		return -ENOTSUP;

	if (l_safe_atox8(ofono_modem_get_string(modem, "InterfaceNumber"),
				&interface_number) < 0)
		return -EINVAL;

	pass_through = l_strdup_printf(QMI_WWAN_PASS_THROUGH, ifname);
	if (stat(pass_through, &st) == -1) {
		if (errno == ENOENT)
			no_pass_through = true;
		else
			return -errno;
	}

	data = l_new(struct gobi_data, 1);
	data->main_net_ifindex = ifindex;
	l_strlcpy(data->main_net_name, ifname, sizeof(data->main_net_name));
	data->interface_number = interface_number;
	data->no_pass_through = no_pass_through;
	/* See drivers/net/ethernet/qualcomm/rmnet/rmnet_private.h */
	data->max_aggregation_size = 16384;

	ofono_modem_set_data(modem, data);
	ofono_modem_set_capabilities(modem, OFONO_MODEM_CAPABILITY_LTE);

	return 0;
}

static void cleanup_services(struct gobi_data *data)
{
	int i;

	qmi_service_free(data->dms);
	data->dms = NULL;

	qmi_service_free(data->wda);
	data->wda = NULL;

	qmi_service_free(data->nas);
	data->nas = NULL;

	qmi_service_free(data->wds);
	data->wds = NULL;

	qmi_service_free(data->wms);
	data->wms = NULL;

	qmi_service_free(data->voice);
	data->voice = NULL;

	qmi_service_free(data->pds);
	data->pds = NULL;

	qmi_service_free(data->uim);
	data->uim = NULL;

	for (i = 0; i < MAX_CONTEXTS; i++) {
		qmi_service_free(data->context_services[i].wds_ipv4);
		qmi_service_free(data->context_services[i].wds_ipv6);
	}

	memset(&data->context_services, 0, sizeof(data->context_services));
}

static void gobi_remove(struct ofono_modem *modem)
{
	struct gobi_data *data = ofono_modem_get_data(modem);

	DBG("%p", modem);

	ofono_modem_set_data(modem, NULL);

	if (data->set_powered_id) {
		l_netlink_cancel(l_rtnl_get(), data->set_powered_id);
		data->set_powered_id = 0;
	}

	if (data->set_mtu_id) {
		l_netlink_cancel(l_rtnl_get(), data->set_mtu_id);
		data->set_mtu_id = 0;
	}

	if (data->rmnet_id) {
		rmnet_cancel(data->rmnet_id);
		data->rmnet_id = 0;
	}

	cleanup_services(data);

	qmi_qmux_device_free(data->device);

	l_free(data);
}

static void add_service_request(struct gobi_data *data,
					struct qmi_service **member,
					uint32_t service_type)
{
	struct service_request req = { .member = member,
					.service_type = service_type };

	if (data->num_service_requests == L_ARRAY_SIZE(data->service_requests)) {
		ofono_error("No room to add service request");
		return;
	}

	data->service_requests[data->num_service_requests++] = req;
}

static void __shutdown_device(struct ofono_modem *modem)
{
	struct gobi_data *data = ofono_modem_get_data(modem);

	data->discover_attempts = 0;
	memset(&data->service_requests, 0, sizeof(data->service_requests));
	data->cur_service_request = 0;
	data->num_service_requests = 0;
	data->features = 0;
	data->data_format = WDA_DATA_FORMAT_UNKNOWN;

	qmi_qmux_device_free(data->device);
	data->device = NULL;
}

static void shutdown_cb(void *user_data)
{
	struct ofono_modem *modem = user_data;

	DBG("");

	__shutdown_device(modem);
	ofono_modem_set_powered(modem, FALSE);
}

static void shutdown_device(struct ofono_modem *modem)
{
	struct gobi_data *data = ofono_modem_get_data(modem);

	DBG("%p", modem);

	cleanup_services(data);

	if (!l_memeqzero(data->rmnet_interfaces,
					sizeof(data->rmnet_interfaces))) {
		rmnet_del_interfaces(data->n_premux, data->rmnet_interfaces);
		data->n_premux = 0;
		memset(data->rmnet_interfaces, 0,
						sizeof(data->rmnet_interfaces));
	}

	if (qmi_qmux_device_shutdown(data->device, shutdown_cb, modem, NULL) < 0)
		shutdown_cb(modem);
}

static void power_reset_cb(struct qmi_result *result, void *user_data)
{
	struct ofono_modem *modem = user_data;

	DBG("");

	if (qmi_result_set_error(result, NULL)) {
		shutdown_device(modem);
		return;
	}

	ofono_modem_set_powered(modem, TRUE);
}

static void get_oper_mode_cb(struct qmi_result *result, void *user_data)
{
	struct ofono_modem *modem = user_data;
	struct gobi_data *data = ofono_modem_get_data(modem);
	struct qmi_param *param;
	uint8_t mode;

	DBG("");

	if (qmi_result_set_error(result, NULL)) {
		shutdown_device(modem);
		return;
	}

	if (!qmi_result_get_uint8(result, QMI_DMS_RESULT_OPER_MODE, &mode)) {
		shutdown_device(modem);
		return;
	}

	data->oper_mode = mode;

	/*
	 * Telit QMI LTE modem must remain online. If powered down, it also
	 * powers down the sim card, and QMI interface has no way to bring
	 * it back alive.
	 */
	if (ofono_modem_get_boolean(modem, "AlwaysOnline")) {
		ofono_modem_set_powered(modem, TRUE);
		return;
	}

	switch (data->oper_mode) {
	case QMI_DMS_OPER_MODE_ONLINE:
		param = qmi_param_new_uint8(QMI_DMS_PARAM_OPER_MODE,
					QMI_DMS_OPER_MODE_LOW_POWER);
		if (!param) {
			shutdown_device(modem);
			return;
		}

		if (qmi_service_send(data->dms, QMI_DMS_SET_OPER_MODE, param,
					power_reset_cb, modem, NULL) > 0)
			return;

		shutdown_device(modem);
		break;
	default:
		ofono_modem_set_powered(modem, TRUE);
		break;
	}
}

static void get_caps_cb(struct qmi_result *result, void *user_data)
{
	struct ofono_modem *modem = user_data;
	struct gobi_data *data = ofono_modem_get_data(modem);
	const struct qmi_dms_device_caps *caps;
	uint16_t len;
	uint8_t i;

	DBG("");

	if (qmi_result_set_error(result, NULL))
		goto error;

	caps = qmi_result_get(result, QMI_DMS_RESULT_DEVICE_CAPS, &len);
	if (!caps)
		goto error;

        DBG("service capabilities %d", caps->data_capa);
        DBG("sim supported %d", caps->sim_supported);

        for (i = 0; i < caps->radio_if_count; i++)
                DBG("radio = %d", caps->radio_if[i]);

	if (qmi_service_send(data->dms, QMI_DMS_GET_OPER_MODE, NULL,
					get_oper_mode_cb, modem, NULL) > 0)
		return;

error:
	shutdown_device(modem);
}

static void request_service_cb(struct qmi_service *service, void *user_data)
{
	struct ofono_modem *modem = user_data;
	struct gobi_data *data = ofono_modem_get_data(modem);
	struct service_request *req =
		&data->service_requests[data->cur_service_request];

	DBG("");

	if (!service)
		goto error;

	*req->member = service;

	data->cur_service_request += 1;
	if (data->cur_service_request == data->num_service_requests) {
		DBG("All services requested, query DMS Capabilities");

		if (qmi_service_send(data->dms, QMI_DMS_GET_CAPS, NULL,
						get_caps_cb, modem, NULL) > 0)
			return;

		goto error;
	}

	req = &data->service_requests[data->cur_service_request];
	DBG("Requesting: %u", req->service_type);

	if (qmi_qmux_device_create_client(data->device, req->service_type,
					request_service_cb, modem, NULL))
		return;

error:
	shutdown_device(modem);
}

static uint32_t start_service_requests(struct ofono_modem *modem)
{
	struct gobi_data *data = ofono_modem_get_data(modem);
	unsigned int i;

	DBG("");

	for (i = 0; i < (data->n_premux ? data->n_premux : 1); i++) {
		add_service_request(data, &data->context_services[i].wds_ipv4,
					QMI_SERVICE_WDS);
		add_service_request(data, &data->context_services[i].wds_ipv6,
					QMI_SERVICE_WDS);
	}

	return qmi_qmux_device_create_client(data->device, QMI_SERVICE_DMS,
				request_service_cb, modem, NULL);
}

static void rmnet_get_interfaces_cb(int error, unsigned int n_interfaces,
					const struct rmnet_ifinfo *interfaces,
					void *user_data)
{
	struct ofono_modem *modem = user_data;
	struct gobi_data *data = ofono_modem_get_data(modem);
	unsigned int i;

	DBG("error: %d, n_interfaces: %u", error, n_interfaces);
	data->rmnet_id = 0;

	if (error)
		goto error;

	DBG("RMNet interfaces created:");

	for (i = 0; i < n_interfaces; i++)
		DBG("\t%s[%d], mux_id: %u",
			interfaces[i].ifname, interfaces[i].ifindex,
			interfaces[i].mux_id);

	memcpy(data->rmnet_interfaces, interfaces,
				sizeof(struct rmnet_ifinfo) * n_interfaces);
	data->n_premux = n_interfaces;

	if (start_service_requests(modem) > 0)
		return;
error:
	shutdown_device(modem);
}

static void enable_set_mtu_cb(int error, uint16_t type,
					const void *msg, uint32_t len,
					void *user_data)
{
	struct ofono_modem *modem = user_data;
	struct gobi_data *data = ofono_modem_get_data(modem);

	DBG("error: %d", error);

	data->set_mtu_id = 0;

	if (error)
		goto error;

	if (data->data_format != WDA_DATA_FORMAT_802_3) {
		DBG("Setting QMI WWAN to raw_ip");

		if (qmi_wwan_set_raw_ip(data->main_net_name, 'Y') < 0) {
			ofono_warn("Unable to set raw_ip");
			goto error;
		}
	}

	if (L_IN_SET(data->data_format, WDA_DATA_FORMAT_RMNET_QMAP5)) {
		DBG("Setting QMI WWAN to pass_through");

		if (qmi_wwan_set_pass_through(data->main_net_name, 'Y') < 0) {
			ofono_error("Unable to set pass_through");
			goto error;
		}

		data->rmnet_id = rmnet_get_interfaces(data->main_net_ifindex,
							MAX_CONTEXTS,
							rmnet_get_interfaces_cb,
							modem, NULL);
		if (data->rmnet_id > 0)
			return;

		ofono_error("Unable to request RMNet interfaces");
		goto error;
	}

	if (start_service_requests(modem) > 0)
		return;
error:
	shutdown_device(modem);
}

/*
 * Some firmware accepts the Set Data Format command successfully, but doesn't
 * change anything.  Try to detect and warn if that happens
 */
static int compare_data_format(struct gobi_data *data, struct qmi_result *result)
{
	struct qmi_wda_data_format expected;
	struct qmi_wda_data_format actual;
	int r;

	if (!wda_get_data_format(data, &expected))
		return -EPROTO;

	r = qmi_wda_parse_data_format(result, &actual);
	if (r < 0)
		return -EBADMSG;

	if (expected.ll_protocol != actual.ll_protocol ||
			expected.ul_aggregation_protocol !=
			actual.ul_aggregation_protocol ||
			expected.dl_aggregation_protocol !=
			actual.dl_aggregation_protocol)
		return -EBADE;

	return 0;
}

static void set_data_format_cb(struct qmi_result *result, void *user_data)
{
	struct ofono_modem *modem = user_data;
	struct gobi_data *data = ofono_modem_get_data(modem);
	struct qmi_endpoint_info endpoint_info = {
		.endpoint_type = QMI_DATA_ENDPOINT_TYPE_HSUSB,
		.interface_number = data->interface_number,
	};
	struct qmi_wda_data_format format;
	uint32_t mtu;

	DBG("");

	if (!qmi_result_set_error(result, NULL)) {
		if (!compare_data_format(data, result))
			goto done;

		ofono_error("Setting Data Format had no effect");
	}

	if (data->data_format == WDA_DATA_FORMAT_802_3)
		goto error;

	DBG("Trying next data format");
	data->data_format += 1;

	if (!wda_get_data_format(data, &format))
		goto error;

	if (qmi_wda_set_data_format(data->wda, &endpoint_info, &format,
					set_data_format_cb, modem, NULL) > 0)
		return;

	goto error;

done:
	DBG("Set Data Format succeeded, try to set MTU...");

	if (L_WARN_ON(wda_data_format_to_mtu(data->data_format, &mtu) < 0))
		goto error;

	data->set_mtu_id = l_rtnl_link_set_mtu(l_rtnl_get(),
						data->main_net_ifindex, mtu,
						enable_set_mtu_cb, modem, NULL);
	if (data->set_mtu_id)
		return;
error:
	shutdown_device(modem);
}

static void create_wda_cb(struct qmi_service *service, void *user_data)
{
	struct ofono_modem *modem = user_data;
	struct gobi_data *data = ofono_modem_get_data(modem);
	struct qmi_endpoint_info endpoint_info = {
		.endpoint_type = QMI_DATA_ENDPOINT_TYPE_HSUSB,
		.interface_number = data->interface_number,
	};
	struct qmi_wda_data_format format;

	DBG("");

	if (!service) {
		DBG("Failed to request WDA service, assume 802.3");

		if (qmi_qmux_device_create_client(data->device, QMI_SERVICE_DMS,
					request_service_cb, modem, NULL) > 0)
			return;

		goto error;
	}

	data->wda = service;

	if (data->no_pass_through)
		data->data_format = WDA_DATA_FORMAT_802_3;
	else
		data->data_format = WDA_DATA_FORMAT_UNKNOWN + 1;

	if (!wda_get_data_format(data, &format))
		goto error;

	if (qmi_wda_set_data_format(data->wda, &endpoint_info, &format,
					set_data_format_cb, modem, NULL) > 0)
		return;
error:
	shutdown_device(modem);
}

static void discover_cb(void *user_data)
{
	struct ofono_modem *modem = user_data;
	struct gobi_data *data = ofono_modem_get_data(modem);
	uint16_t major;
	uint16_t minor;

	DBG("");

	if (qmi_qmux_device_has_service(data->device, QMI_SERVICE_DMS))
		data->features |= GOBI_DMS;
	if (qmi_qmux_device_has_service(data->device, QMI_SERVICE_NAS))
		data->features |= GOBI_NAS;
	if (qmi_qmux_device_has_service(data->device, QMI_SERVICE_WDS))
		data->features |= GOBI_WDS;
	if (qmi_qmux_device_has_service(data->device, QMI_SERVICE_WDA))
		data->features |= GOBI_WDA;
	if (qmi_qmux_device_has_service(data->device, QMI_SERVICE_PDS))
		data->features |= GOBI_PDS;
	if (qmi_qmux_device_has_service(data->device, QMI_SERVICE_UIM))
		data->features |= GOBI_UIM;
	if (qmi_qmux_device_has_service(data->device, QMI_SERVICE_VOICE))
		data->features |= GOBI_VOICE;

	if (qmi_qmux_device_get_service_version(data->device, QMI_SERVICE_WMS,
						&major, &minor)) {
		if (major < 1 || (major == 1 && minor < 2))
			ofono_warn("unsupported WMS version: %u.%u, need: 1.2",
					major, minor);
		else
			data->features |= GOBI_WMS;
	}

	if (!(data->features & GOBI_DMS)) {
		if (++data->discover_attempts < 3 &&
				!qmi_qmux_device_discover(data->device,
								discover_cb,
								modem, NULL))
			return;

		goto error;
	}

	add_service_request(data, &data->dms, QMI_SERVICE_DMS);
	if (data->features & GOBI_NAS)
		add_service_request(data, &data->nas, QMI_SERVICE_NAS);
	if (data->features & GOBI_WDS)
		add_service_request(data, &data->wds, QMI_SERVICE_WDS);
	if (data->features & GOBI_WMS)
		add_service_request(data, &data->wms, QMI_SERVICE_WMS);
	if (data->features & GOBI_VOICE)
		add_service_request(data, &data->voice, QMI_SERVICE_VOICE);
	if (data->features & GOBI_UIM)
		add_service_request(data, &data->uim, QMI_SERVICE_UIM);

	if (qmi_qmux_device_create_client(data->device, QMI_SERVICE_WDA,
						create_wda_cb, modem, NULL))
		return;

error:
	shutdown_device(modem);
}

static void init_powered_down_cb(int error, uint16_t type,
					const void *msg, uint32_t len,
					void *user_data)
{
	struct ofono_modem *modem = user_data;
	struct gobi_data *data = ofono_modem_get_data(modem);
	int r;

	DBG("error: %d", error);

	data->set_powered_id = 0;

	if (error)
		goto error;

	DBG("Setting QMI_WWAN to 802.3 mode");

	/* Must set pass_through first, before toggling raw_ip */
	if (!data->no_pass_through) {
		r = qmi_wwan_set_pass_through(data->main_net_name, 'N');
		if (r < 0) {
			ofono_warn("Unable to reset pass_through");
			goto error;
		}
	}

	r = qmi_wwan_set_raw_ip(data->main_net_name, 'N');
	if (r < 0) {
		ofono_warn("Unable to reset raw_ip");
		goto error;
	}

	r = qmi_qmux_device_discover(data->device, discover_cb, modem, NULL);
	if (!r)
		return;
error:
	__shutdown_device(modem);
}

/*
 * Enable the modem. The following modem properties are optionally set:
 *
 * RequestThrottleTimeUs
 *   The minimum period, in microseconds, in which back-to-back *
 *   modem service requests may be sent.
 *
 */
static int gobi_enable(struct ofono_modem *modem)
{
	struct gobi_data *data = ofono_modem_get_data(modem);
	struct qmi_qmux_device_options options =
					{ QMI_QMUX_DEVICE_QUIRK_NONE, 0 };
	int min_req_period_us;
	const char *device;

	DBG("%p", modem);

	device = ofono_modem_get_string(modem, "Device");
	if (!device)
		return -EINVAL;

	/*
	 * If the QMI minimum service request period property is set, then
	 * set the appropriate QMI QMUX device quirk and value.
	 */
	min_req_period_us = ofono_modem_get_integer(modem,
						"RequestThrottleTimeUs");
	if (min_req_period_us > 0) {
		options.quirks |= QMI_QMUX_DEVICE_QUIRK_REQ_RATE_LIMIT;
		options.min_req_period_us = min_req_period_us;
	}

	data->device = qmi_qmux_device_new(device, &options);
	if (!data->device)
		return -EIO;

	if (getenv("OFONO_QMI_DEBUG"))
		qmi_qmux_device_set_debug(data->device, gobi_debug, "");

	if (getenv("OFONO_QMI_IO_DEBUG"))
		qmi_qmux_device_set_io_debug(data->device,
						gobi_io_debug, "QMI: ");

	data->set_powered_id =
		l_rtnl_set_powered(l_rtnl_get(), data->main_net_ifindex,
					false, init_powered_down_cb,
					modem, NULL);
	if (data->set_powered_id)
		return -EINPROGRESS;

	__shutdown_device(modem);
	return -EIO;
}

static void power_disable_cb(struct qmi_result *result, void *user_data)
{
	struct ofono_modem *modem = user_data;

	DBG("");

	shutdown_device(modem);
}

static int gobi_disable(struct ofono_modem *modem)
{
	struct gobi_data *data = ofono_modem_get_data(modem);
	struct qmi_param *param;

	DBG("%p", modem);

	/*
	 * Telit QMI modem must remain online. If powered down, it also
	 * powers down the sim card, and QMI interface has no way to bring
	 * it back alive.
	 */
	if (ofono_modem_get_boolean(modem, "AlwaysOnline"))
		goto out;

	param = qmi_param_new_uint8(QMI_DMS_PARAM_OPER_MODE,
					QMI_DMS_OPER_MODE_LOW_POWER);
	if (!param)
		return -ENOMEM;

	if (qmi_service_send(data->dms, QMI_DMS_SET_OPER_MODE, param,
					power_disable_cb, modem, NULL) > 0)
		return -EINPROGRESS;

	qmi_param_free(param);
out:
	shutdown_device(modem);

	return -EINPROGRESS;
}

static void set_online_cb(struct qmi_result *result, void *user_data)
{
	struct cb_data *cbd = user_data;
	ofono_modem_online_cb_t cb = cbd->cb;

	DBG("");

	if (qmi_result_set_error(result, NULL))
		CALLBACK_WITH_FAILURE(cb, cbd->data);
	else
		CALLBACK_WITH_SUCCESS(cb, cbd->data);
}

static void powered_up_cb(int error, uint16_t type,
				const void *msg, uint32_t len,
				void *user_data)
{
	struct cb_data *cbd = user_data;
	struct gobi_data *data = cbd->user;
	struct qmi_param *param;
	ofono_modem_online_cb_t cb = cbd->cb;

	DBG("error: %d", error);

	data->set_powered_id = 0;

	if (error)
		goto error;

	param = qmi_param_new_uint8(QMI_DMS_PARAM_OPER_MODE,
						QMI_DMS_OPER_MODE_ONLINE);
	if (!param)
		goto error;

	cb_data_ref(cbd);

	if (qmi_service_send(data->dms, QMI_DMS_SET_OPER_MODE, param,
				set_online_cb, cbd, cb_data_unref) > 0)
		return;

	qmi_param_free(param);
	cb_data_unref(cbd);
error:
	CALLBACK_WITH_FAILURE(cb, cbd->data);
}

static void powered_down_cb(int error, uint16_t type,
				const void *msg, uint32_t len,
				void *user_data)
{
	struct cb_data *cbd = user_data;
	struct gobi_data *data = cbd->user;
	struct qmi_param *param;
	ofono_modem_online_cb_t cb = cbd->cb;

	DBG("error: %d", error);

	data->set_powered_id = 0;

	if (error)
		goto error;

	param = qmi_param_new_uint8(QMI_DMS_PARAM_OPER_MODE,
					QMI_DMS_OPER_MODE_LOW_POWER);
	if (!param)
		goto error;

	cb_data_ref(cbd);

	if (qmi_service_send(data->dms, QMI_DMS_SET_OPER_MODE, param,
				set_online_cb, cbd, cb_data_unref) > 0)
		return;

	qmi_param_free(param);
	cb_data_unref(cbd);
error:
	CALLBACK_WITH_FAILURE(cb, cbd->data);
}

static void gobi_set_online(struct ofono_modem *modem, ofono_bool_t online,
				ofono_modem_online_cb_t cb, void *user_data)
{
	struct gobi_data *data = ofono_modem_get_data(modem);
	struct l_netlink *rtnl = l_rtnl_get();
	struct cb_data *cbd = cb_data_new(cb, user_data);
	l_netlink_command_func_t powered_cb;

	DBG("%p %s using_mux: %s", modem, online ? "online" : "offline",
		data->n_premux ? "yes" : "no");

	cbd->user = data;

	if (online)
		powered_cb = powered_up_cb;
	else
		powered_cb = powered_down_cb;

	if (!data->n_premux) {
		powered_cb(0, 0, NULL, 0, cbd);
		cb_data_unref(cbd);
		return;
	}

	data->set_powered_id = l_rtnl_set_powered(rtnl, data->main_net_ifindex,
							online, powered_cb, cbd,
							cb_data_unref);
	if (data->set_powered_id)
		return;

	cb_data_unref(cbd);
	CALLBACK_WITH_FAILURE(cb, user_data);
}

static void gobi_pre_sim(struct ofono_modem *modem)
{
	struct gobi_data *data = ofono_modem_get_data(modem);
	bool legacy = ofono_modem_get_boolean(modem, "ForceSimLegacy");

	DBG("%p", modem);

	ofono_devinfo_create(modem, 0, "qmimodem", qmi_service_clone(data->dms));

	if ((data->features & GOBI_UIM) && !legacy)
		ofono_sim_create(modem, 0, "qmimodem",
						qmi_service_clone(data->dms),
						qmi_service_clone(data->uim));
	else /* DMS always available */
		ofono_sim_create(modem, 0, "qmimodem_legacy",
						qmi_service_clone(data->dms));

	if (data->features & GOBI_VOICE)
		ofono_voicecall_create(modem, 0, "qmimodem",
					qmi_service_clone(data->voice));

	if (data->features & GOBI_PDS) /* exclusive use, no need to clone */
		ofono_location_reporting_create(modem, 0, "qmimodem",
						l_steal_ptr(data->pds));
}

static void gobi_setup_gprs(struct ofono_modem *modem)
{
	struct gobi_data *data = ofono_modem_get_data(modem);
	struct ofono_gprs *gprs;
	struct ofono_gprs_context *gc;
	int i;

	gprs = ofono_gprs_create(modem, 0, "qmimodem",
					qmi_service_clone(data->wds),
					qmi_service_clone(data->nas));
	if (!gprs) {
		ofono_warn("Unable to create gprs for: %s",
					ofono_modem_get_path(modem));
		return;
	}

	/* Simple case of 802.3 interface, no QMAP */
	if (data->n_premux == 0) {
		struct qmi_service *ipv4 = data->context_services[0].wds_ipv4;
		struct qmi_service *ipv6 = data->context_services[0].wds_ipv6;

		gc = ofono_gprs_context_create(modem, 0, "qmimodem", -1,
						qmi_service_clone(ipv4),
						qmi_service_clone(ipv6));
		if (!gc) {
			ofono_warn("Unable to create gprs-context for: %s",
					ofono_modem_get_path(modem));
			return;
		}

		ofono_gprs_add_context(gprs, gc);
		ofono_gprs_context_set_interface(gc, data->main_net_name);

		return;
	}

	for (i = 0; i < data->n_premux; i++) {
		struct qmi_service *ipv4 = data->context_services[i].wds_ipv4;
		struct qmi_service *ipv6 = data->context_services[i].wds_ipv6;
		struct rmnet_ifinfo *ifinfo = data->rmnet_interfaces + i;

		gc = ofono_gprs_context_create(modem, 0, "qmimodem",
						ifinfo->mux_id,
						qmi_service_clone(ipv4),
						qmi_service_clone(ipv6));

		if (!gc) {
			ofono_warn("gprs-context creation failed for [%d] %s",
					i + 1, ofono_modem_get_path(modem));
			continue;
		}

		ofono_gprs_add_context(gprs, gc);
		ofono_gprs_context_set_interface(gc, ifinfo->ifname);
	}
}

static void gobi_post_sim(struct ofono_modem *modem)
{
	struct gobi_data *data = ofono_modem_get_data(modem);

	DBG("%p", modem);

	if (data->features & GOBI_WDS)
		ofono_lte_create(modem, 0, "qmimodem",
					qmi_service_clone(data->wds));

	if (data->features & GOBI_NAS)
		ofono_radio_settings_create(modem, 0, "qmimodem",
					qmi_service_clone(data->dms),
					qmi_service_clone(data->nas));

	if (data->features & GOBI_WMS)
		ofono_sms_create(modem, 0, "qmimodem",
					qmi_service_clone(data->wms));

	if ((data->features & GOBI_WMS) && (data->features & GOBI_UIM) &&
			!ofono_modem_get_boolean(modem, "ForceSimLegacy")) {
		struct ofono_message_waiting *mw =
					ofono_message_waiting_create(modem);

		if (mw)
			ofono_message_waiting_register(mw);
	}

	if (data->features & GOBI_WDS)
		gobi_setup_gprs(modem);
}

static void gobi_post_online(struct ofono_modem *modem)
{
	struct gobi_data *data = ofono_modem_get_data(modem);

	DBG("%p", modem);

	if (data->features & GOBI_NAS) {
		ofono_netreg_create(modem, 0, "qmimodem",
						qmi_service_clone(data->nas));
		ofono_netmon_create(modem, 0, "qmimodem",
						qmi_service_clone(data->nas));
	}

	if (data->features & GOBI_VOICE) {
		ofono_ussd_create(modem, 0, "qmimodem",
						qmi_service_clone(data->voice));
		ofono_call_settings_create(modem, 0, "qmimodem",
						qmi_service_clone(data->voice));
		ofono_call_barring_create(modem, 0, "qmimodem",
						qmi_service_clone(data->voice));
		ofono_call_forwarding_create(modem, 0, "qmimodem",
						qmi_service_clone(data->voice));
	}
}

static struct ofono_modem_driver gobi_driver = {
	.probe		= gobi_probe,
	.remove		= gobi_remove,
	.enable		= gobi_enable,
	.disable	= gobi_disable,
	.set_online	= gobi_set_online,
	.pre_sim	= gobi_pre_sim,
	.post_sim	= gobi_post_sim,
	.post_online	= gobi_post_online,
};

OFONO_MODEM_DRIVER_BUILTIN(gobi, &gobi_driver)