mirror of
https://gitlab.freedesktop.org/NetworkManager/NetworkManager.git
synced 2026-05-07 13:08:10 +02:00
cloud-setup: make nm_http_client_req() accept a method argument
We'll need to be able to issue PUT calls. Conflicts: variable alignments only (cherry picked from commitcd74d75002) (cherry picked from commiteff4372045) (cherry picked from commitaaf66e9174) (cherry picked from commit3d94f4fdf9) (cherry picked from commit181466c6da)
This commit is contained in:
parent
d6d161a31d
commit
7243307bb8
6 changed files with 30 additions and 0 deletions
|
|
@ -262,6 +262,7 @@ nm_http_client_req(NMHttpClient * self,
|
||||||
int timeout_msec,
|
int timeout_msec,
|
||||||
gssize max_data,
|
gssize max_data,
|
||||||
const char *const * http_headers,
|
const char *const * http_headers,
|
||||||
|
const char * http_method,
|
||||||
GCancellable * cancellable,
|
GCancellable * cancellable,
|
||||||
GAsyncReadyCallback callback,
|
GAsyncReadyCallback callback,
|
||||||
gpointer user_data)
|
gpointer user_data)
|
||||||
|
|
@ -322,6 +323,9 @@ nm_http_client_req(NMHttpClient * self,
|
||||||
curl_easy_setopt(edata->ehandle, CURLOPT_HTTPHEADER, edata->headers);
|
curl_easy_setopt(edata->ehandle, CURLOPT_HTTPHEADER, edata->headers);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (http_method)
|
||||||
|
curl_easy_setopt(edata->ehandle, CURLOPT_CUSTOMREQUEST, http_method);
|
||||||
|
|
||||||
if (timeout_msec > 0) {
|
if (timeout_msec > 0) {
|
||||||
edata->timeout_source = _source_attach(self,
|
edata->timeout_source = _source_attach(self,
|
||||||
nm_g_timeout_source_new(timeout_msec,
|
nm_g_timeout_source_new(timeout_msec,
|
||||||
|
|
@ -397,6 +401,7 @@ typedef struct {
|
||||||
GTask * task;
|
GTask * task;
|
||||||
char * uri;
|
char * uri;
|
||||||
const char *const * http_headers;
|
const char *const * http_headers;
|
||||||
|
const char * http_method;
|
||||||
NMHttpClientPollReqCheckFcn check_fcn;
|
NMHttpClientPollReqCheckFcn check_fcn;
|
||||||
gpointer check_user_data;
|
gpointer check_user_data;
|
||||||
GBytes * response_data;
|
GBytes * response_data;
|
||||||
|
|
@ -434,6 +439,7 @@ _poll_req_probe_start_fcn(GCancellable * cancellable,
|
||||||
poll_req_data->request_timeout_ms,
|
poll_req_data->request_timeout_ms,
|
||||||
poll_req_data->request_max_data,
|
poll_req_data->request_max_data,
|
||||||
poll_req_data->http_headers,
|
poll_req_data->http_headers,
|
||||||
|
poll_req_data->http_method,
|
||||||
cancellable,
|
cancellable,
|
||||||
callback,
|
callback,
|
||||||
user_data);
|
user_data);
|
||||||
|
|
@ -520,6 +526,7 @@ nm_http_client_poll_req(NMHttpClient * self,
|
||||||
int poll_timeout_ms,
|
int poll_timeout_ms,
|
||||||
int ratelimit_timeout_ms,
|
int ratelimit_timeout_ms,
|
||||||
const char *const * http_headers,
|
const char *const * http_headers,
|
||||||
|
const char * http_method,
|
||||||
GCancellable * cancellable,
|
GCancellable * cancellable,
|
||||||
NMHttpClientPollReqCheckFcn check_fcn,
|
NMHttpClientPollReqCheckFcn check_fcn,
|
||||||
gpointer check_user_data,
|
gpointer check_user_data,
|
||||||
|
|
|
||||||
|
|
@ -39,6 +39,7 @@ void nm_http_client_poll_req(NMHttpClient * self,
|
||||||
int poll_timeout_ms,
|
int poll_timeout_ms,
|
||||||
int ratelimit_timeout_ms,
|
int ratelimit_timeout_ms,
|
||||||
const char *const * http_headers,
|
const char *const * http_headers,
|
||||||
|
const char * http_method,
|
||||||
GCancellable * cancellable,
|
GCancellable * cancellable,
|
||||||
NMHttpClientPollReqCheckFcn check_fcn,
|
NMHttpClientPollReqCheckFcn check_fcn,
|
||||||
gpointer check_user_data,
|
gpointer check_user_data,
|
||||||
|
|
|
||||||
|
|
@ -111,6 +111,7 @@ detect(NMCSProvider *provider, GTask *task)
|
||||||
7000,
|
7000,
|
||||||
1000,
|
1000,
|
||||||
NULL,
|
NULL,
|
||||||
|
NULL,
|
||||||
g_task_get_cancellable(task),
|
g_task_get_cancellable(task),
|
||||||
NULL,
|
NULL,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
@ -332,6 +333,7 @@ _get_config_metadata_ready_cb(GObject *source, GAsyncResult *result, gpointer us
|
||||||
10000,
|
10000,
|
||||||
1000,
|
1000,
|
||||||
NULL,
|
NULL,
|
||||||
|
NULL,
|
||||||
get_config_data->intern_cancellable,
|
get_config_data->intern_cancellable,
|
||||||
NULL,
|
NULL,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
@ -349,6 +351,7 @@ _get_config_metadata_ready_cb(GObject *source, GAsyncResult *result, gpointer us
|
||||||
10000,
|
10000,
|
||||||
1000,
|
1000,
|
||||||
NULL,
|
NULL,
|
||||||
|
NULL,
|
||||||
get_config_data->intern_cancellable,
|
get_config_data->intern_cancellable,
|
||||||
NULL,
|
NULL,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
@ -366,6 +369,7 @@ _get_config_metadata_ready_cb(GObject *source, GAsyncResult *result, gpointer us
|
||||||
10000,
|
10000,
|
||||||
1000,
|
1000,
|
||||||
NULL,
|
NULL,
|
||||||
|
NULL,
|
||||||
get_config_data->intern_cancellable,
|
get_config_data->intern_cancellable,
|
||||||
NULL,
|
NULL,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
@ -383,6 +387,7 @@ _get_config_metadata_ready_cb(GObject *source, GAsyncResult *result, gpointer us
|
||||||
10000,
|
10000,
|
||||||
1000,
|
1000,
|
||||||
NULL,
|
NULL,
|
||||||
|
NULL,
|
||||||
get_config_data->intern_cancellable,
|
get_config_data->intern_cancellable,
|
||||||
NULL,
|
NULL,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
@ -480,6 +485,7 @@ get_config(NMCSProvider *provider, NMCSProviderGetConfigTaskData *get_config_dat
|
||||||
15000,
|
15000,
|
||||||
1000,
|
1000,
|
||||||
NULL,
|
NULL,
|
||||||
|
NULL,
|
||||||
get_config_data->intern_cancellable,
|
get_config_data->intern_cancellable,
|
||||||
_get_config_metadata_ready_check,
|
_get_config_metadata_ready_check,
|
||||||
get_config_data,
|
get_config_data,
|
||||||
|
|
|
||||||
|
|
@ -76,6 +76,7 @@ detect(NMCSProvider *provider, GTask *task)
|
||||||
7000,
|
7000,
|
||||||
1000,
|
1000,
|
||||||
NM_MAKE_STRV(NM_AZURE_METADATA_HEADER),
|
NM_MAKE_STRV(NM_AZURE_METADATA_HEADER),
|
||||||
|
NULL,
|
||||||
g_task_get_cancellable(task),
|
g_task_get_cancellable(task),
|
||||||
NULL,
|
NULL,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
@ -294,6 +295,7 @@ _get_config_ips_prefix_list_cb(GObject *source, GAsyncResult *result, gpointer u
|
||||||
10000,
|
10000,
|
||||||
1000,
|
1000,
|
||||||
NM_MAKE_STRV(NM_AZURE_METADATA_HEADER),
|
NM_MAKE_STRV(NM_AZURE_METADATA_HEADER),
|
||||||
|
NULL,
|
||||||
get_config_data->intern_cancellable,
|
get_config_data->intern_cancellable,
|
||||||
NULL,
|
NULL,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
@ -316,6 +318,7 @@ _get_config_ips_prefix_list_cb(GObject *source, GAsyncResult *result, gpointer u
|
||||||
10000,
|
10000,
|
||||||
1000,
|
1000,
|
||||||
NM_MAKE_STRV(NM_AZURE_METADATA_HEADER),
|
NM_MAKE_STRV(NM_AZURE_METADATA_HEADER),
|
||||||
|
NULL,
|
||||||
get_config_data->intern_cancellable,
|
get_config_data->intern_cancellable,
|
||||||
NULL,
|
NULL,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
@ -333,6 +336,7 @@ _get_config_ips_prefix_list_cb(GObject *source, GAsyncResult *result, gpointer u
|
||||||
10000,
|
10000,
|
||||||
1000,
|
1000,
|
||||||
NM_MAKE_STRV(NM_AZURE_METADATA_HEADER),
|
NM_MAKE_STRV(NM_AZURE_METADATA_HEADER),
|
||||||
|
NULL,
|
||||||
get_config_data->intern_cancellable,
|
get_config_data->intern_cancellable,
|
||||||
NULL,
|
NULL,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
@ -415,6 +419,7 @@ _get_config_iface_cb(GObject *source, GAsyncResult *result, gpointer user_data)
|
||||||
10000,
|
10000,
|
||||||
1000,
|
1000,
|
||||||
NM_MAKE_STRV(NM_AZURE_METADATA_HEADER),
|
NM_MAKE_STRV(NM_AZURE_METADATA_HEADER),
|
||||||
|
NULL,
|
||||||
get_config_data->intern_cancellable,
|
get_config_data->intern_cancellable,
|
||||||
NULL,
|
NULL,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
@ -515,6 +520,7 @@ _get_net_ifaces_list_cb(GObject *source, GAsyncResult *result, gpointer user_dat
|
||||||
10000,
|
10000,
|
||||||
1000,
|
1000,
|
||||||
NM_MAKE_STRV(NM_AZURE_METADATA_HEADER),
|
NM_MAKE_STRV(NM_AZURE_METADATA_HEADER),
|
||||||
|
NULL,
|
||||||
get_config_data->intern_cancellable,
|
get_config_data->intern_cancellable,
|
||||||
NULL,
|
NULL,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
@ -538,6 +544,7 @@ get_config(NMCSProvider *provider, NMCSProviderGetConfigTaskData *get_config_dat
|
||||||
15000,
|
15000,
|
||||||
1000,
|
1000,
|
||||||
NM_MAKE_STRV(NM_AZURE_METADATA_HEADER),
|
NM_MAKE_STRV(NM_AZURE_METADATA_HEADER),
|
||||||
|
NULL,
|
||||||
get_config_data->intern_cancellable,
|
get_config_data->intern_cancellable,
|
||||||
NULL,
|
NULL,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
|
||||||
|
|
@ -106,6 +106,7 @@ detect(NMCSProvider *provider, GTask *task)
|
||||||
7000,
|
7000,
|
||||||
1000,
|
1000,
|
||||||
NULL,
|
NULL,
|
||||||
|
NULL,
|
||||||
g_task_get_cancellable(task),
|
g_task_get_cancellable(task),
|
||||||
_detect_get_meta_data_check_cb,
|
_detect_get_meta_data_check_cb,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
@ -267,6 +268,7 @@ _get_config_metadata_ready_cb(GObject *source, GAsyncResult *result, gpointer us
|
||||||
10000,
|
10000,
|
||||||
1000,
|
1000,
|
||||||
NULL,
|
NULL,
|
||||||
|
NULL,
|
||||||
get_config_data->intern_cancellable,
|
get_config_data->intern_cancellable,
|
||||||
NULL,
|
NULL,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
@ -284,6 +286,7 @@ _get_config_metadata_ready_cb(GObject *source, GAsyncResult *result, gpointer us
|
||||||
10000,
|
10000,
|
||||||
1000,
|
1000,
|
||||||
NULL,
|
NULL,
|
||||||
|
NULL,
|
||||||
get_config_data->intern_cancellable,
|
get_config_data->intern_cancellable,
|
||||||
NULL,
|
NULL,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
@ -381,6 +384,7 @@ get_config(NMCSProvider *provider, NMCSProviderGetConfigTaskData *get_config_dat
|
||||||
15000,
|
15000,
|
||||||
1000,
|
1000,
|
||||||
NULL,
|
NULL,
|
||||||
|
NULL,
|
||||||
get_config_data->intern_cancellable,
|
get_config_data->intern_cancellable,
|
||||||
_get_config_metadata_ready_check,
|
_get_config_metadata_ready_check,
|
||||||
get_config_data,
|
get_config_data,
|
||||||
|
|
|
||||||
|
|
@ -79,6 +79,7 @@ detect(NMCSProvider *provider, GTask *task)
|
||||||
7000,
|
7000,
|
||||||
1000,
|
1000,
|
||||||
NM_MAKE_STRV(NM_GCP_METADATA_HEADER),
|
NM_MAKE_STRV(NM_GCP_METADATA_HEADER),
|
||||||
|
NULL,
|
||||||
g_task_get_cancellable(task),
|
g_task_get_cancellable(task),
|
||||||
NULL,
|
NULL,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
@ -227,6 +228,7 @@ _get_config_ips_list_cb(GObject *source, GAsyncResult *result, gpointer user_dat
|
||||||
HTTP_POLL_TIMEOUT_MS,
|
HTTP_POLL_TIMEOUT_MS,
|
||||||
HTTP_RATE_LIMIT_MS,
|
HTTP_RATE_LIMIT_MS,
|
||||||
NM_MAKE_STRV(NM_GCP_METADATA_HEADER),
|
NM_MAKE_STRV(NM_GCP_METADATA_HEADER),
|
||||||
|
NULL,
|
||||||
get_config_data->intern_cancellable,
|
get_config_data->intern_cancellable,
|
||||||
NULL,
|
NULL,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
@ -313,6 +315,7 @@ _get_config_iface_cb(GObject *source, GAsyncResult *result, gpointer user_data)
|
||||||
HTTP_POLL_TIMEOUT_MS,
|
HTTP_POLL_TIMEOUT_MS,
|
||||||
HTTP_RATE_LIMIT_MS,
|
HTTP_RATE_LIMIT_MS,
|
||||||
NM_MAKE_STRV(NM_GCP_METADATA_HEADER),
|
NM_MAKE_STRV(NM_GCP_METADATA_HEADER),
|
||||||
|
NULL,
|
||||||
get_config_data->intern_cancellable,
|
get_config_data->intern_cancellable,
|
||||||
NULL,
|
NULL,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
@ -412,6 +415,7 @@ _get_net_ifaces_list_cb(GObject *source, GAsyncResult *result, gpointer user_dat
|
||||||
HTTP_POLL_TIMEOUT_MS,
|
HTTP_POLL_TIMEOUT_MS,
|
||||||
HTTP_RATE_LIMIT_MS,
|
HTTP_RATE_LIMIT_MS,
|
||||||
NM_MAKE_STRV(NM_GCP_METADATA_HEADER),
|
NM_MAKE_STRV(NM_GCP_METADATA_HEADER),
|
||||||
|
NULL,
|
||||||
get_config_data->intern_cancellable,
|
get_config_data->intern_cancellable,
|
||||||
NULL,
|
NULL,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
@ -435,6 +439,7 @@ get_config(NMCSProvider *provider, NMCSProviderGetConfigTaskData *get_config_dat
|
||||||
HTTP_POLL_TIMEOUT_MS,
|
HTTP_POLL_TIMEOUT_MS,
|
||||||
HTTP_RATE_LIMIT_MS,
|
HTTP_RATE_LIMIT_MS,
|
||||||
NM_MAKE_STRV(NM_GCP_METADATA_HEADER),
|
NM_MAKE_STRV(NM_GCP_METADATA_HEADER),
|
||||||
|
NULL,
|
||||||
get_config_data->intern_cancellable,
|
get_config_data->intern_cancellable,
|
||||||
NULL,
|
NULL,
|
||||||
NULL,
|
NULL,
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue