* without waiting
*/
for (i = 0; i < num_servers; i++) {
- status = imessaging_send(
- msg_ctx,
- servers[i],
- MSG_PING,
- &data_blob_null);
+ status = imessaging_send(msg_ctx, servers[i], MSG_PING, NULL);
if (NT_STATUS_IS_OK(status)) {
*event_server = servers[i];
TALLOC_FREE(frame);
status = messaging_send(parent->msg_ctx,
parent->cleanupd,
MSG_SMB_NOTIFY_CLEANUP,
- &data_blob_null);
+ NULL);
if (!NT_STATUS_IS_OK(status)) {
DBG_ERR("messaging_send returned %s\n",
nt_errstr(status));
status = messaging_send(parent->msg_ctx,
parent->cleanupd,
MSG_SMB_NOTIFY_CLEANUP,
- &data_blob_null);
+ NULL);
if (!NT_STATUS_IS_OK(status)) {
DBG_ERR("messaging_send returned %s\n",
nt_errstr(status));
"(IP %s)\n", (unsigned int)procid_to_pid(&pid),
state->ip));
- messaging_send(state->msg_ctx, pid, MSG_SHUTDOWN,
- &data_blob_null);
+ messaging_send(state->msg_ctx, pid, MSG_SHUTDOWN, NULL);
return 0;
}
DEBUG( 2, ( "Closing idle connection\n" ) );
messaging_send(sconn->msg_ctx,
messaging_server_id(sconn->msg_ctx),
- MSG_SHUTDOWN, &data_blob_null);
+ MSG_SHUTDOWN,
+ NULL);
return False;
}
messaging_register(msg_ctx, NULL, MSG_PONG, pong_message);
for (i=0;i<n;i++) {
- messaging_send(msg_ctx, pid_to_procid(pid), MSG_PING,
- &data_blob_null);
+ messaging_send(msg_ctx, pid_to_procid(pid), MSG_PING, NULL);
}
while (pong_count < i) {
strlcpy(buf, "1234567890", sizeof(buf));
for (i=0;i<n;i++) {
- messaging_send(msg_ctx, messaging_server_id(msg_ctx), MSG_PING,
- &data_blob_null);
+ messaging_send(msg_ctx,
+ messaging_server_id(msg_ctx),
+ MSG_PING,
+ NULL);
messaging_send_buf(msg_ctx, messaging_server_id(msg_ctx),
MSG_PING,(uint8_t *)buf, 11);
}
MSG_PING,
(uint8_t *)buf, 11)))
ping_count++;
- if(NT_STATUS_IS_OK(messaging_send(
- msg_ctx, pid_to_procid(pid),
- MSG_PING, &data_blob_null)))
- ping_count++;
+ if (NT_STATUS_IS_OK(messaging_send(msg_ctx,
+ pid_to_procid(pid),
+ MSG_PING,
+ NULL)))
+ ping_count++;
while (ping_count > pong_count + 20) {
ret = tevent_loop_once(evt_ctx);