bpo-31904: Add support for VxWorks RTOS

Include/osdefs.h

@@ -14,6 +14,10 @@ extern "C" {
 #define DELIM L';'
 #endif
 
+#ifdef __VXWORKS__
+#define DELIM L';'
+#endif
+
 /* Filename separator */
 #ifndef SEP
 #define SEP L'/'

Lib/subprocess.py

@@ -66,7 +66,11 @@
     _mswindows = True
 except ModuleNotFoundError:
     _mswindows = False
-    import _posixsubprocess
+    _vxworks = (sys.platform == "vxworks")
+    if _vxworks:
+        import _vxwapi
+    else:
+        import _posixsubprocess
     import select
     import selectors
 else:
@@ -733,6 +737,14 @@ def __init__(self, args, bufsize=-1, executable=None,
                 raise ValueError("preexec_fn is not supported on Windows "
                                  "platforms")
         else:
+            if _vxworks:
+                if shell:
+                    raise ValueError("shell is not supported on VxWorks")
+                if preexec_fn is not None:
+                    raise ValueError("Preexecution function is not supported"
+                                     "on VxWorks");
+                if start_new_session:
+                    raise ValueError("VxWorks does not support sessions");
             # POSIX
             if pass_fds and not close_fds:
                 warnings.warn("pass_fds overriding close_fds.", RuntimeWarning)
@@ -1580,7 +1592,17 @@ def _execute_child(self, args, executable, preexec_fn, close_fds,
                             for dir in os.get_exec_path(env))
                     fds_to_keep = set(pass_fds)
                     fds_to_keep.add(errpipe_write)
-                    self.pid = _posixsubprocess.fork_exec(
+                    if _vxworks:
+                        self.pid = _vxwapi.rtp_spawn(
+                            args, executable_list,
+                            close_fds, tuple(sorted(map(int, fds_to_keep))),
+                            cwd, env_list,
+                            p2cread, p2cwrite, c2pread, c2pwrite,
+                            errread, errwrite,
+                            errpipe_read, errpipe_write,
+                            restore_signals, start_new_session, preexec_fn)
+                    else:
+                        self.pid = _posixsubprocess.fork_exec(
                             args, executable_list,
                             close_fds, tuple(sorted(map(int, fds_to_keep))),
                             cwd, env_list,
@@ -1589,6 +1611,8 @@ def _execute_child(self, args, executable, preexec_fn, close_fds,
                             errpipe_read, errpipe_write,
                             restore_signals, start_new_session, preexec_fn)
                     self._child_created = True
+                    if _vxworks and self.pid == -1:
+                        self._child_created = False
                 finally:
                     # be sure the FD is closed no matter what
                     os.close(errpipe_write)

Lib/test/test_os.py

@@ -1518,7 +1518,8 @@ def mock_execve(name, *args):
         os.execve = orig_execve
         os.defpath = orig_defpath
 
-
+@unittest.skipUnless(hasattr(os, 'execv'),
+                         "No os.execv or os.execve function to test.")
 class ExecTests(unittest.TestCase):
     @unittest.skipIf(USING_LINUXTHREADS,
                      "avoid triggering a linuxthreads bug: see issue #4970")

Lib/test/test_time.py

@@ -88,6 +88,8 @@ def check_ns(sec, ns):
             check_ns(time.clock_gettime(time.CLOCK_REALTIME),
                      time.clock_gettime_ns(time.CLOCK_REALTIME))
 
+    @unittest.skipUnless(hasattr(time, 'clock'),
+                         'need time.clock()')
     def test_clock(self):
         with self.assertWarns(DeprecationWarning):
             time.clock()
@@ -312,7 +314,13 @@ def test_ctime(self):
         self.assertEqual(time.ctime(t), 'Sun Sep 16 01:03:52 1973')
         t = time.mktime((2000, 1, 1, 0, 0, 0, 0, 0, -1))
         self.assertEqual(time.ctime(t), 'Sat Jan  1 00:00:00 2000')
-        for year in [-100, 100, 1000, 2000, 2050, 10000]:
+        # the largest year on VxWorks is 2038
+        if 'vxworks' in sys.platform :
+            range = [-100, 100, 1000, 2000]
+        else:
+            range = [-100, 100, 1000, 2000, 2050, 10000]
+
+        for year in range:
             try:
                 testval = time.mktime((year, 1, 10) + (0,)*6)
             except (ValueError, OverflowError):
@@ -549,8 +557,10 @@ def test_localtime_failure(self):
         self.assertRaises(ValueError, time.ctime, float("nan"))
 
     def test_get_clock_info(self):
-        clocks = ['clock', 'monotonic', 'perf_counter', 'process_time', 'time']
-
+        if hasattr(time, 'clock'):
+            clocks = ['clock', 'monotonic', 'perf_counter', 'process_time', 'time']
+        else:
+            clocks = ['monotonic', 'perf_counter', 'process_time', 'time']
         for name in clocks:
             if name == 'clock':
                 with self.assertWarns(DeprecationWarning):

Modules/_cryptmodule.c

@@ -4,7 +4,9 @@
 #include "Python.h"
 
 #include <sys/types.h>
-
+#ifdef __VXWORKS__
+#include <openssl/des.h>
+#endif
 /* Module crypt */
 
 /*[clinic input]
@@ -39,8 +41,12 @@ crypt_crypt_impl(PyObject *module, const char *word, const char *salt)
     struct crypt_data data;
     memset(&data, 0, sizeof(data));
     crypt_result = crypt_r(word, salt, &data);
+#else
+#ifdef __VXWORKS__
+    crypt_result = DES_crypt(word, salt);
 #else
     crypt_result = crypt(word, salt);
+#endif
 #endif
     return Py_BuildValue("s", crypt_result);
 }