aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorJouni Malinen <j@w1.fi>2012-08-09 19:38:59 (GMT)
committerJouni Malinen <j@w1.fi>2012-08-09 20:18:32 (GMT)
commit4702d3a248375b2b779b12145f99a0cb333db8a2 (patch)
treef4cc6159b4fe4fc920bcfd1d51fba472f5814022
parent87a728b9c7f88e8e70e73d2adc9e62a15c78df8e (diff)
downloadhostap-4702d3a248375b2b779b12145f99a0cb333db8a2.zip
hostap-4702d3a248375b2b779b12145f99a0cb333db8a2.tar.gz
hostap-4702d3a248375b2b779b12145f99a0cb333db8a2.tar.bz2
AOSP: P2P SD
-rw-r--r--src/p2p/p2p.c61
-rw-r--r--src/p2p/p2p_i.h8
-rw-r--r--src/p2p/p2p_sd.c40
3 files changed, 106 insertions, 3 deletions
diff --git a/src/p2p/p2p.c b/src/p2p/p2p.c
index 7b003ac..09c0878 100644
--- a/src/p2p/p2p.c
+++ b/src/p2p/p2p.c
@@ -121,6 +121,11 @@ static void p2p_expire_peers(struct p2p_data *p2p)
wpa_msg(p2p->cfg->msg_ctx, MSG_ERROR, "P2P: Expiring old peer "
"entry " MACSTR, MAC2STR(dev->info.p2p_device_addr));
+#ifdef ANDROID_P2P
+ /* SD_FAIR_POLICY: Update the current sd_dev_list pointer to next device */
+ if(&dev->list == p2p->sd_dev_list)
+ p2p->sd_dev_list = dev->list.next;
+#endif
dl_list_del(&dev->list);
p2p_device_free(p2p, dev);
}
@@ -413,6 +418,11 @@ static struct p2p_device * p2p_create_device(struct p2p_data *p2p,
wpa_msg(p2p->cfg->msg_ctx, MSG_DEBUG,
"P2P: Remove oldest peer entry to make room for a new "
"peer");
+#ifdef ANDROID_P2P
+ /* SD_FAIR_POLICY: Update the current sd_dev_list pointer to next device */
+ if(&oldest->list == p2p->sd_dev_list)
+ p2p->sd_dev_list = oldest->list.next;
+#endif
dl_list_del(&oldest->list);
p2p_device_free(p2p, oldest);
}
@@ -897,7 +907,15 @@ static int p2p_run_after_scan(struct p2p_data *p2p)
p2p->after_scan_tx->wait_time);
os_free(p2p->after_scan_tx);
p2p->after_scan_tx = NULL;
+#ifdef ANDROID_P2P
+ /* For SD frames, there is a scenario, where we can receive a SD request frame during p2p_scan.
+ * At that moment, we will send the SD response from this context. After sending the SD response,
+ * we need to continue p2p_find. But if we return 1 from here, p2p_find is going to be stopped.
+ */
+ return 0;
+#else
return 1;
+#endif
}
op = p2p->start_after_scan;
@@ -2239,8 +2257,16 @@ struct p2p_data * p2p_init(const struct p2p_config *cfg)
p2p->cfg->model_number = os_strdup(cfg->model_number);
if (cfg->serial_number)
p2p->cfg->serial_number = os_strdup(cfg->serial_number);
-
+#ifdef ANDROID_P2P
+ /* 100ms listen time is too less to receive the response frames in some scenarios
+ * increasing min listen time to 200ms.
+ */
+ p2p->min_disc_int = 2;
+ /* SD_FAIR_POLICY: Initializing the SD current serviced pointer to NULL */
+ p2p->sd_dev_list = NULL;
+#else
p2p->min_disc_int = 1;
+#endif
p2p->max_disc_int = 3;
os_get_random(&p2p->next_tie_breaker, 1);
@@ -2294,6 +2320,10 @@ void p2p_flush(struct p2p_data *p2p)
dl_list_del(&dev->list);
p2p_device_free(p2p, dev);
}
+#ifdef ANDROID_P2P
+ /* SD_FAIR_POLICY: Initializing the SD current serviced pointer to NULL */
+ p2p->sd_dev_list = NULL;
+#endif
p2p_free_sd_queries(p2p);
os_free(p2p->after_scan_tx);
p2p->after_scan_tx = NULL;
@@ -2472,8 +2502,37 @@ int p2p_set_country(struct p2p_data *p2p, const char *country)
void p2p_continue_find(struct p2p_data *p2p)
{
struct p2p_device *dev;
+#ifdef ANDROID_P2P
+ int skip=1;
+#endif
p2p_set_state(p2p, P2P_SEARCH);
dl_list_for_each(dev, &p2p->devices, struct p2p_device, list) {
+#ifdef ANDROID_P2P
+ /* SD_FAIR_POLICY: We need to give chance to all devices in the device list
+ * There may be a scenario, where a particular peer device have
+ * not registered any query response. When we send a SD request to such device,
+ * no response will be received. And if we continue to get probe responses from that device,
+ * and if that device happens to be on top in our device list,
+ * we will always continue to send SD requests always to that peer only.
+ * We will not be able to send SD requests to other devices in that case.
+ * This implementation keeps track of last serviced peer device.
+ * And then takes the next one from the device list, in the next iteration.
+ */
+ if (p2p->sd_dev_list && p2p->sd_dev_list != &p2p->devices) {
+ if(skip) {
+ if ((&dev->list == p2p->sd_dev_list) ) {
+ skip = 0;
+ if (dev->list.next == &p2p->devices)
+ p2p->sd_dev_list = NULL;
+ }
+ continue;
+ }
+ }
+ p2p->sd_dev_list = &dev->list;
+ wpa_printf(MSG_DEBUG, "P2P: ### Servicing %p dev->flags 0x%x SD schedule %s devaddr " MACSTR,
+ p2p->sd_dev_list, dev->flags, dev->flags & P2P_DEV_SD_SCHEDULE ? "TRUE": "FALSE",
+ MAC2STR(dev->info.p2p_device_addr));
+#endif
if (dev->flags & P2P_DEV_SD_SCHEDULE) {
if (p2p_start_sd(p2p, dev) == 0)
return;
diff --git a/src/p2p/p2p_i.h b/src/p2p/p2p_i.h
index 8f9449e..4ccd38d 100644
--- a/src/p2p/p2p_i.h
+++ b/src/p2p/p2p_i.h
@@ -223,6 +223,14 @@ struct p2p_data {
*/
struct dl_list devices;
+#ifdef ANDROID_P2P
+ /**
+ * sd_dev_list - device pointer to be serviced next
+ * for service discovery
+ */
+ struct dl_list *sd_dev_list;
+#endif
+
/**
* go_neg_peer - Pointer to GO Negotiation peer
*/
diff --git a/src/p2p/p2p_sd.c b/src/p2p/p2p_sd.c
index 9e3588a..37b3f7b 100644
--- a/src/p2p/p2p_sd.c
+++ b/src/p2p/p2p_sd.c
@@ -406,7 +406,7 @@ void p2p_rx_gas_initial_resp(struct p2p_data *p2p, const u8 *sa,
if (p2p->state != P2P_SD_DURING_FIND || p2p->sd_peer == NULL ||
os_memcmp(sa, p2p->sd_peer->info.p2p_device_addr, ETH_ALEN) != 0) {
- wpa_msg(p2p->cfg->msg_ctx, MSG_DEBUG,
+ wpa_msg(p2p->cfg->msg_ctx, MSG_ERROR,
"P2P: Ignore unexpected GAS Initial Response from "
MACSTR, MAC2STR(sa));
return;
@@ -841,6 +841,19 @@ void * p2p_sd_request(struct p2p_data *p2p, const u8 *dst,
const struct wpabuf *tlvs)
{
struct p2p_sd_query *q;
+#ifdef ANDROID_P2P
+ /* Currently, supplicant doesn't support more than one pending broadcast SD request.
+ * So reject if application is registering another one before cancelling the existing one.
+ */
+ for (q = p2p->sd_queries; q; q = q->next) {
+ if( (q->for_all_peers == 1) && (!dst)) {
+ wpa_printf(MSG_ERROR, "P2P: Already one pending"
+ " Broadcast request. Please cancel the current one"
+ " before adding a new one");
+ return NULL;
+ }
+ }
+#endif
q = os_zalloc(sizeof(*q));
if (q == NULL)
@@ -859,7 +872,13 @@ void * p2p_sd_request(struct p2p_data *p2p, const u8 *dst,
q->next = p2p->sd_queries;
p2p->sd_queries = q;
- wpa_msg(p2p->cfg->msg_ctx, MSG_DEBUG, "P2P: Added SD Query %p", q);
+ wpa_msg(p2p->cfg->msg_ctx, MSG_DEBUG, "P2P: Added SD Query %p for_all_peers %d", q, q->for_all_peers);
+
+ if (dst == NULL) {
+ struct p2p_device *dev;
+ dl_list_for_each(dev, &p2p->devices, struct p2p_device, list)
+ dev->flags &= ~P2P_DEV_SD_INFO;
+ }
return q;
}
@@ -874,8 +893,25 @@ void p2p_sd_service_update(struct p2p_data *p2p)
int p2p_sd_cancel_request(struct p2p_data *p2p, void *req)
{
if (p2p_unlink_sd_query(p2p, req)) {
+#ifdef ANDROID_P2P
+ struct p2p_device *dev;
+ struct p2p_sd_query *q = (struct p2p_sd_query *)req;
+#endif
wpa_msg(p2p->cfg->msg_ctx, MSG_DEBUG,
"P2P: Cancel pending SD query %p", req);
+#ifdef ANDROID_P2P
+ /* If the request is a bcast query, then clear the
+ * P2P_DEV_SD_INFO flag so that when new sd query is registered,
+ * we will send the SD request frames to peer devices.
+ */
+ if(q->for_all_peers) {
+ p2p->sd_dev_list = NULL;
+ dl_list_for_each(dev, &p2p->devices,
+ struct p2p_device, list) {
+ dev->flags &= ~P2P_DEV_SD_INFO;
+ }
+ }
+#endif
p2p_free_sd_query(req);
return 0;
}