dbus_new_handlers_p2p.c 68 KB

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