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); } /****************************************************************************
