diff --git a/cache/src/tango_cache_tools.h b/cache/src/tango_cache_tools.h index 7874b9d..6cac7b8 100644 --- a/cache/src/tango_cache_tools.h +++ b/cache/src/tango_cache_tools.h @@ -6,6 +6,12 @@ #define MESA_HANDLE_RUNTIME_LOGV2(handle, lv, fmt, args...) \ MESA_handle_runtime_log((handle), (lv), "TANGO_CACHE", "%s:%d, " fmt, __FILE__, __LINE__, ##args) +#ifdef CACHE_DEBUG_SWITCH +#define DBG_CACHE(msg...) do{printf(msg);}while(0) +#else +#define DBG_CACHE(msg...) +#endif + int Base64_EncodeBlock(const unsigned char *in, int inl, unsigned char *out); int Base64_DecodeBlock(const unsigned char *in, int inl, unsigned char *out, int outsize); diff --git a/cache/src/tango_cache_transfer.cpp b/cache/src/tango_cache_transfer.cpp index bf7eb20..5fb6398 100644 --- a/cache/src/tango_cache_transfer.cpp +++ b/cache/src/tango_cache_transfer.cpp @@ -138,6 +138,7 @@ static int http_put_bodypart_request_evbuf(struct tango_cache_ctx *ctx, bool ful rc = curl_multi_add_handle(ctx->instance->multi_hd, ctx->curl); assert(rc==CURLM_OK); + DBG_CACHE("http_put_bodypart_request_evbuf, state: %d, length: %lu, key: %s\n", ctx->put.state, ctx->put.upload_length, ctx->object_key); return 1; } @@ -196,6 +197,7 @@ int curl_get_minio_uploadID(struct tango_cache_ctx *ctx) rc = curl_multi_add_handle(ctx->instance->multi_hd, ctx->curl); assert(rc==CURLM_OK); + DBG_CACHE("curl_get_minio_uploadID, state: %d, key: %s\n", ctx->put.state, ctx->object_key); return 1; } @@ -293,6 +295,7 @@ bool cache_kick_combine_minio(struct tango_cache_ctx *ctx) rc = curl_multi_add_handle(ctx->instance->multi_hd, ctx->curl); assert(rc==CURLM_OK); + DBG_CACHE("cache_kick_combine_minio, state: %d, key: %s\n", ctx->put.state, ctx->object_key); return true; } @@ -354,6 +357,7 @@ int cache_kick_upload_minio_end(struct tango_cache_ctx *ctx) { int ret = 0; + DBG_CACHE("cache_kick_upload_minio_end, state: %d, key: %s\n", ctx->put.state, ctx->object_key); ctx->put.close_state = true;//仅设置状态,并非真正关闭;内部状态机轮转结束后再关闭 if(ctx->fail_state) { @@ -412,6 +416,7 @@ int cache_kick_upload_minio_end(struct tango_cache_ctx *ctx) void tango_cache_curl_put_done(struct tango_cache_ctx *ctx, CURLcode res, long res_code) { + DBG_CACHE("tango_cache_curl_put_done, state: %d, key: %s\n", ctx->put.state, ctx->object_key); switch(ctx->put.state) { case PUT_STATE_WAIT_START: