hvirtual/cinelerra/messages.C

   1 #include <string.h>
   2 #include "bcipc.h"
   3 #include "messages.h"
   4 #include <stdio.h>
   5 #include <stdlib.h>
   6 #include <unistd.h>
   7
   8 #include <libintl.h>
   9 #define _(String) gettext(String)
  10 #define gettext_noop(String) String
  11 #define N_(String) gettext_noop (String)
  12
  13 Messages::Messages(int input_flag, int output_flag, int id)
  14 {
  15         if(id == -1)
  16         {
  17                 msgid = msgget(IPC_PRIVATE, IPC_CREAT | 0777);
  18                 client = 0;
  19         }
  20         else
  21         {
  22                 this->msgid = id;
  23                 client = 1;
  24         }
  25
  26         this->input_flag = input_flag;
  27         this->output_flag = output_flag;
  28         bc_enter_msg_id(msgid);
  29 }
  30
  31 Messages::~Messages()
  32 {
  33         if(!client)
  34         {
  35                 msgctl(msgid, IPC_RMID, NULL);
  36                 bc_remove_msg_id(msgid);
  37         }
  38 }
  39
  40 char* Messages::get_message_buffer()
  41 {
  42         return buffer.text;
  43 }
  44
  45 int Messages::read_message(char *text)
  46 {
  47         buffer.mtype = input_flag;
  48
  49         if((msgrcv(msgid, (struct msgbuf*)&buffer, MESSAGESIZE, input_flag, 0)) < 0)
  50         {
  51                 printf(_("recieve message failed\n"));
  52                 sleep(1);     // don't flood the screen during the loop
  53                 return -1;
  54         }
  55
  56 //printf("%d %d\n", buffer.text[0], buffer.mtype);
  57         strcpy(text, buffer.text);
  58         return 0;
  59 }
  60
  61 long Messages::read_message()
  62 {
  63         buffer.mtype = input_flag;
  64
  65         if((msgrcv(msgid, (struct msgbuf*)&buffer, MESSAGESIZE, input_flag, 0)) < 0)
  66         {
  67                 printf(_("recieve message failed\n"));
  68                 sleep(1);
  69                 return -1;
  70         }
  71         return atol(buffer.text);
  72 }
  73
  74 float Messages::read_message_f()
  75 {
  76         float value;
  77         char *data = read_message_raw();
  78         sscanf(data, "%f", &value);
  79         return value;
  80 }
  81
  82 char* Messages::read_message_raw()
  83 {
  84         buffer.mtype = input_flag;
  85
  86         if((msgrcv(msgid, (struct msgbuf*)&buffer, MESSAGESIZE, input_flag, 0)) < 0)
  87         {
  88                 printf(_("recieve message failed\n"));
  89                 sleep(1);
  90                 return "RECIEVE MESSAGE FAILED";
  91         }
  92         else
  93                 return buffer.text;
  94 }
  95
  96 int Messages::read_message(long *value1, long *value2)
  97 {
  98         char *data = read_message_raw();
  99         sscanf(data, "%ld %ld", value1, value2);
 100         return 0;
 101 }
 102
 103 int Messages::read_message_f(float *value1, float *value2)
 104 {
 105         char *data = read_message_raw();
 106         sscanf(data, "%f %f", value1, value2);
 107         return 0;
 108 }
 109
 110 int Messages::read_message(long *command, long *value1, long *value2)
 111 {
 112         char *data = read_message_raw();
 113         sscanf(data, "%ld %ld %ld", command, value1, value2);
 114         return 0;
 115 }
 116
 117 int Messages::read_message(long *command, long *value1, long *value2, long *value3)
 118 {
 119         char *data = read_message_raw();
 120         sscanf(data, "%ld %ld %ld %ld", command, value1, value2, value3);
 121         return 0;
 122 }
 123
 124 int Messages::read_message_f(float *value1, float *value2, float *value3)
 125 {
 126         char *data = read_message_raw();
 127         sscanf(data, "%f %f %f", value1, value2, value3);
 128         return 0;
 129 }
 130
 131 int Messages::read_message_f(float *value1, float *value2, float *value3, float *value4)
 132 {
 133         char *data = read_message_raw();
 134         sscanf(data, "%f %f %f %f", value1, value2, value3, value4);
 135         return 0;
 136 }
 137
 138 int Messages::read_message(int *command, char *text)
 139 {
 140         int i, j;
 141
 142         char *data = read_message_raw();
 143         sscanf(data, "%d", command);
 144 // find the start of the text
 145         for(i = 0; i < MESSAGESIZE && data[i] != ' '; i++) { ; }
 146 // get the space
 147         i++;
 148 // copy the text part
 149         for(j = 0; (text[j] = data[i]) != 0; i++, j++) { ; }
 150         return 0;
 151 }
 152
 153
 154 int Messages::write_message(char *text)
 155 {
 156         buffer.mtype = output_flag;
 157         strcpy(buffer.text, text);
 158
 159         if((msgsnd(msgid, (struct msgbuf*)&buffer, strlen(text) + 1, 0)) < 0) printf(_("send message failed\n"));
 160         return 0;
 161 }
 162
 163 int Messages::write_message_raw()
 164 {
 165         buffer.mtype = output_flag;
 166
 167         if((msgsnd(msgid, (struct msgbuf*)&buffer, strlen(buffer.text) + 1, 0)) < 0) printf(_("send message failed\n"));
 168         return 0;
 169 }
 170
 171 int Messages::write_message_flagged(int output_flag, int command)
 172 {
 173         buffer.mtype = output_flag;
 174         sprintf(buffer.text, "%d", command);
 175
 176         if((msgsnd(msgid, (struct msgbuf*)&buffer, strlen(buffer.text) + 1, 0)) < 0) printf(_("send message failed\n"));
 177         return 0;
 178 }
 179
 180 int Messages::write_message(int number)
 181 {
 182         sprintf(buffer.text, "%d", number);
 183         buffer.mtype = output_flag;
 184         if((msgsnd(msgid, (struct msgbuf*)&buffer, strlen(buffer.text) + 1, 0)) < 0) perror(_("Messages::write_message"));
 185         return 0;
 186 }
 187
 188 int Messages::write_message_f(float number)
 189 {
 190         sprintf(buffer.text, "%f", number);
 191         buffer.mtype = output_flag;
 192         if((msgsnd(msgid, (struct msgbuf*)&buffer, strlen(buffer.text) + 1, 0)) < 0) perror(_("Messages::write_message"));
 193         return 0;
 194 }
 195
 196 int Messages::write_message(int command, char *text)
 197 {
 198         sprintf(buffer.text, "%d %s", command, text);
 199         return write_message_raw();
 200 }
 201
 202 int Messages::write_message(long command, long value)
 203 {
 204         sprintf(buffer.text, "%ld %ld", command, value);
 205         return write_message_raw();
 206 }
 207
 208 int Messages::write_message_f(float value1, float value2)
 209 {
 210         sprintf(buffer.text, "%f %f", value1, value2);
 211         return write_message_raw();
 212 }
 213
 214 int Messages::write_message(long command, long value1, long value2)
 215 {
 216         sprintf(buffer.text, "%ld %ld %ld", command, value1, value2);
 217         return write_message_raw();
 218 }
 219
 220 int Messages::write_message(long command, long value1, long value2, long value3)
 221 {
 222         sprintf(buffer.text, "%ld %ld %ld %ld", command, value1, value2, value3);
 223         return write_message_raw();
 224 }
 225
 226 int Messages::write_message_f(float value1, float value2, float value3, float value4)
 227 {
 228         sprintf(buffer.text, "%f %f %f %f", value1, value2, value3, value4);
 229         return write_message_raw();
 230 }
 231
 232 int Messages::write_message_f(float value1, float value2, float value3)
 233 {
 234         sprintf(buffer.text, "%f %f %f", value1, value2, value3);
 235         return write_message_raw();
 236 }
 237
 238 int Messages::get_id()
 239 {
 240         return msgid;
 241 }