summaryrefslogtreecommitdiff
path: root/librabbitmq/win32
diff options
context:
space:
mode:
authorAlan Antonuk <alan.antonuk@gmail.com>2013-04-11 10:53:59 -0700
committerAlan Antonuk <alan.antonuk@gmail.com>2013-04-17 09:56:29 -0700
commita2a91f532b7e648b2468acad39ae7169ac020d0a (patch)
tree78010b44a0e00011cc17787d144abc7dc358c560 /librabbitmq/win32
parent317a56cfffb05e72713bfa8a8e7236b7c39ddb8d (diff)
downloadrabbitmq-c-github-ask-a2a91f532b7e648b2468acad39ae7169ac020d0a.tar.gz
Fix code formatting to match the rest of the lib
Diffstat (limited to 'librabbitmq/win32')
-rw-r--r--librabbitmq/win32/socket.c4
-rw-r--r--librabbitmq/win32/socket.h2
-rw-r--r--librabbitmq/win32/threads.c9
3 files changed, 9 insertions, 6 deletions
diff --git a/librabbitmq/win32/socket.c b/librabbitmq/win32/socket.c
index 815530f..fa2b0f7 100644
--- a/librabbitmq/win32/socket.c
+++ b/librabbitmq/win32/socket.c
@@ -95,12 +95,12 @@ amqp_socket_setsockopt(int sock, int level, int optname,
int
amqp_socket_close(int sockfd, AMQP_UNUSED void *user_data)
{
- return closesocket(sockfd);
+ return closesocket(sockfd);
}
ssize_t
amqp_socket_writev(int sock, struct iovec *iov, int nvecs,
- AMQP_UNUSED void *user_data)
+ AMQP_UNUSED void *user_data)
{
DWORD ret;
if (WSASend(sock, (LPWSABUF)iov, nvecs, &ret, 0, NULL, NULL) == 0) {
diff --git a/librabbitmq/win32/socket.h b/librabbitmq/win32/socket.h
index db40a97..58e1a99 100644
--- a/librabbitmq/win32/socket.h
+++ b/librabbitmq/win32/socket.h
@@ -60,7 +60,7 @@ amqp_socket_setsockopt(int sock, int level, int optname, const void *optval,
size_t optlen);
ssize_t
-amqp_socket_writev(int sock, struct iovec *iov, int nvecs, AMQP_UNUSED void* user_data);
+amqp_socket_writev(int sock, struct iovec *iov, int nvecs, AMQP_UNUSED void *user_data);
int
amqp_socket_error(AMQP_UNUSED void *user_data);
diff --git a/librabbitmq/win32/threads.c b/librabbitmq/win32/threads.c
index 0501408..1559c5f 100644
--- a/librabbitmq/win32/threads.c
+++ b/librabbitmq/win32/threads.c
@@ -11,8 +11,9 @@ int
pthread_mutex_init(pthread_mutex_t *mutex, void *attr)
{
*mutex = malloc(sizeof(CRITICAL_SECTION));
- if (!*mutex)
+ if (!*mutex) {
return 1;
+ }
InitializeCriticalSection(*mutex);
return 0;
}
@@ -20,8 +21,9 @@ pthread_mutex_init(pthread_mutex_t *mutex, void *attr)
int
pthread_mutex_lock(pthread_mutex_t *mutex)
{
- if (!*mutex)
+ if (!*mutex) {
return 1;
+ }
EnterCriticalSection(*mutex);
return 0;
@@ -30,8 +32,9 @@ pthread_mutex_lock(pthread_mutex_t *mutex)
int
pthread_mutex_unlock(pthread_mutex_t *mutex)
{
- if (!*mutex)
+ if (!*mutex) {
return 1;
+ }
LeaveCriticalSection(*mutex);
return 0;