al_sending.h File Reference

#include "Buffer.h"
#include "arq.h"
#include "al.h"
#include "rcpc.h"

Go to the source code of this file.

Classes
struct	al_sending_entity
Defines
#define	MAX_ARQ_BUFFER_SIZE   10
#define	MAX_AL_BUFFER_SIZE   100000
Functions
int	al_send_request (al_sending_entity *which, bytes *al_sdu)
int	al_send_byte (al_sending_entity *which, unsigned char b)
int	al_request (al_sending_entity *which)
int	al_requested_size (al_sending_entity *which)
int	al_buffer_level (al_sending_entity *which)
void	al_arq_request (al_sending_entity *which, arq_message *clone)
void	al_arq_received (al_sending_entity *which, arq_message *clone)
al_sending_entity *	new_al_sending_entity (channel_info *nfo)
void	make_forward_control (bytes *forward_control, unsigned int snf, unsigned int pt, unsigned int rn)
void	make_backward_control (bytes *backward_control, unsigned int snb, unsigned int sm)
int	inc_sn (al_sending_entity *which)
bytes *	get_al_pdu (al_sending_entity *which, int size)

---

Define Documentation

#define MAX_AL_BUFFER_SIZE   100000

Definition at line 12 of file al_sending.h. Referenced by new_al_receiving_entity(), and new_al_sending_entity().

#define MAX_ARQ_BUFFER_SIZE   10

Definition at line 11 of file al_sending.h. Referenced by new_al_sending_entity().

---

Function Documentation

void al_arq_received (  al_sending_entity *  which, arq_message *  clone )

Definition at line 150 of file al_sending.c. References bwrite(), and al_sending_entity::forward_arq. { bwrite(which->forward_arq,clone); }

void al_arq_request (  al_sending_entity *  which, arq_message *  clone )

Definition at line 140 of file al_sending.c. References al_sending_entity::backward_arq, and bwrite(). { bwrite(which->backward_arq,clone); }

int al_buffer_level (  al_sending_entity *  which  )

Definition at line 125 of file al_sending.c. References al_sending_entity::al_sdus, and blevel(). Referenced by code_video(), and multiplex(). { return blevel(which->al_sdus); /* returns number of BYTEs in buffer */ }

int al_request (  al_sending_entity *  which  )

Definition at line 56 of file al_sending.c. References al_sending_entity::al_sdus, blevel(), and al_sending_entity::forward_arq. Referenced by multiplex(). : * * 0 When the al_sending_entity has nothing to send. * -1 There is an ARQ waiting to be requested. * 1 New data available (no ARQ). */ { int val; if (blevel(which->forward_arq)) val = -1; else if (blevel(which->al_sdus)) val = 1; else val = 0; return val; }

int al_requested_size (  al_sending_entity *  which  )

Definition at line 78 of file al_sending.c. References al_sending_entity::backward_arq, blevel(), bpeek(), al_sending_entity::forward_arq, buf_rcpc::length, al_sending_entity::rcpcs, arq_message::sequence_number, and buf_rcpc::sequence_number. Referenced by multiplex(). { int i,val=0; buf_rcpc* grossie; arq_message* jon; if (blevel(which->forward_arq)) { /* * return size of al_pdu at top of buffer (plus forward/backward control) * Check all buf_rcpc's in rcpcs buffer and see which one's sequence * number matches the sequence number of the arq message on top of the * forward_arq buffer */ if ((jon = bpeek(which->forward_arq,0)) == NULL) { printf("al_requested_size() - ERROR forward arq buffer has entries that"); printf(" can't be read!\n"); } for(i=0;i<blevel(which->rcpcs);i++) { grossie = (buf_rcpc *) bpeek(which->rcpcs,i); if (grossie->sequence_number == jon->sequence_number) { val = grossie->length; break; } } /* add on for control fields */ val += 4; /* for forward control */ if (blevel(which->backward_arq)) val+=4; if (i == blevel(which->rcpcs)) { printf("al_requested_size() - ERROR trying to send arq for sequence"); printf(" number not in rcpcs buffer\n"); } } else val = 0; return val; }

int al_send_byte (  al_sending_entity *  which, unsigned char  b )

Definition at line 44 of file al_sending.c. References al_sending_entity::al_sdus, blevel(), bsize(), and bwrite(). Referenced by code_video(), and putbits(). { if (bsize(which->al_sdus) < (1+blevel(which->al_sdus))) return (0); bwrite(which->al_sdus, &b); return (1); }

int al_send_request (  al_sending_entity *  which, bytes *  al_sdu )

Definition at line 14 of file al_sending.c. References al_sending_entity::al_sdus, blevel(), bsize(), bwrite(), byte, get_byte(), and num_bytes(). Referenced by code_audio(). : the pdu does * not make it to the remote end in a whole format, ie. the size of it * may change. * * Returns 1 if succesful, 0 if unsuccesful (ie. buffer full) */ { int i; byte b; /* * check to make sure there's sufficient room in buffer for * incoming SDU. If not, fail. */ if ((bsize(which->al_sdus)) < num_bytes(al_sdu) + blevel(which->al_sdus)) return 0; /* otherwise put the bytes into the buffer and now free it */ for (i=0;i<num_bytes(al_sdu);i++) { b=get_byte(al_sdu,i); bwrite(which->al_sdus,&b); } return 1; }

bytes* get_al_pdu (  al_sending_entity *  which, int  size )

Definition at line 297 of file al_sending.c. References al_sending_entity::al_sdus, bread(), byte, crc16(), crc8(), new_bytes(), set_byte(), and al_sending_entity::type. Referenced by multiplex(). { int i; bytes *al_pdu=NULL; byte b; byte crc8val = 0; unsigned short crc16val = 0; al_pdu = new_bytes(size); if (which->type == AL1) { /* no crc */ for(i=0; i<size;i++) { bread(which->al_sdus, &b); set_byte(al_pdu, i, b); } } else if (which->type == AL2) { /* add a one byte crc */ for(i=0; i<size-1;i++) { bread(which->al_sdus, &b); crc8(&crc8val,b); set_byte(al_pdu, i, b); } set_byte(al_pdu, size - 1, crc8val); } else if (which->type == AL3) { /* add a two byte crc */ for(i=0; i<size-2;i++) { bread(which->al_sdus, &b); crc16(&crc16val,b); set_byte(al_pdu, i, b); } set_byte(al_pdu, size - 2, (byte) (crc16val >> 8)); set_byte(al_pdu, size - 1, (byte) crc16val & 0x00FF); } return al_pdu; }

int inc_sn (  al_sending_entity *  which  )

Definition at line 285 of file al_sending.c. References al_sending_entity::vs. { int returnval = which->vs; which->vs = (which->vs + 1) % 32; return returnval; }

void make_backward_control (  bytes *  backward_control, unsigned int  snb, unsigned int  sm )

Definition at line 236 of file al_sending.c. References bytes::block, byte, encode_bch(), error(), getbitint(), bytes::length, makecrc4(), and setbitint(). : * sequence number backward snb, * supervisory message sm, * and determines CRCb field. * * Returns in backward_control (which should be a pointer to an empty * bytes structure (ie not initialized)) * * (only used in old H.223/Annex A) */ { int i; unsigned int *field; byte *block; byte crc; field = (unsigned int *) malloc(sizeof(unsigned int)); *field = 0; if (field == NULL) error("make_backward_control","can't malloc field"); block = (byte *) calloc(4, sizeof(byte)); if (field == NULL) error("make_backward_control","can't malloc block"); /* set snb part of field */ for(i=6;i<=10;i++) setbitint(field,i,getbitint(snb,i+6)); /* set sm part of field */ for(i=11;i<=12;i++) setbitint(field,i,getbitint(sm,i+4)); /* figure out 4 bit CRC and append here */ crc = makecrc4(*field); printf("al_sending field %x crc %x\n",*field,crc); *field = *field | crc; printf("al_sending resulting field %x\n",*field); /* perform (31,11) BCH on it */ encode_bch(*field,block,2); backward_control->block = block; backward_control->length = 4; free(field); }

void make_forward_control (  bytes *  forward_control, unsigned int  snf, unsigned int  pt, unsigned int  rn )

Definition at line 194 of file al_sending.c. References bytes::block, byte, encode_bch(), error(), getbitint(), makecrc4(), and setbitint(). : * sequence number forward snf, * payload type pt, * retransmission number rn, * and determines CRCf field. * * Returns in forward_control (which will be a pointer to a bytes structure * of length 4. It should just be an empty bytes pointer when passed in) * * (only used in old H.223/Annex A) */ { int i; unsigned int *field; byte crc; field = (unsigned int *) malloc(sizeof(unsigned int)); *field = 0; if (field == NULL) error("make_forward_control","can't allocate field"); /* set the snf part of field */ for(i=6;i<=10;i++) setbitint(field,i,getbitint(snf,i+6)); /* set the pt part of field */ setbitint(field,11,pt); /* set the rn part of field */ setbitint(field,12,rn); /* figure out 4 bit CRC and append here */ crc = makecrc4(*field); *field = *field | crc; /* perform (31,11) BCH on it */ encode_bch(*field,forward_control->block,2); free(field); }

al_sending_entity* new_al_sending_entity (  channel_info *  nfo  )

Definition at line 162 of file al_sending.c. References al_sending_entity::al_sdus, channel_info::arq_type, al_sending_entity::arq_type, al_sending_entity::backward_arq, byte, channel_info::crc_bytes, al_sending_entity::crc_bytes, error(), al_sending_entity::forward_arq, channel_info::framed, al_sending_entity::framed, MAX_AL_BUFFER_SIZE, MAX_ARQ_BUFFER_SIZE, mkbuffer(), channel_info::rcpc_code, al_sending_entity::rcpc_code, channel_info::rcpc_rate, al_sending_entity::rcpc_rate, al_sending_entity::rcpcs, channel_info::seq_num, al_sending_entity::seq_num, channel_info::type, al_sending_entity::type, and al_sending_entity::vs. Referenced by finish_config(). { al_sending_entity *new_al; new_al = (al_sending_entity *) malloc(sizeof(al_sending_entity)); /* printf("New al sending entity has address %x\n",new_al); */ if (new_al == NULL) { error("new_al_sending_entity","can't malloc al_sending entity"); } else { new_al->al_sdus = mkbuffer(MAX_AL_BUFFER_SIZE,sizeof(byte)); new_al->rcpcs = mkbuffer(32,sizeof(buf_rcpc)); new_al->forward_arq = mkbuffer(MAX_ARQ_BUFFER_SIZE,sizeof(arq_message)); new_al->backward_arq = mkbuffer(MAX_ARQ_BUFFER_SIZE,sizeof(arq_message)); new_al->vs = 0; /* Copy parameters from channel_info *nfo */ new_al->type = nfo->type; new_al->framed = nfo->framed; new_al->seq_num = nfo->seq_num; new_al->rcpc_code = nfo->rcpc_code; new_al->rcpc_rate = nfo->rcpc_rate; new_al->arq_type = nfo->arq_type; new_al->crc_bytes = nfo->crc_bytes; } return new_al; }

---