sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2025-03-09 08:58:35 +03:00
Code

r3023: added immediate send of messages when they are first queued. This makes things a bit more efficient

Browse Source 
(This used to be commit 8380225d326e4bfb3f15fddc72c097870713132a)
This commit is contained in:
Andrew Tridgell 2004-10-17 13:33:03 +00:00 committed by Gerald (Jerry) Carter
parent 605560149e
commit 6cc8941f05
2 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -375,6 +375,8 @@ NTSTATUS messaging_send(void *msg_ctx, servid_t server, uint32_t msg_type, DATA_
talloc_set_destructor(rec, rec_destructor); talloc_set_destructor(rec, rec_destructor);
messaging_send_handler(msg->event.ev, rec->fde, 0, EVENT_FD_WRITE);
return NT_STATUS_OK; return NT_STATUS_OK;
} }

7
source4/torture/local/messaging.c
View File

@ -93,11 +93,7 @@ static BOOL test_ping_speed(TALLOC_CTX *mem_ctx)
ping_count++; ping_count++;
} }
while (ping_count > pong_count + 20) { while (ping_count > pong_count + 10) {
event_loop_once(ev);
event_loop_once(ev);
event_loop_once(ev);
event_loop_once(ev);
event_loop_once(ev); event_loop_once(ev);
} }
} }
@ -110,7 +106,6 @@ static BOOL test_ping_speed(TALLOC_CTX *mem_ctx)
printf("sending exit\n"); printf("sending exit\n");
messaging_send(msg_ctx, 1, MY_EXIT, NULL); messaging_send(msg_ctx, 1, MY_EXIT, NULL);
event_loop_once(ev);
if (ping_count != pong_count) { if (ping_count != pong_count) {
printf("ping test failed! received %d, sent %d\n", pong_count, ping_count); printf("ping test failed! received %d, sent %d\n", pong_count, ping_count);