add draft pru support

src/index.js

@@ -18,6 +18,7 @@ var autorun = require('./autorun');
 var server = require('./server');
 var socketHandlers = require('./socket_handlers');
 var ffi = require('./ffiimp');
+var pru = require('./pru');
 //var rc = require('./rc');
 
 var debug = process.env.DEBUG ? true : false;
@@ -646,6 +647,9 @@ for (var x in socketHandlers) {
 for (var x in ffi) {
     f[x] = ffi[x];
 }
+for (var x in pru) {
+    f[x] = pru[x];
+}
 /*for(var x in rc) {
     exports[x] = rc[x];
 }*/

src/pru.js

@@ -0,0 +1,102 @@
+var fs = require('fs');
+var shell = require('shelljs');
+var winston = require('winston');
+
+var debug = process.env.DEBUG ? true : false;
+
+var rproc_path = '/sys/class/remoteproc/remoteproc';
+var fw_path = '/lib/firmware/am335x-pru';
+
+//modprobe/unprobe
+var modProbe = function (mod, probe) {
+    mod = mod || 'pru_rproc'; //default pru_rproc
+    probe = typeof probe !== 'undefined' ? probe : true;
+    if (probe)
+        var cmd = 'modprobe ' + mod; //for modprobe
+    else
+        var cmd = 'modprobe -r ' + mod; //for  modunprobe
+    if (debug) winston.debug('running modprobe');
+    code = shell.exec(cmd).code;
+    if (code > 0)
+        winston.error("modprobe/modunprobe failed");
+}
+//pru enable/disable
+var pruEnable = function (pruno, enable) {
+    var pruno = typeof pruno !== 'undefined' ? pruno : '0';
+    if (pruno != 0 && pruno != 1) {
+        winston.error('PRU Core No. should be 0 or 1');
+        return false;
+    } else
+        pruno += 1;
+    var path = rproc_path + pruno + '/state';
+    var enable = typeof enable !== 'undefined' ? enable : true;
+    var currentState = (fs.readFileSync(path).toString());
+    var state;
+    if (currentState == 'offline\n' && enable) state = 'start\n'; //start only if offline
+    else if (currentState == 'running\n' && !enable) state = 'stop\n'; //stop only if running
+    if (typeof state != 'undefined') {
+        if (debug) winston.debug('Changing PRU' + pruno + 'state from' + currentState);
+        fs.writeFileSync(path, state);
+    }
+}
+//pru reset
+var pruReset = function (pruno) {
+    if (pruno != 0 && pruno != 1) {
+        winston.error('PRU Core No. should be 0 or 1');
+        return false;
+    }
+    pruEnable(pruno, false);
+    pruEnable(pruno, true);
+}
+// loadFirmware
+var loadPRUFirmware = function (filepath, pruno) {
+    var pruno = typeof pruno !== 'undefined' ? pruno : '0';
+    if (pruno != 0 && pruno != 1) {
+        winston.error('PRU Core No. should be 0 or 1');
+        return false;
+    }
+    if (!(fs.existsSync(filepath))) {
+        winston.error('Firmware file not found');
+        return false;
+    }
+    pruEnable(pruno, false); //disable PRU before loading firmware if not already disabled
+    var path = fw_path + pruno + ' -fw';
+    shell.cp(filepath, path); //used because fs.copyFile() not supported, fast enough
+    pruEnable(pruno, true); //enable PRU after loading firmware
+}
+//sendmsg
+var sendrpMsg = function (message, pruno) {
+    var pruno = typeof pruno !== 'undefined' ? pruno : '0';
+    if (pruno != 0 && pruno != 1) {
+        winston.error('PRU Core No. should be 0 or 1');
+        return false;
+    }
+    pruno += 1;
+    var channel = 'rpmsg_pru3' + pruno;
+    var path = '/dev/' + channel; //default is rpmsg_pru31
+    fs.writeFileSync(path, message + '\n');
+}
+//getmsg
+var getrpMsg = function (pruno) {
+    var pruno = typeof pruno !== 'undefined' ? pruno : '0';
+    if (pruno != 0 && pruno != 1) {
+        winston.error('PRU Core No. should be 0 or 1');
+        return false;
+    }
+    pruno += 1;
+    var channel = 'rpmsg_pru3' + pruno;
+    var path = '/dev/' + channel;
+    if (!(fs.existsSync(path))) {
+        winston.error('getMsg failed to fetch message');
+        return false;
+    } else return fs.readFileSync(path).toString();
+}
+
+module.exports = {
+    modProbe: modProbe,
+    pruEnable: pruEnable,
+    pruReset: pruReset,
+    loadPRUFirmware: loadPRUFirmware,
+    sendrpMsg: sendrpMsg,
+    getrpMsg: getrpMsg
+}