NetBurner Community Forum

Code: Select all

	//Extract the command (without parameters) and put in member var
	string ParsedMessage::ParseCommand(string message)
	{
		//Take everything up to the _cmdDelimiter as the command
		const size_t found_pos = message.find(_cmdDelimiter);

		if (found_pos != string::npos)
		{
			_command = message.substr(0, found_pos);
			return message.substr(found_pos + 1);
		}
		else
		{
			_command = message; //no delimiter treat the entire message as the command.
			return EMPTY_STRING;
		}
	}

Code: Select all

  char* p_char = strtok(c_string_to_parse, ";\n");  //allow either ; or new line as delimiters
  while (p_char)
  {
   //Depending on how complicated your parsing is you'll have more code and method calls here
  //strncpy and strcat are typically useful

  //Then somewhere in the loop, usually near the end you use strtok again with the  alternate form
      p_char = strtok(NULL, ";\n");
   }

Code: Select all

#include <stdio.h>
#include <string.h>
#include <startnet.h>
#include <tcp.h>
#include <iosys.h>
#include <NBPKQuadSerial.h>
#include "io.h"
#include "tasks.h"
#include <iostream>
#include <string>
using namespace std;

int len;
void SerialDataParseLine(int port, string linein) {
	len = linein.length();
	if (len < 10) return; //All the data I deal with will be longer than this
	cout << "P" << port << ": " << linein << endl; //For display only

	if (linein[0] == '#') { //First char is a pound sign
		//Do something with the data
	}
}

string str[4];
size_t found;
void SerialDataAppend(int port, char *buf) {
	str[port].append(buf);
	found = str[port].find("\r\n"); //Check for a line break
	while (found != string::npos) { //Found one
		SerialDataParseLine(port, str[port].substr(0, found)); //Send the line on for processing
		str[port] = str[port].substr(found+2); //Remove the line we just read
		found = str[port].find("\r\n"); //Check for another line break
	}
	if (str[port].length() > 1024) {
		iprintf("Serial RX buffer exceeded 1KB without a line break, cleared.\r\n");
		str[port] = "";
	}
}


void SerialPortTask(void * pd) {
	int i;
	int fd_serial[4];    // Quad serial port fds
	static char Read_Serial[4][256];

	for (i = 0; i < 4; i++) { //Open all 4 serial ports
		fd_serial[i] = PK70QuadOpenSerial(i, 115200, 1, 8, eParityNone );
		//iprintf("Opening Serial Port %d = %d\r\n", i, fd_serial[i]);
	}

	while(1) {
		fd_set read_fds; // Declare fds masks for reading and errors
		FD_ZERO(&read_fds); // Init the read and error masks to 0 (no file descriptors)
		for (i = 0; i < 4; i++) { //Add fds for each serial
			FD_SET(fd_serial[i], &read_fds);
		}
		long wait = 1;
		if (select( FD_SETSIZE, &read_fds, (fd_set *)0, (fd_set *)0, wait)) {
		for (i = 0; i < 4; i++) {
				if (FD_ISSET(fd_serial[i], &read_fds)) {
					int rv = read(fd_serial[i], Read_Serial[i], 256);
					if (rv > 0) { //Got data
						Read_Serial[i][rv] = 0;//Null terminate the data
						SerialDataAppend(i, Read_Serial[i]);
					}
				}
			}
		}
	}
}
DWORD SerialTaskStack[USER_TASK_STK_SIZE];
void StartSerial() {
	iprintf("Starting Serial Port Task.\r\n");
	OSTaskCreatewName(SerialPortTask, (void *)0, &SerialTaskStack[USER_TASK_STK_SIZE], SerialTaskStack, SERIAL_PORT_TASK_PRIO, "QUADSERIAL");
}