fix memory leak in blocked client

siscia · siscia · commit 26d22c2b9186 · 2019-08-14T19:03:34.000+02:00
diff --git a/redisql_lib/src/redis_type.rs b/redisql_lib/src/redis_type.rs
@@ -29,20 +29,22 @@ impl Context {
         }
     }
     pub fn no_client() -> Self {
+        debug!("New thread safe context");
         let ctx = unsafe {
             ffi::RedisModule_GetThreadSafeContext.unwrap()(
                 std::ptr::null_mut(),
             )
         };
         Context {
             ctx,
-            thread_safe: false,
+            thread_safe: true,
         }
     }
     pub fn as_ptr(&self) -> *mut ffi::RedisModuleCtx {
         self.ctx
     }
     pub fn thread_safe(blocked_client: &BlockedClient) -> Context {
+        debug!("New thread safe context");
         let ctx = unsafe {
             ffi::RedisModule_GetThreadSafeContext.unwrap()(
                 blocked_client.as_ptr(),

Original file line number	Diff line number	Diff line change
`@@ -29,20 +29,22 @@ impl Context {`
`29`	`29`	`}`
`30`	`30`	`}`
`31`	`31`	`pub fn no_client() -> Self {`
	`32`	`+ debug!("New thread safe context");`
`32`	`33`	`let ctx = unsafe {`
`33`	`34`	`ffi::RedisModule_GetThreadSafeContext.unwrap()(`
`34`	`35`	`std::ptr::null_mut(),`
`35`	`36`	`)`
`36`	`37`	`};`
`37`	`38`	`Context {`
`38`	`39`	`ctx,`
`39`		`- thread_safe: false,`
	`40`	`+ thread_safe: true,`
`40`	`41`	`}`
`41`	`42`	`}`
`42`	`43`	`pub fn as_ptr(&self) -> *mut ffi::RedisModuleCtx {`
`43`	`44`	`self.ctx`
`44`	`45`	`}`
`45`	`46`	`pub fn thread_safe(blocked_client: &BlockedClient) -> Context {`
	`47`	`+ debug!("New thread safe context");`
`46`	`48`	`let ctx = unsafe {`
`47`	`49`	`ffi::RedisModule_GetThreadSafeContext.unwrap()(`
`48`	`50`	`blocked_client.as_ptr(),`