Skip to content

Commit d66f523

Browse files
hmmm
1 parent 91218d9 commit d66f523

File tree

5 files changed

+7
-2
lines changed

5 files changed

+7
-2
lines changed

Cargo.lock

Lines changed: 2 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

dht.db

292 KB
Binary file not shown.

dht/Cargo.toml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,7 @@ smallvec = { version = "1.13.2", features = ["const_new"] }
3838
base64 = "0.22.1"
3939
eyre = "0.6.12"
4040
diesel = { version = "2.2.10", features = ["sqlite", "returning_clauses_for_sqlite_3_35", "r2d2" ] }
41+
libsqlite3-sys = { version = ">=0.17.2, <0.34.0", features = ["bundled"] }
4142

4243
[dev-dependencies]
4344
color-eyre = "0.6"

dht/src/dht/dht_handle.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -231,7 +231,8 @@ impl DhtHandle {
231231
.values(swarm::info_hash.eq(&info_hash))
232232
.on_conflict_do_nothing()
233233
.returning(swarm::info_hash)
234-
.get_result(conn)?;
234+
.get_result(conn)
235+
.inspect_err(|e| warn!("{e}"))?;
235236

236237
let now = unix_timestmap_ms();
237238
insert_into(peer::table)
@@ -249,6 +250,7 @@ impl DhtHandle {
249250
.do_update()
250251
.set(peer::last_announced.eq(now))
251252
.execute(conn)
253+
.inspect_err(|e| warn!("{e}"))
252254
})
253255
}
254256
/************************************** CLIENT SECTION *********************************************/

dht/src/dht/krpc_broker.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ impl KrpcBroker {
7878
let mut buf = [0u8; 1500];
7979

8080
loop {
81-
let (amount, socket_addr) = socket.recv_from(&mut buf).await.expect("common MTU 1500 exceeded");
81+
let (amount, socket_addr) = socket.recv_from(&mut buf).await.unwrap();
8282
trace!("received packet from {socket_addr}");
8383
match (&buf[..amount]).parse() {
8484
Ok(msg) => {

0 commit comments

Comments
 (0)