mirror of
https://github.com/logos-messaging/nim-sds.git
synced 2026-06-07 01:39:29 +00:00
temporary log changes
This commit is contained in:
parent
239f619625
commit
f8e831ff71
@ -62,23 +62,32 @@ var
|
|||||||
ctxPoolLock: Lock
|
ctxPoolLock: Lock
|
||||||
|
|
||||||
proc acquireCtx(callback: SdsCallBack, userData: pointer): ptr SdsContext =
|
proc acquireCtx(callback: SdsCallBack, userData: pointer): ptr SdsContext =
|
||||||
|
echo "AAAA acquireCtx 1"
|
||||||
ctxPoolLock.acquire()
|
ctxPoolLock.acquire()
|
||||||
|
echo "AAAA acquireCtx 2"
|
||||||
defer: ctxPoolLock.release()
|
defer: ctxPoolLock.release()
|
||||||
|
echo "AAAA acquireCtx 3"
|
||||||
if ctxPool.len > 0:
|
if ctxPool.len > 0:
|
||||||
|
echo "AAAA acquireCtx 4"
|
||||||
result = ctxPool.pop()
|
result = ctxPool.pop()
|
||||||
else:
|
else:
|
||||||
|
echo "AAAA acquireCtx 5"
|
||||||
result = sds_thread.createSdsThread().valueOr:
|
result = sds_thread.createSdsThread().valueOr:
|
||||||
let msg = "Error in createSdsThread: " & $error
|
let msg = "Error in createSdsThread: " & $error
|
||||||
callback(RET_ERR, unsafeAddr msg[0], cast[csize_t](len(msg)), userData)
|
callback(RET_ERR, unsafeAddr msg[0], cast[csize_t](len(msg)), userData)
|
||||||
return nil
|
return nil
|
||||||
|
|
||||||
proc releaseCtx(ctx: ptr SdsContext) =
|
proc releaseCtx(ctx: ptr SdsContext) =
|
||||||
|
echo "AAAA releaseCtx 1"
|
||||||
ctxPoolLock.acquire()
|
ctxPoolLock.acquire()
|
||||||
|
echo "AAAA releaseCtx 2"
|
||||||
defer: ctxPoolLock.release()
|
defer: ctxPoolLock.release()
|
||||||
|
echo "AAAA releaseCtx 3"
|
||||||
ctx.userData = nil
|
ctx.userData = nil
|
||||||
ctx.eventCallback = nil
|
ctx.eventCallback = nil
|
||||||
ctx.eventUserData = nil
|
ctx.eventUserData = nil
|
||||||
ctxPool.add(ctx)
|
ctxPool.add(ctx)
|
||||||
|
echo "AAAA releaseCtx 4"
|
||||||
|
|
||||||
proc handleRequest(
|
proc handleRequest(
|
||||||
ctx: ptr SdsContext,
|
ctx: ptr SdsContext,
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user