sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2025-02-22 05:57:43 +03:00
Code

Use tevent_req_oom

Browse Source 
This fixes a few Coverity errors
This commit is contained in:
Volker Lendecke 2011-06-19 21:10:01 +02:00 committed by Volker Lendecke
parent 8e1b9640e7
commit f0ff6f390a
15 changed files with 25 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/tsocket/tsocket_helpers.c
View File

@ -73,7 +73,7 @@ struct tevent_req *tdgram_sendto_queue_send(TALLOC_CTX *mem_ctx,
tdgram_sendto_queue_trigger,
NULL);
if (!ok) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
goto post;
}
@ -346,7 +346,7 @@ struct tevent_req *tstream_readv_pdu_queue_send(TALLOC_CTX *mem_ctx,
tstream_readv_pdu_queue_trigger,
NULL);
if (!ok) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
goto post;
}
@ -453,7 +453,7 @@ struct tevent_req *tstream_writev_queue_send(TALLOC_CTX *mem_ctx,
tstream_writev_queue_trigger,
NULL);
if (!ok) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
goto post;
}

4
libcli/cldap/cldap.c
View File

@ -631,7 +631,7 @@ struct tevent_req *cldap_search_send(TALLOC_CTX *mem_ctx,
}
if (!tevent_req_set_endtime(req, state->caller.cldap->event.ctx, end)) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
goto post;
}
@ -680,7 +680,7 @@ static void cldap_search_state_queue_done(struct tevent_req *subreq)
/* wait for incoming traffic */
if (!cldap_recvfrom_setup(state->caller.cldap)) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return;
}

2
source3/lib/fncall.c
View File

@ -266,7 +266,7 @@ struct tevent_req *fncall_send(TALLOC_CTX *mem_ctx, struct tevent_context *ev,
return tevent_req_post(req, ev);
}
if (!fncall_set_pending(req, state->ctx, ev)) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return tevent_req_post(req, ev);
}
return req;

4
source3/lib/tldap.c
View File

@ -541,7 +541,7 @@ static void tldap_msg_sent(struct tevent_req *subreq)
}
if (!tldap_msg_set_pending(req)) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return;
}
}
@ -1703,7 +1703,7 @@ static void tldap_search_done(struct tevent_req *subreq)
case TLDAP_RES_SEARCH_ENTRY:
case TLDAP_RES_SEARCH_REFERENCE:
if (!tldap_msg_set_pending(subreq)) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return;
}
tevent_req_notify_callback(req);

2
source3/libsmb/async_smb.c
View File

@ -369,7 +369,7 @@ struct tevent_req *cli_smb_req_create(TALLOC_CTX *mem_ctx,
if (cli->timeout) {
endtime = timeval_current_ofs_msec(cli->timeout);
if (!tevent_req_set_endtime(result, ev, endtime)) {
tevent_req_nomem(NULL, result);
tevent_req_oom(result);
}
}
return result;

2
source3/libsmb/cliconnect.c
View File

@ -1365,7 +1365,7 @@ static void cli_sesssetup_blob_done(struct tevent_req *subreq)
* More to send
*/
if (!cli_sesssetup_blob_next(state, &subreq)) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return;
}
tevent_req_set_callback(subreq, cli_sesssetup_blob_done, req);

8
source3/libsmb/namequery.c
View File

@ -1595,7 +1595,7 @@ static struct tevent_req *name_queries_send(
if (!tevent_req_set_endtime(
subreq, state->ev,
timeval_current_ofs(0, state->timeout_msec * 1000))) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return tevent_req_post(req, ev);
}
tevent_req_set_callback(subreq, name_queries_done, req);
@ -1678,7 +1678,7 @@ static void name_queries_next(struct tevent_req *subreq)
if (!tevent_req_set_endtime(
subreq, state->ev,
timeval_current_ofs(0, state->timeout_msec * 1000))) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return;
}
state->subreqs[state->num_sent] = subreq;
@ -1915,7 +1915,7 @@ static struct tevent_req *query_wins_list_send(
}
if (!tevent_req_set_endtime(subreq, state->ev,
timeval_current_ofs(2, 0))) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return tevent_req_post(req, ev);
}
tevent_req_set_callback(subreq, query_wins_list_done, req);
@ -1962,7 +1962,7 @@ static void query_wins_list_done(struct tevent_req *subreq)
}
if (!tevent_req_set_endtime(subreq, state->ev,
timeval_current_ofs(2, 0))) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return;
}
tevent_req_set_callback(subreq, query_wins_list_done, req);

2
source3/torture/wbc_async.c
View File

@ -551,7 +551,7 @@ struct tevent_req *wb_trans_send(TALLOC_CTX *mem_ctx,
if (!tevent_queue_add(wb_ctx->queue, ev, req, wb_trans_trigger,
NULL)) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return tevent_req_post(req, ev);
}
return req;

6
source3/winbindd/wb_lookupsids.c
View File

@ -481,7 +481,7 @@ static void wb_lookupsids_done(struct tevent_req *subreq)
&state->tmp_domains, &state->tmp_names.names[i],
state->res_domains, state->res_names,
res_sid_index)) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return;
}
}
@ -544,7 +544,7 @@ static void wb_lookupsids_single_done(struct tevent_req *subreq)
&src_domains, &src_name,
state->res_domains, state->res_names,
res_sid_index)) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return;
}
state->single_sids_done += 1;
@ -619,7 +619,7 @@ static void wb_lookupsids_lookuprids_done(struct tevent_req *subreq)
&src_domains, &src_name,
state->res_domains, state->res_names,
res_sid_index)) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return;
}
}

2
source3/winbindd/winbindd_dual.c
View File

@ -127,7 +127,7 @@ struct tevent_req *wb_child_request_send(TALLOC_CTX *mem_ctx,
if (!tevent_queue_add(child->queue, ev, req,
wb_child_request_trigger, NULL)) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return tevent_req_post(req, ev);
}
return req;

2
source3/winbindd/winbindd_dual_ndr.c
View File

@ -144,7 +144,7 @@ static void wbint_bh_raw_call_done(struct tevent_req *subreq)
state->response->extra_data.data,
state->response->length - sizeof(struct winbindd_response));
if (state->response->extra_data.data && !state->out_data.data) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return;
}

2
source4/kdc/proxy.c
View File

@ -556,7 +556,7 @@ static void kdc_tcp_proxy_read_pdu_done(struct tevent_req *subreq)
*/
state->out = data_blob_talloc(state, raw.data + 4, raw.length - 4);
if (state->out.length != raw.length - 4) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return;
}

2
source4/ldap_server/ldap_server.c
View File

@ -708,7 +708,7 @@ static struct tevent_req *ldapsrv_process_call_send(TALLOC_CTX *mem_ctx,
ok = tevent_queue_add(call_queue, ev, req,
ldapsrv_process_call_trigger, NULL);
if (!ok) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return tevent_req_post(req, ev);
}

2
source4/lib/messaging/messaging.c
View File

@ -1178,7 +1178,7 @@ static void irpc_bh_raw_call_incoming_handler(struct irpc_request *irpc,
m->ndr->data + m->ndr->offset,
m->ndr->data_size - m->ndr->offset);
if ((m->ndr->data_size - m->ndr->offset) > 0 && !state->out_data.data) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return;
}

4
source4/libcli/wrepl/winsrepl.c
View File

@ -201,7 +201,7 @@ struct tevent_req *wrepl_connect_send(TALLOC_CTX *mem_ctx,
wrepl_connect_trigger,
NULL);
if (!ok) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return tevent_req_post(req, ev);
}
@ -382,7 +382,7 @@ struct tevent_req *wrepl_request_send(TALLOC_CTX *mem_ctx,
wrepl_request_trigger,
NULL);
if (!ok) {
tevent_req_nomem(NULL, req);
tevent_req_oom(req);
return tevent_req_post(req, ev);
}