svn commit: samba r16921 - in branches/tmp/vl-messaging/source/lib: .

[vlendec at samba.org]

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;