Mediastreamer2 VoIP 엔진 탐색. 11 부

글의 소재는 제 글에서 가져왔습니다. 젠 채널.

데이터 이동 메커니즘

• 데이터 블록 dblk_t
• 메시지 mblk_t
• 메시지 mblk_t 작업을 위한 함수
• 대기열 queue_t
• 대기열 작업을 위한 함수 queue_t
• 필터 연결
• 데이터 처리 그래프의 신호 지점
• 티커의 활동 비하인드 스토리
• 버퍼라이저(MSBufferizer)
• MSBufferizer 작업을 위한 함수

과거에 기사 우리는 자체 필터를 개발했습니다. 이 문서에서는 미디어 스트리머 필터 간에 데이터를 이동하는 내부 메커니즘에 중점을 둘 것입니다. 이렇게 하면 나중에 더 적은 노력으로 정교한 필터를 작성할 수 있습니다.

데이터 이동 메커니즘

미디어 스트리머의 데이터 이동은 구조에 설명된 대기열을 사용하여 수행됩니다. queue_t. 다음과 같은 메시지 문자열 mblk_t, 그 자체에는 신호 데이터가 포함되어 있지 않으며 이전, 다음 메시지 및 데이터 블록에만 연결됩니다. 또한, 단일 링크된 메시지 목록을 구성할 수 있는 동일한 유형의 메시지에 대한 링크 필드도 있다는 점을 특히 강조하고 싶습니다. 우리는 그러한 목록으로 통합된 메시지 그룹을 튜플이라고 부를 것입니다. 따라서 대기열의 모든 요소는 단일 메시지가 될 수 있습니다. mblk_t, 아마도 메시지 튜플의 헤드일 수도 있습니다. mblk_t. 각 튜플 메시지에는 자체 와드 데이터 블록이 있을 수 있습니다. 튜플이 필요한 이유는 잠시 후에 논의하겠습니다.

위에서 언급했듯이 메시지 자체에는 데이터 블록이 포함되어 있지 않으며 대신 블록이 저장된 메모리 영역에 대한 포인터만 포함되어 있습니다. 이 부분에서 미디어 스트리머 작업의 전체적인 그림은 만화 "몬스터 주식회사"에 나오는 문 창고를 연상시킵니다. 여기서 문(데이터 링크 - 방)은 머리 위 컨베이어를 따라 미친 속도로 움직이고 방 자체는 미친 속도로 움직입니다. 움직이지 마십시오.

이제 계층 구조를 따라 아래에서 위로 이동하면서 미디어 스트리머의 데이터 전송 메커니즘에 나열된 엔터티를 자세히 살펴보겠습니다.

데이터 블록 dblk_t

데이터 블록은 헤더와 데이터 버퍼로 구성됩니다. 헤더는 다음 구조로 설명됩니다.

typedef struct datab
{
unsigned char *db_base; // Указатель на начало буфер данных.
unsigned char *db_lim;  // Указатель на конец буфер данных.
void (*db_freefn)(void*); // Функция освобождения памяти при удалении блока.
int db_ref; // Счетчик ссылок.
} dblk_t;

구조체의 필드에는 버퍼의 시작, 버퍼의 끝 및 데이터 버퍼를 삭제하는 함수에 대한 포인터가 포함되어 있습니다. 헤더의 마지막 요소 db_ref — 참조 카운터, 0에 도달하면 메모리에서 이 블록을 삭제하라는 신호 역할을 합니다. 함수에 의해 데이터 블록이 생성된 경우 datab_alloc() , 데이터 버퍼는 헤더 바로 뒤에 메모리에 배치됩니다. 다른 모든 경우에는 버퍼가 별도로 어딘가에 위치할 수 있습니다. 데이터 버퍼에는 필터로 처리하려는 신호 샘플이나 기타 데이터가 포함됩니다.

데이터 블록의 새 인스턴스는 다음 함수를 사용하여 생성됩니다.

dblk_t *datab_alloc(int size);

입력 매개변수로 블록이 저장할 데이터의 크기가 제공됩니다. 할당된 메모리의 시작 부분에 헤더(구조)를 배치하기 위해 더 많은 메모리가 할당됩니다. 데이터베이스. 그러나 다른 기능을 사용할 때 항상 이런 현상이 발생하는 것은 아니며, 어떤 경우에는 데이터 버퍼가 데이터 블록 헤더와 별도로 위치할 수 있습니다. 구조를 생성할 때 해당 필드가 다음과 같이 구성됩니다. db_base 데이터 영역의 시작 부분을 가리킨다. db_lim 끝까지. 링크 수 db_ref 1로 설정되어 있습니다. 데이터 지우기 기능 포인터가 0으로 설정됩니다.

메시지 mblk_t

명시된 바와 같이 대기열 요소는 유형입니다. mblk_t, 이는 다음과 같이 정의됩니다:

typedef struct msgb
{
  struct msgb *b_prev;   // Указатель на предыдущий элемент списка.
  struct msgb *b_next;   // Указатель на следующий элемент списка.
  struct msgb *b_cont;   // Указатель для подклейки к сообщению других сообщений, для создания кортежа сообщений.
  struct datab *b_datap; // Указатель на структуру блока данных.
  unsigned char *b_rptr; // Указатель на начало области данных для чтения данных буфера b_datap.
  unsigned char *b_wptr; // Указатель на начало области данных для записи данных буфера b_datap.
  uint32_t reserved1;    // Зарезервированное поле1, медиастример помещает туда служебную информацию. 
  uint32_t reserved2;    // Зарезервированное поле2, медиастример помещает туда служебную информацию.
  #if defined(ORTP_TIMESTAMP)
  struct timeval timestamp;
  #endif
  ortp_recv_addr_t recv_addr;
} mblk_t;

구조 mblk_t 시작 부분에 포인터가 포함되어 있습니다. b_prev, b_next, 이중 연결 목록(큐인 큐)을 구성하는 데 필요합니다. queue_t).

그런 다음 포인터가 나타납니다. b_cont, 메시지가 튜플의 일부인 경우에만 사용됩니다. 튜플의 마지막 메시지의 경우 이 포인터는 null로 유지됩니다.

다음으로 데이터 블록에 대한 포인터를 봅니다. b_datap, 메시지가 존재합니다. 그 뒤에는 블록 데이터 버퍼 내부 영역에 대한 포인터가 옵니다. 필드 b_rptr 버퍼에서 데이터를 읽을 위치를 지정합니다. 필드 b_wptr 버퍼에 대한 쓰기가 수행될 위치를 나타냅니다.

나머지 필드는 서비스 성격을 가지며 데이터 전송 메커니즘의 작동과 관련이 없습니다.

아래에는 이름이 포함된 단일 메시지가 있습니다. m1 및 데이터 블록 d1.

다음 그림은 세 개의 메시지로 구성된 튜플을 보여줍니다. m1, m1_1, m1_2.

메시징 기능 mblk_t

새로운 메시지 mblk_t 함수에 의해 생성됨:

mblk_t *allocb(int size, int pri); 

그녀는 기억 속에 새로운 메시지를 남겼다 mblk_t 지정된 크기의 데이터 블록 포함 크기, 두 번째 인수 - pri 이 버전의 라이브러리에서는 사용되지 않습니다. 0으로 유지되어야 합니다. 함수가 작동하는 동안 새 메시지의 구조를 위해 메모리가 할당되고 함수가 호출됩니다. mblk_init(), 생성된 구조 인스턴스의 모든 필드를 재설정한 다음 위에서 언급한 내용을 사용하여 datab_alloc(), 데이터 버퍼를 생성합니다. 그런 다음 구조의 필드가 구성됩니다.

mp->b_datap=datab;
mp->b_rptr=mp->b_wptr=datab->db_base;
mp->b_next=mp->b_prev=mp->b_cont=NULL;

출력에서는 초기화된 필드와 빈 데이터 버퍼가 포함된 새 메시지를 받습니다. 메시지에 데이터를 추가하려면 해당 데이터를 데이터 블록 버퍼에 복사해야 합니다.

memcpy(msg->b_rptr, data, size);

어디에서 데이터 데이터 소스에 대한 포인터이고, 크기 - 크기.
그런 다음 쓰기 지점에 대한 포인터를 업데이트하여 버퍼의 여유 영역 시작 부분을 다시 가리키도록 해야 합니다.

msg->b_wptr = msg->b_wptr + size

복사하지 않고 기존 버퍼에서 메시지를 생성해야 하는 경우 다음 기능을 사용하세요.

mblk_t *esballoc(uint8_t *buf, int size, int pri, void (*freefn)(void*)); 

함수는 메시지와 데이터 블록의 구조를 생성한 후 주소의 데이터에 대한 포인터를 구성합니다. buf. 저것들. 이 경우 데이터 버퍼는 함수를 사용하여 데이터 블록을 생성할 때처럼 데이터 블록의 헤더 필드 뒤에 위치하지 않습니다. datab_alloc(). 함수에 전달된 데이터가 있는 버퍼는 원래 위치에 유지되지만 포인터의 도움으로 새로 생성된 데이터 블록의 헤더에 연결되어 그에 따라 메시지에 연결됩니다.

하나의 메시지에 mblk_t 여러 데이터 블록을 순차적으로 연결할 수 있습니다. 이는 다음 함수에 의해 수행됩니다.

mblk_t * appendb(mblk_t *mp, const char *data, int size, bool_t pad); 

mp — 다른 데이터 블록이 추가될 메시지;
데이터 — 블록에 대한 포인터, 그 복사본이 메시지에 추가됩니다.
크기 - 데이터 크기
인주 — 할당된 메모리의 크기가 4바이트 경계를 따라 정렬되어야 함을 나타내는 플래그(패딩은 XNUMX으로 수행됨)

기존 메시지 데이터 버퍼에 충분한 공간이 있으면 새 데이터가 이미 있는 데이터 뒤에 붙여넣어집니다. 메시지 데이터 버퍼에 여유 공간이 적은 경우 크기, 충분한 버퍼 크기를 가진 새 메시지가 생성되고 데이터가 해당 버퍼에 복사됩니다. 포인터를 사용하여 원본 메시지에 연결된 새 메시지입니다. b_cont. 이 경우 메시지는 튜플로 변합니다.

튜플에 다른 데이터 블록을 추가해야 하는 경우 다음 함수를 사용해야 합니다.

void msgappend(mblk_t *mp, const char *data, int size, bool_t pad);

그녀는 튜플에서 마지막 메시지를 찾을 것입니다(그는 b_cont null이 됨) 이 메시지에 대한 함수를 호출합니다. 부록().

다음 함수를 사용하여 메시지나 튜플의 데이터 크기를 확인할 수 있습니다.

int msgdsize(const mblk_t *mp);

튜플의 모든 메시지를 반복하고 해당 메시지의 데이터 버퍼에 있는 총 데이터 양을 반환합니다. 각 메시지에 대해 데이터 양은 다음과 같이 계산됩니다.

 mp->b_wptr - mp->b_rptr

두 개의 튜플을 결합하려면 다음 함수를 사용하세요.

mblk_t *concatb(mblk_t *mp, mblk_t *newm);

그녀는 튜플을 추가합니다 뉴엠 튜플의 꼬리까지 mp 그리고 결과 튜플의 마지막 메시지에 대한 포인터를 반환합니다.

필요한 경우 튜플은 단일 데이터 블록이 포함된 하나의 메시지로 바뀔 수 있습니다. 이는 다음 함수에 의해 수행됩니다.

void msgpullup(mblk_t *mp,int len);

인수인 경우 렌 -1이면 할당된 버퍼의 크기가 자동으로 결정됩니다. 만약에 렌 양수이면 이 크기의 버퍼가 생성되고 튜플 메시지 데이터가 여기에 복사됩니다. 버퍼가 부족하면 복사가 중지됩니다. 튜플의 첫 번째 메시지는 복사된 데이터가 포함된 새 크기 버퍼를 수신합니다. 나머지 메시지는 삭제되고 메모리는 힙으로 반환됩니다.

구조물을 삭제할 때 mblk_t 호출할 때 데이터 블록의 참조 카운트가 고려됩니다. 프리비() 0으로 판명되면 데이터 버퍼가 인스턴스와 함께 삭제됩니다. mblk_t, 그것을 가리킨다.

새 메시지 필드 초기화:

void mblk_init(mblk_t *mp);

메시지에 다른 데이터를 추가하려면 다음을 수행하세요.

mblk_t * appendb(mblk_t *mp, const char *data, size_t size, bool_t pad);

새 데이터가 메시지 데이터 버퍼의 여유 공간에 맞지 않으면 필요한 크기의 버퍼가 포함된 별도로 생성된 메시지가 메시지에 첨부되고(추가된 메시지에 대한 포인터가 첫 번째 메시지에 설정됨) 메시지가 튜플로 변합니다.

튜플에 데이터 조각 추가:

void msgappend(mblk_t *mp, const char *data, size_t size, bool_t pad); 

이 함수는 루프에서appendb()를 호출합니다.

두 개의 튜플을 하나로 결합:

mblk_t *concatb(mblk_t *mp, mblk_t *newm);

메시지 뉴엠 에 첨부됩니다 mp.

단일 메시지의 복사본 만들기:

mblk_t *copyb(const mblk_t *mp);

모든 데이터 블록이 포함된 튜플 복사 완료:

mblk_t *copymsg(const mblk_t *mp);

튜플의 요소는 함수에 의해 복사됩니다. 복사().

메시지의 간편한 복사본 만들기 mblk_t. 이 경우 데이터 블록은 복사되지 않지만 참조 카운터는 증가합니다. db_ref:

mblk_t *dupb(mblk_t *mp);

튜플의 경량 복사본 만들기. 데이터 블록은 복사되지 않으며 해당 참조 카운터만 증가됩니다. db_ref:

mblk_t *dupmsg(mblk_t* m);

튜플의 모든 메시지를 하나의 메시지로 묶기:

void msgpullup(mblk_t *mp,size_t len);

만약 인수 렌 -1이면 할당된 버퍼의 크기가 자동으로 결정됩니다.

메시지 삭제, 튜플:

void freemsg(mblk_t *mp);

데이터 블록의 참조 카운트는 1씩 감소합니다. 0에 도달하면 데이터 블록도 삭제됩니다.

메시지 또는 튜플의 총 데이터 양을 계산합니다.

size_t msgdsize(const mblk_t *mp);

대기열 끝에서 메시지 검색:

mblk_t *ms_queue_peek_last (q);

한 메시지의 예약된 필드 내용을 다른 메시지로 복사합니다(실제로 이러한 필드에는 미디어 스트리머에서 사용하는 플래그가 포함되어 있습니다).

mblk_meta_copy(const mblk_t *source, mblk *dest);

열 queue_t

미디어 스트리머의 메시지 큐는 순환 이중 연결 목록으로 구현됩니다. 각 목록 요소에는 신호 샘플이 있는 데이터 블록에 대한 포인터가 포함되어 있습니다. 데이터 블록에 대한 포인터만 차례로 이동하고 데이터 자체는 움직이지 않는 것으로 나타났습니다. 저것들. 해당 링크만 이동됩니다.
대기열을 설명하는 구조 queue_t, 아래에 표시됨:

typedef struct _queue
{
   mblk_t _q_stopper; /* "Холостой" элемент очереди, не указывает на данные, используется только для управления очередью. При инициализации очереди (qinit()) его указатели настраиваются так, чтобы они указывали на него самого. */
   int q_mcount;        // Количество элементов в очереди.
} queue_t;

구조에는 필드(포인터)가 포함되어 있습니다. _q_스토퍼 *mblk_t를 입력하면 대기열의 첫 번째 요소(메시지)를 가리킵니다. 구조의 두 번째 필드는 대기열에 있는 메시지의 카운터입니다.
아래 그림은 1개의 메시지 m4, m1, m2, m3를 포함하는 q4이라는 큐를 보여줍니다.

다음 그림은 1개의 메시지 m4,m1,m2,m3를 포함하는 q4이라는 큐를 보여줍니다. 메시지 m2는 두 개의 추가 메시지 m2_1 및 m2_2를 포함하는 튜플의 헤드입니다.

대기열 작업을 위한 함수 queue_t

대기열 초기화:

void qinit(queue_t *q);

분야 _q_스토퍼 (이하 “스토퍼”라 칭함)은 다음 함수에 의해 초기화됩니다. mblk_init(), 이전 요소와 다음 요소 포인터가 자신을 가리키도록 조정됩니다. 대기열 요소 카운터가 0으로 재설정됩니다.

새 요소(메시지) 추가:

void putq(queue_t *q, mblk_t *m);

새로운 요소 m 목록 끝에 추가되면 요소 포인터가 조정되어 스토퍼가 해당 다음 요소가 되고 스토퍼의 이전 요소가 됩니다. 대기열 요소 카운터가 증가됩니다.

대기열에서 요소 검색:

mblk_t * getq(queue_t *q); 

스토퍼가 검색된 후 나오는 메시지이며 요소 카운터가 감소됩니다. 스토퍼를 제외하고 대기열에 요소가 없으면 0이 반환됩니다.

대기열에 메시지 삽입:

void insq(queue_t *q, mblk_t *emp, mblk_t *mp); 

요소 mp 요소 앞에 삽입됨 EMP. 만약 EMP=0이면 메시지가 대기열의 꼬리에 추가됩니다.

대기열 헤드에서 메시지 검색:

void remq(queue_t *q, mblk_t *mp); 

요소 카운터가 감소합니다.

큐의 첫 번째 요소에 대한 포인터 읽기:

mblk_t * peekq(queue_t *q); 

요소 자체를 삭제하는 동안 대기열에서 모든 요소를 ​​제거합니다.

void flushq(queue_t *q, int how);

논의 방법 사용되지 않습니다. 대기열 요소 카운터는 0으로 설정됩니다.

큐의 마지막 요소에 대한 포인터를 읽는 매크로:

mblk_t * qlast(queue_t *q);

메시지 대기열로 작업할 때 다음 사항에 유의하세요. ms_queue_put(q, m) 메시지에 대한 널 포인터를 사용하면 함수가 반복됩니다. 프로그램이 정지됩니다. 비슷하게 행동한다 ms_queue_next(q,m).

필터 연결

위에 설명된 대기열은 한 필터에서 다른 필터로 또는 하나에서 여러 필터로 메시지를 전달하는 데 사용됩니다. 필터와 해당 연결은 방향성 그래프를 형성합니다. 필터의 입력 또는 출력을 일반 단어 "핀"이라고 합니다. 필터가 서로 연결되는 순서를 설명하기 위해 미디어 스트리머는 "신호 지점"이라는 개념을 사용합니다. 신호 지점은 구조입니다. _MSC포인트에는 필터에 대한 포인터와 해당 핀 중 하나의 번호가 포함되어 있으므로 필터의 입력 또는 출력 중 하나의 연결을 설명합니다.

데이터 처리 그래프의 신호 지점

typedef struct _MSCPoint{
struct _MSFilter *filter; // Указатель на фильтр медиастримера.
int pin;                        // Номер одного из входов или выходов фильтра, т.е. пин.
} MSCPoint;

필터 핀의 번호는 0부터 시작됩니다.

메시지 큐에 의한 두 핀의 연결은 다음 구조로 설명됩니다. _MS큐에는 메시지 큐와 연결되는 두 신호 지점에 대한 포인터가 포함되어 있습니다.

typedef struct _MSQueue
{
queue_t q;
MSCPoint prev;
MSCPoint next;
}MSQueue;

우리는 이 구조를 신호 링크라고 부를 것입니다. 각 미디어 스트리머 필터에는 입력 링크 테이블과 출력 링크 테이블(MSQueue). 테이블 크기는 필터를 생성할 때 설정됩니다. 이미 내보낸 유형의 변수를 사용하여 이 작업을 수행했습니다. MSFilterDesc, 자체 필터를 개발했을 때. 다음은 미디어 스트리머의 필터를 설명하는 구조입니다. MS필터:

struct _MSFilter{
    MSFilterDesc *desc;    /* Указатель на дескриптор фильтра. */
    /* Защищенные атрибуты, их нельзя сдвигать или убирать иначе будет нарушена работа с плагинами. */
    ms_mutex_t lock;      /* Семафор. */
    MSQueue **inputs;     /* Таблица входных линков. */
    MSQueue **outputs;    /* Таблица выходных линков. */
    struct _MSFactory *factory; /* Указатель на фабрику, которая создала данный экземпляр фильтра. */
    void *padding;              /* Не используется, будет задействован если добавятся защищенные поля. */
    void *data;                 /* Указатель на произвольную структуру для хранения данных внутреннего состояния фильтра и промежуточных вычислений. */
    struct _MSTicker *ticker;   /* Указатель на объект тикера, который не должен быть нулевым когда вызывается функция process(). */
    /*private attributes, they can be moved and changed at any time*/
    MSList *notify_callbacks; /* Список обратных вызовов, используемых для обработки событий фильтра. */
    uint32_t last_tick;       /* Номер последнего такта, когда выполнялся вызов process(). */ 
    MSFilterStats *stats;     /* Статистика работы фильтра.*/
    int postponed_task; /*Количество отложенных задач. Некоторые фильтры могут откладывать обработку данных (вызов process()) на несколько тактов.*/
    bool_t seen;  /* Флаг, который использует тикер, чтобы помечать что этот экземпляр фильтра он уже обслужил на данном такте.*/
};
typedef struct _MSFilter MSFilter;

계획에 따라 C 프로그램에서 필터를 연결한 후(티커는 연결하지 않음) 방향성 그래프를 만들었습니다. 노드는 구조의 인스턴스입니다. MS필터, 가장자리는 링크의 인스턴스입니다. MSQueue.

티커의 활동 비하인드 스토리

내가 티커가 진드기 소스에 대한 필터라고 말했을 때, 그것은 그것에 대한 완전한 진실이 아니었습니다. 티커는 시계에서 기능을 실행하는 개체입니다. 프로세스() 연결된 회로(그래프)의 모든 필터. C 프로그램의 그래프 필터에 티커를 연결하면 지금부터 끌 때까지 티커가 제어할 그래프를 티커에 표시합니다. 연결 후 티커는 관리에 맡겨진 그래프를 검사하기 시작하여 이를 포함하는 필터 목록을 작성합니다. 동일한 필터를 두 번 "계산"하지 않기 위해 검색된 필터에 확인란을 배치하여 표시합니다. 본. 각 필터가 가지고 있는 링크 테이블을 이용하여 검색을 수행합니다.

그래프를 소개하는 동안 티커는 필터 중에 데이터 블록의 소스 역할을 하는 필터가 하나 이상 있는지 확인합니다. 아무것도 없으면 그래프가 잘못된 것으로 간주되어 티커가 충돌합니다.

그래프가 "올바른" 것으로 판명되면 발견된 각 필터에 대해 초기화를 위해 함수가 호출됩니다. 전처리(). 다음 처리 주기(기본적으로 10밀리초마다)가 시작되자마자 티커는 함수를 호출합니다. 프로세스() 이전에 발견된 모든 소스 필터에 대해, 그런 다음 목록에 있는 나머지 필터에 대해. 필터에 입력 링크가 있으면 함수를 실행합니다. 프로세스() 입력 링크 대기열이 빌 때까지 반복됩니다. 그런 다음 목록의 다음 필터로 이동하여 입력 링크에 메시지가 없어질 때까지 "스크롤"합니다. 목록이 끝날 때까지 티커는 필터에서 필터로 이동합니다. 이것으로 사이클 처리가 완료됩니다.

이제 튜플로 돌아가서 그러한 엔터티가 미디어 스트리머에 추가된 이유에 대해 이야기하겠습니다. 일반적으로 필터 내부에서 작동하는 알고리즘에 필요한 데이터 양은 일치하지 않으며 입력에서 수신되는 데이터 버퍼 크기의 배수도 아닙니다. 예를 들어, 정의에 따라 크기가 512의 거듭제곱인 데이터 블록만 처리할 수 있는 고속 푸리에 변환을 수행하는 필터를 작성하고 있습니다. 160카운트로 하자. 데이터가 전화 채널에 의해 생성된 경우 입력에 있는 각 메시지의 데이터 버퍼는 XNUMX개의 신호 샘플을 가져옵니다. 필요한 양의 데이터가 있을 때까지 입력에서 데이터를 수집하지 않는 것이 좋습니다. 그러나 이 경우 티커와 충돌이 발생하여 입력 링크가 비어 있을 때까지 필터 스크롤이 실패하게 됩니다. 이전에는 이 규칙을 필터의 세 번째 원칙으로 지정했습니다. 이 원칙에 따르면 필터의 process() 함수는 입력 대기열에서 모든 데이터를 가져와야 합니다.

또한 전체 블록만 가져올 수 있으므로 입력에서 512개의 샘플만 가져올 수 없습니다. 필터는 640개의 샘플을 가져와서 그 중 512개를 사용해야 하며 나머지는 데이터의 새로운 부분을 축적하기 전에 사용됩니다. 따라서 필터는 주요 작업 외에도 입력 데이터의 중간 저장을 위한 보조 작업을 제공해야 합니다. 미디어 스트리머 개발자와 이 일반적인 문제에 대한 솔루션은 튜플을 사용하여 이 문제를 해결하는 특수 개체인 MSBufferizer(버퍼러)를 개발했습니다.

버퍼라이저(MSBufferizer)

이는 필터 내부에 입력 데이터를 축적하고 정보의 양이 필터 알고리즘을 실행하기에 충분할 때 즉시 처리를 위해 제출하기 시작하는 개체입니다. 버퍼가 데이터를 축적하는 동안 필터는 프로세서의 처리 능력을 사용하지 않고 유휴 모드에서 작동합니다. 그러나 버퍼러의 읽기 함수가 0이 아닌 값을 반환하자마자 필터의 process() 함수는 버퍼러에서 데이터가 소진될 때까지 필요한 크기의 부분을 가져와 처리하기 시작합니다.
아직 필요하지 않은 데이터는 튜플의 첫 번째 요소로 버퍼에 남아 있으며, 여기에 입력 데이터의 후속 블록이 연결됩니다.

버퍼를 설명하는 구조:

struct _MSBufferizer{
queue_t q; /* Очередь сообщений. */
int size; /* Суммарный размер данных находящихся в буферизаторе в данный момент. */
};
typedef struct _MSBufferizer MSBufferizer;

MSBufferizer 작업을 위한 함수

새 버퍼 인스턴스 만들기:

MSBufferizer * ms_bufferizer_new(void);

메모리가 할당되고 초기화됩니다. ms_bufferizer_init() 그리고 포인터가 반환됩니다.

초기화 기능:

void ms_bufferizer_init(MSBufferizer *obj); 

대기열을 초기화하는 중입니다. q, 필드 크기 0으로 설정됩니다.

메시지 추가:

void ms_bufferizer_put(MSBufferizer *obj, mblk_t *m); 

메시지 m이 대기열에 추가됩니다. 계산된 데이터 블록의 크기가 다음에 추가됩니다. 크기.

링크 데이터 큐의 모든 메시지를 버퍼로 전송 q:

void ms_bufferizer_put_from_queue(MSBufferizer *obj, MSQueue *q);   

링크에서 메시지 전송하기 q 버퍼에서 함수를 사용하여 수행됩니다. ms_bufferizer_put().

버퍼에서 읽기:

int ms_bufferizer_read(MSBufferizer *obj, uint8_t *data, int datalen); 

버퍼에 축적된 데이터의 크기가 요청한 데이터의 크기보다 작은 경우(데이터렌), 함수는 0을 반환하고 데이터는 데이터에 복사되지 않습니다. 그렇지 않으면 버퍼에 있는 튜플의 데이터를 순차적으로 복사합니다. 복사 후에는 튜플이 삭제되고 메모리가 해제됩니다. datalen 바이트가 복사되는 순간 복사가 종료됩니다. 데이터 블록 중간에 공간이 부족하면 이 메시지에서 데이터 블록은 복사되지 않은 나머지 부분으로 축소됩니다. 다음에 전화하면 이 시점부터 복사가 계속됩니다.

현재 버퍼에서 사용할 수 있는 데이터의 양을 읽습니다.

int ms_bufferizer_get_avail(MSBufferizer *obj); 

필드를 반환합니다. 크기 버퍼러.

버퍼의 데이터 일부 삭제:

void ms_bufferizer_skip_bytes(MSBufferizer *obj, int bytes);

지정된 바이트 수의 데이터가 검색되고 삭제됩니다. 가장 오래된 데이터는 폐기됩니다.

버퍼의 모든 메시지 삭제:

void ms_bufferizer_flush(MSBufferizer *obj); 

데이터 카운터가 0으로 재설정됩니다.

버퍼의 모든 메시지 삭제:

void ms_bufferizer_uninit(MSBufferizer *obj); 

카운터는 재설정되지 않습니다.

버퍼 제거 및 메모리 해제:

void ms_bufferizer_destroy(MSBufferizer *obj);  

버퍼러 사용 예는 여러 미디어 스트리머 필터의 소스 코드에서 찾을 수 있습니다. 예를 들어 MS_L16_ENC 필터에서는 샘플의 바이트를 네트워크 순서에서 호스트 순서로 재배열합니다. l16.c

다음 글에서는 티커 부하 추정 문제와 미디어 스트리머에서 과도한 컴퓨팅 부하를 처리하는 방법에 대해 살펴보겠습니다.

출처 : habr.com