diff options
| author | Erk- <[email protected]> | 2018-12-22 14:04:31 +0100 |
|---|---|---|
| committer | Alex M. M <[email protected]> | 2018-12-22 14:04:31 +0100 |
| commit | a2baca08bfd558ed7981cfe8ddb2659f3b6e9fb9 (patch) | |
| tree | 498124365df67b3e2c3e18b6bc1383c3bfa2d70c /examples | |
| parent | Fix `Emoji::url` to use .gif for animated emoji (#449) (diff) | |
| download | serenity-a2baca08bfd558ed7981cfe8ddb2659f3b6e9fb9.tar.xz serenity-a2baca08bfd558ed7981cfe8ddb2659f3b6e9fb9.zip | |
Implement the proposed change to the sharemap (`Mutex` => `RwLock`) (#453)
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/05_command_framework/src/main.rs | 8 | ||||
| -rw-r--r-- | examples/06_voice/src/main.rs | 16 | ||||
| -rw-r--r-- | examples/10_voice_receive/src/main.rs | 6 |
3 files changed, 15 insertions, 15 deletions
diff --git a/examples/05_command_framework/src/main.rs b/examples/05_command_framework/src/main.rs index 1a6ca6c..fb6990a 100644 --- a/examples/05_command_framework/src/main.rs +++ b/examples/05_command_framework/src/main.rs @@ -54,7 +54,7 @@ fn main() { let mut client = Client::new(&token, Handler).expect("Err creating client"); { - let mut data = client.data.lock(); + let mut data = client.data.write(); data.insert::<CommandCounter>(HashMap::default()); data.insert::<ShardManagerContainer>(Arc::clone(&client.shard_manager)); } @@ -106,7 +106,7 @@ fn main() { // Increment the number of times this command has been run once. If // the command's name does not exist in the counter, add a default // value of 0. - let mut data = ctx.data.lock(); + let mut data = ctx.data.write(); let counter = data.get_mut::<CommandCounter>().expect("Expected CommandCounter in ShareMap."); let entry = counter.entry(command_name.to_string()).or_insert(0); *entry += 1; @@ -246,7 +246,7 @@ fn main() { command!(commands(ctx, msg, _args) { let mut contents = "Commands used:\n".to_string(); - let data = ctx.data.lock(); + let data = ctx.data.read(); let counter = data.get::<CommandCounter>().expect("Expected CommandCounter in ShareMap."); for (k, v) in counter { @@ -375,7 +375,7 @@ command!(about(_ctx, msg, _args) { command!(latency(ctx, msg, _args) { // The shard manager is an interface for mutating, stopping, restarting, and // retrieving information about shards. - let data = ctx.data.lock(); + let data = ctx.data.read(); let shard_manager = match data.get::<ShardManagerContainer>() { Some(v) => v, diff --git a/examples/06_voice/src/main.rs b/examples/06_voice/src/main.rs index d24e2a6..8dbc4d5 100644 --- a/examples/06_voice/src/main.rs +++ b/examples/06_voice/src/main.rs @@ -56,7 +56,7 @@ fn main() { // voice manager into it. This allows the voice manager to be accessible by // event handlers and framework commands. { - let mut data = client.data.lock(); + let mut data = client.data.write(); data.insert::<VoiceManager>(Arc::clone(&client.voice_manager)); } @@ -86,7 +86,7 @@ command!(deafen(ctx, msg) { }, }; - let mut manager_lock = ctx.data.lock().get::<VoiceManager>().cloned().unwrap(); + let mut manager_lock = ctx.data.read().get::<VoiceManager>().cloned().unwrap(); let mut manager = manager_lock.lock(); let handler = match manager.get_mut(guild_id) { @@ -134,7 +134,7 @@ command!(join(ctx, msg) { } }; - let mut manager_lock = ctx.data.lock().get::<VoiceManager>().cloned().expect("Expected VoiceManager in ShareMap."); + let mut manager_lock = ctx.data.read().get::<VoiceManager>().cloned().expect("Expected VoiceManager in ShareMap."); let mut manager = manager_lock.lock(); if manager.join(guild_id, connect_to).is_some() { @@ -154,7 +154,7 @@ command!(leave(ctx, msg) { }, }; - let mut manager_lock = ctx.data.lock().get::<VoiceManager>().cloned().expect("Expected VoiceManager in ShareMap."); + let mut manager_lock = ctx.data.read().get::<VoiceManager>().cloned().expect("Expected VoiceManager in ShareMap."); let mut manager = manager_lock.lock(); let has_handler = manager.get(guild_id).is_some(); @@ -177,7 +177,7 @@ command!(mute(ctx, msg) { }, }; - let mut manager_lock = ctx.data.lock().get::<VoiceManager>().cloned().expect("Expected VoiceManager in ShareMap."); + let mut manager_lock = ctx.data.read().get::<VoiceManager>().cloned().expect("Expected VoiceManager in ShareMap."); let mut manager = manager_lock.lock(); let handler = match manager.get_mut(guild_id) { @@ -227,7 +227,7 @@ command!(play(ctx, msg, args) { }, }; - let mut manager_lock = ctx.data.lock().get::<VoiceManager>().cloned().expect("Expected VoiceManager in ShareMap."); + let mut manager_lock = ctx.data.read().get::<VoiceManager>().cloned().expect("Expected VoiceManager in ShareMap."); let mut manager = manager_lock.lock(); if let Some(handler) = manager.get_mut(guild_id) { @@ -260,7 +260,7 @@ command!(undeafen(ctx, msg) { }, }; - let mut manager_lock = ctx.data.lock().get::<VoiceManager>().cloned().expect("Expected VoiceManager in ShareMap."); + let mut manager_lock = ctx.data.read().get::<VoiceManager>().cloned().expect("Expected VoiceManager in ShareMap."); let mut manager = manager_lock.lock(); if let Some(handler) = manager.get_mut(guild_id) { @@ -281,7 +281,7 @@ command!(unmute(ctx, msg) { return Ok(()); }, }; - let mut manager_lock = ctx.data.lock().get::<VoiceManager>().cloned().expect("Expected VoiceManager in ShareMap."); + let mut manager_lock = ctx.data.read().get::<VoiceManager>().cloned().expect("Expected VoiceManager in ShareMap."); let mut manager = manager_lock.lock(); if let Some(handler) = manager.get_mut(guild_id) { diff --git a/examples/10_voice_receive/src/main.rs b/examples/10_voice_receive/src/main.rs index 113b769..7b95cc8 100644 --- a/examples/10_voice_receive/src/main.rs +++ b/examples/10_voice_receive/src/main.rs @@ -73,7 +73,7 @@ fn main() { // voice manager into it. This allows the voice manager to be accessible by // event handlers and framework commands. { - let mut data = client.data.lock(); + let mut data = client.data.write(); data.insert::<VoiceManager>(Arc::clone(&client.voice_manager)); } @@ -107,7 +107,7 @@ command!(join(ctx, msg, args) { }, }; - let mut manager_lock = ctx.data.lock().get::<VoiceManager>().cloned().expect("Expected VoiceManager in ShareMap."); + let mut manager_lock = ctx.data.read().get::<VoiceManager>().cloned().expect("Expected VoiceManager in ShareMap."); let mut manager = manager_lock.lock(); if let Some(handler) = manager.join(guild_id, connect_to) { @@ -128,7 +128,7 @@ command!(leave(ctx, msg) { }, }; - let mut manager_lock = ctx.data.lock().get::<VoiceManager>().cloned().expect("Expected VoiceManager in ShareMap."); + let mut manager_lock = ctx.data.read().get::<VoiceManager>().cloned().expect("Expected VoiceManager in ShareMap."); let mut manager = manager_lock.lock(); let has_handler = manager.get(guild_id).is_some(); |