aboutsummaryrefslogtreecommitdiffstats
path: root/lib/libdvben50221/asn_1.c
blob: 803eb605544f08eef832407fd147405e78126025 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
/*
	ASN.1 routines, implementation for libdvben50221
	an implementation for the High Level Common Interface

	Copyright (C) 2004, 2005 Manu Abraham <abraham.manu@gmail.com>
	Copyright (C) 2006 Andrew de Quincey (adq_dvb@lidskialf.net)

	This library is free software; you can redistribute it and/or modify
	it under the terms of the GNU Lesser General Public License as
	published by the Free Software Foundation; either version 2.1 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 Lesser General Public License for more details.

	You should have received a copy of the GNU Lesser General Public
	License along with this library; if not, write to the Free Software
	Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307 USA
*/

#include <stdio.h>
#include "asn_1.h"

int asn_1_decode(uint16_t * length, uint8_t * asn_1_array,
		 uint32_t asn_1_array_len)
{
	uint8_t length_field;

	if (asn_1_array_len < 1)
		return -1;
	length_field = asn_1_array[0];

	if (length_field < 0x80) {
		// there is only one word
		*length = length_field & 0x7f;
		return 1;
	} else if (length_field == 0x81) {
		if (asn_1_array_len < 2)
			return -1;

		*length = asn_1_array[1];
		return 2;
	} else if (length_field == 0x82) {
		if (asn_1_array_len < 3)
			return -1;

		*length = (asn_1_array[1] << 8) | asn_1_array[2];
		return 3;
	}

	return -1;
}

int asn_1_encode(uint16_t length, uint8_t * asn_1_array,
		 uint32_t asn_1_array_len)
{
	if (length < 0x80) {
		if (asn_1_array_len < 1)
			return -1;

		asn_1_array[0] = length & 0x7f;
		return 1;
	} else if (length < 0x100) {
		if (asn_1_array_len < 2)
			return -1;

		asn_1_array[0] = 0x81;
		asn_1_array[1] = length;
		return 2;
	} else {
		if (asn_1_array_len < 3)
			return -1;

		asn_1_array[0] = 0x82;
		asn_1_array[1] = length >> 8;
		asn_1_array[2] = length;
		return 3;
	}

	// never reached
}
pan>); // done return datetime; } void en50221_app_datetime_destroy(struct en50221_app_datetime *datetime) { pthread_mutex_destroy(&datetime->lock); free(datetime); } void en50221_app_datetime_register_enquiry_callback(struct en50221_app_datetime *datetime, en50221_app_datetime_enquiry_callback callback, void *arg) { pthread_mutex_lock(&datetime->lock); datetime->callback = callback; datetime->callback_arg = arg; pthread_mutex_unlock(&datetime->lock); } int en50221_app_datetime_send(struct en50221_app_datetime *datetime, uint16_t session_number, time_t utc_time, int time_offset) { uint8_t data[11]; int data_length; data[0] = (TAG_DATE_TIME >> 16) & 0xFF; data[1] = (TAG_DATE_TIME >> 8) & 0xFF; data[2] = TAG_DATE_TIME & 0xFF; if (time_offset != -1) { data[3] = 7; unixtime_to_dvbdate(utc_time, data + 4); data[9] = time_offset >> 8; data[10] = time_offset; data_length = 11; } else { data[3] = 5; unixtime_to_dvbdate(utc_time, data + 4); data_length = 9; } return datetime->funcs->send_data(datetime->funcs->arg, session_number, data, data_length); } int en50221_app_datetime_message(struct en50221_app_datetime *datetime, uint8_t slot_id, uint16_t session_number, uint32_t resource_id, uint8_t * data, uint32_t data_length) { (void) resource_id; // get the tag if (data_length < 3) { print(LOG_LEVEL, ERROR, 1, "Received short data\n"); return -1; } uint32_t tag = (data[0] << 16) | (data[1] << 8) | data[2]; switch (tag) { case TAG_DATE_TIME_ENQUIRY: return en50221_app_datetime_parse_enquiry(datetime, slot_id, session_number, data + 3, data_length - 3); } print(LOG_LEVEL, ERROR, 1, "Received unexpected tag %x\n", tag); return -1; } static int en50221_app_datetime_parse_enquiry(struct en50221_app_datetime *datetime, uint8_t slot_id, uint16_t session_number, uint8_t * data, uint32_t data_length) { // validate data if (data_length != 2) { print(LOG_LEVEL, ERROR, 1, "Received short data\n"); return -1; } if (data[0] != 1) { print(LOG_LEVEL, ERROR, 1, "Received short data\n"); return -1; } uint8_t response_interval = data[1]; // tell the app pthread_mutex_lock(&datetime->lock); en50221_app_datetime_enquiry_callback cb = datetime->callback; void *cb_arg = datetime->callback_arg; pthread_mutex_unlock(&datetime->lock); if (cb) { return cb(cb_arg, slot_id, session_number, response_interval); } return 0; }