5359edc160de518d8e43fdd3448365c15b912c3c
galt
  Mon Jul 22 11:48:10 2019 -0700
Added ipv6 support. Listening processes us hybrid dual stack feature of OS to simplify implementation and use a single listening socket. Works with both TCP and UDP. Parasol working. geoIp also updated and ready for IPv6. Should be invisible to most users, while providing connections via ipv6 where available. Supports both ipv4 and ipv6.

diff --git src/parasol/parasol/parasol.c src/parasol/parasol/parasol.c
index ab6205d..a6bfbe2 100644
--- src/parasol/parasol/parasol.c
+++ src/parasol/parasol/parasol.c
@@ -101,66 +101,66 @@
 
 void getResultsFile(char results[PATH_LEN])
 /* get the results file, either from -results= option or a default.*/
 {
 char curDir[PATH_LEN];
 char defaultResults[PATH_LEN];
 
 (void) getcwd(curDir, sizeof(curDir));  // ignore return value
 safef(defaultResults, sizeof(defaultResults), "%s/results", curDir);
 safecpy(results, PATH_LEN, optionVal("results", defaultResults));
 }
 
 boolean commandHubExt(char *command, struct paraMessage *pm, struct paraMultiMessage *pmm)
 /* Send a command to hub. */
 {
-pmInitFromName(pm, paraHubHost, paraHubPort);
+pmInitFromName(pm, paraHubHost, paraHubPortStr);
 
 if (pmm)
     {
     /* ensure the multi-message response comes from the correct ip and has no duplicate msgs*/
-    pmmInit(pmm, pm, pm->ipAddress.sin_addr);
+    pmmInit(pmm, pm);
     }
 
 return pmSendString(pm, hubRudp, command);
 }
 
 boolean commandHub(char *command)
 /* Send a command to hub. */
 {
 struct paraMessage pm;
 return commandHubExt(command, &pm, NULL);
 }
 
-char *hubCommandGetReciept(char *command)
-/* Send command to hub,  wait for one line respons and
+char *hubCommandGetReceipt(char *command)
+/* Send command to hub, wait for one line response and
  * return it.  freeMem return value when done. */
 {
 struct paraMessage pm;
 if (!commandHub(command))
     return NULL;
 if (pmReceive(&pm, hubRudp))
     return cloneString(pm.data);
 else
     return NULL;
 }
 
 void hubCommandCheckReceipt(char *command)
 /* Send command to hub, and wait for one line response which should
  * be 'ok'. */
 {
-char *line = hubCommandGetReciept(command);
+char *line = hubCommandGetReceipt(command);
 if (line == NULL || !sameString(line, "ok"))
     errAbort("Hub didn't acknowledge %s", command);
 freeMem(line);
 }
 
 void hubCommandAndPrint(char *command)
 /* Send command to hub, and print response until blank line. */
 {
 char *line = NULL;
 struct slRef *list = NULL, *ref;
 struct paraMessage pm;
 struct paraMultiMessage pmm;
 int count = 0;
 char *row[256];
 
@@ -264,62 +264,62 @@
 char *err = optionVal("err", NULL);
 char *jobIdString;
 int i;
 char curDir[PATH_LEN];
 (void) getcwd(curDir, sizeof(curDir)); // ignore return value
 char *dir = optionVal("dir", curDir);
 char results[PATH_LEN];
 getResultsFile(results);
 
 dyStringPrintf(dy, "addJob2 %s %s %s %s %s %f %lld",
                userName, dir, in, out, results, cpuUsage, ramUsage);
 for (i=0; i<argc; ++i)
     dyStringPrintf(dy, " %s", argv[i]);
 pmCheckCommandSize(dy->string, dy->stringSize);
 
-jobIdString = hubCommandGetReciept(dy->string);
+jobIdString = hubCommandGetReceipt(dy->string);
 dyStringFree(&dy);
 if (sameString(jobIdString, "0"))
     errAbort("sick batch?: hub returned jobId==%s", jobIdString);
 if (printId)
     printf("%s\n", jobIdString);
 if (verbose)
     {
     printf("your job %s (\"%s", jobIdString, argv[0]);
     for (i=1; i<argc; ++i)
 	 printf(" %s", argv[i]);
     printf("\") has been submitted\n");
     }
 
 if (optionExists("wait"))
     {
     waitAndExit(results, jobIdString, err);
     }
 freez(&jobIdString);
 }
 
 
 void clearSickBatch()
 /* Tell hub to clear sick stats on a batch. */
 {
 struct dyString *dy = newDyString(1024);
 char *response;
 char results[PATH_LEN];
 getResultsFile(results);
 
 dyStringPrintf(dy, "clearSickNodes %s %s", userName, results);
-response = hubCommandGetReciept(dy->string);
+response = hubCommandGetReceipt(dy->string);
 if (!sameString(response, "0"))
     errAbort("Couldn't clear sick nodes for %s %s", userName, results);
 dyStringFree(&dy);
 freez(&response);
 }
 
 void checkDeadNodesASAP()
 /* Tell hub to check dead nodes for signs of life ASAP. */
 {
 mustBeRoot();
 commandHub("checkDeadNodesASAP");
 }
 
 
 
@@ -488,52 +488,52 @@
 int i;
 for (i=0; i<count; ++i)
     {
     hubCommandCheckReceipt("ping");
     }
 printf("Pinged hub %d times\n", count);
 }
 
 void freeBatch()
 /* Send msg to hub to reset done and crashed counts on batch */
 {
 char results[PATH_LEN];
 getResultsFile(results);
 char command[2*PATH_LEN];
 safef(command, sizeof(command), "freeBatch %s %s", getUser(), results);
-char *result = hubCommandGetReciept(command);
+char *result = hubCommandGetReceipt(command);
 if (result == NULL)
     errAbort("result == NULL");
 if (sameOk(result, "-3"))
     errAbort("User not found.");
 if (sameOk(result, "-2"))
     errAbort("Batch not found.");
 if (sameOk(result, "-1"))
     warn("Unable to free batch.  Jobs are queued or running.");
 if (sameOk(result, "0"))
     printf("Batch freed.\n");
 freez(&result);
 }
 
 void flushResults()
 /* Send msg to hub to flush results file */
 {
 char results[PATH_LEN];
 getResultsFile(results);
 char command[2*PATH_LEN];
 safef(command, sizeof(command), "flushResults %s %s", getUser(), results);
-char *result = hubCommandGetReciept(command);
+char *result = hubCommandGetReceipt(command);
 if (result == NULL)
     errAbort("result == NULL");
 if (sameOk(result, "-3"))
     errAbort("User not found.");
 if (sameOk(result, "-2"))
     errAbort("Batch not found.");
 if (sameOk(result, "-1"))
     warn("Flushed results. Some jobs are still queued or running.");
 if (sameOk(result, "0"))
     printf("Flushed results.\n");
 freez(&result);
 }
 
 void parasol(char *command, int argc, char *argv[])
 /* parasol - Parasol program - for launching programs in parallel on a computer cluster. */