We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d23b17d commit eaf1cb7Copy full SHA for eaf1cb7
app/roster/src/application/server/handle.rs
@@ -121,8 +121,10 @@ impl Handler {
121
122
let hash = cmd.hash_key();
123
124
+ /*
125
let is_in_slot =
126
hash.map(|hash| ctx.is_in_slot(hash)).unwrap_or(true);
127
+ */
128
let is_in_slot = true;
129
130
if !is_in_slot {
app/roster/src/application/server/server_thread.rs
@@ -66,6 +66,7 @@ impl ServerMonoThreadedHandle {
66
)?;
67
68
let shard = Rc::new(self.dial.shard);
69
+
70
// We initialize the listener on the TCP for this thread.
71
loop {
72
// TODO(@miaxos): Check cancellation
0 commit comments