lmtp: lmtp-client - Support command pipelining

diff --git a/src/lmtp/lmtp-client.c b/src/lmtp/lmtp-client.c
index ff26cb527c83c0e817aa2286167da84974d81e77..367feac614475e00605ec9f98b531ed0bf85d513 100644 (file)
--- a/src/lmtp/lmtp-client.c
+++ b/src/lmtp/lmtp-client.c
@@ -197,6 +197,7 @@ struct client *client_create(int fd_in, int fd_out,
        lmtp_set.rcpt_param_extensions = rcpt_param_extensions;
        lmtp_set.rcpt_domain_optional = TRUE;
        lmtp_set.max_client_idle_time_msecs = CLIENT_IDLE_TIMEOUT_MSECS;
+       lmtp_set.max_pipelined_commands = 5;
        lmtp_set.rawlog_dir = client->lmtp_set->lmtp_rawlog_dir;
        lmtp_set.event_parent = client->event;
 

diff --git a/src/lmtp/lmtp-commands.c b/src/lmtp/lmtp-commands.c
index da4eb19f1a44df07212f50296c6e1c17282aeff4..ecf9fc922442932cc1fd23f6f20e58ac8f6c12ca 100644 (file)
--- a/src/lmtp/lmtp-commands.c
+++ b/src/lmtp/lmtp-commands.c
@@ -28,6 +28,8 @@ int cmd_mail(void *conn_ctx,
 {
        struct client *client = (struct client *)conn_ctx;
 
+       smtp_server_command_pipeline_block(cmd);
+
        return client->v.cmd_mail(client, cmd, data);
 }