Changeset 128 in MondoRescue for branches/2.05/mondo/mondo/common/libmondo-fifo.c

Timestamp:

Nov 19, 2005, 2:27:41 AM (18 years ago)

Author:

bcornec

Message:

indent on all the C code

File:

• branches/2.05/mondo/mondo/common/libmondo-fifo.c (modified) (7 diffs)

branches/2.05/mondo/mondo/common/libmondo-fifo.c

@@ -1 +1 @@
 /* libmondo-fifo.c
-   $Id: libmondo-fifo.c,v 1.7 2004/06/10 15:29:12 hugo Exp $
+   $Id$
 
 
@@ -92 +92 @@
 #include <stdio.h>
 #include <signal.h>
-#include <fcntl.h>      
+#include <fcntl.h>
 #include <stdio.h>
- 
+
 #include <errno.h>
 #include <sys/types.h>
@@ -115 +115 @@
  * The SIGPIPE handler sets this to TRUE.
  */
-bool g_sigpipe=FALSE;
+bool g_sigpipe = FALSE;
 
 /**
  * PID of the "main" process.
  */
-pid_t g_mastermind_pid=0;
+pid_t g_mastermind_pid = 0;
 
 
@@ -132 +132 @@
  * Size of the buffer used with @c buffer.
  */
-int g_tape_buffer_size_MB=0;
+int g_tape_buffer_size_MB = 0;
 
 /* @} - end of globalGroup */
@@ -148 +148 @@
  * @return A file pointer to/from the @c buffer process.
  */
-FILE*open_device_via_buffer(char*device, char direction, long internal_tape_block_size)
+FILE *open_device_via_buffer(char *device, char direction,
+                             long internal_tape_block_size)
 {
-  char sz_dir[32];
-  char keych;
-  char *tmp;
-  char *command;
-  FILE*fres;
-  int bufsize; // in megabytes
-  int res;
-  int wise_upper_limit;
-  int wise_lower_limit;
-
-  malloc_string(tmp);
-  malloc_string(command);
-  assert_string_is_neither_NULL_nor_zerolength(device);
-  assert(direction=='w'||direction=='r');
-  sprintf(sz_dir, "%c", direction);
-  wise_upper_limit = (am_I_in_disaster_recovery_mode() ? 8 : 32);
-  wise_lower_limit = 1; // wise_upper_limit/2 + 1;
-  paranoid_system("sync");
-  for(bufsize=wise_upper_limit,res=-1; res!=0 && bufsize>=wise_lower_limit; bufsize--)
-    {
-      sprintf(tmp, "dd if=/dev/zero bs=1024 count=16k 2> /dev/null | buffer -o /dev/null -s %ld -m %d%c", internal_tape_block_size, bufsize, 'm');
-      res = run_program_and_log_output(tmp, 2);
-    }
-  if (!res)
-    {
-      bufsize++;
-      sprintf(tmp, "Negotiated max buffer of %d MB ", bufsize);
-      log_to_screen(tmp);
-    }
-  else
-    {
-      bufsize=0;
-      res=0;
-      log_to_screen("Cannot negotiate a buffer of ANY size. Using dd instead.");
-    }
-  if (direction=='r')
-    { keych = 'i'; }
-  else
-    { keych = 'o'; }
-  if (bufsize)
-    { sprintf(g_sz_call_to_buffer, "buffer -m %d%c -p%d -B -s%ld -%c %s 2>> %s", bufsize, 'm', (direction=='r')?20:75, internal_tape_block_size, keych, device, MONDO_LOGFILE); }
-  else
-    { sprintf(g_sz_call_to_buffer, "dd bs=%ld %cf=%s", internal_tape_block_size, keych, device); }
-  log_msg (2, "Calling buffer --- command = '%s'", g_sz_call_to_buffer);
-  fres = popen(g_sz_call_to_buffer, sz_dir);
-  if (fres)
-    { log_msg (2, "Successfully opened ('%c') tape device %s", direction, device); }
-  else
-    { log_msg (2, "Failed to open ('%c') tape device %s", direction, device); }
-  sleep(2);
-  sprintf(tmp, "ps wwax | grep \"%s\"", g_sz_call_to_buffer);
-  if (run_program_and_log_output(tmp, 2))
-    { log_msg(2, "Warning - I think I failed to open tape, actually."); }
-  g_tape_buffer_size_MB = bufsize;
-  strcmp(tmp, g_sz_call_to_buffer);
-  tmp[30] = '\0';
-  sprintf(command, "ps wwax | grep buffer | grep -v grep");
-  if (run_program_and_log_output(command, 1))
-    {
-      fres = NULL;
-      log_to_screen("Failed to open tape streamer. Buffer error.");
-    }
-  else
-    {
-      log_to_screen("Buffer successfully started.");
-    }
-
-  paranoid_free(command);
-  paranoid_free(tmp);
-  return(fres);
+    char sz_dir[32];
+    char keych;
+    char *tmp;
+    char *command;
+    FILE *fres;
+    int bufsize;                // in megabytes
+    int res;
+    int wise_upper_limit;
+    int wise_lower_limit;
+
+    malloc_string(tmp);
+    malloc_string(command);
+    assert_string_is_neither_NULL_nor_zerolength(device);
+    assert(direction == 'w' || direction == 'r');
+    sprintf(sz_dir, "%c", direction);
+    wise_upper_limit = (am_I_in_disaster_recovery_mode()? 8 : 32);
+    wise_lower_limit = 1;       // wise_upper_limit/2 + 1;
+    paranoid_system("sync");
+    for (bufsize = wise_upper_limit, res = -1;
+         res != 0 && bufsize >= wise_lower_limit; bufsize--) {
+        sprintf(tmp,
+                "dd if=/dev/zero bs=1024 count=16k 2> /dev/null | buffer -o /dev/null -s %ld -m %d%c",
+                internal_tape_block_size, bufsize, 'm');
+        res = run_program_and_log_output(tmp, 2);
+    }
+    if (!res) {
+        bufsize++;
+        sprintf(tmp, "Negotiated max buffer of %d MB ", bufsize);
+        log_to_screen(tmp);
+    } else {
+        bufsize = 0;
+        res = 0;
+        log_to_screen
+            ("Cannot negotiate a buffer of ANY size. Using dd instead.");
+    }
+    if (direction == 'r') {
+        keych = 'i';
+    } else {
+        keych = 'o';
+    }
+    if (bufsize) {
+        sprintf(g_sz_call_to_buffer,
+                "buffer -m %d%c -p%d -B -s%ld -%c %s 2>> %s", bufsize, 'm',
+                (direction == 'r') ? 20 : 75, internal_tape_block_size,
+                keych, device, MONDO_LOGFILE);
+    } else {
+        sprintf(g_sz_call_to_buffer, "dd bs=%ld %cf=%s",
+                internal_tape_block_size, keych, device);
+    }
+    log_msg(2, "Calling buffer --- command = '%s'", g_sz_call_to_buffer);
+    fres = popen(g_sz_call_to_buffer, sz_dir);
+    if (fres) {
+        log_msg(2, "Successfully opened ('%c') tape device %s", direction,
+                device);
+    } else {
+        log_msg(2, "Failed to open ('%c') tape device %s", direction,
+                device);
+    }
+    sleep(2);
+    sprintf(tmp, "ps wwax | grep \"%s\"", g_sz_call_to_buffer);
+    if (run_program_and_log_output(tmp, 2)) {
+        log_msg(2, "Warning - I think I failed to open tape, actually.");
+    }
+    g_tape_buffer_size_MB = bufsize;
+    strcmp(tmp, g_sz_call_to_buffer);
+    tmp[30] = '\0';
+    sprintf(command, "ps wwax | grep buffer | grep -v grep");
+    if (run_program_and_log_output(command, 1)) {
+        fres = NULL;
+        log_to_screen("Failed to open tape streamer. Buffer error.");
+    } else {
+        log_to_screen("Buffer successfully started.");
+    }
+
+    paranoid_free(command);
+    paranoid_free(tmp);
+    return (fres);
 }
 
@@ -228 +236 @@
 void kill_buffer()
 {
-  char *tmp;
-  char *command;
-
-  malloc_string(tmp);
-  malloc_string(command);
-  paranoid_system("sync");
-  sprintf(command, "ps wwax | fgrep \"%s\" | fgrep -v grep | awk '{print $1;}' | grep -v PID | tr -s '\n' ' ' | awk '{ print $1; }'", g_sz_call_to_buffer);
-  log_msg (2, "kill_buffer() --- command = %s", command);
-  strcpy(tmp, call_program_and_get_last_line_of_output(command));
-  sprintf(command, "kill %s", tmp);
-  log_msg (2, "kill_buffer() --- command = %s", command);
-  if (strlen(tmp)>0) { run_program_and_log_output(command, TRUE); }
-  paranoid_free(tmp);
-  paranoid_free(command);
+    char *tmp;
+    char *command;
+
+    malloc_string(tmp);
+    malloc_string(command);
+    paranoid_system("sync");
+    sprintf(command,
+            "ps wwax | fgrep \"%s\" | fgrep -v grep | awk '{print $1;}' | grep -v PID | tr -s '\n' ' ' | awk '{ print $1; }'",
+            g_sz_call_to_buffer);
+    log_msg(2, "kill_buffer() --- command = %s", command);
+    strcpy(tmp, call_program_and_get_last_line_of_output(command));
+    sprintf(command, "kill %s", tmp);
+    log_msg(2, "kill_buffer() --- command = %s", command);
+    if (strlen(tmp) > 0) {
+        run_program_and_log_output(command, TRUE);
+    }
+    paranoid_free(tmp);
+    paranoid_free(command);
 }
 
@@ -254 +266 @@
 void sigpipe_occurred(int sig)
 {
-  g_sigpipe = TRUE;
+    g_sigpipe = TRUE;
 }
 
 /* @} - end of fifoGroup */
 
-int 
-extract_config_file_from_ramdisk( struct s_bkpinfo *bkpinfo, 
-                  char *ramdisk_fname, 
-                  char *output_cfg_file, 
-                  char *output_mountlist_file);
+int
+extract_config_file_from_ramdisk(struct s_bkpinfo *bkpinfo,
+                                 char *ramdisk_fname,
+                                 char *output_cfg_file,
+                                 char *output_mountlist_file);