소스 검색

Bug: 83070 Correct some spelling mistakes and typos

Ran sources through spell checker and corrected various spelling mistakes
and typos. Not exhaustive, didn't look at all dirs.

Signed-off-by: Jake Smith <jake.smith@lexisnexis.com>
Jake Smith 14 년 전
부모
커밋
5b502f6164
64개의 변경된 파일108개의 추가작업 그리고 108개의 파일을 삭제
  1. 1 1
      common/thorhelper/thorxmlread.cpp
  2. 1 1
      common/thorhelper/thorxmlwrite.cpp
  3. 1 1
      common/thorhelper/thorxmlwrite.hpp
  4. 2 2
      common/workunit/workunit.cpp
  5. 1 1
      common/workunit/wujobq.cpp
  6. 2 2
      dali/base/dacsds.cpp
  7. 1 1
      dali/base/dadfs.cpp
  8. 2 2
      dali/base/dafdesc.hpp
  9. 8 8
      dali/base/dasds.cpp
  10. 1 1
      dali/base/dasds.hpp
  11. 1 1
      dali/base/dasubs.cpp
  12. 1 1
      dali/base/dautils.cpp
  13. 1 1
      dali/dfuplus/main.cpp
  14. 1 1
      deployment/deploy/DeploymentEngine.cpp
  15. 4 4
      esp/services/ws_ecl/ws_ecl_service.cpp
  16. 2 2
      esp/services/ws_fs/ws_fsService.cpp
  17. 4 4
      initfiles/componentfiles/configxml/sasha.xsd
  18. 1 1
      system/jhtree/jhutil.hpp
  19. 1 1
      system/jlib/jexcept.cpp
  20. 1 1
      system/jlib/jexcept.hpp
  21. 3 3
      system/jlib/jfile.cpp
  22. 1 1
      system/jlib/jio.hpp
  23. 1 1
      system/jlib/jlib.hpp
  24. 1 1
      system/jlib/jmisc.hpp
  25. 1 1
      system/jlib/jmutex.hpp
  26. 7 7
      system/jlib/jptree.cpp
  27. 3 3
      system/jlib/jsocket.cpp
  28. 1 1
      system/jlib/jsocket.hpp
  29. 1 1
      system/jlib/jsort.cpp
  30. 1 1
      system/jlib/jsorta.hpp
  31. 1 1
      system/jlib/jstring.hpp
  32. 2 2
      system/jlib/jsuperhash.hpp
  33. 1 1
      system/jlib/jthread.cpp
  34. 1 1
      system/jlib/jthread.hpp
  35. 1 1
      system/jlib/jutil.cpp
  36. 1 1
      system/jlib/jutil.hpp
  37. 1 1
      system/mp/mpbase.hpp
  38. 6 6
      system/mp/mpcomm.cpp
  39. 1 1
      thorlcr/activities/catch/thcatchslave.cpp
  40. 3 3
      thorlcr/activities/csvread/thcsvrslave.cpp
  41. 1 1
      thorlcr/activities/enth/thenthslave.cpp
  42. 1 1
      thorlcr/activities/group/thgroupslave.cpp
  43. 3 3
      thorlcr/activities/hashdistrib/thhashdistribslave.cpp
  44. 1 1
      thorlcr/activities/indexwrite/thindexwrite.cpp
  45. 1 1
      thorlcr/activities/iterate/thiterateslave.cpp
  46. 2 2
      thorlcr/activities/keydiff/thkeydiffslave.cpp
  47. 1 1
      thorlcr/activities/keyedjoin/thkeyedjoinslave.cpp
  48. 2 2
      thorlcr/activities/keypatch/thkeypatchslave.cpp
  49. 1 1
      thorlcr/activities/lookupjoin/thlookupjoinslave.cpp
  50. 1 1
      thorlcr/activities/msort/thmsort.cpp
  51. 2 2
      thorlcr/activities/msort/thsortu.cpp
  52. 1 1
      thorlcr/activities/nsplitter/thnsplitterslave.cpp
  53. 1 1
      thorlcr/activities/spill/thspillslave.cpp
  54. 1 1
      thorlcr/activities/thdiskbase.cpp
  55. 3 3
      thorlcr/activities/thdiskbaseslave.cpp
  56. 1 1
      thorlcr/graph/thgraph.hpp
  57. 1 1
      thorlcr/mfilemanager/thmfilemanager.cpp
  58. 1 1
      thorlcr/slave/slave.cpp
  59. 1 1
      thorlcr/thorutil/thalloc.hpp
  60. 1 1
      thorlcr/thorutil/thbufdef.hpp
  61. 1 1
      thorlcr/thorutil/thcompressutil.hpp
  62. 1 1
      tools/copyexp/copyexp.cpp
  63. 1 1
      tools/esdl/esdlcomp.cpp
  64. 3 3
      tools/hidl/hidlcomp.cpp

+ 1 - 1
common/thorhelper/thorxmlread.cpp

@@ -1003,7 +1003,7 @@ public:
     }
     ~CMarkReadStream()
     {
-        free(bufLowerHalf); // pointer to whole buf infact
+        free(bufLowerHalf); // pointer to whole buf in fact
         stream.Release();
     }
 

+ 1 - 1
common/thorhelper/thorxmlwrite.cpp

@@ -624,7 +624,7 @@ CommonXmlWriter * CreateCommonXmlWriter(unsigned _flags, unsigned _initialIndent
     switch (xmlType)
     {
     case WTStandard:
-        return new CommonXmlWriter(_flags, _initialIndent, _flusher);//standart XML writer
+        return new CommonXmlWriter(_flags, _initialIndent, _flusher);//standard XML writer
     case WTEncodingData64:
         return new CommonEncoded64XmlWriter(_flags, _initialIndent, _flusher);//writes xsd type attributes, and all data as base64binary
     case WTEncoding:

+ 1 - 1
common/thorhelper/thorxmlwrite.hpp

@@ -102,7 +102,7 @@ public:
     virtual void outputUtf8(unsigned len, const char *field, const char *fieldname);
 };
 
-//Writed all encoded DATA fields as base64Binary
+//Writes all encoded DATA fields as base64Binary
 class thorhelper_decl CommonEncoded64XmlWriter : public CommonEncodedXmlWriter
 {
 public:

+ 2 - 2
common/workunit/workunit.cpp

@@ -2174,7 +2174,7 @@ public:
 
     
     IConstWorkUnitIterator* getWorkUnitsSorted( WUSortField *sortorder, // list of fields to sort by (terminated by WUSFterm)
-                                                WUSortField *filters,   // NULL or list of fields to folteron (terminated by WUSFterm)
+                                                WUSortField *filters,   // NULL or list of fields to filter on (terminated by WUSFterm)
                                                 const void *filterbuf,  // (appended) string values for filters
                                                 unsigned startoffset,
                                                 unsigned maxnum,
@@ -2402,7 +2402,7 @@ public:
     }
 
     virtual IConstWorkUnitIterator* getWorkUnitsSorted( WUSortField *sortorder, // list of fields to sort by (terminated by WUSFterm)
-                                                        WUSortField *filters,   // NULL or list of fields to folteron (terminated by WUSFterm)
+                                                        WUSortField *filters,   // NULL or list of fields to filter on (terminated by WUSFterm)
                                                         const void *filterbuf,  // (appended) string values for filters
                                                         unsigned startoffset,
                                                         unsigned maxnum,

+ 1 - 1
common/workunit/wujobq.cpp

@@ -534,7 +534,7 @@ public:
                     }
                     while (qd2!=qd);
                     PROGLOG("Job Queue contention - delaying before retrying");
-                    Sleep(getRandom()%5000);    // dining phisosopher delay
+                    Sleep(getRandom()%5000);    // dining philosopher delay
                     wait = getRandom()%4000+3000; // try and prevent sync
                     qd  = qdata;
                 }

+ 2 - 2
dali/base/dacsds.cpp

@@ -1740,7 +1740,7 @@ IPropertyTree &CClientSDSManager::queryProperties() const
     CMessageBuffer mb;
     mb.append((int)DAMP_SDSCMD_GETPROPS);
     if (!queryCoven().sendRecv(mb, RANK_RANDOM, MPTAG_DALI_SDS_REQUEST))
-        throw MakeSDSException(SDSExcpt_FailedToCommunicateWithServer, "querying sds diagnositc info");
+        throw MakeSDSException(SDSExcpt_FailedToCommunicateWithServer, "querying sds diagnostic info");
     SdsReply replyMsg;  
     mb.read((int &)replyMsg);
     switch (replyMsg)
@@ -1926,7 +1926,7 @@ void CClientSDSManager::setConfigOpt(const char *opt, const char *value)
             }
             else
             {
-                PROGLOG("Increating clientThrottleLimit from %d to %d", clientThrottleLimit, newV);
+                PROGLOG("Increasing clientThrottleLimit from %d to %d", clientThrottleLimit, newV);
                 concurrentRequests.signal(-diff); // new limit is higher than old
             }
             clientThrottleLimit = newV;

+ 1 - 1
dali/base/dadfs.cpp

@@ -5680,7 +5680,7 @@ StringBuffer & CDistributedFilePart::getPartName(StringBuffer &partname)
     }
     const char *mask=parent.queryPartMask();
     if (!mask||!*mask) {
-        const char *err ="CDistributedFilePart::getPartName cannot determing part name (no mask)";
+        const char *err ="CDistributedFilePart::getPartName cannot determine part name (no mask)";
         ERRLOG(err);
         throw MakeStringException(-1,err);
     }

+ 2 - 2
dali/base/dafdesc.hpp

@@ -306,7 +306,7 @@ extern da_decl void setBaseDirectory(const char * dir,bool replicatedir=false,DF
 extern da_decl const char *queryPartMask();
 extern da_decl StringBuffer &getPartMask(StringBuffer &ret,const char *lname=NULL,unsigned partmax=0);
 extern da_decl void setPartMask(const char * mask);
-extern da_decl bool setReplicateDir(const char *name,StringBuffer &out, bool isrep=true,const char *baseDir=NULL,const char *repDir=NULL); // changes direcctory of name pssed to backup directory
+extern da_decl bool setReplicateDir(const char *name,StringBuffer &out, bool isrep=true,const char *baseDir=NULL,const char *repDir=NULL); // changes direcctory of name passed to backup directory
 
 extern da_decl IFileDescriptor *createFileDescriptor();
 extern da_decl IFileDescriptor *createFileDescriptor(IPropertyTree *attr);      // ownership of attr tree is taken
@@ -329,7 +329,7 @@ extern da_decl void removePartFiles(IFileDescriptor *desc,IMultiException *mexce
 
 extern da_decl StringBuffer &setReplicateFilename(StringBuffer &filename,unsigned drvnum,const char *baseDir=NULL,const char *repDir=NULL);
 
-// path seperator utility routines (work for both host and non-host OS)
+// path separator utility routines (work for both host and non-host OS)
 
 inline char OsSepChar(DFD_OS os)
 {

+ 8 - 8
dali/base/dasds.cpp

@@ -510,7 +510,7 @@ public:
 
     void removeSubscriber(SubscriptionId id)
     {
-        ForEachItemIn(s, subscriptions) // do not expect a lot of subscripers per connection - probably ~ 1.
+        ForEachItemIn(s, subscriptions) // do not expect a lot of subscribers per connection - probably ~ 1.
         {
             if (id == subscriptions.item(s).queryId())
             {
@@ -2330,7 +2330,7 @@ CRemoteTreeBase *CRemoteTreeBase::createChild(int pos, const char *childName)
 
 ///////////
 
-static CheckedCriticalSection suppressedOrphanUnlockCrit; // to temporarily supress unlockall
+static CheckedCriticalSection suppressedOrphanUnlockCrit; // to temporarily suppress unlockall
 static bool suppressedOrphanUnlock=false;
 
 #ifdef __64BIT__
@@ -3068,7 +3068,7 @@ public:
     bool unlock(ConnectionId id)
     {
         bool ret = false;
-        CPendingLockBlock b(*this); // carefully placed, removePending can destroy this, therefore must be destoyed last
+        CPendingLockBlock b(*this); // carefully placed, removePending can destroy this, therefore must be destroyed last
         {
             CHECKEDCRITICALBLOCK(crit, fakeCritTimeout);    
             LockData *ld = connectionInfo.getValue(id);
@@ -3237,7 +3237,7 @@ public:
     bool lock(unsigned mode, unsigned timeout, ConnectionId id, SessionId sessionId, IUnlockCallback &callback)
     {
         bool ret = false;
-        CPendingLockBlock b(*this); // carefully placed, removePending can destroy this, therefore must be destoyed last
+        CPendingLockBlock b(*this); // carefully placed, removePending can destroy this, therefore must be destroyed last
         { CHECKEDCRITICALBLOCK(crit, fakeCritTimeout);
             return _lock(mode, timeout, id, sessionId, callback);
         }
@@ -4151,7 +4151,7 @@ void CSDSTransactionServer::processMessage(CMessageBuffer &mb)
                     }
                     mb.clear();
                     mb.append((int)DAMP_SDSREPLY_OK);
-                    mb.append(newIds); // JCSMORE not particualry efficent change later
+                    mb.append(newIds); // JCSMORE not particularly efficient change later
                     if (block0.slow())
                     {
                         block0.appendMsg(", xpath=").append(connection->queryXPath());
@@ -4298,7 +4298,7 @@ void CSDSTransactionServer::processMessage(CMessageBuffer &mb)
         StringBuffer s;
         e->errorMessage(s);
         // NB: wanted to do this in a catch (IPTreeException *) block, but did catch,
-        // inspite of being able to query with dynamic cast
+        // in spite of being able to query with dynamic cast
         // something to do with rethrow, if I changed to catch early as IPT then it would catch here correctly.
         if (QUERYINTERFACE(e, IPTreeException))
         {
@@ -8253,7 +8253,7 @@ bool CCovenSDSManager::fireException(IException *e)
             if (handled)
             {
                 LOG(MCdisaster, unknownJob, e, "FATAL, too many exceptions");
-                return false; // did not sucessfully handle.
+                return false; // did not successfully handle.
             }
             LOG(MCoperatorError, unknownJob, e, "Exception while restarting or shutting down");
             return true;
@@ -8261,7 +8261,7 @@ bool CCovenSDSManager::fireException(IException *e)
         handled = false;
         processingUnhandled = true;
     }
-    // Handle exception on a seperate thread, to avoid complication with joining/restarting deadlocks.
+    // Handle exception on a separate thread, to avoid complication with joining/restarting deadlocks.
     class CHandleException : public Thread
     {
         CCovenSDSManager &manager;

+ 1 - 1
dali/base/dasds.hpp

@@ -25,7 +25,7 @@
 #define RTM_NONE        0x00
 #define RTM_LOCK_READ   0x01        // non-exclusive lock
 #define RTM_LOCK_WRITE  0x02        // exclusive lock
-#define RTM_LOCK_SUB    0x10        // locks all decendants as well as self 
+#define RTM_LOCK_SUB    0x10        // locks all descendants as well as self
 #define RTM_SUB         0x20        // loads entire sub-tree
 #define RTM_CREATE      0x40        // replace existing elements
 #define RTM_CREATE_UNIQUE (RTM_CREATE | 0x80)   // used with xpath pointing to parent where a newly unique name branch is to be created

+ 1 - 1
dali/base/dasubs.cpp

@@ -599,7 +599,7 @@ public:
             MemoryBuffer qb;
             size32_t dlen;
             mb.read(dlen);
-            qb.append(dlen,mb.readDirect(dlen)); // this is bit inefficent - perhaps could be improved
+            qb.append(dlen,mb.readDirect(dlen)); // this is bit inefficient - perhaps could be improved
             managers.item(i).notify(id,qb);
         }
     }

+ 1 - 1
dali/base/dautils.cpp

@@ -908,7 +908,7 @@ bool CDfsLogicalFileName::getExternalPath(StringBuffer &dir, StringBuffer &tail,
         char c=*(s++);
         if (isPathSepChar(c)) {
             if (e)
-                *e = MakeStringException(-1,"Path cannot contain separators, use '::' to seperate directories: (%s)",get());
+                *e = MakeStringException(-1,"Path cannot contain separators, use '::' to separate directories: (%s)",get());
             return false;
         }
         if ((c==':')&&(s!=t1)&&(*s==':')) {

+ 1 - 1
dali/dfuplus/main.cpp

@@ -109,7 +109,7 @@ void handleSyntax()
     out.append("        dstfile=<destination-file-path>\n");
     out.append("    remove options:\n");
     out.append("        name=<logical-name>\n");
-    out.append("        names=<multiple-logical-names-seperated-by-comma>\n");
+    out.append("        names=<multiple-logical-names-separated-by-comma>\n");
     out.append("        namelist=<logical-name-list-in-file>\n");
     out.append("        nodelete=0|1    -- optional\n");
     out.append("    rename options:\n");

+ 1 - 1
deployment/deploy/DeploymentEngine.cpp

@@ -1474,7 +1474,7 @@ void CDeploymentEngine::copyInstallFiles(const char* instanceName, int instanceI
          //any dynamically generated paths are generated with '\\'
          //In configenv, remote copying takes care of the paths
          //if this is configgen, and we are on linux, replace
-         //paths with right seperator
+         //paths with right separator
          if (PATHSEPCHAR == '/' && os == MachineOsLinux)
            src.replace('\\', '/');
 

+ 4 - 4
esp/services/ws_ecl/ws_ecl_service.cpp

@@ -290,7 +290,7 @@ void CWsEclBinding::getDynNavData(IEspContext &context, IProperties *params, IPr
 }
 
 
-static inline bool isPathSeperator(char sep)
+static inline bool isPathSeparator(char sep)
 {
     return (sep=='\\')||(sep=='/');
 }
@@ -299,7 +299,7 @@ static inline const char *skipPathNodes(const char *&s, int skip)
 {
     if (s) {
         while (*s) {
-            if (isPathSeperator(*s++))
+            if (isPathSeparator(*s++))
                 if (!skip--)
                     return s;
         }
@@ -312,7 +312,7 @@ static inline const char *nextPathNode(const char *&s, StringBuffer &node, int s
     if (skip)
         skipPathNodes(s, skip);
     if (s) while (*s) {
-        if (isPathSeperator(*s))
+        if (isPathSeparator(*s))
             return s++;
         node.append(*s++);
     }
@@ -321,7 +321,7 @@ static inline const char *nextPathNode(const char *&s, StringBuffer &node, int s
 
 static inline const char *firstPathNode(const char *&s, StringBuffer &node)
 {
-    if (s && isPathSeperator(*s))
+    if (s && isPathSeparator(*s))
         s++;
     return nextPathNode(s, node);
 }

+ 2 - 2
esp/services/ws_fs/ws_fsService.cpp

@@ -1830,7 +1830,7 @@ bool CFileSprayEx::onSprayFixed(IEspContext &context, IEspSprayFixed &req, IEspS
             rmfn.setEp(ep);
             StringBuffer fnamebuf(srcfile);
             fnamebuf.trim();
-            rmfn.append(fnamebuf.str());    // handles comma seperated files
+            rmfn.append(fnamebuf.str());    // handles comma separated files
             source->setMultiFilename(rmfn);
         }
         else
@@ -1989,7 +1989,7 @@ bool CFileSprayEx::onSprayVariable(IEspContext &context, IEspSprayVariable &req,
             rmfn.setEp(ep);
             StringBuffer fnamebuf(srcfile);
             fnamebuf.trim();
-            rmfn.append(fnamebuf.str());    // handles comma seperated files
+            rmfn.append(fnamebuf.str());    // handles comma separated files
             source->setMultiFilename(rmfn);
         }
         else

+ 4 - 4
initfiles/componentfiles/configxml/sasha.xsd

@@ -1,6 +1,6 @@
 <!--
 
-## Copyright © 2011 HPCC Systems.  All rights reserved.
+## Copyright © 2011 HPCC Systems.  All rights reserved.
 -->
 
 <?xml version="1.0" encoding="UTF-8"?>
@@ -383,7 +383,7 @@
         <xs:attribute name="xrefList" type="xs:string" use="optional" default="*">
             <xs:annotation>
                 <xs:appinfo>
-                    <tooltip>comma seperated list of clusters to xref (* for all clusters).</tooltip>
+                    <tooltip>comma separated list of clusters to xref (* for all clusters).</tooltip>
                 </xs:appinfo>
             </xs:annotation>
         </xs:attribute>
@@ -422,7 +422,7 @@
         <xs:attribute name="thorQMonQueues" type="xs:string" use="optional" default="*">
             <xs:annotation>
                 <xs:appinfo>
-                    <tooltip>comma seperated list of Thor queues to monitor (* for all).</tooltip>
+                    <tooltip>comma separated list of Thor queues to monitor (* for all).</tooltip>
                 </xs:appinfo>
             </xs:annotation>
         </xs:attribute>
@@ -459,7 +459,7 @@
         <xs:attribute name="dafsmonList" type="xs:string" use="optional" default="*">
             <xs:annotation>
                 <xs:appinfo>
-                    <tooltip>comma seperated list of clusters and IPs to monitor (* for all clusters).</tooltip>
+                    <tooltip>comma separated list of clusters and IPs to monitor (* for all clusters).</tooltip>
                 </xs:appinfo>
             </xs:annotation>
         </xs:attribute>

+ 1 - 1
system/jhtree/jhutil.hpp

@@ -23,7 +23,7 @@
 #include "jqueue.tpp"
 #include "jhtree.hpp"
 
-// TABLE should be SuperHashTable derivitive to contain MAPPING's
+// TABLE should be SuperHashTable derivative to contain MAPPING's
 // MAPPING should be something that constructs with (KEY, ENTRY) and impl. query returning ref. to ENTRY
 template <class KEY, class ENTRY, class MAPPING, class TABLE>
 class CMRUCacheOf : public CInterface, public IInterface

+ 1 - 1
system/jlib/jexcept.cpp

@@ -732,7 +732,7 @@ static void doPrintStackReport( size_t ip, size_t _bp, size_t sp )
 {
     if (_bp==0) {
 #ifdef _AMD64_
-        PrintLog("inline assembler is not suported in 64bit AMD compiler; StackReport incomplete bp tend to not be used");
+        PrintLog("inline assembler is not supported in 64bit AMD compiler; StackReport incomplete bp tend to not be used");
 #else
         __asm { 
             mov eax,ebp

+ 1 - 1
system/jlib/jexcept.hpp

@@ -131,7 +131,7 @@ interface jlib_thrown_decl IOutOfMemException: extends IException
 void  jlib_decl EnableSEHtoExceptionMapping(); // return value can be used to disable
 void  jlib_decl DisableSEHtoExceptionMapping();         
 // NB only enables for current thread or threads started after call
-// requres /EHa option to be set in VC++ options (after /GX)
+// requires /EHa option to be set in VC++ options (after /GX)
 
 void jlib_decl *setSEHtoExceptionHandler(IExceptionHandler *handler); // sets handler and return old value
 

+ 3 - 3
system/jlib/jfile.cpp

@@ -1632,7 +1632,7 @@ public:
         DWORD numRead;
         if (ReadFile(file,data,len,&numRead,NULL) == 0) {
             DWORD err = GetLastError();
-            if (err==ERROR_BROKEN_PIPE)  // windows returs this at end of pipe
+            if (err==ERROR_BROKEN_PIPE)  // windows returns this at end of pipe
                 return 0;
             throw MakeOsException(GetLastError(),"CSequentialFileIO::read"); 
         }
@@ -3025,7 +3025,7 @@ StringBuffer& getFullFileName(StringBuffer& filename, bool noExtension)
     return filename;
 }
 
-/* Get the file name only. If noExtension is true, the extesion (if any) will be trimmed */ 
+/* Get the file name only. If noExtension is true, the extension (if any) will be trimmed */ 
 StringBuffer& getFileNameOnly(StringBuffer& filename, bool noExtension)
 {
     char drive[_MAX_DRIVE];
@@ -4207,7 +4207,7 @@ StringBuffer & RemoteFilename::getPath(StringBuffer & name) const
         return getRemotePath(name);
 }
 
-bool RemoteFilename::isUnixPath() const // bit arbitary
+bool RemoteFilename::isUnixPath() const // bit arbitrary
 {
     if (tailpath.length()!=0) {
         char c = tailpath[0];

+ 1 - 1
system/jlib/jio.hpp

@@ -192,7 +192,7 @@ interface IRowStream : extends IInterface
 
 interface IRowWriter: extends IInterface
 {
-    virtual void putRow(const void *row) = 0; // takes ownershop of row
+    virtual void putRow(const void *row) = 0; // takes ownership of row
     virtual void flush() = 0;
 };
 

+ 1 - 1
system/jlib/jlib.hpp

@@ -307,7 +307,7 @@ public:
     static ModInit glue(modInit, __LINE__) (& glue(_modInit, __LINE__), PRIORITY, MODULE_PRIORITY); \
     static bool glue(_modInit, __LINE__) ()
 
-// Assumes related MODULE_INIT preceeded the use of MODULE_EXIT
+// Assumes related MODULE_INIT preceded the use of MODULE_EXIT
 #define MODULE_EXIT()                                   \
     static void glue(_modExit, __LINE__)();         \
     static ModExit glue(modExit, __LINE__)(& glue(_modExit, __LINE__)); \

+ 1 - 1
system/jlib/jmisc.hpp

@@ -65,7 +65,7 @@ jlib_decl ILogMsgHandler * queryLegacyLogMsgHandler();
 #ifndef DISABLE_PRINTLOG
 jlib_decl void PrintLogDirect(const char *msg);
 jlib_decl int  PrintLog(const char *fmt, ...);
-jlib_decl void SPrintLog(const char *fmt,...); // not tertminated by LF
+jlib_decl void SPrintLog(const char *fmt,...); // not terminated by LF
 #define PrintExceptionLog(_e,_txt) EXCLOG(_e, _txt)
 
 #ifdef _DEBUG

+ 1 - 1
system/jlib/jmutex.hpp

@@ -365,7 +365,7 @@ class jlib_decl NonReentrantSpinLock
 {
     atomic_t value;
     struct { volatile ThreadId tid; } owner; // atomic
-    inline NonReentrantSpinLock(NonReentrantSpinLock & value) { assert(false); } // dummy to prevent inadvetant use as block
+    inline NonReentrantSpinLock(NonReentrantSpinLock & value) { assert(false); } // dummy to prevent inadvertent use as block
 public:
     inline NonReentrantSpinLock()       
     {

+ 7 - 7
system/jlib/jptree.cpp

@@ -3121,7 +3121,7 @@ bool PTree::checkPattern(const char *&xxpath) const
                     if (legacynumeric)
                     {
                         if (isdigit(*rhs))
-                            WARNLOG("Possible depreicated use of quoted numeric comparison operation: %s", xxpath);
+                            WARNLOG("Possible deprecated use of quoted numeric comparison operation: %s", xxpath);
                     }
 #endif
                 }
@@ -3405,7 +3405,7 @@ IPropertyTree &PTStackIterator::query()
 
 bool PTStackIterator::next()
 {
-    bool seperator = false;
+    bool separator = false;
     if (iter)
     {
         IPropertyTree *element = NULL;
@@ -3438,8 +3438,8 @@ bool PTStackIterator::next()
                     current = element;
                     return true;
                 case '.':
-                    if (seperator) throw MakeXPathException(xpath, PTreeExcpt_XPath_ParseError, 0, "Syntax error");
-                    seperator=false;
+                    if (separator) throw MakeXPathException(xpath, PTreeExcpt_XPath_ParseError, 0, "Syntax error");
+                    separator=false;
                     ++xxpath;
                     if (*xpath && '/' != *xpath)
                         throw MakeXPathException(xpath-1, PTreeExcpt_XPath_Unsupported, 0, "");
@@ -3455,10 +3455,10 @@ bool PTStackIterator::next()
                         xxpath = "";
                         element = NULL;
                     }
-                    seperator=true;
+                    separator=true;
                     break;
                 default:
-                    seperator=false;
+                    separator=false;
                     if (iter->isValid()) 
                         pushToStack(iter, xxpath);
 
@@ -3874,7 +3874,7 @@ protected:
     }
     void error(const char *msg=NULL, bool giveContext=true, XmlReadExcptCode code=XmlRead_syntax)
     {
-        // NB: there is little validataion in parse, error can be late.
+        // NB: there is little validation in parse, error can be late.
         StringBuffer context;
         if (giveContext)
         {

+ 3 - 3
system/jlib/jsocket.cpp

@@ -861,7 +861,7 @@ void CSocket::open(int listen_queue_size,bool reuseports)
     int saverr;
     if (::bind(sock, &u.sa, ul) != 0) {
         saverr = ERRNO();
-        if (saverr==EADDRINUSE) {   // don't log as error (some useages probe ports)
+        if (saverr==EADDRINUSE) {   // don't log as error (some usages probe ports)
 ErrPortInUse:
             closesock();
             char msg[1024]; 
@@ -3252,7 +3252,7 @@ bool SocketListParser::next(StringAttr & ip, unsigned & port)
             }
         }
 done:
-        //copy up to the appropraite dot from the previous ip.
+        //copy up to the appropriate dot from the previous ip.
         const unsigned dotCount = 3;        //more what about 6 digit ip's
         cur = lastIp;
         loop
@@ -3560,7 +3560,7 @@ class CSocketSelectThread: public Thread
 #define HASHNULL (HASHTABSIZE-1)
 #define HASHTABMASK (HASHTABSIZE-1)
     byte hashtab[HASHTABSIZE];
-#define HASHSOCKET(s) ((((unsigned)s)>>2)&HASHTABMASK)      // with some knowlege of windows handles
+#define HASHSOCKET(s) ((((unsigned)s)>>2)&HASHTABMASK)      // with some knowledge of windows handles
 
     void inithash()
     {

+ 1 - 1
system/jlib/jsocket.hpp

@@ -300,7 +300,7 @@ public:
     virtual bool set_nagle(bool on) = 0; // returns old state
 
 
-    // set 'linger' time - time close will linger so that outstanding unsent data will be transmited
+    // set 'linger' time - time close will linger so that outstanding unsent data will be transmitted
     //
     virtual void set_linger(int lingersecs) = 0;  
 

+ 1 - 1
system/jlib/jsort.cpp

@@ -814,7 +814,7 @@ class CRowStreamMerger
     inline bool siftDown(unsigned p)
     {
         //MTIME_SECTION(defaultTimer, "CJStreamMergerBase::siftDown");
-        // assumimg that all descendents of p form a heap, sift p down to its correct position, and so include it in the heap
+        // assuming that all descendants of p form a heap, sift p down to its correct position, and so include it in the heap
         bool nochange = true;
         while(1)
         {

+ 1 - 1
system/jlib/jsorta.hpp

@@ -27,7 +27,7 @@
 
 
 
-/* the following somewhat inellegantly implements:
+/* the following somewhat inelegantly implements:
 
 template <class C> 
 void qsortarray(C *a, size32_t n, sortCompareFunction compare, sortSwapFunction doswap)

+ 1 - 1
system/jlib/jstring.hpp

@@ -331,7 +331,7 @@ public:
 
 // --$appendURL-----------------------------------------------------------------
 // appends the URL encoded version of src to dest 
-// if len is unspecied, then src is assumed to be an NTS 
+// if len is unspecified, then src is assumed to be an NTS 
 // if lower is TRUE a-f is used for hex numbers, otherwise A-F is used 
 // -----------------------------------------------------------------------------
 #define ENCODE_SPACES 1

+ 2 - 2
system/jlib/jsuperhash.hpp

@@ -127,7 +127,7 @@ class SuperHashTableOf : public SuperHashTable
       { return SuperHashTable::removeExact(et); }
 };
 
-// Macro to provice find method taking reference instead of pointer
+// Macro to provide find method taking reference instead of pointer
 
 #define IMPLEMENT_SUPERHASHTABLEOF_REF_FIND(ET, FP)                        \
     inline ET *      find(FP & fp) const                                   \
@@ -371,7 +371,7 @@ public:
     ~LinkedHTMapping() { this->et.Release(); }
 };
 
-// template mapping object for string to arbitary object
+// template mapping object for string to arbitrary object
 template <class ET>
 class StringHTMapping : public CInterface
 {

+ 1 - 1
system/jlib/jthread.cpp

@@ -57,7 +57,7 @@ MODULE_EXIT()
 
 void addThreadExceptionHandler(IExceptionHandler *handler)
 {
-    assertex(exceptionHandlers); // have to ensure MODULE_INIT has appropriate proirity.
+    assertex(exceptionHandlers); // have to ensure MODULE_INIT has appropriate priority.
     exceptionHandlers->append(handler);
 }
 

+ 1 - 1
system/jlib/jthread.hpp

@@ -235,7 +235,7 @@ interface IPipeProcess: extends IInterface
 {
     virtual bool run(const char *title,const char *prog, const char *dir,
                        bool hasinput,bool hasoutput,bool haserror=false,
-                       size32_t stderrbufsize=0) = 0;               // set to non-zero to automatcally buffer stderror output
+                       size32_t stderrbufsize=0) = 0;               // set to non-zero to automatically buffer stderror output
     virtual bool hasInput() = 0;                                    // i.e. can write to pipe
     virtual size32_t write(size32_t sz, const void *buffer) = 0;    // write pipe process standard output
     virtual bool hasOutput() = 0;                                   // i.e. can read from pipe

+ 1 - 1
system/jlib/jutil.cpp

@@ -1222,7 +1222,7 @@ void DelimToStringArray(const char *csl, StringArray &dst, const char * delim,bo
     loop {
         while (isspace(*s))
             s++;
-        if (!*s&&(dst.ordinality()==dstlen)) // this check is to allow trailing seperators (e.g. ",," is 3 (NULL) entries) but not generate an entry for ""
+        if (!*s&&(dst.ordinality()==dstlen)) // this check is to allow trailing separators (e.g. ",," is 3 (NULL) entries) but not generate an entry for ""
             break;
         const char *e = s;
         while (*e) {

+ 1 - 1
system/jlib/jutil.hpp

@@ -142,7 +142,7 @@ class StringArray : public ArrayOf<const char *, const char *>
 {
 };
 
-// seperated list to array
+// separated list to array
 extern jlib_decl void DelimToStringArray(const char *csl, StringArray &dst, const char * delim, bool deldup=false);
 extern jlib_decl void CslToStringArray(const char *csl, StringArray &dst, bool deldup=false);
 

+ 1 - 1
system/mp/mpbase.hpp

@@ -154,7 +154,7 @@ enum MessagePassingError
     MPERR_ok,
     MPERR_connection_failed,            // connection dropped (or could not be made)
     MPERR_process_not_in_group,         // using an 'inner' communicator when not part of it's group 
-    MPERR_protocol_version_mismatch,    // inconpatible version of MP being used
+    MPERR_protocol_version_mismatch,    // incompatible version of MP being used
     MPERR_link_closed                   // raised if other end closed (e.g. aborted) during a specific recv or probe
 };
 

+ 6 - 6
system/mp/mpcomm.cpp

@@ -655,7 +655,7 @@ protected: friend class CMPPacketReader;
                     return false;
                 }
                 if (remaining<10000)
-                    remaining = 10000; // 10s min granuality for MP
+                    remaining = 10000; // 10s min granularity for MP
                 newsock = ISocket::connect_timeout(remoteep,remaining);
                 newsock->set_keep_alive(true);
 #ifdef _FULLTRACE
@@ -686,7 +686,7 @@ protected: friend class CMPPacketReader;
                     if (attachSocket(newsock,remoteep,hostep,true, NULL)) {
                         newsock->Release();
 #ifdef _TRACE
-                        LOG(MCdebugInfo(100), unknownJob, "MP: connnected to %s",str.toCharArray());
+                        LOG(MCdebugInfo(100), unknownJob, "MP: connected to %s",str.toCharArray());
 #endif
                         lastxfer = msTick();
                         closed = false;
@@ -1331,7 +1331,7 @@ CMPChannel::~CMPChannel()
     reader->Release();
 }
 
-bool CMPChannel::attachSocket(ISocket *newsock,const SocketEndpoint &remoteep,const SocketEndpoint &_localep,bool ismaster, size32_t *confirm) // takes ownership if succeeeds
+bool CMPChannel::attachSocket(ISocket *newsock,const SocketEndpoint &remoteep,const SocketEndpoint &_localep,bool ismaster, size32_t *confirm) // takes ownership if succeeds
 {
 #ifdef _FULLTRACE       
     PROGLOG("MP: attachSocket on entry");
@@ -1348,7 +1348,7 @@ bool CMPChannel::attachSocket(ISocket *newsock,const SocketEndpoint &remoteep,co
         StringBuffer ep2;
         _localep.getUrlStr(ep1);
         remoteep.getUrlStr(ep2);
-        LOG(MCdebugInfo(100), unknownJob, "MP: Possible clash beween %s->%s %d(%d)",ep1.str(),ep2.str(),(int)ismaster,(int)master);
+        LOG(MCdebugInfo(100), unknownJob, "MP: Possible clash between %s->%s %d(%d)",ep1.str(),ep2.str(),(int)ismaster,(int)master);
         try {
             if (ismaster!=master) {
                 if (ismaster) {
@@ -2020,7 +2020,7 @@ public:
             msg->transferFrom(mbuf);
             msg->init(dst->endpoint(),tag,reply);
             parent->getReceiveQ().enqueue(msg);
-            mbuf.clear(); // for consistant semantics
+            mbuf.clear(); // for consistent semantics
             return true;
         }
 
@@ -2031,7 +2031,7 @@ public:
             return false;
         if (!channel.send(mbuf,tag,mbuf.getReplyTag(),tm,false))
             return false;
-        mbuf.clear(); // for consistant semantics
+        mbuf.clear(); // for consistent semantics
         return true;
     }
 

+ 1 - 1
thorlcr/activities/catch/thcatchslave.cpp

@@ -199,7 +199,7 @@ class CSkipCatchSlaveActivity : public CCatchSlaveActivityBase
             throw;
         }
         if (global)
-            return barrier->wait(false); // if canceled returns false
+            return barrier->wait(false); // if cancelled returns false
         return true;
     }
 

+ 3 - 3
thorlcr/activities/csvread/thcsvrslave.cpp

@@ -38,7 +38,7 @@
 class CCsvReadSlaveActivity : public CDiskReadSlaveActivityBase, public CThorDataLink
 {
     IHThorCsvReadArg *helper;
-    StringAttr csvQuote, csvSeperate, csvTerminate;
+    StringAttr csvQuote, csvSeparate, csvTerminate;
     Owned<IRowStream> out;
     rowcount_t limit;
     rowcount_t stopAfter;
@@ -82,7 +82,7 @@ class CCsvReadSlaveActivity : public CDiskReadSlaveActivityBase, public CThorDat
             readFinished = false;
             //Initialise information...
             ICsvParameters * csvInfo = activity.helper->queryCsvParameters();
-            csvSplitter.init(activity.helper->getMaxColumns(), csvInfo, activity.csvQuote, activity.csvSeperate, activity.csvTerminate);
+            csvSplitter.init(activity.helper->getMaxColumns(), csvInfo, activity.csvQuote, activity.csvSeparate, activity.csvTerminate);
         }
         virtual void setPart(IPartDescriptor *partDesc, unsigned partNoSerialized)
         {
@@ -189,7 +189,7 @@ public:
             data.read(b);
             if (b) data.read(csvQuote);
             data.read(b);
-            if (b) data.read(csvSeperate);
+            if (b) data.read(csvSeparate);
             data.read(b);
             if (b) data.read(csvTerminate);
         }

+ 1 - 1
thorlcr/activities/enth/thenthslave.cpp

@@ -64,7 +64,7 @@ protected:
             abortSoon = true;
 #if THOR_TRACE_LEVEL >= 5
         ActPrintLog("ENTH: init - Numerator = %"RCPF"d, Denominator = %"RCPF"d", numerator, denominator);   
-        ActPrintLog("%s: Inital value of counter %"RCPF"d", actStr.str(), counter);
+        ActPrintLog("%s: Initial value of counter %"RCPF"d", actStr.str(), counter);
 #endif
     }
 

+ 1 - 1
thorlcr/activities/group/thgroupslave.cpp

@@ -75,7 +75,7 @@ public:
 #endif
             lastNode = (container.queryJob().queryMyRank() == container.queryJob().querySlaves());
 
-            rollover.clear(); // JCSMORE - should be albe to reuse the CGroupTranser obj.
+            rollover.clear(); // JCSMORE - should be able to reuse the CGroupTranser obj.
             rollover.setown(new CGroupTransfer(&container, queryRowAllocator(), queryRowSerializer(), queryRowDeserializer(), transferAcceptPort));
         }
 

+ 3 - 3
thorlcr/activities/hashdistrib/thhashdistribslave.cpp

@@ -931,7 +931,7 @@ ICompare *CDistributorBase::dedupcompare;
 // protocol is:
 // 1) 0 byte block              - indicates end of input - no ack required
 // 2) 1 byte block {1}          - request to send - ack required
-// 3) >1 byte block {...,0} - block sent following RTS recieved - no ack required
+// 3) >1 byte block {...,0} - block sent following RTS received - no ack required
 // 4) >1 byte block {...,1}    - block sent - ack required
 // ack is always a single byte 0 for stop and 1 for continue
 
@@ -1001,7 +1001,7 @@ Restart:
                 comm.recv(msg,sender,tag);
                 sz = msg.length();
 #ifdef _FULL_TRACE
-                ActPrintLog("HDIST MP recieved block from %d size %d",(int)sender,sz);
+                ActPrintLog("HDIST MP received block from %d size %d",(int)sender,sz);
 #endif
             }
             else
@@ -1589,7 +1589,7 @@ public:
 
     CATCH_NEXTROW()
     {
-        ActivityTimer t(totalCycles, timeActivities, NULL); // careful not to call again in derivates
+        ActivityTimer t(totalCycles, timeActivities, NULL); // careful not to call again in derivatives
         if (abortSoon||eofin) {
             eofin = true;
             return NULL;

+ 1 - 1
thorlcr/activities/indexwrite/thindexwrite.cpp

@@ -96,7 +96,7 @@ public:
                 {
                     IGroup &group = groups.item(g);
                     if (gwidth != groups.item(g).ordinality())
-                        throw MakeActivityException(this, 0, "Unsupported, cannot output multiple refactored widths, targetting cluster '%s' and '%s'", clusters.item(0), clusters.item(g));
+                        throw MakeActivityException(this, 0, "Unsupported, cannot output multiple refactored widths, targeting cluster '%s' and '%s'", clusters.item(0), clusters.item(g));
                     if (gwidth != restrictedWidth)
                         groups.replace(*group.subset((unsigned)0, restrictedWidth), g);
                 }

+ 1 - 1
thorlcr/activities/iterate/thiterateslave.cpp

@@ -442,7 +442,7 @@ public:
         ActivityTimer t(totalCycles, timeActivities, NULL);
         if (dohere) {
             OwnedConstThorRow row;
-            row.set(helper->next()); // needs linking alledgedly
+            row.set(helper->next()); // needs linking allegedly
             if (row.get()) {
                 dataLinkIncrement();
                 return row.getClear();

+ 2 - 2
thorlcr/activities/keydiff/thkeydiffslave.cpp

@@ -167,7 +167,7 @@ public:
 
         CDateTime createTime, modifiedTime, accessedTime;
         ifile->getTime(&createTime, &modifiedTime, &accessedTime);
-        // round file time down to nearest sec. Nanosec accurancy is not preserved elsewhere and can lead to mismatch later.
+        // round file time down to nearest sec. Nanosec accuracy is not preserved elsewhere and can lead to mismatch later.
         unsigned hour, min, sec, nanosec;
         modifiedTime.getTime(hour, min, sec, nanosec);
         modifiedTime.setTime(hour, min, sec, 0);
@@ -184,7 +184,7 @@ public:
 
             CDateTime createTime, modifiedTime, accessedTime;
             ifile->getTime(&createTime, &modifiedTime, &accessedTime);
-            // round file time down to nearest sec. Nanosec accurancy is not preserved elsewhere and can lead to mismatch later.
+            // round file time down to nearest sec. Nanosec accuracy is not preserved elsewhere and can lead to mismatch later.
             unsigned hour, min, sec, nanosec;
             modifiedTime.getTime(hour, min, sec, nanosec);
             modifiedTime.setTime(hour, min, sec, 0);

+ 1 - 1
thorlcr/activities/keyedjoin/thkeyedjoinslave.cpp

@@ -1576,7 +1576,7 @@ public:
     }
     inline void resetLastStats()
     {
-// NB: part manager retains seek/scan counts accross setKey calls
+// NB: part manager retains seek/scan counts across setKey calls
 //      lastSeeks = lastScans = 0;
     }
 

+ 2 - 2
thorlcr/activities/keypatch/thkeypatchslave.cpp

@@ -164,7 +164,7 @@ public:
 
         CDateTime createTime, modifiedTime, accessedTime;
         ifile->getTime(&createTime, &modifiedTime, &accessedTime);
-        // round file time down to nearest sec. Nanosec accurancy is not preserved elsewhere and can lead to mismatch later.
+        // round file time down to nearest sec. Nanosec accuracy is not preserved elsewhere and can lead to mismatch later.
         unsigned hour, min, sec, nanosec;
         modifiedTime.getTime(hour, min, sec, nanosec);
         modifiedTime.setTime(hour, min, sec, 0);
@@ -181,7 +181,7 @@ public:
 
             CDateTime createTime, modifiedTime, accessedTime;
             ifile->getTime(&createTime, &modifiedTime, &accessedTime);
-            // round file time down to nearest sec. Nanosec accurancy is not preserved elsewhere and can lead to mismatch later.
+            // round file time down to nearest sec. Nanosec accuracy is not preserved elsewhere and can lead to mismatch later.
             unsigned hour, min, sec, nanosec;
             modifiedTime.getTime(hour, min, sec, nanosec);
             modifiedTime.setTime(hour, min, sec, 0);

+ 1 - 1
thorlcr/activities/lookupjoin/thlookupjoinslave.cpp

@@ -539,7 +539,7 @@ public:
         // will have to merge rhsMatchSets in a tree as there can be a large number of outer records per node.
         // topn does something similar, reuse.
         // when all merged, have complete merged set on node 0 only.
-        // either output all from node 0, or parition set and distribute parition info to each node for output.
+        // either output all from node 0, or partition set and distribute partition info to each node for output.
 
         // If right only, no need to broadcast rhs record set, can look for matches in local input and merge match etc. set as above.
 

+ 1 - 1
thorlcr/activities/msort/thmsort.cpp

@@ -97,7 +97,7 @@ protected:
         for (; s<container.queryJob().querySlaves(); s++)
         {
             SocketEndpoint ep;
-            ep.deserialize(queryInitializationData(s)); // this is a bit of a Kludge untill we get proper MP Thor
+            ep.deserialize(queryInitializationData(s)); // this is a bit of a Kludge until we get proper MP Thor
             imaster->AddSlave(&container.queryJob().queryJobComm(), s+1, ep,mpTagRPC);
         }
     }

+ 2 - 2
thorlcr/activities/msort/thsortu.cpp

@@ -714,7 +714,7 @@ public:
             }
             if ((gotsz||denormGot||fret.get())&&(keepremaining!=(unsigned)-1))
                 keepremaining--;
-            // treat SKIP and exclude as match sucess
+            // treat SKIP and exclude as match success
             leftmatched = true;
         }
         if (gotsz)
@@ -1177,7 +1177,7 @@ retry:
                                     }
                                     if (ret.get()&&(keepremaining!=(unsigned)-1))
                                         keepremaining--;
-                                    // treat SKIP and exclude as match sucess
+                                    // treat SKIP and exclude as match success
                                     if (rightouter)
                                         rightmatched[rightidx] = true;
                                     leftmatched = true;

+ 1 - 1
thorlcr/activities/nsplitter/thnsplitterslave.cpp

@@ -377,7 +377,7 @@ SplitterOutput::SplitterOutput(NSplitterSlaveActivity &_activity, unsigned _outp
 
 void SplitterOutput::addCycles(unsigned __int64 elapsedCycles)
 {
-    totalCycles += elapsedCycles; // per output time, inquired by pulling acts.
+    totalCycles += elapsedCycles; // per output
     SpinBlock b(activity.timingLock);
     activity.getTotalCyclesRef() += elapsedCycles; // Splitter act aggregate time.
 }

+ 1 - 1
thorlcr/activities/spill/thspillslave.cpp

@@ -161,7 +161,7 @@ public:
         mb.append(crc);
         CDateTime createTime, modifiedTime, accessedTime;
         ifile->getTime(&createTime, &modifiedTime, &accessedTime);
-        // round file time down to nearest sec. Nanosec accurancy is not preserved elsewhere and can lead to mismatch later.
+        // round file time down to nearest sec. Nanosec accuracy is not preserved elsewhere and can lead to mismatch later.
         unsigned hour, min, sec, nanosec;
         modifiedTime.getTime(hour, min, sec, nanosec);
         modifiedTime.setTime(hour, min, sec, 0);

+ 1 - 1
thorlcr/activities/thdiskbase.cpp

@@ -269,7 +269,7 @@ void CWriteMasterBase::init()
         if (blockCompressed)
             props.setPropBool("@blockCompressed", true);
         if (TAKdiskwrite == container.getKind() && (0 != (diskHelperBase->getFlags() & TDXtemporary)) && container.queryOwner().queryOwner() && (!container.queryOwner().isGlobal())) // I am in a child query
-        { // do early, becasue this will be local act. and will not come back to master until end of owning graph.
+        { // do early, because this will be local act. and will not come back to master until end of owning graph.
             publish();
         }
     }

+ 3 - 3
thorlcr/activities/thdiskbaseslave.cpp

@@ -108,7 +108,7 @@ void CDiskPartHandlerBase::setPart(IPartDescriptor *_partDesc, unsigned partNoSe
     firstInGroup = true;
     which = partDesc->queryPartIndex();
 
-    activity.helper->setCallback(this); // NB, if we were to have >1 of these objects, would prob. need seperate helper instances also
+    activity.helper->setCallback(this); // NB, if we were to have >1 of these objects, would prob. need separate helper instances also
     open();
 }
 
@@ -155,7 +155,7 @@ void CDiskPartHandlerBase::open()
                 ActPrintLog(&activity, "Calculated crc = %x, storedCrc = %x", calcCrc, storedCrc);
                 if (calcCrc != storedCrc)
                 {
-                    IThorException *e = MakeActivityException(&activity, TE_FileCrc, "CRC Failure validaing compressed file: %s", iFile->queryFilename());
+                    IThorException *e = MakeActivityException(&activity, TE_FileCrc, "CRC Failure validating compressed file: %s", iFile->queryFilename());
                     e->setAudience(MSGAUD_operator);
                     throw e;
                 }
@@ -537,7 +537,7 @@ void CDiskWriteSlaveActivityBase::processDone(MemoryBuffer &mb)
 
     CDateTime createTime, modifiedTime, accessedTime;
     ifile->getTime(&createTime, &modifiedTime, &accessedTime);
-    // round file time down to nearest sec. Nanosec accurancy is not preserved elsewhere and can lead to mismatch later.
+    // round file time down to nearest sec. Nanosec accuracy is not preserved elsewhere and can lead to mismatch later.
     unsigned hour, min, sec, nanosec;
     modifiedTime.getTime(hour, min, sec, nanosec);
     modifiedTime.setTime(hour, min, sec, 0);

+ 1 - 1
thorlcr/graph/thgraph.hpp

@@ -196,7 +196,7 @@ protected:
     Owned<CActivityBase> activity;
     CGraphBase *resultsGraph, *owner;
     CGraphDependencyArray dependsOn;
-    Owned<IThorBoundLoopGraph> loopGraph; // really only here as master and slave derivities set/use
+    Owned<IThorBoundLoopGraph> loopGraph; // really only here as master and slave derivatives set/use
     MemoryBuffer createCtxMb, startCtxMb;
     bool haveCreateCtx, haveStartCtx;
 

+ 1 - 1
thorlcr/mfilemanager/thmfilemanager.cpp

@@ -72,7 +72,7 @@ class CFileManager : public CSimpleInterface, implements IThorFileManager
             if (file)
             {
                 file.clear();
-                // JCSMORE delete orphanes file parts here..
+                // JCSMORE delete orphan file parts here..
                 // i.e. shouldn't it call
                 // dfd.removeEntry(scopedName.str(), userDesc);
                 // And/Or queryDistributedFileDirectory().removePhysical(scopedName.str(), 0, NULL, NULL, userDesc);

+ 1 - 1
thorlcr/slave/slave.cpp

@@ -236,7 +236,7 @@ CActivityBase *createIfActionSlave(CGraphElementBase *container);
 
 class CGenericSlaveGraphElement : public CSlaveGraphElement
 {
-    bool wuidread2diskread; // master decides after interoggating result and sneaks in info before slave creates
+    bool wuidread2diskread; // master decides after interrogating result and sneaks in info before slave creates
     StringAttr wuidreadFilename;
 public:
     CGenericSlaveGraphElement(CGraphBase &_owner, IPropertyTree &xgmml) : CSlaveGraphElement(_owner, xgmml)

+ 1 - 1
thorlcr/thorutil/thalloc.hpp

@@ -41,7 +41,7 @@ interface IThorRowManager : extends IInterface
     virtual memsize_t remaining() = 0;
     virtual void reportLeaks() = 0;
     virtual void setLCRrowCRCchecking(bool on=true) = 0;
-    // the followng are used to extend row with slack
+    // the following are used to extend row with slack
     virtual void *extendRow(void * original, size32_t newsize, unsigned activityId, size32_t &size) = 0;
     virtual void *allocateExt(size32_t size, unsigned activityId, size32_t &outsize) = 0;
 };

+ 1 - 1
thorlcr/thorutil/thbufdef.hpp

@@ -45,7 +45,7 @@
 #define NSPLITTER_BLOCK_BUFFER_SIZE             (0x10000)               // 64K
 #define DISTRIBUTE_PULL_BUFFER_SIZE             (0x100000*32)           // 32MB
 #define SORT_BUFFER_TOTAL                       (0x100000*20)           // 20MB (estimate)
-#define DISTRIBUTE_SINGLE_BUFFER_SIZE           (0x10000)               // 64K  - NB per node and multiplied by asyc send
+#define DISTRIBUTE_SINGLE_BUFFER_SIZE           (0x10000)               // 64K  - NB per node and multiplied by async send
 #define FUNNEL_MIN_BUFF_SIZE                    (0x100000*2)            // 2MB
 #define FUNNEL_MAX_BUFF_SIZE                    (0x100000*20)           // 20MB
 #define COMBINE_MAX_BUFF_SIZE                   (0x100000*20)           // 20MB

+ 1 - 1
thorlcr/thorutil/thcompressutil.hpp

@@ -35,7 +35,7 @@
 
 /*
     Note: The first sizeof(size32_t) bytes of the compressed buffer contain the
-    orgininal (uncompressed) size of the data or 0. If 0, it indicates that
+    original (uncompressed) size of the data or 0. If 0, it indicates that
     buffer is uncompressed - this happens if the data could not be compressed 
     by a minimum of 80%.
 */

+ 1 - 1
tools/copyexp/copyexp.cpp

@@ -263,7 +263,7 @@ void copyCompress(const char *from, const char *to, size32_t rowsize, bool fast,
     }
 #ifdef __linux__
     // this is not really needed in windows - if it is we will have to
-    // test the file extenstion - .exe, .bat
+    // test the file extension - .exe, .bat
 
     struct stat info;
     if (stat(from, &info) == 0)  // cannot fail - exception would have been thrown above

+ 1 - 1
tools/esdl/esdlcomp.cpp

@@ -1041,7 +1041,7 @@ static EspMethodInfo* sortMethods(EspMethodInfo* ms)
         }
     }
 
-    // recurively sort
+    // recursively sort
     smallest->next = sortMethods(smallest->next);
 
     return smallest;

+ 3 - 3
tools/hidl/hidlcomp.cpp

@@ -4614,7 +4614,7 @@ void EspMessageInfo::write_esp()
                 else
                 {
                     outf("\t{\n");
-                    outf("\t\t//*** defualt kind: %s; type=%s, name=%s\n", getTypeKindName(pi->kind), pi->typname, uname);
+                    outf("\t\t//*** default kind: %s; type=%s, name=%s\n", getTypeKindName(pi->kind), pi->typname, uname);
                     outf("\t\tbuffer.append(\"<%s>\");\n", pi->getXmlTag());
                     outf("\t\tbuffer.append(src.get%s());\n", uname);
                     outf("\t\tbuffer.append(\"</%s>\");\n", pi->getXmlTag());
@@ -4833,14 +4833,14 @@ void EspMessageInfo::write_esp()
                     indentOuts("{\n");
                     if (nilRemove)
                     {
-                        indentOutf(1,"//*** defualt kind: %s; type=%s, name=%s\n", getTypeKindName(pi->kind), pi->typname, uname);
+                        indentOutf(1,"//*** default kind: %s; type=%s, name=%s\n", getTypeKindName(pi->kind), pi->typname, uname);
                         indentOutf("StringBuffer tmp(src.get%s());\n",uname);
                         indentOutf("if (tmp.length()>0)\n");
                         indentOutf1(1,"buffer.appendf(\"<%s>%%s</%s>\",tmp.str());\n", pi->name,pi->name);
                     }
                     else
                     {
-                        indentOutf(1,"//*** defualt kind: %s; type=%s, name=%s\n", getTypeKindName(pi->kind), pi->typname, uname);
+                        indentOutf(1,"//*** default kind: %s; type=%s, name=%s\n", getTypeKindName(pi->kind), pi->typname, uname);
                         indentOutf("buffer.append(\"<%s>\");\n", pi->getXmlTag());
                         indentOutf("buffer.append(src.get%s());\n", uname);
                         indentOutf("buffer.append(\"</%s>\");\n", pi->getXmlTag());