Lines Matching full:local
179 * This is not transmitted, only local.
186 uint8_t *local_host_addr; /* local virtual address */
451 * current_addr as passed in is an address in the local ram_addr_t in register_to_network()
480 * comp->offset as passed in is an address in the local ram_addr_t in compress_to_network()
558 RDMALocalBlocks *local = &rdma->local_ram_blocks; in rdma_add_block() local
560 RDMALocalBlock *old = local->block; in rdma_add_block()
562 local->block = g_new0(RDMALocalBlock, local->nb_blocks + 1); in rdma_add_block()
564 if (local->nb_blocks) { in rdma_add_block()
566 for (int x = 0; x < local->nb_blocks; x++) { in rdma_add_block()
571 &local->block[x]); in rdma_add_block()
574 memcpy(local->block, old, sizeof(RDMALocalBlock) * local->nb_blocks); in rdma_add_block()
578 block = &local->block[local->nb_blocks]; in rdma_add_block()
584 block->index = local->nb_blocks; in rdma_add_block()
593 block->is_ram_block = local->init ? false : true; in rdma_add_block()
599 trace_rdma_add_block(block_name, local->nb_blocks, in rdma_add_block()
607 local->nb_blocks++; in rdma_add_block()
632 RDMALocalBlocks *local = &rdma->local_ram_blocks; in qemu_rdma_init_ram_blocks() local
636 memset(local, 0, sizeof *local); in qemu_rdma_init_ram_blocks()
639 trace_qemu_rdma_init_ram_blocks(local->nb_blocks); in qemu_rdma_init_ram_blocks()
642 local->init = true; in qemu_rdma_init_ram_blocks()
651 RDMALocalBlocks *local = &rdma->local_ram_blocks; in rdma_delete_block() local
652 RDMALocalBlock *old = local->block; in rdma_delete_block()
688 for (int x = 0; x < local->nb_blocks; x++) { in rdma_delete_block()
694 if (local->nb_blocks > 1) { in rdma_delete_block()
696 local->block = g_new0(RDMALocalBlock, local->nb_blocks - 1); in rdma_delete_block()
699 memcpy(local->block, old, sizeof(RDMALocalBlock) * block->index); in rdma_delete_block()
702 if (block->index < (local->nb_blocks - 1)) { in rdma_delete_block()
703 memcpy(local->block + block->index, old + (block->index + 1), in rdma_delete_block()
705 (local->nb_blocks - (block->index + 1))); in rdma_delete_block()
706 for (int x = block->index; x < local->nb_blocks - 1; x++) { in rdma_delete_block()
707 local->block[x].index--; in rdma_delete_block()
711 assert(block == local->block); in rdma_delete_block()
712 local->block = NULL; in rdma_delete_block()
723 local->nb_blocks--; in rdma_delete_block()
725 if (local->nb_blocks && rdma->blockmap) { in rdma_delete_block()
726 for (int x = 0; x < local->nb_blocks; x++) { in rdma_delete_block()
728 (void *)(uintptr_t)local->block[x].offset, in rdma_delete_block()
729 &local->block[x]); in rdma_delete_block()
1013 RDMALocalBlocks *local = &rdma->local_ram_blocks; in qemu_rdma_reg_whole_ram_blocks() local
1015 for (i = 0; i < local->nb_blocks; i++) { in qemu_rdma_reg_whole_ram_blocks()
1018 local->block[i].mr = in qemu_rdma_reg_whole_ram_blocks()
1020 local->block[i].local_host_addr, in qemu_rdma_reg_whole_ram_blocks()
1021 local->block[i].length, access in qemu_rdma_reg_whole_ram_blocks()
1029 if (!local->block[i].mr && in qemu_rdma_reg_whole_ram_blocks()
1033 local->block[i].mr = in qemu_rdma_reg_whole_ram_blocks()
1035 local->block[i].local_host_addr, in qemu_rdma_reg_whole_ram_blocks()
1036 local->block[i].length, access); in qemu_rdma_reg_whole_ram_blocks()
1037 trace_qemu_rdma_register_odp_mr(local->block[i].block_name); in qemu_rdma_reg_whole_ram_blocks()
1039 if (local->block[i].mr) { in qemu_rdma_reg_whole_ram_blocks()
1041 (uintptr_t)local->block[i].local_host_addr, in qemu_rdma_reg_whole_ram_blocks()
1042 local->block[i].length, in qemu_rdma_reg_whole_ram_blocks()
1043 local->block[i].mr->lkey, in qemu_rdma_reg_whole_ram_blocks()
1044 local->block[i].block_name, in qemu_rdma_reg_whole_ram_blocks()
1049 if (!local->block[i].mr) { in qemu_rdma_reg_whole_ram_blocks()
1051 "Failed to register local dest ram block!"); in qemu_rdma_reg_whole_ram_blocks()
1061 ibv_dereg_mr(local->block[i].mr); in qemu_rdma_reg_whole_ram_blocks()
1062 local->block[i].mr = NULL; in qemu_rdma_reg_whole_ram_blocks()
3351 RDMALocalBlocks *local; in rdma_registration_handle() local
3378 local = &rdma->local_ram_blocks; in rdma_registration_handle()
3428 /* Sort our local RAM Block list so it's the same as the source, in rdma_registration_handle()
3435 for (int i = 0; i < local->nb_blocks; i++) { in rdma_registration_handle()
3436 local->block[i].index = i; in rdma_registration_handle()
3451 * their "local" descriptions with what was sent. in rdma_registration_handle()
3453 for (int i = 0; i < local->nb_blocks; i++) { in rdma_registration_handle()
3455 (uintptr_t)(local->block[i].local_host_addr); in rdma_registration_handle()
3458 rdma->dest_blocks[i].remote_rkey = local->block[i].mr->rkey; in rdma_registration_handle()
3461 rdma->dest_blocks[i].offset = local->block[i].offset; in rdma_registration_handle()
3462 rdma->dest_blocks[i].length = local->block[i].length; in rdma_registration_handle()
3466 local->block[i].block_name, in rdma_registration_handle()
3467 local->block[i].offset, in rdma_registration_handle()
3468 local->block[i].length, in rdma_registration_handle()
3469 local->block[i].local_host_addr, in rdma_registration_handle()
3470 local->block[i].src_index); in rdma_registration_handle()
3615 * the source. We've already built our local RAMBlock list, but not
3635 /* Find the matching RAMBlock in our local list */ in rdma_block_notification_handle()
3713 RDMALocalBlocks *local = &rdma->local_ram_blocks; in rdma_registration_stop() local
3747 * and then propagates the remote ram block descriptions to his local copy. in rdma_registration_stop()
3750 if (local->nb_blocks != nb_dest_blocks) { in rdma_registration_stop()
3752 local->nb_blocks, nb_dest_blocks); in rdma_registration_stop()
3766 if (rdma->dest_blocks[i].length != local->block[i].length) { in rdma_registration_stop()
3769 local->block[i].block_name, i, in rdma_registration_stop()
3770 local->block[i].length, in rdma_registration_stop()
3775 local->block[i].remote_host_addr = in rdma_registration_stop()
3777 local->block[i].remote_rkey = rdma->dest_blocks[i].remote_rkey; in rdma_registration_stop()