123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172 |
- #ifndef WRITEPIB_SOURCE
- #define WRITEPIB_SOURCE
- #include <stdint.h>
- #include <unistd.h>
- #include <string.h>
- #include <memory.h>
- #include "../tools/memory.h"
- #include "../tools/error.h"
- #include "../tools/files.h"
- #include "../plc/plc.h"
- signed WritePIB (struct plc * plc)
- {
- struct channel * channel = (struct channel *)(plc->channel);
- struct message * message = (struct message *)(plc->message);
- #ifndef __GNUC__
- #pragma pack (push,1)
- #endif
- struct __packed vs_wr_mod_request
- {
- struct ethernet_hdr ethernet;
- struct qualcomm_hdr qualcomm;
- uint8_t MODULEID;
- uint8_t RESERVED;
- uint16_t MLENGTH;
- uint32_t MOFFSET;
- uint32_t MCHKSUM;
- uint8_t MBUFFER [PLC_RECORD_SIZE];
- }
- * request = (struct vs_wr_mod_request *) (message);
- struct __packed vs_wr_mod_confirm
- {
- struct ethernet_hdr ethernet;
- struct qualcomm_hdr qualcomm;
- uint8_t MSTATUS;
- uint8_t MODULEID;
- uint8_t RESERVED;
- uint16_t MLENGTH;
- uint32_t MOFFSET;
- }
- * confirm = (struct vs_wr_mod_confirm *) (message);
- #ifndef __GNUC__
- #pragma pack (pop)
- #endif
- uint16_t length = PLC_RECORD_SIZE;
- uint32_t extent = lseek (plc->PIB.file, 0, SEEK_END);
- uint32_t offset = lseek (plc->PIB.file, 0, SEEK_SET);
- Request (plc, "Write %s to scratch", plc->PIB.name);
- while (extent)
- {
- memset (message, 0, sizeof (* message));
- EthernetHeader (&request->ethernet, channel->peer, channel->host, channel->type);
- QualcommHeader (&request->qualcomm, 0, (VS_WR_MOD | MMTYPE_REQ));
- if (length > extent)
- {
- length = extent;
- }
- if (read (plc->PIB.file, request->MBUFFER, length) != length)
- {
- error (1, errno, FILE_CANTREAD, plc->PIB.name);
- }
- request->MODULEID = VS_MODULE_PIB;
- request->RESERVED = 0;
- request->MLENGTH = HTOLE16 (length);
- request->MOFFSET = HTOLE32 (offset);
- request->MCHKSUM = checksum32 (request->MBUFFER, length, 0);
- plc->packetsize = sizeof (* request);
- if (SendMME (plc) <= 0)
- {
- error (PLC_EXIT (plc), errno, CHANNEL_CANTSEND);
- return (-1);
- }
- if (ReadMME (plc, 0, (VS_WR_MOD | MMTYPE_CNF)) <= 0)
- {
- error (PLC_EXIT (plc), errno, CHANNEL_CANTREAD);
- return (-1);
- }
- if (confirm->MSTATUS)
- {
- Failure (plc, PLC_WONTDOIT);
- return (-1);
- }
- if (LE16TOH (confirm->MLENGTH) != length)
- {
- error (PLC_EXIT (plc), 0, PLC_ERR_LENGTH);
- length = PLC_RECORD_SIZE;
- offset = 0;
- continue;
- }
- if (LE32TOH (confirm->MOFFSET) != offset)
- {
- error (PLC_EXIT (plc), 0, PLC_ERR_OFFSET);
- length = PLC_RECORD_SIZE;
- offset = 0;
- continue;
- }
- extent -= length;
- offset += length;
- }
- return (0);
- }
- #endif
|