aboutsummaryrefslogtreecommitdiff
path: root/src/Steer.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/Steer.c')
-rw-r--r--src/Steer.c53
1 files changed, 17 insertions, 36 deletions
diff --git a/src/Steer.c b/src/Steer.c
index 4433187..8556777 100644
--- a/src/Steer.c
+++ b/src/Steer.c
@@ -84,12 +84,9 @@ static pthread_mutex_t steer_mutex = PTHREAD_MUTEX_INITIALIZER;
@@*/
int HTTP_SteerQueue(const char *thorn, const char *parameter, const char *value)
{
- int retval;
- int buffer_length;
- int parameter_length;
- char *tmp;
-
- retval = 0;
+ int retval = -1;
+ int buffer_length = 0;
+ int parameter_length = 0;
#ifdef CCTK_PTHREADS
pthread_mutex_lock(&steer_mutex);
@@ -102,7 +99,7 @@ int HTTP_SteerQueue(const char *thorn, const char *parameter, const char *value)
if(buffer_length+parameter_length+1 > queuebuffer_size)
{
- tmp = (char *)realloc(queuebuffer, buffer_length+parameter_length+1);
+ char *tmp = (char *)realloc(queuebuffer, buffer_length+parameter_length+1);
if(tmp)
{
@@ -110,10 +107,6 @@ int HTTP_SteerQueue(const char *thorn, const char *parameter, const char *value)
queuebuffer_size = buffer_length+parameter_length+1;
retval = 0;
}
- else
- {
- retval = -1;
- }
}
if(!retval)
@@ -182,9 +175,9 @@ int HTTP_SteerDispatch(void)
static int CommunicateBuffer(void)
{
#ifdef CCTK_MPI
- int rank;
- int nprocs;
- int buffer_size;
+ int rank = 0;
+ int nprocs = 1;
+ int buffer_size = 0;
CCTK_INT8 transmit_buffer_size;
/* Work out how many processes there are. */
@@ -287,24 +280,18 @@ static int CommunicateBuffer(void)
@@*/
static int SteerParameters(void)
{
- int retval;
-
- char *token;
- char *thorn;
- char *parameter;
- char *value;
-
- retval = 0;
+ int retval = 0;
+ char *value = NULL;
if(queuebuffer)
{
- token = strtok(queuebuffer, "\n");
+ char *token = strtok(queuebuffer, "\n");
while(token)
{
- thorn = token;
+ char *thorn = token;
- parameter = strchr(token, ':');
+ char *parameter = strchr(token, ':');
if(parameter)
{
@@ -379,16 +366,14 @@ static int SteerParameters(void)
static void ByteSwap(void *buf,int nelements,int elementsize)
{
#ifndef WORDS_BIGENDIAN
- char *buffer;
+ char *buffer=(char *)buf;
int i;
int s,d;
-
- buffer=(char *)buf;
for(i=0;i<nelements;i++,buffer+=elementsize)
{
/* do the swap thing on each element */
- for(s=0,d=elementsize-1;s<d;s++,d--)
+ for(s=0, d=elementsize-1; s < d; s++,d--)
{
char c=buffer[s];
buffer[s]=buffer[d];
@@ -403,12 +388,10 @@ static void ByteSwap(void *buf,int nelements,int elementsize)
int CCTK_ParameterSet(char *parameter, char *thorn, char *value)
{
- int rank;
+ int rank = 0;
#ifdef CCTK_MPI
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
-#else
- rank = 0;
#endif
fprintf(stderr, "%d - %s::%s='%s'\n", rank, thorn, parameter, value);
@@ -419,8 +402,8 @@ int CCTK_ParameterSet(char *parameter, char *thorn, char *value)
int main(int argc, char *argv[])
{
int i;
- int rank;
- char value[20];
+ int rank = 0;
+ char value[20] = {'\0'};
#ifdef CCTK_MPI
MPI_Init(&argc, &argv);
@@ -428,8 +411,6 @@ int main(int argc, char *argv[])
#ifdef CCTK_MPI
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
-#else
- rank = 0;
#endif
for(i = 0; i < 6; i++)