缓存取消上传+测试用例
This commit is contained in:
1
cache/include/tango_cache_client.h
vendored
1
cache/include/tango_cache_client.h
vendored
@@ -150,6 +150,7 @@ struct tango_cache_ctx *tango_cache_update_start(struct tango_cache_instance *in
|
|||||||
int tango_cache_update_frag_data(struct tango_cache_ctx *ctx, const char *data, size_t size);
|
int tango_cache_update_frag_data(struct tango_cache_ctx *ctx, const char *data, size_t size);
|
||||||
int tango_cache_update_frag_evbuf(struct tango_cache_ctx *ctx, enum EVBUFFER_COPY_WAY way, struct evbuffer *evbuf);
|
int tango_cache_update_frag_evbuf(struct tango_cache_ctx *ctx, enum EVBUFFER_COPY_WAY way, struct evbuffer *evbuf);
|
||||||
void tango_cache_update_end(struct tango_cache_ctx *ctx);
|
void tango_cache_update_end(struct tango_cache_ctx *ctx);
|
||||||
|
//<2F><><EFBFBD><EFBFBD>cancel<65><EFBFBD><F3B2BBBB><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ص<EFBFBD><D8B5><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʧ<EFBFBD><CAA7>
|
||||||
void tango_cache_update_cancel(struct tango_cache_ctx *ctx);
|
void tango_cache_update_cancel(struct tango_cache_ctx *ctx);
|
||||||
|
|
||||||
//<2F><>ȡ<EFBFBD><C8A1><EFBFBD><EFBFBD>keyֵ<79><D6B5><EFBFBD><EFBFBD>CACHE_OBJECT_KEY_HASH_SWITCH=1<><31><EFBFBD><EFBFBD><EFBFBD><EFBFBD>URL/<2F>ļ<EFBFBD><C4BC><EFBFBD><EFBFBD><EFBFBD>ϣʱ<CFA3><CAB1><EFBFBD><EFBFBD>
|
//<2F><>ȡ<EFBFBD><C8A1><EFBFBD><EFBFBD>keyֵ<79><D6B5><EFBFBD><EFBFBD>CACHE_OBJECT_KEY_HASH_SWITCH=1<><31><EFBFBD><EFBFBD><EFBFBD><EFBFBD>URL/<2F>ļ<EFBFBD><C4BC><EFBFBD><EFBFBD><EFBFBD>ϣʱ<CFA3><CAB1><EFBFBD><EFBFBD>
|
||||||
|
|||||||
1
cache/src/tango_cache_client.cpp
vendored
1
cache/src/tango_cache_client.cpp
vendored
@@ -268,6 +268,7 @@ void tango_cache_update_cancel(struct tango_cache_ctx *ctx)
|
|||||||
ctx->curl = NULL;
|
ctx->curl = NULL;
|
||||||
}
|
}
|
||||||
tango_cache_set_fail_state(ctx, CACHE_UPDATE_CANCELED);
|
tango_cache_set_fail_state(ctx, CACHE_UPDATE_CANCELED);
|
||||||
|
//<2F>Ѿ<EFBFBD><D1BE><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ֶ<EFBFBD><D6B6>ϴ<EFBFBD>IDʱ<44><CAB1><EFBFBD><EFBFBD><EFBFBD><EFBFBD>cancelɾ<6C><C9BE>
|
||||||
if(ctx->put.uploadID!=NULL && cache_cancel_upload_minio(ctx))
|
if(ctx->put.uploadID!=NULL && cache_cancel_upload_minio(ctx))
|
||||||
{
|
{
|
||||||
ctx->put.state = PUT_STATE_CANCEL;
|
ctx->put.state = PUT_STATE_CANCEL;
|
||||||
|
|||||||
Reference in New Issue
Block a user