提交: c7562623ec4d4b15568f572c948502040503c2e5 - TunnelSerialToIEEE1888 (hg)

Tunnel(Serial To IEEE1888)

Commit MetaInfo

• 修订版: c7562623ec4d4b15568f572c948502040503c2e5 (tree)
• 时间: 2015-07-10 14:49:53
• 作者: MirrgieRiana Kurilab
• Commiter: MirrgieRiana Kurilab

Log Message

rename: AntsElement -> FiapPacketBuffer

更改概述

• modified: TunnelSerialToIEEE1888/core.ino
• add: TunnelSerialToIEEE1888/FiapPacketBuffer.h
• add: TunnelSerialToIEEE1888/FiapPacketBuffer.ino
• delete: TunnelSerialToIEEE1888/AntsElement.h
• delete: TunnelSerialToIEEE1888/AntsElement.ino

差异

diff -r de5d2ab4fd03 -r c7562623ec4d TunnelSerialToIEEE1888/AntsElement.h
--- a/TunnelSerialToIEEE1888/AntsElement.h	Fri Jul 10 14:37:42 2015 +0900
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -1,53 +0,0 @@
-#ifndef INCLUDE_AntsElement_h
-#define INCLUDE_AntsElement_h
-
-class DateTime
-{
-public:
-  unsigned short year;
-  byte month; // 1~12
-  byte day; // 1~31
-  byte hour; // 0~23
-  byte minute; // 0~59
-  byte second; // 0~59
-};
-
-// addElementをひたすら呼び出すだけで送信される。
-// 内部でバッファリングされるので、一連の追加が終わったらflushする。
-class AntsElement
-{
-public:
-
-#define AntsElement_ELEMENTS_MAX_LENGTH 15
-#define AntsElement_CID_MAX_LENGTH 40
-#define AntsElement_VALUE_MAX_LENGTH 40
-
-  AntsElement();
-
-  // 現在入っているデータを破棄する。
-  void clear();
-
-  // すべての引数は、メソッド内で複製されるので呼び出した後は変更してよい。
-  // これ以上追加できない場合は自動的にflushされる
-  // 文字数制限あり。
-  void acceptElement(char* cid, char* value, DateTime dateTime);
-
-  // 自動的にclearされる。
-  void flush();
-
-  struct fiap_element fiapElements[AntsElement_ELEMENTS_MAX_LENGTH];
-
-  char fiapElement_cids
-    [AntsElement_ELEMENTS_MAX_LENGTH]
-    [AntsElement_CID_MAX_LENGTH];
-
-  char fiapElement_values
-    [AntsElement_ELEMENTS_MAX_LENGTH]
-    [AntsElement_VALUE_MAX_LENGTH];
-
-  int fiapElementLength;
-
-};
-
-#endif
-

diff -r de5d2ab4fd03 -r c7562623ec4d TunnelSerialToIEEE1888/AntsElement.ino
--- a/TunnelSerialToIEEE1888/AntsElement.ino	Fri Jul 10 14:37:42 2015 +0900
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -1,57 +0,0 @@
-#include "AntsElement.h"
-
-AntsElement::AntsElement()
-{
-  clear();
-}
-
-void AntsElement::clear()
-{
-  fiapElementLength = 0;
-}
-
-void AntsElement::acceptElement(char* cid, char* value, DateTime dateTime)
-{
-  if (fiapElementLength >= AntsElement_ELEMENTS_MAX_LENGTH) {
-    flush();
-  }
-
-  strcpy(fiapElement_cids[fiapElementLength], cid);
-  strcpy(fiapElement_values[fiapElementLength], value);
-
-  struct fiap_element tmp = { 
-    fiapElement_cids[fiapElementLength],
-    fiapElement_values[fiapElementLength],
-    dateTime.year,
-    dateTime.month,
-    dateTime.day,
-    dateTime.hour,
-    dateTime.minute,
-    dateTime.second,
-    "+09:00",
-  };
-  fiapElements[fiapElementLength] = tmp;
-
-  fiapElementLength++;
-  if (fiapElementLength >= AntsElement_ELEMENTS_MAX_LENGTH) {
-    flush();
-  }
-}
-
-void AntsElement::flush()
-{
-  if (fiapElementLength > 0) {
-    int res = fiapUploadAgent.post(fiapElements, fiapElementLength);
-    clear();
-    
-    if (res == 5) {
-      Serial.println("[Warning]:HTTP timeout");
-    } else if (res != 0) {
-      Serial.print("[Warning]:HTTP error: ");
-      Serial.print(res);
-      Serial.println("");
-    }
-  }
-}
-
-

diff -r de5d2ab4fd03 -r c7562623ec4d TunnelSerialToIEEE1888/FiapPacketBuffer.h
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/TunnelSerialToIEEE1888/FiapPacketBuffer.h	Fri Jul 10 14:49:53 2015 +0900
@@ -0,0 +1,56 @@
+#ifndef INCLUDE_FiapPacketBuffer_h
+#define INCLUDE_FiapPacketBuffer_h
+
+class DateTime
+{
+public:
+  unsigned short year;
+  byte month; // 1~12
+  byte day; // 1~31
+  byte hour; // 0~23
+  byte minute; // 0~59
+  byte second; // 0~59
+};
+
+#define FiapPacketBuffer_ELEMENTS_MAX_LENGTH 15
+#define FiapPacketBuffer_CID_MAX_LENGTH 40
+#define FiapPacketBuffer_VALUE_MAX_LENGTH 40
+
+// acceptElementをひたすら呼び出すだけで送信される。
+// 内部でバッファリングされる。一連の追加が終わったらflushすると、送信される。
+// まったくflushしなくても、上限に到達したら自動的にflushされる。
+class FiapPacketBuffer
+{
+public:
+
+  FiapPacketBuffer();
+
+  // 現在入っているデータを破棄する。
+  void clear();
+
+  // すべての引数は、メソッド内で複製されるので呼び出した後は変更してよい。
+  // これ以上追加できない場合は自動的にflushされる
+  // 文字数制限あり。
+  void acceptElement(char* cid, char* value, DateTime dateTime);
+
+  // 自動的にclearされる。
+  void flush();
+
+private:
+
+  struct fiap_element fiapElements[FiapPacketBuffer_ELEMENTS_MAX_LENGTH];
+
+  char fiapElement_cids
+    [FiapPacketBuffer_ELEMENTS_MAX_LENGTH]
+    [FiapPacketBuffer_CID_MAX_LENGTH];
+
+  char fiapElement_values
+    [FiapPacketBuffer_ELEMENTS_MAX_LENGTH]
+    [FiapPacketBuffer_VALUE_MAX_LENGTH];
+
+  int fiapElementLength;
+
+};
+
+#endif
+

diff -r de5d2ab4fd03 -r c7562623ec4d TunnelSerialToIEEE1888/FiapPacketBuffer.ino
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/TunnelSerialToIEEE1888/FiapPacketBuffer.ino	Fri Jul 10 14:49:53 2015 +0900
@@ -0,0 +1,57 @@
+#include "FiapPacketBuffer.h"
+
+FiapPacketBuffer::FiapPacketBuffer()
+{
+  clear();
+}
+
+void FiapPacketBuffer::clear()
+{
+  fiapElementLength = 0;
+}
+
+void FiapPacketBuffer::acceptElement(char* cid, char* value, DateTime dateTime)
+{
+  if (fiapElementLength >= FiapPacketBuffer_ELEMENTS_MAX_LENGTH) {
+    flush();
+  }
+
+  strcpy(fiapElement_cids[fiapElementLength], cid);
+  strcpy(fiapElement_values[fiapElementLength], value);
+
+  struct fiap_element tmp = { 
+    fiapElement_cids[fiapElementLength],
+    fiapElement_values[fiapElementLength],
+    dateTime.year,
+    dateTime.month,
+    dateTime.day,
+    dateTime.hour,
+    dateTime.minute,
+    dateTime.second,
+    "+09:00",
+  };
+  fiapElements[fiapElementLength] = tmp;
+
+  fiapElementLength++;
+  if (fiapElementLength >= FiapPacketBuffer_ELEMENTS_MAX_LENGTH) {
+    flush();
+  }
+}
+
+void FiapPacketBuffer::flush()
+{
+  if (fiapElementLength > 0) {
+    int res = fiapUploadAgent.post(fiapElements, fiapElementLength);
+    clear();
+    
+    if (res == 5) {
+      Serial.println("[Warning]:HTTP timeout");
+    } else if (res != 0) {
+      Serial.print("[Warning]:HTTP error: ");
+      Serial.print(res);
+      Serial.println("");
+    }
+  }
+}
+
+

diff -r de5d2ab4fd03 -r c7562623ec4d TunnelSerialToIEEE1888/core.ino
--- a/TunnelSerialToIEEE1888/core.ino	Fri Jul 10 14:37:42 2015 +0900
+++ b/TunnelSerialToIEEE1888/core.ino	Fri Jul 10 14:49:53 2015 +0900
@@ -1,7 +1,7 @@
 #include "TunnelSerialToIEEE1888.h"
 #include "core.h"
 
-#include "AntsElement.h"
+#include "FiapPacketBuffer.h"
 
 void initCore()
 {
@@ -22,7 +22,7 @@
   waitMs = 200;
 }
 
-AntsElement antsElement;
+FiapPacketBuffer fiapPacketBuffer;
 
 void tunnel::invokeCommand(SerialReader* serialReader)
 {
@@ -63,7 +63,7 @@
   if (strcmp(serialReader->argumentsString[0], "FlushFiapPacket") == 0) {
 
     // 操作
-    antsElement.flush();
+    fiapPacketBuffer.flush();
 
     // ptint
     Serial.println("Message:flush");
@@ -82,7 +82,7 @@
       dateTime.minute = serialReader->argumentsInt[4];
       dateTime.second = serialReader->argumentsInt[5];
 
-      antsElement.acceptElement(
+      fiapPacketBuffer.acceptElement(
       serialReader->argumentsString[1],
       serialReader->argumentsString[2],
       dateTime);