| 1158 threadpool_run(pool, thrpool_exec, data); |
1158 threadpool_run(pool, thrpool_exec, data); |
| 1159 |
1159 |
| 1160 return REQ_PROCESSING; |
1160 return REQ_PROCESSING; |
| 1161 } |
1161 } |
| 1162 |
1162 |
| |
1163 static nsapi_return_callback_func nsapi_return_callback; |
| |
1164 |
| |
1165 void nsapi_set_saf_return_callback(nsapi_return_callback_func callback) { |
| |
1166 nsapi_return_callback = callback; |
| |
1167 } |
| |
1168 |
| 1163 void nsapi_saf_return(Session *session, Request *request, int ret) { |
1169 void nsapi_saf_return(Session *session, Request *request, int ret) { |
| 1164 NSAPISession *sn = (NSAPISession*)session; |
1170 NSAPISession *sn = (NSAPISession*)session; |
| 1165 NSAPIRequest *rq = (NSAPIRequest*)request; |
1171 NSAPIRequest *rq = (NSAPIRequest*)request; |
| 1166 |
1172 |
| 1167 rq->context.last_req_code = ret; |
1173 rq->context.last_req_code = ret; |
| 1172 nsapi_handle_request(sn, rq); |
1178 nsapi_handle_request(sn, rq); |
| 1173 } |
1179 } |
| 1174 } |
1180 } |
| 1175 |
1181 |
| 1176 void nsapi_function_return(Session *session, Request *request, int ret) { |
1182 void nsapi_function_return(Session *session, Request *request, int ret) { |
| |
1183 if(nsapi_return_callback && nsapi_return_callback(session, request, ret)) { |
| |
1184 return; |
| |
1185 } |
| 1177 ev_saf_return(session->ev, session, request, ret); |
1186 ev_saf_return(session->ev, session, request, ret); |
| 1178 } |
1187 } |
| 1179 |
1188 |
| 1180 void nsapi_change_threadpool( |
1189 void nsapi_change_threadpool( |
| 1181 NSAPISession *sn, |
1190 NSAPISession *sn, |