aboutsummaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorErk- <[email protected]>2018-12-22 14:04:31 +0100
committerAlex M. M <[email protected]>2018-12-22 14:04:31 +0100
commita2baca08bfd558ed7981cfe8ddb2659f3b6e9fb9 (patch)
tree498124365df67b3e2c3e18b6bc1383c3bfa2d70c /examples
parentFix `Emoji::url` to use .gif for animated emoji (#449) (diff)
downloadserenity-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.rs8
-rw-r--r--examples/06_voice/src/main.rs16
-rw-r--r--examples/10_voice_receive/src/main.rs6
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();