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

[vlendec at samba.org]

Author: vlendec
Date: 2006-06-08 14:51:11 +0000 (Thu, 08 Jun 2006)
New Revision: 16099

WebSVN: http://websvn.samba.org/cgi-bin/viewcvs.cgi?view=rev&root=samba&rev=16099

Log:
A little more reformatting
Modified:
   branches/tmp/vl-messaging/source/lib/messages_dgram.c
   branches/tmp/vl-messaging/source/lib/messages_stream.c


Changeset:
Modified: branches/tmp/vl-messaging/source/lib/messages_dgram.c
===================================================================
--- branches/tmp/vl-messaging/source/lib/messages_dgram.c	2006-06-08 14:44:16 UTC (rev 16098)
+++ branches/tmp/vl-messaging/source/lib/messages_dgram.c	2006-06-08 14:51:11 UTC (rev 16099)
@@ -39,10 +39,10 @@
 ****************************************************************************/
 
 BOOL message_send_pid_dgram(int socket_fd, 
-							struct process_id pid, int msg_type,
-							const void *buf, size_t len,
-							BOOL duplicates_allowed,
-							unsigned int timeout)
+			    struct process_id pid, int msg_type,
+			    const void *buf, size_t len,
+			    BOOL duplicates_allowed,
+			    unsigned int timeout)
 {
 	DATA_BLOB packet;
 	struct message_rec *hdr;
@@ -162,7 +162,7 @@
 			message_received_handler(msg);
 		} else {
 			DEBUG(5, ("Invalid message length received, got %d, "
-					  "expected %d\n", msg->len, dgram.length));
+				  "expected %d\n", msg->len, dgram.length));
 		}
 		SAFE_FREE(dgram.data);
 	}

Modified: branches/tmp/vl-messaging/source/lib/messages_stream.c
===================================================================
--- branches/tmp/vl-messaging/source/lib/messages_stream.c	2006-06-08 14:44:16 UTC (rev 16098)
+++ branches/tmp/vl-messaging/source/lib/messages_stream.c	2006-06-08 14:51:11 UTC (rev 16099)
@@ -170,9 +170,9 @@
 ****************************************************************************/
 
 static BOOL message_send_pid_stream_internal(struct messaging_client *client,
-											 int msg_type,
-											 const void *buf, size_t len,
-											 BOOL duplicates_allowed)
+					     int msg_type,
+					     const void *buf, size_t len,
+					     BOOL duplicates_allowed)
 {
 	struct message *msg, *tmp;
 	struct message_rec *hdr;
@@ -192,7 +192,7 @@
 
 	msg->contents->length = sizeof(struct message_rec) + len;
 	msg->contents->data = TALLOC_ARRAY(msg->contents, uint8_t,
-								   msg->contents->length);
+					   msg->contents->length);
 	if (msg->contents->data == NULL) {
 		DEBUG(0, ("talloc failed\n"));
 		TALLOC_FREE(msg);
@@ -206,7 +206,8 @@
 	hdr->src = procid_self();
 	hdr->dest = client->pid;
 	if (len > 0) {
-		memcpy(msg->contents->data + sizeof(struct message_rec), buf, len);
+		memcpy(msg->contents->data + sizeof(struct message_rec), buf,
+		       len);
 	}
 	
 	msg->written = 0;
@@ -253,7 +254,8 @@
 	
 	ZERO_STRUCT(sunaddr);
 	sunaddr.sun_family = AF_UNIX;
-	strncpy(sunaddr.sun_path, message_path(pid), sizeof(sunaddr.sun_path)-1);
+	strncpy(sunaddr.sun_path, message_path(pid),
+		sizeof(sunaddr.sun_path)-1);
 
 	if (connect(result->fd, (struct sockaddr *)&sunaddr,
 			sizeof(sunaddr)) == 0) {
@@ -389,7 +391,8 @@
  Check client's incoming data
 ****************************************************************************/
 
-static BOOL client_readable(struct messaging_client *c, char** msg_buf, size_t* len)
+static BOOL client_readable(struct messaging_client *c, char** msg_buf,
+			    size_t* len)
 {
 	struct message_rec *msg_rec;
 
@@ -480,10 +483,10 @@
 ****************************************************************************/
 
 BOOL message_send_pid_stream(int socket_fd, 
-							 struct process_id pid, int msg_type,
-							 const void *buf, size_t len,
-							 BOOL duplicates_allowed,
-							 unsigned int timeout)
+			     struct process_id pid, int msg_type,
+			     const void *buf, size_t len,
+			     BOOL duplicates_allowed,
+			     unsigned int timeout)
 {
 	struct messaging_client *client;
 
@@ -500,7 +503,7 @@
 	}
 
 	return message_send_pid_stream_internal(client, msg_type,
-											buf, len, duplicates_allowed);
+						buf, len, duplicates_allowed);
 }
 
 /****************************************************************************