Diff: afLib/afLib.h

Revision:

0:846e2321c637

diff -r 000000000000 -r 846e2321c637 afLib/afLib.h
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/afLib/afLib.h	Fri Apr 13 04:19:23 2018 +0000
@@ -0,0 +1,173 @@
+/**
+ * Copyright 2015 Afero, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef AFLIB_H__
+#define AFLIB_H__
+
+#include "mbed.h"
+#include "iafLib.h"
+#include "SPI.h"
+#include "Command.h"
+#include "StatusCommand.h"
+#include "afSPI.h"
+// #include "WatchDogWrapper.hpp"
+
+#define STATE_IDLE                          0
+#define STATE_STATUS_SYNC                   1
+#define STATE_STATUS_ACK                    3
+#define STATE_SEND_BYTES                    4
+#define STATE_RECV_BYTES                    5
+#define STATE_CMD_COMPLETE                  6
+
+#define SPI_FRAME_LEN                       16
+
+#define REQUEST_QUEUE_SIZE                  10
+
+typedef struct {
+    uint8_t     messageType;
+    uint16_t    attrId;
+    uint8_t     requestId;
+    uint16_t    valueLen;
+    uint8_t     *p_value;
+} request_t;
+
+class afLib : public iafLib {
+public:
+    afLib(PinName mcuInterrupt, isr isrWrapper,
+          onAttributeSet attrSet, onAttributeSetComplete attrSetComplete, afSPI *theSPI);
+//wsugi 20161128
+    ~afLib();
+//wsugi 20161128
+
+// motoo tanaka 20171116
+    virtual int getRequestId(void) ;
+// motoo tanaka 20171116
+// motoo tanaka 20171229
+    virtual void disable_irq(void) { fco.disable_irq() ; }
+    virtual void enable_irq(void) { fco.enable_irq() ; }
+    
+    virtual void loop(void);
+
+    virtual int getAttribute(const uint16_t attrId);
+
+    virtual int setAttributeBool(const uint16_t attrId, const bool value);
+
+    virtual int setAttribute8(const uint16_t attrId, const int8_t value);
+
+    virtual int setAttribute16(const uint16_t attrId, const int16_t value);
+
+    virtual int setAttribute32(const uint16_t attrId, const int32_t value);
+
+    virtual int setAttribute64(const uint16_t attrId, const int64_t value);
+
+    virtual int setAttribute(const uint16_t attrId, const string &value);
+
+    virtual int setAttribute(const uint16_t attrId, const uint16_t valueLen, const char *value);
+
+    virtual int setAttribute(const uint16_t attrId, const uint16_t valueLen, const uint8_t *value);
+
+    virtual int setAttributeComplete(uint8_t requestId, const uint16_t attrId, const uint16_t valueLen, const uint8_t *value);
+
+    virtual bool isIdle();
+
+    virtual void mcuISR();
+
+private:
+    Timeout deathWish;
+    Timer *checkLastSync;
+    static void kick_the_bucket();
+    afSPI *_theSPI;
+
+    //SPISettings _spiSettings;
+    volatile int _interrupts_pending;
+    int _state;
+    uint16_t _bytesToSend;
+    uint16_t _bytesToRecv;
+    uint8_t _requestId;
+    uint16_t _outstandingSetGetAttrId;
+
+    // Application Callbacks.
+    onAttributeSet _onAttrSet;
+    onAttributeSetComplete _onAttrSetComplete;
+
+    Command *_writeCmd;
+    uint16_t _writeBufferLen;
+    uint8_t *_writeBuffer;
+
+    Command *_readCmd;
+    uint16_t _readBufferLen;
+    uint8_t *_readBuffer;
+
+    int _writeCmdOffset;
+    int _readCmdOffset;
+
+    StatusCommand *_txStatus;
+    StatusCommand *_rxStatus;
+
+    request_t _request;
+    request_t _requestQueue[REQUEST_QUEUE_SIZE];
+
+#ifdef ATTRIBUTE_CLI
+    int parseCommand(const char *cmd);
+#endif
+
+    void sendCommand(void);
+
+    void runStateMachine(void);
+
+    void printState(int state);
+
+    //void beginSPI();
+
+    //void endSPI();
+
+    int exchangeStatus(StatusCommand *tx, StatusCommand *rx);
+
+    bool inSync(StatusCommand *tx, StatusCommand *rx);
+
+    int writeStatus(StatusCommand *c);
+
+    void sendBytes();
+
+    void recvBytes();
+
+    void dumpBytes(char *label, int len, uint8_t *bytes);
+
+    void updateIntsPending(int amount);
+
+    void queueInit(void);
+
+    int queuePut(uint8_t messageType, uint8_t requestId, const uint16_t attributeId, uint16_t valueLen, const uint8_t *value);
+
+    int queueGet(uint8_t *messageType, uint8_t *requestId, uint16_t *attributeId, uint16_t *valueLen, uint8_t **value);
+
+    int doGetAttribute(uint8_t requestId, uint16_t attrId);
+
+    int doSetAttribute(uint8_t requestId, uint16_t attrId, uint16_t valueLen, uint8_t *value);
+
+    int doUpdateAttribute(uint8_t requestId, uint16_t attrId, uint8_t status, uint16_t valueLen, uint8_t *value);
+
+    void onStateIdle(void);
+    void onStateSync(void);
+    void onStateAck(void);
+    void onStateSendBytes(void);
+    void onStateRecvBytes(void);
+    void onStateCmdComplete(void);
+    void printTransaction(uint8_t *rbytes, int len);
+    InterruptIn fco;
+};
+
+#endif // AFLIB_H__
\ No newline at end of file