/***************************************************************************** /* Support.c Miscellaneous support functions for HTTPd. VERSION HISTORY --------------- 23-DEC-2017 MGD HttpIsoTimeString() 30-OCT-2017 MGD ThisLongAgo() 04-MAY-2017 MGD HtmlMetaInfo() MS Edge #include #include #include #include /* VMS related header files */ #include #include #include #ifndef __VAX #include #endif #include #include #include #include #include #include #include #include #include #ifndef __VAX /* lib$cvts_from_internal_time() does not exist with V7.3-2 or earlier */ #include #include #define CVT$K_VAX_F 0 #define CVT$K_IEEE_S 4 #endif /* application related header files */ #include "wasd.h" #define WASD_MODULE "SUPPORT" /******************/ /* global storage */ /******************/ #define RFC_1123_DATE yup BOOL TimeAheadOfGmt; ulong TimeGmtDeltaBinary [QUAD2]; char TimeGmtString [8], TimeGmtVmsString [8], TimeZoneString [8]; char *DayName [] = { "", "Monday", "Tuesday", "Wednesday", "Thursday", "Friday", "Saturday", "Sunday" }; char *MonthName [] = { "", "January", "February", "March", "April", "May", "June", "July", "August", "September", "October", "November", "December" }; /* these arrays are used with the TOUP() and TOLO() macros defined in WASD.H */ int ToUpperCase [] = { 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46, 47, 48, 49, 50, 51, 52, 53, 54, 55, 56, 57, 58, 59, 60, 61, 62, 63, 64, 65, 66, 67, 68, 69, 70, 71, 72, 73, 74, 75, 76, 77, 78, 79, 80, 81, 82, 83, 84, 85, 86, 87, 88, 89, 90, 91, 92, 93, 94, 95, 96, 65, 66, 67, 68, 69, 70, 71, 72, 73, 74, 75, 76, 77, 78, 79, 80, 81, 82, 83, 84, 85, 86, 87, 88, 89, 90,123,124,125,126,127, 128,129,130,131,132,133,134,135,136,137,138,139,140,141,142,143, 144,145,146,147,148,149,150,151,152,153,154,155,156,157,158,159, 160,161,162,163,164,165,166,167,168,169,170,171,172,173,174,175, 176,177,178,179,180,181,182,183,184,185,186,187,188,189,190,191, 192,193,194,195,196,197,198,199,200,201,202,203,204,205,206,207, 208,209,210,211,212,213,214,215,216,217,218,219,220,221,222,223, 224,225,226,227,228,229,230,231,232,233,234,235,236,237,238,239, 240,241,242,243,244,245,246,247,248,249,250,251,252,253,254,255 }; int ToLowerCase [] = { 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46, 47, 48, 49, 50, 51, 52, 53, 54, 55, 56, 57, 58, 59, 60, 61, 62, 63, 64, 97, 98, 99,100,101,102,103,104,105,106,107,108,109,110,111, 112,113,114,115,116,117,118,119,120,121,122, 91, 92, 93, 94, 95, 96, 97, 98, 99,100,101,102,103,104,105,106,107,108,109,110,111, 112,113,114,115,116,117,118,119,120,121,122,123,124,125,126,127, 128,129,130,131,132,133,134,135,136,137,138,139,140,141,142,143, 144,145,146,147,148,149,150,151,152,153,154,155,156,157,158,159, 160,161,162,163,164,165,166,167,168,169,170,171,172,173,174,175, 176,177,178,179,180,181,182,183,184,185,186,187,188,189,190,191, 192,193,194,195,196,197,198,199,200,201,202,203,204,205,206,207, 208,209,210,211,212,213,214,215,216,217,218,219,220,221,222,223, 224,225,226,227,228,229,230,231,232,233,234,235,236,237,238,239, 240,241,242,243,244,245,246,247,248,249,250,251,252,253,254,255 }; /********************/ /* external storage */ /********************/ extern BOOL AccountingZeroOnStartup, CliSoftwareID, MonitorEnabled; extern int CharsetCount, EfnWait, ServerPort; extern ulong SysPrvMask[]; extern char ErrorSanityCheck[], HttpdName[], HttpdVersion[], ServerHostName[], SoftwareID[]; extern ACCOUNTING_STRUCT *AccountingPtr; extern CONFIG_STRUCT Config; extern HTTPD_GBLSEC *HttpdGblSecPtr; extern HTTPD_PROCESS HttpdProcess; extern MSG_STRUCT Msgs; #ifdef __VAX extern SYS_INFO SysInfo; #endif extern WATCH_STRUCT Watch; /*****************************************************************************/ /* Declare an AST, exit if there is any problem ... must have our ASTs! */ void SysDclAst ( void *Address, ulong Parameter ) { int status; /*********/ /* begin */ /*********/ if (0 && WATCH_MODULE(WATCH_MOD__OTHER)) WatchThis (WATCHALL, WATCH_MOD__OTHER, "SysDclAst() !&A(!&X)", Address, Parameter); status = sys$dclast (Address, Parameter, 0); if (VMSok (status)) return; if (status == SS$_EXQUOTA) { /* no ASTs means not much of anything else can happen so just exit! */ sys$canexh(0); /* make the message a little more meaningful */ sys$exit (SS$_EXASTLM); } else ErrorExitVmsStatus (status, "sys$dclast()", FI_LI); } /*****************************************************************************/ /* Generic list handling function. Add entry to head of list. */ LIST_ENTRY* ListAddHead ( LIST_HEAD *lptr, LIST_ENTRY *eptr, ulong DataType ) { /*********/ /* begin */ /*********/ if (!lptr->HeadPtr) { /* empty list */ lptr->HeadPtr = lptr->TailPtr = eptr; eptr->PrevPtr = eptr->NextPtr = NULL; if (DataType) eptr->DataType = DataType; lptr->EntryCount++; return (eptr); } else { /* non-empty list */ eptr->PrevPtr = NULL; eptr->NextPtr = lptr->HeadPtr; eptr->NextPtr->PrevPtr = lptr->HeadPtr = eptr; if (DataType) eptr->DataType = DataType; lptr->EntryCount++; return (eptr); } } /*****************************************************************************/ /* Generic list handling function. Add entry to tail of list. */ LIST_ENTRY* ListAddTail ( LIST_HEAD *lptr, LIST_ENTRY *eptr, ulong DataType ) { /*********/ /* begin */ /*********/ if (!lptr->HeadPtr) { /* empty list */ lptr->HeadPtr = lptr->TailPtr = eptr; eptr->PrevPtr = eptr->NextPtr = NULL; if (DataType) eptr->DataType = DataType; lptr->EntryCount++; return (eptr); } else { /* non-empty list */ eptr->NextPtr = NULL; eptr->PrevPtr = lptr->TailPtr; eptr->PrevPtr->NextPtr = lptr->TailPtr = eptr; if (DataType) eptr->DataType = DataType; lptr->EntryCount++; return (eptr); } } /*****************************************************************************/ /* Generic list handling function. Add entry 2 "in front of" entry 1. */ LIST_ENTRY* ListAddBefore ( LIST_HEAD *lptr, LIST_ENTRY *e1ptr, LIST_ENTRY *e2ptr, ulong DataType ) { /*********/ /* begin */ /*********/ if (lptr->HeadPtr == e1ptr) { /* at head of list */ e1ptr->PrevPtr = e2ptr; e2ptr->PrevPtr = NULL; e2ptr->NextPtr = e1ptr; lptr->HeadPtr = e2ptr; if (DataType) e2ptr->DataType = DataType; lptr->EntryCount++; return (e2ptr); } else { /* not at head of list */ if (e1ptr->PrevPtr) { e2ptr->PrevPtr = e1ptr->PrevPtr; e2ptr->PrevPtr->NextPtr = e2ptr; } e1ptr->PrevPtr = e2ptr; e2ptr->NextPtr = e1ptr; if (DataType) e2ptr->DataType = DataType; lptr->EntryCount++; return (e2ptr); } } /*****************************************************************************/ /* Generic list handling function. Remove entry from list. Check first that entry looks legitimate, return NULL if not! */ LIST_ENTRY* ListRemove ( LIST_HEAD *lptr, LIST_ENTRY *eptr ) { /*********/ /* begin */ /*********/ if (!eptr->PrevPtr) { /* at head of list */ if (!eptr->NextPtr) { /* only entry in list */ if (lptr->HeadPtr != eptr || lptr->TailPtr != eptr) return (NULL); lptr->HeadPtr = lptr->TailPtr = NULL; if (lptr->EntryCount) lptr->EntryCount--; return (eptr); } else { /* remove from head of list */ if (lptr->HeadPtr != eptr) return (NULL); eptr->NextPtr->PrevPtr = NULL; lptr->HeadPtr = eptr->NextPtr; if (lptr->EntryCount) lptr->EntryCount--; return (eptr); } } else { /* not at head of list */ if (!eptr->NextPtr) { /* at tail of list */ if (lptr->TailPtr != eptr) return (NULL); eptr->PrevPtr->NextPtr = NULL; lptr->TailPtr = eptr->PrevPtr; if (lptr->EntryCount) lptr->EntryCount--; return (eptr); } else { /* somewhere in the middle! */ if (eptr->PrevPtr->NextPtr != eptr || eptr->NextPtr->PrevPtr != eptr) return (NULL); eptr->PrevPtr->NextPtr = eptr->NextPtr; eptr->NextPtr->PrevPtr = eptr->PrevPtr; if (lptr->EntryCount) lptr->EntryCount--; return (eptr); } } } /*****************************************************************************/ /* Generic list handling function. If not already there move it to the head. */ #ifdef __DECC #pragma inline(ListMoveHead) #endif LIST_ENTRY* ListMoveHead ( LIST_HEAD *lptr, LIST_ENTRY *eptr ) { /*********/ /* begin */ /*********/ /* move entry to the head of the cache list */ if (lptr->HeadPtr != eptr) { ListRemove (lptr, eptr); ListAddHead (lptr, eptr, 0); } return (eptr); } /*****************************************************************************/ /* Generic list handling function. If not already there move it to the tail. */ #ifdef __DECC #pragma inline(ListMoveTail) #endif LIST_ENTRY* ListMoveTail ( LIST_HEAD *lptr, LIST_ENTRY *eptr ) { /*********/ /* begin */ /*********/ /* move entry to the head of the cache list */ if (lptr->TailPtr != eptr) { ListRemove (lptr, eptr); ListAddTail (lptr, eptr, 0); } return (eptr); } /*****************************************************************************/ /* Generic list handling function. Remove the head entry. */ #ifdef __DECC #pragma inline(ListRemoveHead) #endif LIST_ENTRY* ListRemoveHead (LIST_HEAD *lptr) { LIST_ENTRY *eptr; /*********/ /* begin */ /*********/ if (eptr = lptr->HeadPtr) ListRemove (lptr, eptr); return (eptr); } /*****************************************************************************/ /* Generic list handling function. Remove the tail entry. */ #ifdef __DECC #pragma inline(ListRemoveTail) #endif LIST_ENTRY* ListRemoveTail (LIST_HEAD *lptr) { LIST_ENTRY *eptr; /*********/ /* begin */ /*********/ if (eptr = lptr->TailPtr) ListRemove (lptr, eptr); return (eptr); } /*****************************************************************************/ /* Generic list handling function. Check if a specific entry is in specific list. */ LIST_ENTRY* ListCheck ( LIST_HEAD *lptr, LIST_ENTRY *eptr ) { LIST_ENTRY *teptr; /*********/ /* begin */ /*********/ fprintf (stdout, "ListCheck() %d %d %d %d\n", lptr, lptr->HeadPtr, lptr->TailPtr, lptr->EntryCount); for (teptr = lptr->HeadPtr; teptr; teptr = teptr->NextPtr) if (teptr == eptr) return (eptr); return (NULL); } /*****************************************************************************/ /* list the entries in the list. */ ListDebug (LIST_HEAD* lptr) { LIST_ENTRY *eptr; /*********/ /* begin */ /*********/ for (eptr = lptr->HeadPtr; eptr; eptr = eptr->NextPtr) fprintf (stdout, "%d <- %d -> %d\n", eptr->PrevPtr, eptr, eptr->NextPtr); } /*****************************************************************************/ /* Generate the appropriate server signature returned the supplied buffer. */ char* ServerSignature ( REQUEST_STRUCT *rqptr, char *BufferPtr, int BufferSize ) { int status, ServerPortNumber; char *cptr, *sptr, *zptr, *ServerHostNamePtr; char MsgBuffer [256], EmailBuffer [256]; /*********/ /* begin */ /*********/ if (WATCH_MODULE(WATCH_MOD__OTHER)) WatchThis (WATCHALL, WATCH_MOD__OTHER, "ServerSignature()"); if (!Config.cfServer.Signature) { BufferPtr[0] = '\0'; return (BufferPtr); } if (rqptr) { ServerHostNamePtr = rqptr->ServicePtr->ServerHostName; ServerPortNumber = rqptr->ServicePtr->ServerPort; } else { ServerHostNamePtr = ServerHostName; ServerPortNumber = ServerPort; } if (Config.cfServer.Signature == CONFIG_SERVER_SIGNATURE_EMAIL && Config.cfServer.AdminEmail[0]) { status = FaoToBuffer (EmailBuffer, sizeof(EmailBuffer), NULL, "!AZ", Config.cfServer.AdminEmail, ServerHostNamePtr); if (VMSnok (status)) ErrorNoticed (rqptr, status, NULL, FI_LI); } else EmailBuffer[0] = '\0'; if (CliSoftwareID) { cptr = MsgFor(rqptr, MSG_STATUS_SIGNATURE); zptr = (sptr = MsgBuffer) + sizeof(MsgBuffer)-1; while (*cptr && *cptr != '!' && sptr < zptr) *sptr++ = *cptr++; if (strsame (cptr, "!AZ/", 4)) { cptr += 4; while (*cptr && sptr < zptr) *sptr++ = *cptr++; *sptr = '\0'; status = FaoToBuffer (BufferPtr, BufferSize, NULL, MsgBuffer, SoftwareID, EmailBuffer[0] ? EmailBuffer : ServerHostNamePtr, ServerPortNumber); if (VMSnok (status)) ErrorNoticed (rqptr, status, NULL, FI_LI); return (BufferPtr); } ErrorNoticed (rqptr, SS$_BUGCHECK, ErrorSanityCheck, FI_LI); } status = FaoToBuffer (BufferPtr, BufferSize, NULL, MsgFor(rqptr, MSG_STATUS_SIGNATURE), HttpdName, HttpdVersion, EmailBuffer[0] ? EmailBuffer : ServerHostNamePtr, ServerPortNumber); if (VMSnok (status)) ErrorNoticed (rqptr, status, NULL, FI_LI); return (BufferPtr); } /*****************************************************************************/ /* Create an HTTP format local time string in the storage pointed at by 'TimeString', e.g. "Fri, 25 Aug 1995 17:32:40" (RFC1123). If 'Time64Ptr' is null the time string represents the current time. If it points to a quadword, VMS time value the string represents that time. 'TimeString' must point to storage large enough for 31 characters. */ int HttpLocalTimeString ( char *TimeString, ulong *Time64Ptr ) { /* alternate formats for time string */ #ifdef RFC_1123_DATE /* day, dd mmm yyyy hh:mm */ static $DESCRIPTOR (HttpTimeFaoDsc, "!3AZ, !2ZW !3AZ !4ZW !2ZW:!2ZW:!2ZW"); #else /* weekday, dd-mmm-yyyy hh:mm */ static $DESCRIPTOR (HttpTimeFaoDsc, "!3AZ, !2ZW-!3AZ-!4ZW !2ZW:!2ZW:!2ZW"); #endif static $DESCRIPTOR (TimeStringDsc, ""); int status; ulong Time64 [QUAD2]; ushort Length; ushort NumTime [7]; ulong DayOfWeek; /*********/ /* begin */ /*********/ if (WATCH_MODULE(WATCH_MOD__OTHER)) WatchThis (WATCHALL, WATCH_MOD__OTHER, "HttpLocalTimeString()"); if (Time64Ptr) PUT_QUAD_QUAD (Time64Ptr, Time64) else sys$gettim (&Time64); status = sys$numtim (&NumTime, &Time64); if (VMSnok (status = lib$day_of_week (&Time64, &DayOfWeek))) return (status); /* set the descriptor address and size of the resultant time string */ TimeStringDsc.dsc$w_length = 25; TimeStringDsc.dsc$a_pointer = TimeString; status = sys$fao (&HttpTimeFaoDsc, &Length, &TimeStringDsc, DayName[DayOfWeek], NumTime[2], MonthName[NumTime[1]], NumTime[0], NumTime[3], NumTime[4], NumTime[5]); if (VMSnok (status) || status == SS$_BUFFEROVF) TimeString[0] = '\0'; else TimeString[Length] = '\0'; return (status); } /*****************************************************************************/ /* Create an HTTP format Greenwich Mean Time (UTC) time string in the storage pointed at by 'TimeString', e.g. "Fri, 25 Aug 1995 17:32:40 GMT" (RFC1123). This must be at least 30 characters capacity. If 'Time64Ptr' is NULL the time string represents the current time. If it points to a quadword, VMS time value the string represents that time. */ int HttpGmTimeString ( char *TimeString, ulong *Time64Ptr ) { /* alternate formats for time string */ #ifdef RFC_1123_DATE /* day, dd mmm yyyy hh:mm */ static $DESCRIPTOR (HttpTimeFaoDsc, "!3AZ, !2ZW !3AZ !4ZW !2ZW:!2ZW:!2ZW GMT"); #else /* weekday, dd-mmm-yyyy hh:mm */ static $DESCRIPTOR (HttpTimeFaoDsc, "!3AZ, !2ZW-!3AZ-!4ZW !2ZW:!2ZW:!2ZW GMT"); #endif static $DESCRIPTOR (TimeStringDsc, ""); int status; ulong Time64 [QUAD2]; ushort Length; ushort NumTime [7]; ulong DayOfWeek; /*********/ /* begin */ /*********/ if (WATCH_MODULE(WATCH_MOD__OTHER)) WatchThis (WATCHALL, WATCH_MOD__OTHER, "HttpGmTimeString()"); if (Time64Ptr) PUT_QUAD_QUAD (Time64Ptr, Time64) else sys$gettim (&Time64); if (VMSnok (status = TimeAdjustGMT (true, &Time64))) return (status); status = sys$numtim (&NumTime, &Time64); if (VMSnok (status = lib$day_of_week (&Time64, &DayOfWeek))) return (status); /* set the descriptor address and size of the resultant time string */ TimeStringDsc.dsc$w_length = 29; TimeStringDsc.dsc$a_pointer = TimeString; status = sys$fao (&HttpTimeFaoDsc, &Length, &TimeStringDsc, DayName[DayOfWeek], NumTime[2], MonthName[NumTime[1]], NumTime[0], NumTime[3], NumTime[4], NumTime[5]); if (VMSnok (status) || status == SS$_BUFFEROVF) TimeString[0] = '\0'; else TimeString[Length] = '\0'; return (status); } /*****************************************************************************/ /* Create an ISO 8601 format UTC (GMT) basic time string in the storage pointed at by 'TimeString', e.g. "19950825T173240.34Z+0000", or separated local time string, e.g. "1995-08-25T17:32:40.34Z+0930". This must be at least 32 characters capacity. If 'Time64Ptr' is NULL the time string represents the current time. If it points to a quadword, VMS time value the string represents that time. */ int HttpIsoTimeString ( BOOL LocalTimeZone, char *TimeString, ulong *Time64Ptr ) { static $DESCRIPTOR (UtcTimeFaoDsc, "!4ZL!2ZL!2ZLT!2ZL!2ZL!2ZL.!2ZL+0000"); static $DESCRIPTOR (LocalTimeFaoDsc, "!4ZL-!2ZL-!2ZLT!2ZL:!2ZL:!2ZL.!2ZL!AZ"); static $DESCRIPTOR (TimeStringDsc, ""); int status; ulong Time64 [QUAD2]; ushort Length; ushort NumTime [7]; /*********/ /* begin */ /*********/ if (WATCH_MODULE(WATCH_MOD__OTHER)) WatchThis (WATCHALL, WATCH_MOD__OTHER, "HttpIsoTimeString()"); if (Time64Ptr) PUT_QUAD_QUAD (Time64Ptr, Time64) else sys$gettim (&Time64); if (!LocalTimeZone) if (VMSnok (status = TimeAdjustGMT (true, &Time64))) return (status); status = sys$numtim (&NumTime, &Time64); /* set the descriptor address and size of the resultant time string */ TimeStringDsc.dsc$w_length = 31; TimeStringDsc.dsc$a_pointer = TimeString; if (LocalTimeZone) status = sys$fao (&LocalTimeFaoDsc, &Length, &TimeStringDsc, NumTime[0], NumTime[1], NumTime[2], NumTime[3], NumTime[4], NumTime[5], NumTime[6], TimeZoneString); else status = sys$fao (&UtcTimeFaoDsc, &Length, &TimeStringDsc, NumTime[0], NumTime[1], NumTime[2], NumTime[3], NumTime[4], NumTime[5], NumTime[6]); if (VMSnok (status) || status == SS$_BUFFEROVF) TimeString[0] = '\0'; else TimeString[Length] = '\0'; return (status); } /*****************************************************************************/ /* Given a string such as "Fri, 25 Aug 1995 17:32:40 GMT" (RFC1123), or "Friday, 25-Aug-1995 17:32:40 GMT" (RFC 1036), create an internal, local, binary time with the current GMT offset. See complementary function HttpGmTimeString(). */ int HttpGmTime ( char *TimeString, ulong *Time64Ptr ) { static char *MonthName [] = { "", "Jan", "Feb", "Mar", "Apr", "May", "Jun", "Jul", "Aug", "Sep", "Oct", "Nov", "Dec" }; int status; ushort Length; ushort NumTime [7] = { 0,0,0,0,0,0,0 }; ulong DayOfWeek; char *tptr; /*********/ /* begin */ /*********/ tptr = TimeString; /* hunt straight for the comma after the weekday name! */ while (*tptr && *tptr != ',') tptr++; if (*tptr) tptr++; /* span white space between weekday name and date */ while (*tptr && ISLWS(*tptr)) tptr++; if (!*tptr) return (STS$K_ERROR); /* get the date and then skip to month name */ if (isdigit(*tptr)) NumTime[2] = atoi (tptr); while (*tptr && isdigit(*tptr)) tptr++; while (*tptr && (*tptr == '-' || ISLWS(*tptr))) tptr++; if (!*tptr) return (STS$K_ERROR); /* get the month number from the name and skip to the year */ for (NumTime[1] = 1; NumTime[1] <= 12; NumTime[1]++) if (strsame (tptr, MonthName[NumTime[1]], 3)) break; if (NumTime[1] > 12) return (STS$K_ERROR); while (isalpha(*tptr)) tptr++; while (*tptr && (*tptr == '-' || ISLWS(*tptr))) tptr++; if (!*tptr) return (STS$K_ERROR); /* get the year and then skip to the hour */ if (isdigit(*tptr)) { NumTime[0] = atoi (tptr); if (NumTime[0] <= 99) { /* for older browsers supplying 2 digit years, some Y2K insurance! */ if (NumTime[0] >= 70) NumTime[0] += 1900; else NumTime[0] += 2000; } } while (*tptr && isdigit(*tptr)) tptr++; while (*tptr && ISLWS(*tptr)) tptr++; if (!*tptr) return (STS$K_ERROR); /* get the hour, minute and second */ if (isdigit(*tptr)) NumTime[3] = atoi (tptr); while (*tptr && isdigit(*tptr)) tptr++; if (*tptr == ':') tptr++; if (isdigit(*tptr)) NumTime[4] = atoi (tptr); while (*tptr && isdigit(*tptr)) tptr++; if (*tptr == ':') tptr++; if (isdigit(*tptr)) NumTime[5] = atoi (tptr); while (*tptr && isdigit(*tptr)) tptr++; if (*tptr == ':') tptr++; if (!*tptr) return (STS$K_ERROR); /* the only thing remaining should be the "GMT" */ while (*tptr && ISLWS(*tptr)) tptr++; if (!MATCH3 (tptr, "GMT")) return (STS$K_ERROR); /*******************************************/ /* convert what looks like legitimate GMT! */ /*******************************************/ status = lib$cvt_vectim (&NumTime, Time64Ptr); if (VMSnok (status)) return (status); return (TimeAdjustGMT (false, Time64Ptr)); } /*****************************************************************************/ /* Determine the offset from GMT (UTC) using either the WASD_GMT or HTTPD$GMT or SYS$TIMEZONE_DIFFERENTIAL logicals. If WASD_GMT and HTTPD$GMT is not defined time should be set from the timezone differential logical. Function RequestBegin() calls this every hour to recheck GMT offset and detect daylight saving or other timezone changes. */ int TimeSetGMT () { static BOOL UseTimezoneDifferential = false; int status; /*********/ /* begin */ /*********/ if (!UseTimezoneDifferential) { status = TimeSetHttpdGmt(); /* return if error and that error was not that the name did not exist */ if (VMSok (status) || status != SS$_NOLOGNAM) return (status); } UseTimezoneDifferential = true; return (TimeSetTimezone()); } /*****************************************************************************/ /* The SYS$TIMEZONE_DIFFERENTIAL logical contains the number of seconds offset from GMT (UTC) as a positive (ahead) or negative (behind) number. Set the 'TimeGmtString' global storage to a "+hh:mm" or "-hh:mm" string equivalent, and the 'TimeAheadOfGmt' global boolean and 'TimeGmtVmsString' delta-time global string. */ int TimeSetTimezone () { static ushort Length; static $DESCRIPTOR (TimezoneLogicalNameDsc, "SYS$TIMEZONE_DIFFERENTIAL"); static $DESCRIPTOR (LnmSystemDsc, "LNM$SYSTEM"); static $DESCRIPTOR (TimeGmtStringFaoDsc, "!AZ!2ZL:!2ZL"); static $DESCRIPTOR (TimeGmtVmsStringFaoDsc, "0 !2ZL:!2ZL"); static $DESCRIPTOR (TimeZoneStringFaoDsc, "!AZ!2ZL!2ZL"); static VMS_ITEM_LIST3 LnmItems [] = { { sizeof(TimeGmtString)-1, LNM$_STRING, TimeGmtString, &Length }, { 0,0,0,0 } }; int status; long Hours, Minutes, Seconds; char *SignPtr; $DESCRIPTOR (TimeGmtStringDsc, TimeGmtString); $DESCRIPTOR (TimeGmtVmsStringDsc, TimeGmtVmsString); $DESCRIPTOR (TimeZoneStringDsc, TimeZoneString); /*********/ /* begin */ /*********/ status = sys$trnlnm (0, &LnmSystemDsc, &TimezoneLogicalNameDsc, 0, &LnmItems); if (VMSnok (status)) return (status); TimeGmtString[Length] = '\0'; Seconds = atol(TimeGmtString); if (Seconds < 0) { TimeAheadOfGmt = false; Seconds = -Seconds; SignPtr = "-"; } else { TimeAheadOfGmt = true; SignPtr = "+"; } Hours = Seconds / 3600; Minutes = (Seconds - Hours * 3600) / 60; sys$fao (&TimeGmtStringFaoDsc, &Length, &TimeGmtStringDsc, SignPtr, Hours, Minutes); TimeGmtString[Length] = '\0'; sys$fao (&TimeGmtVmsStringFaoDsc, &Length, &TimeGmtVmsStringDsc, Hours, Minutes); TimeGmtVmsString[Length] = '\0'; sys$fao (&TimeZoneStringFaoDsc, &Length, &TimeZoneStringDsc, SignPtr, Hours, Minutes); TimeZoneString[Length] = '\0'; TimeGmtVmsStringDsc.dsc$w_length = Length; if (VMSnok (status = sys$bintim (&TimeGmtVmsStringDsc, &TimeGmtDeltaBinary))) return (status); if (QUAD_NOT_ZERO(TimeGmtDeltaBinary)) return (status); /* time must have been zero, make it one, one-hundreth of a second */ TimeGmtDeltaBinary[0] = -100000; TimeGmtDeltaBinary[1] = -1; return (SS$_NORMAL); } /*****************************************************************************/ /* Translate the logical WASD_GMT or HTTPD$GMT (defined to be something like "+10:30" or "-01:15") and convert it into a delta time structure and store in 'TimeGmtDeltaBinary'. Store whether it is in advance or behind GMT in boolean 'TimeAheadOfGmt'. Store the logical string in 'TimeGmtString'. */ int TimeSetHttpdGmt () { static ushort Length; static $DESCRIPTOR (WasdLogNameDsc, "WASD_GMT"); static $DESCRIPTOR (HttpdLogNameDsc, "HTTPD$GMT"); static $DESCRIPTOR (LnmFileDevDsc, "LNM$FILE_DEV"); static VMS_ITEM_LIST3 LnmItems [] = { { sizeof(TimeGmtString)-1, LNM$_STRING, TimeGmtString, &Length }, { 0,0,0,0 } }; int status; char *cptr, *sptr; $DESCRIPTOR (TimeGmtVmsStringDsc, TimeGmtVmsString); /*********/ /* begin */ /*********/ status = sys$trnlnm (0, &LnmFileDevDsc, &WasdLogNameDsc, 0, &LnmItems); if (VMSnok (status)) { status = sys$trnlnm (0, &LnmFileDevDsc, &HttpdLogNameDsc, 0, &LnmItems); if (VMSnok (status)) return (status); } TimeGmtString[Length] = '\0'; if (TimeGmtString[0] == '$') return (SS$_NORMAL); if (*(cptr = TimeGmtString) == '-') TimeAheadOfGmt = false; else TimeAheadOfGmt = true; if (*cptr == '+' || *cptr == '-') cptr++; sptr = TimeGmtVmsString; *sptr++ = '0'; *sptr++ = ' '; while (*cptr) *sptr++ = *cptr++; *sptr = '\0'; TimeGmtVmsStringDsc.dsc$w_length = sptr - TimeGmtVmsString; if (VMSnok (status = sys$bintim (&TimeGmtVmsStringDsc, &TimeGmtDeltaBinary))) return (status); if (QUAD_NOT_ZERO(TimeGmtDeltaBinary)) return (status); /* time must have been zero, make it one, one-hundreth of a second */ TimeGmtDeltaBinary[0] = -100000; TimeGmtDeltaBinary[1] = -1; return (SS$_NORMAL); } /*****************************************************************************/ /* The GMT is generated by calculating using an offset using 'TimeGmtDeltaOffset' and boolean 'TimeAheadOfGmt'. Adjust either to or from GMT. */ int TimeAdjustGMT ( BOOL ToGmTime, ulong *Time64Ptr ) { int status; ulong AdjustedTime [QUAD2]; /*********/ /* begin */ /*********/ if ((ToGmTime && TimeAheadOfGmt) || (!ToGmTime && !TimeAheadOfGmt)) { /* to GMT from local and ahead of GMT, or to local from GMT and behind */ status = lib$sub_times (Time64Ptr, &TimeGmtDeltaBinary, &AdjustedTime); } else { /* to GMT from local and behind GMT, or to local from GMT and ahead */ status = lib$add_times (Time64Ptr, &TimeGmtDeltaBinary, &AdjustedTime); } PUT_QUAD_QUAD (AdjustedTime, Time64Ptr); return (status); } /*****************************************************************************/ /* */ char* DigitDayTime (ulong *Time64Ptr) { static char TimeString [16]; static $DESCRIPTOR (TimeFaoDsc, "!2ZL !2ZL:!2ZL:!2ZL\0"); static $DESCRIPTOR (TimeStringDsc, TimeString); int status; ulong Time64[QUAD2]; ushort NumTime [7]; /*********/ /* begin */ /*********/ if (!Time64Ptr) sys$gettim (Time64Ptr = &Time64); if (VMSnok (status = sys$numtim (&NumTime, Time64Ptr))) return ("*ERROR*"); if (VMSnok (sys$fao (&TimeFaoDsc, 0, &TimeStringDsc, NumTime[2], NumTime[3], NumTime[4], NumTime[5]))) return ("*ERROR*"); return (TimeString); } /*****************************************************************************/ /* Return a pointer to the name of the day of the week for the supplied binary time. If a NULL pointer to the binary time then return current day of week. */ char* DayOfWeekName (ulong *Time64Ptr) { int status; ulong DayOfWeek; ulong Time64[QUAD2]; /*********/ /* begin */ /*********/ if (!Time64Ptr) sys$gettim (Time64Ptr = &Time64); if (VMSnok (status = lib$day_of_week (Time64Ptr, &DayOfWeek))) DayOfWeek = 0; return (DayName[DayOfWeek]); } /*****************************************************************************/ /* HTTP/1.0 and HTTP/1.1 requests. If the content length has changed (HTTP/1.0 de facto standard), or if it has been modified since the specified date and time then return a normal status indicating that the object has been modified. If not modified then create a 304 HTTP header and return a LIB$_NEGTIM status to indicate the file should not be sent. With VMS' fractions of a second, add one second to the specified 'since' time to ensure a reliable comparison. Returns NORMAL if modified, NEGTIM if not modified. Implements defacto HTTP/1.0 persistent connections. Currently we only provide "keep-alive" response if we're sending a file in binary mode and know its precise length. An accurate "Content-Length:" field is vital for the client's correct reception of the transmitted data. The only other time a "keep-alive" response can be provided is HERE, where a 304 header is returned (it has a content length of precisely zero!) */ int HttpIfModifiedSince ( REQUEST_STRUCT *rqptr, ulong *RdtTime64Ptr, int LastContentLength ) { static ulong OneSecondDelta [QUAD2] = { -10000000, -1 }; int status; ulong AdjustedTime64[QUAD2], ScratchTime64 [QUAD2]; /*********/ /* begin */ /*********/ if (WATCH_MODULE(WATCH_MOD__OTHER)) WatchThis (WATCHALL, WATCH_MOD__OTHER, "HttpIfModifiedSince() !UL !UL !%D", LastContentLength, rqptr->rqHeader.IfModifiedSinceLength, &rqptr->rqTime.IfModifiedSinceTime64[0]); if (QUAD_ZERO(rqptr->rqTime.IfModifiedSinceTime64)) return (SS$_NORMAL); if (rqptr->rqHeader.HttpVersion == HTTP_VERSION_1_0 && rqptr->rqHeader.IfModifiedSinceLength >= 0 && LastContentLength >= 0 && rqptr->rqHeader.IfModifiedSinceLength != LastContentLength) return (SS$_NORMAL); /* add one second to the modified time, ensures a negative time */ status = lib$add_times (&rqptr->rqTime.IfModifiedSinceTime64, &OneSecondDelta, &AdjustedTime64); if (VMSnok (status)) { rqptr->rqResponse.ErrorTextPtr = "lib$add_times()"; ErrorVmsStatus (rqptr, status, FI_LI); return (status); } if (WATCH_MODULE(WATCH_MOD__OTHER)) WatchThis (WATCHALL, WATCH_MOD__OTHER, "!%D", &AdjustedTime64); /* a positive time results the file has been modified */ status = lib$sub_times (RdtTime64Ptr, &AdjustedTime64, &ScratchTime64); /* modified */ if (VMSok (status)) return (SS$_NORMAL); if (status == LIB$_NEGTIM) { /* not modified (note the zero content length!) */ ResponseHeader (rqptr, 304, NULL, 0, NULL, NULL); return (LIB$_NEGTIM); } /* woops */ rqptr->rqResponse.ErrorTextPtr = "lib$sub_times()"; ErrorVmsStatus (rqptr, status, FI_LI); return (status); } /*****************************************************************************/ /* HTTP/1.1 if-not-modified-since request. If it has NOT been modified since the specified date and time then return a normal status indicating that the object has not been modified. If modified then create a 412 HTTP header (precondition failed) and return a LIB$_NEGTIM status to indicate the request should not be processed. With VMS' fractions of a second, add one second to the specified 'since' time to ensure a reliable comparison. Returns NORMAL if modified, NEGTIM if not modified. */ int HttpIfUnModifiedSince ( REQUEST_STRUCT *rqptr, ulong *RdtTime64Ptr ) { static ulong OneSecondDelta [QUAD2] = { -10000000, -1 }; int status; ulong AdjustedTime64[QUAD2], ScratchTime64 [QUAD2]; /*********/ /* begin */ /*********/ if (WATCH_MODULE(WATCH_MOD__OTHER)) WatchThis (WATCHALL, WATCH_MOD__OTHER, "HttpIfUnModifiedSince() !%D", &rqptr->rqTime.IfModifiedSinceTime64); if (QUAD_ZERO(rqptr->rqTime.IfUnModifiedSinceTime64)) return (SS$_NORMAL); /* add one second to the modified time, ensures a negative time */ status = lib$add_times (&rqptr->rqTime.IfModifiedSinceTime64, &OneSecondDelta, &AdjustedTime64); if (VMSnok (status)) { rqptr->rqResponse.ErrorTextPtr = "lib$add_times()"; ErrorVmsStatus (rqptr, status, FI_LI); return (status); } if (WATCH_MODULE(WATCH_MOD__OTHER)) WatchThis (WATCHALL, WATCH_MOD__OTHER, "!%D", &AdjustedTime64); /* a positive time results the file has been modified */ status = lib$sub_times (RdtTime64Ptr, &AdjustedTime64, &ScratchTime64); if (VMSok (status)) { /* modified, precondition failed (note the zero content length!) */ ResponseHeader (rqptr, 412, NULL, 0, NULL, NULL); return (SS$_NORMAL); } /* if not modified! */ if (status == LIB$_NEGTIM) return (LIB$_NEGTIM); /* woops */ rqptr->rqResponse.ErrorTextPtr = "lib$sub_times()"; ErrorVmsStatus (rqptr, status, FI_LI); return (status); } /*****************************************************************************/ /* HTTP/1.1 if-range not modified since. Returns NORMAL if modified, NEGTIM if not modified. */ int HttpIfRange ( REQUEST_STRUCT *rqptr, ulong *RdtTime64Ptr ) { static ulong OneSecondDelta [QUAD2] = { -10000000, -1 }; int status; ulong AdjustedTime64[QUAD2], ScratchTime64 [QUAD2]; /*********/ /* begin */ /*********/ if (WATCH_MODULE(WATCH_MOD__OTHER)) WatchThis (WATCHALL, WATCH_MOD__OTHER, "HttpIfRange() !%D", &rqptr->rqTime.IfRangeBeginTime64[0]); if (QUAD_ZERO(rqptr->rqTime.IfRangeBeginTime64)) return (SS$_NORMAL); /* add one second to the modified time, ensures a negative time */ status = lib$add_times (&rqptr->rqTime.IfRangeBeginTime64, &OneSecondDelta, &AdjustedTime64); if (VMSnok (status)) { rqptr->rqResponse.ErrorTextPtr = "lib$add_times()"; ErrorVmsStatus (rqptr, status, FI_LI); return (status); } if (WATCH_MODULE(WATCH_MOD__OTHER)) WatchThis (WATCHALL, WATCH_MOD__OTHER, "!%D", &AdjustedTime64); /* a positive time results the file has been modified */ status = lib$sub_times (RdtTime64Ptr, &AdjustedTime64, &ScratchTime64); if (VMSok (status)) { /* modified, cancel any range data */ if (rqptr->rqHeader.RangeBytePtr) rqptr->rqHeader.RangeBytePtr->Total = 0; return (SS$_NORMAL); } /* if not modified! */ if (status == LIB$_NEGTIM) return (LIB$_NEGTIM); /* woops */ rqptr->rqResponse.ErrorTextPtr = "lib$sub_times()"; ErrorVmsStatus (rqptr, status, FI_LI); return (status); } /*****************************************************************************/ /* Return a reasonable HTTP status from the supplied VMS status. */ int VmsToHttpStatus (int VmsStatus) { int HttpStatus; /*********/ /* begin */ /*********/ if (VmsStatus == RMS$_FNF || VmsStatus == RMS$_DNF || VmsStatus == RMS$_DEV || VmsStatus == SS$_NOSUCHDEV || VmsStatus == SS$_NOSUCHFILE) HttpStatus = 404; else if (VmsStatus == RMS$_SYN || VmsStatus == RMS$_FNM || VmsStatus == RMS$_TYP || VmsStatus == RMS$_VER || VmsStatus == RMS$_DIR || VmsStatus == SS$_BADFILENAME || VmsStatus == SS$_BADFILEVER || VmsStatus == SS$_BADIRECTORY) HttpStatus = 403; else if (VmsStatus == RMS$_FLK) HttpStatus = 423; else if (VmsStatus == SS$_DIRNOTEMPTY || VmsStatus == SS$_EXDISKQUOTA) HttpStatus = 409; else if (VmsStatus == RMS$_PRV || VmsStatus == SS$_NOPRIV) HttpStatus = 403; else if (VmsStatus == SS$_CREATED) HttpStatus = 201; else if (VmsStatus & 1) HttpStatus = 200; else HttpStatus = 500; if (WATCH_MODULE(WATCH_MOD__OTHER)) WatchThis (WATCHALL, WATCH_MOD__OTHER, "VmsToHttpStatus() !&S !UL", VmsStatus, HttpStatus); return (HttpStatus); } /*****************************************************************************/ /* Return the a pointer to abbreviated meaning of the supplied HTTP status code. These are typical of those included on the response header status line. */ char *HttpStatusCodeText (int StatusCode) { /*********/ /* begin */ /*********/ switch (StatusCode) { case 100 : return ("Continue"); /* (HTTP/1.1) */ case 101 : return ("Switching Protocols"); /* (HTTP/1.1) */ case 102 : return ("Processing"); /* (WebDAV - RFC2581) */ case 200 : return ("OK"); case 201 : return ("Created"); case 202 : return ("Accepted"); case 203 : return ("Non-authoritative"); /* (HTTP/1.1) */ case 204 : return ("No Content"); case 205 : return ("Reset Content"); /* (HTTP/1.1) */ case 206 : return ("Partial Content"); /* (HTTP/1.1) */ case 207 : return ("Multistatus"); /* (WebDAV - RFC2581) */ case 300 : return ("Multiple Choices"); /* (HTTP/1.1) */ case 301 : return ("Moved Permanently"); case 302 : return ("Found (Moved Temporarily)"); case 303 : return ("See Other"); /* (HTTP/1.1) */ case 304 : return ("Not Modified"); case 305 : return ("Use Proxy"); /* (HTTP/1.1) */ case 306 : return ("[reserved]"); case 307 : return ("Temporary Redirect"); /* (HTTP/1.1) */ case 400 : return ("Bad Request"); case 401 : return ("Authorization Required"); case 402 : return ("Payment Required"); /* (HTTP/1.1) */ case 403 : return ("Forbidden"); case 404 : return ("Not Found"); case 405 : return ("Method Not Allowed"); /* (HTTP/1.1) */ case 406 : return ("Not Acceptable"); /* (HTTP/1.1) */ case 407 : return ("Proxy Authentication Required"); /* (HTTP/1.1) */ case 408 : return ("Request Timeout"); /* (HTTP/1.1) */ case 409 : return ("Conflict"); /* (HTTP/1.1) */ case 410 : return ("Gone"); /* (HTTP/1.1) */ case 411 : return ("Length Required"); /* (HTTP/1.1) */ case 412 : return ("Precondition Failed"); /* (HTTP/1.1) */ case 413 : return ("Request Entity Too Large"); /* (HTTP/1.1) */ case 414 : return ("Request URI Too Long"); /* (HTTP/1.1) */ case 415 : return ("Unsupported Media Type"); /* (HTTP/1.1) */ case 416 : return ("Requested Range Not Satisfiable"); /* (HTTP/1.1) */ case 417 : return ("Expectation Failed"); /* (HTTP/1.1) */ case 418 : return ("I'm a teapot"); /* (RFC2324) */ case 421 : return ("Misdirected Request"); /* (HTTP/2 - RFC7540) */ case 422 : return ("Unprocessable Entity"); /* (WebDAV - RFC2581) */ case 423 : return ("Locked"); /* (WebDAV - RFC2581) */ case 424 : return ("Failed Dependency"); /* (WebDAV - RFC2581) */ case 426 : return ("Upgrade Required"); /* (RFC2847) */ case 500 : return ("Internal Error"); case 501 : return ("Not Implemented"); case 502 : return ("Bad Gateway"); case 503 : return ("Service Unavailable"); case 504 : return ("Gateway Timeout"); /* (HTTP/1.1) */ case 505 : return ("HTTP Version Not Supported"); /* (HTTP/1.1) */ case 507 : return ("Insufficient Storage"); /* (WebDAV - RFC2581) */ default : return ("Unknown Code!"); } } /*****************************************************************************/ /* Return the a pointer an explanation of the supplied HTTP status code. These are supplied from the message database can be are used in error messages, etc. */ char *HttpStatusCodeExplanation ( REQUEST_STRUCT *rqptr, int StatusCode ) { /*********/ /* begin */ /*********/ switch (StatusCode) { /* continue (HTTP/1.1) */ case 100 : return (MsgFor(rqptr,MSG_HTTP_100)); /* switching protocols (HTTP/1.1) */ case 101 : return (MsgFor(rqptr,MSG_HTTP_101)); /* processing (WedDAV - RFC2518) */ case 102 : return ("processing"); /* success */ case 200 : return (MsgFor(rqptr,MSG_HTTP_200)); /* created */ case 201 : return (MsgFor(rqptr,MSG_HTTP_201)); /* accepted */ case 202 : return (MsgFor(rqptr,MSG_HTTP_202)); /* non-authoritative (HTTP/1.1) */ case 203 : return (MsgFor(rqptr,MSG_HTTP_203)); /* no content */ case 204 : return (MsgFor(rqptr,MSG_HTTP_204)); /* reset content (HTTP/1.1) */ case 205 : return (MsgFor(rqptr,MSG_HTTP_205)); /* partial content (HTTP/1.1) */ case 206 : return (MsgFor(rqptr,MSG_HTTP_206)); /* multi-status (WedDAV - RFC2518) */ case 207 : return ("multi-status"); /* multiple choices (HTTP/1.1) */ case 300 : return (MsgFor(rqptr,MSG_HTTP_300)); /* moved permanently */ case 301 : return (MsgFor(rqptr,MSG_HTTP_301)); /* moved temporarily */ case 302 : return (MsgFor(rqptr,MSG_HTTP_302)); /* see other (HTTP/1.1) */ case 303 : return (MsgFor(rqptr,MSG_HTTP_303)); /* not modified */ case 304 : return (MsgFor(rqptr,MSG_HTTP_304)); /* use proxy (HTTP/1.1) */ case 305 : return (MsgFor(rqptr,MSG_HTTP_305)); /* reserved (WedDAV - RFC2518) */ case 306 : return ("reserved"); /* temporary redirect (WedDAV - RFC2518) */ case 307 : return ("temporary redirect"); /* bad request */ case 400 : return (MsgFor(rqptr,MSG_HTTP_400)); /* authorization required */ case 401 : return (MsgFor(rqptr,MSG_HTTP_401)); /* payment required */ case 402 : return (MsgFor(rqptr,MSG_HTTP_402)); /* forbidden */ case 403 : return (MsgFor(rqptr,MSG_HTTP_403)); /* not found */ case 404 : return (MsgFor(rqptr,MSG_HTTP_404)); /* method not allowed (HTTP/1.1) */ case 405 : return (MsgFor(rqptr,MSG_HTTP_405)); /* not acceptable (HTTP/1.1) */ case 406 : return (MsgFor(rqptr,MSG_HTTP_406)); /* proxy authentication required (HTTP/1.1) */ case 407 : return (MsgFor(rqptr,MSG_HTTP_407)); /* request timeout (HTTP/1.1) */ case 408 : return (MsgFor(rqptr,MSG_HTTP_408)); /* resource conflict (HTTP/1.1) */ case 409 : return (MsgFor(rqptr,MSG_HTTP_409)); /* gone (HTTP/1.1) */ case 410 : return (MsgFor(rqptr,MSG_HTTP_410)); /* length required (HTTP/1.1) */ case 411 : return (MsgFor(rqptr,MSG_HTTP_411)); /* precondition failed (HTTP/1.1) */ case 412 : return (MsgFor(rqptr,MSG_HTTP_412)); /* request entity too large (HTTP/1.1) */ case 413 : return (MsgFor(rqptr,MSG_HTTP_413)); /* request-URI too long (HTTP/1.1) */ case 414 : return (MsgFor(rqptr,MSG_HTTP_414)); /* unsupported media type (HTTP/1.1) */ case 415 : return (MsgFor(rqptr,MSG_HTTP_415)); /* requested range not satisfiable (HTTP/1.1) */ case 416 : return (MsgFor(rqptr,MSG_HTTP_416)); /* expectation failed (HTTP/1.1) */ case 417 : return (MsgFor(rqptr,MSG_HTTP_417)); /* misdirected request (HTTP/2 - RFC7540) */ case 421 : return ("misdirected request"); /* unprocessable entity (WedDAV - RFC2518) */ case 422 : return ("unprocessable entity"); /* locked (WedDAV - RFC2518) */ case 423 : return ("locked"); /* internal error */ case 500 : return (MsgFor(rqptr,MSG_HTTP_500)); /* not implemented */ case 501 : return (MsgFor(rqptr,MSG_HTTP_501)); /* bad gateway */ case 502 : return (MsgFor(rqptr,MSG_HTTP_502)); /* service unavailable */ case 503 : return (MsgFor(rqptr,MSG_HTTP_503)); /* gateway timeout (HTTP/1.1) */ case 504 : return (MsgFor(rqptr,MSG_HTTP_504)); /* HTTP version not supported (HTTP/1.1) */ case 505 : return (MsgFor(rqptr,MSG_HTTP_505)); /* unknown code! */ default : return ("The server is reporting an UNKNOWN status code!"); } } /*****************************************************************************/ /* Returns 1 if time 1 is later than time 2, 0 if the same, and -1 if time 1 is earlier than time 2. */ int CompareVmsTime64 ( ulong *Time64Ptr1, ulong *Time64Ptr2 ) { int status; ulong Time64 [QUAD2]; /*********/ /* begin */ /*********/ status = lib$sub_times (Time64Ptr1, Time64Ptr2, Time64); if (status == LIB$_NEGTIM) return (-1); else if (VMSok (status)) { if (QUAD_EQUAL_QUAD(Time64Ptr1, Time64Ptr2)) return (0); else return (1); } else { #ifndef __VAX ErrorExitVmsStatus (status, "lib$sub_times()", FI_LI); #else if (SysInfo.VersionInteger >= 730) ErrorExitVmsStatus (status, "lib$sub_times()", FI_LI); else if (status == SS$_IVTIME) { /* at least VAX VMS V6.2 returns IVTIME when others do not */ ErrorNoticed (NULL, status, "lib$sub_times()", FI_LI); return (0); } else ErrorExitVmsStatus (status, "lib$sub_times()", FI_LI); #endif } } /*****************************************************************************/ /* Returns a pointer to a VmGetHeap()ed string of tags for an internally generated HTML document. */ char* HtmlMetaInfo ( REQUEST_STRUCT *rqptr, char *VmsInfoPtr ) { int status; ulong FaoVector [16]; ulong *vecptr; ushort Length; char *MetaPtr; char Buffer [2048]; /*********/ /* begin */ /*********/ vecptr = &FaoVector; *vecptr++ = SoftwareID; *vecptr++ = rqptr->rqTime.GmDateTime; if (rqptr->RemoteUser[0]) { *vecptr++ = "\n"; *vecptr++ = rqptr->RemoteUser; *vecptr++ = rqptr->rqAuth.RealmDescrPtr; *vecptr++ = rqptr->ServicePtr->ServerHostPort; } else { *vecptr++ = "\n"; *vecptr++ = rqptr->ServicePtr->ServerHostPort; } if (VmsInfoPtr && VmsInfoPtr[0]) { if (Config.cfReport.MetaInfoEnabled) { *vecptr++ = "\n!&@"; *vecptr++ = VmsInfoPtr; if (rqptr->PathOds) { *vecptr++ = "\n"; switch (rqptr->PathOds) { case MAPURL_PATH_ODS_2 : *vecptr++ = "2"; break; case MAPURL_PATH_ODS_5 : *vecptr++ = "5"; break; case MAPURL_PATH_ODS_ADS : *vecptr++ = "ADS"; break; case MAPURL_PATH_ODS_PWK : *vecptr++ = "PWK"; break; case MAPURL_PATH_ODS_SMB : *vecptr++ = "SMB"; break; case MAPURL_PATH_ODS_SRI : *vecptr++ = "SRI"; break; default : *vecptr++ = "?"; } } else *vecptr++ = ""; } else *vecptr++ = ""; } else *vecptr++ = ""; status = FaolToBuffer (Buffer, sizeof(Buffer), &Length, "\n\ \n\ !&@\ !&@\ \n", &FaoVector); if (VMSnok (status) || status == SS$_BUFFEROVF) { ErrorNoticed (rqptr, status, NULL, FI_LI); return ("\n"); } MetaPtr = VmGetHeap (rqptr, Length+1); memcpy (MetaPtr, Buffer, Length+1); return (MetaPtr); } /*****************************************************************************/ /* Return a string containing a duration string. Durations are in standard (VMS) 100nS units. If less than one minute provide as 'seconds.micro[milli]seconds'. If a minute or greater as '[ddd-]hh.mm.ss'. */ char* DurationString ( REQUEST_STRUCT *rqptr, ulong *Time64Ptr ) { static $DESCRIPTOR (DateFaoDsc, "!13%D\0"); static $DESCRIPTOR (TimeFaoDsc, "!8%T\0"); static $DESCRIPTOR (TimeDsc, ""); double dsecs; char *sptr; /*********/ /* begin */ /*********/ if (WATCHMOD (rqptr, WATCH_MOD__OTHER)) WatchThis (WATCHITM(rqptr), WATCH_MOD__OTHER, "DurationString() !&X !&X !%T", Time64Ptr[0], Time64Ptr[1], Time64Ptr); if (rqptr) sptr = VmGetHeap (rqptr, 32); else /* this might leak a bit! */ sptr = VmGet (32); /* if less than 60 seconds */ if ((Time64Ptr[1] == 0xffffffff && Time64Ptr[0] >= 0xdc3cba00) || (!Time64Ptr[0] && !Time64Ptr[1])) { /* less than one minute, give in seconds and fractions */ dsecs = (double)(-(long)Time64Ptr[0]); #ifndef __VAX sprintf (sptr, "%.6f", dsecs / 10000000.0); #else sprintf (sptr, "%.3f", dsecs / 10000000.0); #endif } else if (Time64Ptr[1] > 0xffffff36 || (Time64Ptr[1] == 0xffffff36 && Time64Ptr[0] >= 0xd5960000)) { /* less than twenty-four hours */ TimeDsc.dsc$a_pointer = sptr; TimeDsc.dsc$w_length = 32; sys$fao (&TimeFaoDsc, 0, &TimeDsc, Time64Ptr); } else if (Time64Ptr[1] && Time64Ptr[0]) { /* greater than twenty-four hours */ TimeDsc.dsc$a_pointer = sptr; TimeDsc.dsc$w_length = 32; sys$fao (&DateFaoDsc, 0, &TimeDsc, Time64Ptr); sptr[4] = 160; /* ISO8859-1 non-breaking space */ } else sptr = "0.0"; return (sptr); } /*****************************************************************************/ /* Return an allocated string containing the average duration. */ char* AverageDurationString ( REQUEST_STRUCT *rqptr, ulong *Time64Ptr, ulong Count ) { int status; ulong Time64 [QUAD2]; float fcount; /*********/ /* begin */ /*********/ if (WATCHMOD (rqptr, WATCH_MOD__OTHER)) WatchThis (WATCHITM(rqptr), WATCH_MOD__OTHER, "AverageDurationString() !&X !&X !%T", Time64Ptr[0], Time64Ptr[1], Time64Ptr); PUT_ZERO_QUAD (Time64); if (Count) { PUT_QUAD_QUAD (Time64Ptr, Time64); fcount = (float)Count; fcount = 1.0 / fcount; #ifndef __VAX /* could use lib$mults_delta_time() only it doesn't exist on V7.3 :-( */ status = cvt$convert_float (&fcount, CVT$K_IEEE_S, &fcount, CVT$K_VAX_F, 0); if (VMSnok (status)) { ErrorNoticed (rqptr, status, NULL, FI_LI); PUT_ZERO_QUAD (Time64); } #endif status = lib$multf_delta_time (&fcount, &Time64); if (VMSnok (status)) { ErrorNoticed (rqptr, status, NULL, FI_LI); PUT_ZERO_QUAD (Time64); } } return (DurationString (rqptr, &Time64)); } /*****************************************************************************/ /* Format a string containing how many seconds, minutes, hours, days ago from the current time. For example; "15s", "10m", "17h", "152d". Return VMS status. |AgoBuf| should be at least 16 chars. */ int ThisLongAgo ( ulong *Time64Ptr, char *AgoBuf ) { static ulong LibDeltaSecs = LIB$K_DELTA_SECONDS; static $DESCRIPTOR (AgoFaoDsc, "!UL!AZ\0"); static $DESCRIPTOR (AgoBufDsc, ""); int status; ulong SecsAgo; ulong AgoTime64 [2], NowTime64 [2]; /*********/ /* begin */ /*********/ if (WATCH_MODULE(WATCH_MOD__OTHER)) WatchThis (WATCHALL, WATCH_MOD__OTHER, "ThisLongAgo() !8XL", Time64Ptr); AgoBuf[0] = '\0'; if (QUAD_ZERO(Time64Ptr)) return (SS$_NORMAL); sys$gettim (&NowTime64); status = lib$sub_times (&NowTime64, Time64Ptr, &AgoTime64); if (VMSok (status)) status = lib$cvt_from_internal_time (&LibDeltaSecs, &SecsAgo, &AgoTime64); if (VMSnok (status)) return (status); AgoBufDsc.dsc$a_pointer = AgoBuf; AgoBufDsc.dsc$w_length = 16; status = SS$_NORMAL; if (SecsAgo >= (60*60*24)) status = sys$fao (&AgoFaoDsc, 0, &AgoBufDsc, SecsAgo / (60*60*24), "d"); else if (SecsAgo >= (60*60)) status = sys$fao (&AgoFaoDsc, 0, &AgoBufDsc, SecsAgo / (60*60), "h"); else if (SecsAgo >= 60) status = sys$fao (&AgoFaoDsc, 0, &AgoBufDsc, SecsAgo / 60, "m"); else if (SecsAgo > 1) status = sys$fao (&AgoFaoDsc, 0, &AgoBufDsc, SecsAgo, "s"); else strcpy (AgoBuf, "now"); return (status); } /*****************************************************************************/ /* Put into the supplied buffer the time with the year removed (e.g. 31-OCT 23:01:15"). The buffer should have at least 16 bytes capacity. */ void TimeSansYear ( ulong *Time64Ptr, char *Buffer ) { static $DESCRIPTOR (TimeFaoDsc, "!20%D\0"); static char TimeBuf [32]; static $DESCRIPTOR (TimeBufDsc, TimeBuf); int status; char *cptr, *sptr; /*********/ /* begin */ /*********/ if (WATCH_MODULE(WATCH_MOD__OTHER)) WatchThis (WATCHALL, WATCH_MOD__OTHER, "ThisLongAgo() !8XL", Time64Ptr); if (QUAD_ZERO(Time64Ptr)) { strcpy (Buffer, "(none)"); return; } Buffer[0] = '\0'; status = sys$fao (&TimeFaoDsc, 0, &TimeBufDsc, Time64Ptr); if (VMSnok (status)) return; sptr = Buffer; for (cptr = TimeBuf; *cptr && *cptr != '-'; *sptr++ = *cptr++); for (*sptr++ = *cptr++; *cptr && *cptr != '-'; *sptr++ = *cptr++); while (*cptr && *cptr != ' ') cptr++; while (*cptr) *sptr++ = *cptr++; *sptr = '\0'; } /*****************************************************************************/ /* Convert a VMS quadword, binary time to a Unix-style time component structure. */ BOOL TimeVmsToUnix ( ulong *Time64Ptr, struct tm *TmPtr ) { static ulong LibDayOfWeek = LIB$K_DAY_OF_WEEK; static ulong LibDayOfYear = LIB$K_DAY_OF_YEAR; int status; ulong DayOfWeek, DayOfYear; ushort NumTime [7]; ulong Time64 [QUAD2]; /*********/ /* begin */ /*********/ if (!Time64Ptr) sys$gettim (Time64Ptr = &Time64); if (VMSnok (status = sys$numtim (&NumTime, Time64Ptr))) return (status); lib$cvt_from_internal_time (&LibDayOfWeek, &DayOfWeek, Time64Ptr); lib$cvt_from_internal_time (&LibDayOfYear, &DayOfYear, Time64Ptr); TmPtr->tm_sec = NumTime[5]; TmPtr->tm_min = NumTime[4]; TmPtr->tm_hour = NumTime[3]; TmPtr->tm_mday = NumTime[2]; TmPtr->tm_mon = NumTime[1] - 1; TmPtr->tm_year = NumTime[0] - 1900; TmPtr->tm_wday = DayOfWeek; TmPtr->tm_yday = DayOfYear; TmPtr->tm_isdst = 0; return (SS$_NORMAL); } /****************************************************************************/ /* generate a standard VMS protection string from the mask. 'String' must be at least 28 bytes (better use 32 :^) Returns the length of the string. */ int FormatProtection ( ushort pmask, char *String ) { char *sptr; /*********/ /* begin */ /*********/ sptr = String; if (!(pmask & 0x0001)) *sptr++ = 'R'; if (!(pmask & 0x0002)) *sptr++ = 'W'; if (!(pmask & 0x0004)) *sptr++ = 'E'; if (!(pmask & 0x0008)) *sptr++ = 'D'; *sptr++ = ','; if (!(pmask & 0x0010)) *sptr++ = 'R'; if (!(pmask & 0x0020)) *sptr++ = 'W'; if (!(pmask & 0x0040)) *sptr++ = 'E'; if (!(pmask & 0x0080)) *sptr++ = 'D'; *sptr++ = ','; if (!(pmask & 0x0100)) *sptr++ = 'R'; if (!(pmask & 0x0200)) *sptr++ = 'W'; if (!(pmask & 0x0400)) *sptr++ = 'E'; if (!(pmask & 0x0800)) *sptr++ = 'D'; *sptr++ = ','; if (!(pmask & 0x1000)) *sptr++ = 'R'; if (!(pmask & 0x2000)) *sptr++ = 'W'; if (!(pmask & 0x4000)) *sptr++ = 'E'; if (!(pmask & 0x8000)) *sptr++ = 'D'; *sptr = '\0'; return (sptr - String); } /*****************************************************************************/ /* Just return the process' current BYTLM quota. */ GetJpiBytLm () { static ulong Pid = 0; static ulong JpiBytLm; static VMS_ITEM_LIST3 JpiItems [] = { { sizeof(JpiBytLm), JPI$_BYTLM, &JpiBytLm, 0 }, {0,0,0,0} }; int status; IO_SB IOsb; /*********/ /* begin */ /*********/ status = sys$getjpiw (EfnWait, &Pid, 0, &JpiItems, &IOsb, 0, 0); if (VMSok (status)) status = IOsb.Status; if (VMSok (status)) return (JpiBytLm); ErrorExitVmsStatus (status, NULL, FI_LI); } /*****************************************************************************/ /* Returns a pointer to a dynamic string containing the client host details as "name (address)" or just "address". */ char* ClientHostString (REQUEST_STRUCT *rqptr) { static $DESCRIPTOR (AddressFaoDsc, "!AZ\0"); static $DESCRIPTOR (NameAddressFaoDsc, "!AZ (!AZ)\0"); ushort Length; char *cptr; char Buffer [256]; $DESCRIPTOR (BufferDsc, Buffer); /*********/ /* begin */ /*********/ if (!strcmp (rqptr->ClientPtr->Lookup.HostName, &rqptr->ClientPtr->IpAddressString)) sys$fao (&AddressFaoDsc, &Length, &BufferDsc, &rqptr->ClientPtr->IpAddressString); else sys$fao (&NameAddressFaoDsc, &Length, &BufferDsc, rqptr->ClientPtr->Lookup.HostName, &rqptr->ClientPtr->IpAddressString); cptr = VmGetHeap (rqptr, Length); strcpy (cptr, Buffer); return (cptr); } /*****************************************************************************/ /* */ char* UserAtClient (REQUEST_STRUCT *rqptr) { char *cptr, *sptr, *zptr; char StringBuffer [256]; /*********/ /* begin */ /*********/ if (!rqptr->RemoteUser[0]) return (rqptr->ClientPtr->Lookup.HostName); zptr = (sptr = StringBuffer) + sizeof(StringBuffer)-1; for (cptr = rqptr->RemoteUser; *cptr; cptr++) if (!isalnum(*cptr) && *cptr != '-' && *cptr != '_') break; if (*cptr) *sptr++ = '\"'; for (cptr = rqptr->RemoteUser; *cptr && sptr < zptr; *sptr++ = *cptr++); if (StringBuffer[0] == '\"' && sptr < zptr) *sptr++ = '\"'; if (rqptr->rqAuth.RealmPtr) { if (sptr < zptr) *sptr++ = '.'; for (cptr = rqptr->rqAuth.RealmPtr; *cptr && sptr < zptr; *sptr++ = *cptr++); } if (sptr < zptr) *sptr++ = '@'; for (cptr = rqptr->ClientPtr->Lookup.HostName; *cptr && sptr < zptr; *sptr++ = *cptr++); *sptr = '\0'; cptr = VmGetHeap (rqptr, sptr-StringBuffer); strcpy (cptr, StringBuffer); return (cptr); } /****************************************************************************/ /* Given a buffer of UTF-8 convert in-situ to 8 bit ASCII. Ignore non- 8 bit ASCII characters. End-of-string is indicated by text-length not a null-character, however the resultant string is nulled. If supplied the 8 bit character 'SubsChar' is substituted for any non 8 bit code in the string. Return the number of converted characters. Return -1 if there is an error. The string is mangled if an error. */ int ConvertFromUtf8 ( char *UtfPtr, int UtfCount, char SubsChar ) { uchar ch; uchar *cptr, *sptr, *zptr; /*********/ /* begin */ /*********/ if (WATCH_MODULE(WATCH_MOD__OTHER)) WatchThis (WATCHALL, WATCH_MOD__OTHER, "ConvertFromUtf8() !&C !#H", SubsChar, UtfCount, UtfPtr); if (UtfCount == -1) UtfCount = strlen(UtfPtr); if (UtfCount < 0) return (-1); /* is there a potentially UTF-8 bit pattern here? */ for (zptr = (cptr = (uchar*)UtfPtr) + UtfCount; cptr < zptr; cptr++) if ((*cptr & 0xc0) == 0xc0) break; /* return if no UTF-8 conversion necessary (i.e. all 7 bit characters) */ if (cptr >= zptr) return (UtfCount); if (*cptr == 0xff) return (cptr - (uchar*)UtfPtr); sptr = cptr; while (cptr < zptr) { if ((*cptr & 0xf8) == 0xf0) { /* four byte sequence */ if (++cptr >= zptr) goto utf8_nbg; if ((*cptr & 0xc0) != 0x80) goto utf8_nbg; if (++cptr >= zptr) goto utf8_nbg; if ((*cptr & 0xc0) != 0x80) goto utf8_nbg; if (++cptr >= zptr) goto utf8_nbg; if ((*cptr & 0xc0) != 0x80) goto utf8_nbg; if (SubsChar) *sptr++ = SubsChar; } else if ((*cptr & 0xf0) == 0xe0) { /* three byte sequence */ if (++cptr >= zptr) goto utf8_nbg; if ((*cptr & 0xc0) != 0x80) goto utf8_nbg; if (++cptr >= zptr) goto utf8_nbg; if ((*cptr & 0xc0) != 0x80) goto utf8_nbg; if (SubsChar) *sptr++ = SubsChar; } else if ((*cptr & 0xe0) == 0xc0) { /* two byte sequence */ if (*cptr & 0x1c) { /* out-of-range character */ if (++cptr >= zptr) goto utf8_nbg; if ((*cptr & 0xc0) != 0x80) goto utf8_nbg; if (++cptr >= zptr) goto utf8_nbg; if (SubsChar) *sptr++ = SubsChar; } else { /* 8 bit ASCII 128 to 255 */ ch = (*cptr & 0x03) << 6; if (++cptr >= zptr) goto utf8_nbg; if ((*cptr & 0xc0) != 0x80) goto utf8_nbg; ch |= *cptr & 0x3f; *sptr++ = ch; cptr++; } } else { /* 8 bit ASCII 0 to 127 */ *sptr++ = *cptr++; } } *sptr = '\0'; return (sptr - (uchar*)UtfPtr); utf8_nbg: return (-1); } /****************************************************************************/ /* Given a buffer of 8 bit ASCII text convert it in-situ to UTF-8. Worst-case the buffer space needs to be two times in size (i.e. every character has the hi bit set requiring a leading UTF-8 byte). End-of-string is indicated by text-length not a null-character, however the resultant string is nulled. Return the length of the converted string. Return -1 if the buffer space will be too small. */ int ConvertToUtf8 ( char *TextPtr, int TextLength, int SizeOfText ) { int HiBitCount = 0; char *cptr, *sptr, *zptr; /*********/ /* begin */ /*********/ if (WATCH_MODULE(WATCH_MOD__OTHER)) WatchThis (WATCHALL, WATCH_MOD__OTHER, "ConvertFromUtf8() !!UL !#H", SizeOfText, TextLength, TextPtr); if (TextLength == -1) TextLength = strlen(TextPtr); for (zptr = (cptr = TextPtr) + TextLength; cptr < zptr; cptr++) if (*cptr & 0x80) HiBitCount++; if (!HiBitCount) return (TextLength); if (TextLength + HiBitCount >= SizeOfText - 1) return (-1); sptr = (cptr = (zptr = TextPtr) + TextLength - 1) + HiBitCount + 1; *sptr-- = '\0'; while (cptr >= zptr) { if (*cptr & 0x80) { *sptr-- = (*cptr & 0x3f) | 0x80; *sptr-- = ((*cptr-- & 0xc0) >> 6) | 0xc0; } else *sptr-- = *cptr--; } return (TextLength + HiBitCount); } /****************************************************************************/ /* For UTF-8 encoded file names hex-escape characters that cause issues. This is intended to feed into RMS services such as $PARSE. Return zero if the original string can be used. Return minus one if the buffer overflowed. Return the number of characters in the escaped string when the buffer should be used. */ int ConvertUtf8ToEscape ( char *FileSpec, char *BufferPtr, int BufferSize ) { static char HexDigit [] = "0123456789ABCDEF"; static char ScratchBuffer [ODS_MAX_FILE_NAME_LENGTH+1]; char *cptr, *sptr, *zptr; /*********/ /* begin */ /*********/ if (WATCH_MODULE(WATCH_MOD__OTHER)) WatchThis (WATCHALL, WATCH_MOD__OTHER, "ConvertUtf8ToEscape() !&Z", FileSpec); for (cptr = FileSpec; *cptr; cptr++) if (*(uchar*)cptr >= 0x80 && *(uchar*)cptr <= 0x9f) break; if (!*cptr) return (0); if (BufferPtr == FileSpec) { /* reusing the file spec buffer so put it into a scratch buffer */ zptr = (sptr = ScratchBuffer) + sizeof(ScratchBuffer)-1; for (cptr = FileSpec; *cptr && sptr < zptr; *sptr++ = *cptr++); if (sptr >= zptr) { BufferPtr[0] = '\0'; return (-1); } *sptr = '\0'; cptr = ScratchBuffer; } else cptr = FileSpec; zptr = (sptr = BufferPtr) + BufferSize - 1; while (*cptr && sptr < zptr) { if (*(uchar*)cptr >= 0x80 && *(uchar*)cptr <= 0x9f) { *sptr++ = '^'; if (sptr < zptr) *sptr++ = HexDigit[((uchar)*cptr & 0xf0) >> 4]; if (sptr < zptr) *sptr++ = HexDigit[(uchar)*cptr & 0x0f]; cptr++; } else *sptr++ = *cptr++; } if (sptr >= zptr) { BufferPtr[0] = '\0'; return (-1); } *sptr = '\0'; if (WATCH_MODULE(WATCH_MOD_ODS)) WatchThis (WATCHALL, WATCH_MOD_ODS, "!&Z", BufferPtr); return (sptr - BufferPtr); } /*****************************************************************************/ /* Generate a unique request identifier. Based on the description and code of the Apache Group's "mod_unique" module. One change has been made to allow the ID to be used as part of VMS file names, the substitution of '@' for '_'. */ char* GenerateUniqueId (REQUEST_STRUCT *rqptr) { static uchar ValueTable [] = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789_-"; static int UniqueIdCount = 0; static char UniqueIdString [UNIQUE_ID_SIZE+8]; int idx; ulong TimeStamp; char *sptr; uchar *cptr; #ifndef __VAX # pragma member_alignment __save # pragma nomember_alignment #endif struct { uint Stamp; uint IpAddr; uint Pid; ushort Count; ushort Zeroes; } UniqueId; #ifndef __VAX # pragma member_alignment __restore #endif /*********/ /* begin */ /*********/ TimeStamp = decc$fix_time (&rqptr->rqTime.BeginTime64); UniqueId.Stamp = htonl(TimeStamp); UniqueId.IpAddr = htonl(rqptr->ServicePtr->ServerIpAddress); UniqueId.Pid = htonl(HttpdProcess.Pid); UniqueId.Count = htons(UniqueIdCount); /* this is just padding for the encoding */ UniqueId.Zeroes = 0; UniqueIdCount++; sptr = UniqueIdString; cptr = (uchar*)&UniqueId; for (idx = 0; idx < sizeof(UniqueId)-sizeof(short); idx += 3) { *sptr++ = ValueTable[cptr[idx]>>2]; *sptr++ = ValueTable[((cptr[idx] & 0x03) << 4) | ((cptr[idx+1] & 0xf0) >> 4)]; *sptr++ = ValueTable[((cptr[idx+1] & 0x0f) << 2) | ((cptr[idx+2] & 0xc0) >> 6)]; *sptr++ = ValueTable[cptr[idx+2] & 0x3f]; } UniqueIdString[UNIQUE_ID_SIZE] = '\0'; return (UniqueIdString); } /*****************************************************************************/ /* Support version 10 and pre-version-10 logical and file naming conventions. Look for one of multiple (usually just two but can be more) possible logical names. When one is successfully translated return a pointer to it's null terminated name. Otherwise test for a subsequent and return a pointer to it if found. If none is found then return NoneFound if zero or positive, return the LogicalName if minus one. The constants should be #defined in the manner of "?WASD_CONFIG_GLOBAL\0HTTPD$CONFIG\0". */ char* v10orPrev10 ( char *LogicalName, int NoneFound ) { static ushort Length; static char ValueString [128]; static $DESCRIPTOR (LogicalNameDsc, ""); static $DESCRIPTOR (LnmFileDevDsc, "LNM$FILE_DEV"); static VMS_ITEM_LIST3 LnmItems [] = { { sizeof(ValueString)-1, LNM$_STRING, ValueString, &Length }, { 0,0,0,0 } }; int status; char *cptr, *sptr; /*********/ /* begin */ /*********/ if (!LogicalName || LogicalName[0] != '?') return (LogicalName); /* stop at any logical name delimiting colon (perhaps of a file name) */ for (sptr = cptr = LogicalName+1; *sptr && *sptr != ':'; sptr++); while (*cptr) { LogicalNameDsc.dsc$a_pointer = cptr; LogicalNameDsc.dsc$w_length = sptr - cptr; status = sys$trnlnm (0, &LnmFileDevDsc, &LogicalNameDsc, 0, &LnmItems); if (VMSok (status)) return (cptr); /* scan past any logical-delimiting colon */ while (*sptr) sptr++; /* stop at any logical name delimiting colon (perhaps of a file name) */ for (cptr = (sptr += 1); *sptr && *sptr != ':'; sptr++); } if (NoneFound != -1) return (NoneFound); return (LogicalName+1); } /*****************************************************************************/ /* Translate a logical name using LNM$FILE_DEV. Returns a pointer to the value string, allocated by VmGet() (i.e. server globally) which must be VmFree()ed if not required), or NULL if the name does not exist. */ char* SysTrnLnm (char *LogName) { static ushort ValueLength; static ulong LnmAttributes; static char LogValue [256]; static $DESCRIPTOR (LogNameDsc, ""); static $DESCRIPTOR (LnmTableDsc, "LNM$FILE_DEV"); static struct { short int buf_len; short int item; void *buf_addr; ushort *ret_len; } LnmItems [] = { { sizeof(LnmAttributes), LNM$_ATTRIBUTES, &LnmAttributes, 0 }, { sizeof(LogValue)-1, LNM$_STRING, LogValue, &ValueLength }, { 0,0,0,0 } }; int status; char *aptr, *cptr, *sptr; /*********/ /* begin */ /*********/ for (cptr = LogName; *cptr; cptr++); LogNameDsc.dsc$w_length = cptr - LogName; LogNameDsc.dsc$a_pointer = LogName; status = sys$trnlnm (0, &LnmTableDsc, &LogNameDsc, 0, &LnmItems); if (!(status & 1) || !(LnmAttributes & LNM$M_EXISTS)) return (NULL); aptr = sptr = VmGet (ValueLength+1); for (cptr = LogValue; ValueLength--; *sptr++ = *cptr++); *sptr = '\0'; return (aptr); } /****************************************************************************/ /* Assign a global symbol. */ int SetGlobalSymbol ( char *Name, char *String ) { static int GlobalSymbol = LIB$K_CLI_GLOBAL_SYM; static $DESCRIPTOR (NameDsc, ""); static $DESCRIPTOR (ValueDsc, ""); int status; /*********/ /* begin */ /*********/ NameDsc.dsc$a_pointer = Name; NameDsc.dsc$w_length = strlen(Name); ValueDsc.dsc$a_pointer = String; ValueDsc.dsc$w_length = strlen(String); status = lib$set_symbol (&NameDsc, &ValueDsc, &GlobalSymbol); return (status); } /*****************************************************************************/ /* Return a float number of seconds. */ float FloatDeltaTime (ulong *DeltaTimePtr) { static int LibDeltaSecs = LIB$K_DELTA_SECONDS_F; int status; float fsecs; /*********/ /* begin */ /*********/ if (IS_ZERO_DELTA_TIME(DeltaTimePtr)) return (0.0); #ifdef __ia64 status = lib$cvts_from_internal_time (&LibDeltaSecs, &fsecs, DeltaTimePtr); #else status = lib$cvtf_from_internal_time (&LibDeltaSecs, &fsecs, DeltaTimePtr); # ifdef __ALPHA if (VMSok(status)) status = cvt$convert_float (&fsecs, CVT$K_VAX_F, &fsecs, CVT$K_IEEE_S, 0); # endif #endif if (VMSnok(status)) { ErrorNoticed (NULL, status, "lib$cvts_from_internal_time()", FI_LI); return (0.0); } return (fsecs); } /*****************************************************************************/ /* Return a longword bytes/second. */ int BytesPerSecond ( ulong *BytesRxPtr, ulong *BytesTxPtr, ulong *DeltaTimePtr ) { static int LibDeltaSecs = LIB$K_DELTA_SECONDS_F; int status; uint bps; float fbytes = 0.0, fsecs; /*********/ /* begin */ /*********/ /* if zero time then only an artifact will be generated! */ if (IS_ZERO_DELTA_TIME(DeltaTimePtr)) return (0); if (BytesRxPtr) fbytes += (float)BytesRxPtr[0] + ((float)BytesRxPtr[1] * 4294967296.0); if (BytesTxPtr) fbytes += (float)BytesTxPtr[0] + ((float)BytesTxPtr[1] * 4294967296.0); #ifdef __ia64 status = lib$cvts_from_internal_time (&LibDeltaSecs, &fsecs, DeltaTimePtr); #else status = lib$cvtf_from_internal_time (&LibDeltaSecs, &fsecs, DeltaTimePtr); # ifdef __ALPHA if (VMSok(status)) status = cvt$convert_float (&fsecs, CVT$K_VAX_F, &fsecs, CVT$K_IEEE_S, 0); # endif #endif if (VMSnok(status)) { if (status != LIB$_DELTIMREQ) ErrorNoticed (NULL, status, "lib$cvts_from_internal_time()", FI_LI); return (0); } /* if greater than 2000000000 (2GB/S) it's likely to be an artifact! */ if ((bps = (uint)(fbytes / fsecs)) < 2000000000) return ((int)bps); else return (0); } /*****************************************************************************/ /* Calculate percentages of unsigned longs using floats to avoid integer overflow and allowing more accurate rounding. */ int PercentOf ( ulong arg1, ulong arg2 ) { int iperc; float farg1, farg2, fperc; /*********/ /* begin */ /*********/ if (arg2) { farg1 = (float)arg1; farg2 = (float)arg2; fperc = farg1 * 100.0 / farg2; iperc = (int)fperc; if (fperc - (float)iperc >= 0.5) iperc++; return (iperc); } return (0); } /*****************************************************************************/ /* Calculate percentages of quadwards using floats to avoid overflow and allowing more accurate rounding. */ int QuadPercentOf ( ulong *qarg1, ulong *qarg2 ) { int iqperc; float fqarg1, fqarg2, fqperc; /*********/ /* begin */ /*********/ if (qarg2[0] || qarg2[1]) { fqarg1 = (float)qarg1[0] + ((float)qarg1[1] * 4294967296.0); fqarg2 = (float)qarg2[0] + ((float)qarg2[1] * 4294967296.0); if (fqarg2 == 0.0) return (0); fqperc = fqarg1 * 100.0 / fqarg2; iqperc = (int)fqperc; if (fqperc - (float)iqperc >= 0.5) iqperc++; return (iqperc); } return (0); } /*****************************************************************************/ /* For non-64 bit platform; is quadword one less than quadword two. */ #if !USE_INT64 BOOL QuadLtQuad ( void *quad1, void *quad2 ) { ulong *q1 = quad1, *q2 = quad2; /*********/ /* begin */ /*********/ /* if q1 is negative and q2 not then it's less than */ if ((q1[1] & 0x80000000) && !(q2[1] & 0x80000000)) return (true); /* if q1 is positive and and q2 not then it's greater than */ if (!(q1[1] & 0x80000000) && (q2[1] & 0x80000000)) return (false); if ((q1[1] & 0x80000000) && (q2[1] & 0x80000000)) { /* both negative numbers */ if (q1[1] > q2[1]) return (true); if (q1[1] < q2[1]) return (false); if (q1[0] > q2[0]) return (true); } else { /* both positive numbers */ if (q1[1] < q2[1]) return (true); if (q1[1] > q2[1]) return (false); if (q1[0] < q2[0]) return (true); } return (false); } #endif /* !USE_INT64 */ /*****************************************************************************/ /* Integer power-of. */ int ipow ( int base, int exp ) { int result = 1; /*********/ /* begin */ /*********/ while (exp) { if (exp & 1) result *= base; exp >>= 1; base *= base; } return (result); } /*****************************************************************************/ /* $ HTTPD /TEST MATCH for the relative performance of MATCH1..8() and memcmp(). */ #if WATCH_MOD MatchPerf () #pragma optimize save #pragma optimize level=0 { int cnt, result; char MatchTest1 [] = "01234567890", MatchTest2 [] = "012345678_0"; int MatchTest3 = '0123'; /*********/ /* begin */ /*********/ lib$init_timer (0); for (cnt = 100000000; cnt; cnt--) { result = MATCH2 (MatchTest1, MatchTest2); result = MATCH3 (MatchTest1, MatchTest2); result = MATCH4 (MatchTest1, MatchTest2); result = MATCH5 (MatchTest1, MatchTest2); result = MATCH6 (MatchTest1, MatchTest2); result = MATCH7 (MatchTest1, MatchTest2); result = MATCH8 (MatchTest1, MatchTest2); } lib$show_timer (0,0,0,0); lib$init_timer (0); for (cnt = 100000000; cnt; cnt--) { result = !memcmp (MatchTest1, MatchTest2, 2); result = !memcmp (MatchTest1, MatchTest2, 3); result = !memcmp (MatchTest1, MatchTest2, 4); result = !memcmp (MatchTest1, MatchTest2, 5); result = !memcmp (MatchTest1, MatchTest2, 6); result = !memcmp (MatchTest1, MatchTest2, 7); result = !memcmp (MatchTest1, MatchTest2, 8); } lib$show_timer (0,0,0,0); lib$init_timer (0); for (cnt = 100000000; cnt; cnt--) { result = MATCH2 (MatchTest1, MatchTest2); result = MATCH3 (MatchTest1, MatchTest2); result = MATCH4 (MatchTest1, MatchTest2); result = MATCH2 (MatchTest1, MatchTest2); result = MATCH3 (MatchTest1, MatchTest2); result = MATCH4 (MatchTest1, MatchTest2); } lib$show_timer (0,0,0,0); lib$init_timer (0); for (cnt = 100000000; cnt; cnt--) { result = SAME2 (MatchTest1, MatchTest3); result = SAME3 (MatchTest1, MatchTest3); result = SAME4 (MatchTest1, MatchTest3); result = SAME2 (MatchTest1, MatchTest3); result = SAME3 (MatchTest1, MatchTest3); result = SAME4 (MatchTest1, MatchTest3); } lib$show_timer (0,0,0,0); } #pragma optimize restore #endif /* WATCH_MOD */ /*****************************************************************************/ /* Trace of call stack for debug purposes. Include call in code to use :-) */ DebugTrace () { int status; #ifndef __VAX struct invo_context_blk icb; #endif /*********/ /* begin */ /*********/ fprintf (stdout, "TRACE+++++++++++\n"); fflush (stdout); #ifdef __ALPHA lib$get_curr_invo_context (&icb); while (lib$get_prev_invo_context (&icb), !icb.libicb$v_bottom_of_stack) fprintf (stdout, "%08.08X%08.08X\n", icb.libicb$q_program_counter[1], icb.libicb$q_program_counter[0]); #endif #ifdef __ia64 lib$i64_init_invo_context (&icb, LIBICB$K_INVO_CONTEXT_VERSION); lib$i64_get_curr_invo_context (&icb); while (lib$i64_get_prev_invo_context (&icb), !icb.libicb$v_bottom_of_stack) fprintf (stdout, "%08.08X%08.08X\n", ((ULONGPTR)&icb.libicb$ih_pc)[1], ((ULONGPTR)&icb.libicb$ih_pc)[0]); #endif #ifdef __VAX fprintf (stdout, "***UNAVAILABLE*** for VAX\n"); #endif fprintf (stdout, "+++++++++++TRACE\n"); fflush (stdout); } /****************************************************************************/