gfwleak/tango-tfe
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

实现cancel的逻辑。

Browse Source
This commit is contained in:
zhengchao
2018-11-23 20:45:12 +08:00
parent 5d20a52552
commit cc049d7f7c
1 changed files with 13 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
common/src/tfe_future.cpp
View File

@@ -39,6 +39,7 @@ struct future
struct timeval timeout;
future_success_cb * cb_success;
future_failed_cb * cb_failed;
char is_cancelled;
};
struct promise
@@ -220,6 +221,10 @@ void future_destroy(struct future * f)
{
__promise_destroy(p);
}
else
{
f->is_cancelled=1;
}
}
void promise_finish(struct promise * p)
{
@@ -252,7 +257,10 @@ static void fp_stat_latency(struct _future_promise_debug* debug, int is_success)
void promise_failed(struct promise * p, enum e_future_error error, const char * what)
{
if(!g_FP_instance.no_stats) fp_stat_latency(&p->debug, 0);
p->f.cb_failed(error, what, p->f.user);
if(!p->f.is_cancelled)
{
p->f.cb_failed(error, what, p->f.user);
}
if(!p->may_success_many_times)
{
promise_finish(p);
@@ -263,7 +271,10 @@ void promise_failed(struct promise * p, enum e_future_error error, const char *
void promise_success(struct promise * p, void * result)
{
if(!g_FP_instance.no_stats) fp_stat_latency(&p->debug, 1);
p->f.cb_success(result, p->f.user);
if(!p->f.is_cancelled)
{
p->f.cb_success(result, p->f.user);
}
if(!p->may_success_many_times)
{
promise_finish(p);