Steve Karg
c3a4c229fe
* Enable lcov coverage in unit testing via cmake. * fix pipeline build error * add compile options for unit test to silence some warnings * remove all BAC_TEST unit tests in src/bacnet/ folder. They are now in test/bacnet/ folders using ztest. * removed key.c - only used for unit test. * produce XML test result output for parsing * produce junit XML test result output * change lint workflow to quality * update readme badge for quality results Co-authored-by: Steve Karg <skarg@users.sourceforge.net>
314 lines
11 KiB
C
314 lines
11 KiB
C
/*####COPYRIGHTBEGIN####
|
|
-------------------------------------------
|
|
Copyright (C) 2005 Steve Karg
|
|
|
|
This program is free software; you can redistribute it and/or
|
|
modify it under the terms of the GNU General Public License
|
|
as published by the Free Software Foundation; either version 2
|
|
of the License, or (at your option) any later version.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; if not, write to:
|
|
The Free Software Foundation, Inc.
|
|
59 Temple Place - Suite 330
|
|
Boston, MA 02111-1307, USA.
|
|
|
|
As a special exception, if other files instantiate templates or
|
|
use macros or inline functions from this file, or you compile
|
|
this file and link it with other works to produce a work based
|
|
on this file, this file does not by itself cause the resulting
|
|
work to be covered by the GNU General Public License. However
|
|
the source code for this file must still be made available in
|
|
accordance with section (3) of the GNU General Public License.
|
|
|
|
This exception does not invalidate any other reasons why a work
|
|
based on this file might be covered by the GNU General Public
|
|
License.
|
|
-------------------------------------------
|
|
####COPYRIGHTEND####*/
|
|
#include <stdint.h>
|
|
#include "bacnet/bacenum.h"
|
|
#include "bacnet/bacdcode.h"
|
|
#include "bacnet/bacdef.h"
|
|
#include "bacnet/awf.h"
|
|
|
|
/** @file awf.c Atomic Write File */
|
|
|
|
/* encode service */
|
|
int awf_encode_apdu(
|
|
uint8_t *apdu, uint8_t invoke_id, BACNET_ATOMIC_WRITE_FILE_DATA *data)
|
|
{
|
|
int apdu_len = 0; /* total length of the apdu, return value */
|
|
uint32_t i = 0;
|
|
|
|
if (apdu) {
|
|
apdu[0] = PDU_TYPE_CONFIRMED_SERVICE_REQUEST;
|
|
apdu[1] = encode_max_segs_max_apdu(0, MAX_APDU);
|
|
apdu[2] = invoke_id;
|
|
apdu[3] = SERVICE_CONFIRMED_ATOMIC_WRITE_FILE; /* service choice */
|
|
apdu_len = 4;
|
|
apdu_len += encode_application_object_id(
|
|
&apdu[apdu_len], data->object_type, data->object_instance);
|
|
switch (data->access) {
|
|
case FILE_STREAM_ACCESS:
|
|
apdu_len += encode_opening_tag(&apdu[apdu_len], 0);
|
|
apdu_len += encode_application_signed(
|
|
&apdu[apdu_len], data->type.stream.fileStartPosition);
|
|
apdu_len += encode_application_octet_string(
|
|
&apdu[apdu_len], &data->fileData[0]);
|
|
apdu_len += encode_closing_tag(&apdu[apdu_len], 0);
|
|
break;
|
|
case FILE_RECORD_ACCESS:
|
|
apdu_len += encode_opening_tag(&apdu[apdu_len], 1);
|
|
apdu_len += encode_application_signed(
|
|
&apdu[apdu_len], data->type.record.fileStartRecord);
|
|
apdu_len += encode_application_unsigned(
|
|
&apdu[apdu_len], data->type.record.returnedRecordCount);
|
|
for (i = 0; i < data->type.record.returnedRecordCount; i++) {
|
|
apdu_len += encode_application_octet_string(
|
|
&apdu[apdu_len], &data->fileData[i]);
|
|
}
|
|
apdu_len += encode_closing_tag(&apdu[apdu_len], 1);
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
return apdu_len;
|
|
}
|
|
|
|
/* decode the service request only */
|
|
int awf_decode_service_request(
|
|
uint8_t *apdu, unsigned apdu_len_max, BACNET_ATOMIC_WRITE_FILE_DATA *data)
|
|
{
|
|
int len = 0;
|
|
int apdu_len = BACNET_STATUS_ERROR;
|
|
BACNET_OBJECT_TYPE object_type = OBJECT_NONE;
|
|
uint32_t object_instance = 0;
|
|
BACNET_UNSIGNED_INTEGER unsigned_value = 0;
|
|
uint32_t i = 0;
|
|
|
|
/* check for value pointers */
|
|
if ((apdu_len_max == 0) || (!data)) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
len = bacnet_object_id_application_decode(
|
|
&apdu[0], apdu_len_max, &object_type, &object_instance);
|
|
if (len <= 0) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
data->object_type = object_type;
|
|
data->object_instance = object_instance;
|
|
apdu_len = len;
|
|
if (apdu_len < apdu_len_max) {
|
|
if (decode_is_opening_tag_number(&apdu[apdu_len], 0)) {
|
|
data->access = FILE_STREAM_ACCESS;
|
|
/* a tag number of 0 is not extended so only one octet */
|
|
apdu_len++;
|
|
/* fileStartPosition */
|
|
if (apdu_len >= apdu_len_max) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
len = bacnet_signed_application_decode(&apdu[apdu_len],
|
|
apdu_len_max - apdu_len, &data->type.stream.fileStartPosition);
|
|
if (len <= 0) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
apdu_len += len;
|
|
/* fileData */
|
|
if (apdu_len >= apdu_len_max) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
len = bacnet_octet_string_application_decode(
|
|
&apdu[apdu_len], apdu_len_max, &data->fileData[0]);
|
|
if (len <= 0) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
apdu_len += len;
|
|
/* closing tag */
|
|
if (apdu_len >= apdu_len_max) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
if (!decode_is_closing_tag_number(&apdu[apdu_len], 0)) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
/* a tag number of 0 is not extended so only one octet */
|
|
apdu_len++;
|
|
} else if (decode_is_opening_tag_number(&apdu[apdu_len], 1)) {
|
|
data->access = FILE_RECORD_ACCESS;
|
|
/* a tag number of 0 is not extended so only one octet */
|
|
apdu_len++;
|
|
/* fileStartRecord */
|
|
if (apdu_len >= apdu_len_max) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
len = bacnet_signed_application_decode(&apdu[apdu_len],
|
|
apdu_len_max - apdu_len, &data->type.record.fileStartRecord);
|
|
if (len <= 0) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
apdu_len += len;
|
|
/* returnedRecordCount */
|
|
if (apdu_len >= apdu_len_max) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
len = bacnet_unsigned_application_decode(
|
|
&apdu[apdu_len], apdu_len_max, &unsigned_value);
|
|
if (len <= 0) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
data->type.record.returnedRecordCount = unsigned_value;
|
|
apdu_len += len;
|
|
if (apdu_len >= apdu_len_max) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
/* fileData */
|
|
for (i = 0; i < data->type.record.returnedRecordCount; i++) {
|
|
if (i < BACNET_WRITE_FILE_RECORD_COUNT) {
|
|
len = bacnet_octet_string_application_decode(
|
|
&apdu[apdu_len], apdu_len_max, &data->fileData[i]);
|
|
if (len <= 0) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
apdu_len += len;
|
|
/* closing tag or another record */
|
|
if (apdu_len >= apdu_len_max) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
} else {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
}
|
|
if (!decode_is_closing_tag_number(&apdu[apdu_len], 1)) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
/* tag number 1 is not extended so only one octet */
|
|
apdu_len++;
|
|
} else {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
}
|
|
|
|
return apdu_len;
|
|
}
|
|
|
|
int awf_decode_apdu(uint8_t *apdu,
|
|
unsigned apdu_len,
|
|
uint8_t *invoke_id,
|
|
BACNET_ATOMIC_WRITE_FILE_DATA *data)
|
|
{
|
|
int len = 0;
|
|
unsigned offset = 0;
|
|
|
|
if (!apdu) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
/* optional checking - most likely was already done prior to this call */
|
|
if (apdu[0] != PDU_TYPE_CONFIRMED_SERVICE_REQUEST) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
/* apdu[1] = encode_max_segs_max_apdu(0, MAX_APDU); */
|
|
*invoke_id = apdu[2]; /* invoke id - filled in by net layer */
|
|
if (apdu[3] != SERVICE_CONFIRMED_ATOMIC_WRITE_FILE) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
offset = 4;
|
|
|
|
if (apdu_len > offset) {
|
|
len =
|
|
awf_decode_service_request(&apdu[offset], apdu_len - offset, data);
|
|
}
|
|
|
|
return len;
|
|
}
|
|
|
|
int awf_ack_encode_apdu(
|
|
uint8_t *apdu, uint8_t invoke_id, BACNET_ATOMIC_WRITE_FILE_DATA *data)
|
|
{
|
|
int apdu_len = 0; /* total length of the apdu, return value */
|
|
|
|
if (apdu) {
|
|
apdu[0] = PDU_TYPE_COMPLEX_ACK;
|
|
apdu[1] = invoke_id;
|
|
apdu[2] = SERVICE_CONFIRMED_ATOMIC_WRITE_FILE; /* service choice */
|
|
apdu_len = 3;
|
|
switch (data->access) {
|
|
case FILE_STREAM_ACCESS:
|
|
apdu_len += encode_context_signed(
|
|
&apdu[apdu_len], 0, data->type.stream.fileStartPosition);
|
|
break;
|
|
case FILE_RECORD_ACCESS:
|
|
apdu_len += encode_context_signed(
|
|
&apdu[apdu_len], 1, data->type.record.fileStartRecord);
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
return apdu_len;
|
|
}
|
|
|
|
/* decode the service request only */
|
|
int awf_ack_decode_service_request(
|
|
uint8_t *apdu, unsigned apdu_len, BACNET_ATOMIC_WRITE_FILE_DATA *data)
|
|
{
|
|
int len = 0;
|
|
uint8_t tag_number = 0;
|
|
uint32_t len_value_type = 0;
|
|
|
|
/* check for value pointers */
|
|
if (apdu_len && data) {
|
|
len =
|
|
decode_tag_number_and_value(&apdu[0], &tag_number, &len_value_type);
|
|
if (tag_number == 0) {
|
|
data->access = FILE_STREAM_ACCESS;
|
|
len += decode_signed(&apdu[len], len_value_type,
|
|
&data->type.stream.fileStartPosition);
|
|
} else if (tag_number == 1) {
|
|
data->access = FILE_RECORD_ACCESS;
|
|
len += decode_signed(
|
|
&apdu[len], len_value_type, &data->type.record.fileStartRecord);
|
|
} else {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
}
|
|
|
|
return len;
|
|
}
|
|
|
|
int awf_ack_decode_apdu(uint8_t *apdu,
|
|
unsigned apdu_len,
|
|
uint8_t *invoke_id,
|
|
BACNET_ATOMIC_WRITE_FILE_DATA *data)
|
|
{
|
|
int len = 0;
|
|
unsigned offset = 0;
|
|
|
|
if (!apdu) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
/* optional checking - most likely was already done prior to this call */
|
|
if (apdu[0] != PDU_TYPE_COMPLEX_ACK) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
*invoke_id = apdu[1]; /* invoke id - filled in by net layer */
|
|
if (apdu[2] != SERVICE_CONFIRMED_ATOMIC_WRITE_FILE) {
|
|
return BACNET_STATUS_ERROR;
|
|
}
|
|
offset = 3;
|
|
|
|
if (apdu_len > offset) {
|
|
len = awf_ack_decode_service_request(
|
|
&apdu[offset], apdu_len - offset, data);
|
|
}
|
|
|
|
return len;
|
|
}
|