#include <stdlib.h>
#include <stdbool.h>
#include <unistd.h>
#include "rpcclt_openapi.h"
#include "proc_util.h"
uint32_t intIfNum,
uint32_t queue,
uint32_t numQueues)
{
uint64_t *p = (uint64_t *) 0;
uint32_t countsRead;
int i;
p = (uint64_t *) calloc(numQueues, sizeof(*p));
if (!p)
{
printf("Unable to allocate buffer of %u bytes\n", numQueues * sizeof(*p));
exit(1);
}
counts.
size = numQueues *
sizeof(*p);
intIfNum,
queue,
&counts,
&countsRead);
{
for (i = 0; i < countsRead; i++)
{
{
printf("MC Queue TX interface %u queue %u: %llu\n", intIfNum, queue, p[i]);
}
else
{
printf("MC Queue TX interface %u queue %d: %llu\n", intIfNum, i, p[i]);
}
}
}
else
{
printf("FAILED (%d) MC Queue TX interface %u queue %d\n", result, intIfNum, queue);
}
if (p)
{
free(p);
}
return result;
}
uint32_t intIfNum,
uint32_t queue,
uint32_t numQueues)
{
uint64_t *p = (uint64_t *) 0;
uint32_t countsRead;
int i;
p = (uint64_t *) calloc(numQueues, sizeof(*p));
if (!p)
{
printf("Unable to allocate buffer of %u bytes\n", numQueues * sizeof(*p));
exit(1);
}
counts.pstart = p;
counts.size = numQueues * sizeof(*p);
intIfNum,
queue,
&counts,
&countsRead);
{
for (i = 0; i < countsRead; i++)
{
{
printf("UC Queue TX interface %u queue %u: %llu\n", intIfNum, queue, p[i]);
}
else
{
printf("UC Queue TX interface %u queue %d: %llu\n", intIfNum, i, p[i]);
}
}
}
else
{
printf("FAILED (%d) UC Queue TX interface %u queue %d\n", result, intIfNum, queue);
}
if (p)
{
free(p);
}
return result;
}
uint32_t queue,
uint32_t numQueues)
{
uint64_t *p = (uint64_t *) 0;
uint32_t countsRead;
int i;
p = (uint64_t *) calloc(numQueues, sizeof(*p));
if (!p)
{
printf("Unable to allocate buffer of %u bytes\n", numQueues * sizeof(*p));
exit(1);
}
counts.pstart = p;
counts.size = numQueues * sizeof(*p);
queue,
&counts,
&countsRead);
{
for (i = 0; i < countsRead; i++)
{
{
printf("CPU Queue TX queue %u: %llu\n", queue, p[i]);
}
else
{
printf("CPU Queue TX queue %d: %llu\n", i, p[i]);
}
}
}
else
{
printf("FAILED (%d) CPU Queue TX queue %d\n", result, queue);
}
if (p)
{
free(p);
}
return result;
}
uint32_t queue,
uint32_t numQueues)
{
uint64_t *p = (uint64_t *) 0;
uint32_t countsRead;
int i;
p = (uint64_t *) calloc(numQueues, sizeof(*p));
if (!p)
{
printf("Unable to allocate buffer of %u bytes\n", numQueues * sizeof(*p));
exit(1);
}
counts.pstart = p;
counts.size = numQueues * sizeof(*p);
queue,
&counts,
&countsRead);
{
for (i = 0; i < countsRead; i++)
{
{
printf("CPU Queue drops queue %u: %llu\n", queue, p[i]);
}
else
{
printf("CPU Queue drops queue %d: %llu\n", i, p[i]);
}
}
}
else
{
printf("FAILED (%d) CPU Queue drops queue %d\n", result, queue);
}
if (p)
{
free(p);
}
return result;
}
int main (int argc, char **argv)
{
uint32_t numQueues;
int i;
uint32_t cpuIntf;
uint32_t ifNum;
l7proc_crashlog_register();
if ((result =
{
printf ("Failed to initialize RPC to OpEN. result = %d exit test\n", result);
exit (2);
}
{
sleep (1);
}
{
printf ("openapiCosQueueNumQueuesGet failed %d\n", result);
exit (2);
}
printf("numQueues is %d\n", numQueues);
ifNum = 0;
{
do
{
printf("UC Queue Transmits for interface %d\n", ifNum);
printf("*********************************\n");
printf("MC Queue Transmits for interface %d\n", ifNum);
printf("*********************************\n");
}
ifNum = 0;
{
do
{
for (i = 0; i < numQueues; i++)
{
readUCQueueTx(&clientHandle, ifNum, i, 1);
}
for (i = 0; i < numQueues; i++)
{
readMCQueueTx(&clientHandle, ifNum, i, 1);
}
}
{
printf ("openapiCosQueueNumQueuesGet failed %d\n", result);
exit (2);
}
{
printf ("openapiCosQueueNumQueuesGet (for CPU) failed %d\n", result);
exit (2);
}
for (i = 0; i < numQueues; i++)
{
readCPUQueueTx(&clientHandle, i, 1);
}
for (i = 0; i < numQueues; i++)
{
readCPUQueueDrops(&clientHandle, i, 1);
}
return 0;
}