Attention is currently required from: flichtenheld, plaisthos.
Hello flichtenheld, plaisthos,
I'd like you to reexamine a change. Please visit
http://gerrit.openvpn.net/c/openvpn/+/809?usp=email
to look at the new patch set (#2).
Change subject: PUSH_UPDATE: Added remove_option() and do_update().
......................................................................
PUSH_UPDATE: Added remove_option() and do_update().
* Added remove_option() function and some utility functions to remove options at
runtime following the push-update logic.
* Added do_update() function to close and reopen the tun and apply option
updates.
Change-Id: I507180d7397b6959844a30908010132bc3411067
Signed-off-by: Marco Baffo <[email protected]>
---
M src/openvpn/init.c
M src/openvpn/init.h
M src/openvpn/options.c
M src/openvpn/push.c
M src/openvpn/route.c
M src/openvpn/route.h
6 files changed, 354 insertions(+), 32 deletions(-)
git pull ssh://gerrit.openvpn.net:29418/openvpn refs/changes/09/809/2
diff --git a/src/openvpn/init.c b/src/openvpn/init.c
index f8d9d06..b95a61a 100644
--- a/src/openvpn/init.c
+++ b/src/openvpn/init.c
@@ -2567,6 +2567,47 @@
return true;
}
+bool
+do_update(struct context *c, unsigned int option_types_found)
+{
+ /* Not necessary since to receive the update the openvpn
+ * instance must be up and running but just in case
+ */
+ if (!c->c2.do_up_ran)
+ {
+ return false;
+ }
+
+ bool tt_dco_win = tuntap_is_dco_win(c->c1.tuntap);
+ if (tt_dco_win)
+ {
+ msg(M_NONFATAL, "dco-win doesn't yet support reopening TUN device");
+ return false;
+ }
+
+ if (!do_deferred_options(c, option_types_found))
+ {
+ msg(D_PUSH_ERRORS, "ERROR: Failed to apply push options");
+ return false;
+ }
+
+ do_close_tun(c, true);
+
+ management_sleep(1);
+ int error_flags = 0;
+ c->c2.did_open_tun = do_open_tun(c, &error_flags);
+ update_time();
+
+ if (c->c2.did_open_tun)
+ {
+ initialization_sequence_completed(c, error_flags);
+ }
+
+ CLEAR(c->c1.pulled_options_digest_save);
+
+ return true;
+}
+
/*
* These are the option categories which will be accepted by pull.
*/
diff --git a/src/openvpn/init.h b/src/openvpn/init.h
index ea7eb30..3d0206e 100644
--- a/src/openvpn/init.h
+++ b/src/openvpn/init.h
@@ -86,6 +86,8 @@
bool pulled_options,
unsigned int option_types_found);
+bool do_update(struct context *c, unsigned int option_types_found);
+
unsigned int pull_permission_mask(const struct context *c);
const char *format_common_name(struct context *c, struct gc_arena *gc);
diff --git a/src/openvpn/options.c b/src/openvpn/options.c
index 8dea578..5b4419d 100644
--- a/src/openvpn/options.c
+++ b/src/openvpn/options.c
@@ -1055,6 +1055,40 @@
gc_free(&gc);
}
}
+
+static void
+delete_all_dhcp_fo(struct options *o, struct env_item **list)
+{
+ struct env_item *current, *prev;
+
+ ASSERT(list);
+
+ for (current = *list, prev = NULL; current != NULL; current =
current->next)
+ {
+ char *tmp_value = NULL;
+ if (!strncmp(current->string, "foreign_option_",
sizeof("foreign_option_")-1))
+ {
+ tmp_value = strchr(current->string, '=');
+ if (tmp_value && ++tmp_value)
+ {
+ if (!strncmp(tmp_value, "dhcp-option ", sizeof("dhcp-option
")-1))
+ {
+ if (prev)
+ {
+ prev->next = current->next;
+ }
+ else
+ {
+ *list = current->next;
+ }
+ o->foreign_option_index--;
+ }
+ }
+ }
+ prev = current;
+ }
+}
+
#endif /* ifndef _WIN32 */
static in_addr_t
@@ -3260,8 +3294,16 @@
msg(M_INFO, "Flag 'def1' added to --redirect-gateway (iservice is in
use)");
opt->routes->flags |= RG_DEF1;
}
+ else if ((!opt->routes
+ || opt->route_method != ROUTE_METHOD_SERVICE
+ || !(opt->routes->flags & RG_REROUTE_GW))
+ && (opt->routes->flags & RG_DEF1))
+ {
+ msg(M_INFO, "Flag 'def1' removed from --redirect-gateway");
+ opt->routes->flags &= ~RG_DEF1;
+ }
}
-#endif
+#endif /* ifdef _WIN32 */
/*
* Save/Restore certain option defaults before --pull is applied.
@@ -5452,37 +5494,6 @@
}
}
-void
-options_server_import(struct options *o,
- const char *filename,
- int msglevel,
- unsigned int permission_mask,
- unsigned int *option_types_found,
- struct env_set *es)
-{
- msg(D_PUSH, "OPTIONS IMPORT: reading client specific options from: %s",
filename);
- read_config_file(o,
- filename,
- 0,
- filename,
- 0,
- msglevel,
- permission_mask,
- option_types_found,
- es);
-}
-
-void
-options_string_import(struct options *options,
- const char *config,
- const int msglevel,
- const unsigned int permission_mask,
- unsigned int *option_types_found,
- struct env_set *es)
-{
- read_config_string("[CONFIG-STRING]", options, config, msglevel,
permission_mask, option_types_found, es);
-}
-
#define VERIFY_PERMISSION(mask) { \
if (!verify_permission(p[0], file, line, (mask), permission_mask,
\
option_types_found, msglevel, options,
is_inline)) \
@@ -5585,6 +5596,169 @@
return options->forward_compatible ? M_WARN : msglevel;
}
+static void
+remove_option(struct context *c,
+ struct options *options,
+ char *p[],
+ bool is_inline,
+ const char *file,
+ int line,
+ const int msglevel,
+ const unsigned int permission_mask,
+ unsigned int *option_types_found,
+ struct env_set *es)
+{
+ int msglevel_fc = msglevel_forward_compatible(options, msglevel);
+
+ if (streq(p[0], "ifconfig") && !p[1])
+ {
+ VERIFY_PERMISSION(OPT_P_UP);
+ options->ifconfig_local = NULL;
+ options->ifconfig_remote_netmask = NULL;
+ }
+ else if (streq(p[0], "ifconfig-ipv6") && !p[1])
+ {
+ VERIFY_PERMISSION(OPT_P_UP);
+ options->ifconfig_ipv6_local = NULL;
+ options->ifconfig_ipv6_netbits = 0;
+ options->ifconfig_ipv6_remote = NULL;
+ }
+ else if (streq(p[0], "route") && !p[1])
+ {
+ VERIFY_PERMISSION(OPT_P_ROUTE);
+ if (c->c1.route_list)
+ {
+ destroy_routes_v4(c->c1.route_list, c->c1.tuntap,
+ ROUTE_OPTION_FLAGS(&c->options),
+ es, &c->net_ctx, options);
+ }
+ }
+ else if (streq(p[0], "route-ipv6") && !p[1])
+ {
+ VERIFY_PERMISSION(OPT_P_ROUTE);
+ if (c->c1.route_ipv6_list)
+ {
+ destroy_routes_v6(c->c1.route_ipv6_list, c->c1.tuntap,
+ ROUTE_OPTION_FLAGS(&c->options),
+ es, &c->net_ctx, options);
+ }
+ }
+ else if (streq(p[0], "route-gateway") && !p[1])
+ {
+ VERIFY_PERMISSION(OPT_P_ROUTE_EXTRAS);
+ options->route_gateway_via_dhcp = false;
+ options->route_default_gateway = NULL;
+ }
+ else if (streq(p[0], "route-metric") && !p[1])
+ {
+ VERIFY_PERMISSION(OPT_P_ROUTE);
+ options->route_default_metric = 0;
+ }
+ else if (streq(p[0], "push-continuation") && !p[1])
+ {
+ VERIFY_PERMISSION(OPT_P_PULL_MODE);
+ options->push_continuation = 0;
+ }
+ else if ((streq(p[0], "redirect-gateway") || streq(p[0],
"redirect-private")) && !p[1])
+ {
+ VERIFY_PERMISSION(OPT_P_ROUTE);
+ if (options->routes)
+ {
+ options->routes->flags = 0;
+ }
+ if (options->routes_ipv6)
+ {
+ options->routes_ipv6->flags = 0;
+ }
+ }
+ else if (streq(p[0], "dns") && !p[1])
+ {
+ VERIFY_PERMISSION(OPT_P_DHCPDNS);
+ gc_free(&options->dns_options.gc);
+ CLEAR(options->dns_options);
+ }
+ else if (streq(p[0], "topology") && !p[1])
+ {
+ VERIFY_PERMISSION(OPT_P_UP);
+ options->topology = TOP_UNDEF;
+ helper_setdefault_topology(options);
+ }
+ else if (streq(p[0], "tun-mtu") && !p[1])
+ {
+ VERIFY_PERMISSION(OPT_P_PUSH_MTU|OPT_P_CONNECTION);
+ options->ce.tun_mtu = TUN_MTU_DEFAULT;
+ options->ce.tun_mtu_defined = false;
+ options->ce.occ_mtu = 0;
+ }
+ else if (streq(p[0], "block-ipv6") && !p[1])
+ {
+ VERIFY_PERMISSION(OPT_P_ROUTE);
+ options->block_ipv6 = false;
+ }
+#if defined(_WIN32) || defined(TARGET_ANDROID)
+ else if (streq(p[0], "dhcp-option") && !p[1])
+ {
+ struct tuntap_options *o = &options->tuntap_options;
+ VERIFY_PERMISSION(OPT_P_DHCPDNS);
+
+ o->domain = NULL;
+ o->netbios_scope = NULL;
+ o->netbios_node_type = 0;
+ o->dns6_len = 0;
+ memset(o->dns6, 0, sizeof(o->dns6));
+ o->dns_len = 0;
+ memset(o->dns, 0, sizeof(o->dns));
+ o->wins_len = 0;
+ memset(o->wins, 0, sizeof(o->wins));
+ o->ntp_len = 0;
+ memset(o->ntp, 0, sizeof(o->ntp));
+ o->nbdd_len = 0;
+ memset(o->nbdd, 0, sizeof(o->nbdd));
+ while (o->domain_search_list_len-- > 0)
+ {
+ o->domain_search_list[o->domain_search_list_len] = NULL;
+ }
+ o->disable_nbt = 0;
+ o->dhcp_options = 0;
+#if defined(TARGET_ANDROID)
+ o->http_proxy_port = 0;
+ o->http_proxy = NULL;
+#endif
+ }
+#endif /* if defined(_WIN32) || defined(TARGET_ANDROID) */
+#ifdef _WIN32
+ else if (streq(p[0], "block-outside-dns") && !p[1])
+ {
+ VERIFY_PERMISSION(OPT_P_DHCPDNS);
+ options->block_outside_dns = false;
+ }
+#else /* ifdef _WIN32 */
+ else if (streq(p[0], "dhcp-option") && !p[1])
+ {
+ VERIFY_PERMISSION(OPT_P_DHCPDNS);
+ delete_all_dhcp_fo(options, &es->list);
+ }
+#endif
+ else
+ {
+ int i;
+ int msglevel_unknown = msglevel_fc;
+ /* Check if an option is in --ignore-unknown-option and
+ * set warning level to non fatal */
+ for (i = 0; options->ignore_unknown_option &&
options->ignore_unknown_option[i]; i++)
+ {
+ if (streq(p[0], options->ignore_unknown_option[i]))
+ {
+ msglevel_unknown = M_WARN;
+ break;
+ }
+ }
+ msg(msglevel_unknown, "Unrecognized option or missing or extra
parameter(s) in %s:%d: -%s (%s)", file, line, p[0], PACKAGE_VERSION);
+ }
+ return;
+err:
+ msg(msglevel, "Error occurred trying to remove %s option", p[0]);
+}
bool
apply_push_options(struct context *c,
struct options *options,
@@ -5618,11 +5792,47 @@
add_option(options, p, false, file, line_num, 0, msglevel,
permission_mask, option_types_found, es);
}
+ else if (push_update_option_flags & PUSH_OPT_TO_REMOVE)
+ {
+ remove_option(c, options, p, false, file, line_num, msglevel,
+ permission_mask, option_types_found, es);
+ }
}
}
return true;
}
+void
+options_server_import(struct options *o,
+ const char *filename,
+ int msglevel,
+ unsigned int permission_mask,
+ unsigned int *option_types_found,
+ struct env_set *es)
+{
+ msg(D_PUSH, "OPTIONS IMPORT: reading client specific options from: %s",
filename);
+ read_config_file(o,
+ filename,
+ 0,
+ filename,
+ 0,
+ msglevel,
+ permission_mask,
+ option_types_found,
+ es);
+}
+
+void
+options_string_import(struct options *options,
+ const char *config,
+ const int msglevel,
+ const unsigned int permission_mask,
+ unsigned int *option_types_found,
+ struct env_set *es)
+{
+ read_config_string("[CONFIG-STRING]", options, config, msglevel,
permission_mask, option_types_found, es);
+}
+
static void
set_user_script(struct options *options,
const char **script,
diff --git a/src/openvpn/push.c b/src/openvpn/push.c
index 71a0372..69ea4bf 100644
--- a/src/openvpn/push.c
+++ b/src/openvpn/push.c
@@ -542,6 +542,11 @@
{
msg(M_WARN, "No option found");
}
+ else if (!do_update(c, option_types_found))
+ {
+ msg(D_PUSH_ERRORS, "Failed to update options");
+ goto error;
+ }
}
}
event_timeout_clear(&c->c2.push_request_interval);
diff --git a/src/openvpn/route.c b/src/openvpn/route.c
index 2e584c7..0cd71d2 100644
--- a/src/openvpn/route.c
+++ b/src/openvpn/route.c
@@ -1291,6 +1291,60 @@
}
}
+void
+destroy_routes_v4(struct route_list *rl, const struct tuntap *tt,
+ unsigned int flags, const struct env_set *es,
+ openvpn_net_ctx_t *ctx, struct options *options)
+{
+ if (rl && (rl->iflags & RL_ROUTES_ADDED))
+ {
+ struct route_ipv4 *r;
+ for (r = rl->routes; r; r = r->next)
+ {
+ delete_route(r, tt, flags, &rl->rgi, es, ctx);
+ }
+ rl->iflags &= ~RL_ROUTES_ADDED;
+ }
+
+ undo_redirect_default_route_to_vpn(rl, tt, flags, es, ctx);
+
+ if (rl)
+ {
+ clear_route_list(rl);
+ }
+ if (options->routes)
+ {
+ options->routes->routes = NULL;
+ options->routes->flags = 0;
+ }
+}
+
+void
+destroy_routes_v6(struct route_ipv6_list *rl6, const struct tuntap *tt,
+ unsigned int flags, const struct env_set *es,
+ openvpn_net_ctx_t *ctx, struct options *options)
+{
+ if (rl6 && (rl6->iflags & RL_ROUTES_ADDED))
+ {
+ struct route_ipv6 *r6;
+ for (r6 = rl6->routes_ipv6; r6; r6 = r6->next)
+ {
+ delete_route_ipv6(r6, tt, flags, es, ctx);
+ }
+ rl6->iflags &= ~RL_ROUTES_ADDED;
+ }
+
+ if (rl6)
+ {
+ clear_route_ipv6_list(rl6);
+ }
+ if (options->routes_ipv6)
+ {
+ options->routes_ipv6->routes_ipv6 = NULL;
+ options->routes_ipv6->flags = 0;
+ }
+}
+
#ifndef ENABLE_SMALL
static const char *
diff --git a/src/openvpn/route.h b/src/openvpn/route.h
index 421e7d2..b798c9d 100644
--- a/src/openvpn/route.h
+++ b/src/openvpn/route.h
@@ -321,6 +321,16 @@
const struct env_set *es,
openvpn_net_ctx_t *ctx);
+void
+destroy_routes_v4(struct route_list *rl, const struct tuntap *tt,
+ unsigned int flags, const struct env_set *es,
+ openvpn_net_ctx_t *ctx, struct options *options);
+
+void
+destroy_routes_v6(struct route_ipv6_list *rl6, const struct tuntap *tt,
+ unsigned int flags, const struct env_set *es,
+ openvpn_net_ctx_t *ctx, struct options *options);
+
void setenv_routes(struct env_set *es, const struct route_list *rl);
void setenv_routes_ipv6(struct env_set *es, const struct route_ipv6_list *rl6);
--
To view, visit http://gerrit.openvpn.net/c/openvpn/+/809?usp=email
To unsubscribe, or for help writing mail filters, visit
http://gerrit.openvpn.net/settings
Gerrit-Project: openvpn
Gerrit-Branch: master
Gerrit-Change-Id: I507180d7397b6959844a30908010132bc3411067
Gerrit-Change-Number: 809
Gerrit-PatchSet: 2
Gerrit-Owner: mrbff <[email protected]>
Gerrit-Reviewer: flichtenheld <[email protected]>
Gerrit-Reviewer: plaisthos <[email protected]>
Gerrit-CC: openvpn-devel <[email protected]>
Gerrit-Attention: plaisthos <[email protected]>
Gerrit-Attention: flichtenheld <[email protected]>
Gerrit-MessageType: newpatchset
_______________________________________________
Openvpn-devel mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/openvpn-devel
