src/parasol/inc/paraLib.h 1.26
1.26 2009/12/04 23:50:23 markd
added -cpu and -ram to the parasol add jobs command
Index: src/parasol/inc/paraLib.h
===================================================================
RCS file: /projects/compbio/cvsroot/kent/src/parasol/inc/paraLib.h,v
retrieving revision 1.25
retrieving revision 1.26
diff -b -B -U 1000000 -r1.25 -r1.26
--- src/parasol/inc/paraLib.h 21 May 2008 21:59:37 -0000 1.25
+++ src/parasol/inc/paraLib.h 4 Dec 2009 23:50:23 -0000 1.26
@@ -1,70 +1,75 @@
/* paraLib - some misc. routines used by multiple parasol
* associated programs. */
#ifndef PARALIB_H
#define PARALIB_H
extern char *cuserid(char *__s); /* Linux should define this but... */
extern int paraHubPort; /* Port for hub. */
extern int paraNodePort; /* Port for nodes. */
boolean sendWithSig(int fd, char *string);
/* Send a string with the signature prepended. Warn
* but don't abort if there's a problem. Return TRUE
* on success. */
void mustSendWithSig(int fd, char *string);
/* Send a string with the signature prepended.
* Abort on failure. */
char *getMachine();
/* Return host machine name. */
char *getUser();
/* Get user name */
int forkOrDie();
/* Fork, aborting if it fails. */
struct runJobMessage
/* Parsed out runJob message as paraNode sees it. */
{
char *jobIdString; /* Unique ID - ascii number */
char *reserved; /* Reserved for future expansion, always "0" */
char *user; /* User associated with job. */
char *dir; /* Directory to run job in. */
char *in; /* File for stdin. */
char *out; /* File for stdout. */
char *err; /* File for stderr. */
float cpus; /* Number of CPUs used by job */
long long ram; /* Number of bytes of RAM used by job */
char *command; /* Command line for job. */
};
boolean parseRunJobMessage(char *line, struct runJobMessage *rjm);
/* Parse runJobMessage as paraNodes sees it. */
void fillInErrFile(char errFile[512], int jobId, char *tempDir);
/* Fill in error file name */
extern time_t now; /* Time when started processing current message */
void findNow();
/* Just set now to current time. */
char* paraFormatIp(bits32 ip);
/* format a binary IP added into dotted quad format. ip should be
* in host byte order. Warning: static return. */
void paraDaemonize(char *progName);
/* daemonize parasol server process, closing open file descriptors and
* starting logging based on the -logFacility and -log command line options .
* if -debug is supplied , don't fork. */
+long long paraParseRam(char *ram);
+/* Parse RAM expression like 2000000, 2t, 2g, 2m, 2k
+ * Returns long long number of bytes, or -1 for error
+ * The value of input variable ram may be modified. */
+
#define NORMAL_PRIORITY 10 /* 1 is highest priority */
#define MAX_PRIORITY 10000 /* 10000 is the lowest priority */
#endif /* PARALIB_H */