From 9d5085261520f342b23e2efddf0b7debc9cc6cf4 Mon Sep 17 00:00:00 2001 From: Mary Lincy Dcouto Date: Thu, 29 Jul 2021 23:07:23 +0530 Subject: [PATCH] updating c-sdk to 0.25.6, changes to timeoutRemaining type --- service/build.bat | 2 +- service/cziti/sdk.go | 18 +++++++++++++----- 2 files changed, 14 insertions(+), 6 deletions(-) diff --git a/service/build.bat b/service/build.bat index 799c976e..c3538624 100644 --- a/service/build.bat +++ b/service/build.bat @@ -14,7 +14,7 @@ REM See the License for the specific language governing permissions and REM limitations under the License. REM SET REPO_URL=https://github.com/openziti/ziti-tunnel-sdk-c.git -SET ZITI_TUNNEL_REPO_BRANCH=v0.15.10 +SET ZITI_TUNNEL_REPO_BRANCH=v0.15.11 REM override the c sdk used in the build - leave blank for the same as specified in the tunneler sdk SET ZITI_SDK_C_BRANCH= REM the number of TCP connections the tunneler sdk can have at any one time diff --git a/service/cziti/sdk.go b/service/cziti/sdk.go index 511e336a..fb5506be 100644 --- a/service/cziti/sdk.go +++ b/service/cziti/sdk.go @@ -428,18 +428,26 @@ func serviceCB(ziti_ctx C.ziti_context, service *C.ziti_service, status C.int, z var pcId string pcId = C.GoString(pq.id) - log.Infof("Posture query %s, timeout %d, timeoutRemaining %d", C.GoString(pq.id), int(pq.timeout), int(pq.timeoutRemaining)) + + var pcTimeoutRemaining int + if unsafe.Pointer(pq.timeoutRemaining) != C.NULL { + pcTimeoutRemaining = int(*(*C.int)(pq.timeoutRemaining)) + } else { + pcTimeoutRemaining = -1 + } + + log.Infof("Posture query %s, timeout %d, timeoutRemaining %d", pcId, int(pq.timeout), pcTimeoutRemaining) _, found := pcIds[pcId] if found { log.Tracef("posture check with id %s already in failing posture check map", pcId) for _, pc := range postureChecks { - if pc.Id == C.GoString(pq.id) { + if pc.Id == pcId { if timeout == -1 || timeout > int(pq.timeout) { timeout = int(pq.timeout) } - if timeoutRemaining == -1 || timeoutRemaining > int(pq.timeoutRemaining) { - timeoutRemaining = int(pq.timeoutRemaining) + if timeoutRemaining == -1 || timeoutRemaining > pcTimeoutRemaining { + timeoutRemaining = pcTimeoutRemaining } break } @@ -451,7 +459,7 @@ func serviceCB(ziti_ctx C.ziti_context, service *C.ziti_service, status C.int, z QueryType: C.GoString(pq.query_type), Id: pcId, Timeout: int(pq.timeout), - TimeoutRemaining: int(pq.timeoutRemaining), + TimeoutRemaining: pcTimeoutRemaining, } timeout = pc.Timeout timeoutRemaining = pc.TimeoutRemaining