Mediastreamer2 ভিওআইপি ইঞ্জিন অন্বেষণ করা হচ্ছে। পার্ট 11

নিবন্ধের উপাদান আমার থেকে নেওয়া হয়েছে জেন চ্যানেল.

ডাটা মুভমেন্ট মেকানিজম

• ডেটা ব্লক dblk_t
• বার্তা mblk_t
• mblk_t বার্তাগুলির সাথে কাজ করার জন্য ফাংশন
• সারি সারি_টি
• quees queue_t এর সাথে কাজ করার জন্য ফাংশন
• ফিল্টার সংযুক্ত করা হচ্ছে
• ডেটা প্রসেসিং গ্রাফের সিগন্যাল পয়েন্ট
• পর্দার আড়ালে টিকার তৎপরতা
• বাফারাইজার (MSBufferizer)
• MSBufferizer এর সাথে কাজ করার জন্য ফাংশন

শেষে প্রবন্ধ আমরা আমাদের নিজস্ব ফিল্টার তৈরি করেছি। এই নিবন্ধটি মিডিয়া স্ট্রিমার ফিল্টারগুলির মধ্যে ডেটা সরানোর জন্য অভ্যন্তরীণ প্রক্রিয়ার উপর ফোকাস করবে। এটি আপনাকে ভবিষ্যতে কম পরিশ্রমে অত্যাধুনিক ফিল্টার লিখতে অনুমতি দেবে।

ডাটা মুভমেন্ট মেকানিজম

মিডিয়া স্ট্রিমারে ডেটা আন্দোলন কাঠামো দ্বারা বর্ণিত সারিগুলি ব্যবহার করে সঞ্চালিত হয় queue_t. বার্তা স্ট্রিং মত mblk_t, যা নিজেরাই সিগন্যাল ডেটা ধারণ করে না, তবে শুধুমাত্র পূর্ববর্তী, পরবর্তী বার্তা এবং ডেটা ব্লকের সাথে লিঙ্ক করে। এছাড়াও, আমি বিশেষভাবে জোর দিতে চাই যে একই ধরণের বার্তার লিঙ্কের জন্য একটি ক্ষেত্রও রয়েছে, যা আপনাকে বার্তাগুলির একটি এককভাবে লিঙ্কযুক্ত তালিকা সংগঠিত করতে দেয়। আমরা এই ধরনের একটি তালিকা দ্বারা একত্রিত বার্তাগুলির একটি গ্রুপকে একটি টিপল বলব। সুতরাং, সারির যেকোনো উপাদান একটি একক বার্তা হতে পারে mblk_t, এবং সম্ভবত একটি বার্তা টিপল মাথা mblk_t. প্রতিটি টিপল বার্তার নিজস্ব ওয়ার্ড ডেটা ব্লক থাকতে পারে। আমরা একটু পরে আলোচনা করব কেন tuples প্রয়োজন।

উপরে উল্লিখিত হিসাবে, বার্তাটি নিজেই ডেটার একটি ব্লক ধারণ করে না; পরিবর্তে, এটি শুধুমাত্র মেমরি এলাকার একটি পয়েন্টার ধারণ করে যেখানে ব্লকটি সংরক্ষণ করা হয়। এই অংশে, মিডিয়া স্ট্রিমারের কাজের সামগ্রিক চিত্র কার্টুন "মনস্টারস, ইনকর্পোরেটেড"-এর দরজার গুদামের কথা মনে করিয়ে দেয়, যেখানে দরজাগুলি (ডেটা - রুমগুলির লিঙ্ক) ওভারহেড কনভেয়রগুলির সাথে একটি উন্মাদ গতিতে চলে, যখন রুমগুলি নিজেই গতিহীন থাকা

এখন, নীচে থেকে উপরে স্তরবিন্যাস বরাবর সরানো, আসুন মিডিয়া স্ট্রিমারে ডেটা ট্রান্সমিশন মেকানিজমের তালিকাভুক্ত সত্তাগুলিকে বিশদভাবে বিবেচনা করি।

ডেটা ব্লক dblk_t

ডেটা ব্লক একটি হেডার এবং একটি ডেটা বাফার নিয়ে গঠিত। শিরোনামটি নিম্নলিখিত কাঠামো দ্বারা বর্ণিত হয়েছে,

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

কাঠামোর ক্ষেত্রগুলিতে বাফারের শুরুতে, বাফারের শেষের দিকে এবং ডেটা বাফার মুছে ফেলার ফাংশনের পয়েন্টার থাকে। হেডারে শেষ উপাদান db_ref — রেফারেন্স কাউন্টার, যদি এটি শূন্যে পৌঁছায়, এটি মেমরি থেকে এই ব্লকটি মুছে ফেলার জন্য একটি সংকেত হিসাবে কাজ করে। যদি ফাংশন দ্বারা ডেটা ব্লক তৈরি করা হয় datab_alloc() , তারপর ডাটা বাফার হেডারের পরপরই মেমরিতে স্থাপন করা হবে। অন্য সব ক্ষেত্রে, বাফার আলাদাভাবে কোথাও অবস্থিত হতে পারে। ডেটা বাফারে সিগন্যালের নমুনা বা অন্যান্য ডেটা থাকবে যা আমরা ফিল্টারগুলির সাথে প্রক্রিয়া করতে চাই৷

ফাংশন ব্যবহার করে একটি ডেটা ব্লকের একটি নতুন উদাহরণ তৈরি করা হয়েছে:

dblk_t *datab_alloc(int size);

একটি ইনপুট প্যারামিটার হিসাবে, ব্লকটি যে ডেটা সংরক্ষণ করবে তার আকার দেওয়া হয়। বরাদ্দকৃত মেমরির শুরুতে হেডার - স্ট্রাকচার - রাখার জন্য আরও মেমরি বরাদ্দ করা হয় ডেটাব. কিন্তু অন্যান্য ফাংশন ব্যবহার করার সময়, এটি সবসময় ঘটবে না; কিছু ক্ষেত্রে, ডেটা ব্লক হেডার থেকে ডেটা বাফার আলাদাভাবে অবস্থিত হতে পারে। একটি কাঠামো তৈরি করার সময়, ক্ষেত্রগুলি কনফিগার করা হয় যাতে তার ক্ষেত্রটি db_base তথ্য এলাকার শুরুতে নির্দেশিত, এবং db_lim তার শেষ পর্যন্ত লিঙ্ক গণনা db_ref এক সেট করা হয়. ডেটা ক্লিয়ার ফাংশন পয়েন্টার শূন্য সেট করা হয়েছে।

বার্তা 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_পরবর্তী, যা একটি দ্বিগুণ লিঙ্কযুক্ত তালিকা সংগঠিত করার জন্য প্রয়োজনীয় (যা একটি সারি queue_t).

তারপর পয়েন্টার আসে b_cont, যা শুধুমাত্র তখনই ব্যবহৃত হয় যখন বার্তাটি একটি টিপলের অংশ হয়। টিপলে শেষ বার্তার জন্য, এই পয়েন্টারটি শূন্য থাকে।

এরপরে আমরা একটি ডেটা ব্লকের জন্য একটি পয়েন্টার দেখতে পাই 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 লাইব্রেরির এই সংস্করণে ব্যবহৃত হয় না। এটা শূন্য থাকা উচিত. ফাংশনটির অপারেশন চলাকালীন, নতুন বার্তার কাঠামোর জন্য মেমরি বরাদ্দ করা হবে এবং ফাংশনটি কল করা হবে 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*)); 

ফাংশন, বার্তা এবং ডেটা ব্লকের কাঠামো তৈরি করার পরে, ঠিকানায় ডেটাতে তার পয়েন্টারগুলি কনফিগার করবে বুফ. সেগুলো. এই ক্ষেত্রে, ডেটা বাফারটি ডেটা ব্লকের হেডার ক্ষেত্রগুলির পরে অবস্থিত নয়, যেমনটি ফাংশনের সাথে ডেটা ব্লক তৈরি করার সময় ছিল datab_alloc(). ফাংশনে পাস করা ডেটা সহ বাফারটি যেখানে ছিল সেখানেই থাকবে, তবে পয়েন্টারের সাহায্যে এটি ডেটা ব্লকের নতুন তৈরি শিরোনামের সাথে সংযুক্ত করা হবে এবং সেই অনুযায়ী, বার্তাটির সাথে।

একটা মেসেজের কাছে mblk_t বেশ কিছু ডেটা ব্লক পর্যায়ক্রমে সংযুক্ত করা যেতে পারে। এটি ফাংশন দ্বারা সম্পন্ন করা হয়:

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

mp — একটি বার্তা যেখানে অন্য ডেটা ব্লক যোগ করা হবে;
উপাত্ত — ব্লকে পয়েন্টার, যার একটি অনুলিপি বার্তায় যোগ করা হবে;
আয়তন - ডেটা আকার;
প্যাড — একটি পতাকা যা বরাদ্দ করা মেমরির আকার অবশ্যই 4-বাইটের সীমানা বরাবর সারিবদ্ধ করা উচিত (প্যাডিং শূন্য দিয়ে করা হবে)।

যদি বিদ্যমান মেসেজ ডেটা বাফারে পর্যাপ্ত জায়গা থাকে, তাহলে নতুন ডেটা আগে থেকে থাকা ডেটার পিছনে পেস্ট করা হবে। মেসেজ ডাটা বাফার এর চেয়ে কম ফাঁকা জায়গা থাকলে আয়তন, তারপর একটি পর্যাপ্ত বাফার আকারের সাথে একটি নতুন বার্তা তৈরি করা হয় এবং ডেটা তার বাফারে অনুলিপি করা হয়। এটি একটি নতুন বার্তা, একটি পয়েন্টার ব্যবহার করে আসলটির সাথে লিঙ্ক করা হয়েছে৷ b_cont. এই ক্ষেত্রে, বার্তা টিপলে পরিণত হয়।

আপনি যদি টুপলে ডেটার অন্য ব্লক যুক্ত করতে চান তবে আপনাকে ফাংশনটি ব্যবহার করতে হবে:

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

সে টিপলে শেষ বার্তাটি খুঁজে পাবে (তার কাছে আছে b_cont নাল হবে) এবং এই বার্তার জন্য ফাংশন কল করবে সংযোজন ().

আপনি ফাংশন ব্যবহার করে একটি বার্তা বা টিপলে ডেটার আকার খুঁজে পেতে পারেন:

int msgdsize(const mblk_t *mp);

এটি টিপলের সমস্ত বার্তাগুলি লুপ করবে এবং সেই বার্তাগুলির ডেটা বাফারগুলিতে মোট ডেটার পরিমাণ ফেরত দেবে। প্রতিটি বার্তার জন্য, ডেটার পরিমাণ নিম্নরূপ গণনা করা হয়:

 mp->b_wptr - mp->b_rptr

দুটি টিপল একত্রিত করতে, ফাংশনটি ব্যবহার করুন:

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

সে টিপল যুক্ত করে newm টুপলের লেজের কাছে mp এবং ফলাফল টিপলের শেষ বার্তায় একটি পয়েন্টার ফেরত দেয়।

প্রয়োজনে, একটি টিপলকে ডেটার একক ব্লক সহ একটি বার্তায় পরিণত করা যেতে পারে; এটি ফাংশন দ্বারা করা হয়:

void msgpullup(mblk_t *mp,int len);

যদি যুক্তি লেন হয় -1, তাহলে বরাদ্দকৃত বাফারের আকার স্বয়ংক্রিয়ভাবে নির্ধারিত হয়। যদি লেন একটি ধনাত্মক সংখ্যা, এই আকারের একটি বাফার তৈরি করা হবে এবং টুপল বার্তা ডেটা এতে কপি করা হবে। বাফার ফুরিয়ে গেলে, কপি করা সেখানেই বন্ধ হয়ে যাবে। টিপলের প্রথম বার্তাটি কপি করা ডেটা সহ একটি নতুন আকারের বাফার পাবে। অবশিষ্ট বার্তাগুলি মুছে ফেলা হবে এবং মেমরিটি হিপে ফিরে আসবে।

একটি কাঠামো মুছে ফেলার সময় mblk_t কল করার সময় যদি ডেটা ব্লকের রেফারেন্স গণনা বিবেচনায় নেওয়া হয় freeb() এটা শূন্য হতে সক্রিয় আউট, তারপর তথ্য বাফার ইনস্ট্যান্স বরাবর মুছে ফেলা হয় 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);

বার্তা 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);

ডেটা ব্লকের রেফারেন্স গণনা এক দ্বারা হ্রাস করা হয়েছে। যদি এটি শূন্যে পৌঁছায়, ডেটা ব্লকটিও মুছে ফেলা হয়।

একটি বার্তা বা টিপলে ডেটার মোট পরিমাণের গণনা।

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 টাইপ করুন, এটি সারির প্রথম উপাদান (বার্তা) নির্দেশ করে। কাঠামোর দ্বিতীয় ক্ষেত্রটি সারিতে থাকা বার্তাগুলির কাউন্টার।
নীচের চিত্রটি q1 নামের একটি সারি দেখায় যেখানে 4টি বার্তা m1, m2, m3, m4 রয়েছে।

নিম্নলিখিত চিত্রটি q1 নামের একটি সারি দেখায় যেখানে 4টি বার্তা m1,m2,m3,m4 রয়েছে। বার্তা m2 হল একটি টিপলের মাথা যাতে আরও দুটি বার্তা m2_1 এবং m2_2 রয়েছে।

quees queue_t এর সাথে কাজ করার জন্য ফাংশন

সারি আরম্ভ:

void qinit(queue_t *q);

ক্ষেত্র _q_স্টপার (এখন আমরা এটিকে "স্টপার" বলব) ফাংশন দ্বারা আরম্ভ করা হয় mblk_init(), এর পূর্ববর্তী উপাদান এবং পরবর্তী উপাদান পয়েন্টার নিজেকে নির্দেশ করার জন্য সামঞ্জস্য করা হয়। সারি উপাদান কাউন্টার শূন্য রিসেট করা হয়.

একটি নতুন উপাদান যোগ করা হচ্ছে (বার্তা):

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);

যুক্তি কিভাবে ব্যবহার করা হয় না. সারি উপাদান কাউন্টার শূন্য সেট করা হয়.

সারির শেষ উপাদানটিতে একটি পয়েন্টার পড়ার জন্য ম্যাক্রো:

mblk_t * qlast(queue_t *q);

বার্তা সারি নিয়ে কাজ করার সময়, আপনি যখন কল করবেন তখন সচেতন থাকুন ms_queue_put(q, m) বার্তার একটি নাল পয়েন্টার সহ, ফাংশনটি লুপ হয়ে যায়। আপনার প্রোগ্রাম হিমায়িত হবে. একইভাবে আচরণ করে ms_queue_next(q, m).

ফিল্টার সংযুক্ত করা হচ্ছে

উপরে বর্ণিত সারিটি এক ফিল্টার থেকে অন্য ফিল্টারে বা এক থেকে একাধিক ফিল্টারে বার্তা পাঠাতে ব্যবহৃত হয়। ফিল্টার এবং তাদের সংযোগ একটি নির্দেশিত গ্রাফ গঠন করে। ফিল্টারের ইনপুট বা আউটপুটকে সাধারণ শব্দ "পিন" বলা হবে। যে ক্রমে ফিল্টার একে অপরের সাথে সংযুক্ত থাকে তা বর্ণনা করতে, মিডিয়া স্ট্রিমার একটি "সিগন্যাল পয়েন্ট" ধারণা ব্যবহার করে। সংকেত বিন্দু গঠন _MSCP পয়েন্ট, যা ফিল্টারের একটি পয়েন্টার এবং এর একটি পিনের সংখ্যা ধারণ করে; সেই অনুযায়ী, এটি ফিল্টারের ইনপুট বা আউটপুটগুলির একটির সংযোগ বর্ণনা করে।

ডেটা প্রসেসিং গ্রাফের সিগন্যাল পয়েন্ট

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

ফিল্টার পিনগুলি শূন্য থেকে শুরু করে সংখ্যাযুক্ত।

একটি বার্তা সারি দ্বারা দুটি পিনের সংযোগ কাঠামো দ্বারা বর্ণিত হয় _MS সারি, এতে একটি বার্তা সারি রয়েছে এবং এটি সংযোগকারী দুটি সংকেত পয়েন্টের পয়েন্টার রয়েছে:

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

আমরা এই কাঠামোটিকে একটি সংকেত লিঙ্ক বলব। প্রতিটি মিডিয়া স্ট্রিমার ফিল্টারে ইনপুট লিঙ্কগুলির একটি টেবিল এবং আউটপুট লিঙ্কগুলির একটি টেবিল রয়েছে (MSQueue) একটি ফিল্টার তৈরি করার সময় টেবিলের আকার সেট করা হয়; আমরা ইতিমধ্যে টাইপের এক্সপোর্ট করা ভেরিয়েবল ব্যবহার করে এটি করেছি MSFilterDesc, যখন আমরা আমাদের নিজস্ব ফিল্টার তৈরি করি। নীচে একটি কাঠামো রয়েছে যা মিডিয়া স্ট্রিমারে যে কোনও ফিল্টার বর্ণনা করে, এমএসফিল্টার:

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;

আমরা আমাদের পরিকল্পনা অনুসারে সি প্রোগ্রামে ফিল্টারগুলি সংযুক্ত করার পরে (কিন্তু টিকারের সাথে সংযোগ করিনি), আমরা এর মাধ্যমে একটি নির্দেশিত গ্রাফ তৈরি করেছি, যার নোডগুলি কাঠামোর উদাহরণ এমএসফিল্টার, এবং প্রান্তগুলি লিঙ্কের উদাহরণ MSQueue.

পর্দার আড়ালে টিকার তৎপরতা

যখন আমি আপনাকে বলেছিলাম যে টিকারটি টিকগুলির উত্সের জন্য একটি ফিল্টার, তখন এটি সম্পর্কে সম্পূর্ণ সত্য ছিল না। একটি টিকার হল একটি বস্তু যা ঘড়িতে ফাংশন চালায় প্রক্রিয়া() সার্কিটের সমস্ত ফিল্টার (গ্রাফ) যার সাথে এটি সংযুক্ত। যখন আমরা একটি সি প্রোগ্রামে একটি গ্রাফ ফিল্টারের সাথে একটি টিকার সংযোগ করি, তখন আমরা টিকারের গ্রাফটি দেখাই যা এটি এখন থেকে নিয়ন্ত্রণ করবে যতক্ষণ না আমরা এটি বন্ধ করি। সংযোগ করার পরে, টিকারটি তার যত্নের জন্য অর্পিত গ্রাফটি পরীক্ষা করতে শুরু করে, এটি অন্তর্ভুক্ত করে এমন ফিল্টারগুলির একটি তালিকা সংকলন করে। একই ফিল্টারকে দুবার "গণনা" না করার জন্য, এটি সনাক্ত করা ফিল্টারগুলিতে একটি চেকবক্স স্থাপন করে চিহ্নিত করে দেখা. অনুসন্ধান প্রতিটি ফিল্টার আছে যে লিঙ্ক টেবিল ব্যবহার করে বাহিত হয়.

গ্রাফের পরিচায়ক সফরের সময়, টিকার পরীক্ষা করে যে ফিল্টারগুলির মধ্যে অন্তত এমন একটি আছে যা ডেটা ব্লকের উত্স হিসাবে কাজ করে। যদি কোনটি না থাকে, তাহলে গ্রাফটি ভুল বলে বিবেচিত হবে এবং টিকার ক্র্যাশ হবে।

যদি গ্রাফটি "সঠিক" হতে দেখা যায়, প্রতিটি পাওয়া ফিল্টারের জন্য, ফাংশনটিকে আরম্ভ করার জন্য বলা হয় পূর্ব প্রক্রিয়া(). পরবর্তী প্রক্রিয়াকরণ চক্রের (ডিফল্টরূপে প্রতি 10 মিলিসেকেন্ডে) মুহূর্তটি আসার সাথে সাথে টিকার ফাংশনটিকে কল করে প্রক্রিয়া() পূর্বে পাওয়া সমস্ত উৎস ফিল্টারের জন্য, এবং তারপর তালিকার অবশিষ্ট ফিল্টারগুলির জন্য। ফিল্টার ইনপুট লিঙ্ক আছে, তারপর ফাংশন চলমান প্রক্রিয়া() ইনপুট লিঙ্ক সারি খালি না হওয়া পর্যন্ত পুনরাবৃত্তি হয়। এর পরে, এটি তালিকার পরবর্তী ফিল্টারে চলে যায় এবং ইনপুট লিঙ্কগুলি বার্তামুক্ত না হওয়া পর্যন্ত এটিকে "স্ক্রোল" করে। তালিকা শেষ না হওয়া পর্যন্ত টিকার ফিল্টার থেকে ফিল্টারে চলে যায়। এটি চক্রের প্রক্রিয়াকরণ সম্পূর্ণ করে।

এখন আমরা টিপলে ফিরে যাব এবং মিডিয়া স্ট্রিমারে কেন এমন একটি সত্তা যুক্ত করা হয়েছিল সে সম্পর্কে কথা বলব। সাধারণভাবে, ফিল্টারের অভ্যন্তরে অপারেটিং অ্যালগরিদম দ্বারা প্রয়োজনীয় ডেটার পরিমাণ মিলিত হয় না এবং ইনপুটে প্রাপ্ত ডেটা বাফারগুলির আকারের একাধিক নয়৷ উদাহরণস্বরূপ, আমরা একটি ফিল্টার লিখছি যা একটি দ্রুত ফুরিয়ার রূপান্তর সম্পাদন করে, যা সংজ্ঞা অনুসারে শুধুমাত্র ডেটা ব্লকগুলিকে প্রক্রিয়া করতে পারে যার আকার দুটি শক্তি। এটা 512 গণনা করা যাক. যদি একটি টেলিফোন চ্যানেল দ্বারা ডেটা তৈরি করা হয়, তাহলে ইনপুটে প্রতিটি বার্তার ডেটা বাফার আমাদের 160টি সংকেত নমুনা নিয়ে আসবে। প্রয়োজনীয় পরিমাণ ডেটা না পাওয়া পর্যন্ত ইনপুট থেকে ডেটা সংগ্রহ না করা প্রলুব্ধ হয়। কিন্তু এই ক্ষেত্রে, টিকারের সাথে একটি সংঘর্ষ ঘটবে, যা ইনপুট লিঙ্কটি খালি না হওয়া পর্যন্ত ফিল্টারটি স্ক্রোল করার ব্যর্থ চেষ্টা করবে। পূর্বে, আমরা এই নিয়মটিকে ফিল্টারের তৃতীয় নীতি হিসাবে মনোনীত করেছি। এই নীতি অনুসারে, ফিল্টারের প্রক্রিয়া() ফাংশনটি অবশ্যই ইনপুট সারি থেকে সমস্ত ডেটা গ্রহণ করবে।

উপরন্তু, ইনপুট থেকে শুধুমাত্র 512টি নমুনা নেওয়া সম্ভব হবে না, যেহেতু আপনি শুধুমাত্র সম্পূর্ণ ব্লক নিতে পারবেন, যেমন ফিল্টারটিকে 640টি নমুনা নিতে হবে এবং তাদের মধ্যে 512টি ব্যবহার করতে হবে, অবশিষ্টটি ডেটার একটি নতুন অংশ জমা করার আগে। এইভাবে, আমাদের ফিল্টার, তার প্রধান কাজ ছাড়াও, ইনপুট ডেটার মধ্যবর্তী স্টোরেজের জন্য সহায়ক ক্রিয়াগুলি প্রদান করতে হবে। মিডিয়া স্ট্রিমারের বিকাশকারীরা এবং এই সাধারণ সমস্যার সমাধানের জন্য একটি বিশেষ অবজেক্ট তৈরি করেছেন - এমএসবিফারাইজার (বাফারার), যা টিপল ব্যবহার করে এই সমস্যার সমাধান করে।

বাফারাইজার (MSBufferizer)

এটি এমন একটি বস্তু যা ফিল্টারের ভিতরে ইনপুট ডেটা জমা করবে এবং ফিল্টার অ্যালগরিদম চালানোর জন্য তথ্যের পরিমাণ যথেষ্ট হওয়ার সাথে সাথে এটি প্রক্রিয়াকরণের জন্য জমা দেওয়া শুরু করবে। যখন বাফার ডেটা জমা করছে, তখন ফিল্টারটি নিষ্ক্রিয় মোডে কাজ করবে, প্রসেসরের প্রক্রিয়াকরণ শক্তি ব্যবহার না করে। কিন্তু যত তাড়াতাড়ি বাফারার থেকে রিডিং ফাংশন শূন্য ছাড়া অন্য একটি মান প্রদান করে, ফিল্টারের প্রক্রিয়া() ফাংশনটি প্রয়োজনীয় আকারের অংশে বাফারার থেকে ডেটা গ্রহণ এবং প্রক্রিয়া করতে শুরু করে, যতক্ষণ না এটি শেষ হয়।
যে ডেটা এখনও প্রয়োজন হয় না তা টিপলের প্রথম উপাদান হিসাবে বাফারে থাকে, যার সাথে ইনপুট ডেটার পরবর্তী ব্লকগুলি সংযুক্ত করা হয়।

কাঠামো যা বাফার বর্ণনা করে:

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

MSBufferizer এর সাথে কাজ করার জন্য ফাংশন

একটি নতুন বাফার উদাহরণ তৈরি করা হচ্ছে:

MSBufferizer * ms_bufferizer_new(void);

মেমরি বরাদ্দ করা হয়, শুরু হয় ms_buferizer_init() এবং একটি পয়েন্টার ফেরত দেওয়া হয়।

সূচনা ফাংশন:

void ms_bufferizer_init(MSBufferizer *obj); 

সারি শুরু হচ্ছে q, ক্ষেত্র আয়তন শূন্য সেট করা হয়।

একটি বার্তা যোগ করা হচ্ছে:

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

বার্তা m যোগ করা হয়েছে সারিতে। ডেটা ব্লকের গণনাকৃত আকার যোগ করা হয়েছে আয়তন.

লিঙ্ক ডেটা সারি থেকে বাফারে সমস্ত বার্তা স্থানান্তর করা হচ্ছে q:

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

একটি লিঙ্ক থেকে বার্তা স্থানান্তর q বাফার মধ্যে ফাংশন ব্যবহার করে সঞ্চালিত হয় ms_buferizer_put().

বাফার থেকে পড়া:

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

যদি বাফারে জমা হওয়া ডেটার আকার অনুরোধকৃতের চেয়ে কম হয় (ডেটালেন), তারপর ফাংশন শূন্য প্রদান করে, ডেটা ডেটাতে অনুলিপি করা হয় না। অন্যথায়, বাফারে অবস্থিত টিপল থেকে ডেটা অনুক্রমিক অনুলিপি করা হয়। অনুলিপি করার পরে, টিপল মুছে ফেলা হয় এবং মেমরি মুক্ত হয়। ডেটালেন বাইট কপি করা হলে কপি করা শেষ হয়। যদি একটি ডেটা ব্লকের মাঝখানে স্থান ফুরিয়ে যায়, তাহলে এই বার্তায়, ডেটা ব্লকটি অবশিষ্ট আনকপি করা অংশে হ্রাস পাবে। পরের বার যখন আপনি কল করবেন, তখন থেকে কপি করা চলবে।

বর্তমানে বাফারে উপলব্ধ ডেটার পরিমাণ পড়া:

int ms_bufferizer_get_avail(MSBufferizer *obj); 

মাঠে ফেরে আয়তন বাফারার

বাফারে ডেটার অংশ বাদ দেওয়া হচ্ছে:

void ms_bufferizer_skip_bytes(MSBufferizer *obj, int bytes);

ডেটার বাইটের নির্দিষ্ট সংখ্যা পুনরুদ্ধার করা হয় এবং বাতিল করা হয়। প্রাচীনতম তথ্য বাতিল করা হয়.

বাফারে সমস্ত বার্তা মুছে ফেলা হচ্ছে:

void ms_bufferizer_flush(MSBufferizer *obj); 

ডেটা কাউন্টারটি শূন্যে রিসেট করা হয়েছে।

বাফারে সমস্ত বার্তা মুছে ফেলা হচ্ছে:

void ms_bufferizer_uninit(MSBufferizer *obj); 

কাউন্টার রিসেট করা হয় না.

বাফার অপসারণ এবং মেমরি মুক্ত করা:

void ms_bufferizer_destroy(MSBufferizer *obj);  

বাফার ব্যবহার করার উদাহরণ বেশ কয়েকটি মিডিয়া স্ট্রিমার ফিল্টারের সোর্স কোডে পাওয়া যাবে। উদাহরণস্বরূপ, MS_L16_ENC ফিল্টারে, যা নেটওয়ার্ক অর্ডার থেকে হোস্ট অর্ডারে নমুনাগুলিতে বাইটগুলিকে পুনর্বিন্যাস করে: l16.c

পরবর্তী নিবন্ধে, আমরা একটি টিকারের উপর লোড অনুমান করার সমস্যা এবং মিডিয়া স্ট্রিমারে অত্যধিক কম্পিউটিং লোডের বিরুদ্ধে লড়াই করার উপায়গুলি দেখব।

উত্স: www.habr.com