एंड्रॉइड पर मूल कोड प्रगति प्रदर्शित करने के लिए यूनिक्स पाइप का उपयोग करना

एक परियोजना में, मुझे एंड्रॉइड पर मूल कोड (विशेष रूप से, पोर्ट किए गए FFmpeg) की प्रगति को ट्रैक करने की आवश्यकता थी। स्थिति इस तथ्य से भी जटिल थी कि कई कारणों से कोड को कई प्रक्रियाओं में निष्पादित किया गया था।





निम्नलिखित विकल्पों में से निम्नलिखित थे:

• IPC कोड से कॉल करता है
• logcat पार्सिंग
• पाइप के माध्यम से डेटा स्थानांतरण

सबसे उपयुक्त विकल्प उत्तरार्द्ध था - नामित पाइपों का उपयोग, यूनिक्स-सिस्टम में इंटरप्रोसेस इंटरैक्शन के लिए एक मानक उपकरण (इसके साथ अपरिचित लोगों के लिए, आप यहां उदाहरण के लिए पढ़ सकते हैं)। संक्षेप में, यह फ़ाइल इंटरफ़ेस वाला एक तरफ़ा FIFO चैनल है। लिखते समय, इसे तब तक ब्लॉक किया जाता है जब तक कि कोई अन्य प्रक्रिया इसे पढ़ने के लिए नहीं खोलती है और इसके विपरीत - जब पढ़ते हैं, तो चैनल फिर से अवरुद्ध हो जाता है जब तक कि कोई अन्य प्रक्रिया इसे डेटा नहीं लिखती है। एक बड़ा प्लस यह है कि कई प्रक्रियाएं एक ही समय में एक पाइप को लिख सकती हैं।



इस विचार को प्रदर्शित करने वाली एक परीक्षण परियोजना निहित है। यह एक सेवा चलाता है जो मूल कोड से पाइप को लिखता है, साथ ही एक पाठक धागा जो स्क्रीन पर परिणाम प्रदर्शित करता है।



स्ट्रीम-पाठक । Mffifo फ़ंक्शन के साथ एक नया पाइप बनाता है (यह उसी नाम के सिस्टम कॉल पर केवल एक आवरण है) और इसे बाइट्स पढ़ता है, जैसा कि एक नियमित फ़ाइल से होता है। जब तक पाइप के दूसरी तरफ कोई व्यक्ति डेटा लिखना शुरू नहीं करता है तब तक कॉल कॉल निष्पादन को रोक देता है। यह सुविधाजनक AsyncTask क्लास का उपयोग करता है, जो आपको पृष्ठभूमि में एक फ़ंक्शन निष्पादित करने और एक यूआई स्ट्रीम के लिए मध्यवर्ती परिणाम प्रकाशित करने की अनुमति देता है।

final TextView disp = new TextView( this );

disp.setText( "0" );

setContentView(disp);



final String pipename = getDir( "pipedemo" , Context.MODE_WORLD_WRITEABLE)

.getAbsolutePath() + "/pipe" ;

final File pipe = new File (pipename);



new AsyncTask<Void, Integer, Integer>() {



@Override

protected void onProgressUpdate(Integer... values) {

disp.setText( "" +values[0]);

};



protected Integer doInBackground(Void... params ) {



//create a pipe

if (mkfifo(pipename) == -1) {

Log.d(TAG, "Pipe error" );

return -1;

}



FileInputStream fis;

try {

fis = new FileInputStream(pipe);

int res = 0;

while (res != -1) { //blocks until someone writes to this pipe

res = fis.read();

publishProgress(res);

}

} catch (Exception e) {

e.printStackTrace();

}

return 0;

}

}.execute();



* This source code was highlighted with Source Code Highlighter .

स्ट्रीम-लेखक । हम इसे एक अलग सेवा में लॉन्च करते हैं। यह एक लंबे समय तक चलने वाला कार्य करता है, इस बहुत ही पाइप में प्रगति लिखता है।

final String pipename = intent.getStringExtra( "fn" );

new Thread( new Runnable() {



@Override

public void run() {

process(pipename);

}

}).start();



* This source code was highlighted with Source Code Highlighter .

Vorning 1 : हालांकि कोड को एक अलग प्रक्रिया में निष्पादित किया जा सकता है, एक अलग धागे में लंबे ऑपरेशन चलाएं, अन्यथा सिस्टम चेतावनी के बिना प्रक्रिया को मार देगा।



Vorning 2 : sdcard पर पाइप न बनाएं - FAT32 उनका समर्थन नहीं करता है।

JNIEXPORT jint JNICALL Java_ru_jecklandin_cats_ProcessingService_process

(JNIEnv * env, jobject, jstring path) {



const char * cpath = env->GetStringUTFChars(path, NULL);

struct stat buf;



if ( stat(cpath, &buf) < 0 || ! (buf.st_mode | S_IFIFO)) {

LOGD( "The file isn't a pipe" );

return -1;

}



int fp = open(cpath, O_WRONLY);

if (fp == -1) {

LOGD( "Could not open the pipe" );

return -1;

}



for ( int i=0; i<10; ++i) {

sleep(1);

write(fp, &i, 1);

}

close(fp);

env->ReleaseStringUTFChars(path, cpath);

return 0;

}



* This source code was highlighted with Source Code Highlighter .

मेनिफ़ेस्ट में हमारी सेवा में "प्रक्रिया" विशेषता जोड़ें।

< service android:name =".ProcessingService"

android:process =":remote" >

</ service >



* This source code was highlighted with Source Code Highlighter .

डीडीएमएस में हम दोनों प्रक्रियाओं को देखते हैं।







हम स्क्रीन पर बढ़ते अंकों को देखते हैं (बहुत प्रभावशाली नहीं)।



इस तरह से, डुप्लेक्स संचार (एक और पाइप होने) को व्यवस्थित करना संभव है। बेशक, समाधान सभी मामलों के लिए उपयुक्त नहीं है। यदि आपको वस्तुओं को स्थानांतरित करने की आवश्यकता है, तो मानक एंड्रॉइड आईपीसी तंत्र का उपयोग करना बेहतर है, जो आपको प्रक्रियाओं के बीच क्रमबद्ध वस्तुओं को स्थानांतरित करने की अनुमति देता है।



संदर्भ:

developers.sun.com/solaris/articles/named_pipes.html

developer.android.com/guide/developing/tools/aidl.html