github/linuxkit
1
0
Fork 0
mirror of https://github.com/linuxkit/linuxkit.git synced 2025-07-23 11:00:25 +00:00
Code Issues Projects Releases Wiki Activity

transfused: replace brittle init control message writing with write_exactly

Browse Source 
Signed-off-by: David Sheets <dsheets@docker.com>
This commit is contained in:
David Sheets 2016-12-14 14:41:00 +00:00
parent 6cf50dd803
commit b9ff275a88
1 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
alpine/packages/transfused/transfused.c
View File

@ -927,19 +927,14 @@ void *determine_mount_suitability(parameters *params, int allow_empty,
void *init_thread(void *params_ptr) void *init_thread(void *params_ptr)
{ {
parameters *params = params_ptr; parameters *params = params_ptr;
int write_count, read_count, len; int read_count, len;
char init_msg[6] = {'\6', '\0', '\0', '\0', '\0', '\0'}; char init_msg[6] = {'\6', '\0', '\0', '\0', '\0', '\0'};
void *buf, *response; void *buf, *response;
uint16_t msg_type; uint16_t msg_type;
params->ctl_sock = connect_socket(params->server); params->ctl_sock = connect_socket(params->server);
/* TODO: handle short write/socket conditions */ write_exactly("init", params->ctl_sock, init_msg, sizeof(init_msg));
write_count = write(params->ctl_sock, init_msg, sizeof(init_msg));
if (write_count < 0)
die(1, NULL, "init thread: couldn't write init", "");
if (write_count != sizeof(init_msg))
die(1, NULL, "init thread: incomplete write", "");
buf = must_malloc("incoming control message buffer", CTL_BUFSZ); buf = must_malloc("incoming control message buffer", CTL_BUFSZ);