remote 457 cib/callbacks.c crm_remote_send(client_obj->remote, notify_src); remote 90 cib/notify.c if (client->ipcs == NULL && client->remote == NULL) { remote 128 cib/notify.c crm_remote_send(client->remote, update->msg); remote 270 cib/remote.c client->remote->auth_timeout = 0; remote 272 cib/remote.c if (client->remote->authenticated == TRUE) { remote 276 cib/remote.c mainloop_del_fd(client->remote->source); remote 324 cib/remote.c new_client->remote = calloc(1, sizeof(crm_remote_t)); remote 331 cib/remote.c new_client->remote->tls_session = remote 334 cib/remote.c if (new_client->remote->tls_session == NULL) { remote 342 cib/remote.c new_client->remote->tcp_socket = csock; remote 346 cib/remote.c new_client->remote->auth_timeout = remote 349 cib/remote.c new_client->remote->source = remote 373 cib/remote.c csock = client->remote->tcp_socket; remote 377 cib/remote.c if (client->remote->tls_session) { remote 378 cib/remote.c void *sock_ptr = gnutls_transport_get_ptr(*client->remote->tls_session); remote 381 cib/remote.c if (client->remote->tls_handshake_complete) { remote 382 cib/remote.c gnutls_bye(*client->remote->tls_session, GNUTLS_SHUT_WR); remote 384 cib/remote.c gnutls_deinit(*client->remote->tls_session); remote 385 cib/remote.c gnutls_free(client->remote->tls_session); remote 386 cib/remote.c client->remote->tls_session = NULL; remote 473 cib/remote.c int timeout = client->remote->authenticated ? -1 : 1000; remote 478 cib/remote.c if (client->kind == CRM_CLIENT_TLS && (client->remote->tls_handshake_complete == FALSE)) { remote 484 cib/remote.c rc = gnutls_handshake(*client->remote->tls_session); remote 494 cib/remote.c client->remote->tls_handshake_complete = TRUE; remote 495 cib/remote.c if (client->remote->auth_timeout) { remote 496 cib/remote.c g_source_remove(client->remote->auth_timeout); remote 499 cib/remote.c client->remote->auth_timeout = remote 506 cib/remote.c crm_remote_recv(client->remote, timeout, &disconnected); remote 509 cib/remote.c if (client->remote->authenticated == FALSE) { remote 515 cib/remote.c command = crm_remote_parse_buffer(client->remote); remote 522 cib/remote.c client->remote->authenticated = TRUE; remote 523 cib/remote.c g_source_remove(client->remote->auth_timeout); remote 524 cib/remote.c client->remote->auth_timeout = 0; remote 538 cib/remote.c crm_remote_send(client->remote, reg); remote 543 cib/remote.c command = crm_remote_parse_buffer(client->remote); remote 548 cib/remote.c command = crm_remote_parse_buffer(client->remote); remote 1182 crmd/remote_lrmd_ra.c const char *remote = ID(result); remote 1184 crmd/remote_lrmd_ra.c if (remote) { remote 1185 crmd/remote_lrmd_ra.c remote_node_down(remote, DOWN_ERASE_LRM); remote 96 include/crm/common/ipcs.h struct crm_remote_s *remote; /* TCP/TLS */ remote 198 include/crm_internal.h int crm_remote_send(crm_remote_t * remote, xmlNode * msg); remote 199 include/crm_internal.h int crm_remote_ready(crm_remote_t * remote, int total_timeout /*ms */ ); remote 200 include/crm_internal.h gboolean crm_remote_recv(crm_remote_t * remote, int total_timeout /*ms */ , int *disconnected); remote 201 include/crm_internal.h xmlNode *crm_remote_parse_buffer(crm_remote_t * remote); remote 217 include/crm_internal.h int crm_initiate_client_tls_handshake(crm_remote_t * remote, int timeout_ms); remote 192 lib/cluster/membership.c const char *remote = crm_element_value(result, data->field); remote 196 lib/cluster/membership.c CRM_CHECK(remote != NULL, return); remote 204 lib/cluster/membership.c node = g_hash_table_lookup(crm_remote_peer_cache, remote); remote 208 lib/cluster/membership.c node = crm_remote_peer_get(remote); remote 402 lib/common/ipc.c if (c->remote) { remote 403 lib/common/ipc.c if (c->remote->auth_timeout) { remote 404 lib/common/ipc.c g_source_remove(c->remote->auth_timeout); remote 406 lib/common/ipc.c free(c->remote->buffer); remote 407 lib/common/ipc.c free(c->remote); remote 110 lib/common/remote.c crm_remote_header(crm_remote_t * remote) remote 112 lib/common/remote.c struct crm_remote_header_v0 *header = (struct crm_remote_header_v0 *)remote->buffer; remote 113 lib/common/remote.c if(remote->buffer_offset < sizeof(struct crm_remote_header_v0)) { remote 143 lib/common/remote.c crm_initiate_client_tls_handshake(crm_remote_t * remote, int timeout_ms) remote 150 lib/common/remote.c rc = gnutls_handshake(*remote->tls_session); remote 152 lib/common/remote.c pollrc = crm_remote_ready(remote, 1000); remote 311 lib/common/remote.c crm_remote_sendv(crm_remote_t * remote, struct iovec * iov, int iovs) remote 319 lib/common/remote.c if (remote->tls_session) { remote 320 lib/common/remote.c rc = crm_send_tls(remote->tls_session, iov[lpc].iov_base, iov[lpc].iov_len); remote 321 lib/common/remote.c } else if (remote->tcp_socket) { remote 323 lib/common/remote.c if (remote->tcp_socket) { remote 325 lib/common/remote.c rc = crm_send_plaintext(remote->tcp_socket, iov[lpc].iov_base, iov[lpc].iov_len); remote 335 lib/common/remote.c crm_remote_send(crm_remote_t * remote, xmlNode * msg) remote 366 lib/common/remote.c rc = crm_remote_sendv(remote, iov, 2); remote 384 lib/common/remote.c crm_remote_parse_buffer(crm_remote_t * remote) remote 387 lib/common/remote.c struct crm_remote_header_v0 *header = crm_remote_header(remote); remote 389 lib/common/remote.c if (remote->buffer == NULL || header == NULL) { remote 403 lib/common/remote.c remote->buffer + header->payload_offset, remote 420 lib/common/remote.c memcpy(uncompressed, remote->buffer, header->payload_offset); /* Preserve the header */ remote 421 lib/common/remote.c remote->buffer_size = header->payload_offset + size_u; remote 423 lib/common/remote.c free(remote->buffer); remote 424 lib/common/remote.c remote->buffer = uncompressed; remote 425 lib/common/remote.c header = crm_remote_header(remote); remote 429 lib/common/remote.c remote->buffer_offset = 0; remote 431 lib/common/remote.c CRM_LOG_ASSERT(remote->buffer[sizeof(struct crm_remote_header_v0) + header->payload_uncompressed - 1] == 0); remote 433 lib/common/remote.c xml = string2xml(remote->buffer + header->payload_offset); remote 439 lib/common/remote.c crm_err("Couldn't parse: '%.120s'", remote->buffer + header->payload_offset); remote 455 lib/common/remote.c crm_remote_ready(crm_remote_t *remote, int total_timeout) remote 464 lib/common/remote.c if (remote->tls_session) { remote 465 lib/common/remote.c void *sock_ptr = gnutls_transport_get_ptr(*remote->tls_session); remote 468 lib/common/remote.c } else if (remote->tcp_socket) { remote 470 lib/common/remote.c if (remote->tcp_socket) { remote 472 lib/common/remote.c sock = remote->tcp_socket; remote 516 lib/common/remote.c crm_remote_recv_once(crm_remote_t * remote) remote 520 lib/common/remote.c struct crm_remote_header_v0 *header = crm_remote_header(remote); remote 528 lib/common/remote.c if(remote->buffer_size < read_len) { remote 529 lib/common/remote.c remote->buffer_size = 2 * read_len; remote 531 lib/common/remote.c (unsigned long long) remote->buffer_size); remote 533 lib/common/remote.c remote->buffer = realloc_safe(remote->buffer, remote->buffer_size + 1); remote 534 lib/common/remote.c CRM_ASSERT(remote->buffer != NULL); remote 538 lib/common/remote.c if (remote->tls_session) { remote 539 lib/common/remote.c rc = gnutls_record_recv(*(remote->tls_session), remote 540 lib/common/remote.c remote->buffer + remote->buffer_offset, remote 541 lib/common/remote.c remote->buffer_size - remote->buffer_offset); remote 550 lib/common/remote.c } else if (remote->tcp_socket) { remote 552 lib/common/remote.c if (remote->tcp_socket) { remote 555 lib/common/remote.c rc = read(remote->tcp_socket, remote 556 lib/common/remote.c remote->buffer + remote->buffer_offset, remote 557 lib/common/remote.c remote->buffer_size - remote->buffer_offset); remote 569 lib/common/remote.c remote->buffer_offset += rc; remote 571 lib/common/remote.c remote->buffer[remote->buffer_offset] = '\0'; remote 573 lib/common/remote.c rc, (unsigned long long) remote->buffer_offset); remote 580 lib/common/remote.c (unsigned long long) remote->buffer_offset); remote 585 lib/common/remote.c (unsigned long long) remote->buffer_offset, remote 590 lib/common/remote.c header = crm_remote_header(remote); remote 592 lib/common/remote.c if(remote->buffer_offset < header->size_total) { remote 594 lib/common/remote.c (unsigned long long) remote->buffer_offset, remote 598 lib/common/remote.c (unsigned long long) remote->buffer_offset); remote 599 lib/common/remote.c return remote->buffer_offset; remote 617 lib/common/remote.c crm_remote_recv(crm_remote_t *remote, int total_timeout, int *disconnected) remote 635 lib/common/remote.c rc = crm_remote_ready(remote, remaining_timeout); remote 647 lib/common/remote.c rc = crm_remote_recv_once(remote); remote 85 lib/lrmd/lrmd_client.c crm_remote_t *remote; remote 327 lib/lrmd/lrmd_client.c if (native->remote->tls_session) { remote 364 lib/lrmd/lrmd_client.c rc = crm_remote_ready(native->remote, 0); remote 367 lib/lrmd/lrmd_client.c xml = crm_remote_parse_buffer(native->remote); remote 371 lib/lrmd/lrmd_client.c crm_remote_recv(native->remote, -1, &disconnected); remote 372 lib/lrmd/lrmd_client.c xml = crm_remote_parse_buffer(native->remote); remote 389 lib/lrmd/lrmd_client.c xml = crm_remote_parse_buffer(native->remote); remote 417 lib/lrmd/lrmd_client.c return crm_remote_ready(native->remote, 0); remote 516 lib/lrmd/lrmd_client.c if (native->remote->tls_session) { remote 517 lib/lrmd/lrmd_client.c gnutls_bye(*native->remote->tls_session, GNUTLS_SHUT_RDWR); remote 518 lib/lrmd/lrmd_client.c gnutls_deinit(*native->remote->tls_session); remote 519 lib/lrmd/lrmd_client.c gnutls_free(native->remote->tls_session); remote 536 lib/lrmd/lrmd_client.c free(native->remote->buffer); remote 537 lib/lrmd/lrmd_client.c native->remote->buffer = NULL; remote 541 lib/lrmd/lrmd_client.c native->remote->tls_session = NULL; remote 579 lib/lrmd/lrmd_client.c xml = crm_remote_parse_buffer(native->remote); remote 593 lib/lrmd/lrmd_client.c crm_remote_recv(native->remote, remaining_timeout, disconnected); remote 594 lib/lrmd/lrmd_client.c xml = crm_remote_parse_buffer(native->remote); remote 638 lib/lrmd/lrmd_client.c if (native->remote->buffer && native->process_notify) { remote 656 lib/lrmd/lrmd_client.c rc = lrmd_tls_send_msg(native->remote, msg, global_remote_msg_id, "request"); remote 1159 lib/lrmd/lrmd_client.c native->remote->tls_session = create_psk_tls_session(sock, GNUTLS_CLIENT, native->psk_cred_c); remote 1161 lib/lrmd/lrmd_client.c if (crm_initiate_client_tls_handshake(native->remote, LRMD_CLIENT_HANDSHAKE_TIMEOUT) != 0) { remote 1164 lib/lrmd/lrmd_client.c gnutls_deinit(*native->remote->tls_session); remote 1165 lib/lrmd/lrmd_client.c gnutls_free(native->remote->tls_session); remote 1166 lib/lrmd/lrmd_client.c native->remote->tls_session = NULL; remote 1240 lib/lrmd/lrmd_client.c native->remote->tls_session = create_psk_tls_session(sock, GNUTLS_CLIENT, native->psk_cred_c); remote 1242 lib/lrmd/lrmd_client.c if (crm_initiate_client_tls_handshake(native->remote, LRMD_CLIENT_HANDSHAKE_TIMEOUT) != 0) { remote 1244 lib/lrmd/lrmd_client.c gnutls_deinit(*native->remote->tls_session); remote 1245 lib/lrmd/lrmd_client.c gnutls_free(native->remote->tls_session); remote 1246 lib/lrmd/lrmd_client.c native->remote->tls_session = NULL; remote 1358 lib/lrmd/lrmd_client.c if (native->remote->tls_session) { remote 1359 lib/lrmd/lrmd_client.c gnutls_bye(*native->remote->tls_session, GNUTLS_SHUT_RDWR); remote 1360 lib/lrmd/lrmd_client.c gnutls_deinit(*native->remote->tls_session); remote 1361 lib/lrmd/lrmd_client.c gnutls_free(native->remote->tls_session); remote 1362 lib/lrmd/lrmd_client.c native->remote->tls_session = 0; remote 1828 lib/lrmd/lrmd_client.c pvt->remote = calloc(1, sizeof(crm_remote_t)); remote 1897 lib/lrmd/lrmd_client.c free(native->remote); remote 623 lib/pengine/container.c if (common_unpack(xml_remote, &tuple->remote, parent, data_set) == FALSE) { remote 627 lib/pengine/container.c g_hash_table_iter_init(&gIter, tuple->remote->allowed_nodes); remote 635 lib/pengine/container.c tuple->node->details->remote_rsc = tuple->remote; remote 636 lib/pengine/container.c tuple->remote->container = tuple->docker; // Ensures is_container_remote_node() functions correctly immediately remote 653 lib/pengine/container.c parent->children = g_list_append(parent->children, tuple->remote); remote 683 lib/pengine/container.c if(tuple->remote) { remote 693 lib/pengine/container.c set_bit(tuple->remote->flags, pe_rsc_allow_remote_remotes); remote 730 lib/pengine/container.c tuple_for_remote(resource_t *remote) remote 732 lib/pengine/container.c resource_t *top = remote; remote 746 lib/pengine/container.c if(tuple->remote == remote) { remote 816 lib/pengine/container.c crm_trace("Cannot fix address for %s", tuple->remote->id); remote 1154 lib/pengine/container.c rsc_active = tuple_rsc_active(tuple->remote, all); remote 1263 lib/pengine/container.c print_rsc_in_list(tuple->remote, child_text, options, print_data); remote 1283 lib/pengine/container.c if(tuple->remote) { remote 1284 lib/pengine/container.c offset += snprintf(buffer + offset, LINE_MAX - offset, "%s", rsc_printable_id(tuple->remote)); remote 1344 lib/pengine/container.c print_rsc_in_list(tuple->remote, child_text, options, print_data); remote 1388 lib/pengine/container.c if(tuple->remote) { remote 1389 lib/pengine/container.c free_xml(tuple->remote->xml); remote 1390 lib/pengine/container.c tuple->remote->xml = NULL; remote 1391 lib/pengine/container.c tuple->remote->fns->free(tuple->remote); remote 1392 lib/pengine/container.c tuple->remote = NULL; remote 164 lib/pengine/remote.c xmlNode *remote; remote 167 lib/pengine/remote.c remote = create_xml_node(parent, XML_CIB_TAG_RESOURCE); remote 170 lib/pengine/remote.c crm_xml_add(remote, XML_ATTR_ID, uname); remote 171 lib/pengine/remote.c crm_xml_add(remote, XML_AGENT_ATTR_CLASS, PCMK_RESOURCE_CLASS_OCF); remote 172 lib/pengine/remote.c crm_xml_add(remote, XML_AGENT_ATTR_PROVIDER, "pacemaker"); remote 173 lib/pengine/remote.c crm_xml_add(remote, XML_ATTR_TYPE, "remote"); remote 176 lib/pengine/remote.c xml_sub = create_xml_node(remote, XML_TAG_META_SETS); remote 194 lib/pengine/remote.c xml_sub = create_xml_node(remote, XML_TAG_ATTR_SETS); remote 206 lib/pengine/remote.c xml_sub = create_xml_node(remote, "operations"); remote 215 lib/pengine/remote.c return remote; remote 68 lib/pengine/variant.h resource_t *remote; remote 232 lrmd/main.c return lrmd_tls_send_msg(client->remote, reply, id, "reply"); remote 254 lrmd/main.c if (client->remote == NULL) { remote 258 lrmd/main.c return lrmd_tls_send_msg(client->remote, msg, 0, "notify"); remote 61 lrmd/tls_backend.c if (client->remote->tls_handshake_complete == FALSE) { remote 67 lrmd/tls_backend.c rc = gnutls_handshake(*client->remote->tls_session); remote 77 lrmd/tls_backend.c client->remote->tls_handshake_complete = TRUE; remote 78 lrmd/tls_backend.c if (client->remote->auth_timeout) { remote 79 lrmd/tls_backend.c g_source_remove(client->remote->auth_timeout); remote 81 lrmd/tls_backend.c client->remote->auth_timeout = 0; remote 89 lrmd/tls_backend.c rc = crm_remote_ready(client->remote, 0); remote 98 lrmd/tls_backend.c crm_remote_recv(client->remote, -1, &disconnected); remote 100 lrmd/tls_backend.c request = crm_remote_parse_buffer(client->remote); remote 125 lrmd/tls_backend.c request = crm_remote_parse_buffer(client->remote); remote 156 lrmd/tls_backend.c if (client->remote->tls_session) { remote 160 lrmd/tls_backend.c sock_ptr = gnutls_transport_get_ptr(*client->remote->tls_session); remote 163 lrmd/tls_backend.c gnutls_bye(*client->remote->tls_session, GNUTLS_SHUT_RDWR); remote 164 lrmd/tls_backend.c gnutls_deinit(*client->remote->tls_session); remote 165 lrmd/tls_backend.c gnutls_free(client->remote->tls_session); remote 178 lrmd/tls_backend.c client->remote->auth_timeout = 0; remote 180 lrmd/tls_backend.c if (client->remote->tls_handshake_complete == TRUE) { remote 184 lrmd/tls_backend.c mainloop_del_fd(client->remote->source); remote 185 lrmd/tls_backend.c client->remote->source = NULL; remote 216 lrmd/tls_backend.c new_client->remote = calloc(1, sizeof(crm_remote_t)); remote 218 lrmd/tls_backend.c new_client->remote->tls_session = session; remote 219 lrmd/tls_backend.c new_client->remote->auth_timeout = remote 223 lrmd/tls_backend.c new_client->remote->source = remote 2123 pengine/allocate.c resource_t *remote = NULL; remote 2168 pengine/allocate.c remote = action->node->details->remote_rsc; remote 2169 pengine/allocate.c if (remote == NULL) { remote 2183 pengine/allocate.c if (remote->container) { remote 149 pengine/container.c if(tuple->remote && is_remote_node(docker_host)) { remote 155 pengine/container.c INFINITY, tuple->remote, docker_host->details->remote_rsc, NULL, NULL, data_set); remote 158 pengine/container.c if(tuple->remote) { remote 159 pengine/container.c tuple->remote->cmds->allocate(tuple->remote, prefer, data_set); remote 222 pengine/container.c if(tuple->remote) { remote 223 pengine/container.c tuple->remote->cmds->create_actions(tuple->remote, data_set); remote 299 pengine/container.c if(tuple->remote) { remote 305 pengine/container.c tuple->remote->cmds->internal_constraints(tuple->remote, data_set); remote 309 pengine/container.c CRM_ASSERT(tuple->remote); remote 834 pengine/container.c if (tuple->remote && tuple->docker && container_fix_remote_addr(tuple->remote)) { remote 836 pengine/container.c xmlNode *nvpair = get_xpath_object("//nvpair[@name='addr']", tuple->remote->xml, LOG_ERR); remote 837 pengine/container.c const char *calculated_addr = container_fix_remote_addr_in(tuple->remote, nvpair, "value"); remote 840 pengine/container.c crm_trace("Fixed addr for %s on %s", tuple->remote->id, calculated_addr); remote 841 pengine/container.c g_hash_table_replace(tuple->remote->parameters, strdup("addr"), strdup(calculated_addr)); remote 843 pengine/container.c crm_err("Could not fix addr for %s", tuple->remote->id); remote 852 pengine/container.c if(tuple->remote) { remote 853 pengine/container.c tuple->remote->cmds->expand(tuple->remote, data_set); remote 909 pengine/container.c if (tuple->docker && tuple->remote remote 910 pengine/container.c && tuple->remote->cmds->create_probe(tuple->remote, node, complete, remote 916 pengine/container.c char *probe_uuid = generate_op_key(tuple->remote->id, RSC_STATUS, 0); remote 917 pengine/container.c action_t *probe = find_first_action(tuple->remote->actions, probe_uuid, NULL, node); remote 923 pengine/container.c tuple->remote->id, node->details->uname); remote 926 pengine/container.c NULL, tuple->remote, NULL, probe, remote 964 pengine/container.c if(tuple->remote) { remote 965 pengine/container.c LogActions(tuple->remote, data_set, terminal); remote 2916 pengine/native.c resource_t *remote = node->details->remote_rsc->container; remote 2918 pengine/native.c if(remote->role == RSC_ROLE_STOPPED) { remote 2934 pengine/native.c if(remote->allocated_to remote 2935 pengine/native.c && g_hash_table_lookup(remote->known_on, remote->allocated_to->details->id) == NULL) { remote 2942 pengine/native.c custom_action_order(remote, generate_op_key(remote->id, RSC_STATUS, 0), NULL, remote 2947 pengine/native.c rsc->id, node->details->id, remote->id); remote 2955 pengine/native.c || is_set(remote->flags, pe_rsc_failed) remote 2956 pengine/native.c || remote->next_role == RSC_ROLE_STOPPED remote 2957 pengine/native.c || (remote->allocated_to remote 2958 pengine/native.c && pe_find_node(remote->running_on, remote->allocated_to->details->uname) == NULL) remote 2964 pengine/native.c custom_action_order(remote, generate_op_key(remote->id, RSC_STOP, 0), NULL, remote 2968 pengine/native.c rsc->id, node->details->id, remote->id);