[PATCH] hashmap: Allow freeing of keys in addition to values

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

 



On 08/06/2013 11:02 AM, Arun Raghavan wrote:
> This is handy for cases where we want to have the key freed at entry
> removal or hashmap free'ing time. For example, this is useful when
> creating a hashmap based on non-static strings.

I agree about the problem about string keys, but I think the
implementation could be more elegant:

1) The free_cb functions could be supplied with pa_hashmap_new and
stored inside the hashmap, rather than being supplied in several places.

2) This applies mostly to strings. Could we perhaps make a convenience
layer for string-key hashmaps, like this:

pa_hashmap_put_strkey(const char *strkey, void *value) {
  void *key = pa_strdup(strkey);
  pa_hashmap_put(key, value);
}

...and similar for other functions, when necessary?


> ---
>  src/modules/alsa/alsa-mixer.c                      | 28 ++++++-------
>  src/modules/alsa/module-alsa-card.c                |  2 +-
>  src/modules/bluetooth/bluetooth-util.c             | 14 +++----
>  src/modules/bluetooth/module-bluetooth-discover.c  |  6 +--
>  src/modules/bluetooth/module-bluetooth-proximity.c |  6 +--
>  src/modules/dbus/iface-card.c                      |  6 +--
>  src/modules/dbus/iface-core.c                      | 48 +++++++++++-----------
>  src/modules/dbus/iface-device.c                    |  6 +--
>  src/modules/gconf/module-gconf.c                   |  4 +-
>  src/modules/macosx/module-bonjour-publish.c        |  4 +-
>  src/modules/module-augment-properties.c            |  4 +-
>  src/modules/module-card-restore.c                  |  2 +-
>  src/modules/module-console-kit.c                   |  4 +-
>  src/modules/module-device-manager.c                | 16 ++++----
>  src/modules/module-filter-apply.c                  | 10 ++---
>  src/modules/module-role-cork.c                     |  6 +--
>  src/modules/module-stream-restore.c                |  8 ++--
>  src/modules/module-suspend-on-idle.c               |  4 +-
>  src/modules/module-systemd-login.c                 |  8 ++--
>  src/modules/module-udev-detect.c                   |  4 +-
>  src/modules/module-zeroconf-discover.c             |  6 +--
>  src/modules/module-zeroconf-publish.c              |  6 +--
>  src/modules/raop/module-raop-discover.c            |  6 +--
>  src/modules/rtp/headerlist.c                       |  4 +-
>  src/modules/rtp/module-rtp-recv.c                  |  8 ++--
>  src/pulse/context.c                                |  4 +-
>  src/pulse/proplist.c                               |  6 +--
>  src/pulse/stream.c                                 |  3 +-
>  src/pulsecore/card.c                               |  8 ++--
>  src/pulsecore/core.c                               |  4 +-
>  src/pulsecore/database-simple.c                    | 10 ++---
>  src/pulsecore/device-port.c                        |  2 +-
>  src/pulsecore/hashmap.c                            | 29 +++++++------
>  src/pulsecore/hashmap.h                            | 14 +++----
>  src/pulsecore/memblock.c                           | 10 ++---
>  src/pulsecore/modargs.c                            |  4 +-
>  src/pulsecore/mutex-win32.c                        |  4 +-
>  src/pulsecore/namereg.c                            |  2 +-
>  src/pulsecore/protocol-dbus.c                      | 34 +++++++--------
>  src/pulsecore/protocol-native.c                    |  4 +-
>  src/pulsecore/shared.c                             |  2 +-
>  src/pulsecore/sink-input.c                         | 12 +++---
>  src/pulsecore/sink.c                               | 10 ++---
>  src/pulsecore/source.c                             | 10 ++---
>  44 files changed, 198 insertions(+), 194 deletions(-)
> 
> diff --git a/src/modules/alsa/alsa-mixer.c b/src/modules/alsa/alsa-mixer.c
> index 545ae9f..fe5b7b1 100644
> --- a/src/modules/alsa/alsa-mixer.c
> +++ b/src/modules/alsa/alsa-mixer.c
> @@ -530,7 +530,7 @@ void pa_alsa_path_set_free(pa_alsa_path_set *ps) {
>      pa_assert(ps);
>  
>      if (ps->paths)
> -        pa_hashmap_free(ps->paths, NULL);
> +        pa_hashmap_free(ps->paths, NULL, NULL);
>  
>      pa_xfree(ps);
>  }
> @@ -3237,7 +3237,7 @@ static void path_set_condense(pa_alsa_path_set *ps, snd_mixer_t *m) {
>  
>              if (is_subset) {
>                  pa_log_debug("Removing path '%s' as it is a subset of '%s'.", p->name, p2->name);
> -                pa_hashmap_remove(ps->paths, p);
> +                pa_hashmap_remove(ps->paths, p, NULL);
>                  break;
>              }
>          }
> @@ -3337,19 +3337,19 @@ void pa_alsa_profile_set_free(pa_alsa_profile_set *ps) {
>      pa_assert(ps);
>  
>      if (ps->input_paths)
> -        pa_hashmap_free(ps->input_paths, (pa_free_cb_t) pa_alsa_path_free);
> +        pa_hashmap_free(ps->input_paths, NULL, (pa_free_cb_t) pa_alsa_path_free);
>  
>      if (ps->output_paths)
> -        pa_hashmap_free(ps->output_paths, (pa_free_cb_t) pa_alsa_path_free);
> +        pa_hashmap_free(ps->output_paths, NULL, (pa_free_cb_t) pa_alsa_path_free);
>  
>      if (ps->profiles)
> -        pa_hashmap_free(ps->profiles, (pa_free_cb_t) profile_free);
> +        pa_hashmap_free(ps->profiles, NULL, (pa_free_cb_t) profile_free);
>  
>      if (ps->mappings)
> -        pa_hashmap_free(ps->mappings, (pa_free_cb_t) mapping_free);
> +        pa_hashmap_free(ps->mappings, NULL, (pa_free_cb_t) mapping_free);
>  
>      if (ps->decibel_fixes)
> -        pa_hashmap_free(ps->decibel_fixes, (pa_free_cb_t) decibel_fix_free);
> +        pa_hashmap_free(ps->decibel_fixes, NULL, (pa_free_cb_t) decibel_fix_free);
>  
>      pa_xfree(ps);
>  }
> @@ -3776,13 +3776,13 @@ static void mapping_paths_probe(pa_alsa_mapping *m, pa_alsa_profile *profile,
>      mixer_handle = pa_alsa_open_mixer_for_pcm(pcm_handle, NULL, &hctl_handle);
>      if (!mixer_handle || !hctl_handle) {
>           /* Cannot open mixer, remove all entries */
> -        pa_hashmap_remove_all(ps->paths, NULL);
> +        pa_hashmap_remove_all(ps->paths, NULL, NULL);
>          return;
>      }
>  
>      PA_HASHMAP_FOREACH(p, ps->paths, state) {
>          if (pa_alsa_path_probe(p, mixer_handle, hctl_handle, m->profile_set->ignore_dB) < 0) {
> -            pa_hashmap_remove(ps->paths, p);
> +            pa_hashmap_remove(ps->paths, p, NULL);
>          }
>      }
>  
> @@ -4290,7 +4290,7 @@ static void paths_drop_unsupported(pa_hashmap* h) {
>      p = pa_hashmap_iterate(h, &state, &key);
>      while (p) {
>          if (p->supported <= 0) {
> -            pa_hashmap_remove(h, key);
> +            pa_hashmap_remove(h, key, NULL);
>              pa_alsa_path_free(p);
>          }
>          p = pa_hashmap_iterate(h, &state, &key);
> @@ -4420,8 +4420,8 @@ void pa_alsa_profile_set_probe(
>  
>      paths_drop_unsupported(ps->input_paths);
>      paths_drop_unsupported(ps->output_paths);
> -    pa_hashmap_free(broken_inputs, NULL);
> -    pa_hashmap_free(broken_outputs, NULL);
> +    pa_hashmap_free(broken_inputs, NULL, NULL);
> +    pa_hashmap_free(broken_outputs, NULL, NULL);
>  
>      ps->probed = true;
>  }
> @@ -4460,14 +4460,14 @@ void pa_alsa_profile_set_drop_unsupported(pa_alsa_profile_set *ps) {
>  
>      PA_HASHMAP_FOREACH(p, ps->profiles, state) {
>          if (!p->supported) {
> -            pa_hashmap_remove(ps->profiles, p->name);
> +            pa_hashmap_remove(ps->profiles, p->name, NULL);
>              profile_free(p);
>          }
>      }
>  
>      PA_HASHMAP_FOREACH(m, ps->mappings, state) {
>          if (m->supported <= 0) {
> -            pa_hashmap_remove(ps->mappings, m->name);
> +            pa_hashmap_remove(ps->mappings, m->name, NULL);
>              mapping_free(m);
>          }
>      }
> diff --git a/src/modules/alsa/module-alsa-card.c b/src/modules/alsa/module-alsa-card.c
> index d0294e8..d242fc8 100644
> --- a/src/modules/alsa/module-alsa-card.c
> +++ b/src/modules/alsa/module-alsa-card.c
> @@ -871,7 +871,7 @@ void pa__done(pa_module*m) {
>      if (u->mixer_handle)
>          snd_mixer_close(u->mixer_handle);
>      if (u->jacks)
> -        pa_hashmap_free(u->jacks, NULL);
> +        pa_hashmap_free(u->jacks, NULL, NULL);
>  
>      if (u->card && u->card->sinks)
>          pa_idxset_remove_all(u->card->sinks, (pa_free_cb_t) pa_alsa_sink_free);
> diff --git a/src/modules/bluetooth/bluetooth-util.c b/src/modules/bluetooth/bluetooth-util.c
> index dd280cb..4b0f67e 100644
> --- a/src/modules/bluetooth/bluetooth-util.c
> +++ b/src/modules/bluetooth/bluetooth-util.c
> @@ -262,7 +262,7 @@ static void device_free(pa_bluetooth_device *d) {
>              continue;
>  
>          d->transports[i] = NULL;
> -        pa_hashmap_remove(d->discovery->transports, t->path);
> +        pa_hashmap_remove(d->discovery->transports, t->path, NULL);
>          t->state = PA_BLUETOOTH_TRANSPORT_STATE_DISCONNECTED;
>          pa_hook_fire(&d->discovery->hooks[PA_BLUETOOTH_HOOK_TRANSPORT_STATE_CHANGED], t);
>          transport_free(t);
> @@ -675,7 +675,7 @@ static void remove_all_devices(pa_bluetooth_discovery *y) {
>  
>      pa_assert(y);
>  
> -    while ((d = pa_hashmap_steal_first(y->devices))) {
> +    while ((d = pa_hashmap_steal_first(y->devices, NULL))) {
>          run_callback(d, true);
>          device_free(d);
>      }
> @@ -1172,7 +1172,7 @@ static DBusHandlerResult filter_cb(DBusConnection *bus, DBusMessage *m, void *us
>  
>          pa_log_debug("Device %s removed", path);
>  
> -        if ((d = pa_hashmap_remove(y->devices, path))) {
> +        if ((d = pa_hashmap_remove(y->devices, path, NULL))) {
>              run_callback(d, true);
>              device_free(d);
>          }
> @@ -1327,7 +1327,7 @@ static DBusHandlerResult filter_cb(DBusConnection *bus, DBusMessage *m, void *us
>              if (pa_streq(interface, "org.bluez.Device1")) {
>                  pa_bluetooth_device *d;
>  
> -                if (!(d = pa_hashmap_remove(y->devices, path)))
> +                if (!(d = pa_hashmap_remove(y->devices, path, NULL)))
>                      pa_log_warn("Unknown device removed %s", path);
>                  else {
>                      pa_log_debug("Device %s removed", path);
> @@ -1772,7 +1772,7 @@ static DBusMessage *endpoint_clear_configuration(DBusConnection *c, DBusMessage
>  
>          pa_log_debug("Clearing transport %s profile %d", t->path, t->profile);
>          t->device->transports[t->profile] = NULL;
> -        pa_hashmap_remove(y->transports, t->path);
> +        pa_hashmap_remove(y->transports, t->path, NULL);
>          t->state = PA_BLUETOOTH_TRANSPORT_STATE_DISCONNECTED;
>          pa_hook_fire(&y->hooks[PA_BLUETOOTH_HOOK_TRANSPORT_STATE_CHANGED], t);
>  
> @@ -2109,12 +2109,12 @@ void pa_bluetooth_discovery_unref(pa_bluetooth_discovery *y) {
>  
>      if (y->devices) {
>          remove_all_devices(y);
> -        pa_hashmap_free(y->devices, NULL);
> +        pa_hashmap_free(y->devices, NULL, NULL);
>      }
>  
>      if (y->transports) {
>          pa_assert(pa_hashmap_isempty(y->transports));
> -        pa_hashmap_free(y->transports, NULL);
> +        pa_hashmap_free(y->transports, NULL, NULL);
>      }
>  
>      if (y->connection) {
> diff --git a/src/modules/bluetooth/module-bluetooth-discover.c b/src/modules/bluetooth/module-bluetooth-discover.c
> index cbd56cc..496cc64 100644
> --- a/src/modules/bluetooth/module-bluetooth-discover.c
> +++ b/src/modules/bluetooth/module-bluetooth-discover.c
> @@ -115,7 +115,7 @@ static pa_hook_result_t load_module_for_device(pa_bluetooth_discovery *y, const
>              /* Hmm, disconnection? Then the module unloads itself */
>  
>              pa_log_debug("Unregistering module for %s", d->path);
> -            pa_hashmap_remove(u->hashmap, mi->path);
> +            pa_hashmap_remove(u->hashmap, mi->path, NULL);
>              pa_xfree(mi->path);
>              pa_xfree(mi);
>          }
> @@ -179,12 +179,12 @@ void pa__done(pa_module* m) {
>      if (u->hashmap) {
>          struct module_info *mi;
>  
> -        while ((mi = pa_hashmap_steal_first(u->hashmap))) {
> +        while ((mi = pa_hashmap_steal_first(u->hashmap, NULL))) {
>              pa_xfree(mi->path);
>              pa_xfree(mi);
>          }
>  
> -        pa_hashmap_free(u->hashmap, NULL);
> +        pa_hashmap_free(u->hashmap, NULL, NULL);
>      }
>  
>      if (u->modargs)
> diff --git a/src/modules/bluetooth/module-bluetooth-proximity.c b/src/modules/bluetooth/module-bluetooth-proximity.c
> index c4e6ca6..24b4f55 100644
> --- a/src/modules/bluetooth/module-bluetooth-proximity.c
> +++ b/src/modules/bluetooth/module-bluetooth-proximity.c
> @@ -167,7 +167,7 @@ static void io_event_cb(
>      if ((r = read(fd, &x, 1)) <= 0) {
>          pa_log_warn("Child watching '%s' died abnormally: %s", b->address, r == 0 ? "EOF" : pa_cstrerror(errno));
>  
> -        pa_assert_se(pa_hashmap_remove(b->userdata->bondings, b->address) == b);
> +        pa_assert_se(pa_hashmap_remove(b->userdata->bondings, b->address, NULL) == b);
>          bonding_free(b);
>          return;
>      }
> @@ -280,7 +280,7 @@ static void bonding_remove(struct userdata *u, const char *a) {
>      struct bonding *b;
>      pa_assert(u);
>  
> -    pa_return_if_fail((b = pa_hashmap_remove(u->bondings, a)));
> +    pa_return_if_fail((b = pa_hashmap_remove(u->bondings, a, NULL)));
>  
>      pa_log_info("No longer watching device '%s'", b->address);
>      bonding_free(b);
> @@ -466,7 +466,7 @@ void pa__done(pa_module*m) {
>          return;
>  
>      if (u->bondings)
> -        pa_hashmap_free(u->bondings, (pa_free_cb_t) bonding_free);
> +        pa_hashmap_free(u->bondings, NULL, (pa_free_cb_t) bonding_free);
>  
>      if (u->dbus_connection) {
>          update_matches(u, false);
> diff --git a/src/modules/dbus/iface-card.c b/src/modules/dbus/iface-card.c
> index 19dd4ed..49a0abf 100644
> --- a/src/modules/dbus/iface-card.c
> +++ b/src/modules/dbus/iface-card.c
> @@ -495,7 +495,7 @@ static pa_hook_result_t card_profile_added_cb(void *hook_data, void *call_data,
>          return PA_HOOK_OK;
>  
>      p = pa_dbusiface_card_profile_new(c, core, profile, c->next_profile_index++);
> -    pa_assert_se(pa_hashmap_put(c->profiles, pa_dbusiface_card_profile_get_name(p), p) >= 0);
> +    pa_assert_se(pa_hashmap_put(c->profiles, (char *) pa_dbusiface_card_profile_get_name(p), p) >= 0);
>  
>      /* Send D-Bus signal */
>      object_path = pa_dbusiface_card_profile_get_path(p);
> @@ -532,7 +532,7 @@ pa_dbusiface_card *pa_dbusiface_card_new(pa_dbusiface_core *core, pa_card *card)
>  
>      PA_HASHMAP_FOREACH(profile, card->profiles, state) {
>          pa_dbusiface_card_profile *p = pa_dbusiface_card_profile_new(c, card->core, profile, c->next_profile_index++);
> -        pa_hashmap_put(c->profiles, pa_dbusiface_card_profile_get_name(p), p);
> +        pa_hashmap_put(c->profiles, (char *) pa_dbusiface_card_profile_get_name(p), p);
>      }
>  
>      pa_assert_se(pa_dbus_protocol_add_interface(c->dbus_protocol, c->path, &card_interface_info, c) >= 0);
> @@ -550,7 +550,7 @@ void pa_dbusiface_card_free(pa_dbusiface_card *c) {
>  
>      pa_hook_slot_free(c->card_profile_added_slot);
>  
> -    pa_hashmap_free(c->profiles, (pa_free_cb_t) pa_dbusiface_card_profile_free);
> +    pa_hashmap_free(c->profiles, NULL, (pa_free_cb_t) pa_dbusiface_card_profile_free);
>      pa_proplist_free(c->proplist);
>      pa_dbus_protocol_unref(c->dbus_protocol);
>      pa_subscription_free(c->subscription);
> diff --git a/src/modules/dbus/iface-core.c b/src/modules/dbus/iface-core.c
> index edc22ab..c1c968b 100644
> --- a/src/modules/dbus/iface-core.c
> +++ b/src/modules/dbus/iface-core.c
> @@ -1665,7 +1665,7 @@ static void subscription_cb(pa_core *core, pa_subscription_event_type_t t, uint3
>                  pa_assert_se(dbus_message_append_args(signal_msg, DBUS_TYPE_OBJECT_PATH, &object_path, DBUS_TYPE_INVALID));
>  
>              } else if ((t & PA_SUBSCRIPTION_EVENT_TYPE_MASK) == PA_SUBSCRIPTION_EVENT_REMOVE) {
> -                if (!(card_iface = pa_hashmap_remove(c->cards, PA_UINT32_TO_PTR(idx))))
> +                if (!(card_iface = pa_hashmap_remove(c->cards, PA_UINT32_TO_PTR(idx), NULL)))
>                      return;
>  
>                  object_path = pa_dbusiface_card_get_path(card_iface);
> @@ -1699,7 +1699,7 @@ static void subscription_cb(pa_core *core, pa_subscription_event_type_t t, uint3
>                  pa_assert_se(dbus_message_append_args(signal_msg, DBUS_TYPE_OBJECT_PATH, &object_path, DBUS_TYPE_INVALID));
>  
>              } else if ((t & PA_SUBSCRIPTION_EVENT_TYPE_MASK) == PA_SUBSCRIPTION_EVENT_REMOVE) {
> -                if (!(stream_iface = pa_hashmap_remove(c->playback_streams, PA_UINT32_TO_PTR(idx))))
> +                if (!(stream_iface = pa_hashmap_remove(c->playback_streams, PA_UINT32_TO_PTR(idx), NULL)))
>                      return;
>  
>                  object_path = pa_dbusiface_stream_get_path(stream_iface);
> @@ -1733,7 +1733,7 @@ static void subscription_cb(pa_core *core, pa_subscription_event_type_t t, uint3
>                  pa_assert_se(dbus_message_append_args(signal_msg, DBUS_TYPE_OBJECT_PATH, &object_path, DBUS_TYPE_INVALID));
>  
>              } else if ((t & PA_SUBSCRIPTION_EVENT_TYPE_MASK) == PA_SUBSCRIPTION_EVENT_REMOVE) {
> -                if (!(stream_iface = pa_hashmap_remove(c->record_streams, PA_UINT32_TO_PTR(idx))))
> +                if (!(stream_iface = pa_hashmap_remove(c->record_streams, PA_UINT32_TO_PTR(idx), NULL)))
>                      return;
>  
>                  object_path = pa_dbusiface_stream_get_path(stream_iface);
> @@ -1767,7 +1767,7 @@ static void subscription_cb(pa_core *core, pa_subscription_event_type_t t, uint3
>                  pa_assert_se(dbus_message_append_args(signal_msg, DBUS_TYPE_OBJECT_PATH, &object_path, DBUS_TYPE_INVALID));
>  
>              } else if ((t & PA_SUBSCRIPTION_EVENT_TYPE_MASK) == PA_SUBSCRIPTION_EVENT_REMOVE) {
> -                if (!(sample_iface = pa_hashmap_remove(c->samples, PA_UINT32_TO_PTR(idx))))
> +                if (!(sample_iface = pa_hashmap_remove(c->samples, PA_UINT32_TO_PTR(idx), NULL)))
>                      return;
>  
>                  object_path = pa_dbusiface_sample_get_path(sample_iface);
> @@ -1801,7 +1801,7 @@ static void subscription_cb(pa_core *core, pa_subscription_event_type_t t, uint3
>                  pa_assert_se(dbus_message_append_args(signal_msg, DBUS_TYPE_OBJECT_PATH, &object_path, DBUS_TYPE_INVALID));
>  
>              } else if ((t & PA_SUBSCRIPTION_EVENT_TYPE_MASK) == PA_SUBSCRIPTION_EVENT_REMOVE) {
> -                if (!(module_iface = pa_hashmap_remove(c->modules, PA_UINT32_TO_PTR(idx))))
> +                if (!(module_iface = pa_hashmap_remove(c->modules, PA_UINT32_TO_PTR(idx), NULL)))
>                      return;
>  
>                  object_path = pa_dbusiface_module_get_path(module_iface);
> @@ -1835,7 +1835,7 @@ static void subscription_cb(pa_core *core, pa_subscription_event_type_t t, uint3
>                  pa_assert_se(dbus_message_append_args(signal_msg, DBUS_TYPE_OBJECT_PATH, &object_path, DBUS_TYPE_INVALID));
>  
>              } else if ((t & PA_SUBSCRIPTION_EVENT_TYPE_MASK) == PA_SUBSCRIPTION_EVENT_REMOVE) {
> -                if (!(client_iface = pa_hashmap_remove(c->clients, PA_UINT32_TO_PTR(idx))))
> +                if (!(client_iface = pa_hashmap_remove(c->clients, PA_UINT32_TO_PTR(idx), NULL)))
>                      return;
>  
>                  object_path = pa_dbusiface_client_get_path(client_iface);
> @@ -1870,7 +1870,7 @@ static pa_hook_result_t sink_put_cb(void *hook_data, void *call_data, void *slot
>      object_path = pa_dbusiface_device_get_path(d);
>  
>      pa_assert_se(pa_hashmap_put(c->sinks_by_index, PA_UINT32_TO_PTR(s->index), d) >= 0);
> -    pa_assert_se(pa_hashmap_put(c->sinks_by_path, object_path, d) >= 0);
> +    pa_assert_se(pa_hashmap_put(c->sinks_by_path, (char *) object_path, d) >= 0);
>  
>      pa_assert_se(signal_msg = dbus_message_new_signal(PA_DBUS_CORE_OBJECT_PATH,
>                                                        PA_DBUS_CORE_INTERFACE,
> @@ -1893,9 +1893,9 @@ static pa_hook_result_t sink_unlink_cb(void *hook_data, void *call_data, void *s
>      pa_assert(c);
>      pa_assert(s);
>  
> -    pa_assert_se(d = pa_hashmap_remove(c->sinks_by_index, PA_UINT32_TO_PTR(s->index)));
> +    pa_assert_se(d = pa_hashmap_remove(c->sinks_by_index, PA_UINT32_TO_PTR(s->index), NULL));
>      object_path = pa_dbusiface_device_get_path(d);
> -    pa_assert_se(pa_hashmap_remove(c->sinks_by_path, object_path));
> +    pa_assert_se(pa_hashmap_remove(c->sinks_by_path, object_path, NULL));
>  
>      pa_assert_se(signal_msg = dbus_message_new_signal(PA_DBUS_CORE_OBJECT_PATH,
>                                                        PA_DBUS_CORE_INTERFACE,
> @@ -1924,7 +1924,7 @@ static pa_hook_result_t source_put_cb(void *hook_data, void *call_data, void *sl
>      object_path = pa_dbusiface_device_get_path(d);
>  
>      pa_assert_se(pa_hashmap_put(c->sources_by_index, PA_UINT32_TO_PTR(s->index), d) >= 0);
> -    pa_assert_se(pa_hashmap_put(c->sources_by_path, object_path, d) >= 0);
> +    pa_assert_se(pa_hashmap_put(c->sources_by_path, (char *) object_path, d) >= 0);
>  
>      pa_assert_se((signal_msg = dbus_message_new_signal(PA_DBUS_CORE_OBJECT_PATH,
>                                                         PA_DBUS_CORE_INTERFACE,
> @@ -1947,9 +1947,9 @@ static pa_hook_result_t source_unlink_cb(void *hook_data, void *call_data, void
>      pa_assert(c);
>      pa_assert(s);
>  
> -    pa_assert_se(d = pa_hashmap_remove(c->sources_by_index, PA_UINT32_TO_PTR(s->index)));
> +    pa_assert_se(d = pa_hashmap_remove(c->sources_by_index, PA_UINT32_TO_PTR(s->index), NULL));
>      object_path = pa_dbusiface_device_get_path(d);
> -    pa_assert_se(pa_hashmap_remove(c->sources_by_path, object_path));
> +    pa_assert_se(pa_hashmap_remove(c->sources_by_path, object_path, NULL));
>  
>      pa_assert_se(signal_msg = dbus_message_new_signal(PA_DBUS_CORE_OBJECT_PATH,
>                                                        PA_DBUS_CORE_INTERFACE,
> @@ -2060,13 +2060,13 @@ pa_dbusiface_core *pa_dbusiface_core_new(pa_core *core) {
>      PA_IDXSET_FOREACH(sink, core->sinks, idx) {
>          device = pa_dbusiface_device_new_sink(c, sink);
>          pa_hashmap_put(c->sinks_by_index, PA_UINT32_TO_PTR(idx), device);
> -        pa_hashmap_put(c->sinks_by_path, pa_dbusiface_device_get_path(device), device);
> +        pa_hashmap_put(c->sinks_by_path, (char *) pa_dbusiface_device_get_path(device), device);
>      }
>  
>      PA_IDXSET_FOREACH(source, core->sources, idx) {
>          device = pa_dbusiface_device_new_source(c, source);
>          pa_hashmap_put(c->sources_by_index, PA_UINT32_TO_PTR(idx), device);
> -        pa_hashmap_put(c->sources_by_path, pa_dbusiface_device_get_path(device), device);
> +        pa_hashmap_put(c->sources_by_path, (char *) pa_dbusiface_device_get_path(device), device);
>      }
>  
>      PA_IDXSET_FOREACH(sink_input, core->sink_inputs, idx)
> @@ -2097,16 +2097,16 @@ void pa_dbusiface_core_free(pa_dbusiface_core *c) {
>      /* Note that the order of freeing is important below.
>       * Do not change it for the sake of tidiness without checking! */
>      pa_subscription_free(c->subscription);
> -    pa_hashmap_free(c->cards, (pa_free_cb_t) pa_dbusiface_card_free);
> -    pa_hashmap_free(c->sinks_by_path, NULL);
> -    pa_hashmap_free(c->sinks_by_index, (pa_free_cb_t) pa_dbusiface_device_free);
> -    pa_hashmap_free(c->sources_by_path, NULL);
> -    pa_hashmap_free(c->sources_by_index, (pa_free_cb_t) pa_dbusiface_device_free);
> -    pa_hashmap_free(c->playback_streams, (pa_free_cb_t) pa_dbusiface_stream_free);
> -    pa_hashmap_free(c->record_streams, (pa_free_cb_t) pa_dbusiface_stream_free);
> -    pa_hashmap_free(c->samples, (pa_free_cb_t) pa_dbusiface_sample_free);
> -    pa_hashmap_free(c->modules, (pa_free_cb_t) pa_dbusiface_module_free);
> -    pa_hashmap_free(c->clients, (pa_free_cb_t) pa_dbusiface_client_free);
> +    pa_hashmap_free(c->cards, NULL, (pa_free_cb_t) pa_dbusiface_card_free);
> +    pa_hashmap_free(c->sinks_by_path, NULL, NULL);
> +    pa_hashmap_free(c->sinks_by_index, NULL, (pa_free_cb_t) pa_dbusiface_device_free);
> +    pa_hashmap_free(c->sources_by_path, NULL, NULL);
> +    pa_hashmap_free(c->sources_by_index, NULL, (pa_free_cb_t) pa_dbusiface_device_free);
> +    pa_hashmap_free(c->playback_streams, NULL, (pa_free_cb_t) pa_dbusiface_stream_free);
> +    pa_hashmap_free(c->record_streams, NULL, (pa_free_cb_t) pa_dbusiface_stream_free);
> +    pa_hashmap_free(c->samples, NULL, (pa_free_cb_t) pa_dbusiface_sample_free);
> +    pa_hashmap_free(c->modules, NULL, (pa_free_cb_t) pa_dbusiface_module_free);
> +    pa_hashmap_free(c->clients, NULL, (pa_free_cb_t) pa_dbusiface_client_free);
>      pa_hook_slot_free(c->sink_put_slot);
>      pa_hook_slot_free(c->sink_unlink_slot);
>      pa_hook_slot_free(c->source_put_slot);
> diff --git a/src/modules/dbus/iface-device.c b/src/modules/dbus/iface-device.c
> index 4af0333..f99512e 100644
> --- a/src/modules/dbus/iface-device.c
> +++ b/src/modules/dbus/iface-device.c
> @@ -1223,7 +1223,7 @@ pa_dbusiface_device *pa_dbusiface_device_new_sink(pa_dbusiface_core *core, pa_si
>  
>      PA_HASHMAP_FOREACH(port, sink->ports, state) {
>          pa_dbusiface_device_port *p = pa_dbusiface_device_port_new(d, sink->core, port, d->next_port_index++);
> -        pa_hashmap_put(d->ports, pa_dbusiface_device_port_get_name(p), p);
> +        pa_hashmap_put(d->ports, (char *) pa_dbusiface_device_port_get_name(p), p);
>      }
>  
>      pa_assert_se(pa_dbus_protocol_add_interface(d->dbus_protocol, d->path, &device_interface_info, d) >= 0);
> @@ -1257,7 +1257,7 @@ pa_dbusiface_device *pa_dbusiface_device_new_source(pa_dbusiface_core *core, pa_
>  
>      PA_HASHMAP_FOREACH(port, source->ports, state) {
>          pa_dbusiface_device_port *p = pa_dbusiface_device_port_new(d, source->core, port, d->next_port_index++);
> -        pa_hashmap_put(d->ports, pa_dbusiface_device_port_get_name(p), p);
> +        pa_hashmap_put(d->ports, (char *) pa_dbusiface_device_port_get_name(p), p);
>      }
>  
>      pa_assert_se(pa_dbus_protocol_add_interface(d->dbus_protocol, d->path, &device_interface_info, d) >= 0);
> @@ -1279,7 +1279,7 @@ void pa_dbusiface_device_free(pa_dbusiface_device *d) {
>          pa_assert_se(pa_dbus_protocol_remove_interface(d->dbus_protocol, d->path, source_interface_info.name) >= 0);
>          pa_source_unref(d->source);
>      }
> -    pa_hashmap_free(d->ports, (pa_free_cb_t) pa_dbusiface_device_port_free);
> +    pa_hashmap_free(d->ports, NULL, (pa_free_cb_t) pa_dbusiface_device_port_free);
>      pa_proplist_free(d->proplist);
>      pa_dbus_protocol_unref(d->dbus_protocol);
>      pa_subscription_free(d->subscription);
> diff --git a/src/modules/gconf/module-gconf.c b/src/modules/gconf/module-gconf.c
> index 448fde5..c43d549 100644
> --- a/src/modules/gconf/module-gconf.c
> +++ b/src/modules/gconf/module-gconf.c
> @@ -290,7 +290,7 @@ static int handle_event(struct userdata *u) {
>                      goto fail;
>  
>                  if ((m = pa_hashmap_get(u->module_infos, name))) {
> -                    pa_hashmap_remove(u->module_infos, name);
> +                    pa_hashmap_remove(u->module_infos, name, NULL);
>                      module_info_free(m);
>                  }
>  
> @@ -401,7 +401,7 @@ void pa__done(pa_module*m) {
>          pa_close(u->fd);
>  
>      if (u->module_infos)
> -        pa_hashmap_free(u->module_infos, (pa_free_cb_t) module_info_free);
> +        pa_hashmap_free(u->module_infos, NULL, (pa_free_cb_t) module_info_free);
>  
>      pa_xfree(u);
>  }
> diff --git a/src/modules/macosx/module-bonjour-publish.c b/src/modules/macosx/module-bonjour-publish.c
> index 26081ec..a172c34 100644
> --- a/src/modules/macosx/module-bonjour-publish.c
> +++ b/src/modules/macosx/module-bonjour-publish.c
> @@ -321,7 +321,7 @@ static struct service *get_service(struct userdata *u, pa_object *device) {
>  static void service_free(struct service *s) {
>      pa_assert(s);
>  
> -    pa_hashmap_remove(s->userdata->services, s->device);
> +    pa_hashmap_remove(s->userdata->services, s->device, NULL);
>  
>      if (s->service)
>          DNSServiceRefDeallocate(s->service);
> @@ -490,7 +490,7 @@ void pa__done(pa_module*m) {
>      unpublish_all_services(u);
>  
>      if (u->services)
> -        pa_hashmap_free(u->services, NULL);
> +        pa_hashmap_free(u->services, NULL, NULL);
>  
>      if (u->sink_new_slot)
>          pa_hook_slot_free(u->sink_new_slot);
> diff --git a/src/modules/module-augment-properties.c b/src/modules/module-augment-properties.c
> index fcc3462..1c9f7a4 100644
> --- a/src/modules/module-augment-properties.c
> +++ b/src/modules/module-augment-properties.c
> @@ -246,7 +246,7 @@ static void make_room(pa_hashmap *cache) {
>      while (pa_hashmap_size(cache) >= MAX_CACHE_SIZE) {
>          struct rule *r;
>  
> -        pa_assert_se(r = pa_hashmap_steal_first(cache));
> +        pa_assert_se(r = pa_hashmap_steal_first(cache, NULL));
>          rule_free(r);
>      }
>  }
> @@ -348,7 +348,7 @@ void pa__done(pa_module *m) {
>          pa_hook_slot_free(u->client_proplist_changed_slot);
>  
>      if (u->cache)
> -        pa_hashmap_free(u->cache, (pa_free_cb_t) rule_free);
> +        pa_hashmap_free(u->cache, NULL, (pa_free_cb_t) rule_free);
>  
>      pa_xfree(u);
>  }
> diff --git a/src/modules/module-card-restore.c b/src/modules/module-card-restore.c
> index 928f153..429a462 100644
> --- a/src/modules/module-card-restore.c
> +++ b/src/modules/module-card-restore.c
> @@ -137,7 +137,7 @@ static void entry_free(struct entry* e) {
>      pa_assert(e);
>  
>      pa_xfree(e->profile);
> -    pa_hashmap_free(e->ports, (pa_free_cb_t) port_info_free);
> +    pa_hashmap_free(e->ports, NULL, (pa_free_cb_t) port_info_free);
>  
>      pa_xfree(e);
>  }
> diff --git a/src/modules/module-console-kit.c b/src/modules/module-console-kit.c
> index 007d23b..c00d5c3 100644
> --- a/src/modules/module-console-kit.c
> +++ b/src/modules/module-console-kit.c
> @@ -146,7 +146,7 @@ static void free_session(struct session *session) {
>  static void remove_session(struct userdata *u, const char *id) {
>      struct session *session;
>  
> -    if (!(session = pa_hashmap_remove(u->sessions, id)))
> +    if (!(session = pa_hashmap_remove(u->sessions, id, NULL)))
>          return;
>  
>      free_session(session);
> @@ -346,7 +346,7 @@ void pa__done(pa_module *m) {
>          return;
>  
>      if (u->sessions)
> -        pa_hashmap_free(u->sessions, (pa_free_cb_t) free_session);
> +        pa_hashmap_free(u->sessions, NULL, (pa_free_cb_t) free_session);
>  
>      if (u->connection) {
>          pa_dbus_remove_matches(
> diff --git a/src/modules/module-device-manager.c b/src/modules/module-device-manager.c
> index 6ae9cee..b818f9b 100644
> --- a/src/modules/module-device-manager.c
> +++ b/src/modules/module-device-manager.c
> @@ -1306,24 +1306,24 @@ static int extension_cb(pa_native_protocol *p, pa_module *m, pa_native_connectio
>          for (i = 0; i < n_devices; ++i) {
>              const char *s;
>              if (pa_tagstruct_gets(t, &s) < 0) {
> -                while ((device = pa_hashmap_steal_first(h))) {
> +                while ((device = pa_hashmap_steal_first(h, NULL))) {
>                      pa_xfree(device->device);
>                      pa_xfree(device);
>                  }
>  
> -                pa_hashmap_free(h, NULL);
> +                pa_hashmap_free(h, NULL, NULL);
>                  pa_log_error("Protocol error on reorder");
>                  goto fail;
>              }
>  
>              /* Ensure this is a valid entry */
>              if (!(e = entry_read(u, s))) {
> -                while ((device = pa_hashmap_steal_first(h))) {
> +                while ((device = pa_hashmap_steal_first(h, NULL))) {
>                      pa_xfree(device->device);
>                      pa_xfree(device);
>                  }
>  
> -                pa_hashmap_free(h, NULL);
> +                pa_hashmap_free(h, NULL, NULL);
>                  pa_log_error("Client specified an unknown device in it's reorder list.");
>                  goto fail;
>              }
> @@ -1333,12 +1333,12 @@ static int extension_cb(pa_native_protocol *p, pa_module *m, pa_native_connectio
>                  first = false;
>                  sink_mode = (0 == strncmp("sink:", s, 5));
>              } else if ((sink_mode && 0 != strncmp("sink:", s, 5)) || (!sink_mode && 0 != strncmp("source:", s, 7))) {
> -                while ((device = pa_hashmap_steal_first(h))) {
> +                while ((device = pa_hashmap_steal_first(h, NULL))) {
>                      pa_xfree(device->device);
>                      pa_xfree(device);
>                  }
>  
> -                pa_hashmap_free(h, NULL);
> +                pa_hashmap_free(h, NULL, NULL);
>                  pa_log_error("Attempted to reorder mixed devices (sinks and sources)");
>                  goto fail;
>              }
> @@ -1408,10 +1408,10 @@ static int extension_cb(pa_native_protocol *p, pa_module *m, pa_native_connectio
>          n_devices = pa_hashmap_size(h);
>          devices = pa_xnew(struct device_t *,  n_devices);
>          idx = 0;
> -        while ((device = pa_hashmap_steal_first(h))) {
> +        while ((device = pa_hashmap_steal_first(h, NULL))) {
>              devices[idx++] = device;
>          }
> -        pa_hashmap_free(h, NULL);
> +        pa_hashmap_free(h, NULL, NULL);
>  
>          /* Simple bubble sort */
>          for (i = 0; i < n_devices; ++i) {
> diff --git a/src/modules/module-filter-apply.c b/src/modules/module-filter-apply.c
> index 05d4284..4e58890 100644
> --- a/src/modules/module-filter-apply.c
> +++ b/src/modules/module-filter-apply.c
> @@ -262,7 +262,7 @@ static void housekeeping_time_callback(pa_mainloop_api*a, pa_time_event* e, cons
>  
>              pa_log_debug("Detected filter %s as no longer used. Unloading.", filter->name);
>              idx = filter->module_index;
> -            pa_hashmap_remove(u->filters, filter);
> +            pa_hashmap_remove(u->filters, filter, NULL);
>              filter_free(filter);
>              pa_module_unload_request_by_index(u->core, idx, true);
>          }
> @@ -577,7 +577,7 @@ static pa_hook_result_t sink_unlink_cb(pa_core *core, pa_sink *sink, struct user
>              }
>  
>              idx = filter->module_index;
> -            pa_hashmap_remove(u->filters, filter);
> +            pa_hashmap_remove(u->filters, filter, NULL);
>              filter_free(filter);
>  
>              if (can_unload_module(u, idx))
> @@ -649,7 +649,7 @@ static pa_hook_result_t source_unlink_cb(pa_core *core, pa_source *source, struc
>              }
>  
>              idx = filter->module_index;
> -            pa_hashmap_remove(u->filters, filter);
> +            pa_hashmap_remove(u->filters, filter, NULL);
>              filter_free(filter);
>  
>              if (can_unload_module(u, idx))
> @@ -742,12 +742,12 @@ void pa__done(pa_module *m) {
>      if (u->filters) {
>          struct filter *f;
>  
> -        while ((f = pa_hashmap_steal_first(u->filters))) {
> +        while ((f = pa_hashmap_steal_first(u->filters, NULL))) {
>              pa_module_unload_request_by_index(u->core, f->module_index, true);
>              filter_free(f);
>          }
>  
> -        pa_hashmap_free(u->filters, NULL);
> +        pa_hashmap_free(u->filters, NULL, NULL);
>      }
>  
>      pa_xfree(u);
> diff --git a/src/modules/module-role-cork.c b/src/modules/module-role-cork.c
> index 9906d2e..74a9243 100644
> --- a/src/modules/module-role-cork.c
> +++ b/src/modules/module-role-cork.c
> @@ -129,7 +129,7 @@ static inline void apply_cork_to_sink(struct userdata *u, pa_sink *s, pa_sink_in
>              pa_sink_input_set_mute(j, true, false);
>              pa_sink_input_send_event(j, PA_STREAM_EVENT_REQUEST_CORK, NULL);
>          } else if (!cork) {
> -            pa_hashmap_remove(u->cork_state, j);
> +            pa_hashmap_remove(u->cork_state, j, NULL);
>  
>              if (corked_here && (corked || muted)) {
>                  pa_log_debug("Found a '%s' stream that should be uncorked/unmuted.", cork_role);
> @@ -161,7 +161,7 @@ static pa_hook_result_t process(struct userdata *u, pa_sink_input *i, bool creat
>      pa_sink_input_assert_ref(i);
>  
>      if (!create)
> -        pa_hashmap_remove(u->cork_state, i);
> +        pa_hashmap_remove(u->cork_state, i, NULL);
>  
>      if (!(role = pa_proplist_gets(i->proplist, PA_PROP_MEDIA_ROLE)))
>          return PA_HOOK_OK;
> @@ -304,7 +304,7 @@ void pa__done(pa_module *m) {
>          pa_hook_slot_free(u->sink_input_move_finish_slot);
>  
>      if (u->cork_state)
> -        pa_hashmap_free(u->cork_state, NULL);
> +        pa_hashmap_free(u->cork_state, NULL, NULL);
>  
>      pa_xfree(u);
>  
> diff --git a/src/modules/module-stream-restore.c b/src/modules/module-stream-restore.c
> index 735dcde..b2ce102 100644
> --- a/src/modules/module-stream-restore.c
> +++ b/src/modules/module-stream-restore.c
> @@ -949,7 +949,7 @@ static void handle_entry_remove(DBusConnection *conn, DBusMessage *msg, void *us
>      send_entry_removed_signal(de);
>      trigger_save(de->userdata);
>  
> -    pa_assert_se(pa_hashmap_remove(de->userdata->dbus_entries, de->entry_name));
> +    pa_assert_se(pa_hashmap_remove(de->userdata->dbus_entries, de->entry_name, NULL));
>      dbus_entry_free(de);
>  
>      pa_dbus_send_empty_reply(conn, msg);
> @@ -2099,7 +2099,7 @@ static int extension_cb(pa_native_protocol *p, pa_module *m, pa_native_connectio
>  
>                  PA_HASHMAP_FOREACH(de, u->dbus_entries, state) {
>                      send_entry_removed_signal(de);
> -                    dbus_entry_free(pa_hashmap_remove(u->dbus_entries, de->entry_name));
> +                    dbus_entry_free(pa_hashmap_remove(u->dbus_entries, de->entry_name, NULL));
>                  }
>  #endif
>                  pa_database_clear(u->database);
> @@ -2211,7 +2211,7 @@ static int extension_cb(pa_native_protocol *p, pa_module *m, pa_native_connectio
>  #ifdef HAVE_DBUS
>                  if ((de = pa_hashmap_get(u->dbus_entries, name))) {
>                      send_entry_removed_signal(de);
> -                    dbus_entry_free(pa_hashmap_remove(u->dbus_entries, name));
> +                    dbus_entry_free(pa_hashmap_remove(u->dbus_entries, name, NULL));
>                  }
>  #endif
>  
> @@ -2507,7 +2507,7 @@ void pa__done(pa_module*m) {
>          pa_assert_se(pa_dbus_protocol_unregister_extension(u->dbus_protocol, INTERFACE_STREAM_RESTORE) >= 0);
>          pa_assert_se(pa_dbus_protocol_remove_interface(u->dbus_protocol, OBJECT_PATH, stream_restore_interface_info.name) >= 0);
>  
> -        pa_hashmap_free(u->dbus_entries, (pa_free_cb_t) dbus_entry_free);
> +        pa_hashmap_free(u->dbus_entries, NULL, (pa_free_cb_t) dbus_entry_free);
>  
>          pa_dbus_protocol_unref(u->dbus_protocol);
>      }
> diff --git a/src/modules/module-suspend-on-idle.c b/src/modules/module-suspend-on-idle.c
> index 6d49acb..1ef77f8 100644
> --- a/src/modules/module-suspend-on-idle.c
> +++ b/src/modules/module-suspend-on-idle.c
> @@ -376,7 +376,7 @@ static pa_hook_result_t device_unlink_hook_cb(pa_core *c, pa_object *o, struct u
>      pa_object_assert_ref(o);
>      pa_assert(u);
>  
> -    if ((d = pa_hashmap_remove(u->device_infos, o)))
> +    if ((d = pa_hashmap_remove(u->device_infos, o, NULL)))
>          device_info_free(d);
>  
>      return PA_HOOK_OK;
> @@ -518,7 +518,7 @@ void pa__done(pa_module*m) {
>      if (u->source_output_state_changed_slot)
>          pa_hook_slot_free(u->source_output_state_changed_slot);
>  
> -    pa_hashmap_free(u->device_infos, (pa_free_cb_t) device_info_free);
> +    pa_hashmap_free(u->device_infos, NULL, (pa_free_cb_t) device_info_free);
>  
>      pa_xfree(u);
>  }
> diff --git a/src/modules/module-systemd-login.c b/src/modules/module-systemd-login.c
> index 18f8cc5..2c60a3a 100644
> --- a/src/modules/module-systemd-login.c
> +++ b/src/modules/module-systemd-login.c
> @@ -128,7 +128,7 @@ static int get_session_list(struct userdata *u) {
>           * this here. */
>  
>          for (s = sessions; *s; s++) {
> -            o = pa_hashmap_remove(u->previous_sessions, *s);
> +            o = pa_hashmap_remove(u->previous_sessions, *s, NULL);
>              if (o)
>                  pa_hashmap_put(u->sessions, o->id, o);
>              else
> @@ -140,7 +140,7 @@ static int get_session_list(struct userdata *u) {
>          free(sessions);
>      }
>  
> -    pa_hashmap_remove_all(u->previous_sessions, (pa_free_cb_t) free_session);
> +    pa_hashmap_remove_all(u->previous_sessions, NULL, (pa_free_cb_t) free_session);
>  
>      return 0;
>  }
> @@ -219,8 +219,8 @@ void pa__done(pa_module *m) {
>          return;
>  
>      if (u->sessions) {
> -        pa_hashmap_free(u->sessions, (pa_free_cb_t) free_session);
> -        pa_hashmap_free(u->previous_sessions, (pa_free_cb_t) free_session);
> +        pa_hashmap_free(u->sessions, NULL, (pa_free_cb_t)free_session);
> +        pa_hashmap_free(u->previous_sessions, NULL, (pa_free_cb_t)free_session);
>      }
>  
>      if (u->io)
> diff --git a/src/modules/module-udev-detect.c b/src/modules/module-udev-detect.c
> index fcedfcd..0dd5793 100644
> --- a/src/modules/module-udev-detect.c
> +++ b/src/modules/module-udev-detect.c
> @@ -436,7 +436,7 @@ static void remove_card(struct userdata *u, struct udev_device *dev) {
>      pa_assert(u);
>      pa_assert(dev);
>  
> -    if (!(d = pa_hashmap_remove(u->devices, udev_device_get_devpath(dev))))
> +    if (!(d = pa_hashmap_remove(u->devices, udev_device_get_devpath(dev), NULL)))
>          return;
>  
>      pa_log_info("Card %s removed.", d->path);
> @@ -841,7 +841,7 @@ void pa__done(pa_module *m) {
>          pa_close(u->inotify_fd);
>  
>      if (u->devices)
> -        pa_hashmap_free(u->devices, (pa_free_cb_t) device_free);
> +        pa_hashmap_free(u->devices, NULL, (pa_free_cb_t) device_free);
>  
>      pa_xfree(u);
>  }
> diff --git a/src/modules/module-zeroconf-discover.c b/src/modules/module-zeroconf-discover.c
> index 4ec3747..0652e9a 100644
> --- a/src/modules/module-zeroconf-discover.c
> +++ b/src/modules/module-zeroconf-discover.c
> @@ -282,7 +282,7 @@ static void browser_cb(
>  
>          if ((t2 = pa_hashmap_get(u->tunnels, t))) {
>              pa_module_unload_request_by_index(u->core, t2->module_index, true);
> -            pa_hashmap_remove(u->tunnels, t2);
> +            pa_hashmap_remove(u->tunnels, t2, NULL);
>              tunnel_free(t2);
>          }
>      }
> @@ -421,12 +421,12 @@ void pa__done(pa_module*m) {
>      if (u->tunnels) {
>          struct tunnel *t;
>  
> -        while ((t = pa_hashmap_steal_first(u->tunnels))) {
> +        while ((t = pa_hashmap_steal_first(u->tunnels, NULL))) {
>              pa_module_unload_request_by_index(u->core, t->module_index, true);
>              tunnel_free(t);
>          }
>  
> -        pa_hashmap_free(u->tunnels, NULL);
> +        pa_hashmap_free(u->tunnels, NULL, NULL);
>      }
>  
>      pa_xfree(u);
> diff --git a/src/modules/module-zeroconf-publish.c b/src/modules/module-zeroconf-publish.c
> index 3350008..fe1f8f8 100644
> --- a/src/modules/module-zeroconf-publish.c
> +++ b/src/modules/module-zeroconf-publish.c
> @@ -374,7 +374,7 @@ finish:
>  
>      /* Remove this service */
>      if (r < 0) {
> -        pa_hashmap_remove(s->userdata->services, s->key);
> +        pa_hashmap_remove(s->userdata->services, s->key, NULL);
>          service_free(s);
>      }
>  
> @@ -474,7 +474,7 @@ static pa_hook_result_t device_unlink_cb(pa_core *c, pa_object *o, struct userda
>  
>      pa_threaded_mainloop_lock(u->mainloop);
>  
> -    if ((s = pa_hashmap_remove(u->services, o)))
> +    if ((s = pa_hashmap_remove(u->services, o, NULL)))
>          service_free(s);
>  
>      pa_threaded_mainloop_unlock(u->mainloop);
> @@ -786,7 +786,7 @@ fail:
>  static void client_free(pa_mainloop_api *api PA_GCC_UNUSED, void *userdata) {
>      struct userdata *u = (struct userdata *) userdata;
>  
> -    pa_hashmap_free(u->services, (pa_free_cb_t) service_free);
> +    pa_hashmap_free(u->services, NULL, (pa_free_cb_t) service_free);
>  
>      if (u->main_entry_group)
>          avahi_entry_group_free(u->main_entry_group);
> diff --git a/src/modules/raop/module-raop-discover.c b/src/modules/raop/module-raop-discover.c
> index c7efe9a..9ea2848 100644
> --- a/src/modules/raop/module-raop-discover.c
> +++ b/src/modules/raop/module-raop-discover.c
> @@ -257,7 +257,7 @@ static void browser_cb(
>  
>          if ((t2 = pa_hashmap_get(u->tunnels, t))) {
>              pa_module_unload_request_by_index(u->core, t2->module_index, true);
> -            pa_hashmap_remove(u->tunnels, t2);
> +            pa_hashmap_remove(u->tunnels, t2, NULL);
>              tunnel_free(t2);
>          }
>      }
> @@ -376,12 +376,12 @@ void pa__done(pa_module*m) {
>      if (u->tunnels) {
>          struct tunnel *t;
>  
> -        while ((t = pa_hashmap_steal_first(u->tunnels))) {
> +        while ((t = pa_hashmap_steal_first(u->tunnels, NULL))) {
>              pa_module_unload_request_by_index(u->core, t->module_index, true);
>              tunnel_free(t);
>          }
>  
> -        pa_hashmap_free(u->tunnels, NULL);
> +        pa_hashmap_free(u->tunnels, NULL, NULL);
>      }
>  
>      pa_xfree(u);
> diff --git a/src/modules/rtp/headerlist.c b/src/modules/rtp/headerlist.c
> index 9e95e3c..bfc97cd 100644
> --- a/src/modules/rtp/headerlist.c
> +++ b/src/modules/rtp/headerlist.c
> @@ -56,7 +56,7 @@ pa_headerlist* pa_headerlist_new(void) {
>  }
>  
>  void pa_headerlist_free(pa_headerlist* p) {
> -    pa_hashmap_free(MAKE_HASHMAP(p), (pa_free_cb_t) header_free);
> +    pa_hashmap_free(MAKE_HASHMAP(p), NULL, (pa_free_cb_t) header_free);
>  }
>  
>  int pa_headerlist_puts(pa_headerlist *p, const char *key, const char *value) {
> @@ -134,7 +134,7 @@ int pa_headerlist_remove(pa_headerlist *p, const char *key) {
>      pa_assert(p);
>      pa_assert(key);
>  
> -    if (!(hdr = pa_hashmap_remove(MAKE_HASHMAP(p), key)))
> +    if (!(hdr = pa_hashmap_remove(MAKE_HASHMAP(p), key, NULL)))
>          return -1;
>  
>      header_free(hdr);
> diff --git a/src/modules/rtp/module-rtp-recv.c b/src/modules/rtp/module-rtp-recv.c
> index 7ff2c75..43505fa 100644
> --- a/src/modules/rtp/module-rtp-recv.c
> +++ b/src/modules/rtp/module-rtp-recv.c
> @@ -186,7 +186,7 @@ static void sink_input_kill(pa_sink_input* i) {
>      pa_sink_input_assert_ref(i);
>      pa_assert_se(s = i->userdata);
>  
> -    pa_hashmap_remove(s->userdata->by_origin, s->sdp_info.origin);
> +    pa_hashmap_remove(s->userdata->by_origin, s->sdp_info.origin, NULL);
>      session_free(s);
>  }
>  
> @@ -635,7 +635,7 @@ static void sap_event_cb(pa_mainloop_api *m, pa_io_event *e, int fd, pa_io_event
>  
>      if (goodbye) {
>  
> -        if ((s = pa_hashmap_remove(u->by_origin, info.origin)))
> +        if ((s = pa_hashmap_remove(u->by_origin, info.origin, NULL)))
>              session_free(s);
>  
>          pa_sdp_info_destroy(&info);
> @@ -675,7 +675,7 @@ static void check_death_event_cb(pa_mainloop_api *m, pa_time_event *t, const str
>          k = pa_atomic_load(&s->timestamp);
>  
>          if (k + DEATH_TIMEOUT < now.tv_sec) {
> -            pa_hashmap_remove(u->by_origin, s->sdp_info.origin);
> +            pa_hashmap_remove(u->by_origin, s->sdp_info.origin, NULL);
>              session_free(s);
>          }
>      }
> @@ -770,7 +770,7 @@ void pa__done(pa_module*m) {
>      pa_sap_context_destroy(&u->sap_context);
>  
>      if (u->by_origin)
> -        pa_hashmap_free(u->by_origin, (pa_free_cb_t) session_free);
> +        pa_hashmap_free(u->by_origin, NULL, (pa_free_cb_t) session_free);
>  
>      pa_xfree(u->sink_name);
>      pa_xfree(u);
> diff --git a/src/pulse/context.c b/src/pulse/context.c
> index 1ba2672..4d3cc0e 100644
> --- a/src/pulse/context.c
> +++ b/src/pulse/context.c
> @@ -241,9 +241,9 @@ static void context_free(pa_context *c) {
>  #endif
>  
>      if (c->record_streams)
> -        pa_hashmap_free(c->record_streams, NULL);
> +        pa_hashmap_free(c->record_streams, NULL, NULL);
>      if (c->playback_streams)
> -        pa_hashmap_free(c->playback_streams, NULL);
> +        pa_hashmap_free(c->playback_streams, NULL, NULL);
>  
>      if (c->mempool)
>          pa_mempool_free(c->mempool);
> diff --git a/src/pulse/proplist.c b/src/pulse/proplist.c
> index 6e91103..ca3a4f9 100644
> --- a/src/pulse/proplist.c
> +++ b/src/pulse/proplist.c
> @@ -70,7 +70,7 @@ pa_proplist* pa_proplist_new(void) {
>  void pa_proplist_free(pa_proplist* p) {
>      pa_assert(p);
>  
> -    pa_hashmap_free(MAKE_HASHMAP(p), (pa_free_cb_t) property_free);
> +    pa_hashmap_free(MAKE_HASHMAP(p), NULL, (pa_free_cb_t) property_free);
>  }
>  
>  /** Will accept only valid UTF-8 */
> @@ -351,7 +351,7 @@ int pa_proplist_unset(pa_proplist *p, const char *key) {
>      if (!pa_proplist_key_valid(key))
>          return -1;
>  
> -    if (!(prop = pa_hashmap_remove(MAKE_HASHMAP(p), key)))
> +    if (!(prop = pa_hashmap_remove(MAKE_HASHMAP(p), key, NULL)))
>          return -2;
>  
>      property_free(prop);
> @@ -654,7 +654,7 @@ int pa_proplist_contains(pa_proplist *p, const char *key) {
>  void pa_proplist_clear(pa_proplist *p) {
>      pa_assert(p);
>  
> -    pa_hashmap_remove_all(MAKE_HASHMAP(p), (pa_free_cb_t) property_free);
> +    pa_hashmap_remove_all(MAKE_HASHMAP(p), NULL, (pa_free_cb_t) property_free);
>  }
>  
>  pa_proplist* pa_proplist_copy(const pa_proplist *p) {
> diff --git a/src/pulse/stream.c b/src/pulse/stream.c
> index 746179b..1ee1934 100644
> --- a/src/pulse/stream.c
> +++ b/src/pulse/stream.c
> @@ -260,7 +260,8 @@ static void stream_unlink(pa_stream *s) {
>          pa_pdispatch_unregister_reply(s->context->pdispatch, s);
>  
>      if (s->channel_valid) {
> -        pa_hashmap_remove((s->direction == PA_STREAM_RECORD) ? s->context->record_streams : s->context->playback_streams, PA_UINT32_TO_PTR(s->channel));
> +        pa_hashmap_remove((s->direction == PA_STREAM_RECORD) ? s->context->record_streams : s->context->playback_streams,
> +                          PA_UINT32_TO_PTR(s->channel), NULL);
>          s->channel = 0;
>          s->channel_valid = false;
>      }
> diff --git a/src/pulsecore/card.c b/src/pulsecore/card.c
> index c771cac..6ea1e8f 100644
> --- a/src/pulsecore/card.c
> +++ b/src/pulsecore/card.c
> @@ -128,10 +128,10 @@ void pa_card_new_data_done(pa_card_new_data *data) {
>      pa_proplist_free(data->proplist);
>  
>      if (data->profiles)
> -        pa_hashmap_free(data->profiles, (pa_free_cb_t) pa_card_profile_free);
> +        pa_hashmap_free(data->profiles, NULL, (pa_free_cb_t) pa_card_profile_free);
>  
>      if (data->ports)
> -        pa_hashmap_free(data->ports, (pa_free_cb_t) pa_device_port_unref);
> +        pa_hashmap_free(data->ports, NULL, (pa_free_cb_t) pa_device_port_unref);
>  
>      pa_xfree(data->name);
>      pa_xfree(data->active_profile);
> @@ -239,10 +239,10 @@ void pa_card_free(pa_card *c) {
>      pa_assert(pa_idxset_isempty(c->sources));
>      pa_idxset_free(c->sources, NULL);
>  
> -    pa_hashmap_free(c->ports, (pa_free_cb_t) pa_device_port_unref);
> +    pa_hashmap_free(c->ports, NULL, (pa_free_cb_t) pa_device_port_unref);
>  
>      if (c->profiles)
> -        pa_hashmap_free(c->profiles, (pa_free_cb_t) pa_card_profile_free);
> +        pa_hashmap_free(c->profiles, NULL, (pa_free_cb_t) pa_card_profile_free);
>  
>      pa_proplist_free(c->proplist);
>      pa_xfree(c->driver);
> diff --git a/src/pulsecore/core.c b/src/pulsecore/core.c
> index b198822..9fb17dd 100644
> --- a/src/pulsecore/core.c
> +++ b/src/pulsecore/core.c
> @@ -194,10 +194,10 @@ static void core_free(pa_object *o) {
>      pa_idxset_free(c->sink_inputs, NULL);
>  
>      pa_assert(pa_hashmap_isempty(c->namereg));
> -    pa_hashmap_free(c->namereg, NULL);
> +    pa_hashmap_free(c->namereg, NULL, NULL);
>  
>      pa_assert(pa_hashmap_isempty(c->shared));
> -    pa_hashmap_free(c->shared, NULL);
> +    pa_hashmap_free(c->shared, NULL, NULL);
>  
>      pa_subscription_free_all(c);
>  
> diff --git a/src/pulsecore/database-simple.c b/src/pulsecore/database-simple.c
> index 0d22e5b..27a1710 100644
> --- a/src/pulsecore/database-simple.c
> +++ b/src/pulsecore/database-simple.c
> @@ -265,7 +265,7 @@ void pa_database_close(pa_database *database) {
>      pa_database_sync(database);
>      pa_xfree(db->filename);
>      pa_xfree(db->tmp_filename);
> -    pa_hashmap_free(db->map, (pa_free_cb_t) free_entry);
> +    pa_hashmap_free(db->map, NULL, (pa_free_cb_t) free_entry);
>      pa_xfree(db);
>  }
>  
> @@ -306,7 +306,7 @@ int pa_database_set(pa_database *database, const pa_datum *key, const pa_datum*
>          /* entry with same key exists in hashmap */
>          entry *r;
>          if (overwrite) {
> -            r = pa_hashmap_remove(db->map, key);
> +            r = pa_hashmap_remove(db->map, key, NULL);
>              pa_hashmap_put(db->map, &e->key, e);
>          } else {
>              /* won't overwrite, so clean new entry */
> @@ -327,7 +327,7 @@ int pa_database_unset(pa_database *database, const pa_datum *key) {
>      pa_assert(db);
>      pa_assert(key);
>  
> -    e = pa_hashmap_remove(db->map, key);
> +    e = pa_hashmap_remove(db->map, key, NULL);
>      if (!e)
>          return -1;
>  
> @@ -337,11 +337,11 @@ int pa_database_unset(pa_database *database, const pa_datum *key) {
>  }
>  
>  int pa_database_clear(pa_database *database) {
> -    simple_data *db = (simple_data*)database;
> +    simple_data *db = (simple_data*) database;
>  
>      pa_assert(db);
>  
> -    pa_hashmap_remove_all(db->map, (pa_free_cb_t) free_entry);
> +    pa_hashmap_remove_all(db->map, NULL, (pa_free_cb_t) free_entry);
>  
>      return 0;
>  }
> diff --git a/src/pulsecore/device-port.c b/src/pulsecore/device-port.c
> index 8bff5b6..46d617d 100644
> --- a/src/pulsecore/device-port.c
> +++ b/src/pulsecore/device-port.c
> @@ -98,7 +98,7 @@ static void device_port_free(pa_object *o) {
>          pa_proplist_free(p->proplist);
>  
>      if (p->profiles)
> -        pa_hashmap_free(p->profiles, NULL);
> +        pa_hashmap_free(p->profiles, NULL, NULL);
>  
>      pa_xfree(p->name);
>      pa_xfree(p->description);
> diff --git a/src/pulsecore/hashmap.c b/src/pulsecore/hashmap.c
> index 0629164..6f3ae68 100644
> --- a/src/pulsecore/hashmap.c
> +++ b/src/pulsecore/hashmap.c
> @@ -35,7 +35,7 @@
>  #define NBUCKETS 127
>  
>  struct hashmap_entry {
> -    const void *key;
> +    void *key;
>      void *value;
>  
>      struct hashmap_entry *bucket_next, *bucket_previous;
> @@ -68,7 +68,7 @@ pa_hashmap *pa_hashmap_new(pa_hash_func_t hash_func, pa_compare_func_t compare_f
>      return h;
>  }
>  
> -static void remove_entry(pa_hashmap *h, struct hashmap_entry *e) {
> +static void remove_entry(pa_hashmap *h, struct hashmap_entry *e, pa_free_cb_t key_free_cb) {
>      pa_assert(h);
>      pa_assert(e);
>  
> @@ -94,6 +94,9 @@ static void remove_entry(pa_hashmap *h, struct hashmap_entry *e) {
>          BY_HASH(h)[hash] = e->bucket_next;
>      }
>  
> +    if (key_free_cb)
> +        key_free_cb(e->key);
> +
>      if (pa_flist_push(PA_STATIC_FLIST_GET(entries), e) < 0)
>          pa_xfree(e);
>  
> @@ -101,10 +104,10 @@ static void remove_entry(pa_hashmap *h, struct hashmap_entry *e) {
>      h->n_entries--;
>  }
>  
> -void pa_hashmap_free(pa_hashmap *h, pa_free_cb_t free_cb) {
> +void pa_hashmap_free(pa_hashmap *h, pa_free_cb_t key_free_cb, pa_free_cb_t value_free_cb) {
>      pa_assert(h);
>  
> -    pa_hashmap_remove_all(h, free_cb);
> +    pa_hashmap_remove_all(h, key_free_cb, value_free_cb);
>      pa_xfree(h);
>  }
>  
> @@ -120,7 +123,7 @@ static struct hashmap_entry *hash_scan(pa_hashmap *h, unsigned hash, const void
>      return NULL;
>  }
>  
> -int pa_hashmap_put(pa_hashmap *h, const void *key, void *value) {
> +int pa_hashmap_put(pa_hashmap *h, void *key, void *value) {
>      struct hashmap_entry *e;
>      unsigned hash;
>  
> @@ -176,7 +179,7 @@ void* pa_hashmap_get(pa_hashmap *h, const void *key) {
>      return e->value;
>  }
>  
> -void* pa_hashmap_remove(pa_hashmap *h, const void *key) {
> +void* pa_hashmap_remove(pa_hashmap *h, const void *key, pa_free_cb_t key_free_cb) {
>      struct hashmap_entry *e;
>      unsigned hash;
>      void *data;
> @@ -189,21 +192,21 @@ void* pa_hashmap_remove(pa_hashmap *h, const void *key) {
>          return NULL;
>  
>      data = e->value;
> -    remove_entry(h, e);
> +    remove_entry(h, e, key_free_cb);
>  
>      return data;
>  }
>  
> -void pa_hashmap_remove_all(pa_hashmap *h, pa_free_cb_t free_cb) {
> +void pa_hashmap_remove_all(pa_hashmap *h, pa_free_cb_t key_free_cb, pa_free_cb_t value_free_cb) {
>      pa_assert(h);
>  
>      while (h->iterate_list_head) {
>          void *data;
>          data = h->iterate_list_head->value;
> -        remove_entry(h, h->iterate_list_head);
> +        remove_entry(h, h->iterate_list_head, key_free_cb);
>  
> -        if (free_cb)
> -            free_cb(data);
> +        if (value_free_cb)
> +            value_free_cb(data);
>      }
>  }
>  
> @@ -291,7 +294,7 @@ void* pa_hashmap_last(pa_hashmap *h) {
>      return h->iterate_list_tail->value;
>  }
>  
> -void* pa_hashmap_steal_first(pa_hashmap *h) {
> +void* pa_hashmap_steal_first(pa_hashmap *h, pa_free_cb_t key_free_cb) {
>      void *data;
>  
>      pa_assert(h);
> @@ -300,7 +303,7 @@ void* pa_hashmap_steal_first(pa_hashmap *h) {
>          return NULL;
>  
>      data = h->iterate_list_head->value;
> -    remove_entry(h, h->iterate_list_head);
> +    remove_entry(h, h->iterate_list_head, key_free_cb);
>  
>      return data;
>  }
> diff --git a/src/pulsecore/hashmap.h b/src/pulsecore/hashmap.h
> index a57fab3..7524099 100644
> --- a/src/pulsecore/hashmap.h
> +++ b/src/pulsecore/hashmap.h
> @@ -36,20 +36,20 @@ typedef struct pa_hashmap pa_hashmap;
>  /* Create a new hashmap. Use the specified functions for hashing and comparing objects in the map */
>  pa_hashmap *pa_hashmap_new(pa_hash_func_t hash_func, pa_compare_func_t compare_func);
>  
> -/* Free the hash table. Calls the specified function for every value in the table. The function may be NULL */
> -void pa_hashmap_free(pa_hashmap*, pa_free_cb_t free_cb);
> +/* Free the hash table. Calls the specified functions for every key and value in the table. The function may be NULL */
> +void pa_hashmap_free(pa_hashmap*, pa_free_cb_t key_free_cb, pa_free_cb_t value_free_cbfree_cb);
>  
>  /* Add an entry to the hashmap. Returns non-zero when the entry already exists */
> -int pa_hashmap_put(pa_hashmap *h, const void *key, void *value);
> +int pa_hashmap_put(pa_hashmap *h, void *key, void *value);
>  
>  /* Return an entry from the hashmap */
>  void* pa_hashmap_get(pa_hashmap *h, const void *key);
>  
>  /* Returns the data of the entry while removing */
> -void* pa_hashmap_remove(pa_hashmap *h, const void *key);
> +void* pa_hashmap_remove(pa_hashmap *h, const void *key, pa_free_cb_t key_free_cb);
>  
> -/* If free_cb is not NULL, it's called for each entry. */
> -void pa_hashmap_remove_all(pa_hashmap *h, pa_free_cb_t free_cb);
> +/* If the free_cbs are not NULL, they are called for each key and entry. */
> +void pa_hashmap_remove_all(pa_hashmap *h, pa_free_cb_t key_free_cb, pa_free_cb_t value_free_cb);
>  
>  /* Return the current number of entries of the hashmap */
>  unsigned pa_hashmap_size(pa_hashmap *h);
> @@ -69,7 +69,7 @@ void *pa_hashmap_iterate(pa_hashmap *h, void **state, const void**key);
>  void *pa_hashmap_iterate_backwards(pa_hashmap *h, void **state, const void**key);
>  
>  /* Remove the oldest entry in the hashmap and return it */
> -void *pa_hashmap_steal_first(pa_hashmap *h);
> +void *pa_hashmap_steal_first(pa_hashmap *h, pa_free_cb_t key_free_cb);
>  
>  /* Return the oldest entry in the hashmap */
>  void* pa_hashmap_first(pa_hashmap *h);
> diff --git a/src/pulsecore/memblock.c b/src/pulsecore/memblock.c
> index 2d83b72..9ebc66c 100644
> --- a/src/pulsecore/memblock.c
> +++ b/src/pulsecore/memblock.c
> @@ -541,7 +541,7 @@ static void memblock_free(pa_memblock *b) {
>  
>              pa_mutex_lock(import->mutex);
>  
> -            pa_assert_se(pa_hashmap_remove(import->blocks, PA_UINT32_TO_PTR(b->per_type.imported.id)));
> +            pa_assert_se(pa_hashmap_remove(import->blocks, PA_UINT32_TO_PTR(b->per_type.imported.id), NULL));
>  
>              pa_assert(segment->n_blocks >= 1);
>              if (-- segment->n_blocks <= 0)
> @@ -701,7 +701,7 @@ static void memblock_replace_import(pa_memblock *b) {
>  
>      pa_mutex_lock(import->mutex);
>  
> -    pa_assert_se(pa_hashmap_remove(import->blocks, PA_UINT32_TO_PTR(b->per_type.imported.id)));
> +    pa_assert_se(pa_hashmap_remove(import->blocks, PA_UINT32_TO_PTR(b->per_type.imported.id), NULL));
>  
>      memblock_make_local(b);
>  
> @@ -929,7 +929,7 @@ static pa_memimport_segment* segment_attach(pa_memimport *i, uint32_t shm_id) {
>  static void segment_detach(pa_memimport_segment *seg) {
>      pa_assert(seg);
>  
> -    pa_hashmap_remove(seg->import->segments, PA_UINT32_TO_PTR(seg->memory.id));
> +    pa_hashmap_remove(seg->import->segments, PA_UINT32_TO_PTR(seg->memory.id), NULL);
>      pa_shm_free(&seg->memory);
>  
>      if (seg->trap)
> @@ -964,8 +964,8 @@ void pa_memimport_free(pa_memimport *i) {
>  
>      pa_mutex_unlock(i->pool->mutex);
>  
> -    pa_hashmap_free(i->blocks, NULL);
> -    pa_hashmap_free(i->segments, NULL);
> +    pa_hashmap_free(i->blocks, NULL, NULL);
> +    pa_hashmap_free(i->segments, NULL, NULL);
>  
>      pa_mutex_free(i->mutex);
>  
> diff --git a/src/pulsecore/modargs.c b/src/pulsecore/modargs.c
> index 09ca9fc..8d8964d 100644
> --- a/src/pulsecore/modargs.c
> +++ b/src/pulsecore/modargs.c
> @@ -259,8 +259,8 @@ static void free_func(void *p) {
>  void pa_modargs_free(pa_modargs*ma) {
>      pa_assert(ma);
>  
> -    pa_hashmap_free(ma->raw, free_func);
> -    pa_hashmap_free(ma->unescaped, free_func);
> +    pa_hashmap_free(ma->raw, NULL, free_func);
> +    pa_hashmap_free(ma->unescaped, NULL, free_func);
>      pa_xfree(ma);
>  }
>  
> diff --git a/src/pulsecore/mutex-win32.c b/src/pulsecore/mutex-win32.c
> index 01e8b4a..aa80fb0 100644
> --- a/src/pulsecore/mutex-win32.c
> +++ b/src/pulsecore/mutex-win32.c
> @@ -80,7 +80,7 @@ pa_cond *pa_cond_new(void) {
>  void pa_cond_free(pa_cond *c) {
>      assert(c);
>  
> -    pa_hashmap_free(c->wait_events, NULL);
> +    pa_hashmap_free(c->wait_events, NULL, NULL);
>      pa_xfree(c);
>  }
>  
> @@ -125,7 +125,7 @@ int pa_cond_wait(pa_cond *c, pa_mutex *m) {
>  
>      pa_mutex_lock(m);
>  
> -    pa_hashmap_remove(c->wait_events, event);
> +    pa_hashmap_remove(c->wait_events, event, NULL);
>  
>      CloseHandle(event);
>  
> diff --git a/src/pulsecore/namereg.c b/src/pulsecore/namereg.c
> index 7704abe..a8a6ff6 100644
> --- a/src/pulsecore/namereg.c
> +++ b/src/pulsecore/namereg.c
> @@ -190,7 +190,7 @@ void pa_namereg_unregister(pa_core *c, const char *name) {
>      pa_assert(c);
>      pa_assert(name);
>  
> -    pa_assert_se(e = pa_hashmap_remove(c->namereg, name));
> +    pa_assert_se(e = pa_hashmap_remove(c->namereg, name, NULL));
>  
>      if (c->default_sink == e->data)
>          pa_namereg_set_default_sink(c, NULL);
> diff --git a/src/pulsecore/protocol-dbus.c b/src/pulsecore/protocol-dbus.c
> index 0ff4d83..02deee2 100644
> --- a/src/pulsecore/protocol-dbus.c
> +++ b/src/pulsecore/protocol-dbus.c
> @@ -169,8 +169,8 @@ void pa_dbus_protocol_unref(pa_dbus_protocol *p) {
>      pa_assert(pa_hashmap_isempty(p->connections));
>      pa_assert(pa_idxset_isempty(p->extensions));
>  
> -    pa_hashmap_free(p->objects, NULL);
> -    pa_hashmap_free(p->connections, NULL);
> +    pa_hashmap_free(p->objects, NULL, NULL);
> +    pa_hashmap_free(p->connections, NULL, NULL);
>      pa_idxset_free(p->extensions, NULL);
>  
>      for (i = 0; i < PA_DBUS_PROTOCOL_HOOK_MAX; ++i)
> @@ -649,7 +649,7 @@ static pa_hashmap *create_method_handlers(const pa_dbus_interface_info *info) {
>          h->n_arguments = info->method_handlers[i].n_arguments;
>          h->receive_cb = info->method_handlers[i].receive_cb;
>  
> -        pa_hashmap_put(handlers, h->method_name, h);
> +        pa_hashmap_put(handlers, (char *) h->method_name, h);
>      }
>  
>      return handlers;
> @@ -674,7 +674,7 @@ static pa_hashmap *extract_method_signatures(pa_hashmap *method_handlers) {
>                  pa_strbuf_puts(sig_buf, handler->arguments[i].type);
>          }
>  
> -        pa_hashmap_put(signatures, handler->method_name, pa_strbuf_tostring_free(sig_buf));
> +        pa_hashmap_put(signatures, (char *) handler->method_name, pa_strbuf_tostring_free(sig_buf));
>      }
>  
>      return signatures;
> @@ -696,7 +696,7 @@ static pa_hashmap *create_property_handlers(const pa_dbus_interface_info *info)
>          h->get_cb = info->property_handlers[i].get_cb;
>          h->set_cb = info->property_handlers[i].set_cb;
>  
> -        pa_hashmap_put(handlers, h->property_name, h);
> +        pa_hashmap_put(handlers, (char *) h->property_name, h);
>      }
>  
>      return handlers;
> @@ -827,7 +827,7 @@ int pa_dbus_protocol_remove_interface(pa_dbus_protocol *p, const char* path, con
>      if (!(obj_entry = pa_hashmap_get(p->objects, path)))
>          return -1;
>  
> -    if (!(iface_entry = pa_hashmap_remove(obj_entry->interfaces, interface)))
> +    if (!(iface_entry = pa_hashmap_remove(obj_entry->interfaces, interface, NULL)))
>          return -1;
>  
>      update_introspection(obj_entry);
> @@ -835,9 +835,9 @@ int pa_dbus_protocol_remove_interface(pa_dbus_protocol *p, const char* path, con
>      pa_log_debug("Interface %s removed from object %s", iface_entry->name, obj_entry->path);
>  
>      pa_xfree(iface_entry->name);
> -    pa_hashmap_free(iface_entry->method_signatures, pa_xfree);
> -    pa_hashmap_free(iface_entry->method_handlers, (pa_free_cb_t) method_handler_free);
> -    pa_hashmap_free(iface_entry->property_handlers, (pa_free_cb_t) property_handler_free);
> +    pa_hashmap_free(iface_entry->method_signatures, NULL, pa_xfree);
> +    pa_hashmap_free(iface_entry->method_handlers, NULL, (pa_free_cb_t) method_handler_free);
> +    pa_hashmap_free(iface_entry->property_handlers, NULL, (pa_free_cb_t) property_handler_free);
>  
>      for (i = 0; i < iface_entry->n_signals; ++i) {
>          unsigned j;
> @@ -859,9 +859,9 @@ int pa_dbus_protocol_remove_interface(pa_dbus_protocol *p, const char* path, con
>      if (pa_hashmap_isempty(obj_entry->interfaces)) {
>          unregister_object(p, obj_entry);
>  
> -        pa_hashmap_remove(p->objects, path);
> +        pa_hashmap_remove(p->objects, path, NULL);
>          pa_xfree(obj_entry->path);
> -        pa_hashmap_free(obj_entry->interfaces, NULL);
> +        pa_hashmap_free(obj_entry->interfaces, NULL, NULL);
>          pa_xfree(obj_entry->introspection);
>          pa_xfree(obj_entry);
>      }
> @@ -941,14 +941,14 @@ int pa_dbus_protocol_unregister_connection(pa_dbus_protocol *p, DBusConnection *
>      pa_assert(p);
>      pa_assert(conn);
>  
> -    if (!(conn_entry = pa_hashmap_remove(p->connections, conn)))
> +    if (!(conn_entry = pa_hashmap_remove(p->connections, conn, NULL)))
>          return -1;
>  
>      unregister_all_objects(p, conn);
>  
>      dbus_connection_unref(conn_entry->connection);
>      pa_idxset_free(conn_entry->all_signals_objects, pa_xfree);
> -    pa_hashmap_free(conn_entry->listening_signals, (pa_free_cb_t) signal_paths_entry_free);
> +    pa_hashmap_free(conn_entry->listening_signals, NULL, (pa_free_cb_t) signal_paths_entry_free);
>      pa_xfree(conn_entry);
>  
>      return 0;
> @@ -992,7 +992,7 @@ void pa_dbus_protocol_add_signal_listener(
>  
>          /* Replace the old signal paths entry for this signal with a new
>           * one. */
> -        if ((signal_paths_entry = pa_hashmap_remove(conn_entry->listening_signals, signal_name)))
> +        if ((signal_paths_entry = pa_hashmap_remove(conn_entry->listening_signals, signal_name, NULL)))
>              signal_paths_entry_free(signal_paths_entry);
>          signal_paths_entry = signal_paths_entry_new(signal_name);
>  
> @@ -1006,7 +1006,7 @@ void pa_dbus_protocol_add_signal_listener(
>  
>          /* We're not interested in individual signals anymore, so let's empty
>           * listening_signals. */
> -        pa_hashmap_remove_all(conn_entry->listening_signals, (pa_free_cb_t) signal_paths_entry_free);
> +        pa_hashmap_remove_all(conn_entry->listening_signals, NULL, (pa_free_cb_t) signal_paths_entry_free);
>  
>          for (i = 0; i < n_objects; ++i)
>              pa_idxset_put(conn_entry->all_signals_objects, pa_xstrdup(objects[i]), NULL);
> @@ -1023,13 +1023,13 @@ void pa_dbus_protocol_remove_signal_listener(pa_dbus_protocol *p, DBusConnection
>      pa_assert_se((conn_entry = pa_hashmap_get(p->connections, conn)));
>  
>      if (signal_name) {
> -        if ((signal_paths_entry = pa_hashmap_remove(conn_entry->listening_signals, signal_name)))
> +        if ((signal_paths_entry = pa_hashmap_remove(conn_entry->listening_signals, signal_name, NULL)))
>              signal_paths_entry_free(signal_paths_entry);
>  
>      } else {
>          conn_entry->listening_for_all_signals = false;
>          pa_idxset_remove_all(conn_entry->all_signals_objects, pa_xfree);
> -        pa_hashmap_remove_all(conn_entry->listening_signals, (pa_free_cb_t) signal_paths_entry_free);
> +        pa_hashmap_remove_all(conn_entry->listening_signals, NULL, (pa_free_cb_t) signal_paths_entry_free);
>      }
>  }
>  
> diff --git a/src/pulsecore/protocol-native.c b/src/pulsecore/protocol-native.c
> index 9342c1a..42f1e4d 100644
> --- a/src/pulsecore/protocol-native.c
> +++ b/src/pulsecore/protocol-native.c
> @@ -5139,7 +5139,7 @@ void pa_native_protocol_unref(pa_native_protocol *p) {
>      for (h = 0; h < PA_NATIVE_HOOK_MAX; h++)
>          pa_hook_done(&p->hooks[h]);
>  
> -    pa_hashmap_free(p->extensions, NULL);
> +    pa_hashmap_free(p->extensions, NULL, NULL);
>  
>      pa_assert_se(pa_shared_remove(p->core, "native-protocol") >= 0);
>  
> @@ -5196,7 +5196,7 @@ void pa_native_protocol_remove_ext(pa_native_protocol *p, pa_module *m) {
>      pa_assert(PA_REFCNT_VALUE(p) >= 1);
>      pa_assert(m);
>  
> -    pa_assert_se(pa_hashmap_remove(p->extensions, m));
> +    pa_assert_se(pa_hashmap_remove(p->extensions, m, NULL));
>  }
>  
>  pa_native_options* pa_native_options_new(void) {
> diff --git a/src/pulsecore/shared.c b/src/pulsecore/shared.c
> index 368a6c3..ea725d7 100644
> --- a/src/pulsecore/shared.c
> +++ b/src/pulsecore/shared.c
> @@ -91,7 +91,7 @@ int pa_shared_remove(pa_core *c, const char *name) {
>      pa_assert(name);
>      pa_assert(c->shared);
>  
> -    if (!(p = pa_hashmap_remove(c->shared, name)))
> +    if (!(p = pa_hashmap_remove(c->shared, name, NULL)))
>          return -1;
>  
>      shared_free(p);
> diff --git a/src/pulsecore/sink-input.c b/src/pulsecore/sink-input.c
> index 47f169e..87ddad4 100644
> --- a/src/pulsecore/sink-input.c
> +++ b/src/pulsecore/sink-input.c
> @@ -241,10 +241,10 @@ void pa_sink_input_new_data_done(pa_sink_input_new_data *data) {
>          pa_format_info_free(data->format);
>  
>      if (data->volume_factor_items)
> -        pa_hashmap_free(data->volume_factor_items, (pa_free_cb_t) volume_factor_entry_free);
> +        pa_hashmap_free(data->volume_factor_items, NULL, (pa_free_cb_t) volume_factor_entry_free);
>  
>      if (data->volume_factor_sink_items)
> -        pa_hashmap_free(data->volume_factor_sink_items, (pa_free_cb_t) volume_factor_entry_free);
> +        pa_hashmap_free(data->volume_factor_sink_items, NULL, (pa_free_cb_t) volume_factor_entry_free);
>  
>      pa_proplist_free(data->proplist);
>  }
> @@ -766,13 +766,13 @@ static void sink_input_free(pa_object *o) {
>          pa_idxset_free(i->direct_outputs, NULL);
>  
>      if (i->thread_info.direct_outputs)
> -        pa_hashmap_free(i->thread_info.direct_outputs, NULL);
> +        pa_hashmap_free(i->thread_info.direct_outputs, NULL, NULL);
>  
>      if (i->volume_factor_items)
> -        pa_hashmap_free(i->volume_factor_items, (pa_free_cb_t) volume_factor_entry_free);
> +        pa_hashmap_free(i->volume_factor_items, NULL, (pa_free_cb_t) volume_factor_entry_free);
>  
>      if (i->volume_factor_sink_items)
> -        pa_hashmap_free(i->volume_factor_sink_items, (pa_free_cb_t) volume_factor_entry_free);
> +        pa_hashmap_free(i->volume_factor_sink_items, NULL, (pa_free_cb_t) volume_factor_entry_free);
>  
>      pa_xfree(i->driver);
>      pa_xfree(i);
> @@ -1340,7 +1340,7 @@ int pa_sink_input_remove_volume_factor(pa_sink_input *i, const char *key) {
>      pa_assert_ctl_context();
>      pa_assert(PA_SINK_INPUT_IS_LINKED(i->state));
>  
> -    v = pa_hashmap_remove(i->volume_factor_items, key);
> +    v = pa_hashmap_remove(i->volume_factor_items, key, NULL);
>  
>      if (!v)
>          return -1;
> diff --git a/src/pulsecore/sink.c b/src/pulsecore/sink.c
> index 3cdabd4..00bc29a 100644
> --- a/src/pulsecore/sink.c
> +++ b/src/pulsecore/sink.c
> @@ -142,7 +142,7 @@ void pa_sink_new_data_done(pa_sink_new_data *data) {
>      pa_proplist_free(data->proplist);
>  
>      if (data->ports)
> -        pa_hashmap_free(data->ports, (pa_free_cb_t) pa_device_port_unref);
> +        pa_hashmap_free(data->ports, NULL, (pa_free_cb_t) pa_device_port_unref);
>  
>      pa_xfree(data->name);
>      pa_xfree(data->active_port);
> @@ -730,7 +730,7 @@ static void sink_free(pa_object *o) {
>      }
>  
>      pa_idxset_free(s->inputs, NULL);
> -    pa_hashmap_free(s->thread_info.inputs, (pa_free_cb_t) pa_sink_input_unref);
> +    pa_hashmap_free(s->thread_info.inputs, NULL, (pa_free_cb_t) pa_sink_input_unref);
>  
>      if (s->silence.memblock)
>          pa_memblock_unref(s->silence.memblock);
> @@ -742,7 +742,7 @@ static void sink_free(pa_object *o) {
>          pa_proplist_free(s->proplist);
>  
>      if (s->ports)
> -        pa_hashmap_free(s->ports, (pa_free_cb_t) pa_device_port_unref);
> +        pa_hashmap_free(s->ports, NULL, (pa_free_cb_t) pa_device_port_unref);
>  
>      pa_xfree(s);
>  }
> @@ -2543,7 +2543,7 @@ int pa_sink_process_msg(pa_msgobject *o, int code, void *userdata, int64_t offse
>                  i->thread_info.sync_next = NULL;
>              }
>  
> -            if (pa_hashmap_remove(s->thread_info.inputs, PA_UINT32_TO_PTR(i->index)))
> +            if (pa_hashmap_remove(s->thread_info.inputs, PA_UINT32_TO_PTR(i->index), NULL))
>                  pa_sink_input_unref(i);
>  
>              pa_sink_invalidate_requested_latency(s, true);
> @@ -2626,7 +2626,7 @@ int pa_sink_process_msg(pa_msgobject *o, int code, void *userdata, int64_t offse
>              i->thread_info.attached = false;
>  
>              /* Let's remove the sink input ...*/
> -            if (pa_hashmap_remove(s->thread_info.inputs, PA_UINT32_TO_PTR(i->index)))
> +            if (pa_hashmap_remove(s->thread_info.inputs, PA_UINT32_TO_PTR(i->index), NULL))
>                  pa_sink_input_unref(i);
>  
>              pa_sink_invalidate_requested_latency(s, true);
> diff --git a/src/pulsecore/source.c b/src/pulsecore/source.c
> index 9c492c1..b14b9c8 100644
> --- a/src/pulsecore/source.c
> +++ b/src/pulsecore/source.c
> @@ -133,7 +133,7 @@ void pa_source_new_data_done(pa_source_new_data *data) {
>      pa_proplist_free(data->proplist);
>  
>      if (data->ports)
> -        pa_hashmap_free(data->ports, (pa_free_cb_t) pa_device_port_unref);
> +        pa_hashmap_free(data->ports, NULL, (pa_free_cb_t) pa_device_port_unref);
>  
>      pa_xfree(data->name);
>      pa_xfree(data->active_port);
> @@ -660,7 +660,7 @@ static void source_free(pa_object *o) {
>      pa_log_info("Freeing source %u \"%s\"", s->index, s->name);
>  
>      pa_idxset_free(s->outputs, NULL);
> -    pa_hashmap_free(s->thread_info.outputs, (pa_free_cb_t) pa_source_output_unref);
> +    pa_hashmap_free(s->thread_info.outputs, NULL, (pa_free_cb_t) pa_source_output_unref);
>  
>      if (s->silence.memblock)
>          pa_memblock_unref(s->silence.memblock);
> @@ -672,7 +672,7 @@ static void source_free(pa_object *o) {
>          pa_proplist_free(s->proplist);
>  
>      if (s->ports)
> -        pa_hashmap_free(s->ports, (pa_free_cb_t) pa_device_port_unref);
> +        pa_hashmap_free(s->ports, NULL, (pa_free_cb_t) pa_device_port_unref);
>  
>      pa_xfree(s);
>  }
> @@ -2024,11 +2024,11 @@ int pa_source_process_msg(pa_msgobject *object, int code, void *userdata, int64_
>              o->thread_info.attached = false;
>  
>              if (o->thread_info.direct_on_input) {
> -                pa_hashmap_remove(o->thread_info.direct_on_input->thread_info.direct_outputs, PA_UINT32_TO_PTR(o->index));
> +                pa_hashmap_remove(o->thread_info.direct_on_input->thread_info.direct_outputs, PA_UINT32_TO_PTR(o->index), NULL);
>                  o->thread_info.direct_on_input = NULL;
>              }
>  
> -            if (pa_hashmap_remove(s->thread_info.outputs, PA_UINT32_TO_PTR(o->index)))
> +            if (pa_hashmap_remove(s->thread_info.outputs, PA_UINT32_TO_PTR(o->index), NULL))
>                  pa_source_output_unref(o);
>  
>              pa_source_invalidate_requested_latency(s, true);
> 



-- 
David Henningsson, Canonical Ltd.
https://launchpad.net/~diwic


[Index of Archives]     [Linux Audio Users]     [AMD Graphics]     [Linux USB Devel]     [Linux Audio Users]     [Yosemite News]     [Linux Kernel]     [Linux SCSI]

  Powered by Linux