1129 threadpool_run(pool, thrpool_exec, data); |
1129 threadpool_run(pool, thrpool_exec, data); |
1130 |
1130 |
1131 return REQ_PROCESSING; |
1131 return REQ_PROCESSING; |
1132 } |
1132 } |
1133 |
1133 |
1134 void nsapi_function_return(Session *session, Request *request, int ret) { |
1134 void nsapi_saf_return(Session *session, Request *request, int ret) { |
1135 NSAPISession *sn = (NSAPISession*)session; |
1135 NSAPISession *sn = (NSAPISession*)session; |
1136 NSAPIRequest *rq = (NSAPIRequest*)request; |
1136 NSAPIRequest *rq = (NSAPIRequest*)request; |
1137 |
1137 |
1138 rq->context.last_req_code = ret; |
1138 rq->context.last_req_code = ret; |
1139 |
1139 |
1140 if(sn->currentpool != sn->defaultpool) { |
1140 if(sn->currentpool != sn->defaultpool) { |
1141 nsapi_change_threadpool(sn, rq, sn->defaultpool); |
1141 nsapi_change_threadpool(sn, rq, sn->defaultpool); |
1142 } else { |
1142 } else { |
1143 nsapi_handle_request(sn, rq); |
1143 nsapi_handle_request(sn, rq); |
1144 } |
1144 } |
|
1145 } |
|
1146 |
|
1147 void nsapi_function_return(Session *session, Request *request, int ret) { |
|
1148 ev_saf_return(session->ev, session, request, ret); |
1145 } |
1149 } |
1146 |
1150 |
1147 void nsapi_change_threadpool( |
1151 void nsapi_change_threadpool( |
1148 NSAPISession *sn, |
1152 NSAPISession *sn, |
1149 NSAPIRequest *rq, |
1153 NSAPIRequest *rq, |