Skip to content

Commit b2091cd

Browse files
author
Ivan Lazarev
committed
[PBCKP-236] [skip] removed unnecessary TODOs
1 parent f61be78 commit b2091cd

File tree

2 files changed

+8
-10
lines changed

2 files changed

+8
-10
lines changed

src/utils/file.c

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -268,7 +268,6 @@ fio_write_all(int fd, void const* buf, size_t size)
268268
return offs;
269269
}
270270

271-
//TODO REVIEW XXX move to remote.c????
272271
/* Get version of remote agent */
273272
void
274273
fio_get_agent_version(int* protocol, char* payload_buf, size_t payload_buf_size)
@@ -3217,7 +3216,6 @@ fio_delete_impl(mode_t mode, char *buf)
32173216
}
32183217

32193218
/* Execute commands at remote host */
3220-
//TODO REVIEW XXX move to remote.c?
32213219
void
32223220
fio_communicate(int in, int out)
32233221
{

src/utils/remote.c

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -117,9 +117,6 @@ bool launch_agent(void)
117117
int infd[2];
118118
int errfd[2];
119119
int agent_version;
120-
//TODO REVIEW XXX review buf_size
121-
int payload_buf_size = 1024 * 8;
122-
char payload_buf[payload_buf_size];
123120

124121
ssh_argc = 0;
125122
#ifdef WIN32
@@ -241,10 +238,13 @@ bool launch_agent(void)
241238
fio_redirect(infd[0], outfd[1], errfd[0]); /* write to stdout */
242239
}
243240

244-
/* Make sure that remote agent has the same version, fork and other features to be binary compatible
245-
*/
246-
fio_get_agent_version(&agent_version, payload_buf, payload_buf_size);
247-
check_remote_agent_compatibility(agent_version, payload_buf, payload_buf_size);
241+
242+
/* Make sure that remote agent has the same version, fork and other features to be binary compatible */
243+
{
244+
char payload_buf[1024];
245+
fio_get_agent_version(&agent_version, payload_buf, sizeof payload_buf);
246+
check_remote_agent_compatibility(agent_version, payload_buf, sizeof payload_buf);
247+
}
248248

249249
return true;
250250
}
@@ -268,7 +268,7 @@ size_t prepare_compatibility_str(char* compatibility_buf, size_t compatibility_b
268268
char* compatibility_params[] = {
269269
COMPATIBILITY_VAL_STR(PG_MAJORVERSION),
270270
#ifdef PGPRO_EDN
271-
//TODO REVIEW can use edition.h/extract_pgpro_edition()
271+
//TODO REVIEW can use edition.h/extract_pgpro_edition() or similar
272272
COMPATIBILITY_VAL_STR(PGPRO_EDN),
273273
#endif
274274
//TODO REVIEW remove? no difference between 32/64 in global/pg_control.

0 commit comments

Comments
 (0)