Merge "wigig_sensing: add SPI profiling"

This commit is contained in:
qctecmdr 2020-05-03 06:14:58 -07:00 • committed by Gerrit - the friendly Code Review server
commit c44ac6a1ef
2 changed files with 226 additions and 45 deletions

View file

@ -1,6 +1,6 @@
// SPDX-License-Identifier: GPL-2.0-only
/*
* Copyright (c) 2019, The Linux foundation. All rights reserved.
* Copyright (c) 2019-2020, The Linux foundation. All rights reserved.
*/
#include <linux/cdev.h>
#include <linux/circ_buf.h>
@ -15,6 +15,7 @@
#include <linux/ioctl.h>
#include <linux/kernel.h>
#include <linux/kfifo.h>
#include <linux/ktime.h>
#include <linux/list.h>
#include <linux/module.h>
#include <linux/of.h>
@ -44,6 +45,35 @@
#define circ_space_to_end(circ, size) \
((CIRC_SPACE_TO_END((circ)->head, (circ)->tail, size)) & ~3)
#ifdef CONFIG_DEBUG_FS
#define SPI_STATS_MEAS_INIT(ctx, idx, name_str) \
do { \
strlcpy((ctx)->spi_stats[idx].name, name_str, \
SPI_STATS_MAX_NAME_LEN); \
atomic64_set(&(ctx)->spi_stats[idx].min, U64_MAX); \
} while (0)
#define SPI_STATS_MEAS_START(ctx, idx) (ctx)->spi_stats[idx].start = ktime_get()
#define SPI_STATS_MEAS_STOP(ctx, idx) \
do { \
struct spi_stats *ss = &(ctx)->spi_stats[idx]; \
u64 min = atomic64_read(&ss->min); \
u64 max = atomic64_read(&ss->max); \
\
ss->delta = ktime_sub(ktime_get(), ss->start); \
atomic64_set(&ss->min, (ktime_to_us(ss->delta) != 0) ? \
min_t(u64, min, ss->delta) : min); \
atomic64_set(&ss->max, max_t(u64, max, ss->delta)); \
atomic64_add(ss->delta, &ss->acc); \
atomic_inc(&ss->num_meas); \
} while (0)
#else /* CONFIG_DEBUG_FS */
#define SPI_STATS_MEAS_INIT(ctx, idx, name_str)
#define SPI_STATS_MEAS_START(ctx, idx)
#define SPI_STATS_MEAS_STOP(ctx, idx)
#endif /* CONFIG_DEBUG_FS */
struct wigig_sensing_platform_data {
struct gpio_desc *dri_gpio;
};
@ -809,17 +839,16 @@ static long wigig_sensing_ioctl(struct file *file, unsigned int cmd,
case WIGIG_SENSING_IOCTL_CHANGE_MODE:
{
struct wigig_sensing_change_mode req;
pr_info("Received WIGIG_SENSING_IOCTL_CHANGE_MODE command\n");
if (copy_from_user(&req, (void *)arg, sizeof(req)))
return -EFAULT;
SPI_STATS_MEAS_START(ctx, SPI_STATS_MEAS_CHANGE_MODE);
rc = wigig_sensing_ioc_change_mode(ctx, &req);
if (copy_to_user((void *)arg, &req, sizeof(req)))
return -EFAULT;
SPI_STATS_MEAS_STOP(ctx, SPI_STATS_MEAS_CHANGE_MODE);
break;
}
case WIGIG_SENSING_IOCTL_CLEAR_DATA:
@ -892,35 +921,35 @@ static int wigig_sensing_deassert_dri(
return rc;
}
#define MAX_SPI_READ_CHUNKS (10)
/*
* Calculate SPI transaction size so that the size is smaller than the maximum
* size and the size is equal per iteration. The equal sizes causes less SPI
* transactions since the length register does not need reprogramming.
* Calculate SPI transaction size so that the size is between the minimum size
* and two times the minimum size. The size must also divide the burst size.
* The motivaion for using equal sized transactions is to prevent reprogramming
* of the length register for every transaction.
*/
static u32 calc_spi_transaction_size(
u32 fill_level, u32 max_spi_transaction_size)
static u32 calc_spi_transaction_size(u32 burst_size,
u32 min_spi_transaction_size)
{
int i;
u32 res;
u32 i, res;
if (fill_level <= max_spi_transaction_size)
return fill_level;
if (burst_size <= min_spi_transaction_size)
return burst_size;
for (i = 2; i < MAX_SPI_READ_CHUNKS; i++) {
res = fill_level / i;
if (res <= max_spi_transaction_size && fill_level % i == 0)
res = burst_size / i;
if (burst_size % res == 0 &&
res >= min_spi_transaction_size &&
res < 2 * min_spi_transaction_size)
return res;
}
return max_spi_transaction_size;
return min_spi_transaction_size;
}
static int wigig_sensing_handle_fifo_ready_dri(struct wigig_sensing_ctx *ctx)
{
int rc = 0;
u32 burst_size = 0;
u32 spi_transaction_size;
mutex_lock(&ctx->spi_lock);
@ -944,15 +973,17 @@ static int wigig_sensing_handle_fifo_ready_dri(struct wigig_sensing_ctx *ctx)
}
/* Program burst size into the transfer length register */
spi_transaction_size = calc_spi_transaction_size(burst_size,
SPI_MAX_TRANSACTION_SIZE);
ctx->spi_transaction_size =
calc_spi_transaction_size(burst_size, SPI_MIN_TRANSACTION_SIZE);
pr_info_ratelimited("spi_transaction_size = %u\n",
ctx->spi_transaction_size);
rc = spis_write_reg(ctx->spi_dev, SPIS_TRNS_LEN_REG_ADDR,
spi_transaction_size << 16);
ctx->spi_transaction_size << 16);
if (rc) {
pr_err("Failed setting SPIS_TRNS_LEN_REG_ADDR\n");
goto End;
}
ctx->last_read_length = spi_transaction_size;
ctx->last_read_length = ctx->spi_transaction_size;
ctx->stm.burst_size_ready = true;
@ -960,15 +991,14 @@ static int wigig_sensing_handle_fifo_ready_dri(struct wigig_sensing_ctx *ctx)
* Allocate a temporary buffer to be used in case of cir_data buffer
* wrap around
*/
vfree(ctx->temp_buffer);
ctx->temp_buffer = 0;
if (burst_size != 0) {
ctx->temp_buffer = vmalloc(burst_size);
if (!ctx->temp_buffer) {
rc = -ENOMEM;
goto End;
}
} else if (ctx->temp_buffer) {
vfree(ctx->temp_buffer);
ctx->temp_buffer = 0;
}
/* Change internal state */
@ -1000,20 +1030,15 @@ static int wigig_sensing_chip_data_ready_internal(struct wigig_sensing_ctx *ctx,
struct cir_data *d = &ctx->cir_data;
struct circ_buf local;
u32 bytes_to_read;
u32 spi_transaction_size;
u32 available_space_to_end;
u32 orig_head;
/*
* Make sure that fill_level is in 32 bit units
*/
fill_level = fill_level & ~0x3;
spi_transaction_size =
calc_spi_transaction_size(fill_level, SPI_MAX_TRANSACTION_SIZE);
local = d->b;
local.head = (local.head + *offset) & (d->size_bytes - 1);
orig_head = local.head;
mutex_lock(&ctx->spi_lock);
while (fill_level > 0) {
if (ctx->stm.change_mode_in_progress) {
@ -1021,8 +1046,8 @@ static int wigig_sensing_chip_data_ready_internal(struct wigig_sensing_ctx *ctx,
break;
}
bytes_to_read = (fill_level < spi_transaction_size) ?
fill_level : spi_transaction_size;
bytes_to_read = (fill_level < SPI_MAX_TRANSACTION_SIZE) ?
fill_level : SPI_MAX_TRANSACTION_SIZE;
available_space_to_end =
circ_space_to_end(&local, d->size_bytes);
pr_debug("fill_level=%u, bytes_to_read=%u, offset=%u, available_space_to_end = %u\n",
@ -1101,15 +1126,24 @@ static int wigig_sensing_chip_data_ready(struct wigig_sensing_ctx *ctx,
}
while (read_bytes < burst_size) {
rc = wigig_sensing_chip_data_ready_internal(ctx, fill_level,
&read_bytes);
if (rc) {
if (ctx->stm.change_mode_in_progress)
pr_err("change_mode_in_progress, aborting SPI transactions\n");
else
pr_err("wigig_sensing_chip_data_ready_internal failed, err %d\n",
rc);
return rc;
if (fill_level >= ctx->spi_transaction_size) {
u32 txn_size = (fill_level >= burst_size) ? burst_size :
ctx->spi_transaction_size;
rc = wigig_sensing_chip_data_ready_internal(
ctx, txn_size, &read_bytes);
if (rc) {
if (ctx->stm.change_mode_in_progress)
pr_err("change_mode_in_progress, aborting SPI transactions\n");
else
pr_err("wigig_sensing_chip_data_ready_internal failed, err %d\n",
rc);
return rc;
}
}
if (ctx->stm.change_mode_in_progress) {
read_bytes = 0;
break;
}
if (read_bytes == burst_size)
@ -1117,11 +1151,13 @@ static int wigig_sensing_chip_data_ready(struct wigig_sensing_ctx *ctx,
/* Read fill_level again */
pr_debug("Reading RGF_USER_SPI_SPI_MBOX_FILL_STATUS register\n");
SPI_STATS_MEAS_START(ctx, SPI_STATS_MEAS_MBOX_FILL_STATUS);
mutex_lock(&ctx->spi_lock);
rc = spis_read_reg(ctx->spi_dev,
RGF_USER_SPI_SPI_MBOX_FILL_STATUS,
&spi_status.v);
mutex_unlock(&ctx->spi_lock);
SPI_STATS_MEAS_STOP(ctx, SPI_STATS_MEAS_MBOX_FILL_STATUS);
if (rc) {
pr_err("Fail to read RGF_USER_SPI_SPI_MBOX_FILL_STATUS, err %d\n",
rc);
@ -1265,10 +1301,12 @@ static irqreturn_t wigig_sensing_dri_isr_thread(int irq, void *cookie)
}
pr_debug("Reading SANITY register\n");
SPI_STATS_MEAS_START(ctx, SPI_STATS_MEAS_SANITY);
mutex_lock(&ctx->spi_lock);
rc = spis_read_reg(ctx->spi_dev, SPIS_SANITY_REG_ADDR,
&sanity_reg);
mutex_unlock(&ctx->spi_lock);
SPI_STATS_MEAS_STOP(ctx, SPI_STATS_MEAS_SANITY);
if (rc || sanity_reg != SPIS_SANITY_REG_VAL) {
pr_err("Fail to read SANITY, expected 0x%X found 0x%X err %d\n",
SPIS_SANITY_REG_VAL, sanity_reg, (int)rc);
@ -1287,11 +1325,12 @@ static irqreturn_t wigig_sensing_dri_isr_thread(int irq, void *cookie)
}
pr_debug("Reading RGF_USER_SPI_SPI_MBOX_FILL_STATUS register\n");
SPI_STATS_MEAS_START(ctx, SPI_STATS_MEAS_MBOX_FILL_STATUS);
mutex_lock(&ctx->spi_lock);
rc = spis_read_reg(ctx->spi_dev, RGF_USER_SPI_SPI_MBOX_FILL_STATUS,
&spi_status.v);
mutex_unlock(&ctx->spi_lock);
SPI_STATS_MEAS_STOP(ctx, SPI_STATS_MEAS_MBOX_FILL_STATUS);
if (rc) {
pr_err("Fail to read RGF_USER_SPI_SPI_MBOX_FILL_STATUS, err %d\n",
rc);
@ -1337,12 +1376,15 @@ static irqreturn_t wigig_sensing_dri_isr_thread(int irq, void *cookie)
spi_status.v &= ~INT_FW_READY;
}
if (spi_status.b.int_data_ready) {
SPI_STATS_MEAS_START(ctx, SPI_STATS_MEAS_DATA_READY);
pr_debug("DATA READY INTERRUPT\n");
if (!ctx->stm.change_mode_in_progress)
wigig_sensing_chip_data_ready(ctx,
spi_status.b.fill_level, ctx->stm.burst_size);
wigig_sensing_chip_data_ready(
ctx, spi_status.b.fill_level, ctx->stm.burst_size);
else
pr_debug("Change mode in progress, aborting data processing\n");
SPI_STATS_MEAS_STOP(ctx, SPI_STATS_MEAS_DATA_READY);
spi_status.v &= ~INT_DATA_READY;
}
if (spi_status.b.int_deep_sleep_exit ||
@ -1379,19 +1421,125 @@ static irqreturn_t wigig_sensing_dri_isr_thread(int irq, void *cookie)
deassert_and_bail_out:
/* Notify FW we are done with interrupt handling */
if (!dont_deassert || additional_inb_command.b.mode != 0) {
SPI_STATS_MEAS_START(ctx, SPI_STATS_MEAS_DEASSERT);
rc = wigig_sensing_deassert_dri(ctx, additional_inb_command);
if (rc)
pr_err("wigig_sensing_deassert_dri() failed, rc=%d\n",
rc);
SPI_STATS_MEAS_STOP(ctx, SPI_STATS_MEAS_DEASSERT);
}
bail_out:
mutex_unlock(&ctx->dri_lock);
SPI_STATS_MEAS_STOP(ctx, SPI_STATS_MEAS_DRI_PROC);
return IRQ_HANDLED;
}
static int wigig_sensing_debugfs_spi_stats_show(struct seq_file *s, void *data)
{
struct wigig_sensing_ctx *ctx = s->private;
int i;
if (ctx == NULL)
return -ENODEV;
seq_printf(s, "|%18s|%10s|%10s|%15s|%10s|%10s|\n",
"Name", "Min [uS]", "Max [uS]", "Acc [uS]", "#", "Avg [uS]");
for (i = 0; i < SPI_STATS_MEAS_MAX; i++) {
struct spi_stats *ss = &ctx->spi_stats[i];
u64 min = atomic64_read(&ss->min);
u64 max = atomic64_read(&ss->max);
u64 acc = atomic64_read(&ss->acc);
u64 num_meas = atomic_read(&ss->num_meas);
seq_printf(s, "|%18s|%10lu|%10lu|%15llu|%10lu|%10lu|\n",
ss->name,
ktime_to_us(min),
ktime_to_us(max),
ktime_to_us(acc),
num_meas,
ktime_to_us((num_meas != 0) ? acc / num_meas : 0));
}
return 0;
}
static int wigig_sensing_seq_spi_stats_open(struct inode *inode,
struct file *file)
{
return single_open(file, wigig_sensing_debugfs_spi_stats_show,
inode->i_private);
}
static const struct file_operations debugfs_spi_stats_fops = {
.open = wigig_sensing_seq_spi_stats_open,
.release = single_release,
.read = seq_read,
.llseek = seq_lseek,
};
static int wigig_sensing_debugfs_spi_stats_init_open(struct seq_file *s,
void *data)
{
struct wigig_sensing_ctx *ctx = s->private;
int i;
if (ctx == NULL)
return -ENODEV;
for (i = 0; i < SPI_STATS_MEAS_MAX; i++) {
struct spi_stats *ss = &ctx->spi_stats[i];
atomic64_set(&ss->min, U64_MAX);
atomic64_set(&ss->max, 0);
atomic64_set(&ss->acc, 0);
atomic_set(&ss->num_meas, 0);
ss->start = 0;
ss->delta = 0;
}
return 0;
}
static int wigig_sensing_seq_spi_stats_init_open(struct inode *inode,
struct file *file)
{
return single_open(file, wigig_sensing_debugfs_spi_stats_init_open,
inode->i_private);
}
static const struct file_operations debugfs_spi_stats_init_fops = {
.open = wigig_sensing_seq_spi_stats_init_open,
.release = single_release,
.read = seq_read,
.llseek = seq_lseek,
};
static int wigig_sensing_debugfs_init(struct wigig_sensing_ctx *ctx)
{
SPI_STATS_MEAS_INIT(ctx, SPI_STATS_MEAS_SANITY, "Sanity");
SPI_STATS_MEAS_INIT(ctx, SPI_STATS_MEAS_DEASSERT, "Deassert DRI");
SPI_STATS_MEAS_INIT(ctx, SPI_STATS_MEAS_DRI_PROC, "DRI proc");
SPI_STATS_MEAS_INIT(ctx, SPI_STATS_MEAS_MBOX_FILL_STATUS,
"MBOX FILL STATUS");
SPI_STATS_MEAS_INIT(ctx, SPI_STATS_MEAS_CHANGE_MODE, "CHANGE MODE");
SPI_STATS_MEAS_INIT(ctx, SPI_STATS_MEAS_DATA_READY, "Data Ready");
ctx->debugfs_dent = debugfs_create_dir("wigig_sensing", NULL);
debugfs_create_file("spi_stats", 0644, ctx->debugfs_dent, ctx,
&debugfs_spi_stats_fops);
debugfs_create_file("spi_stats_init", 0644, ctx->debugfs_dent, ctx,
&debugfs_spi_stats_init_fops);
return 0;
}
static irqreturn_t wigig_sensing_dri_isr_hard(int irq, void *cookie)
{
SPI_STATS_MEAS_START((struct wigig_sensing_ctx *)cookie,
SPI_STATS_MEAS_DRI_PROC);
return IRQ_WAKE_THREAD;
}
@ -1476,6 +1624,9 @@ static int wigig_sensing_probe(struct spi_device *spi)
goto fail_gpiod_get;
}
/* Initialize debugfs */
wigig_sensing_debugfs_init(ctx);
return 0;
fail_gpiod_get:
@ -1503,6 +1654,7 @@ static int wigig_sensing_remove(struct spi_device *spi)
/* Make sure that FW is in STOP mode */
wigig_sensing_ioc_change_mode(ctx, &req);
debugfs_remove_recursive(ctx->debugfs_dent);
device_destroy(ctx->class, ctx->wigig_sensing_dev);
unregister_chrdev_region(ctx->wigig_sensing_dev, 1);
class_destroy(ctx->class);

View file

@ -1,6 +1,6 @@
/* SPDX-License-Identifier: GPL-2.0-only */
/*
* Copyright (c) 2019, The Linux foundation. All rights reserved.
* Copyright (c) 2019-2020, The Linux foundation. All rights reserved.
*/
#ifndef __WIGIG_SENSING_H__
@ -8,6 +8,7 @@
#include <linux/cdev.h>
#include <linux/circ_buf.h>
#include <linux/kfifo.h>
#include <linux/ktime.h>
#include <linux/slab.h>
#include <uapi/misc/wigig_sensing_uapi.h>
@ -41,6 +42,8 @@
#define SPIS_CONFIG_REG_OPT_VAL (0x44200800)
#define SPIS_EXTENDED_RESET_COMMAND_LEN (225)
#define MAX_SPI_READ_CHUNKS (10)
#define SPI_MIN_TRANSACTION_SIZE (512)
#define SPI_MAX_TRANSACTION_SIZE (8*1024)
#define SPI_CMD_TRANSACTION_SIZE (512)
#define SPI_BUFFER_SIZE (SPI_MAX_TRANSACTION_SIZE + OPCODE_WIDTH + \
@ -160,12 +163,34 @@ struct wigig_sensing_stm {
enum wigig_sensing_mode mode_request;
};
enum spi_stats_meas {
SPI_STATS_MEAS_MIN,
SPI_STATS_MEAS_SANITY = SPI_STATS_MEAS_MIN,
SPI_STATS_MEAS_DEASSERT,
SPI_STATS_MEAS_DRI_PROC,
SPI_STATS_MEAS_MBOX_FILL_STATUS,
SPI_STATS_MEAS_CHANGE_MODE,
SPI_STATS_MEAS_DATA_READY,
SPI_STATS_MEAS_MAX,
};
#define SPI_STATS_MAX_NAME_LEN (20)
struct spi_stats {
char name[SPI_STATS_MAX_NAME_LEN];
atomic64_t min;
atomic64_t max;
atomic64_t acc;
atomic_t num_meas;
ktime_t start, delta;
};
struct wigig_sensing_ctx {
dev_t wigig_sensing_dev;
struct cdev cdev;
struct class *class;
struct device *dev;
struct spi_device *spi_dev;
struct dentry *debugfs_dent;
/* Locks */
struct mutex ioctl_lock;
@ -191,6 +216,7 @@ struct wigig_sensing_ctx {
struct wigig_sensing_stm stm;
u32 last_read_length;
union user_rgf_spi_mbox_inb inb_cmd;
u32 spi_transaction_size;
/* CIR buffer */
struct cir_data cir_data;
@ -198,6 +224,9 @@ struct wigig_sensing_ctx {
bool event_pending;
DECLARE_KFIFO(events_fifo, enum wigig_sensing_event, 8);
u32 dropped_bursts;
/* Statistics */
struct spi_stats spi_stats[SPI_STATS_MEAS_MAX];
};
#endif /* __WIGIG_SENSING_H__ */