Skip to content
This repository was archived by the owner on Jul 11, 2021. It is now read-only.

Commit 138b0b2

Browse files
committed
mark unsafe function as such
1 parent accf9f0 commit 138b0b2

2 files changed

Lines changed: 14 additions & 12 deletions

File tree

redisql_lib/src/redis.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1647,8 +1647,10 @@ pub fn get_dbkey_from_name(
16471647
Ok(dbkey)
16481648
}
16491649

1650-
pub fn get_ch_from_dbkeyptr(db: *mut DBKey) -> Sender<Command> {
1651-
unsafe { (*db).tx.clone() }
1650+
pub unsafe fn get_ch_from_dbkeyptr(
1651+
db: *mut DBKey,
1652+
) -> Sender<Command> {
1653+
(*db).tx.clone()
16521654
}
16531655

16541656
pub fn reply_with_error_from_key_type(

src/commands.rs

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ pub extern "C" fn ExecStatement(
9494
}
9595
};
9696

97-
let ch = get_ch_from_dbkeyptr(db);
97+
let ch = unsafe { get_ch_from_dbkeyptr(db) };
9898

9999
let blocked_client = r::rm::BlockedClient {
100100
client: unsafe {
@@ -180,7 +180,7 @@ pub extern "C" fn QueryStatement(
180180
);
181181
}
182182
};
183-
let ch = get_ch_from_dbkeyptr(db);
183+
let ch = unsafe { get_ch_from_dbkeyptr(db) };
184184

185185
let blocked_client = r::rm::BlockedClient {
186186
client: unsafe {
@@ -260,7 +260,7 @@ pub extern "C" fn QueryStatementInto(
260260
);
261261
}
262262
};
263-
let ch = get_ch_from_dbkeyptr(db);
263+
let ch = unsafe { get_ch_from_dbkeyptr(db) };
264264

265265
let blocked_client = r::rm::BlockedClient {
266266
client: unsafe {
@@ -326,7 +326,7 @@ pub extern "C" fn Exec(
326326
);
327327
}
328328
};
329-
let ch = get_ch_from_dbkeyptr(db);
329+
let ch = unsafe { get_ch_from_dbkeyptr(db) };
330330

331331
let blocked_client = r::rm::BlockedClient {
332332
client: unsafe {
@@ -417,7 +417,7 @@ pub extern "C" fn Query(
417417
);
418418
}
419419
};
420-
let ch = get_ch_from_dbkeyptr(db);
420+
let ch = unsafe { get_ch_from_dbkeyptr(db) };
421421

422422
let blocked_client = r::rm::BlockedClient {
423423
client: unsafe {
@@ -496,7 +496,7 @@ pub extern "C" fn QueryInto(
496496
);
497497
}
498498
};
499-
let ch = get_ch_from_dbkeyptr(db);
499+
let ch = unsafe { get_ch_from_dbkeyptr(db) };
500500

501501
let blocked_client = r::rm::BlockedClient {
502502
client: unsafe {
@@ -576,7 +576,7 @@ pub extern "C" fn CreateStatement(
576576
);
577577
}
578578
};
579-
let ch = get_ch_from_dbkeyptr(db);
579+
let ch = unsafe { get_ch_from_dbkeyptr(db) };
580580

581581
let blocked_client = r::rm::BlockedClient {
582582
client: unsafe {
@@ -660,7 +660,7 @@ pub extern "C" fn UpdateStatement(
660660
);
661661
}
662662
};
663-
let ch = get_ch_from_dbkeyptr(db);
663+
let ch = unsafe { get_ch_from_dbkeyptr(db) };
664664

665665
let blocked_client = r::rm::BlockedClient {
666666
client: unsafe {
@@ -745,7 +745,7 @@ pub extern "C" fn DeleteStatement(
745745
);
746746
}
747747
};
748-
let ch = get_ch_from_dbkeyptr(db);
748+
let ch = unsafe { get_ch_from_dbkeyptr(db) };
749749

750750
let blocked_client = r::rm::BlockedClient {
751751
client: unsafe {
@@ -992,7 +992,7 @@ pub extern "C" fn MakeCopy(
992992
}
993993
};
994994

995-
let ch = get_ch_from_dbkeyptr(db);
995+
let ch = unsafe { get_ch_from_dbkeyptr(db) };
996996
let dest_db =
997997
get_dbkey_from_name(context.as_ptr(), argvector[2]);
998998
if dest_db.is_err() {

0 commit comments

Comments
 (0)