File tree 1 file changed +9
-3
lines changed
1 file changed +9
-3
lines changed Original file line number Diff line number Diff line change @@ -203,7 +203,7 @@ impl Launcher {
203
203
204
204
#[ derive( Default ) ]
205
205
struct ActiveRequests {
206
- rb : StaticRb < AbortHandle , 50 > , // the number of requests we handle at the same time.
206
+ rb : StaticRb < AbortHandle , 1000 > , // the number of requests we handle at the same time.
207
207
}
208
208
209
209
impl std:: fmt:: Debug for ActiveRequests {
@@ -241,8 +241,14 @@ impl Udp {
241
241
tx_start : oneshot:: Sender < Started > ,
242
242
rx_halt : oneshot:: Receiver < Halted > ,
243
243
) {
244
- let socket = Arc :: new ( UdpSocket :: bind ( bind_to) . await . expect ( "Could not bind to {self.socket}." ) ) ;
245
- let address = socket. local_addr ( ) . expect ( "Could not get local_addr from {binding}." ) ;
244
+ let socket = Arc :: new (
245
+ UdpSocket :: bind ( bind_to)
246
+ . await
247
+ . unwrap_or_else ( |_| panic ! ( "Could not bind to {bind_to}." ) ) ,
248
+ ) ;
249
+ let address = socket
250
+ . local_addr ( )
251
+ . unwrap_or_else ( |_| panic ! ( "Could not get local_addr from {bind_to}." ) ) ;
246
252
let halt = shutdown_signal_with_message ( rx_halt, format ! ( "Halting Http Service Bound to Socket: {address}" ) ) ;
247
253
248
254
info ! ( target: "UDP TRACKER" , "Starting on: udp://{}" , address) ;
You can’t perform that action at this time.
0 commit comments