replication: ignore o_stream_send errors in doveadm-connection

diff --git a/src/replication/replicator/doveadm-connection.c b/src/replication/replicator/doveadm-connection.c
index c28453b2beefd9aed149eb5094266d43fb5ebf3a..66cf1b8bf138cf62f65b1e70538cefe7b6955b31 100644 (file)
--- a/src/replication/replicator/doveadm-connection.c
+++ b/src/replication/replicator/doveadm-connection.c
@@ -72,7 +72,7 @@ static int client_input_status_overview(struct doveadm_connection *client)
                    waiting_failed_count);
        str_printfa(str, "Total number of known users\t%u\n", user_count);
        str_append_c(str, '\n');
-       o_stream_send(client->conn.output, str_data(str), str_len(str));
+       o_stream_nsend(client->conn.output, str_data(str), str_len(str));
        return 0;
 }
 
@@ -103,10 +103,10 @@ client_input_status(struct doveadm_connection *client, const char *const *args)
                            (long long)user->last_full_sync,
                            user->last_sync_failed ? 1 : 0,
                            (long long)user->last_successful_sync);
-               o_stream_send(client->conn.output, str_data(str), str_len(str));
+               o_stream_nsend(client->conn.output, str_data(str), str_len(str));
        }
        replicator_queue_iter_deinit(&iter);
-       o_stream_send(client->conn.output, "\n", 1);
+       o_stream_nsend(client->conn.output, "\n", 1);
        return 0;
 }
 
@@ -144,7 +144,7 @@ client_input_status_dsyncs(struct doveadm_connection *client)
        }
 
        str_append_c(str, '\n');
-       o_stream_send(client->conn.output, str_data(str), str_len(str));
+       o_stream_nsend(client->conn.output, str_data(str), str_len(str));
        return 0;
 }
 
@@ -166,7 +166,7 @@ client_input_replicate(struct doveadm_connection *client, const char *const *arg
                return -1;
        }
        if (replication_priority_parse(args[0], &priority) < 0) {
-               o_stream_send_str(client->conn.output, "-Invalid priority\n");
+               o_stream_nsend_str(client->conn.output, "-Invalid priority\n");
                return 0;
        }
        full = strchr(args[1], 'f') != NULL;
@@ -175,7 +175,7 @@ client_input_replicate(struct doveadm_connection *client, const char *const *arg
                user = replicator_queue_add(queue, usermask, priority);
                if (full)
                        user->force_full_sync = TRUE;
-               o_stream_send_str(client->conn.output, "+1\n");
+               o_stream_nsend_str(client->conn.output, "+1\n");
                return 0;
        }
 
@@ -190,7 +190,7 @@ client_input_replicate(struct doveadm_connection *client, const char *const *arg
                match_count++;
        }
        replicator_queue_iter_deinit(&iter);
-       o_stream_send_str(client->conn.output,
+       o_stream_nsend_str(client->conn.output,
                          t_strdup_printf("+%u\n", match_count));
        return 0;
 }
@@ -216,7 +216,7 @@ client_input_add(struct doveadm_connection *client, const char *const *args)
                replicator_queue_add_auth_users(queue, set->auth_socket_path,
                                                args[0], ioloop_time);
        }
-       o_stream_send_str(client->conn.output, "+\n");
+       o_stream_nsend_str(client->conn.output, "+\n");
        return 0;
 }
 
@@ -234,10 +234,10 @@ client_input_remove(struct doveadm_connection *client, const char *const *args)
        }
        user = replicator_queue_lookup(queue, args[0]);
        if (user == NULL)
-               o_stream_send_str(client->conn.output, "-User not found\n");
+               o_stream_nsend_str(client->conn.output, "-User not found\n");
        else {
                replicator_queue_remove(queue, &user);
-               o_stream_send_str(client->conn.output, "+\n");
+               o_stream_nsend_str(client->conn.output, "+\n");
        }
        return 0;
 }
@@ -265,7 +265,7 @@ client_input_notify(struct doveadm_connection *client, const char *const *args)
                i_free(user->state);
                user->state = i_strdup(args[2]);
        }
-       o_stream_send_str(client->conn.output, "+\n");
+       o_stream_nsend_str(client->conn.output, "+\n");
        return 0;
 }