diff options
author | Android Build Coastguard Worker <android-build-coastguard-worker@google.com> | 2023-07-07 05:20:03 +0000 |
---|---|---|
committer | Android Build Coastguard Worker <android-build-coastguard-worker@google.com> | 2023-07-07 05:20:03 +0000 |
commit | b58d49bf1e52105a372cc9828208dd45705e954b (patch) | |
tree | 0d20834f77484513d331f1aa6acd9374f0504301 /wcn6740/qcwcn/wifi_hal/rb_wrapper.cpp | |
parent | 96d3c91c4ba96e01ff355c1250a280853e88e6b6 (diff) | |
parent | 17fad3051142f31d3814b20ca9bf43459b762c2a (diff) | |
download | wlan-b58d49bf1e52105a372cc9828208dd45705e954b.tar.gz |
Snap for 10453563 from 17fad3051142f31d3814b20ca9bf43459b762c2a to mainline-uwb-releaseaml_uwb_341710010aml_uwb_341513070aml_uwb_341511050aml_uwb_341310300aml_uwb_341310030aml_uwb_341111010aml_uwb_341011000android14-mainline-uwb-release
Change-Id: I8e9aae36bb23b3162683705a32e95cbd777c2aaf
Diffstat (limited to 'wcn6740/qcwcn/wifi_hal/rb_wrapper.cpp')
-rw-r--r-- | wcn6740/qcwcn/wifi_hal/rb_wrapper.cpp | 166 |
1 files changed, 166 insertions, 0 deletions
diff --git a/wcn6740/qcwcn/wifi_hal/rb_wrapper.cpp b/wcn6740/qcwcn/wifi_hal/rb_wrapper.cpp new file mode 100644 index 0000000..9083725 --- /dev/null +++ b/wcn6740/qcwcn/wifi_hal/rb_wrapper.cpp @@ -0,0 +1,166 @@ +/* Copyright (c) 2015, The Linux Foundation. All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions are + * met: + * * Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * * Redistributions in binary form must reproduce the above + * copyright notice, this list of conditions and the following + * disclaimer in the documentation and/or other materials provided + * with the distribution. + * * Neither the name of The Linux Foundation nor the names of its + * contributors may be used to endorse or promote products derived + * from this software without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED + * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF + * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT + * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS + * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR + * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF + * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR + * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, + * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE + * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN + * IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +#include <stdint.h> +#include <stdlib.h> + +#include "sync.h" +#include "wifi_hal.h" +#include "common.h" + +#include "ring_buffer.h" +#include "rb_wrapper.h" + +#define LOG_TAG "WifiHAL" + +wifi_error rb_init(hal_info *info, struct rb_info *rb_info, int id, + size_t size_of_buf, int num_bufs, char *name) +{ + rb_info->rb_ctx = ring_buffer_init(size_of_buf, num_bufs); + if (rb_info->rb_ctx == NULL) { + ALOGE("Failed to init ring buffer"); + return WIFI_ERROR_OUT_OF_MEMORY; + } + strlcpy(rb_info->name, name, MAX_RB_NAME_SIZE); + rb_info->ctx = info; + rb_info->id = id; + + /* Initialize last_push_time */ + gettimeofday(&rb_info->last_push_time, NULL); + return WIFI_SUCCESS; +} + +void rb_deinit(struct rb_info *rb_info) +{ + if (rb_info->rb_ctx) { + ring_buffer_deinit(rb_info->rb_ctx); + rb_info->rb_ctx = NULL; + } + rb_info->name[0] = '\0'; +} + +void get_rb_status(struct rb_info *rb_info, wifi_ring_buffer_status *rbs) +{ + struct rb_stats rb_stats; + + strlcpy((char *)rbs->name, rb_info->name, MAX_RB_NAME_SIZE); + rbs->flags = rb_info->flags; + rbs->ring_id = rb_info->id; + rbs->verbose_level = rb_info->verbose_level; + rb_get_stats(rb_info->rb_ctx, &rb_stats); + rbs->ring_buffer_byte_size = rb_stats.max_num_bufs * + rb_stats.each_buf_size; + rbs->written_bytes = rb_stats.total_bytes_written; + rbs->read_bytes = rb_stats.total_bytes_read; + rbs->written_records = rb_info->written_records; +} + +int is_rb_name_match(struct rb_info *rb_info, char *name) +{ + return (strncmp(rb_info->name, name, MAX_RB_NAME_SIZE) == 0); +} + +wifi_error ring_buffer_write(struct rb_info *rb_info, u8 *buf, size_t length, + int no_of_records, size_t record_length) +{ + enum rb_status status; + + status = rb_write(rb_info->rb_ctx, buf, length, 0, record_length); + if ((status == RB_FULL) || (status == RB_RETRY)) { + push_out_rb_data(rb_info); + /* Try writing the data after reading it out */ + status = rb_write(rb_info->rb_ctx, buf, length, 0, record_length); + if (status != RB_SUCCESS) { + ALOGE("Failed to rewrite %zu bytes to rb %s with error %d", length, + rb_info->name, status); + return WIFI_ERROR_UNKNOWN; + } + } else if (status == RB_FAILURE) { + ALOGE("Failed to write %zu bytes to rb %s with error %d", length, + rb_info->name, status); + return WIFI_ERROR_UNKNOWN; + } + + if (rb_info->written_records < (UINT_MAX - 1)) + rb_info->written_records += no_of_records; + else + rb_info->written_records = 0; + + return WIFI_SUCCESS; +} + +void push_out_rb_data(void *cb_ctx) +{ + struct rb_info *rb_info = (struct rb_info *)cb_ctx; + hal_info *info = (hal_info *)rb_info->ctx; + wifi_ring_buffer_status rbs; + wifi_ring_buffer_data_handler handler; + + while (info && !info->clean_up) { + size_t length = 0; + u8 *buf; + + buf = rb_get_read_buf(rb_info->rb_ctx, &length); + if (buf == NULL) { + break; + } + get_rb_status(rb_info, &rbs); + pthread_mutex_lock(&info->lh_lock); + handler.on_ring_buffer_data = info->on_ring_buffer_data; + pthread_mutex_unlock(&info->lh_lock); + if (handler.on_ring_buffer_data) { + handler.on_ring_buffer_data(rb_info->name, (char *)buf, + length, &rbs); + } + free(buf); + }; + gettimeofday(&rb_info->last_push_time, NULL); +} + +wifi_error rb_start_logging(struct rb_info *rb_info, u32 verbose_level, + u32 flags, u32 max_interval_sec, u32 min_data_size) +{ + rb_info->verbose_level = verbose_level; + rb_info->flags = flags; + rb_info->max_interval_sec = max_interval_sec; + + rb_config_threshold(rb_info->rb_ctx, min_data_size, push_out_rb_data, rb_info); + return WIFI_SUCCESS; +} + +void rb_check_for_timeout(struct rb_info *rb_info, struct timeval *now) +{ + if (rb_info->max_interval_sec == 0) { + return; + } + if (now->tv_sec >= + (rb_info->last_push_time.tv_sec + + (__kernel_time_t)rb_info->max_interval_sec)) { + push_out_rb_data(rb_info); + } +} |