Author: vlendec Date: 2006-07-10 16:05:29 +0000 (Mon, 10 Jul 2006) New Revision: 16921
WebSVN: http://websvn.samba.org/cgi-bin/viewcvs.cgi?view=rev&root=samba&rev=16921 Log: Reformatting Modified: branches/tmp/vl-messaging/source/lib/messages_socket.c Changeset: Modified: branches/tmp/vl-messaging/source/lib/messages_socket.c =================================================================== --- branches/tmp/vl-messaging/source/lib/messages_socket.c 2006-07-10 16:03:27 UTC (rev 16920) +++ branches/tmp/vl-messaging/source/lib/messages_socket.c 2006-07-10 16:05:29 UTC (rev 16921) @@ -70,7 +70,7 @@ /* send all queued messages and close the clients */ while ((timeout - (time(NULL) - start_time) > 0) && - !can_close_messaging()) { + !can_close_messaging()) { struct timeval tmo; tmo = timeval_set(timeout - (time(NULL) - start_time), 0); message_select_and_dispatch(&tmo); @@ -112,7 +112,7 @@ if (procid_is_me(&socket_pid)) { char *path = NULL; asprintf(&path, "%s/%s", lock_path("messaging"), - procid_str_static(&socket_pid)); + procid_str_static(&socket_pid)); if (path != NULL) { unlink(path); SAFE_FREE(path); @@ -161,7 +161,7 @@ /* it needs to be non blocking for sends */ if (set_blocking(socket_fd, False) < 0) { DEBUG(0, ("set_blocking failed: %s\n", - strerror(errno))); + strerror(errno))); shutdown_sockets(False); return False; } @@ -186,14 +186,14 @@ ****************************************************************************/ BOOL message_send_pid_socket(struct process_id pid, int msg_type, - const void *buf, size_t len, - BOOL duplicates_allowed, - unsigned int timeout) + const void *buf, size_t len, + BOOL duplicates_allowed, + unsigned int timeout) { if ((enum messaging_type)lp_messaging_type() == MESSAGING_TYPE_STREAM) { return message_send_pid_stream(procid_self(), pid, - msg_type, buf, len, - duplicates_allowed, timeout); + msg_type, buf, len, + duplicates_allowed, timeout); } else { struct message_list *li, *tmp; uint8_t* buffer; @@ -246,7 +246,7 @@ ****************************************************************************/ BOOL retrieve_mask_messages_socket(unsigned int mask, - struct message_list **list) + struct message_list **list) { if(received_messages != NULL) { struct message_list *li = received_messages, *tmp;
