Skip to content

Commit

Permalink
code style changes to function definitions
Browse files Browse the repository at this point in the history
  • Loading branch information
tcort committed Sep 2, 2016
1 parent 3e8e467 commit 96b4028
Show file tree
Hide file tree
Showing 5 changed files with 39 additions and 13 deletions.
12 changes: 9 additions & 3 deletions lib_mysqludf_amqp_info.c
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,9 @@

#include "lib_mysqludf_amqp.h"

my_bool lib_mysqludf_amqp_info_init(UDF_INIT *initid, UDF_ARGS *args, char *message) {
my_bool
lib_mysqludf_amqp_info_init(UDF_INIT *initid, UDF_ARGS *args, char *message)
{

if (args->arg_count != 0) {
(void) strncpy(message, "lib_mysqludf_amqp_info: invalid arguments", MYSQL_ERRMSG_SIZE);
Expand All @@ -20,7 +22,9 @@ my_bool lib_mysqludf_amqp_info_init(UDF_INIT *initid, UDF_ARGS *args, char *mess
return 0;
}

char* lib_mysqludf_amqp_info(UDF_INIT *initid, UDF_ARGS *args, char* result, unsigned long* length, char *is_null, char *error) {
char*
lib_mysqludf_amqp_info(UDF_INIT *initid, UDF_ARGS *args, char* result, unsigned long* length, char *is_null, char *error)
{

(void) strncpy(result, PACKAGE_STRING, strlen(PACKAGE_STRING) + 1);
*length = (unsigned long) strlen(result);
Expand All @@ -30,7 +34,9 @@ char* lib_mysqludf_amqp_info(UDF_INIT *initid, UDF_ARGS *args, char* result, uns
return result;
}

void lib_mysqludf_amqp_info_deinit(UDF_INIT *initid) {
void
lib_mysqludf_amqp_info_deinit(UDF_INIT *initid)
{
/* nothing to do here */
return;
}
12 changes: 9 additions & 3 deletions lib_mysqludf_amqp_sendjson.c
Original file line number Diff line number Diff line change
Expand Up @@ -10,14 +10,20 @@
#include "lib_mysqludf_amqp.h"
#include "send.h"

my_bool lib_mysqludf_amqp_sendjson_init(UDF_INIT *initid, UDF_ARGS *args, char *message) {
my_bool
lib_mysqludf_amqp_sendjson_init(UDF_INIT *initid, UDF_ARGS *args, char *message)
{
return lib_mysqludf_amqp_send_init(initid, args, message);
}

char* lib_mysqludf_amqp_sendjson(UDF_INIT *initid, UDF_ARGS *args, char* result, unsigned long* length, char *is_null, char *error) {
char*
lib_mysqludf_amqp_sendjson(UDF_INIT *initid, UDF_ARGS *args, char* result, unsigned long* length, char *is_null, char *error)
{
return lib_mysqludf_amqp_send(initid, args, result, length, is_null, error, "application/json");
}

void lib_mysqludf_amqp_sendjson_deinit(UDF_INIT *initid) {
void
lib_mysqludf_amqp_sendjson_deinit(UDF_INIT *initid)
{
lib_mysqludf_amqp_send_deinit(initid);
}
12 changes: 9 additions & 3 deletions lib_mysqludf_amqp_sendstring.c
Original file line number Diff line number Diff line change
Expand Up @@ -10,14 +10,20 @@
#include "lib_mysqludf_amqp.h"
#include "send.h"

my_bool lib_mysqludf_amqp_sendstring_init(UDF_INIT *initid, UDF_ARGS *args, char *message) {
my_bool
lib_mysqludf_amqp_sendstring_init(UDF_INIT *initid, UDF_ARGS *args, char *message)
{
return lib_mysqludf_amqp_send_init(initid, args, message);
}

char* lib_mysqludf_amqp_sendstring(UDF_INIT *initid, UDF_ARGS *args, char* result, unsigned long* length, char *is_null, char *error) {
char*
lib_mysqludf_amqp_sendstring(UDF_INIT *initid, UDF_ARGS *args, char* result, unsigned long* length, char *is_null, char *error)
{
return lib_mysqludf_amqp_send(initid, args, result, length, is_null, error, "text/plain");
}

void lib_mysqludf_amqp_sendstring_deinit(UDF_INIT *initid) {
void
lib_mysqludf_amqp_sendstring_deinit(UDF_INIT *initid)
{
lib_mysqludf_amqp_send_deinit(initid);
}
12 changes: 9 additions & 3 deletions send.c
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,9 @@ typedef struct conn_info {
char *message_id;
} conn_info_t;

my_bool lib_mysqludf_amqp_send_init(UDF_INIT *initid, UDF_ARGS *args, char *message) {
my_bool
lib_mysqludf_amqp_send_init(UDF_INIT *initid, UDF_ARGS *args, char *message)
{

int rc;
amqp_rpc_reply_t reply;
Expand Down Expand Up @@ -88,7 +90,9 @@ my_bool lib_mysqludf_amqp_send_init(UDF_INIT *initid, UDF_ARGS *args, char *mess
return 1;
}

char* lib_mysqludf_amqp_send(UDF_INIT *initid, UDF_ARGS *args, char* result, unsigned long* length, char *is_null, char *error, char *content_type) {
char*
lib_mysqludf_amqp_send(UDF_INIT *initid, UDF_ARGS *args, char* result, unsigned long* length, char *is_null, char *error, char *content_type)
{

int rc;
conn_info_t *conn_info = (conn_info_t *) initid->ptr;
Expand Down Expand Up @@ -148,7 +152,9 @@ char* lib_mysqludf_amqp_send(UDF_INIT *initid, UDF_ARGS *args, char* result, uns
return conn_info->message_id;
}

void lib_mysqludf_amqp_send_deinit(UDF_INIT *initid) {
void
lib_mysqludf_amqp_send_deinit(UDF_INIT *initid)
{
if (initid->ptr != NULL) {
conn_info_t *conn_info = (conn_info_t *) initid->ptr;
(void) amqp_channel_close(conn_info->conn, 1, AMQP_REPLY_SUCCESS);
Expand Down
4 changes: 3 additions & 1 deletion uuid.c
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,9 @@
/*
* simple implementation of version 4 UUID generation
*/
char *uuidgen(void) {
char*
uuidgen(void)
{

char *buffer = malloc(UUID_BUF_LEN);
if (buffer == NULL) {
Expand Down

0 comments on commit 96b4028

Please sign in to comment.