1 // SPDX-License-Identifier: GPL-2.0 2 /* 3 * Sample in-kernel QMI client driver 4 * 5 * Copyright (c) 2013-2014, The Linux Foundation. All rights reserved. 6 * Copyright (C) 2017 Linaro Ltd. 7 */ 8 #include <linux/kernel.h> 9 #include <linux/module.h> 10 #include <linux/debugfs.h> 11 #include <linux/device.h> 12 #include <linux/platform_device.h> 13 #include <linux/qrtr.h> 14 #include <linux/net.h> 15 #include <linux/completion.h> 16 #include <linux/idr.h> 17 #include <linux/string.h> 18 #include <net/sock.h> 19 #include <linux/soc/qcom/qmi.h> 20 21 #define PING_REQ1_TLV_TYPE 0x1 22 #define PING_RESP1_TLV_TYPE 0x2 23 #define PING_OPT1_TLV_TYPE 0x10 24 #define PING_OPT2_TLV_TYPE 0x11 25 26 #define DATA_REQ1_TLV_TYPE 0x1 27 #define DATA_RESP1_TLV_TYPE 0x2 28 #define DATA_OPT1_TLV_TYPE 0x10 29 #define DATA_OPT2_TLV_TYPE 0x11 30 31 #define TEST_MED_DATA_SIZE_V01 8192 32 #define TEST_MAX_NAME_SIZE_V01 255 33 34 #define TEST_PING_REQ_MSG_ID_V01 0x20 35 #define TEST_DATA_REQ_MSG_ID_V01 0x21 36 37 #define TEST_PING_REQ_MAX_MSG_LEN_V01 266 38 #define TEST_DATA_REQ_MAX_MSG_LEN_V01 8456 39 40 struct test_name_type_v01 { 41 u32 name_len; 42 char name[TEST_MAX_NAME_SIZE_V01]; 43 }; 44 45 static struct qmi_elem_info test_name_type_v01_ei[] = { 46 { 47 .data_type = QMI_DATA_LEN, 48 .elem_len = 1, 49 .elem_size = sizeof(u8), 50 .array_type = NO_ARRAY, 51 .tlv_type = QMI_COMMON_TLV_TYPE, 52 .offset = offsetof(struct test_name_type_v01, 53 name_len), 54 }, 55 { 56 .data_type = QMI_UNSIGNED_1_BYTE, 57 .elem_len = TEST_MAX_NAME_SIZE_V01, 58 .elem_size = sizeof(char), 59 .array_type = VAR_LEN_ARRAY, 60 .tlv_type = QMI_COMMON_TLV_TYPE, 61 .offset = offsetof(struct test_name_type_v01, 62 name), 63 }, 64 {} 65 }; 66 67 struct test_ping_req_msg_v01 { 68 char ping[4]; 69 70 u8 client_name_valid; 71 struct test_name_type_v01 client_name; 72 }; 73 74 static struct qmi_elem_info test_ping_req_msg_v01_ei[] = { 75 { 76 .data_type = QMI_UNSIGNED_1_BYTE, 77 .elem_len = 4, 78 .elem_size = sizeof(char), 79 .array_type = STATIC_ARRAY, 80 .tlv_type = PING_REQ1_TLV_TYPE, 81 .offset = offsetof(struct test_ping_req_msg_v01, 82 ping), 83 }, 84 { 85 .data_type = QMI_OPT_FLAG, 86 .elem_len = 1, 87 .elem_size = sizeof(u8), 88 .array_type = NO_ARRAY, 89 .tlv_type = PING_OPT1_TLV_TYPE, 90 .offset = offsetof(struct test_ping_req_msg_v01, 91 client_name_valid), 92 }, 93 { 94 .data_type = QMI_STRUCT, 95 .elem_len = 1, 96 .elem_size = sizeof(struct test_name_type_v01), 97 .array_type = NO_ARRAY, 98 .tlv_type = PING_OPT1_TLV_TYPE, 99 .offset = offsetof(struct test_ping_req_msg_v01, 100 client_name), 101 .ei_array = test_name_type_v01_ei, 102 }, 103 {} 104 }; 105 106 struct test_ping_resp_msg_v01 { 107 struct qmi_response_type_v01 resp; 108 109 u8 pong_valid; 110 char pong[4]; 111 112 u8 service_name_valid; 113 struct test_name_type_v01 service_name; 114 }; 115 116 static struct qmi_elem_info test_ping_resp_msg_v01_ei[] = { 117 { 118 .data_type = QMI_STRUCT, 119 .elem_len = 1, 120 .elem_size = sizeof(struct qmi_response_type_v01), 121 .array_type = NO_ARRAY, 122 .tlv_type = PING_RESP1_TLV_TYPE, 123 .offset = offsetof(struct test_ping_resp_msg_v01, 124 resp), 125 .ei_array = qmi_response_type_v01_ei, 126 }, 127 { 128 .data_type = QMI_OPT_FLAG, 129 .elem_len = 1, 130 .elem_size = sizeof(u8), 131 .array_type = NO_ARRAY, 132 .tlv_type = PING_OPT1_TLV_TYPE, 133 .offset = offsetof(struct test_ping_resp_msg_v01, 134 pong_valid), 135 }, 136 { 137 .data_type = QMI_UNSIGNED_1_BYTE, 138 .elem_len = 4, 139 .elem_size = sizeof(char), 140 .array_type = STATIC_ARRAY, 141 .tlv_type = PING_OPT1_TLV_TYPE, 142 .offset = offsetof(struct test_ping_resp_msg_v01, 143 pong), 144 }, 145 { 146 .data_type = QMI_OPT_FLAG, 147 .elem_len = 1, 148 .elem_size = sizeof(u8), 149 .array_type = NO_ARRAY, 150 .tlv_type = PING_OPT2_TLV_TYPE, 151 .offset = offsetof(struct test_ping_resp_msg_v01, 152 service_name_valid), 153 }, 154 { 155 .data_type = QMI_STRUCT, 156 .elem_len = 1, 157 .elem_size = sizeof(struct test_name_type_v01), 158 .array_type = NO_ARRAY, 159 .tlv_type = PING_OPT2_TLV_TYPE, 160 .offset = offsetof(struct test_ping_resp_msg_v01, 161 service_name), 162 .ei_array = test_name_type_v01_ei, 163 }, 164 {} 165 }; 166 167 struct test_data_req_msg_v01 { 168 u32 data_len; 169 u8 data[TEST_MED_DATA_SIZE_V01]; 170 171 u8 client_name_valid; 172 struct test_name_type_v01 client_name; 173 }; 174 175 static struct qmi_elem_info test_data_req_msg_v01_ei[] = { 176 { 177 .data_type = QMI_DATA_LEN, 178 .elem_len = 1, 179 .elem_size = sizeof(u32), 180 .array_type = NO_ARRAY, 181 .tlv_type = DATA_REQ1_TLV_TYPE, 182 .offset = offsetof(struct test_data_req_msg_v01, 183 data_len), 184 }, 185 { 186 .data_type = QMI_UNSIGNED_1_BYTE, 187 .elem_len = TEST_MED_DATA_SIZE_V01, 188 .elem_size = sizeof(u8), 189 .array_type = VAR_LEN_ARRAY, 190 .tlv_type = DATA_REQ1_TLV_TYPE, 191 .offset = offsetof(struct test_data_req_msg_v01, 192 data), 193 }, 194 { 195 .data_type = QMI_OPT_FLAG, 196 .elem_len = 1, 197 .elem_size = sizeof(u8), 198 .array_type = NO_ARRAY, 199 .tlv_type = DATA_OPT1_TLV_TYPE, 200 .offset = offsetof(struct test_data_req_msg_v01, 201 client_name_valid), 202 }, 203 { 204 .data_type = QMI_STRUCT, 205 .elem_len = 1, 206 .elem_size = sizeof(struct test_name_type_v01), 207 .array_type = NO_ARRAY, 208 .tlv_type = DATA_OPT1_TLV_TYPE, 209 .offset = offsetof(struct test_data_req_msg_v01, 210 client_name), 211 .ei_array = test_name_type_v01_ei, 212 }, 213 {} 214 }; 215 216 struct test_data_resp_msg_v01 { 217 struct qmi_response_type_v01 resp; 218 219 u8 data_valid; 220 u32 data_len; 221 u8 data[TEST_MED_DATA_SIZE_V01]; 222 223 u8 service_name_valid; 224 struct test_name_type_v01 service_name; 225 }; 226 227 static struct qmi_elem_info test_data_resp_msg_v01_ei[] = { 228 { 229 .data_type = QMI_STRUCT, 230 .elem_len = 1, 231 .elem_size = sizeof(struct qmi_response_type_v01), 232 .array_type = NO_ARRAY, 233 .tlv_type = DATA_RESP1_TLV_TYPE, 234 .offset = offsetof(struct test_data_resp_msg_v01, 235 resp), 236 .ei_array = qmi_response_type_v01_ei, 237 }, 238 { 239 .data_type = QMI_OPT_FLAG, 240 .elem_len = 1, 241 .elem_size = sizeof(u8), 242 .array_type = NO_ARRAY, 243 .tlv_type = DATA_OPT1_TLV_TYPE, 244 .offset = offsetof(struct test_data_resp_msg_v01, 245 data_valid), 246 }, 247 { 248 .data_type = QMI_DATA_LEN, 249 .elem_len = 1, 250 .elem_size = sizeof(u32), 251 .array_type = NO_ARRAY, 252 .tlv_type = DATA_OPT1_TLV_TYPE, 253 .offset = offsetof(struct test_data_resp_msg_v01, 254 data_len), 255 }, 256 { 257 .data_type = QMI_UNSIGNED_1_BYTE, 258 .elem_len = TEST_MED_DATA_SIZE_V01, 259 .elem_size = sizeof(u8), 260 .array_type = VAR_LEN_ARRAY, 261 .tlv_type = DATA_OPT1_TLV_TYPE, 262 .offset = offsetof(struct test_data_resp_msg_v01, 263 data), 264 }, 265 { 266 .data_type = QMI_OPT_FLAG, 267 .elem_len = 1, 268 .elem_size = sizeof(u8), 269 .array_type = NO_ARRAY, 270 .tlv_type = DATA_OPT2_TLV_TYPE, 271 .offset = offsetof(struct test_data_resp_msg_v01, 272 service_name_valid), 273 }, 274 { 275 .data_type = QMI_STRUCT, 276 .elem_len = 1, 277 .elem_size = sizeof(struct test_name_type_v01), 278 .array_type = NO_ARRAY, 279 .tlv_type = DATA_OPT2_TLV_TYPE, 280 .offset = offsetof(struct test_data_resp_msg_v01, 281 service_name), 282 .ei_array = test_name_type_v01_ei, 283 }, 284 {} 285 }; 286 287 /* 288 * ping_write() - ping_pong debugfs file write handler 289 * @file: debugfs file context 290 * @user_buf: reference to the user data (ignored) 291 * @count: number of bytes in @user_buf 292 * @ppos: offset in @file to write 293 * 294 * This function allows user space to send out a ping_pong QMI encoded message 295 * to the associated remote test service and will return with the result of the 296 * transaction. It serves as an example of how to provide a custom response 297 * handler. 298 * 299 * Return: @count, or negative errno on failure. 300 */ 301 static ssize_t ping_write(struct file *file, const char __user *user_buf, 302 size_t count, loff_t *ppos) 303 { 304 struct qmi_handle *qmi = file->private_data; 305 struct test_ping_req_msg_v01 req = {}; 306 struct qmi_txn txn; 307 int ret; 308 309 memcpy(req.ping, "ping", sizeof(req.ping)); 310 311 ret = qmi_txn_init(qmi, &txn, NULL, NULL); 312 if (ret < 0) 313 return ret; 314 315 ret = qmi_send_request(qmi, NULL, &txn, 316 TEST_PING_REQ_MSG_ID_V01, 317 TEST_PING_REQ_MAX_MSG_LEN_V01, 318 test_ping_req_msg_v01_ei, &req); 319 if (ret < 0) { 320 qmi_txn_cancel(&txn); 321 return ret; 322 } 323 324 ret = qmi_txn_wait(&txn, 5 * HZ); 325 if (ret < 0) 326 count = ret; 327 328 return count; 329 } 330 331 static const struct file_operations ping_fops = { 332 .open = simple_open, 333 .write = ping_write, 334 }; 335 336 static void ping_pong_cb(struct qmi_handle *qmi, struct sockaddr_qrtr *sq, 337 struct qmi_txn *txn, const void *data) 338 { 339 const struct test_ping_resp_msg_v01 *resp = data; 340 341 if (!txn) { 342 pr_err("spurious ping response\n"); 343 return; 344 } 345 346 if (resp->resp.result == QMI_RESULT_FAILURE_V01) 347 txn->result = -ENXIO; 348 else if (!resp->pong_valid || memcmp(resp->pong, "pong", 4)) 349 txn->result = -EINVAL; 350 351 complete(&txn->completion); 352 } 353 354 /* 355 * data_write() - data debugfs file write handler 356 * @file: debugfs file context 357 * @user_buf: reference to the user data 358 * @count: number of bytes in @user_buf 359 * @ppos: offset in @file to write 360 * 361 * This function allows user space to send out a data QMI encoded message to 362 * the associated remote test service and will return with the result of the 363 * transaction. It serves as an example of how to have the QMI helpers decode a 364 * transaction response into a provided object automatically. 365 * 366 * Return: @count, or negative errno on failure. 367 */ 368 static ssize_t data_write(struct file *file, const char __user *user_buf, 369 size_t count, loff_t *ppos) 370 371 { 372 struct qmi_handle *qmi = file->private_data; 373 struct test_data_resp_msg_v01 *resp; 374 struct test_data_req_msg_v01 *req; 375 struct qmi_txn txn; 376 int ret; 377 378 req = kzalloc(sizeof(*req), GFP_KERNEL); 379 if (!req) 380 return -ENOMEM; 381 382 resp = kzalloc(sizeof(*resp), GFP_KERNEL); 383 if (!resp) { 384 kfree(req); 385 return -ENOMEM; 386 } 387 388 req->data_len = min_t(size_t, sizeof(req->data), count); 389 if (copy_from_user(req->data, user_buf, req->data_len)) { 390 ret = -EFAULT; 391 goto out; 392 } 393 394 ret = qmi_txn_init(qmi, &txn, test_data_resp_msg_v01_ei, resp); 395 if (ret < 0) 396 goto out; 397 398 ret = qmi_send_request(qmi, NULL, &txn, 399 TEST_DATA_REQ_MSG_ID_V01, 400 TEST_DATA_REQ_MAX_MSG_LEN_V01, 401 test_data_req_msg_v01_ei, req); 402 if (ret < 0) { 403 qmi_txn_cancel(&txn); 404 goto out; 405 } 406 407 ret = qmi_txn_wait(&txn, 5 * HZ); 408 if (ret < 0) { 409 goto out; 410 } else if (!resp->data_valid || 411 resp->data_len != req->data_len || 412 memcmp(resp->data, req->data, req->data_len)) { 413 pr_err("response data doesn't match expectation\n"); 414 ret = -EINVAL; 415 goto out; 416 } 417 418 ret = count; 419 420 out: 421 kfree(resp); 422 kfree(req); 423 424 return ret; 425 } 426 427 static const struct file_operations data_fops = { 428 .open = simple_open, 429 .write = data_write, 430 }; 431 432 static const struct qmi_msg_handler qmi_sample_handlers[] = { 433 { 434 .type = QMI_RESPONSE, 435 .msg_id = TEST_PING_REQ_MSG_ID_V01, 436 .ei = test_ping_resp_msg_v01_ei, 437 .decoded_size = sizeof(struct test_ping_req_msg_v01), 438 .fn = ping_pong_cb 439 }, 440 {} 441 }; 442 443 struct qmi_sample { 444 struct qmi_handle qmi; 445 446 struct dentry *de_dir; 447 struct dentry *de_data; 448 struct dentry *de_ping; 449 }; 450 451 static struct dentry *qmi_debug_dir; 452 453 static int qmi_sample_probe(struct platform_device *pdev) 454 { 455 struct sockaddr_qrtr *sq; 456 struct qmi_sample *sample; 457 char path[20]; 458 int ret; 459 460 sample = devm_kzalloc(&pdev->dev, sizeof(*sample), GFP_KERNEL); 461 if (!sample) 462 return -ENOMEM; 463 464 ret = qmi_handle_init(&sample->qmi, TEST_DATA_REQ_MAX_MSG_LEN_V01, 465 NULL, 466 qmi_sample_handlers); 467 if (ret < 0) 468 return ret; 469 470 sq = dev_get_platdata(&pdev->dev); 471 ret = kernel_connect(sample->qmi.sock, (struct sockaddr *)sq, 472 sizeof(*sq), 0); 473 if (ret < 0) { 474 pr_err("failed to connect to remote service port\n"); 475 goto err_release_qmi_handle; 476 } 477 478 snprintf(path, sizeof(path), "%d:%d", sq->sq_node, sq->sq_port); 479 480 sample->de_dir = debugfs_create_dir(path, qmi_debug_dir); 481 if (IS_ERR(sample->de_dir)) { 482 ret = PTR_ERR(sample->de_dir); 483 goto err_release_qmi_handle; 484 } 485 486 sample->de_data = debugfs_create_file("data", 0600, sample->de_dir, 487 sample, &data_fops); 488 if (IS_ERR(sample->de_data)) { 489 ret = PTR_ERR(sample->de_data); 490 goto err_remove_de_dir; 491 } 492 493 sample->de_ping = debugfs_create_file("ping", 0600, sample->de_dir, 494 sample, &ping_fops); 495 if (IS_ERR(sample->de_ping)) { 496 ret = PTR_ERR(sample->de_ping); 497 goto err_remove_de_data; 498 } 499 500 platform_set_drvdata(pdev, sample); 501 502 return 0; 503 504 err_remove_de_data: 505 debugfs_remove(sample->de_data); 506 err_remove_de_dir: 507 debugfs_remove(sample->de_dir); 508 err_release_qmi_handle: 509 qmi_handle_release(&sample->qmi); 510 511 return ret; 512 } 513 514 static int qmi_sample_remove(struct platform_device *pdev) 515 { 516 struct qmi_sample *sample = platform_get_drvdata(pdev); 517 518 debugfs_remove(sample->de_ping); 519 debugfs_remove(sample->de_data); 520 debugfs_remove(sample->de_dir); 521 522 qmi_handle_release(&sample->qmi); 523 524 return 0; 525 } 526 527 static struct platform_driver qmi_sample_driver = { 528 .probe = qmi_sample_probe, 529 .remove = qmi_sample_remove, 530 .driver = { 531 .name = "qmi_sample_client", 532 }, 533 }; 534 535 static int qmi_sample_new_server(struct qmi_handle *qmi, 536 struct qmi_service *service) 537 { 538 struct platform_device *pdev; 539 struct sockaddr_qrtr sq = { AF_QIPCRTR, service->node, service->port }; 540 int ret; 541 542 pdev = platform_device_alloc("qmi_sample_client", PLATFORM_DEVID_AUTO); 543 if (!pdev) 544 return -ENOMEM; 545 546 ret = platform_device_add_data(pdev, &sq, sizeof(sq)); 547 if (ret) 548 goto err_put_device; 549 550 ret = platform_device_add(pdev); 551 if (ret) 552 goto err_put_device; 553 554 service->priv = pdev; 555 556 return 0; 557 558 err_put_device: 559 platform_device_put(pdev); 560 561 return ret; 562 } 563 564 static void qmi_sample_del_server(struct qmi_handle *qmi, 565 struct qmi_service *service) 566 { 567 struct platform_device *pdev = service->priv; 568 569 platform_device_unregister(pdev); 570 } 571 572 static struct qmi_handle lookup_client; 573 574 static const struct qmi_ops lookup_ops = { 575 .new_server = qmi_sample_new_server, 576 .del_server = qmi_sample_del_server, 577 }; 578 579 static int qmi_sample_init(void) 580 { 581 int ret; 582 583 qmi_debug_dir = debugfs_create_dir("qmi_sample", NULL); 584 if (IS_ERR(qmi_debug_dir)) { 585 pr_err("failed to create qmi_sample dir\n"); 586 return PTR_ERR(qmi_debug_dir); 587 } 588 589 ret = platform_driver_register(&qmi_sample_driver); 590 if (ret) 591 goto err_remove_debug_dir; 592 593 ret = qmi_handle_init(&lookup_client, 0, &lookup_ops, NULL); 594 if (ret < 0) 595 goto err_unregister_driver; 596 597 qmi_add_lookup(&lookup_client, 15, 0, 0); 598 599 return 0; 600 601 err_unregister_driver: 602 platform_driver_unregister(&qmi_sample_driver); 603 err_remove_debug_dir: 604 debugfs_remove(qmi_debug_dir); 605 606 return ret; 607 } 608 609 static void qmi_sample_exit(void) 610 { 611 qmi_handle_release(&lookup_client); 612 613 platform_driver_unregister(&qmi_sample_driver); 614 615 debugfs_remove(qmi_debug_dir); 616 } 617 618 module_init(qmi_sample_init); 619 module_exit(qmi_sample_exit); 620 621 MODULE_DESCRIPTION("Sample QMI client driver"); 622 MODULE_LICENSE("GPL v2"); 623