dbus_new_handlers_p2p.c 56 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148
  1. /*
  2. * WPA Supplicant / dbus-based control interface (P2P)
  3. *
  4. * This program is free software; you can redistribute it and/or modify
  5. * it under the terms of the GNU General Public License version 2 as
  6. * published by the Free Software Foundation.
  7. *
  8. * Alternatively, this software may be distributed under the terms of BSD
  9. * license.
  10. *
  11. * See README and COPYING for more details.
  12. */
  13. #include "includes.h"
  14. #include "utils/includes.h"
  15. #include "common.h"
  16. #include "../config.h"
  17. #include "../wpa_supplicant_i.h"
  18. #include "../wps_supplicant.h"
  19. #include "../notify.h"
  20. #include "dbus_new_helpers.h"
  21. #include "dbus_new.h"
  22. #include "dbus_new_handlers.h"
  23. #include "dbus_new_handlers_p2p.h"
  24. #include "dbus_dict_helpers.h"
  25. #include "p2p/p2p.h"
  26. #include "common/ieee802_11_defs.h"
  27. #include "ap/hostapd.h"
  28. #include "ap/ap_config.h"
  29. #include "ap/wps_hostapd.h"
  30. #include "../p2p_supplicant.h"
  31. /**
  32. * Parses out the mac address from the peer object path.
  33. * @peer_path - object path of the form
  34. * /fi/w1/wpa_supplicant1/Interfaces/n/Peers/00112233445566 (no colons)
  35. * @addr - out param must be of ETH_ALEN size
  36. * Returns 0 if valid (including MAC), -1 otherwise
  37. */
  38. static int parse_peer_object_path(char *peer_path, u8 addr[ETH_ALEN])
  39. {
  40. char *p;
  41. if (!peer_path)
  42. return -1;
  43. p = strrchr(peer_path, '/');
  44. if (!p)
  45. return -1;
  46. p++;
  47. return hwaddr_compact_aton(p, addr);
  48. }
  49. /**
  50. * wpas_dbus_error_persistent_group_unknown - Return a new PersistentGroupUnknown
  51. * error message
  52. * @message: Pointer to incoming dbus message this error refers to
  53. * Returns: a dbus error message
  54. *
  55. * Convenience function to create and return an invalid persistent group error.
  56. */
  57. static DBusMessage * wpas_dbus_error_persistent_group_unknown(
  58. DBusMessage *message)
  59. {
  60. return dbus_message_new_error(message, WPAS_DBUS_ERROR_NETWORK_UNKNOWN,
  61. "There is no such persistent group in "
  62. "this P2P device.");
  63. }
  64. DBusMessage * wpas_dbus_handler_p2p_find(DBusMessage *message,
  65. struct wpa_supplicant *wpa_s)
  66. {
  67. struct wpa_dbus_dict_entry entry;
  68. DBusMessage *reply = NULL;
  69. DBusMessageIter iter;
  70. DBusMessageIter iter_dict;
  71. unsigned int timeout = 0;
  72. unsigned int searchonly = 0;
  73. enum p2p_discovery_type type = P2P_FIND_ONLY_SOCIAL;
  74. int num_req_dev_types = 0;
  75. unsigned int i;
  76. u8 *req_dev_types = NULL;
  77. dbus_message_iter_init(message, &iter);
  78. entry.key = NULL;
  79. if (!wpa_dbus_dict_open_read(&iter, &iter_dict))
  80. goto error;
  81. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  82. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  83. goto error;
  84. if (!os_strcmp(entry.key, "Timeout") &&
  85. (entry.type == DBUS_TYPE_INT32)) {
  86. timeout = entry.uint32_value;
  87. } else if (!os_strcmp(entry.key, "SearchOnly") &&
  88. (entry.type == DBUS_TYPE_BOOLEAN)) {
  89. searchonly = (entry.bool_value == TRUE) ? 1 : 0;
  90. } else if (os_strcmp(entry.key, "RequestedDeviceTypes") == 0) {
  91. if ((entry.type != DBUS_TYPE_ARRAY) ||
  92. (entry.array_type != WPAS_DBUS_TYPE_BINARRAY))
  93. goto error_clear;
  94. req_dev_types =
  95. os_malloc(WPS_DEV_TYPE_LEN * entry.array_len);
  96. if (!req_dev_types)
  97. goto error_clear;
  98. for (i = 0; i < entry.array_len; i++) {
  99. if (wpabuf_len(entry.binarray_value[i]) !=
  100. WPS_DEV_TYPE_LEN)
  101. goto error_clear;
  102. os_memcpy(req_dev_types + i * WPS_DEV_TYPE_LEN,
  103. wpabuf_head(entry.binarray_value[i]),
  104. WPS_DEV_TYPE_LEN);
  105. }
  106. num_req_dev_types = entry.array_len;
  107. } else
  108. goto error_clear;
  109. wpa_dbus_dict_entry_clear(&entry);
  110. }
  111. wpas_p2p_find(wpa_s, timeout, type, num_req_dev_types, req_dev_types);
  112. return reply;
  113. error_clear:
  114. os_free(req_dev_types);
  115. wpa_dbus_dict_entry_clear(&entry);
  116. error:
  117. reply = wpas_dbus_error_invalid_args(message, entry.key);
  118. return reply;
  119. }
  120. DBusMessage * wpas_dbus_handler_p2p_stop_find(DBusMessage *message,
  121. struct wpa_supplicant *wpa_s)
  122. {
  123. wpas_p2p_stop_find(wpa_s);
  124. return NULL;
  125. }
  126. DBusMessage * wpas_dbus_handler_p2p_rejectpeer(DBusMessage *message,
  127. struct wpa_supplicant *wpa_s)
  128. {
  129. DBusMessageIter iter;
  130. char *peer_object_path = NULL;
  131. u8 peer_addr[ETH_ALEN];
  132. dbus_message_iter_init(message, &iter);
  133. dbus_message_iter_get_basic(&iter, &peer_object_path);
  134. if (parse_peer_object_path(peer_object_path, peer_addr) < 0)
  135. return wpas_dbus_error_invalid_args(message, NULL);
  136. if (wpas_p2p_reject(wpa_s, peer_addr) < 0)
  137. return wpas_dbus_error_unknown_error(message,
  138. "Failed to call wpas_p2p_reject method.");
  139. return NULL;
  140. }
  141. DBusMessage * wpas_dbus_handler_p2p_listen(DBusMessage *message,
  142. struct wpa_supplicant *wpa_s)
  143. {
  144. dbus_int32_t timeout = 0;
  145. if (!dbus_message_get_args(message, NULL, DBUS_TYPE_INT32, &timeout,
  146. DBUS_TYPE_INVALID))
  147. return dbus_message_new_error(message, DBUS_ERROR_NO_MEMORY,
  148. NULL);
  149. if (wpas_p2p_listen(wpa_s, (unsigned int)timeout))
  150. return dbus_message_new_error(message, DBUS_ERROR_NO_MEMORY,
  151. NULL);
  152. return NULL;
  153. }
  154. DBusMessage * wpas_dbus_handler_p2p_extendedlisten(
  155. DBusMessage *message, struct wpa_supplicant *wpa_s)
  156. {
  157. unsigned int period = 0, interval = 0;
  158. struct wpa_dbus_dict_entry entry;
  159. DBusMessageIter iter;
  160. DBusMessageIter iter_dict;
  161. dbus_message_iter_init(message, &iter);
  162. entry.key = NULL;
  163. if (!wpa_dbus_dict_open_read(&iter, &iter_dict))
  164. goto error;
  165. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  166. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  167. goto error;
  168. if (!os_strcmp(entry.key, "period") &&
  169. (entry.type == DBUS_TYPE_INT32))
  170. period = entry.uint32_value;
  171. else if (!os_strcmp(entry.key, "interval") &&
  172. (entry.type == DBUS_TYPE_INT32))
  173. interval = entry.uint32_value;
  174. else
  175. goto error_clear;
  176. wpa_dbus_dict_entry_clear(&entry);
  177. }
  178. if (wpas_p2p_ext_listen(wpa_s, period, interval))
  179. return wpas_dbus_error_unknown_error(
  180. message, "failed to initiate a p2p_ext_listen.");
  181. return NULL;
  182. error_clear:
  183. wpa_dbus_dict_entry_clear(&entry);
  184. error:
  185. return wpas_dbus_error_invalid_args(message, entry.key);
  186. }
  187. DBusMessage * wpas_dbus_handler_p2p_presence_request(
  188. DBusMessage *message, struct wpa_supplicant *wpa_s)
  189. {
  190. unsigned int dur1 = 0, int1 = 0, dur2 = 0, int2 = 0;
  191. struct wpa_dbus_dict_entry entry;
  192. DBusMessageIter iter;
  193. DBusMessageIter iter_dict;
  194. dbus_message_iter_init(message, &iter);
  195. entry.key = NULL;
  196. if (!wpa_dbus_dict_open_read(&iter, &iter_dict))
  197. goto error;
  198. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  199. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  200. goto error;
  201. if (!os_strcmp(entry.key, "duration1") &&
  202. (entry.type == DBUS_TYPE_INT32))
  203. dur1 = entry.uint32_value;
  204. else if (!os_strcmp(entry.key, "interval1") &&
  205. entry.type == DBUS_TYPE_INT32)
  206. int1 = entry.uint32_value;
  207. else if (!os_strcmp(entry.key, "duration2") &&
  208. entry.type == DBUS_TYPE_INT32)
  209. dur2 = entry.uint32_value;
  210. else if (!os_strcmp(entry.key, "interval2") &&
  211. entry.type == DBUS_TYPE_INT32)
  212. int2 = entry.uint32_value;
  213. else
  214. goto error_clear;
  215. wpa_dbus_dict_entry_clear(&entry);
  216. }
  217. if (wpas_p2p_presence_req(wpa_s, dur1, int1, dur2, int2) < 0)
  218. return wpas_dbus_error_unknown_error(message,
  219. "Failed to invoke presence request.");
  220. return NULL;
  221. error_clear:
  222. wpa_dbus_dict_entry_clear(&entry);
  223. error:
  224. return wpas_dbus_error_invalid_args(message, entry.key);
  225. }
  226. DBusMessage * wpas_dbus_handler_p2p_group_add(DBusMessage *message,
  227. struct wpa_supplicant *wpa_s)
  228. {
  229. DBusMessageIter iter_dict;
  230. DBusMessage *reply = NULL;
  231. DBusMessageIter iter;
  232. struct wpa_dbus_dict_entry entry;
  233. char *pg_object_path = NULL;
  234. int persistent_group = 0;
  235. int freq = 0;
  236. char *iface = NULL;
  237. char *net_id_str = NULL;
  238. unsigned int group_id = 0;
  239. struct wpa_ssid *ssid;
  240. dbus_message_iter_init(message, &iter);
  241. if (!wpa_dbus_dict_open_read(&iter, &iter_dict))
  242. goto inv_args;
  243. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  244. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  245. goto inv_args;
  246. if (!os_strcmp(entry.key, "persistent") &&
  247. (entry.type == DBUS_TYPE_BOOLEAN)) {
  248. persistent_group = (entry.bool_value == TRUE) ? 1 : 0;
  249. } else if (!os_strcmp(entry.key, "frequency") &&
  250. (entry.type == DBUS_TYPE_INT32)) {
  251. freq = entry.int32_value;
  252. if (freq <= 0)
  253. goto inv_args_clear;
  254. } else if (!os_strcmp(entry.key, "persistent_group_object") &&
  255. entry.type == DBUS_TYPE_OBJECT_PATH)
  256. pg_object_path = os_strdup(entry.str_value);
  257. else
  258. goto inv_args_clear;
  259. wpa_dbus_dict_entry_clear(&entry);
  260. }
  261. if (pg_object_path != NULL) {
  262. /*
  263. * A persistent group Object Path is defined meaning we want
  264. * to re-invoke a persistent group.
  265. */
  266. iface = wpas_dbus_new_decompose_object_path(pg_object_path, 1,
  267. &net_id_str, NULL);
  268. if (iface == NULL ||
  269. os_strcmp(iface, wpa_s->dbus_new_path) != 0) {
  270. reply =
  271. wpas_dbus_error_invalid_args(message,
  272. pg_object_path);
  273. goto out;
  274. }
  275. group_id = strtoul(net_id_str, NULL, 10);
  276. if (errno == EINVAL) {
  277. reply = wpas_dbus_error_invalid_args(
  278. message, pg_object_path);
  279. goto out;
  280. }
  281. /* Get the SSID structure form the persistant group id */
  282. ssid = wpa_config_get_network(wpa_s->conf, group_id);
  283. if (ssid == NULL || ssid->disabled != 2)
  284. goto inv_args;
  285. if (wpas_p2p_group_add_persistent(wpa_s, ssid, 0, freq)) {
  286. reply = wpas_dbus_error_unknown_error(
  287. message,
  288. "Failed to reinvoke a persistent group");
  289. goto out;
  290. }
  291. } else if (wpas_p2p_group_add(wpa_s, persistent_group, freq))
  292. goto inv_args;
  293. out:
  294. os_free(pg_object_path);
  295. os_free(net_id_str);
  296. os_free(iface);
  297. return reply;
  298. inv_args_clear:
  299. wpa_dbus_dict_entry_clear(&entry);
  300. inv_args:
  301. reply = wpas_dbus_error_invalid_args(message, NULL);
  302. goto out;
  303. }
  304. DBusMessage * wpas_dbus_handler_p2p_disconnect(DBusMessage *message,
  305. struct wpa_supplicant *wpa_s)
  306. {
  307. if (wpas_p2p_disconnect(wpa_s))
  308. return wpas_dbus_error_unknown_error(message,
  309. "failed to disconnect");
  310. return NULL;
  311. }
  312. DBusMessage * wpas_dbus_handler_p2p_flush(DBusMessage *message,
  313. struct wpa_supplicant *wpa_s)
  314. {
  315. os_memset(wpa_s->p2p_auth_invite, 0, ETH_ALEN);
  316. wpa_s->force_long_sd = 0;
  317. p2p_flush(wpa_s->global->p2p);
  318. return NULL;
  319. }
  320. DBusMessage * wpas_dbus_handler_p2p_connect(DBusMessage *message,
  321. struct wpa_supplicant *wpa_s)
  322. {
  323. DBusMessageIter iter_dict;
  324. DBusMessage *reply = NULL;
  325. DBusMessageIter iter;
  326. struct wpa_dbus_dict_entry entry;
  327. char *peer_object_path = NULL;
  328. int persistent_group = 0;
  329. int join = 0;
  330. int authorize_only = 0;
  331. int go_intent = -1;
  332. int freq = 0;
  333. u8 addr[ETH_ALEN];
  334. char *pin = NULL;
  335. enum p2p_wps_method wps_method = WPS_NOT_READY;
  336. int new_pin;
  337. char *err_msg = NULL;
  338. char *iface = NULL;
  339. dbus_message_iter_init(message, &iter);
  340. if (!wpa_dbus_dict_open_read(&iter, &iter_dict))
  341. goto inv_args;
  342. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  343. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  344. goto inv_args;
  345. if (!os_strcmp(entry.key, "peer") &&
  346. (entry.type == DBUS_TYPE_OBJECT_PATH)) {
  347. peer_object_path = os_strdup(entry.str_value);
  348. } else if (!os_strcmp(entry.key, "persistent") &&
  349. (entry.type == DBUS_TYPE_BOOLEAN)) {
  350. persistent_group = (entry.bool_value == TRUE) ? 1 : 0;
  351. } else if (!os_strcmp(entry.key, "join") &&
  352. (entry.type == DBUS_TYPE_BOOLEAN)) {
  353. join = (entry.bool_value == TRUE) ? 1 : 0;
  354. } else if (!os_strcmp(entry.key, "authorize_only") &&
  355. (entry.type == DBUS_TYPE_BOOLEAN)) {
  356. authorize_only = (entry.bool_value == TRUE) ? 1 : 0;
  357. } else if (!os_strcmp(entry.key, "frequency") &&
  358. (entry.type == DBUS_TYPE_INT32)) {
  359. freq = entry.int32_value;
  360. if (freq <= 0)
  361. goto inv_args_clear;
  362. } else if (!os_strcmp(entry.key, "go_intent") &&
  363. (entry.type == DBUS_TYPE_INT32)) {
  364. go_intent = entry.int32_value;
  365. if ((go_intent < 0) || (go_intent > 15))
  366. goto inv_args_clear;
  367. } else if (!os_strcmp(entry.key, "wps_method") &&
  368. (entry.type == DBUS_TYPE_STRING)) {
  369. if (!os_strcmp(entry.str_value, "pbc"))
  370. wps_method = WPS_PBC;
  371. else if (!os_strcmp(entry.str_value, "pin"))
  372. wps_method = WPS_PIN_DISPLAY;
  373. else if (!os_strcmp(entry.str_value, "label"))
  374. wps_method = WPS_PIN_LABEL;
  375. else if (!os_strcmp(entry.str_value, "display"))
  376. wps_method = WPS_PIN_DISPLAY;
  377. else if (!os_strcmp(entry.str_value, "keypad"))
  378. wps_method = WPS_PIN_KEYPAD;
  379. else
  380. goto inv_args_clear;
  381. } else if (!os_strcmp(entry.key, "pin") &&
  382. (entry.type == DBUS_TYPE_STRING)) {
  383. pin = os_strdup(entry.str_value);
  384. } else
  385. goto inv_args_clear;
  386. wpa_dbus_dict_entry_clear(&entry);
  387. }
  388. if (!peer_object_path || (wps_method == WPS_NOT_READY) ||
  389. (parse_peer_object_path(peer_object_path, addr) < 0) ||
  390. (p2p_get_peer_info(wpa_s->global->p2p, addr, 0, NULL, 0) < 0)) {
  391. reply = wpas_dbus_error_invalid_args(message, NULL);
  392. goto inv_args;
  393. }
  394. /*
  395. * Validate the wps_method specified and the pin value.
  396. */
  397. if ((!pin || !pin[0]) &&
  398. ((wps_method == WPS_PIN_LABEL) || (wps_method == WPS_PIN_KEYPAD)))
  399. goto inv_args;
  400. new_pin = wpas_p2p_connect(wpa_s, addr, pin, wps_method,
  401. persistent_group, join, authorize_only,
  402. go_intent, freq);
  403. if (new_pin >= 0) {
  404. reply = dbus_message_new_method_return(message);
  405. dbus_message_append_args(reply, DBUS_TYPE_INT32,
  406. &new_pin, DBUS_TYPE_INVALID);
  407. } else {
  408. switch (new_pin) {
  409. case -2:
  410. err_msg = "connect failed due to"
  411. " channel unavailability.";
  412. iface = WPAS_DBUS_ERROR_CONNECT_CHANNEL_UNAVAILABLE;
  413. break;
  414. case -3:
  415. err_msg = "connect failed due to"
  416. " unsupported channel.";
  417. iface = WPAS_DBUS_ERROR_CONNECT_CHANNEL_UNSUPPORTED;
  418. break;
  419. default:
  420. err_msg = "connect failed due to"
  421. " unspecified error.";
  422. iface = WPAS_DBUS_ERROR_CONNECT_UNSPECIFIED_ERROR;
  423. break;
  424. }
  425. /*
  426. * TODO::
  427. * Do we need specialized errors corresponding to above
  428. * error conditions as against just returning a different
  429. * error message?
  430. */
  431. reply = dbus_message_new_error(message, iface, err_msg);
  432. }
  433. out:
  434. os_free(peer_object_path);
  435. os_free(pin);
  436. return reply;
  437. inv_args_clear:
  438. wpa_dbus_dict_entry_clear(&entry);
  439. inv_args:
  440. reply = wpas_dbus_error_invalid_args(message, NULL);
  441. goto out;
  442. }
  443. DBusMessage * wpas_dbus_handler_p2p_invite(DBusMessage *message,
  444. struct wpa_supplicant *wpa_s)
  445. {
  446. DBusMessageIter iter_dict;
  447. DBusMessage *reply = NULL;
  448. DBusMessageIter iter;
  449. struct wpa_dbus_dict_entry entry;
  450. char *peer_object_path = NULL;
  451. char *pg_object_path = NULL;
  452. char *iface = NULL;
  453. char *net_id_str = NULL;
  454. u8 peer_addr[ETH_ALEN];
  455. unsigned int group_id = 0;
  456. int persistent = 0;
  457. struct wpa_ssid *ssid;
  458. dbus_message_iter_init(message, &iter);
  459. if (!wpa_dbus_dict_open_read(&iter, &iter_dict))
  460. goto err;
  461. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  462. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  463. goto err;
  464. if (!os_strcmp(entry.key, "peer") &&
  465. (entry.type == DBUS_TYPE_OBJECT_PATH)) {
  466. peer_object_path = os_strdup(entry.str_value);
  467. wpa_dbus_dict_entry_clear(&entry);
  468. } else if (!os_strcmp(entry.key, "persistent_group_object") &&
  469. (entry.type == DBUS_TYPE_OBJECT_PATH)) {
  470. pg_object_path = os_strdup(entry.str_value);
  471. persistent = 1;
  472. wpa_dbus_dict_entry_clear(&entry);
  473. } else {
  474. wpa_dbus_dict_entry_clear(&entry);
  475. goto err;
  476. }
  477. }
  478. if (!peer_object_path ||
  479. (parse_peer_object_path(peer_object_path, peer_addr) < 0) ||
  480. (p2p_get_peer_info(wpa_s->global->p2p,
  481. peer_addr, 0, NULL, 0) < 0)) {
  482. goto err;
  483. }
  484. if (persistent) {
  485. /*
  486. * A group ID is defined meaning we want to re-invoke a
  487. * persistant group
  488. */
  489. iface = wpas_dbus_new_decompose_object_path(pg_object_path, 1,
  490. &net_id_str, NULL);
  491. if (iface == NULL ||
  492. os_strcmp(iface, wpa_s->dbus_new_path) != 0) {
  493. reply = wpas_dbus_error_invalid_args(message,
  494. pg_object_path);
  495. goto out;
  496. }
  497. group_id = strtoul(net_id_str, NULL, 10);
  498. if (errno == EINVAL) {
  499. reply = wpas_dbus_error_invalid_args(
  500. message, pg_object_path);
  501. goto out;
  502. }
  503. /* Get the SSID structure form the persistant group id */
  504. ssid = wpa_config_get_network(wpa_s->conf, group_id);
  505. if (ssid == NULL || ssid->disabled != 2)
  506. goto err;
  507. if (wpas_p2p_invite(wpa_s, peer_addr, ssid, NULL) < 0) {
  508. reply = wpas_dbus_error_unknown_error(
  509. message,
  510. "Failed to reinvoke a persistent group");
  511. goto out;
  512. }
  513. } else {
  514. /*
  515. * No group ID means propose to a peer to join my active group
  516. */
  517. if (wpas_p2p_invite_group(wpa_s, wpa_s->ifname,
  518. peer_addr, NULL)) {
  519. reply = wpas_dbus_error_unknown_error(
  520. message, "Failed to join to an active group");
  521. goto out;
  522. }
  523. }
  524. out:
  525. os_free(pg_object_path);
  526. os_free(peer_object_path);
  527. return reply;
  528. err:
  529. reply = wpas_dbus_error_invalid_args(message, NULL);
  530. goto out;
  531. }
  532. DBusMessage * wpas_dbus_handler_p2p_prov_disc_req(DBusMessage *message,
  533. struct wpa_supplicant *wpa_s)
  534. {
  535. DBusMessageIter iter;
  536. char *peer_object_path = NULL;
  537. char *config_method = NULL;
  538. u8 peer_addr[ETH_ALEN];
  539. dbus_message_iter_init(message, &iter);
  540. dbus_message_iter_get_basic(&iter, &peer_object_path);
  541. if (parse_peer_object_path(peer_object_path, peer_addr) < 0)
  542. return wpas_dbus_error_invalid_args(message, NULL);
  543. dbus_message_iter_next(&iter);
  544. dbus_message_iter_get_basic(&iter, &config_method);
  545. /*
  546. * Validation checks on config_method are being duplicated here
  547. * to be able to return invalid args reply since the error code
  548. * from p2p module are not granular enough (yet).
  549. */
  550. if (os_strcmp(config_method, "display") &&
  551. os_strcmp(config_method, "keypad") &&
  552. os_strcmp(config_method, "pbc") &&
  553. os_strcmp(config_method, "pushbutton"))
  554. return wpas_dbus_error_invalid_args(message, NULL);
  555. if (wpas_p2p_prov_disc(wpa_s, peer_addr, config_method) < 0)
  556. return wpas_dbus_error_unknown_error(message,
  557. "Failed to send provision discovery request");
  558. return NULL;
  559. }
  560. /*
  561. * P2P Device property accessor methods.
  562. */
  563. DBusMessage * wpas_dbus_getter_p2p_device_properties(
  564. DBusMessage *message, struct wpa_supplicant *wpa_s)
  565. {
  566. DBusMessage *reply = NULL;
  567. DBusMessageIter iter, variant_iter, dict_iter;
  568. DBusMessageIter iter_secdev_dict_entry, iter_secdev_dict_val,
  569. iter_secdev_dict_array;
  570. const char *dev_name;
  571. int num_vendor_extensions = 0;
  572. int i;
  573. const struct wpabuf *vendor_ext[P2P_MAX_WPS_VENDOR_EXT];
  574. if (message == NULL)
  575. reply = dbus_message_new(DBUS_MESSAGE_TYPE_SIGNAL);
  576. else
  577. reply = dbus_message_new_method_return(message);
  578. if (!reply)
  579. goto err_no_mem;
  580. dbus_message_iter_init_append(reply, &iter);
  581. if (!dbus_message_iter_open_container(&iter, DBUS_TYPE_VARIANT,
  582. "a{sv}", &variant_iter) ||
  583. !wpa_dbus_dict_open_write(&variant_iter, &dict_iter))
  584. goto err_no_mem;
  585. /* DeviceName */
  586. dev_name = wpa_s->conf->device_name;
  587. if (dev_name &&
  588. !wpa_dbus_dict_append_string(&dict_iter, "DeviceName", dev_name))
  589. goto err_no_mem;
  590. /* Primary device type */
  591. if (!wpa_dbus_dict_append_byte_array(&dict_iter, "PrimaryDeviceType",
  592. (char *)wpa_s->conf->device_type,
  593. WPS_DEV_TYPE_LEN))
  594. goto err_no_mem;
  595. /* Secondary device types */
  596. if (wpa_s->conf->num_sec_device_types) {
  597. if (!wpa_dbus_dict_begin_array(&dict_iter,
  598. "SecondaryDeviceTypes",
  599. DBUS_TYPE_ARRAY_AS_STRING
  600. DBUS_TYPE_BYTE_AS_STRING,
  601. &iter_secdev_dict_entry,
  602. &iter_secdev_dict_val,
  603. &iter_secdev_dict_array))
  604. goto err_no_mem;
  605. for (i = 0; i < wpa_s->conf->num_sec_device_types; i++)
  606. wpa_dbus_dict_bin_array_add_element(
  607. &iter_secdev_dict_array,
  608. wpa_s->conf->sec_device_type[i],
  609. WPS_DEV_TYPE_LEN);
  610. if (!wpa_dbus_dict_end_array(&dict_iter,
  611. &iter_secdev_dict_entry,
  612. &iter_secdev_dict_val,
  613. &iter_secdev_dict_array))
  614. goto err_no_mem;
  615. }
  616. /* Vendor Extensions */
  617. for (i = 0; i < P2P_MAX_WPS_VENDOR_EXT; i++) {
  618. if (wpa_s->conf->wps_vendor_ext[i] == NULL)
  619. continue;
  620. vendor_ext[num_vendor_extensions++] =
  621. wpa_s->conf->wps_vendor_ext[i];
  622. }
  623. if (num_vendor_extensions &&
  624. !wpa_dbus_dict_append_wpabuf_array(&dict_iter,
  625. "VendorExtension",
  626. vendor_ext,
  627. num_vendor_extensions))
  628. goto err_no_mem;
  629. /* GO Intent */
  630. if (!wpa_dbus_dict_append_uint32(&dict_iter, "GOIntent",
  631. wpa_s->conf->p2p_go_intent))
  632. goto err_no_mem;
  633. /* Persistant Reconnect */
  634. if (!wpa_dbus_dict_append_bool(&dict_iter, "PersistantReconnect",
  635. wpa_s->conf->persistent_reconnect))
  636. goto err_no_mem;
  637. /* Listen Reg Class */
  638. if (!wpa_dbus_dict_append_uint32(&dict_iter, "ListenRegClass",
  639. wpa_s->conf->p2p_listen_reg_class))
  640. goto err_no_mem;
  641. /* Listen Channel */
  642. if (!wpa_dbus_dict_append_uint32(&dict_iter, "ListenChannel",
  643. wpa_s->conf->p2p_listen_channel))
  644. goto err_no_mem;
  645. /* Oper Reg Class */
  646. if (!wpa_dbus_dict_append_uint32(&dict_iter, "OperRegClass",
  647. wpa_s->conf->p2p_oper_reg_class))
  648. goto err_no_mem;
  649. /* Oper Channel */
  650. if (!wpa_dbus_dict_append_uint32(&dict_iter, "OperChannel",
  651. wpa_s->conf->p2p_oper_channel))
  652. goto err_no_mem;
  653. /* SSID Postfix */
  654. if (wpa_s->conf->p2p_ssid_postfix &&
  655. !wpa_dbus_dict_append_string(&dict_iter, "SsidPostfix",
  656. wpa_s->conf->p2p_ssid_postfix))
  657. goto err_no_mem;
  658. /* Intra Bss */
  659. if (!wpa_dbus_dict_append_bool(&dict_iter, "IntraBss",
  660. wpa_s->conf->p2p_intra_bss))
  661. goto err_no_mem;
  662. /* Group Idle */
  663. if (!wpa_dbus_dict_append_uint32(&dict_iter, "GroupIdle",
  664. wpa_s->conf->p2p_group_idle))
  665. goto err_no_mem;
  666. /* Dissasociation low ack */
  667. if (!wpa_dbus_dict_append_uint32(&dict_iter, "disassoc_low_ack",
  668. wpa_s->conf->disassoc_low_ack))
  669. goto err_no_mem;
  670. if (!wpa_dbus_dict_close_write(&variant_iter, &dict_iter) ||
  671. !dbus_message_iter_close_container(&iter, &variant_iter))
  672. goto err_no_mem;
  673. return reply;
  674. err_no_mem:
  675. dbus_message_unref(reply);
  676. return dbus_message_new_error(message, DBUS_ERROR_NO_MEMORY, NULL);
  677. }
  678. DBusMessage * wpas_dbus_setter_p2p_device_properties(
  679. DBusMessage *message, struct wpa_supplicant *wpa_s)
  680. {
  681. DBusMessage *reply = NULL;
  682. DBusMessageIter iter, variant_iter;
  683. struct wpa_dbus_dict_entry entry = {.type = DBUS_TYPE_STRING };
  684. DBusMessageIter iter_dict;
  685. unsigned int i;
  686. dbus_message_iter_init(message, &iter);
  687. dbus_message_iter_next(&iter);
  688. dbus_message_iter_next(&iter);
  689. dbus_message_iter_recurse(&iter, &variant_iter);
  690. if (!wpa_dbus_dict_open_read(&variant_iter, &iter_dict))
  691. return wpas_dbus_error_invalid_args(message, NULL);
  692. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  693. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  694. return wpas_dbus_error_invalid_args(message, NULL);
  695. if (os_strcmp(entry.key, "DeviceName") == 0) {
  696. char *devname;
  697. if (entry.type != DBUS_TYPE_STRING)
  698. goto error_clear;
  699. devname = os_strdup(entry.str_value);
  700. if (devname == NULL)
  701. goto err_no_mem_clear;
  702. os_free(wpa_s->conf->device_name);
  703. wpa_s->conf->device_name = devname;
  704. wpa_s->conf->changed_parameters |=
  705. CFG_CHANGED_DEVICE_NAME;
  706. } else if (os_strcmp(entry.key, "PrimaryDeviceType") == 0) {
  707. if (entry.type != DBUS_TYPE_ARRAY ||
  708. entry.array_type != DBUS_TYPE_BYTE ||
  709. entry.array_len != WPS_DEV_TYPE_LEN)
  710. goto error_clear;
  711. os_memcpy(wpa_s->conf->device_type,
  712. entry.bytearray_value,
  713. WPS_DEV_TYPE_LEN);
  714. wpa_s->conf->changed_parameters |=
  715. CFG_CHANGED_DEVICE_TYPE;
  716. } else if (os_strcmp(entry.key, "SecondaryDeviceTypes") == 0) {
  717. if (entry.type != DBUS_TYPE_ARRAY ||
  718. entry.array_type != WPAS_DBUS_TYPE_BINARRAY ||
  719. entry.array_len > MAX_SEC_DEVICE_TYPES)
  720. goto error;
  721. for (i = 0; i < entry.array_len; i++)
  722. if (wpabuf_len(entry.binarray_value[i]) !=
  723. WPS_DEV_TYPE_LEN)
  724. goto err_no_mem_clear;
  725. for (i = 0; i < entry.array_len; i++)
  726. os_memcpy(wpa_s->conf->sec_device_type[i],
  727. wpabuf_head(entry.binarray_value[i]),
  728. WPS_DEV_TYPE_LEN);
  729. wpa_s->conf->num_sec_device_types = entry.array_len;
  730. wpa_s->conf->changed_parameters |=
  731. CFG_CHANGED_SEC_DEVICE_TYPE;
  732. } else if (os_strcmp(entry.key, "VendorExtension") == 0) {
  733. if ((entry.type != DBUS_TYPE_ARRAY) ||
  734. (entry.array_type != WPAS_DBUS_TYPE_BINARRAY) ||
  735. (entry.array_len > P2P_MAX_WPS_VENDOR_EXT))
  736. goto error_clear;
  737. wpa_s->conf->changed_parameters |=
  738. CFG_CHANGED_VENDOR_EXTENSION;
  739. for (i = 0; i < P2P_MAX_WPS_VENDOR_EXT; i++) {
  740. wpabuf_free(wpa_s->conf->wps_vendor_ext[i]);
  741. if (i < entry.array_len) {
  742. wpa_s->conf->wps_vendor_ext[i] =
  743. entry.binarray_value[i];
  744. entry.binarray_value[i] = NULL;
  745. } else
  746. wpa_s->conf->wps_vendor_ext[i] = NULL;
  747. }
  748. } else if ((os_strcmp(entry.key, "GOIntent") == 0) &&
  749. (entry.type == DBUS_TYPE_UINT32) &&
  750. (entry.uint32_value <= 15))
  751. wpa_s->conf->p2p_go_intent = entry.uint32_value;
  752. else if ((os_strcmp(entry.key, "PersistantReconnect") == 0) &&
  753. (entry.type == DBUS_TYPE_BOOLEAN))
  754. wpa_s->conf->persistent_reconnect = entry.bool_value;
  755. else if ((os_strcmp(entry.key, "ListenRegClass") == 0) &&
  756. (entry.type == DBUS_TYPE_UINT32)) {
  757. wpa_s->conf->p2p_listen_reg_class = entry.uint32_value;
  758. wpa_s->conf->changed_parameters |=
  759. CFG_CHANGED_P2P_LISTEN_CHANNEL;
  760. } else if ((os_strcmp(entry.key, "ListenChannel") == 0) &&
  761. (entry.type == DBUS_TYPE_UINT32)) {
  762. wpa_s->conf->p2p_listen_channel = entry.uint32_value;
  763. wpa_s->conf->changed_parameters |=
  764. CFG_CHANGED_P2P_LISTEN_CHANNEL;
  765. } else if ((os_strcmp(entry.key, "OperRegClass") == 0) &&
  766. (entry.type == DBUS_TYPE_UINT32)) {
  767. wpa_s->conf->p2p_oper_reg_class = entry.uint32_value;
  768. wpa_s->conf->changed_parameters |=
  769. CFG_CHANGED_P2P_OPER_CHANNEL;
  770. } else if ((os_strcmp(entry.key, "OperChannel") == 0) &&
  771. (entry.type == DBUS_TYPE_UINT32)) {
  772. wpa_s->conf->p2p_oper_channel = entry.uint32_value;
  773. wpa_s->conf->changed_parameters |=
  774. CFG_CHANGED_P2P_OPER_CHANNEL;
  775. } else if (os_strcmp(entry.key, "SsidPostfix") == 0) {
  776. char *postfix;
  777. if (entry.type != DBUS_TYPE_STRING)
  778. goto error_clear;
  779. postfix = os_strdup(entry.str_value);
  780. if (!postfix)
  781. goto err_no_mem_clear;
  782. os_free(wpa_s->conf->p2p_ssid_postfix);
  783. wpa_s->conf->p2p_ssid_postfix = postfix;
  784. wpa_s->conf->changed_parameters |=
  785. CFG_CHANGED_P2P_SSID_POSTFIX;
  786. } else if ((os_strcmp(entry.key, "IntraBss") == 0) &&
  787. (entry.type == DBUS_TYPE_BOOLEAN)) {
  788. wpa_s->conf->p2p_intra_bss = entry.bool_value;
  789. wpa_s->conf->changed_parameters |=
  790. CFG_CHANGED_P2P_INTRA_BSS;
  791. } else if ((os_strcmp(entry.key, "GroupIdle") == 0) &&
  792. (entry.type == DBUS_TYPE_UINT32))
  793. wpa_s->conf->p2p_group_idle = entry.uint32_value;
  794. else if (os_strcmp(entry.key, "disassoc_low_ack") == 0 &&
  795. entry.type == DBUS_TYPE_UINT32)
  796. wpa_s->conf->disassoc_low_ack = entry.uint32_value;
  797. else
  798. goto error_clear;
  799. wpa_dbus_dict_entry_clear(&entry);
  800. }
  801. if (wpa_s->conf->changed_parameters) {
  802. /* Some changed parameters requires to update config*/
  803. wpa_supplicant_update_config(wpa_s);
  804. }
  805. return reply;
  806. error_clear:
  807. wpa_dbus_dict_entry_clear(&entry);
  808. error:
  809. reply = wpas_dbus_error_invalid_args(message, entry.key);
  810. wpa_dbus_dict_entry_clear(&entry);
  811. return reply;
  812. err_no_mem_clear:
  813. wpa_dbus_dict_entry_clear(&entry);
  814. return dbus_message_new_error(message, DBUS_ERROR_NO_MEMORY, NULL);
  815. }
  816. DBusMessage * wpas_dbus_getter_p2p_peers(DBusMessage *message,
  817. struct wpa_supplicant *wpa_s)
  818. {
  819. DBusMessage *reply = NULL;
  820. struct p2p_data *p2p = wpa_s->global->p2p;
  821. int next = 0, i = 0;
  822. int num = 0, out_of_mem = 0;
  823. const u8 *addr;
  824. const struct p2p_peer_info *peer_info = NULL;
  825. struct dl_list peer_objpath_list;
  826. struct peer_objpath_node {
  827. struct dl_list list;
  828. char path[WPAS_DBUS_OBJECT_PATH_MAX];
  829. } *node, *tmp;
  830. char **peer_obj_paths = NULL;
  831. dl_list_init(&peer_objpath_list);
  832. /* Get the first peer info */
  833. peer_info = p2p_get_peer_found(p2p, NULL, next);
  834. /* Get next and accumulate them */
  835. next = 1;
  836. while (peer_info != NULL) {
  837. node = os_zalloc(sizeof(struct peer_objpath_node));
  838. if (!node) {
  839. out_of_mem = 1;
  840. goto error;
  841. }
  842. addr = peer_info->p2p_device_addr;
  843. os_snprintf(node->path, WPAS_DBUS_OBJECT_PATH_MAX,
  844. "%s/" WPAS_DBUS_NEW_P2P_PEERS_PART
  845. "/" COMPACT_MACSTR,
  846. wpa_s->dbus_new_path, MAC2STR(addr));
  847. dl_list_add_tail(&peer_objpath_list, &node->list);
  848. num++;
  849. peer_info = p2p_get_peer_found(p2p, addr, next);
  850. }
  851. /*
  852. * Now construct the peer object paths in a form suitable for
  853. * array_property_getter helper below.
  854. */
  855. peer_obj_paths = os_zalloc(num * sizeof(char *));
  856. if (!peer_obj_paths) {
  857. out_of_mem = 1;
  858. goto error;
  859. }
  860. dl_list_for_each_safe(node, tmp, &peer_objpath_list,
  861. struct peer_objpath_node, list)
  862. peer_obj_paths[i++] = node->path;
  863. reply = wpas_dbus_simple_array_property_getter(message,
  864. DBUS_TYPE_OBJECT_PATH,
  865. peer_obj_paths, num);
  866. error:
  867. if (peer_obj_paths)
  868. os_free(peer_obj_paths);
  869. dl_list_for_each_safe(node, tmp, &peer_objpath_list,
  870. struct peer_objpath_node, list) {
  871. dl_list_del(&node->list);
  872. os_free(node);
  873. }
  874. if (out_of_mem)
  875. reply = dbus_message_new_error(message, DBUS_ERROR_NO_MEMORY,
  876. NULL);
  877. return reply;
  878. }
  879. enum wpas_p2p_role {
  880. WPAS_P2P_ROLE_DEVICE,
  881. WPAS_P2P_ROLE_GO,
  882. WPAS_P2P_ROLE_CLIENT,
  883. };
  884. static enum wpas_p2p_role wpas_get_p2p_role(struct wpa_supplicant *wpa_s)
  885. {
  886. struct wpa_ssid *ssid = wpa_s->current_ssid;
  887. if (!ssid)
  888. return WPAS_P2P_ROLE_DEVICE;
  889. if (wpa_s->wpa_state != WPA_COMPLETED)
  890. return WPAS_P2P_ROLE_DEVICE;
  891. switch (ssid->mode) {
  892. case WPAS_MODE_P2P_GO:
  893. case WPAS_MODE_P2P_GROUP_FORMATION:
  894. return WPAS_P2P_ROLE_GO;
  895. case WPAS_MODE_INFRA:
  896. if (ssid->p2p_group)
  897. return WPAS_P2P_ROLE_CLIENT;
  898. return WPAS_P2P_ROLE_DEVICE;
  899. default:
  900. return WPAS_P2P_ROLE_DEVICE;
  901. }
  902. }
  903. DBusMessage * wpas_dbus_getter_p2p_role(DBusMessage *message,
  904. struct wpa_supplicant *wpa_s)
  905. {
  906. char *str;
  907. switch (wpas_get_p2p_role(wpa_s)) {
  908. case WPAS_P2P_ROLE_GO:
  909. str = "GO";
  910. break;
  911. case WPAS_P2P_ROLE_CLIENT:
  912. str = "client";
  913. break;
  914. default:
  915. str = "device";
  916. }
  917. return wpas_dbus_simple_property_getter(message, DBUS_TYPE_STRING,
  918. &str);
  919. }
  920. DBusMessage * wpas_dbus_getter_p2p_group(DBusMessage *message,
  921. struct wpa_supplicant *wpa_s)
  922. {
  923. if (wpa_s->dbus_groupobj_path == NULL)
  924. return NULL;
  925. return wpas_dbus_simple_property_getter(message,
  926. DBUS_TYPE_OBJECT_PATH,
  927. &wpa_s->dbus_groupobj_path);
  928. }
  929. DBusMessage * wpas_dbus_getter_p2p_peergo(DBusMessage *message,
  930. struct wpa_supplicant *wpa_s)
  931. {
  932. char go_peer_obj_path[WPAS_DBUS_OBJECT_PATH_MAX], *path;
  933. if (wpas_get_p2p_role(wpa_s) != WPAS_P2P_ROLE_CLIENT)
  934. return NULL;
  935. os_snprintf(go_peer_obj_path, WPAS_DBUS_OBJECT_PATH_MAX,
  936. "%s/" WPAS_DBUS_NEW_P2P_PEERS_PART "/" COMPACT_MACSTR,
  937. wpa_s->dbus_new_path, MAC2STR(wpa_s->go_dev_addr));
  938. path = go_peer_obj_path;
  939. return wpas_dbus_simple_property_getter(message,
  940. DBUS_TYPE_OBJECT_PATH, &path);
  941. }
  942. /*
  943. * Peer object properties accessor methods
  944. */
  945. DBusMessage * wpas_dbus_getter_p2p_peer_properties(
  946. DBusMessage *message, struct peer_handler_args *peer_args)
  947. {
  948. DBusMessage *reply = NULL;
  949. DBusMessageIter iter, variant_iter, dict_iter;
  950. const struct p2p_peer_info *info = NULL;
  951. char devtype[WPS_DEV_TYPE_BUFSIZE];
  952. const struct wpabuf *vendor_extension[P2P_MAX_WPS_VENDOR_EXT];
  953. int i, num;
  954. /* get the peer info */
  955. info = p2p_get_peer_found(peer_args->wpa_s->global->p2p,
  956. peer_args->p2p_device_addr, 0);
  957. if (info == NULL)
  958. return NULL;
  959. if (message == NULL)
  960. reply = dbus_message_new(DBUS_MESSAGE_TYPE_SIGNAL);
  961. else
  962. reply = dbus_message_new_method_return(message);
  963. if (!reply)
  964. goto err_no_mem;
  965. dbus_message_iter_init_append(reply, &iter);
  966. if (!dbus_message_iter_open_container(&iter, DBUS_TYPE_VARIANT,
  967. "a{sv}", &variant_iter) ||
  968. !wpa_dbus_dict_open_write(&variant_iter, &dict_iter))
  969. goto err_no_mem;
  970. /* Fill out the dictionary */
  971. wps_dev_type_bin2str(info->pri_dev_type, devtype, sizeof(devtype));
  972. if (!wpa_dbus_dict_append_string(&dict_iter, "DeviceName",
  973. info->device_name))
  974. goto err_no_mem;
  975. if (!wpa_dbus_dict_append_string(&dict_iter, "PrimaryDeviceType",
  976. devtype))
  977. goto err_no_mem;
  978. if (!wpa_dbus_dict_append_uint16(&dict_iter, "config_method",
  979. info->config_methods))
  980. goto err_no_mem;
  981. if (!wpa_dbus_dict_append_int32(&dict_iter, "level",
  982. info->level))
  983. goto err_no_mem;
  984. if (!wpa_dbus_dict_append_byte(&dict_iter, "devicecapability",
  985. info->dev_capab))
  986. goto err_no_mem;
  987. if (!wpa_dbus_dict_append_byte(&dict_iter, "groupcapability",
  988. info->group_capab))
  989. goto err_no_mem;
  990. if (info->wps_sec_dev_type_list_len) {
  991. char *sec_dev_types[MAX_SEC_DEVICE_TYPES];
  992. u8 *sec_dev_type_list = NULL;
  993. char secdevtype[WPS_DEV_TYPE_BUFSIZE];
  994. int num_sec_dev_types = 0;
  995. sec_dev_type_list = os_zalloc(info->wps_sec_dev_type_list_len);
  996. if (sec_dev_type_list == NULL)
  997. goto err_no_mem;
  998. os_memcpy(sec_dev_type_list, info->wps_sec_dev_type_list,
  999. info->wps_sec_dev_type_list_len);
  1000. for (i = 0; i < MAX_SEC_DEVICE_TYPES &&
  1001. i < (int) (info->wps_sec_dev_type_list_len /
  1002. WPS_DEV_TYPE_LEN);
  1003. i++) {
  1004. sec_dev_types[i] = os_zalloc(sizeof(secdevtype));
  1005. if (!sec_dev_types[i] ||
  1006. wps_dev_type_bin2str(
  1007. &sec_dev_type_list[i * WPS_DEV_TYPE_LEN],
  1008. sec_dev_types[i],
  1009. sizeof(secdevtype)) == NULL) {
  1010. while (--i >= 0)
  1011. os_free(sec_dev_types[i]);
  1012. os_free(sec_dev_type_list);
  1013. goto err_no_mem;
  1014. }
  1015. num_sec_dev_types++;
  1016. }
  1017. os_free(sec_dev_type_list);
  1018. if (num_sec_dev_types) {
  1019. if (!wpa_dbus_dict_append_string_array(&dict_iter,
  1020. "SecondaryDeviceTypes",
  1021. (const char **)sec_dev_types,
  1022. num_sec_dev_types)) {
  1023. for (i = 0; i < num_sec_dev_types; i++)
  1024. os_free(sec_dev_types[i]);
  1025. goto err_no_mem;
  1026. }
  1027. for (i = 0; i < num_sec_dev_types; i++)
  1028. os_free(sec_dev_types[i]);
  1029. }
  1030. }
  1031. /* Add WPS vendor extensions attribute */
  1032. for (i = 0, num = 0; i < P2P_MAX_WPS_VENDOR_EXT; i++) {
  1033. if (info->wps_vendor_ext[i] == NULL)
  1034. continue;
  1035. vendor_extension[num] = info->wps_vendor_ext[i];
  1036. num++;
  1037. }
  1038. if (!wpa_dbus_dict_append_wpabuf_array(&dict_iter, "VendorExtension",
  1039. vendor_extension, num))
  1040. goto err_no_mem;
  1041. if (!wpa_dbus_dict_close_write(&variant_iter, &dict_iter) ||
  1042. !dbus_message_iter_close_container(&iter, &variant_iter))
  1043. goto err_no_mem;
  1044. return reply;
  1045. err_no_mem:
  1046. dbus_message_unref(reply);
  1047. return dbus_message_new_error(message, DBUS_ERROR_NO_MEMORY, NULL);
  1048. }
  1049. DBusMessage * wpas_dbus_getter_p2p_peer_ies(
  1050. DBusMessage *message, struct peer_handler_args *peer_args)
  1051. {
  1052. return NULL;
  1053. }
  1054. /**
  1055. * wpas_dbus_getter_persistent_groups - Get array of peristent group objects
  1056. * @message: Pointer to incoming dbus message
  1057. * @wpa_s: wpa_supplicant structure for a network interface
  1058. * Returns: a dbus message containing an array of all persistent group
  1059. * dbus object paths.
  1060. *
  1061. * Getter for "Networks" property.
  1062. */
  1063. DBusMessage * wpas_dbus_getter_persistent_groups(DBusMessage *message,
  1064. struct wpa_supplicant *wpa_s)
  1065. {
  1066. DBusMessage *reply = NULL;
  1067. struct wpa_ssid *ssid;
  1068. char **paths;
  1069. unsigned int i = 0, num = 0;
  1070. if (wpa_s->conf == NULL) {
  1071. wpa_printf(MSG_ERROR, "dbus: %s: "
  1072. "An error occurred getting persistent groups list",
  1073. __func__);
  1074. return wpas_dbus_error_unknown_error(message, NULL);
  1075. }
  1076. for (ssid = wpa_s->conf->ssid; ssid; ssid = ssid->next)
  1077. if (network_is_persistent_group(ssid))
  1078. num++;
  1079. paths = os_zalloc(num * sizeof(char *));
  1080. if (!paths) {
  1081. return dbus_message_new_error(message, DBUS_ERROR_NO_MEMORY,
  1082. NULL);
  1083. }
  1084. /* Loop through configured networks and append object path of each */
  1085. for (ssid = wpa_s->conf->ssid; ssid; ssid = ssid->next) {
  1086. if (!network_is_persistent_group(ssid))
  1087. continue;
  1088. paths[i] = os_zalloc(WPAS_DBUS_OBJECT_PATH_MAX);
  1089. if (paths[i] == NULL) {
  1090. reply = dbus_message_new_error(message,
  1091. DBUS_ERROR_NO_MEMORY,
  1092. NULL);
  1093. goto out;
  1094. }
  1095. /* Construct the object path for this network. */
  1096. os_snprintf(paths[i++], WPAS_DBUS_OBJECT_PATH_MAX,
  1097. "%s/" WPAS_DBUS_NEW_PERSISTENT_GROUPS_PART "/%d",
  1098. wpa_s->dbus_new_path, ssid->id);
  1099. }
  1100. reply = wpas_dbus_simple_array_property_getter(message,
  1101. DBUS_TYPE_OBJECT_PATH,
  1102. paths, num);
  1103. out:
  1104. while (i)
  1105. os_free(paths[--i]);
  1106. os_free(paths);
  1107. return reply;
  1108. }
  1109. /**
  1110. * wpas_dbus_getter_persistent_group_properties - Get options for a persistent
  1111. * group
  1112. * @message: Pointer to incoming dbus message
  1113. * @net: wpa_supplicant structure for a network interface and
  1114. * wpa_ssid structure for a configured persistent group (internally network)
  1115. * Returns: DBus message with network properties or DBus error on failure
  1116. *
  1117. * Getter for "Properties" property of a persistent group.
  1118. */
  1119. DBusMessage * wpas_dbus_getter_persistent_group_properties(
  1120. DBusMessage *message, struct network_handler_args *net)
  1121. {
  1122. /*
  1123. * Leveraging the fact that persistent group object is still
  1124. * represented in same manner as network within.
  1125. */
  1126. return wpas_dbus_getter_network_properties(message, net);
  1127. }
  1128. /**
  1129. * wpas_dbus_setter_persistent_group_properties - Get options for a persistent
  1130. * group
  1131. * @message: Pointer to incoming dbus message
  1132. * @net: wpa_supplicant structure for a network interface and
  1133. * wpa_ssid structure for a configured persistent group (internally network)
  1134. * Returns: DBus message with network properties or DBus error on failure
  1135. *
  1136. * Setter for "Properties" property of a persistent group.
  1137. */
  1138. DBusMessage * wpas_dbus_setter_persistent_group_properties(
  1139. DBusMessage *message, struct network_handler_args *net)
  1140. {
  1141. struct wpa_ssid *ssid = net->ssid;
  1142. DBusMessage *reply = NULL;
  1143. DBusMessageIter iter, variant_iter;
  1144. dbus_message_iter_init(message, &iter);
  1145. dbus_message_iter_next(&iter);
  1146. dbus_message_iter_next(&iter);
  1147. dbus_message_iter_recurse(&iter, &variant_iter);
  1148. /*
  1149. * Leveraging the fact that persistent group object is still
  1150. * represented in same manner as network within.
  1151. */
  1152. reply = set_network_properties(message, net->wpa_s, ssid,
  1153. &variant_iter);
  1154. if (reply)
  1155. wpa_printf(MSG_DEBUG, "dbus control interface couldn't set "
  1156. "persistent group properties");
  1157. return reply;
  1158. }
  1159. /**
  1160. * wpas_dbus_new_iface_add_persistent_group - Add a new configured
  1161. * persistent_group
  1162. * @message: Pointer to incoming dbus message
  1163. * @wpa_s: wpa_supplicant structure for a network interface
  1164. * Returns: A dbus message containing the object path of the new
  1165. * persistent group
  1166. *
  1167. * Handler function for "AddPersistentGroup" method call of a P2P Device
  1168. * interface.
  1169. */
  1170. DBusMessage * wpas_dbus_handler_add_persistent_group(
  1171. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1172. {
  1173. DBusMessage *reply = NULL;
  1174. DBusMessageIter iter;
  1175. struct wpa_ssid *ssid = NULL;
  1176. char path_buf[WPAS_DBUS_OBJECT_PATH_MAX], *path = path_buf;
  1177. dbus_message_iter_init(message, &iter);
  1178. ssid = wpa_config_add_network(wpa_s->conf);
  1179. if (ssid == NULL) {
  1180. wpa_printf(MSG_ERROR, "dbus: %s: "
  1181. "Cannot add new persistent group", __func__);
  1182. reply = wpas_dbus_error_unknown_error(
  1183. message,
  1184. "wpa_supplicant could not add "
  1185. "a persistent group on this interface.");
  1186. goto err;
  1187. }
  1188. /* Mark the ssid as being a persistent group before the notification */
  1189. ssid->disabled = 2;
  1190. ssid->p2p_persistent_group = 1;
  1191. wpas_notify_persistent_group_added(wpa_s, ssid);
  1192. wpa_config_set_network_defaults(ssid);
  1193. reply = set_network_properties(message, wpa_s, ssid, &iter);
  1194. if (reply) {
  1195. wpa_printf(MSG_DEBUG, "dbus: %s: "
  1196. "Control interface could not set persistent group "
  1197. "properties", __func__);
  1198. goto err;
  1199. }
  1200. /* Construct the object path for this network. */
  1201. os_snprintf(path, WPAS_DBUS_OBJECT_PATH_MAX,
  1202. "%s/" WPAS_DBUS_NEW_PERSISTENT_GROUPS_PART "/%d",
  1203. wpa_s->dbus_new_path, ssid->id);
  1204. reply = dbus_message_new_method_return(message);
  1205. if (reply == NULL) {
  1206. reply = dbus_message_new_error(message, DBUS_ERROR_NO_MEMORY,
  1207. NULL);
  1208. goto err;
  1209. }
  1210. if (!dbus_message_append_args(reply, DBUS_TYPE_OBJECT_PATH, &path,
  1211. DBUS_TYPE_INVALID)) {
  1212. dbus_message_unref(reply);
  1213. reply = dbus_message_new_error(message, DBUS_ERROR_NO_MEMORY,
  1214. NULL);
  1215. goto err;
  1216. }
  1217. return reply;
  1218. err:
  1219. if (ssid) {
  1220. wpas_notify_persistent_group_removed(wpa_s, ssid);
  1221. wpa_config_remove_network(wpa_s->conf, ssid->id);
  1222. }
  1223. return reply;
  1224. }
  1225. /**
  1226. * wpas_dbus_handler_remove_persistent_group - Remove a configured persistent
  1227. * group
  1228. * @message: Pointer to incoming dbus message
  1229. * @wpa_s: wpa_supplicant structure for a network interface
  1230. * Returns: NULL on success or dbus error on failure
  1231. *
  1232. * Handler function for "RemovePersistentGroup" method call of a P2P Device
  1233. * interface.
  1234. */
  1235. DBusMessage * wpas_dbus_handler_remove_persistent_group(
  1236. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1237. {
  1238. DBusMessage *reply = NULL;
  1239. const char *op;
  1240. char *iface = NULL, *persistent_group_id = NULL;
  1241. int id;
  1242. struct wpa_ssid *ssid;
  1243. dbus_message_get_args(message, NULL, DBUS_TYPE_OBJECT_PATH, &op,
  1244. DBUS_TYPE_INVALID);
  1245. /*
  1246. * Extract the network ID and ensure the network is actually a child of
  1247. * this interface.
  1248. */
  1249. iface = wpas_dbus_new_decompose_object_path(op, 1,
  1250. &persistent_group_id,
  1251. NULL);
  1252. if (iface == NULL || os_strcmp(iface, wpa_s->dbus_new_path) != 0) {
  1253. reply = wpas_dbus_error_invalid_args(message, op);
  1254. goto out;
  1255. }
  1256. id = strtoul(persistent_group_id, NULL, 10);
  1257. if (errno == EINVAL) {
  1258. reply = wpas_dbus_error_invalid_args(message, op);
  1259. goto out;
  1260. }
  1261. ssid = wpa_config_get_network(wpa_s->conf, id);
  1262. if (ssid == NULL) {
  1263. reply = wpas_dbus_error_persistent_group_unknown(message);
  1264. goto out;
  1265. }
  1266. wpas_notify_persistent_group_removed(wpa_s, ssid);
  1267. if (wpa_config_remove_network(wpa_s->conf, id) < 0) {
  1268. wpa_printf(MSG_ERROR, "dbus: %s: "
  1269. "error occurred when removing persistent group %d",
  1270. __func__, id);
  1271. reply = wpas_dbus_error_unknown_error(
  1272. message,
  1273. "error removing the specified persistent group on "
  1274. "this interface.");
  1275. goto out;
  1276. }
  1277. out:
  1278. os_free(iface);
  1279. os_free(persistent_group_id);
  1280. return reply;
  1281. }
  1282. static void remove_persistent_group(struct wpa_supplicant *wpa_s,
  1283. struct wpa_ssid *ssid)
  1284. {
  1285. wpas_notify_persistent_group_removed(wpa_s, ssid);
  1286. if (wpa_config_remove_network(wpa_s->conf, ssid->id) < 0) {
  1287. wpa_printf(MSG_ERROR, "dbus: %s: "
  1288. "error occurred when removing persistent group %d",
  1289. __func__, ssid->id);
  1290. return;
  1291. }
  1292. }
  1293. /**
  1294. * wpas_dbus_handler_remove_all_persistent_groups - Remove all configured
  1295. * persistent groups
  1296. * @message: Pointer to incoming dbus message
  1297. * @wpa_s: wpa_supplicant structure for a network interface
  1298. * Returns: NULL on success or dbus error on failure
  1299. *
  1300. * Handler function for "RemoveAllPersistentGroups" method call of a
  1301. * P2P Device interface.
  1302. */
  1303. DBusMessage * wpas_dbus_handler_remove_all_persistent_groups(
  1304. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1305. {
  1306. struct wpa_ssid *ssid, *next;
  1307. struct wpa_config *config;
  1308. config = wpa_s->conf;
  1309. ssid = config->ssid;
  1310. while (ssid) {
  1311. next = ssid->next;
  1312. if (network_is_persistent_group(ssid))
  1313. remove_persistent_group(wpa_s, ssid);
  1314. ssid = next;
  1315. }
  1316. return NULL;
  1317. }
  1318. /*
  1319. * Group object properties accessor methods
  1320. */
  1321. DBusMessage * wpas_dbus_getter_p2p_group_members(DBusMessage *message,
  1322. struct wpa_supplicant *wpa_s)
  1323. {
  1324. DBusMessage *reply = NULL;
  1325. struct wpa_ssid *ssid;
  1326. unsigned int num_members;
  1327. char **paths;
  1328. unsigned int i;
  1329. void *next = NULL;
  1330. const u8 *addr;
  1331. /* Ensure we are a GO */
  1332. if (wpa_s->wpa_state != WPA_COMPLETED)
  1333. return NULL;
  1334. ssid = wpa_s->conf->ssid;
  1335. /* At present WPAS P2P_GO mode only applicable for p2p_go */
  1336. if (ssid->mode != WPAS_MODE_P2P_GO &&
  1337. ssid->mode != WPAS_MODE_AP &&
  1338. ssid->mode != WPAS_MODE_P2P_GROUP_FORMATION)
  1339. return NULL;
  1340. num_members = p2p_get_group_num_members(wpa_s->p2p_group);
  1341. paths = os_zalloc(num_members * sizeof(char *));
  1342. if (!paths)
  1343. goto out_of_memory;
  1344. i = 0;
  1345. while ((addr = p2p_iterate_group_members(wpa_s->p2p_group, &next))) {
  1346. paths[i] = os_zalloc(WPAS_DBUS_OBJECT_PATH_MAX);
  1347. if (!paths[i])
  1348. goto out_of_memory;
  1349. os_snprintf(paths[i], WPAS_DBUS_OBJECT_PATH_MAX,
  1350. "%s/" WPAS_DBUS_NEW_P2P_GROUPMEMBERS_PART
  1351. "/" COMPACT_MACSTR,
  1352. wpa_s->dbus_groupobj_path, MAC2STR(addr));
  1353. i++;
  1354. }
  1355. reply = wpas_dbus_simple_array_property_getter(message,
  1356. DBUS_TYPE_OBJECT_PATH,
  1357. paths, num_members);
  1358. for (i = 0; i < num_members; i++)
  1359. os_free(paths[i]);
  1360. os_free(paths);
  1361. return reply;
  1362. out_of_memory:
  1363. reply = dbus_message_new_error(message, DBUS_ERROR_NO_MEMORY, NULL);
  1364. if (paths) {
  1365. for (i = 0; i < num_members; i++)
  1366. os_free(paths[i]);
  1367. os_free(paths);
  1368. }
  1369. return reply;
  1370. }
  1371. DBusMessage * wpas_dbus_getter_p2p_group_properties(
  1372. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1373. {
  1374. DBusMessage *reply = NULL;
  1375. DBusMessageIter iter, variant_iter, dict_iter;
  1376. struct hostapd_data *hapd = wpa_s->ap_iface->bss[0];
  1377. const struct wpabuf *vendor_ext[MAX_WPS_VENDOR_EXTENSIONS];
  1378. int num_vendor_ext = 0;
  1379. int i;
  1380. if (!hapd) {
  1381. reply = dbus_message_new_error(message, DBUS_ERROR_FAILED,
  1382. NULL);
  1383. return reply;
  1384. }
  1385. if (message == NULL)
  1386. reply = dbus_message_new(DBUS_MESSAGE_TYPE_SIGNAL);
  1387. else
  1388. reply = dbus_message_new_method_return(message);
  1389. if (!reply)
  1390. goto err_no_mem;
  1391. dbus_message_iter_init_append(reply, &iter);
  1392. if (!dbus_message_iter_open_container(&iter, DBUS_TYPE_VARIANT,
  1393. "a{sv}", &variant_iter) ||
  1394. !wpa_dbus_dict_open_write(&variant_iter, &dict_iter))
  1395. goto err_no_mem;
  1396. /* Parse WPS Vendor Extensions sent in Beacon/Probe Response */
  1397. for (i = 0; i < MAX_WPS_VENDOR_EXTENSIONS; i++) {
  1398. if (hapd->conf->wps_vendor_ext[i] == NULL)
  1399. continue;
  1400. vendor_ext[num_vendor_ext++] = hapd->conf->wps_vendor_ext[i];
  1401. }
  1402. if (!wpa_dbus_dict_append_wpabuf_array(&dict_iter,
  1403. "WPSVendorExtensions",
  1404. vendor_ext, num_vendor_ext))
  1405. goto err_no_mem;
  1406. if (!wpa_dbus_dict_close_write(&variant_iter, &dict_iter) ||
  1407. !dbus_message_iter_close_container(&iter, &variant_iter))
  1408. goto err_no_mem;
  1409. return reply;
  1410. err_no_mem:
  1411. dbus_message_unref(reply);
  1412. return dbus_message_new_error(message, DBUS_ERROR_NO_MEMORY, NULL);
  1413. }
  1414. DBusMessage * wpas_dbus_setter_p2p_group_properties(
  1415. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1416. {
  1417. DBusMessage *reply = NULL;
  1418. DBusMessageIter iter, variant_iter;
  1419. struct wpa_dbus_dict_entry entry = { .type = DBUS_TYPE_STRING };
  1420. DBusMessageIter iter_dict;
  1421. unsigned int i;
  1422. struct hostapd_data *hapd = wpa_s->ap_iface->bss[0];
  1423. if (!hapd)
  1424. goto error;
  1425. dbus_message_iter_init(message, &iter);
  1426. dbus_message_iter_next(&iter);
  1427. dbus_message_iter_next(&iter);
  1428. dbus_message_iter_recurse(&iter, &variant_iter);
  1429. if (!wpa_dbus_dict_open_read(&variant_iter, &iter_dict))
  1430. return wpas_dbus_error_invalid_args(message, NULL);
  1431. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1432. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry)) {
  1433. reply = wpas_dbus_error_invalid_args(message, NULL);
  1434. break;
  1435. }
  1436. if (os_strcmp(entry.key, "WPSVendorExtensions") == 0) {
  1437. if (entry.type != DBUS_TYPE_ARRAY ||
  1438. entry.array_type != WPAS_DBUS_TYPE_BINARRAY ||
  1439. entry.array_len > MAX_WPS_VENDOR_EXTENSIONS)
  1440. goto error;
  1441. for (i = 0; i < MAX_WPS_VENDOR_EXTENSIONS; i++) {
  1442. if (i < entry.array_len) {
  1443. hapd->conf->wps_vendor_ext[i] =
  1444. entry.binarray_value[i];
  1445. entry.binarray_value[i] = NULL;
  1446. } else
  1447. hapd->conf->wps_vendor_ext[i] = NULL;
  1448. }
  1449. hostapd_update_wps(hapd);
  1450. } else
  1451. goto error;
  1452. wpa_dbus_dict_entry_clear(&entry);
  1453. }
  1454. return reply;
  1455. error:
  1456. reply = wpas_dbus_error_invalid_args(message, entry.key);
  1457. wpa_dbus_dict_entry_clear(&entry);
  1458. return reply;
  1459. }
  1460. DBusMessage * wpas_dbus_handler_p2p_add_service(DBusMessage *message,
  1461. struct wpa_supplicant *wpa_s)
  1462. {
  1463. DBusMessageIter iter_dict;
  1464. DBusMessage *reply = NULL;
  1465. DBusMessageIter iter;
  1466. struct wpa_dbus_dict_entry entry;
  1467. int upnp = 0;
  1468. int bonjour = 0;
  1469. char *service = NULL;
  1470. struct wpabuf *query = NULL;
  1471. struct wpabuf *resp = NULL;
  1472. u8 version = 0;
  1473. dbus_message_iter_init(message, &iter);
  1474. if (!wpa_dbus_dict_open_read(&iter, &iter_dict))
  1475. goto error;
  1476. if (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1477. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1478. goto error;
  1479. if (!os_strcmp(entry.key, "service_type") &&
  1480. (entry.type == DBUS_TYPE_STRING)) {
  1481. if (!os_strcmp(entry.str_value, "upnp"))
  1482. upnp = 1;
  1483. else if (!os_strcmp(entry.str_value, "bonjour"))
  1484. bonjour = 1;
  1485. else
  1486. goto error_clear;
  1487. wpa_dbus_dict_entry_clear(&entry);
  1488. }
  1489. }
  1490. if (upnp == 1) {
  1491. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1492. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1493. goto error;
  1494. if (!os_strcmp(entry.key, "version") &&
  1495. entry.type == DBUS_TYPE_INT32)
  1496. version = entry.uint32_value;
  1497. else if (!os_strcmp(entry.key, "service") &&
  1498. entry.type == DBUS_TYPE_STRING)
  1499. service = os_strdup(entry.str_value);
  1500. wpa_dbus_dict_entry_clear(&entry);
  1501. }
  1502. if (version <= 0 || service == NULL)
  1503. goto error;
  1504. if (wpas_p2p_service_add_upnp(wpa_s, version, service) != 0)
  1505. goto error;
  1506. os_free(service);
  1507. } else if (bonjour == 1) {
  1508. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1509. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1510. goto error;
  1511. if (!os_strcmp(entry.key, "query")) {
  1512. if ((entry.type != DBUS_TYPE_ARRAY) ||
  1513. (entry.array_type != DBUS_TYPE_BYTE))
  1514. goto error_clear;
  1515. query = wpabuf_alloc_copy(
  1516. entry.bytearray_value,
  1517. entry.array_len);
  1518. } else if (!os_strcmp(entry.key, "response")) {
  1519. if ((entry.type != DBUS_TYPE_ARRAY) ||
  1520. (entry.array_type != DBUS_TYPE_BYTE))
  1521. goto error_clear;
  1522. resp = wpabuf_alloc_copy(entry.bytearray_value,
  1523. entry.array_len);
  1524. }
  1525. wpa_dbus_dict_entry_clear(&entry);
  1526. }
  1527. if (query == NULL || resp == NULL)
  1528. goto error;
  1529. if (wpas_p2p_service_add_bonjour(wpa_s, query, resp) < 0) {
  1530. wpabuf_free(query);
  1531. wpabuf_free(resp);
  1532. goto error;
  1533. }
  1534. } else
  1535. goto error;
  1536. return reply;
  1537. error_clear:
  1538. wpa_dbus_dict_entry_clear(&entry);
  1539. error:
  1540. return wpas_dbus_error_invalid_args(message, NULL);
  1541. }
  1542. DBusMessage * wpas_dbus_handler_p2p_delete_service(
  1543. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1544. {
  1545. DBusMessageIter iter_dict;
  1546. DBusMessage *reply = NULL;
  1547. DBusMessageIter iter;
  1548. struct wpa_dbus_dict_entry entry;
  1549. int upnp = 0;
  1550. int bonjour = 0;
  1551. int ret = 0;
  1552. char *service = NULL;
  1553. struct wpabuf *query = NULL;
  1554. u8 version = 0;
  1555. dbus_message_iter_init(message, &iter);
  1556. if (!wpa_dbus_dict_open_read(&iter, &iter_dict))
  1557. goto error;
  1558. if (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1559. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1560. goto error;
  1561. if (!os_strcmp(entry.key, "service_type") &&
  1562. (entry.type == DBUS_TYPE_STRING)) {
  1563. if (!os_strcmp(entry.str_value, "upnp"))
  1564. upnp = 1;
  1565. else if (!os_strcmp(entry.str_value, "bonjour"))
  1566. bonjour = 1;
  1567. else
  1568. goto error_clear;
  1569. wpa_dbus_dict_entry_clear(&entry);
  1570. }
  1571. }
  1572. if (upnp == 1) {
  1573. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1574. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1575. goto error;
  1576. if (!os_strcmp(entry.key, "version") &&
  1577. entry.type == DBUS_TYPE_INT32)
  1578. version = entry.uint32_value;
  1579. else if (!os_strcmp(entry.key, "service") &&
  1580. entry.type == DBUS_TYPE_STRING)
  1581. service = os_strdup(entry.str_value);
  1582. else
  1583. goto error_clear;
  1584. wpa_dbus_dict_entry_clear(&entry);
  1585. }
  1586. if (version <= 0 || service == NULL)
  1587. goto error;
  1588. ret = wpas_p2p_service_del_upnp(wpa_s, version, service);
  1589. os_free(service);
  1590. if (ret != 0)
  1591. goto error;
  1592. } else if (bonjour == 1) {
  1593. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1594. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1595. goto error;
  1596. if (!os_strcmp(entry.key, "query")) {
  1597. if ((entry.type != DBUS_TYPE_ARRAY) ||
  1598. (entry.array_type != DBUS_TYPE_BYTE))
  1599. goto error_clear;
  1600. query = wpabuf_alloc_copy(
  1601. entry.bytearray_value,
  1602. entry.array_len);
  1603. } else
  1604. goto error_clear;
  1605. wpa_dbus_dict_entry_clear(&entry);
  1606. }
  1607. if (query == NULL)
  1608. goto error;
  1609. ret = wpas_p2p_service_del_bonjour(wpa_s, query);
  1610. if (ret != 0)
  1611. goto error;
  1612. wpabuf_free(query);
  1613. } else
  1614. goto error;
  1615. return reply;
  1616. error_clear:
  1617. wpa_dbus_dict_entry_clear(&entry);
  1618. error:
  1619. return wpas_dbus_error_invalid_args(message, NULL);
  1620. }
  1621. DBusMessage * wpas_dbus_handler_p2p_flush_service(DBusMessage *message,
  1622. struct wpa_supplicant *wpa_s)
  1623. {
  1624. wpas_p2p_service_flush(wpa_s);
  1625. return NULL;
  1626. }
  1627. DBusMessage * wpas_dbus_handler_p2p_service_sd_req(
  1628. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1629. {
  1630. DBusMessageIter iter_dict;
  1631. DBusMessage *reply = NULL;
  1632. DBusMessageIter iter;
  1633. struct wpa_dbus_dict_entry entry;
  1634. int upnp = 0;
  1635. char *service = NULL;
  1636. char *peer_object_path = NULL;
  1637. struct wpabuf *tlv = NULL;
  1638. u8 version = 0;
  1639. u64 ref = 0;
  1640. u8 addr[ETH_ALEN];
  1641. dbus_message_iter_init(message, &iter);
  1642. if (!wpa_dbus_dict_open_read(&iter, &iter_dict))
  1643. goto error;
  1644. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1645. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1646. goto error;
  1647. if (!os_strcmp(entry.key, "peer_object") &&
  1648. entry.type == DBUS_TYPE_OBJECT_PATH) {
  1649. peer_object_path = os_strdup(entry.str_value);
  1650. } else if (!os_strcmp(entry.key, "service_type") &&
  1651. entry.type == DBUS_TYPE_STRING) {
  1652. if (!os_strcmp(entry.str_value, "upnp"))
  1653. upnp = 1;
  1654. else
  1655. goto error_clear;
  1656. } else if (!os_strcmp(entry.key, "version") &&
  1657. entry.type == DBUS_TYPE_INT32) {
  1658. version = entry.uint32_value;
  1659. } else if (!os_strcmp(entry.key, "service") &&
  1660. entry.type == DBUS_TYPE_STRING) {
  1661. service = os_strdup(entry.str_value);
  1662. } else if (!os_strcmp(entry.key, "tlv")) {
  1663. if (entry.type != DBUS_TYPE_ARRAY ||
  1664. entry.array_type != DBUS_TYPE_BYTE)
  1665. goto error_clear;
  1666. tlv = wpabuf_alloc_copy(entry.bytearray_value,
  1667. entry.array_len);
  1668. } else
  1669. goto error_clear;
  1670. wpa_dbus_dict_entry_clear(&entry);
  1671. }
  1672. if (!peer_object_path ||
  1673. (parse_peer_object_path(peer_object_path, addr) < 0) ||
  1674. (p2p_get_peer_info(wpa_s->global->p2p, addr, 0, NULL, 0) < 0))
  1675. goto error;
  1676. if (upnp == 1) {
  1677. if (version <= 0 || service == NULL)
  1678. goto error;
  1679. ref = (unsigned long) wpas_p2p_sd_request_upnp(wpa_s, addr,
  1680. version,
  1681. service);
  1682. } else {
  1683. if (tlv == NULL)
  1684. goto error;
  1685. ref = (unsigned long)wpas_p2p_sd_request(wpa_s, addr, tlv);
  1686. wpabuf_free(tlv);
  1687. }
  1688. if (ref != 0) {
  1689. reply = dbus_message_new_method_return(message);
  1690. dbus_message_append_args(reply, DBUS_TYPE_UINT64,
  1691. &ref, DBUS_TYPE_INVALID);
  1692. } else {
  1693. reply = wpas_dbus_error_unknown_error(
  1694. message, "Unable to send SD request");
  1695. }
  1696. out:
  1697. os_free(service);
  1698. os_free(peer_object_path);
  1699. return reply;
  1700. error_clear:
  1701. wpa_dbus_dict_entry_clear(&entry);
  1702. error:
  1703. if (tlv)
  1704. wpabuf_free(tlv);
  1705. reply = wpas_dbus_error_invalid_args(message, NULL);
  1706. goto out;
  1707. }
  1708. DBusMessage * wpas_dbus_handler_p2p_service_sd_res(
  1709. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1710. {
  1711. DBusMessageIter iter_dict;
  1712. DBusMessage *reply = NULL;
  1713. DBusMessageIter iter;
  1714. struct wpa_dbus_dict_entry entry;
  1715. char *peer_object_path = NULL;
  1716. struct wpabuf *tlv = NULL;
  1717. int freq = 0;
  1718. int dlg_tok = 0;
  1719. u8 addr[ETH_ALEN];
  1720. dbus_message_iter_init(message, &iter);
  1721. if (!wpa_dbus_dict_open_read(&iter, &iter_dict))
  1722. goto error;
  1723. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1724. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1725. goto error;
  1726. if (!os_strcmp(entry.key, "peer_object") &&
  1727. entry.type == DBUS_TYPE_OBJECT_PATH) {
  1728. peer_object_path = os_strdup(entry.str_value);
  1729. } else if (!os_strcmp(entry.key, "frequency") &&
  1730. entry.type == DBUS_TYPE_INT32) {
  1731. freq = entry.uint32_value;
  1732. } else if (!os_strcmp(entry.key, "dialog_token") &&
  1733. entry.type == DBUS_TYPE_UINT32) {
  1734. dlg_tok = entry.uint32_value;
  1735. } else if (!os_strcmp(entry.key, "tlvs")) {
  1736. if (entry.type != DBUS_TYPE_ARRAY ||
  1737. entry.array_type != DBUS_TYPE_BYTE)
  1738. goto error_clear;
  1739. tlv = wpabuf_alloc_copy(entry.bytearray_value,
  1740. entry.array_len);
  1741. } else
  1742. goto error_clear;
  1743. wpa_dbus_dict_entry_clear(&entry);
  1744. }
  1745. if (!peer_object_path ||
  1746. (parse_peer_object_path(peer_object_path, addr) < 0) ||
  1747. (p2p_get_peer_info(wpa_s->global->p2p, addr, 0, NULL, 0) < 0))
  1748. goto error;
  1749. if (tlv == NULL)
  1750. goto error;
  1751. wpas_p2p_sd_response(wpa_s, freq, addr, (u8) dlg_tok, tlv);
  1752. wpabuf_free(tlv);
  1753. out:
  1754. os_free(peer_object_path);
  1755. return reply;
  1756. error_clear:
  1757. wpa_dbus_dict_entry_clear(&entry);
  1758. error:
  1759. reply = wpas_dbus_error_invalid_args(message, NULL);
  1760. goto out;
  1761. }
  1762. DBusMessage * wpas_dbus_handler_p2p_service_sd_cancel_req(
  1763. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1764. {
  1765. DBusMessageIter iter;
  1766. u64 req = 0;
  1767. dbus_message_iter_init(message, &iter);
  1768. dbus_message_iter_get_basic(&iter, &req);
  1769. if (req == 0)
  1770. goto error;
  1771. if (!wpas_p2p_sd_cancel_request(wpa_s, (void *)(unsigned long) req))
  1772. goto error;
  1773. return NULL;
  1774. error:
  1775. return wpas_dbus_error_invalid_args(message, NULL);
  1776. }
  1777. DBusMessage * wpas_dbus_handler_p2p_service_update(
  1778. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1779. {
  1780. wpas_p2p_sd_service_update(wpa_s);
  1781. return NULL;
  1782. }
  1783. DBusMessage * wpas_dbus_handler_p2p_serv_disc_external(
  1784. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1785. {
  1786. DBusMessageIter iter;
  1787. int ext = 0;
  1788. dbus_message_iter_init(message, &iter);
  1789. dbus_message_iter_get_basic(&iter, &ext);
  1790. wpa_s->p2p_sd_over_ctrl_iface = ext;
  1791. return NULL;
  1792. }