* Command registry
*/
-void smtp_server_command_register(struct smtp_server *server,
- const char *name, smtp_server_cmd_start_func_t *func,
- enum smtp_server_command_flags flags)
+void smtp_server_command_register(struct smtp_server *server, const char *name,
+ smtp_server_cmd_start_func_t *func,
+ enum smtp_server_command_flags flags)
{
struct smtp_server_command_reg cmd;
switch (server->set.protocol) {
case SMTP_PROTOCOL_SMTP:
- smtp_server_command_register(server,
- "EHLO", smtp_server_cmd_ehlo,
+ smtp_server_command_register(
+ server, "EHLO", smtp_server_cmd_ehlo,
SMTP_SERVER_CMD_FLAG_PRETLS |
SMTP_SERVER_CMD_FLAG_PREAUTH);
- smtp_server_command_register(server,
- "HELO", smtp_server_cmd_helo,
+ smtp_server_command_register(
+ server, "HELO", smtp_server_cmd_helo,
SMTP_SERVER_CMD_FLAG_PREAUTH);
break;
case SMTP_PROTOCOL_LMTP:
- smtp_server_command_register(server,
- "LHLO", smtp_server_cmd_ehlo,
+ smtp_server_command_register(
+ server, "LHLO", smtp_server_cmd_ehlo,
SMTP_SERVER_CMD_FLAG_PRETLS |
SMTP_SERVER_CMD_FLAG_PREAUTH);
break;
}
- smtp_server_command_register(server,
- "AUTH", smtp_server_cmd_auth,
+ smtp_server_command_register(
+ server, "AUTH", smtp_server_cmd_auth,
SMTP_SERVER_CMD_FLAG_PREAUTH);
- smtp_server_command_register(server,
- "STARTTLS", smtp_server_cmd_starttls,
+ smtp_server_command_register(
+ server, "STARTTLS", smtp_server_cmd_starttls,
SMTP_SERVER_CMD_FLAG_PRETLS | SMTP_SERVER_CMD_FLAG_PREAUTH);
- smtp_server_command_register(server,
- "MAIL", smtp_server_cmd_mail, 0);
- smtp_server_command_register(server,
- "RCPT", smtp_server_cmd_rcpt, 0);
- smtp_server_command_register(server,
- "DATA", smtp_server_cmd_data, 0);
- smtp_server_command_register(server,
- "BDAT", smtp_server_cmd_bdat, 0);
- smtp_server_command_register(server,
- "RSET", smtp_server_cmd_rset,
+ smtp_server_command_register(
+ server, "MAIL", smtp_server_cmd_mail, 0);
+ smtp_server_command_register(server, "RCPT", smtp_server_cmd_rcpt, 0);
+ smtp_server_command_register(server, "DATA", smtp_server_cmd_data, 0);
+ smtp_server_command_register(server, "BDAT", smtp_server_cmd_bdat, 0);
+ smtp_server_command_register(
+ server, "RSET", smtp_server_cmd_rset,
SMTP_SERVER_CMD_FLAG_PREAUTH);
- smtp_server_command_register(server,
- "VRFY", smtp_server_cmd_vrfy, 0);
- smtp_server_command_register(server,
- "NOOP", smtp_server_cmd_noop,
+ smtp_server_command_register(server, "VRFY", smtp_server_cmd_vrfy, 0);
+ smtp_server_command_register(
+ server, "NOOP", smtp_server_cmd_noop,
SMTP_SERVER_CMD_FLAG_PRETLS | SMTP_SERVER_CMD_FLAG_PREAUTH);
- smtp_server_command_register(server,
- "QUIT", smtp_server_cmd_quit,
+ smtp_server_command_register(
+ server, "QUIT", smtp_server_cmd_quit,
SMTP_SERVER_CMD_FLAG_PRETLS | SMTP_SERVER_CMD_FLAG_PREAUTH);
- smtp_server_command_register(server,
- "XCLIENT", smtp_server_cmd_xclient,
+ smtp_server_command_register(
+ server, "XCLIENT", smtp_server_cmd_xclient,
SMTP_SERVER_CMD_FLAG_PREAUTH);
}
*
*/
-static void
-smtp_server_command_update_event(struct smtp_server_command *cmd)
+static void smtp_server_command_update_event(struct smtp_server_command *cmd)
{
struct event *event = cmd->context.event;
const char *label = (cmd->context.name == NULL ?
conn->command_queue_count--;
}
- /* execute hooks */
+ /* Execute hooks */
if (!smtp_server_command_call_hooks(
&cmd, SMTP_SERVER_COMMAND_HOOK_DESTROY, TRUE))
i_unreached();
struct smtp_server_command *cmd = *_cmd;
struct smtp_server_connection *conn = cmd->context.conn;
- /* preemptively remove command from queue (references may still exist)
+ /* Preemptively remove command from queue (references may still exist)
*/
if (cmd->state >= SMTP_SERVER_COMMAND_STATE_FINISHED) {
e_debug(cmd->context.event, "Abort");
hook = cmd->hooks_head;
while (hook != NULL) {
- /* no double registrations */
+ /* No double registrations */
i_assert(hook->type != type || hook->func != func);
hook = hook->next;
if (!smtp_server_command_replied(&cmd))
return smtp_server_connection_unref(&conn);
- /* submit reply */
+ /* Submit reply */
switch (cmd->state) {
case SMTP_SERVER_COMMAND_STATE_NEW:
case SMTP_SERVER_COMMAND_STATE_PROCESSING:
smtp_server_command_remove_hooks(cmd, SMTP_SERVER_COMMAND_HOOK_NEXT);
- /* limit number of consecutive bad commands */
+ /* Limit number of consecutive bad commands */
if (is_bad)
conn->bad_counter++;
else if (cmd->replies_submitted == cmd->replies_expected)
struct smtp_server_reply *
smtp_server_command_get_reply(struct smtp_server_command *cmd,
- unsigned int idx)
+ unsigned int idx)
{
struct smtp_server_reply *reply;
}
bool smtp_server_command_reply_status_equals(struct smtp_server_command *cmd,
- unsigned int status)
+ unsigned int status)
{
struct smtp_server_reply *reply;
array_idx(&cmd->replies, i);
sent = reply->sent;
}
-
- /* send the same reply for all */
+
+ /* Send the same reply for all */
if (!sent) {
va_list args_copy;
VA_COPY(args_copy, args);
smtp_server_connection_input_resume(conn);
}
-void smtp_server_command_input_capture(struct smtp_server_cmd_ctx *cmd,
+void smtp_server_command_input_capture(
+ struct smtp_server_cmd_ctx *cmd,
smtp_server_cmd_input_callback_t *callback)
{
struct smtp_server_command *command = cmd->cmd;