diff mbox

[1/1] validation: pktio: fix polling tests

Message ID 1430383251-29202-1-git-send-email-alexandru.badicioiu@linaro.org
State New
Headers show

Commit Message

Alexandru Badicioiu April 30, 2015, 8:40 a.m. UTC 
From: Alexandru Badicioiu <alexandru.badicioiu@linaro.org>

Some tests poll input queues for packets but the queues
are setup as scheduled.

Signed-off-by: Alexandru Badicioiu <alexandru.badicioiu@linaro.org>
---
 test/validation/odp_pktio.c |   12 +++++++-----
 1 files changed, 7 insertions(+), 5 deletions(-)

Comments

Stuart Haslam April 30, 2015, 2:04 p.m. UTC | #1 
On Thu, Apr 30, 2015 at 11:40:51AM +0300, alexandru.badicioiu@linaro.org wrote:
> From: Alexandru Badicioiu <alexandru.badicioiu@linaro.org>
> 
> Some tests poll input queues for packets but the queues
> are setup as scheduled.
> 
> Signed-off-by: Alexandru Badicioiu <alexandru.badicioiu@linaro.org>

Reviewed-by: Stuart Haslam <stuart.haslam@linaro.org>

> ---
>  test/validation/odp_pktio.c |   12 +++++++-----
>  1 files changed, 7 insertions(+), 5 deletions(-)
> 
> diff --git a/test/validation/odp_pktio.c b/test/validation/odp_pktio.c
> index 8df367d..33ed80a 100644
> --- a/test/validation/odp_pktio.c
> +++ b/test/validation/odp_pktio.c
> @@ -227,7 +227,7 @@ static odp_pktio_t create_pktio(const char *iface)
>  	return pktio;
>  }
>  
> -static int create_inq(odp_pktio_t pktio)
> +static int create_inq(odp_pktio_t pktio, odp_queue_type_t qtype)
>  {
>  	odp_queue_param_t qparam;
>  	odp_queue_t inq_def;
> @@ -242,7 +242,9 @@ static int create_inq(odp_pktio_t pktio)
>  	inq_def = odp_queue_lookup(inq_name);
>  	if (inq_def == ODP_QUEUE_INVALID)
>  		inq_def = odp_queue_create(inq_name,
> -				ODP_QUEUE_TYPE_PKTIN, &qparam);
> +				ODP_QUEUE_TYPE_PKTIN,
> +				qtype == ODP_QUEUE_TYPE_POLL ? NULL : &qparam);
> +
>  	CU_ASSERT(inq_def != ODP_QUEUE_INVALID);
>  
>  	return odp_pktio_inq_setdef(pktio, inq_def);
> @@ -410,7 +412,7 @@ static void pktio_test_txrx(odp_queue_type_t q_type, int num_pkts)
>  			CU_FAIL("failed to open iface");
>  			return;
>  		}
> -		create_inq(io->id);
> +		create_inq(io->id, q_type);
>  		io->outq = odp_pktio_outq_getdef(io->id);
>  		if (q_type == ODP_QUEUE_TYPE_POLL)
>  			io->inq = odp_pktio_inq_getdef(io->id);
> @@ -526,7 +528,7 @@ static void test_odp_pktio_inq_remdef(void)
>  	int i;
>  
>  	CU_ASSERT(pktio != ODP_PKTIO_INVALID);
> -	CU_ASSERT(create_inq(pktio) == 0);
> +	CU_ASSERT(create_inq(pktio, ODP_QUEUE_TYPE_POLL) == 0);
>  	CU_ASSERT((inq = odp_pktio_inq_getdef(pktio)) != ODP_QUEUE_INVALID);
>  	CU_ASSERT(odp_pktio_inq_remdef(pktio) == 0);
>  
> @@ -583,7 +585,7 @@ static void test_odp_pktio_inq(void)
>  	pktio = create_pktio(iface_name[0]);
>  	CU_ASSERT(pktio != ODP_PKTIO_INVALID);
>  
> -	CU_ASSERT(create_inq(pktio) == 0);
> +	CU_ASSERT(create_inq(pktio, ODP_QUEUE_TYPE_POLL) == 0);
>  	CU_ASSERT(destroy_inq(pktio) == 0);
>  	CU_ASSERT(odp_pktio_close(pktio) == 0);
>  }
> -- 
> 1.7.3.4
>
Maxim Uvarov May 7, 2015, 1:18 p.m. UTC | #2 
Merged,
Maxim.

On 04/30/2015 17:04, Stuart Haslam wrote:
> On Thu, Apr 30, 2015 at 11:40:51AM +0300, alexandru.badicioiu@linaro.org wrote:
>> From: Alexandru Badicioiu <alexandru.badicioiu@linaro.org>
>>
>> Some tests poll input queues for packets but the queues
>> are setup as scheduled.
>>
>> Signed-off-by: Alexandru Badicioiu <alexandru.badicioiu@linaro.org>
> Reviewed-by: Stuart Haslam <stuart.haslam@linaro.org>
>
>> ---
>>   test/validation/odp_pktio.c |   12 +++++++-----
>>   1 files changed, 7 insertions(+), 5 deletions(-)
>>
>> diff --git a/test/validation/odp_pktio.c b/test/validation/odp_pktio.c
>> index 8df367d..33ed80a 100644
>> --- a/test/validation/odp_pktio.c
>> +++ b/test/validation/odp_pktio.c
>> @@ -227,7 +227,7 @@ static odp_pktio_t create_pktio(const char *iface)
>>   	return pktio;
>>   }
>>   
>> -static int create_inq(odp_pktio_t pktio)
>> +static int create_inq(odp_pktio_t pktio, odp_queue_type_t qtype)
>>   {
>>   	odp_queue_param_t qparam;
>>   	odp_queue_t inq_def;
>> @@ -242,7 +242,9 @@ static int create_inq(odp_pktio_t pktio)
>>   	inq_def = odp_queue_lookup(inq_name);
>>   	if (inq_def == ODP_QUEUE_INVALID)
>>   		inq_def = odp_queue_create(inq_name,
>> -				ODP_QUEUE_TYPE_PKTIN, &qparam);
>> +				ODP_QUEUE_TYPE_PKTIN,
>> +				qtype == ODP_QUEUE_TYPE_POLL ? NULL : &qparam);
>> +
>>   	CU_ASSERT(inq_def != ODP_QUEUE_INVALID);
>>   
>>   	return odp_pktio_inq_setdef(pktio, inq_def);
>> @@ -410,7 +412,7 @@ static void pktio_test_txrx(odp_queue_type_t q_type, int num_pkts)
>>   			CU_FAIL("failed to open iface");
>>   			return;
>>   		}
>> -		create_inq(io->id);
>> +		create_inq(io->id, q_type);
>>   		io->outq = odp_pktio_outq_getdef(io->id);
>>   		if (q_type == ODP_QUEUE_TYPE_POLL)
>>   			io->inq = odp_pktio_inq_getdef(io->id);
>> @@ -526,7 +528,7 @@ static void test_odp_pktio_inq_remdef(void)
>>   	int i;
>>   
>>   	CU_ASSERT(pktio != ODP_PKTIO_INVALID);
>> -	CU_ASSERT(create_inq(pktio) == 0);
>> +	CU_ASSERT(create_inq(pktio, ODP_QUEUE_TYPE_POLL) == 0);
>>   	CU_ASSERT((inq = odp_pktio_inq_getdef(pktio)) != ODP_QUEUE_INVALID);
>>   	CU_ASSERT(odp_pktio_inq_remdef(pktio) == 0);
>>   
>> @@ -583,7 +585,7 @@ static void test_odp_pktio_inq(void)
>>   	pktio = create_pktio(iface_name[0]);
>>   	CU_ASSERT(pktio != ODP_PKTIO_INVALID);
>>   
>> -	CU_ASSERT(create_inq(pktio) == 0);
>> +	CU_ASSERT(create_inq(pktio, ODP_QUEUE_TYPE_POLL) == 0);
>>   	CU_ASSERT(destroy_inq(pktio) == 0);
>>   	CU_ASSERT(odp_pktio_close(pktio) == 0);
>>   }
>> -- 
>> 1.7.3.4
>>
> _______________________________________________
> lng-odp mailing list
> lng-odp@lists.linaro.org
> https://lists.linaro.org/mailman/listinfo/lng-odp
diff mbox

Patch

diff --git a/test/validation/odp_pktio.c b/test/validation/odp_pktio.c
index 8df367d..33ed80a 100644
--- a/test/validation/odp_pktio.c
+++ b/test/validation/odp_pktio.c
@@ -227,7 +227,7 @@  static odp_pktio_t create_pktio(const char *iface)
 	return pktio;
 }
 
-static int create_inq(odp_pktio_t pktio)
+static int create_inq(odp_pktio_t pktio, odp_queue_type_t qtype)
 {
 	odp_queue_param_t qparam;
 	odp_queue_t inq_def;
@@ -242,7 +242,9 @@  static int create_inq(odp_pktio_t pktio)
 	inq_def = odp_queue_lookup(inq_name);
 	if (inq_def == ODP_QUEUE_INVALID)
 		inq_def = odp_queue_create(inq_name,
-				ODP_QUEUE_TYPE_PKTIN, &qparam);
+				ODP_QUEUE_TYPE_PKTIN,
+				qtype == ODP_QUEUE_TYPE_POLL ? NULL : &qparam);
+
 	CU_ASSERT(inq_def != ODP_QUEUE_INVALID);
 
 	return odp_pktio_inq_setdef(pktio, inq_def);
@@ -410,7 +412,7 @@  static void pktio_test_txrx(odp_queue_type_t q_type, int num_pkts)
 			CU_FAIL("failed to open iface");
 			return;
 		}
-		create_inq(io->id);
+		create_inq(io->id, q_type);
 		io->outq = odp_pktio_outq_getdef(io->id);
 		if (q_type == ODP_QUEUE_TYPE_POLL)
 			io->inq = odp_pktio_inq_getdef(io->id);
@@ -526,7 +528,7 @@  static void test_odp_pktio_inq_remdef(void)
 	int i;
 
 	CU_ASSERT(pktio != ODP_PKTIO_INVALID);
-	CU_ASSERT(create_inq(pktio) == 0);
+	CU_ASSERT(create_inq(pktio, ODP_QUEUE_TYPE_POLL) == 0);
 	CU_ASSERT((inq = odp_pktio_inq_getdef(pktio)) != ODP_QUEUE_INVALID);
 	CU_ASSERT(odp_pktio_inq_remdef(pktio) == 0);
 
@@ -583,7 +585,7 @@  static void test_odp_pktio_inq(void)
 	pktio = create_pktio(iface_name[0]);
 	CU_ASSERT(pktio != ODP_PKTIO_INVALID);
 
-	CU_ASSERT(create_inq(pktio) == 0);
+	CU_ASSERT(create_inq(pktio, ODP_QUEUE_TYPE_POLL) == 0);
 	CU_ASSERT(destroy_inq(pktio) == 0);
 	CU_ASSERT(odp_pktio_close(pktio) == 0);
 }