Fork us on GitHub Follow us on Facebook Follow us on Twitter

Changeset 6424800 in mainline


Ignore:
Timestamp:
2012-07-13T08:38:20Z (10 years ago)
Author:
Jan Vesely <jano.vesely@…>
Branches:
lfn, master, serial
Children:
ab07cf0
Parents:
1c33539
Message:

hound: Implement client removal

Location:
uspace/srv/audio/hound
Files:
3 edited

Legend:

Unmodified
Added
Removed
  • uspace/srv/audio/hound/hound.c

    r1c33539 r6424800  
    201201}
    202202
     203int hound_remove_source(hound_t *hound, audio_source_t *source)
     204{
     205        assert(hound);
     206        if (!source)
     207                return EINVAL;
     208        log_verbose("Removing source '%s'.", source->name);
     209        fibril_mutex_lock(&hound->list_guard);
     210        if (!list_member(&source->link, &hound->sources)) {
     211                fibril_mutex_unlock(&hound->list_guard);
     212                return EBUSY;
     213        }
     214        list_remove(&source->link);
     215        fibril_mutex_unlock(&hound->list_guard);
     216        return EOK;
     217}
     218
     219int hound_remove_sink(hound_t *hound, audio_sink_t *sink)
     220{
     221        assert(hound);
     222        if (!sink)
     223                return EINVAL;
     224        log_verbose("Removing sink '%s'.", sink->name);
     225        fibril_mutex_lock(&hound->list_guard);
     226        if (!list_empty(&sink->sources)) {
     227                fibril_mutex_unlock(&hound->list_guard);
     228                return EBUSY;
     229        }
     230        list_remove(&sink->link);
     231        fibril_mutex_unlock(&hound->list_guard);
     232        return EOK;
     233}
     234
    203235int hound_connect(hound_t *hound, const char* source_name, const char* sink_name)
    204236{
  • uspace/srv/audio/hound/hound.h

    r1c33539 r6424800  
    5959int hound_add_source(hound_t *hound, audio_source_t *source);
    6060int hound_add_sink(hound_t *hound, audio_sink_t *sink);
     61int hound_remove_source(hound_t *hound, audio_source_t *source);
     62int hound_remove_sink(hound_t *hound, audio_sink_t *sink);
    6163int hound_connect(hound_t *hound, const char* source_name, const char* sink_name);
    6264int hound_disconnect(hound_t *hound, const char* source_name, const char* sink_name);
  • uspace/srv/audio/hound/main.c

    r1c33539 r6424800  
    178178                        audio_client_t * client =
    179179                            audio_client_get_recording(name, &format, sess);
     180                        free(name);
    180181                        if (!client) {
    181182                                log_error("Failed to create recording client");
     
    196197                }
    197198                case HOUND_UNREGISTER_PLAYBACK: {
    198                         //const char *name = get_name();
    199                         //TODO unregister in hound
    200                         //TODO remove from local
     199                        const char *name = get_name();
     200                        int ret = ENOENT;
     201                        list_foreach(local_playback, it) {
     202                                audio_client_t *client =
     203                                    audio_client_list_instance(it);
     204                                if (str_cmp(client->name, name) == 0) {
     205                                        ret = hound_remove_source(&hound,
     206                                            &client->source);
     207                                        if (ret == EOK) {
     208                                                list_remove(&client->link);
     209                                                audio_client_destroy(client);
     210                                        }
     211                                        break;
     212                                }
     213                        }
     214                        free(name);
     215                        async_answer_0(callid, ret);
    201216                        break;
    202217                }
    203218                case HOUND_UNREGISTER_RECORDING: {
    204                         //TODO Get Name
    205                         //TODO unregister in hound
    206                         //TODO remove from local
     219                        const char *name = get_name();
     220                        int ret = ENOENT;
     221                        list_foreach(local_recording, it) {
     222                                audio_client_t *client =
     223                                    audio_client_list_instance(it);
     224                                if (str_cmp(client->name, name) == 0) {
     225                                        ret = hound_remove_sink(&hound,
     226                                            &client->sink);
     227                                        if (ret == EOK) {
     228                                                list_remove(&client->link);
     229                                                audio_client_destroy(client);
     230                                        }
     231                                        break;
     232                                }
     233                        }
     234                        free(name);
     235                        async_answer_0(callid, ret);
    207236                        break;
    208237                }
     
    237266                        break;
    238267                case 0:
     268                        while(!list_empty(&local_recording)) {
     269                                audio_client_t *client =
     270                                    audio_client_list_instance(
     271                                        list_first(&local_recording));
     272                                list_remove(&client->link);
     273                                hound_remove_sink(&hound, &client->sink);
     274                                audio_client_destroy(client);
     275                        }
     276                        while(!list_empty(&local_playback)) {
     277                                audio_client_t *client =
     278                                    audio_client_list_instance(
     279                                        list_first(&local_playback));
     280                                list_remove(&client->link);
     281                                hound_remove_source(&hound, &client->source);
     282                                audio_client_destroy(client);
     283                        }
    239284                        //TODO remove all clients
    240285                        return;
Note: See TracChangeset for help on using the changeset viewer.