| /spdk/test/unit/lib/iscsi/tgt_node.c/ |
| H A D | tgt_node_ut.c | 146 bool result; in allow_any_allowed() local 154 result = iscsi_netmask_allow_addr(netmask, addr1); in allow_any_allowed() 155 CU_ASSERT(result == true); in allow_any_allowed() 157 result = iscsi_netmask_allow_addr(netmask, addr2); in allow_any_allowed() 158 CU_ASSERT(result == true); in allow_any_allowed() 164 bool result; in allow_ipv6_allowed() local 171 result = iscsi_ipv6_netmask_allow_addr(netmask, addr); in allow_ipv6_allowed() 172 CU_ASSERT(result == true); in allow_ipv6_allowed() 174 result = iscsi_netmask_allow_addr(netmask, addr); in allow_ipv6_allowed() 175 CU_ASSERT(result == true); in allow_ipv6_allowed() [all …]
|
| /spdk/test/blobfs/ |
| H A D | blobfs.sh | 41 result=$($rpc_py blobfs_set_cache_size ${test_cache_size}) 42 if [ "${result}" != "True" ]; then 50 result=$($rpc_py blobfs_detect ${bdevname}) 51 if [ "${result}" != "False" ]; then 62 result=$($rpc_py blobfs_detect ${bdevname}) 63 if [ "${result}" != "True" ]; then 77 result=$($rpc_py blobfs_detect ${bdevname}) 78 if [ "${result}" != "True" ]; then
|
| /spdk/lib/nvme/ |
| H A D | nvme_poll_group.c | 462 struct spdk_nvme_poll_group_stat *result; 471 result = calloc(1, sizeof(*result)); 472 if (!result) { 481 result->transport_stat = calloc(transports_count, sizeof(*result->transport_stat)); 482 if (!result->transport_stat) { 484 free(result); 489 rc = nvme_transport_poll_group_get_stats(tgroup, &result->transport_stat[reported_stats_count]); 496 free(result 232 struct spdk_nvme_poll_group_stat *result; spdk_nvme_poll_group_get_stats() local [all...] |
| /spdk/test/unit/lib/util/string.c/ |
| H A D | string_ut.c | 464 char result[256]; in test_strcpy_replace() local 470 rc = spdk_strcpy_replace(result, sizeof(result), original, search1, replace1); in test_strcpy_replace() 472 CU_ASSERT(strcmp(result, original) == 0); in test_strcpy_replace() 474 rc = spdk_strcpy_replace(result, sizeof(result), original, search2, replace2); in test_strcpy_replace() 476 CU_ASSERT(strcmp(result, expected2) == 0); in test_strcpy_replace() 480 rc = spdk_strcpy_replace(result, strlen(expected3) + 1, original, search3, replace3); in test_strcpy_replace() 482 CU_ASSERT(strcmp(result, expected3) == 0); in test_strcpy_replace() 486 rc = spdk_strcpy_replace(result, strlen(expected3), original, search3, replace3); in test_strcpy_replace() 489 rc = spdk_strcpy_replace(result, sizeof(result), original, search4, replace4); in test_strcpy_replace() 491 CU_ASSERT(strcmp(result, expected4) == 0); in test_strcpy_replace() [all …]
|
| /spdk/lib/util/ |
| H A D | string.c | 476 char **result; in spdk_strarray_from_string() local 496 result = calloc(count + 1, sizeof(char *)); in spdk_strarray_from_string() 497 if (result == NULL) { in spdk_strarray_from_string() 507 result[i] = strdup(c); in spdk_strarray_from_string() 509 result[i] = strndup(c, next - c); in spdk_strarray_from_string() 512 if (result[i] == NULL) { in spdk_strarray_from_string() 513 spdk_strarray_free(result); in spdk_strarray_from_string() 522 return result; in spdk_strarray_from_string() 529 char **result; in spdk_strarray_dup() local 536 result = calloc(count + 1, sizeof(char *)); in spdk_strarray_dup() [all …]
|
| /spdk/python/spdk/sma/device/ |
| H A D | nvmf_tcp.py | 47 result = {} 50 result[rpc_param] = getattr(request, grpc_param) 51 return result 74 result = client.call('nvmf_create_subsystem', 105 result = client.call('nvmf_subsystem_add_ns', 128 result = client.call('nvmf_delete_subsystem', 130 if not result: 165 result = client.call('nvmf_subsystem_add_ns', 171 if not result: 204 result = client.call('nvmf_subsystem_remove_ns', [all …]
|
| H A D | nvmf_vfiouser.py | 264 result = self._subsystem_add_ns(client, bdev, subsys, nqn, volume_id) 265 if not result: 292 result = self._subsystem_remove_ns(client, bdev, subsys, nqn) 293 if not result:
|
| /spdk/lib/rocksdb/ |
| H A D | env_spdk.cc | 113 virtual Status Read(size_t n, Slice *result, char *scratch) override; 125 SpdkSequentialFile::Read(size_t n, Slice *result, char *scratch) in Read() argument 133 *result = Slice(scratch, ret); in Read() 162 virtual Status Read(uint64_t offset, size_t n, Slice *result, char *scratch) const override; 173 SpdkRandomAccessFile::Read(uint64_t offset, size_t n, Slice *result, char *scratch) const in Read() argument 180 *result = Slice(scratch, rc); in Read() 374 std::unique_ptr<SequentialFile> *result, in NewSequentialFile() argument 386 result->reset(new SpdkSequentialFile(file)); in NewSequentialFile() 397 return EnvWrapper::NewSequentialFile(fname, result, options); in NewSequentialFile() 402 std::unique_ptr<RandomAccessFile> *result, in NewRandomAccessFile() argument [all …]
|
| /spdk/module/sock/ |
| H A D | sock_kernel.h | |
| /spdk/test/rpc_client/ |
| H A D | rpc_client_test.c | 44 const struct spdk_json_val *result) in get_jsonrpc_method_json_parser() argument 46 return spdk_json_decode_array(result, spdk_json_decode_string, resp->method_names, in get_jsonrpc_method_json_parser() 88 assert(json_resp->result); in spdk_jsonrpc_client_check_rpc_method() 90 rc = get_jsonrpc_method_json_parser(&resp, json_resp->result); in spdk_jsonrpc_client_check_rpc_method() 156 assert(json_resp->result); in spdk_jsonrpc_client_check_null_params_method() 158 if (spdk_json_decode_bool(json_resp->result, &res) != 0 || res != true) { in spdk_jsonrpc_client_check_null_params_method() 281 assert(json_resp->result); in spdk_jsonrpc_client_hook_conn_close() 282 if (spdk_json_decode_bool(json_resp->result, &res) != 0 || res != true) { in spdk_jsonrpc_client_hook_conn_close()
|
| /spdk/lib/ftl/ |
| H A D | ftl_layout.c | 28 float result; in blocks2mib() local 30 result = blocks; in blocks2mib() 31 result *= FTL_BLOCK_SIZE; in blocks2mib() 32 result /= 1024UL; in blocks2mib() 33 result /= 1024UL; in blocks2mib() 35 return result; in blocks2mib() 61 uint64_t result; in ftl_md_region_blocks() local 63 result = spdk_divide_round_up(bytes, alignment); in ftl_md_region_blocks() 64 result *= alignment; in ftl_md_region_blocks() 65 result / in ftl_md_region_blocks() 74 uint64_t result; ftl_md_region_align_blocks() local [all...] |
| H A D | ftl_io.c | 121 size_t result __attribute__((unused)); in ftl_io_cb() local 159 result = spdk_ring_enqueue(ioch->cq, (void **)&io, 1, NULL); in ftl_io_cb() 160 assert(result != 0); in ftl_io_cb()
|
| /spdk/scripts/bpf/ |
| H A D | gen.py | 35 result = '' 44 result += line.replace('__EXE__', self._path).replace('__PID__', str(self._pid)) 45 return result
|
| /spdk/test/vhost/windows/ |
| H A D | windows_scsi_compliance.py | 120 result = results[suite_ver][test][disk] variable 123 if "PASS" in result: 128 … html += "<a href={file}>{result}</a>".format(result=result, file=os.path.join("./", disk, test))
|
| /spdk/python/spdk/sma/ |
| H A D | qmp.py | 192 Execute QMP cmd and read result. Returns resulting message, error or optionally 198 :return command exec response or optionally execute result event 209 response, result = self._receive(event) 212 raise QMPError('QMP Protocol Error, invalid result id') 215 if result is not None: 216 return result 256 result = cli.exec(request['execute'], request.get('arguments'), event) 257 print(json.dumps(result, indent=2))
|
| /spdk/test/iscsi_tgt/qos/ |
| H A D | qos.sh | 37 local result=$1 40 [ "$(bc <<< "$result > $limit*0.85")" -eq 1 ] \ 41 && [ "$(bc <<< "$result < $limit*1.05")" -eq 1 ]
|
| /spdk/examples/go/hello_gorpc/ |
| H A D | hello_gorpc.go | 39 result, err := json.Marshal(resp.Result) 44 fmt.Printf("%s\n", string(result))
|
| /spdk/module/bdev/ocf/ |
| H A D | vbdev_ocf.c | 927 int result; in finish_register() local 944 result = spdk_uuid_generate_sha1(&vbdev->exp_bdev.uuid, &ns_uuid, in finish_register() 946 if (result) { in finish_register() 948 vbdev_ocf_mngt_exit(vbdev, unregister_path_dirty, result); in finish_register() 955 result = spdk_bdev_register(&vbdev->exp_bdev); in finish_register() 956 if (result) { in finish_register() 959 vbdev_ocf_mngt_exit(vbdev, unregister_path_dirty, result); in finish_register() 965 vbdev_ocf_mngt_continue(vbdev, result); in finish_register() 1622 int result; member 1644 if (ctx->result) { in examine_ctx_put() [all...] |
| /spdk/include/spdk/ |
| H A D | jsonrpc.h | 46 struct spdk_json_val *result; member 80 const struct spdk_json_val *result);
|
| /spdk/test/unit/lib/ftl/ftl_band.c/ |
| H A D | ftl_band_ut.c | 356 ftl_addr addr, result, expect; in test_next_xfer_addr() local 365 result = ftl_band_next_xfer_addr(g_band, addr, 1); in test_next_xfer_addr() 366 CU_ASSERT_EQUAL(result, expect); in test_next_xfer_addr() 373 result = ftl_band_next_xfer_addr(g_band, addr, g_dev->xfer_size); in test_next_xfer_addr() 374 CU_ASSERT_EQUAL(result, expect); in test_next_xfer_addr() 382 result = ftl_band_next_xfer_addr(g_band, addr, g_dev->xfer_size + 2); in test_next_xfer_addr() 383 CU_ASSERT_EQUAL(result, expect); in test_next_xfer_addr()
|
| /spdk/scripts/ |
| H A D | sma-client.py | 69 result = client.call(request['method'], request.get('params', {})) 70 print(json.dumps(result, indent=2))
|
| /spdk/test/iscsi_tgt/calsoft/ |
| H A D | calsoft.py | 81 result = {"Calsoft iSCSI tests": case_result_list} 124 json.dump(obj=result, fp=f, indent=2)
|
| /spdk/test/lvol/ |
| H A D | external_copy.sh | 50 result=$(echo $status | jq -r '.state') 54 if [[ "$result" == "complete" ]]; then
|
| /spdk/module/bdev/virtio/ |
| H A D | bdev_virtio_rpc.c | 156 rpc_create_virtio_dev_cb(void *ctx, int result, struct spdk_bdev **bdevs, size_t cnt) in rpc_create_virtio_dev_cb() argument 162 if (result) { in rpc_create_virtio_dev_cb() 164 spdk_strerror(-result)); in rpc_create_virtio_dev_cb()
|
| /spdk/test/dma/test_dma/ |
| H A D | test_dma.c | 453 void *addr, size_t len, struct spdk_memory_domain_translation_result *result) 476 result->iov.iov_base = addr; in dma_test_run_time_poller() 477 result->iov.iov_len = len; in dma_test_run_time_poller() 478 result->iov_count = 1; in dma_test_run_time_poller() 479 result->rdma.lkey = req->mr->lkey; in dma_test_run_time_poller() 480 result->rdma.rkey = req->mr->rkey; in dma_test_run_time_poller() 481 result->dst_domain = dst_domain; 488 result->rdma.lkey = 0xffffffff; in dma_test_construct_task_done() 489 result->rdma.rkey = 0xffffffff; in dma_test_construct_task_done() 347 dma_test_translate_memory_cb(struct spdk_memory_domain * src_domain,void * src_domain_ctx,struct spdk_memory_domain * dst_domain,struct spdk_memory_domain_translation_ctx * dst_domain_ctx,void * addr,size_t len,struct spdk_memory_domain_translation_result * result) dma_test_translate_memory_cb() argument
|