intel/catpt/messages.c

0001 // SPDX-License-Identifier: GPL-2.0-only
0002 //
0003 // Copyright(c) 2020 Intel Corporation. All rights reserved.
0004 //
0005 // Author: Cezary Rojewski <cezary.rojewski@intel.com>
0006 //
0007
0008 #include <linux/slab.h>
0009 #include "core.h"
0010 #include "messages.h"
0011 #include "registers.h"
0012
0013 int catpt_ipc_get_fw_version(struct catpt_dev *cdev,
0014                  struct catpt_fw_version *version)
0015 {
0016     union catpt_global_msg msg = CATPT_GLOBAL_MSG(GET_FW_VERSION);
0017     struct catpt_ipc_msg request = {{0}}, reply;
0018     int ret;
0019
0020     request.header = msg.val;
0021     reply.size = sizeof(*version);
0022     reply.data = version;
0023
0024     ret = catpt_dsp_send_msg(cdev, request, &reply);
0025     if (ret)
0026         dev_err(cdev->dev, "get fw version failed: %d\n", ret);
0027
0028     return ret;
0029 }
0030
0031 struct catpt_alloc_stream_input {
0032     enum catpt_path_id path_id:8;
0033     enum catpt_stream_type stream_type:8;
0034     enum catpt_format_id format_id:8;
0035     u8 reserved;
0036     struct catpt_audio_format input_format;
0037     struct catpt_ring_info ring_info;
0038     u8 num_entries;
0039     /* flex array with entries here */
0040     struct catpt_memory_info persistent_mem;
0041     struct catpt_memory_info scratch_mem;
0042     u32 num_notifications; /* obsolete */
0043 } __packed;
0044
0045 int catpt_ipc_alloc_stream(struct catpt_dev *cdev,
0046                enum catpt_path_id path_id,
0047                enum catpt_stream_type type,
0048                struct catpt_audio_format *afmt,
0049                struct catpt_ring_info *rinfo,
0050                u8 num_modules,
0051                struct catpt_module_entry *modules,
0052                struct resource *persistent,
0053                struct resource *scratch,
0054                struct catpt_stream_info *sinfo)
0055 {
0056     union catpt_global_msg msg = CATPT_GLOBAL_MSG(ALLOCATE_STREAM);
0057     struct catpt_alloc_stream_input input;
0058     struct catpt_ipc_msg request, reply;
0059     size_t size, arrsz;
0060     u8 *payload;
0061     off_t off;
0062     int ret;
0063
0064     off = offsetof(struct catpt_alloc_stream_input, persistent_mem);
0065     arrsz = sizeof(*modules) * num_modules;
0066     size = sizeof(input) + arrsz;
0067
0068     payload = kzalloc(size, GFP_KERNEL);
0069     if (!payload)
0070         return -ENOMEM;
0071
0072     memset(&input, 0, sizeof(input));
0073     input.path_id = path_id;
0074     input.stream_type = type;
0075     input.format_id = CATPT_FORMAT_PCM;
0076     input.input_format = *afmt;
0077     input.ring_info = *rinfo;
0078     input.num_entries = num_modules;
0079     input.persistent_mem.offset = catpt_to_dsp_offset(persistent->start);
0080     input.persistent_mem.size = resource_size(persistent);
0081     if (scratch) {
0082         input.scratch_mem.offset = catpt_to_dsp_offset(scratch->start);
0083         input.scratch_mem.size = resource_size(scratch);
0084     }
0085
0086     /* re-arrange the input: account for flex array 'entries' */
0087     memcpy(payload, &input, sizeof(input));
0088     memmove(payload + off + arrsz, payload + off, sizeof(input) - off);
0089     memcpy(payload + off, modules, arrsz);
0090
0091     request.header = msg.val;
0092     request.size = size;
0093     request.data = payload;
0094     reply.size = sizeof(*sinfo);
0095     reply.data = sinfo;
0096
0097     ret = catpt_dsp_send_msg(cdev, request, &reply);
0098     if (ret)
0099         dev_err(cdev->dev, "alloc stream type %d failed: %d\n",
0100             type, ret);
0101
0102     kfree(payload);
0103     return ret;
0104 }
0105
0106 int catpt_ipc_free_stream(struct catpt_dev *cdev, u8 stream_hw_id)
0107 {
0108     union catpt_global_msg msg = CATPT_GLOBAL_MSG(FREE_STREAM);
0109     struct catpt_ipc_msg request;
0110     int ret;
0111
0112     request.header = msg.val;
0113     request.size = sizeof(stream_hw_id);
0114     request.data = &stream_hw_id;
0115
0116     ret = catpt_dsp_send_msg(cdev, request, NULL);
0117     if (ret)
0118         dev_err(cdev->dev, "free stream %d failed: %d\n",
0119             stream_hw_id, ret);
0120
0121     return ret;
0122 }
0123
0124 int catpt_ipc_set_device_format(struct catpt_dev *cdev,
0125                 struct catpt_ssp_device_format *devfmt)
0126 {
0127     union catpt_global_msg msg = CATPT_GLOBAL_MSG(SET_DEVICE_FORMATS);
0128     struct catpt_ipc_msg request;
0129     int ret;
0130
0131     request.header = msg.val;
0132     request.size = sizeof(*devfmt);
0133     request.data = devfmt;
0134
0135     ret = catpt_dsp_send_msg(cdev, request, NULL);
0136     if (ret)
0137         dev_err(cdev->dev, "set device format failed: %d\n", ret);
0138
0139     return ret;
0140 }
0141
0142 int catpt_ipc_enter_dxstate(struct catpt_dev *cdev, enum catpt_dx_state state,
0143                 struct catpt_dx_context *context)
0144 {
0145     union catpt_global_msg msg = CATPT_GLOBAL_MSG(ENTER_DX_STATE);
0146     struct catpt_ipc_msg request, reply;
0147     int ret;
0148
0149     request.header = msg.val;
0150     request.size = sizeof(state);
0151     request.data = &state;
0152     reply.size = sizeof(*context);
0153     reply.data = context;
0154
0155     ret = catpt_dsp_send_msg(cdev, request, &reply);
0156     if (ret)
0157         dev_err(cdev->dev, "enter dx state failed: %d\n", ret);
0158
0159     return ret;
0160 }
0161
0162 int catpt_ipc_get_mixer_stream_info(struct catpt_dev *cdev,
0163                     struct catpt_mixer_stream_info *info)
0164 {
0165     union catpt_global_msg msg = CATPT_GLOBAL_MSG(GET_MIXER_STREAM_INFO);
0166     struct catpt_ipc_msg request = {{0}}, reply;
0167     int ret;
0168
0169     request.header = msg.val;
0170     reply.size = sizeof(*info);
0171     reply.data = info;
0172
0173     ret = catpt_dsp_send_msg(cdev, request, &reply);
0174     if (ret)
0175         dev_err(cdev->dev, "get mixer info failed: %d\n", ret);
0176
0177     return ret;
0178 }
0179
0180 int catpt_ipc_reset_stream(struct catpt_dev *cdev, u8 stream_hw_id)
0181 {
0182     union catpt_stream_msg msg = CATPT_STREAM_MSG(RESET_STREAM);
0183     struct catpt_ipc_msg request = {{0}};
0184     int ret;
0185
0186     msg.stream_hw_id = stream_hw_id;
0187     request.header = msg.val;
0188
0189     ret = catpt_dsp_send_msg(cdev, request, NULL);
0190     if (ret)
0191         dev_err(cdev->dev, "reset stream %d failed: %d\n",
0192             stream_hw_id, ret);
0193
0194     return ret;
0195 }
0196
0197 int catpt_ipc_pause_stream(struct catpt_dev *cdev, u8 stream_hw_id)
0198 {
0199     union catpt_stream_msg msg = CATPT_STREAM_MSG(PAUSE_STREAM);
0200     struct catpt_ipc_msg request = {{0}};
0201     int ret;
0202
0203     msg.stream_hw_id = stream_hw_id;
0204     request.header = msg.val;
0205
0206     ret = catpt_dsp_send_msg(cdev, request, NULL);
0207     if (ret)
0208         dev_err(cdev->dev, "pause stream %d failed: %d\n",
0209             stream_hw_id, ret);
0210
0211     return ret;
0212 }
0213
0214 int catpt_ipc_resume_stream(struct catpt_dev *cdev, u8 stream_hw_id)
0215 {
0216     union catpt_stream_msg msg = CATPT_STREAM_MSG(RESUME_STREAM);
0217     struct catpt_ipc_msg request = {{0}};
0218     int ret;
0219
0220     msg.stream_hw_id = stream_hw_id;
0221     request.header = msg.val;
0222
0223     ret = catpt_dsp_send_msg(cdev, request, NULL);
0224     if (ret)
0225         dev_err(cdev->dev, "resume stream %d failed: %d\n",
0226             stream_hw_id, ret);
0227
0228     return ret;
0229 }
0230
0231 struct catpt_set_volume_input {
0232     u32 channel;
0233     u32 target_volume;
0234     u64 curve_duration;
0235     u32 curve_type;
0236 } __packed;
0237
0238 int catpt_ipc_set_volume(struct catpt_dev *cdev, u8 stream_hw_id,
0239              u32 channel, u32 volume,
0240              u32 curve_duration,
0241              enum catpt_audio_curve_type curve_type)
0242 {
0243     union catpt_stream_msg msg = CATPT_STAGE_MSG(SET_VOLUME);
0244     struct catpt_ipc_msg request;
0245     struct catpt_set_volume_input input;
0246     int ret;
0247
0248     msg.stream_hw_id = stream_hw_id;
0249     input.channel = channel;
0250     input.target_volume = volume;
0251     input.curve_duration = curve_duration;
0252     input.curve_type = curve_type;
0253
0254     request.header = msg.val;
0255     request.size = sizeof(input);
0256     request.data = &input;
0257
0258     ret = catpt_dsp_send_msg(cdev, request, NULL);
0259     if (ret)
0260         dev_err(cdev->dev, "set stream %d volume failed: %d\n",
0261             stream_hw_id, ret);
0262
0263     return ret;
0264 }
0265
0266 struct catpt_set_write_pos_input {
0267     u32 new_write_pos;
0268     bool end_of_buffer;
0269     bool low_latency;
0270 } __packed;
0271
0272 int catpt_ipc_set_write_pos(struct catpt_dev *cdev, u8 stream_hw_id,
0273                 u32 pos, bool eob, bool ll)
0274 {
0275     union catpt_stream_msg msg = CATPT_STAGE_MSG(SET_WRITE_POSITION);
0276     struct catpt_ipc_msg request;
0277     struct catpt_set_write_pos_input input;
0278     int ret;
0279
0280     msg.stream_hw_id = stream_hw_id;
0281     input.new_write_pos = pos;
0282     input.end_of_buffer = eob;
0283     input.low_latency = ll;
0284
0285     request.header = msg.val;
0286     request.size = sizeof(input);
0287     request.data = &input;
0288
0289     ret = catpt_dsp_send_msg(cdev, request, NULL);
0290     if (ret)
0291         dev_err(cdev->dev, "set stream %d write pos failed: %d\n",
0292             stream_hw_id, ret);
0293
0294     return ret;
0295 }
0296
0297 int catpt_ipc_mute_loopback(struct catpt_dev *cdev, u8 stream_hw_id, bool mute)
0298 {
0299     union catpt_stream_msg msg = CATPT_STAGE_MSG(MUTE_LOOPBACK);
0300     struct catpt_ipc_msg request;
0301     int ret;
0302
0303     msg.stream_hw_id = stream_hw_id;
0304     request.header = msg.val;
0305     request.size = sizeof(mute);
0306     request.data = &mute;
0307
0308     ret = catpt_dsp_send_msg(cdev, request, NULL);
0309     if (ret)
0310         dev_err(cdev->dev, "mute loopback failed: %d\n", ret);
0311
0312     return ret;
0313 }