microhttpd-util: add the trailing newline automatically
It's prone to error and annoying to have to add it manually. It was missing from a few places.
This commit is contained in:
parent
1b4cd64683
commit
f5e757f1ce
|
@ -475,20 +475,20 @@ static int request_handler_entries(
|
|||
|
||||
r = open_journal(m);
|
||||
if (r < 0)
|
||||
return mhd_respondf(connection, r, MHD_HTTP_INTERNAL_SERVER_ERROR, "Failed to open journal: %m\n");
|
||||
return mhd_respondf(connection, r, MHD_HTTP_INTERNAL_SERVER_ERROR, "Failed to open journal: %m");
|
||||
|
||||
if (request_parse_accept(m, connection) < 0)
|
||||
return mhd_respond(connection, MHD_HTTP_BAD_REQUEST, "Failed to parse Accept header.\n");
|
||||
return mhd_respond(connection, MHD_HTTP_BAD_REQUEST, "Failed to parse Accept header.");
|
||||
|
||||
if (request_parse_range(m, connection) < 0)
|
||||
return mhd_respond(connection, MHD_HTTP_BAD_REQUEST, "Failed to parse Range header.\n");
|
||||
return mhd_respond(connection, MHD_HTTP_BAD_REQUEST, "Failed to parse Range header.");
|
||||
|
||||
if (request_parse_arguments(m, connection) < 0)
|
||||
return mhd_respond(connection, MHD_HTTP_BAD_REQUEST, "Failed to parse URL arguments.\n");
|
||||
return mhd_respond(connection, MHD_HTTP_BAD_REQUEST, "Failed to parse URL arguments.");
|
||||
|
||||
if (m->discrete) {
|
||||
if (!m->cursor)
|
||||
return mhd_respond(connection, MHD_HTTP_BAD_REQUEST, "Discrete seeks require a cursor specification.\n");
|
||||
return mhd_respond(connection, MHD_HTTP_BAD_REQUEST, "Discrete seeks require a cursor specification.");
|
||||
|
||||
m->n_entries = 1;
|
||||
m->n_entries_set = true;
|
||||
|
@ -501,7 +501,7 @@ static int request_handler_entries(
|
|||
else if (m->n_skip < 0)
|
||||
r = sd_journal_seek_tail(m->journal);
|
||||
if (r < 0)
|
||||
return mhd_respond(connection, MHD_HTTP_BAD_REQUEST, "Failed to seek in journal.\n");
|
||||
return mhd_respond(connection, MHD_HTTP_BAD_REQUEST, "Failed to seek in journal.");
|
||||
|
||||
response = MHD_create_response_from_callback(MHD_SIZE_UNKNOWN, 4*1024, request_reader_entries, m, NULL);
|
||||
if (!response)
|
||||
|
@ -633,14 +633,14 @@ static int request_handler_fields(
|
|||
|
||||
r = open_journal(m);
|
||||
if (r < 0)
|
||||
return mhd_respondf(connection, r, MHD_HTTP_INTERNAL_SERVER_ERROR, "Failed to open journal: %m\n");
|
||||
return mhd_respondf(connection, r, MHD_HTTP_INTERNAL_SERVER_ERROR, "Failed to open journal: %m");
|
||||
|
||||
if (request_parse_accept(m, connection) < 0)
|
||||
return mhd_respond(connection, MHD_HTTP_BAD_REQUEST, "Failed to parse Accept header.\n");
|
||||
return mhd_respond(connection, MHD_HTTP_BAD_REQUEST, "Failed to parse Accept header.");
|
||||
|
||||
r = sd_journal_query_unique(m->journal, field);
|
||||
if (r < 0)
|
||||
return mhd_respond(connection, MHD_HTTP_BAD_REQUEST, "Failed to query unique fields.\n");
|
||||
return mhd_respond(connection, MHD_HTTP_BAD_REQUEST, "Failed to query unique fields.");
|
||||
|
||||
response = MHD_create_response_from_callback(MHD_SIZE_UNKNOWN, 4*1024, request_reader_fields, m, NULL);
|
||||
if (!response)
|
||||
|
@ -699,10 +699,10 @@ static int request_handler_file(
|
|||
|
||||
fd = open(path, O_RDONLY|O_CLOEXEC);
|
||||
if (fd < 0)
|
||||
return mhd_respondf(connection, errno, MHD_HTTP_NOT_FOUND, "Failed to open file %s: %m\n", path);
|
||||
return mhd_respondf(connection, errno, MHD_HTTP_NOT_FOUND, "Failed to open file %s: %m", path);
|
||||
|
||||
if (fstat(fd, &st) < 0)
|
||||
return mhd_respondf(connection, errno, MHD_HTTP_INTERNAL_SERVER_ERROR, "Failed to stat file: %m\n");
|
||||
return mhd_respondf(connection, errno, MHD_HTTP_INTERNAL_SERVER_ERROR, "Failed to stat file: %m");
|
||||
|
||||
response = MHD_create_response_from_fd_at_offset64(st.st_size, fd, 0);
|
||||
if (!response)
|
||||
|
@ -766,15 +766,15 @@ static int request_handler_machine(
|
|||
|
||||
r = open_journal(m);
|
||||
if (r < 0)
|
||||
return mhd_respondf(connection, r, MHD_HTTP_INTERNAL_SERVER_ERROR, "Failed to open journal: %m\n");
|
||||
return mhd_respondf(connection, r, MHD_HTTP_INTERNAL_SERVER_ERROR, "Failed to open journal: %m");
|
||||
|
||||
r = sd_id128_get_machine(&mid);
|
||||
if (r < 0)
|
||||
return mhd_respondf(connection, r, MHD_HTTP_INTERNAL_SERVER_ERROR, "Failed to determine machine ID: %m\n");
|
||||
return mhd_respondf(connection, r, MHD_HTTP_INTERNAL_SERVER_ERROR, "Failed to determine machine ID: %m");
|
||||
|
||||
r = sd_id128_get_boot(&bid);
|
||||
if (r < 0)
|
||||
return mhd_respondf(connection, r, MHD_HTTP_INTERNAL_SERVER_ERROR, "Failed to determine boot ID: %m\n");
|
||||
return mhd_respondf(connection, r, MHD_HTTP_INTERNAL_SERVER_ERROR, "Failed to determine boot ID: %m");
|
||||
|
||||
hostname = gethostname_malloc();
|
||||
if (!hostname)
|
||||
|
@ -782,11 +782,11 @@ static int request_handler_machine(
|
|||
|
||||
r = sd_journal_get_usage(m->journal, &usage);
|
||||
if (r < 0)
|
||||
return mhd_respondf(connection, r, MHD_HTTP_INTERNAL_SERVER_ERROR, "Failed to determine disk usage: %s\n");
|
||||
return mhd_respondf(connection, r, MHD_HTTP_INTERNAL_SERVER_ERROR, "Failed to determine disk usage: %s");
|
||||
|
||||
r = sd_journal_get_cutoff_realtime_usec(m->journal, &cutoff_from, &cutoff_to);
|
||||
if (r < 0)
|
||||
return mhd_respondf(connection, r, MHD_HTTP_INTERNAL_SERVER_ERROR, "Failed to determine disk usage: %s\n");
|
||||
return mhd_respondf(connection, r, MHD_HTTP_INTERNAL_SERVER_ERROR, "Failed to determine disk usage: %s");
|
||||
|
||||
if (parse_env_file("/etc/os-release", NEWLINE, "PRETTY_NAME", &os_name, NULL) == -ENOENT)
|
||||
(void) parse_env_file("/usr/lib/os-release", NEWLINE, "PRETTY_NAME", &os_name, NULL);
|
||||
|
@ -844,8 +844,7 @@ static int request_handler(
|
|||
assert(method);
|
||||
|
||||
if (!streq(method, "GET"))
|
||||
return mhd_respond(connection, MHD_HTTP_NOT_ACCEPTABLE,
|
||||
"Unsupported method.\n");
|
||||
return mhd_respond(connection, MHD_HTTP_NOT_ACCEPTABLE, "Unsupported method.");
|
||||
|
||||
|
||||
if (!*connection_cls) {
|
||||
|
@ -875,7 +874,7 @@ static int request_handler(
|
|||
if (streq(url, "/machine"))
|
||||
return request_handler_machine(connection, *connection_cls);
|
||||
|
||||
return mhd_respond(connection, MHD_HTTP_NOT_FOUND, "Not found.\n");
|
||||
return mhd_respond(connection, MHD_HTTP_NOT_FOUND, "Not found.");
|
||||
}
|
||||
|
||||
static void help(void) {
|
||||
|
|
|
@ -525,7 +525,7 @@ static int process_http_upload(
|
|||
if (r == -E2BIG)
|
||||
return mhd_respondf(connection,
|
||||
r, MHD_HTTP_REQUEST_ENTITY_TOO_LARGE,
|
||||
"Entry is too large, maximum is " STRINGIFY(DATA_SIZE_MAX) " bytes.\n");
|
||||
"Entry is too large, maximum is " STRINGIFY(DATA_SIZE_MAX) " bytes.");
|
||||
else
|
||||
return mhd_respondf(connection,
|
||||
r, MHD_HTTP_UNPROCESSABLE_ENTITY,
|
||||
|
@ -547,7 +547,7 @@ static int process_http_upload(
|
|||
remaining);
|
||||
}
|
||||
|
||||
return mhd_respond(connection, MHD_HTTP_ACCEPTED, "OK.\n");
|
||||
return mhd_respond(connection, MHD_HTTP_ACCEPTED, "OK.");
|
||||
};
|
||||
|
||||
static int request_handler(
|
||||
|
@ -577,19 +577,16 @@ static int request_handler(
|
|||
*connection_cls);
|
||||
|
||||
if (!streq(method, "POST"))
|
||||
return mhd_respond(connection, MHD_HTTP_NOT_ACCEPTABLE,
|
||||
"Unsupported method.\n");
|
||||
return mhd_respond(connection, MHD_HTTP_NOT_ACCEPTABLE, "Unsupported method.");
|
||||
|
||||
if (!streq(url, "/upload"))
|
||||
return mhd_respond(connection, MHD_HTTP_NOT_FOUND,
|
||||
"Not found.\n");
|
||||
return mhd_respond(connection, MHD_HTTP_NOT_FOUND, "Not found.");
|
||||
|
||||
header = MHD_lookup_connection_value(connection,
|
||||
MHD_HEADER_KIND, "Content-Type");
|
||||
if (!header || !streq(header, "application/vnd.fdo.journal"))
|
||||
return mhd_respond(connection, MHD_HTTP_UNSUPPORTED_MEDIA_TYPE,
|
||||
"Content-Type: application/vnd.fdo.journal"
|
||||
" is required.\n");
|
||||
"Content-Type: application/vnd.fdo.journal is required.");
|
||||
|
||||
{
|
||||
const union MHD_ConnectionInfo *ci;
|
||||
|
@ -599,7 +596,7 @@ static int request_handler(
|
|||
if (!ci) {
|
||||
log_error("MHD_get_connection_info failed: cannot get remote fd");
|
||||
return mhd_respond(connection, MHD_HTTP_INTERNAL_SERVER_ERROR,
|
||||
"Cannot check remote address");
|
||||
"Cannot check remote address.");
|
||||
}
|
||||
|
||||
fd = ci->connect_fd;
|
||||
|
@ -614,7 +611,7 @@ static int request_handler(
|
|||
r = getpeername_pretty(fd, false, &hostname);
|
||||
if (r < 0)
|
||||
return mhd_respond(connection, MHD_HTTP_INTERNAL_SERVER_ERROR,
|
||||
"Cannot check remote hostname");
|
||||
"Cannot check remote hostname.");
|
||||
}
|
||||
|
||||
assert(hostname);
|
||||
|
|
|
@ -48,7 +48,7 @@ void microhttpd_logger(void *arg, const char *fmt, va_list ap) {
|
|||
|
||||
static int mhd_respond_internal(struct MHD_Connection *connection,
|
||||
enum MHD_RequestTerminationCode code,
|
||||
char *buffer,
|
||||
const char *buffer,
|
||||
size_t size,
|
||||
enum MHD_ResponseMemoryMode mode) {
|
||||
struct MHD_Response *response;
|
||||
|
@ -56,7 +56,7 @@ static int mhd_respond_internal(struct MHD_Connection *connection,
|
|||
|
||||
assert(connection);
|
||||
|
||||
response = MHD_create_response_from_buffer(size, buffer, mode);
|
||||
response = MHD_create_response_from_buffer(size, (char*) buffer, mode);
|
||||
if (!response)
|
||||
return MHD_NO;
|
||||
|
||||
|
@ -72,13 +72,17 @@ int mhd_respond(struct MHD_Connection *connection,
|
|||
enum MHD_RequestTerminationCode code,
|
||||
const char *message) {
|
||||
|
||||
const char *fmt;
|
||||
|
||||
fmt = strjoina(message, "\n");
|
||||
|
||||
return mhd_respond_internal(connection, code,
|
||||
(char*) message, strlen(message),
|
||||
fmt, strlen(message) + 1,
|
||||
MHD_RESPMEM_PERSISTENT);
|
||||
}
|
||||
|
||||
int mhd_respond_oom(struct MHD_Connection *connection) {
|
||||
return mhd_respond(connection, MHD_HTTP_SERVICE_UNAVAILABLE, "Out of memory.\n");
|
||||
return mhd_respond(connection, MHD_HTTP_SERVICE_UNAVAILABLE, "Out of memory.");
|
||||
}
|
||||
|
||||
int mhd_respondf(struct MHD_Connection *connection,
|
||||
|
@ -86,6 +90,7 @@ int mhd_respondf(struct MHD_Connection *connection,
|
|||
enum MHD_RequestTerminationCode code,
|
||||
const char *format, ...) {
|
||||
|
||||
const char *fmt;
|
||||
char *m;
|
||||
int r;
|
||||
va_list ap;
|
||||
|
@ -96,8 +101,9 @@ int mhd_respondf(struct MHD_Connection *connection,
|
|||
if (error < 0)
|
||||
error = -error;
|
||||
errno = -error;
|
||||
fmt = strjoina(format, "\n");
|
||||
va_start(ap, format);
|
||||
r = vasprintf(&m, format, ap);
|
||||
r = vasprintf(&m, fmt, ap);
|
||||
va_end(ap);
|
||||
|
||||
if (r < 0)
|
||||
|
|
Loading…
Reference in a new issue