Diff: modem_ref.cpp

Revision:

14:a9c324663732

Parent:

13:10589aaf8853

Child:

17:b4ea2a912fd3

--- a/modem_ref.cpp	Mon Sep 18 13:35:49 2017 +0000
+++ b/modem_ref.cpp	Wed Sep 20 08:48:05 2017 +0000
@@ -189,6 +189,9 @@
                 rem -= alp_parse_chunk(&p, &r);
                 switch (r.type)
                 {
+                    case ALP_OPCODE_RSP_TAG:
+                        REF_PRINT("RESP_TAG[%d]\n", r.meta.tag.id);
+                        break;
                     case ALP_OPCODE_RSP_F_DATA:
                     case ALP_OPCODE_RSP_F_PROP:
                         ASSERT(g_modem.user[id].data != NULL,"ASSERT: NULL Data Buffer for RD on ID %d\n",id);
@@ -381,7 +384,7 @@
     SERIAL_SEND(WC_FLOW_ALP_UNS,tmp, (u8)(lastp-tmp));
 }
 
-public void modem_write_file(u8 fid,void *data,u32 offset,u32 length, u8 id)
+public void modem_write_file(u8 fid, void *data, u32 offset, u32 length, u8 id)
 {
     ALLOC_BUFFER(u8,tmp,(ALP_ACTION_TAG_SIZE + ALP_ACTION_F_WR_DATA_SIZE_MAX(length)));
 
@@ -393,7 +396,7 @@
     DEALLOC_BUFFER(tmp);
 }
 
-public void modem_write_file_root(u8 fid,void *data,u32 offset,u32 length, u8* root_key, u8 id)
+public void modem_write_file_root(u8 fid, void *data, u32 offset, u32 length, u8* root_key, u8 id)
 {
     ALLOC_BUFFER(u8,tmp,(ALP_ACTION_TAG_SIZE + ALP_ACTION_PERM_REQ_SIZE(ALP_ACTION_F_WR_DATA_SIZE_MAX(length))));
 
@@ -463,7 +466,7 @@
     SERIAL_SEND(WC_FLOW_ALP_UNS,tmp, (u8)(p-tmp));
 }
 
-public void modem_notify_file(u8 fid,u32 offset,u32 length,u8 id)
+public void modem_notify_file(u8 fid, u32 offset, u32 length, u8 id)
 {
     u8 tmp[ALP_ACTION_TAG_SIZE + ALP_ACTION_F_TOUCH_SIZE_MAX];
     u8* p = tmp;
@@ -474,7 +477,7 @@
     SERIAL_SEND(WC_FLOW_ALP_UNS,tmp, (u8)(p-tmp));
 }
 
-public void modem_delete_file(u8 fid,u8 id)
+public void modem_delete_file(u8 fid, u8 id)
 {
     u8 tmp[ALP_ACTION_TAG_SIZE + ALP_ACTION_F_DELETE_SIZE];
     u8* p = tmp;
@@ -498,7 +501,7 @@
     DEALLOC_BUFFER(tmp);
 }
 
-public void modem_send_file_content(u8* itf, u8 itf_length, void *istatus, u8 fid,void *data,u32 offset,u32 length, u8 id)
+public void modem_send_file_content(u8* itf, u8 itf_length, void *istatus, u8 fid, void *data, u32 offset, u32 length, u8 id)
 {
     ALLOC_BUFFER(u8,tmp,ALP_ACTION_TAG_SIZE + ALP_ACTION_FORWARD_SIZE(itf_length) + ALP_ACTION_RSP_F_DATA_SIZE_MAX(length));
     u8* p = tmp;
@@ -507,6 +510,8 @@
     REF_PRINT("SEND FILE[%d] CONTENTS @%d %d Bytes (itf %d Bytes)\n",fid,offset,length,itf_length);
     ALP_ACTION_TAG(p,id,true);
     ALP_ACTION_FORWARD(p,itf,itf_length);
+    // NOP action to get istats on ACKs
+    ALP_ACTION_NOP(p,true);
     ALP_ACTION_RSP_F_DATA(p,fid,offset,length,data);
     SERIAL_SEND(WC_FLOW_ALP_UNS,tmp, (u8)(p-tmp));
     DEALLOC_BUFFER(tmp);
@@ -579,7 +584,7 @@
     SERIAL_SEND(WC_FLOW_ALP_RESP,tmp, (u8)(p-tmp));
 }
 
-public void modem_respond_read(u8 fid,void *data,u32 offset,u32 length, int id)
+public void modem_respond_read(u8 fid,void *data, u32 offset, u32 length, int id)
 {
     ALLOC_BUFFER(u8,tmp,ALP_ACTION_RSP_TAG_SIZE + ALP_ACTION_RSP_F_DATA_SIZE_MAX(length));
     u8* p = tmp;