← Back to branch summary

~hilaire-fernandes/drgeo/trunk

« back to all changes in this revision

Viewing changes to VMs/iPad/source/unix/vm-display-X11/sqUnixMozilla.c

  • Committer: Hilaire Fernandes
  • Date: 2012-01-27 21:15:40 UTC
  • Revision ID: hilaire.fernandes@gmail.com-20120127211540-912spf97bhpx6mve
Initial additions

Show diffs side-by-side

added added

removed removed

Lines of Context:
VMs/iPad/source/unix/vm-display-X11/sqUnixMozilla.c
 
1
/* sqUnixMozilla.c -- support for Squeak Netscape plugin
 
2
 *
 
3
 * Author: Bert Freudenberg <bert@isg.cs.uni-magdeburg.de>
 
4
 * 
 
5
 * Last edited: 2007-09-07 13:53:35 by piumarta on emilia
 
6
 *
 
7
 * Originally based on Andreas Raab's sqWin32PluginSupport
 
8
 * 
 
9
 * Notes: The plugin window handling stuff is in sqXWindow.c.
 
10
 *        browserProcessCommand() is called when data is available
 
11
 */
 
12
 
 
13
#include "sq.h"
 
14
 
 
15
#if defined(USE_X11)
 
16
 
 
17
#include <X11/Xlib.h>
 
18
#include <X11/Xatom.h>
 
19
#include <unistd.h>
 
20
#include <stdarg.h>
 
21
#include <fcntl.h>
 
22
#include <errno.h>
 
23
 
 
24
#include "FilePlugin.h"
 
25
 
 
26
#undef DEBUG
 
27
 
 
28
#ifdef DEBUG
 
29
void DPRINT(char *format, ...)
 
30
{
 
31
  static int debug= 42;
 
32
  if (42 == debug) 
 
33
    debug= (NULL != getenv("NPSQUEAK_DEBUG"));
 
34
 
 
35
  if (!debug)
 
36
    {
 
37
      return;
 
38
    }
 
39
  else
 
40
    {
 
41
      static FILE *file= 0;
 
42
      if (!file) 
 
43
        {
 
44
          file= fopen("/tmp/npsqueak.log", "a+");
 
45
        }
 
46
 
 
47
      if (file) {
 
48
        va_list ap;
 
49
        va_start(ap, format);
 
50
        vfprintf(file, format, ap);
 
51
        va_end(ap);
 
52
        fflush(file);
 
53
      }
 
54
    }
 
55
}
 
56
#else
 
57
void DPRINT(char *format, ...) { }
 
58
#endif
 
59
 
 
60
/* from sqXWindow.c */
 
61
extern Display* stDisplay;
 
62
extern Window   stWindow;
 
63
extern Window   browserWindow;
 
64
extern Window   stParent;
 
65
extern int      browserPipes[2];
 
66
 
 
67
/* from interpret.c */
 
68
sqInt stackObjectValue(sqInt);
 
69
sqInt stackIntegerValue(sqInt);
 
70
sqInt isBytes(sqInt);
 
71
sqInt byteSizeOf(sqInt);
 
72
void *firstIndexableField(sqInt);
 
73
sqInt push(sqInt);
 
74
sqInt pop(sqInt);
 
75
sqInt positive32BitIntegerFor(sqInt);
 
76
sqInt nilObject(void);
 
77
sqInt instantiateClassindexableSize(sqInt, sqInt);
 
78
sqInt classByteArray(void);
 
79
sqInt failed(void);
 
80
sqInt pushBool(sqInt);
 
81
 
 
82
/* prototypes */
 
83
 
 
84
static void browserReceive(void *buf, size_t count);
 
85
static void browserSend(const void *buf, size_t count);
 
86
static void browserSendInt(int value);
 
87
static void browserReceiveData();
 
88
static void browserGetURLRequest(int id, char* url, int urlSize,
 
89
                                char* target, int targetSize);
 
90
static void browserPostURLRequest(int id, char* url, int urlSize, 
 
91
                                 char* target, int targetSize, 
 
92
                                 char* postData, int postDataSize);
 
93
 
 
94
typedef struct sqStreamRequest {
 
95
  char *localName;
 
96
  int semaIndex;
 
97
  int state;
 
98
} sqStreamRequest;
 
99
 
 
100
#define MAX_REQUESTS 128
 
101
 
 
102
#define SQUEAK_READ 0
 
103
#define SQUEAK_WRITE 1
 
104
 
 
105
#define inBrowser\
 
106
  (-1 != browserPipes[SQUEAK_READ])
 
107
 
 
108
#define CMD_BROWSER_WINDOW 1
 
109
#define CMD_GET_URL        2
 
110
#define CMD_POST_URL       3
 
111
#define CMD_RECEIVE_DATA   4
 
112
 
 
113
static sqStreamRequest *requests[MAX_REQUESTS];
 
114
 
 
115
 
 
116
 
 
117
/* primitives called from Squeak */
 
118
 
 
119
 
 
120
 
 
121
/*
 
122
  primitivePluginBrowserReady
 
123
  Return true if a connection to the browser
 
124
  has been established. Only necessary if some
 
125
  sort of asynchronous communications are used.
 
126
*/
 
127
int display_primitivePluginBrowserReady()
 
128
{
 
129
  if (inBrowser)
 
130
    {
 
131
      pop(1);
 
132
      pushBool(1);
 
133
    }
 
134
  else
 
135
    primitiveFail();
 
136
  return 1;
 
137
}
 
138
 
 
139
 
 
140
/*
 
141
  primitivePluginRequestUrlStream: url with: semaIndex
 
142
  Request a URL from the browser. Signal semaIndex
 
143
  when the result of the request can be queried.
 
144
  Returns a handle used in subsequent calls to plugin
 
145
  stream functions.
 
146
  Note: A request id is the index into requests[].
 
147
*/
 
148
int display_primitivePluginRequestURLStream()
 
149
{
 
150
  sqStreamRequest *req;
 
151
  int id, url, length, semaIndex;
 
152
 
 
153
  if (!inBrowser) return primitiveFail();
 
154
 
 
155
  DPRINT("VM: primitivePluginRequestURLStream()\n");
 
156
 
 
157
  for (id=0; id<MAX_REQUESTS; id++) {
 
158
    if (!requests[id]) break;
 
159
  }
 
160
  if (id >= MAX_REQUESTS) return primitiveFail();
 
161
 
 
162
  semaIndex= stackIntegerValue(0);
 
163
  url= stackObjectValue(1);
 
164
  if (failed()) return 0;
 
165
 
 
166
  if (!isBytes(url)) return primitiveFail();
 
167
 
 
168
  req= calloc(1, sizeof(sqStreamRequest));
 
169
  if (!req) return primitiveFail();
 
170
  req->localName= NULL;
 
171
  req->semaIndex= semaIndex;
 
172
  req->state= -1;
 
173
  requests[id]= req;
 
174
 
 
175
  length= byteSizeOf(url);
 
176
  browserGetURLRequest(id, firstIndexableField(url), length, NULL, 0);
 
177
  pop(3);
 
178
  push(positive32BitIntegerFor(id));
 
179
  DPRINT("VM:   request id: %i\n", id);
 
180
  return 1;
 
181
}
 
182
 
 
183
 
 
184
/*
 
185
  primitivePluginRequestURL: url target: target semaIndex: semaIndex
 
186
  Request a URL into the given target.
 
187
*/
 
188
int display_primitivePluginRequestURL()
 
189
{
 
190
  sqStreamRequest *req;
 
191
  int url, urlLength;
 
192
  int target, targetLength;
 
193
  int id, semaIndex;
 
194
 
 
195
  if (!browserWindow) return primitiveFail();
 
196
  for (id=0; id<MAX_REQUESTS; id++) {
 
197
    if (!requests[id]) break;
 
198
  }
 
199
 
 
200
  if (id >= MAX_REQUESTS) return primitiveFail();
 
201
 
 
202
  semaIndex= stackIntegerValue(0);
 
203
  target= stackObjectValue(1);
 
204
  url= stackObjectValue(2);
 
205
 
 
206
  if (failed()) return 0;
 
207
  if (!isBytes(url) || !isBytes(target)) return primitiveFail();
 
208
 
 
209
  urlLength= byteSizeOf(url);
 
210
  targetLength= byteSizeOf(target);
 
211
 
 
212
  req= calloc(1, sizeof(sqStreamRequest));
 
213
  if(!req) return primitiveFail();
 
214
  req->localName= NULL;
 
215
  req->semaIndex= semaIndex;
 
216
  req->state= -1;
 
217
  requests[id]= req;
 
218
 
 
219
  browserGetURLRequest(id, firstIndexableField(url), urlLength, firstIndexableField(target), targetLength);
 
220
  pop(4);
 
221
  push(positive32BitIntegerFor(id));
 
222
  return 1;
 
223
}
 
224
 
 
225
 
 
226
/*
 
227
  primitivePluginPostURL: url target: target data: data semaIndex: semaIndex
 
228
  Post data to a URL into the given target.
 
229
*/
 
230
int display_primitivePluginPostURL()
 
231
{
 
232
  sqStreamRequest *req;
 
233
  int url, urlLength;
 
234
  int target, targetLength;
 
235
  int data, dataLength;
 
236
  int id, semaIndex;
 
237
 
 
238
  if (!browserWindow) return primitiveFail();
 
239
  for (id=0; id<MAX_REQUESTS; id++) {
 
240
    if (!requests[id]) break;
 
241
  }
 
242
 
 
243
  if (id >= MAX_REQUESTS) return primitiveFail();
 
244
 
 
245
  semaIndex= stackIntegerValue(0);
 
246
  data= stackObjectValue(1);
 
247
  target= stackObjectValue(2);
 
248
  url= stackObjectValue(3);
 
249
 
 
250
  if (failed()) return 0;
 
251
  if (target == nilObject()) target= 0;
 
252
  if (!isBytes(url) || !isBytes(data) || !(!target || isBytes(target))) return primitiveFail();
 
253
 
 
254
  urlLength= byteSizeOf(url);
 
255
  targetLength= target ? byteSizeOf(target) : 0;
 
256
  dataLength= byteSizeOf(data);
 
257
 
 
258
  req= calloc(1, sizeof(sqStreamRequest));
 
259
  if(!req) return primitiveFail();
 
260
  req->localName= NULL;
 
261
  req->semaIndex= semaIndex;
 
262
  req->state= -1;
 
263
  requests[id]= req;
 
264
 
 
265
  browserPostURLRequest(id, firstIndexableField(url), urlLength, 
 
266
                        target ? firstIndexableField(target) : NULL, targetLength,
 
267
                        firstIndexableField(data), dataLength);
 
268
  pop(4);
 
269
  push(positive32BitIntegerFor(id));
 
270
  return 1;
 
271
}
 
272
 
 
273
/* 
 
274
  primitivePluginRequestFileHandle: id
 
275
  After a URL file request has been successfully
 
276
  completed, return a file handle for the received
 
277
  data. Note: The file handle must be read-only for
 
278
  security reasons.
 
279
*/
 
280
int display_primitivePluginRequestFileHandle()
 
281
{
 
282
  sqStreamRequest *req;
 
283
  int id, fileOop;
 
284
  void *openFn;
 
285
 
 
286
  id= stackIntegerValue(0);
 
287
  if (failed()) return 0;
 
288
  if (id < 0 || id >= MAX_REQUESTS) return primitiveFail();
 
289
 
 
290
  req= requests[id];
 
291
  if (!req || !req->localName) return primitiveFail();
 
292
 
 
293
  fileOop= nilObject();
 
294
 
 
295
  if (req->localName)
 
296
    {
 
297
      DPRINT("VM: Creating file handle for %s\n", req->localName);
 
298
 
 
299
      openFn= ioLoadFunctionFrom("fileOpenNamesizewritesecure", "FilePlugin");
 
300
      if (!openFn)
 
301
      {
 
302
        DPRINT("VM:   Couldn't load fileOpenName:size:write:secure: from FilePlugin!\n");
 
303
        return primitiveFail();
 
304
      }
 
305
  
 
306
      fileOop= ((sqInt (*)(char *, sqInt, sqInt, sqInt))openFn)
 
307
        (req->localName, strlen(req->localName), 0 /* readonly */, 0 /* insecure */);
 
308
 
 
309
      /* if file ends in a $, it was a temp link created by the plugin */
 
310
      if ('$' == req->localName[strlen(req->localName) - 1])
 
311
      {
 
312
        DPRINT("VM:   unlink %s\n", req->localName);
 
313
        if (-1 == unlink(req->localName))
 
314
          DPRINT("VM:   unlink failed: %s\n", strerror(errno));
 
315
      }
 
316
 
 
317
      if (failed()) 
 
318
        {
 
319
          DPRINT("VM:   file open failed\n");
 
320
          return 0;
 
321
        }
 
322
    }
 
323
  pop(2);
 
324
  push(fileOop);
 
325
  return 1;
 
326
}
 
327
 
 
328
 
 
329
/*
 
330
  primitivePluginDestroyRequest: id
 
331
  Destroy a request that has been issued before.
 
332
*/
 
333
sqInt display_primitivePluginDestroyRequest()
 
334
{
 
335
  sqStreamRequest *req;
 
336
  int id;
 
337
 
 
338
  id= stackIntegerValue(0);
 
339
  if (id < 0 || id >= MAX_REQUESTS) return primitiveFail();
 
340
  req= requests[id];
 
341
  if (req) {
 
342
    if (req->localName) free(req->localName);
 
343
    free(req);
 
344
  }
 
345
  requests[id]= NULL;
 
346
  pop(1);
 
347
  return 1;
 
348
}
 
349
 
 
350
 
 
351
/*
 
352
  primitivePluginRequestState: id
 
353
  Return true if the operation was successfully completed.
 
354
  Return false if the operation was aborted.
 
355
  Return nil if the operation is still in progress.
 
356
*/
 
357
sqInt display_primitivePluginRequestState()
 
358
{
 
359
  sqStreamRequest *req;
 
360
  int id;
 
361
 
 
362
  id= stackIntegerValue(0);
 
363
  if (id < 0 || id >= MAX_REQUESTS) return primitiveFail();
 
364
  req= requests[id];
 
365
  if (!req) return primitiveFail();
 
366
  pop(2);
 
367
  if (req->state == -1) push(nilObject());
 
368
  else pushBool(req->state);
 
369
  return 1;
 
370
}
 
371
 
 
372
 
 
373
 
 
374
/* helper functions */
 
375
 
 
376
static void browserReceive(void *buf, size_t count)
 
377
{
 
378
  ssize_t n;
 
379
  n= read(browserPipes[SQUEAK_READ], buf, count);
 
380
  if (n == -1)
 
381
    perror("Squeak read failed:");
 
382
  if (n < count)
 
383
    fprintf(stderr, "Squeak read too few data from pipe\n");
 
384
}
 
385
 
 
386
 
 
387
static void browserSend(const void *buf, size_t count)
 
388
{
 
389
  ssize_t n;
 
390
  n= write(browserPipes[SQUEAK_WRITE], buf, count);
 
391
  if (n == -1)
 
392
    perror("Squeak plugin write failed:");
 
393
  if (n < count)
 
394
    fprintf(stderr, "Squeak wrote too few data to pipe\n");
 
395
}
 
396
 
 
397
static void browserSendInt(int value)
 
398
{
 
399
  browserSend(&value, 4);
 
400
}
 
401
 
 
402
 
 
403
/*
 
404
  browserReceiveData:
 
405
  Called in response to a CMD_RECEIVE_DATA message.
 
406
  Retrieves the data file name and signals the semaphore.
 
407
*/
 
408
static void browserReceiveData()
 
409
{
 
410
  char *localName= NULL;
 
411
  int id, ok;
 
412
 
 
413
  browserReceive(&id, 4);
 
414
  browserReceive(&ok, 4);
 
415
 
 
416
  DPRINT("VM:  receiving data id: %i state %i\n", id, ok);
 
417
 
 
418
  if (ok == 1) {
 
419
    int length= 0;
 
420
    browserReceive(&length, 4);
 
421
    if (length) {
 
422
      localName= malloc(length+1);
 
423
      browserReceive(localName, length);
 
424
      localName[length]= 0;
 
425
      DPRINT("VM:   got filename %s\n", localName);
 
426
    }
 
427
  }
 
428
  if (id >= 0 && id < MAX_REQUESTS) {
 
429
    sqStreamRequest *req= requests[id];
 
430
    if (req) {
 
431
      req->localName= localName;
 
432
      req->state= ok;
 
433
      DPRINT("VM:  signaling semaphore, state=%i\n", ok);
 
434
      /*  synchronizedSignalSemaphoreWithIndex(req->semaIndex);*/
 
435
      signalSemaphoreWithIndex(req->semaIndex);
 
436
    }
 
437
  }
 
438
}
 
439
 
 
440
 
 
441
/*
 
442
  browserGetURLRequest:
 
443
  Notify plugin to get the specified url into target
 
444
*/
 
445
static void browserGetURLRequest(int id, char* url, int urlSize, 
 
446
                                char* target, int targetSize)
 
447
{
 
448
  if (!inBrowser) {
 
449
    fprintf(stderr, "Cannot submit URL request -- "
 
450
            "there is no connection to a browser\n");
 
451
    return;
 
452
  }
 
453
 
 
454
  browserSendInt(CMD_GET_URL);
 
455
  browserSendInt(id);
 
456
 
 
457
  browserSendInt(urlSize);
 
458
  if (urlSize > 0)
 
459
    browserSend(url, urlSize);
 
460
 
 
461
  browserSendInt(targetSize);
 
462
  if (targetSize > 0)
 
463
    browserSend(target, targetSize);
 
464
}
 
465
 
 
466
 
 
467
/*
 
468
  browserPostURLRequest:
 
469
  Notify plugin to post data to the specified url and get result into target
 
470
*/
 
471
static void browserPostURLRequest(int id, char* url, int urlSize, 
 
472
                                 char* target, int targetSize, 
 
473
                                 char* postData, int postDataSize)
 
474
{
 
475
  if (!inBrowser) {
 
476
    fprintf(stderr, "Cannot submit URL post request -- "
 
477
            "there is no connection to a browser\n");
 
478
    return;
 
479
  }
 
480
 
 
481
  browserSendInt(CMD_POST_URL);
 
482
  browserSendInt(id);
 
483
 
 
484
  browserSendInt(urlSize);
 
485
  if (urlSize > 0)
 
486
    browserSend(url, urlSize);
 
487
 
 
488
  browserSendInt(targetSize);
 
489
  if (targetSize > 0)
 
490
    browserSend(target, targetSize);
 
491
 
 
492
  browserSendInt(postDataSize);
 
493
  if (postDataSize > 0)
 
494
    browserSend(postData, postDataSize);
 
495
}
 
496
 
 
497
 
 
498
/***************************************************************
 
499
 * Functions called from sqXWindow.c
 
500
 ***************************************************************/
 
501
 
 
502
/*
 
503
  browserProcessCommand:
 
504
  Handle commands sent by the plugin.
 
505
*/
 
506
void browserProcessCommand(void)
 
507
{
 
508
  static int firstTime= 1;
 
509
  int cmd, n;
 
510
 
 
511
  if (firstTime)
 
512
    {
 
513
      firstTime= 0;
 
514
      /* enable non-blocking reads */
 
515
      fcntl(browserPipes[SQUEAK_READ], F_SETFL, O_NONBLOCK);
 
516
    }
 
517
  DPRINT("VM: browserProcessCommand()\n");
 
518
 
 
519
  n= read(browserPipes[SQUEAK_READ], &cmd, 4);
 
520
  if (0 == n || (-1 == n && EAGAIN == errno))
 
521
    return;
 
522
 
 
523
  switch (cmd)
 
524
    {
 
525
    case CMD_RECEIVE_DATA:
 
526
      /* Data is coming in */
 
527
      browserReceiveData();
 
528
      break;
 
529
    case CMD_BROWSER_WINDOW:
 
530
      /* Parent window has changed () */
 
531
      browserReceive(&browserWindow, 4);
 
532
      stParent= browserWindow;
 
533
      DPRINT("VM:  got browser window 0x%X\n", browserWindow);
 
534
      break;
 
535
    default:
 
536
      fprintf(stderr, "Unknown command from Plugin: %i\n", cmd);
 
537
    }
 
538
}
 
539
 
 
540
 
 
541
#else /* !defined(USE_X11) */
 
542
 
 
543
sqInt display_primitivePluginBrowserReady()             { return primitiveFail(); }
 
544
sqInt display_primitivePluginRequestURLStream()         { return primitiveFail(); }
 
545
sqInt display_primitivePluginRequestURL()               { return primitiveFail(); }
 
546
sqInt display_primitivePluginPostURL()                  { return primitiveFail(); }
 
547
sqInt display_primitivePluginRequestFileHandle()        { return primitiveFail(); }
 
548
sqInt display_primitivePluginDestroyRequest()           { return primitiveFail(); }
 
549
sqInt display_primitivePluginRequestState()             { return primitiveFail(); }
 
550
 
 
551
#endif