Skip to content

Commit

Permalink
Refactor: libcrmcommon: Simplify pcmk__read_available_remote_data.
Browse files Browse the repository at this point in the history
Get rid of the received variable and just make this a couple if blocks.
It's a little easier to follow this way.
  • Loading branch information
clumens committed Oct 18, 2024
1 parent 7f0d325 commit e78786d
Showing 1 changed file with 3 additions and 10 deletions.
13 changes: 3 additions & 10 deletions lib/common/remote.c
Original file line number Diff line number Diff line change
Expand Up @@ -663,7 +663,6 @@ pcmk__read_available_remote_data(pcmk__remote_t *remote)
int rc = pcmk_rc_ok;
size_t read_len = sizeof(struct remote_header_v0);
struct remote_header_v0 *header = localized_remote_header(remote);
bool received = false;
ssize_t read_rc;

if(header) {
Expand All @@ -679,7 +678,7 @@ pcmk__read_available_remote_data(pcmk__remote_t *remote)
remote->buffer = pcmk__realloc(remote->buffer, remote->buffer_size + 1);
}

if (!received && remote->tls_session) {
if (remote->tls_session) {
read_rc = gnutls_record_recv(*(remote->tls_session),
remote->buffer + remote->buffer_offset,
remote->buffer_size - remote->buffer_offset);
Expand All @@ -692,20 +691,14 @@ pcmk__read_available_remote_data(pcmk__remote_t *remote)
gnutls_strerror(read_rc), (long long) read_rc);
rc = EIO;
}
received = true;
}

if (!received && remote->tcp_socket) {
} else if (remote->tcp_socket) {
read_rc = read(remote->tcp_socket,
remote->buffer + remote->buffer_offset,
remote->buffer_size - remote->buffer_offset);
if (read_rc < 0) {
rc = errno;
}
received = true;
}

if (!received) {
} else {
crm_err("Remote connection type undetermined (bug?)");
return ESOCKTNOSUPPORT;
}
Expand Down

0 comments on commit e78786d

Please sign in to comment.