@@ -112,9 +112,9 @@
return ret;
}
-static bool initialized; /* GLOBAL */
-static bool up; /* GLOBAL */
-static time_t next; /* GLOBAL */
+static bool gremlin_initialized; /* GLOBAL */
+static bool gremlin_up; /* GLOBAL */
+static time_t gremlin_next; /* GLOBAL */
/*
* Return false if we should drop a packet.
@@ -125,54 +125,54 @@
const int up_down_level = GREMLIN_UP_DOWN_LEVEL(flags);
const int drop_level = GREMLIN_DROP_LEVEL(flags);
- if (!initialized)
+ if (!gremlin_initialized)
{
- initialized = true;
+ gremlin_initialized = true;
if (up_down_level)
{
- up = false;
+ gremlin_up = false;
}
else
{
- up = true;
+ gremlin_up = true;
}
- next = now;
+ gremlin_next = now;
}
if (up_down_level) /* change up/down state? */
{
- if (now >= next)
+ if (now >= gremlin_next)
{
int delta;
- if (up)
+ if (gremlin_up)
{
delta = roll(down_low[up_down_level - 1], down_high[up_down_level - 1]);
- up = false;
+ gremlin_up = false;
}
else
{
delta = roll(up_low[up_down_level - 1], up_high[up_down_level - 1]);
- up = true;
+ gremlin_up = true;
}
- msg(D_GREMLIN, "GREMLIN: CONNECTION GOING %s FOR %d SECONDS", (up ? "UP" : "DOWN"),
+ msg(D_GREMLIN, "GREMLIN: CONNECTION GOING %s FOR %d SECONDS", (gremlin_up ? "UP" : "DOWN"),
delta);
- next = now + delta;
+ gremlin_next = now + delta;
}
}
if (drop_level)
{
- if (up && flip(drop_freq[drop_level - 1]))
+ if (gremlin_up && flip(drop_freq[drop_level - 1]))
{
dmsg(D_GREMLIN_VERBOSE, "GREMLIN: Random packet drop");
return false;
}
}
- return up;
+ return gremlin_up;
}
/*
@@ -3062,7 +3062,7 @@
}
void
-management_notify_client_needing_auth(struct management *management, const unsigned int mda_key_id,
+management_notify_client_needing_auth(struct management *man, const unsigned int mda_key_id,
struct man_def_auth_context *mdac, const struct env_set *es)
{
if (!(mdac->flags & DAF_CONNECTION_CLOSED))
@@ -3073,12 +3073,12 @@
mode = "REAUTH";
}
msg(M_CLIENT, ">CLIENT:%s,%lu,%u", mode, mdac->cid, mda_key_id);
- man_output_extra_env(management, "CLIENT");
- if (management->connection.env_filter_level > 0)
+ man_output_extra_env(man, "CLIENT");
+ if (man->connection.env_filter_level > 0)
{
- man_output_peer_info_env(management, mdac);
+ man_output_peer_info_env(man, mdac);
}
- man_output_env(es, true, management->connection.env_filter_level, "CLIENT");
+ man_output_env(es, true, man->connection.env_filter_level, "CLIENT");
mdac->flags |= DAF_INITIAL_AUTH;
}
}
@@ -3104,23 +3104,24 @@
}
void
-management_connection_established(struct management *management, struct man_def_auth_context *mdac,
+management_connection_established(struct management *man, struct man_def_auth_context *mdac,
const struct env_set *es)
{
mdac->flags |= DAF_CONNECTION_ESTABLISHED;
msg(M_CLIENT, ">CLIENT:ESTABLISHED,%lu", mdac->cid);
- man_output_extra_env(management, "CLIENT");
- man_output_env(es, true, management->connection.env_filter_level, "CLIENT");
+ man_output_extra_env(man, "CLIENT");
+ man_output_env(es, true, man->connection.env_filter_level, "CLIENT");
}
void
-management_notify_client_close(struct management *management, struct man_def_auth_context *mdac,
+management_notify_client_close(const struct management *man,
+ struct man_def_auth_context *mdac,
const struct env_set *es)
{
if ((mdac->flags & DAF_INITIAL_AUTH) && !(mdac->flags & DAF_CONNECTION_CLOSED))
{
msg(M_CLIENT, ">CLIENT:DISCONNECT,%lu", mdac->cid);
- man_output_env(es, true, management->connection.env_filter_level, "CLIENT");
+ man_output_env(es, true, man->connection.env_filter_level, "CLIENT");
mdac->flags |= DAF_CONNECTION_CLOSED;
}
}
@@ -3980,12 +3981,12 @@
*/
struct command_line *
-command_line_new(const size_t buf_len)
+command_line_new(const size_t len)
{
struct command_line *cl;
ALLOC_OBJ_CLEAR(cl, struct command_line);
- cl->buf = alloc_buf(buf_len);
- cl->residual = alloc_buf(buf_len);
+ cl->buf = alloc_buf(len);
+ cl->residual = alloc_buf(len);
return cl;
}
@@ -389,15 +389,15 @@
void management_notify_generic(const char *str);
-void management_notify_client_needing_auth(struct management *management,
+void management_notify_client_needing_auth(struct management *man,
const unsigned int auth_id,
struct man_def_auth_context *mdac,
const struct env_set *es);
-void management_connection_established(struct management *management,
+void management_connection_established(struct management *man,
struct man_def_auth_context *mdac, const struct env_set *es);
-void management_notify_client_close(struct management *management,
+void management_notify_client_close(const struct management *man,
struct man_def_auth_context *mdac, const struct env_set *es);
void management_learn_addr(struct man_def_auth_context *mdac,
@@ -396,12 +396,12 @@
#endif
char *
-options_string_extract_option(const char *options_string, const char *opt_name, struct gc_arena *gc)
+options_string_extract_option(const char *option_string, const char *opt_name, struct gc_arena *gc)
{
char *ret = NULL;
const size_t opt_name_len = strlen(opt_name);
- const char *p = options_string;
+ const char *p = option_string;
while (p)
{
if (0 == strncmp(p, opt_name, opt_name_len) && strlen(p) > (opt_name_len + 1)
@@ -184,10 +184,10 @@
}
bool
-proxy_send(socket_descriptor_t sd, const void *buf, size_t buf_len)
+proxy_send(socket_descriptor_t sd, const void *buf, size_t len)
{
- const ssize_t size = openvpn_send(sd, buf, buf_len, MSG_NOSIGNAL);
- if (size != (ssize_t)buf_len)
+ const ssize_t size = openvpn_send(sd, buf, len, MSG_NOSIGNAL);
+ if (size != (ssize_t)len)
{
msg(D_LINK_ERRORS | M_ERRNO, "proxy_send: TCP port write failed on send()");
return false;
@@ -1360,7 +1360,7 @@
static void
init_epoch_keys(struct key_state *ks, struct tls_multi *multi, const struct key_type *key_type,
- bool server, struct key2 *key2)
+ bool server, const struct key2 *key2)
{
/* For now we hardcode this to be 4 for the software based data channel
* DCO based implementations/HW implementation might adjust this number
@@ -1403,14 +1403,14 @@
static void
init_key_contexts(struct key_state *ks, struct tls_multi *multi, const struct key_type *key_type,
- bool server, struct key2 *key2, bool dco_enabled)
+ bool server, const struct key2 *key2, bool dco)
{
struct key_ctx_bi *key = &ks->crypto_options.key_ctx_bi;
/* Initialize key contexts */
int key_direction = server ? KEY_DIRECTION_INVERSE : KEY_DIRECTION_NORMAL;
- if (dco_enabled)
+ if (dco)
{
if (key->encrypt.hmac)
{
@@ -220,14 +220,14 @@
* Check X.509 Netscape certificate type field, if available.
*
* @param cert Certificate to check.
- * @param usage One of \c NS_CERT_CHECK_CLIENT, \c NS_CERT_CHECK_SERVER,
+ * @param cert_type One of \c NS_CERT_CHECK_CLIENT, \c NS_CERT_CHECK_SERVER,
* or \c NS_CERT_CHECK_NONE.
*
* @return \c SUCCESS if NS_CERT_CHECK_NONE or if the certificate has
* the expected bit set. \c FAILURE if the certificate does
* not have NS cert type verification or the wrong bit set.
*/
-result_t x509_verify_ns_cert_type(openvpn_x509_cert_t *cert, const int usage);
+result_t x509_verify_ns_cert_type(openvpn_x509_cert_t *cert, const int cert_type);
/*
* Verify X.509 key usage extension field.
@@ -753,9 +753,9 @@
/* Dummy function because Netscape certificate types are not supported in OpenVPN with mbedtls.
* Returns SUCCESS if usage is NS_CERT_CHECK_NONE, FAILURE otherwise. */
result_t
-x509_verify_ns_cert_type(mbedtls_x509_crt *cert, const int usage)
+x509_verify_ns_cert_type(mbedtls_x509_crt *cert, const int cert_type)
{
- if (usage == NS_CERT_CHECK_NONE)
+ if (cert_type == NS_CERT_CHECK_NONE)
{
return SUCCESS;
}
@@ -629,13 +629,13 @@
}
result_t
-x509_verify_ns_cert_type(openvpn_x509_cert_t *peer_cert, const int usage)
+x509_verify_ns_cert_type(openvpn_x509_cert_t *peer_cert, const int cert_type)
{
- if (usage == NS_CERT_CHECK_NONE)
+ if (cert_type == NS_CERT_CHECK_NONE)
{
return SUCCESS;
}
- if (usage == NS_CERT_CHECK_CLIENT)
+ if (cert_type == NS_CERT_CHECK_CLIENT)
{
/*
* Unfortunately, X509_check_purpose() before OpenSSL 4.0 does some weird thing that
@@ -668,7 +668,7 @@
}
return result;
}
- if (usage == NS_CERT_CHECK_SERVER)
+ if (cert_type == NS_CERT_CHECK_SERVER)
{
/*
* Unfortunately, X509_check_purpose() before OpenSSL 4.0 does some weird thing that
@@ -3848,8 +3848,8 @@
static DWORD
-UpdateWaitHandles(LPHANDLE *handles_ptr, LPDWORD count, HANDLE io_event, HANDLE exit_event,
- list_item_t *threads)
+UpdateWaitHandles(LPHANDLE *handles_ptr, LPDWORD count, HANDLE io_event,
+ const list_item_t *threads)
{
static DWORD size = 10;
static LPHANDLE handles = NULL;
@@ -3998,7 +3998,7 @@
goto out;
}
- error = UpdateWaitHandles(&handles, &handle_count, io_event, exit_event, threads);
+ error = UpdateWaitHandles(&handles, &handle_count, io_event, threads);
if (error != NO_ERROR)
{
goto out;
@@ -4065,7 +4065,7 @@
if (!error)
{
error =
- UpdateWaitHandles(&handles, &handle_count, io_event, exit_event, threads);
+ UpdateWaitHandles(&handles, &handle_count, io_event, threads);
}
if (error)
{
@@ -4073,7 +4073,7 @@
&exit_event);
/* Update wait handles again after removing the last worker thread */
RemoveListItem(&threads, CmpHandle, thread);
- UpdateWaitHandles(&handles, &handle_count, io_event, exit_event, threads);
+ UpdateWaitHandles(&handles, &handle_count, io_event, threads);
TerminateThread(thread, 1);
CloseHandleEx(&thread);
CloseHandleEx(&pipe);
@@ -4113,7 +4113,7 @@
/* Worker thread ended */
HANDLE thread = RemoveListItem(&threads, CmpHandle, handles[error]);
- UpdateWaitHandles(&handles, &handle_count, io_event, exit_event, threads);
+ UpdateWaitHandles(&handles, &handle_count, io_event, threads);
CloseHandleEx(&thread);
}
}
@@ -27,7 +27,7 @@
#include <pathcch.h>
#include <lm.h>
-static const WCHAR *white_list[] = {
+static const WCHAR *global_white_list[] = {
L"auth-retry",
L"config",
L"log",
@@ -335,7 +335,7 @@
}
/* option name starts at 2 characters from argv[i] */
- if (OptionLookup(argv[0] + 2, white_list) == -1) /* not found */
+ if (OptionLookup(argv[0] + 2, global_white_list) == -1) /* not found */
{
return FALSE;
}
@@ -137,7 +137,7 @@
static char softhsm2_conf_path[] = "softhsm2_conf_XXXXXX";
int num_certs;
static const char *pkcs11_id_current;
-struct env_set *es;
+struct env_set *test_set;
/* Fill-in certs[] array */
void
@@ -218,15 +218,15 @@
/* environment */
setenv("SOFTHSM2_CONF", softhsm2_conf_path, 1);
- es = env_set_create(NULL);
- setenv_str(es, "SOFTHSM2_CONF", softhsm2_conf_path);
- setenv_str(es, "GNUTLS_PIN", PIN);
+ test_set = env_set_create(NULL);
+ setenv_str(test_set, "SOFTHSM2_CONF", softhsm2_conf_path);
+ setenv_str(test_set, "GNUTLS_PIN", PIN);
/* init the token using the temporary location as storage */
struct argv a = argv_new();
argv_printf(&a, "%s --init-token --free --label \"%s\" --so-pin %s --pin %s",
SOFTHSM2_UTIL_PATH, token_name, PIN, PIN);
- assert_true(openvpn_execve_check(&a, es, 0, "Failed to initialize token"));
+ assert_true(openvpn_execve_check(&a, test_set, 0, "Failed to initialize token"));
/* Import certificates and keys in our test database into the token */
char cert[] = "cert_XXXXXX";
@@ -263,14 +263,14 @@
argv_printf(
&a, "%s --provider %s --load-certificate %s --label \"%s\" --id %08x --login --write",
P11TOOL_PATH, SOFTHSM2_MODULE_PATH, cert, c->friendly_name, num_certs + 1);
- assert_true(openvpn_execve_check(&a, es, 0, "Failed to upload certificate into token"));
+ assert_true(openvpn_execve_check(&a, test_set, 0, "Failed to upload certificate into token"));
argv_free(&a);
a = argv_new();
argv_printf(&a,
"%s --provider %s --load-privkey %s --label \"%s\" --id %08x --login --write",
P11TOOL_PATH, SOFTHSM2_MODULE_PATH, key, c->friendly_name, num_certs + 1);
- assert_true(openvpn_execve_check(&a, es, 0, "Failed to upload key into token"));
+ assert_true(openvpn_execve_check(&a, test_set, 0, "Failed to upload key into token"));
assert_int_equal(ftruncate(cert_fd, 0), 0);
assert_int_equal(ftruncate(key_fd, 0), 0);
@@ -294,7 +294,7 @@
struct argv a = argv_new();
argv_printf(&a, "%s --delete-token --token \"%s\"", SOFTHSM2_UTIL_PATH, token_name);
- assert_true(openvpn_execve_check(&a, es, 0, "Failed to delete token"));
+ assert_true(openvpn_execve_check(&a, test_set, 0, "Failed to delete token"));
argv_free(&a);
rmdir(softhsm2_tokens_path); /* this must be empty after delete token */
@@ -304,7 +304,7 @@
free(c->p11_id);
c->p11_id = NULL;
}
- env_set_destroy(es);
+ env_set_destroy(test_set);
return 0;
}
@@ -35,7 +35,7 @@
#include "interactive.c"
BOOL
-ReportStatusToSCMgr(SERVICE_STATUS_HANDLE service, SERVICE_STATUS *status)
+ReportStatusToSCMgr(SERVICE_STATUS_HANDLE svc_handle, SERVICE_STATUS *svc_status)
{
return TRUE;
}