Resolu[c/Linux]Comment recupérer les infos d'un pipe sans perte de don

Resolu[c/Linux]Comment recupérer les infos d'un pipe sans perte de don - C++ - Programmation

Marsh Posté le 27-03-2003 à 11:03:24    

Je m'explique mieux , MOn application lance un programme (mplayer pour lire les fichiers audios) avec  fork   et communique avec ceui ci par des pipes , le pb , c'est quand je récupère les données de e programmes, des fois , il en  zappe  certaines .
Hors je veux abolument les récupérér car ca me permet de détecter au niveua de mon appli quand il ya eu un changement de chanson .
voila le code , svp aidez moi .
 

Code :
  1. #include "mplayer_backend.h"
  2. #include "select_unselect_utility.h"
  4. //variables globales ,oulala tout ca :-) !
  5. static int pipe_in[2], pipe_out[2];
  6. pid_t  mplayer_pid;          //processus enfant
  7. static pthread_mutex_t mplayer_mutex;
  8. int firsttime=1;
  9. char *song_ref="none";
  11. void write_mplayer_cmd (char *buff)
  12. {       
  13.     write(pipe_in[1],buff,strlen(buff));
  14.     write(pipe_in[1],"\n",1); 
  15. }
  17. int mplayer_get_media_change(void)
  18. {
  19.   char buff[1024];       
  20.   char *data="none";
  22.   while(1){
  23.    fcntl(pipe_out[0],F_SETFL,O_NONBLOCK);
  24.    pthread_mutex_lock (&mplayer_mutex);
  25.    read(pipe_out[0],buff,sizeof(buff));
  26.  
  27.    if (sscanf(buff,"%a[^\f\r]\n",&data)==1){
  28.      // fprintf(stdout,"data: %s\n",data);
  29.       if(strstr(data,"Starting playback" )!=NULL){
  30. //je recupere cette ligne pour savoir qu'une chanson est jouée
  31.           if(!firsttime) {
  32.               next_playlist_element();
  33.            }
  34.            firsttime=0;
  35.    
  36.       }
  37.    }
  38.    pthread_mutex_unlock (&mplayer_mutex);
  39.    *buff='\n';
  40.   usleep(100000);
  41.   }
  42.    return 0;         
  43. }
  45. void mplayer_stop ()
  46. {
  47.   pthread_mutex_lock (&mplayer_mutex);
  48.   write_mplayer_cmd ("seek 0  1\npause" );
  49.   pthread_mutex_unlock (&mplayer_mutex);         
  50. }
  52. void mplayer_pause ()
  53. {
  54.   pthread_mutex_lock (&mplayer_mutex);
  55.   write_mplayer_cmd ("p" );
  56.   pthread_mutex_unlock (&mplayer_mutex);
  57. }
  59. void mplayer_foreward ()
  60. {
  61.   pthread_mutex_lock (&mplayer_mutex);
  62.   write_mplayer_cmd ("seek 10" );
  63.   pthread_mutex_unlock (&mplayer_mutex);
  64. }
  66. void mplayer_backward()
  67. {
  68.   pthread_mutex_lock (&mplayer_mutex);
  69.   write_mplayer_cmd ("seek  -10" );
  70.   pthread_mutex_unlock (&mplayer_mutex);
  71. }
  73. void mplayer_pl_next ()
  74. {
  76.   pthread_mutex_lock (&mplayer_mutex);
  77.   write_mplayer_cmd ("pt_step 1" );
  78.   pthread_mutex_unlock (&mplayer_mutex);
  79. }
  81. void mplayer_pl_previous ()
  82. {
  83.   pthread_mutex_lock (&mplayer_mutex);
  84.   write_mplayer_cmd ("pt_step  -1" );
  85.   pthread_mutex_unlock (&mplayer_mutex);
  86. }
  89. void mplayer_play (char* pathname)
  90. {
  91.   char cmd[64+PATH_MAXI*2];
  92.   char *MPlayerCmd = " mplayer -ao oss -slave -playlist" ;
  94.   if (pipe (pipe_in) < 0) {
  95.     fprintf (stdout,"pipe_in: %s", cmd);
  96.     exit (1);
  97.   } 
  98.   if (pipe (pipe_out) < 0) {
  99.     fprintf (stdout,"pipe_out: %s",cmd);
  100.     exit (1);
  101.   } 
  102.   if ((mplayer_pid = fork ())==0)   //créer un nouveau processus enfant               , test = 0 pour savoir si enfant démarré
  103.   {
  104.       close(pipe_in[1]);
  105.       close(pipe_out[0]);
  106.       dup2(pipe_in[0],STDIN_FILENO);
  107.       dup2(pipe_out[1],STDOUT_FILENO);
  108.       dup2(pipe_out[1],STDERR_FILENO);
  109.       close(pipe_in[0]);
  110.       close(pipe_out[1]);
  111.       fcntl(pipe_out[0],F_SETFL,O_NONBLOCK);
  112.      
  113.       snprintf(cmd,sizeof(cmd),"%s \"%s\" ",MPlayerCmd,pathname);
  114.       launch_player(cmd);                -
  115.       pthread_mutex_init (&mplayer_mutex, NULL);
  116.       pthread_mutex_init (&track_mutex, NULL);
  117.    }
  118. }
  121. void mplayer_quit ()
  122. {                   
  123.   pthread_mutex_lock (&mplayer_mutex);
  124.   write_mplayer_cmd ("q" );
  125.   pthread_mutex_unlock (&mplayer_mutex);   
  126. }


Message édité par psebcopathe le 02-04-2003 à 17:20:27
Reply

Marsh Posté le 27-03-2003 à 11:03:24   

Reply

Marsh Posté le 27-03-2003 à 11:57:15    

psebcopathe a écrit :


Comment recupérer les infos d'un pipe sans perte de données
(...)


On ne peut perdre des données dans un pipe (tout ce qui entre, doit sortir).  
Si le pipe est plein, le processus écrivin est bloqué sur write. Si le pipe est vide, le processus lecteur est bloqué sur read ... SAUF si on utilise NONBLOCK, dans quel cas, les données du pipe sont écrasées par les nouvelles!
 
Conclusion: ...
 

Reply

Marsh Posté le 27-03-2003 à 18:18:11    

ok merci de ta reponse

Reply

Marsh Posté le 28-03-2003 à 17:01:46    

psebcopathe a écrit :

ok merci de ta reponse


mea culpa: en cas d'un NOBLOCK et si le pipe est vide, la lecture (read) sort avec un "erreur" (non mortel). etc.
Donc, je pense que tes pertes viennent du fait que write ne peut écrire dans un tube plein, donc ces données passent à la trappe.
 
Notez: tout vient de NOBLOCK

Reply

Marsh Posté le 28-03-2003 à 19:23:19    

le pb c'est que si je mets pas NOBLOCK , j'ai plus le son de mes chansons et le clavier freeze , elle est ou la connerie ?
 

Reply

Marsh Posté le 28-03-2003 à 19:43:24    

le titre du topic me fais PTDR  :lol:


Message édité par skylight le 28-03-2003 à 19:43:31
Reply

Marsh Posté le 31-03-2003 à 23:59:09    

up de minuit .
J'ai cherche et je n'ai tjs pas trouve , si qqu a une piste pour eviter le NO_BlOck et que ca puisse marcher , je suis preneur .

Reply

Marsh Posté le 01-04-2003 à 05:29:51    

La primitive write retourne le nombre d'octects effectivement écrits, donc déjà ça te permet de vérifier où cloche ton prog (Est ce que tout est bien écrit dans le pipe), et dans ce cas, de pouvoir le corriger. Si tu sais combien d'octets tu as écrit, tu sais aussi combien tu n'en as pas écrit, donc lesquels tu dois renvoyer, le temps que le lecteur ait lu (et donc vidé) dans le pipe.

Reply

Marsh Posté le 01-04-2003 à 09:35:51    

psebcopathe a écrit :

up de minuit .
J'ai cherche et je n'ai tjs pas trouve , si qqu a une piste pour eviter le NO_BlOck et que ca puisse marcher , je suis preneur .


Peut-être essayer d'ordonner mieux les process ...
Sinon, tu posissionne NOBLOCK et tu surveille les messages d'erreur de write (errno doit être égale à quelque chose ...)

Reply

Marsh Posté le 02-04-2003 à 17:19:57    

OK , merci , c'est bon ca marche maintenant !
le seul changement effectué , a été de virer les NOBLOCK et dans la fonction "play" , de rajouter a la fin : "close (2);" et now ca rox sans pb .

Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed