link.c

   1 /* lot's of code c&p-ed directly from mupdf */
   2 #ifdef _WIN32
   3 #define WIN32_LEAN_AND_MEAN
   4 #include <windows.h>
   5 #include <winsock2.h>
   6 #define ssize_t int
   7 #define FMT_ss "%d"
   8 #ifdef _WIN64
   9 #define FMT_s "%i64u"
  10 #else
  11 #define FMT_s "%u"
  12 #endif
  13 #pragma warning (disable:4244)
  14 #pragma warning (disable:4996)
  15 #pragma warning (disable:4995)
  16 #endif
  17
  18 #ifdef _MSC_VER
  19 #include <errno.h>
  20 #include <stdio.h>
  21 #include <string.h>
  22 #include <stdlib.h>
  23 static void __declspec (noreturn) err (int exitcode, const char *fmt, ...)
  24 {
  25     va_list ap;
  26     int errcode;
  27
  28     errcode = errno;
  29     va_start (ap, fmt);
  30     vfprintf (stderr, fmt, ap);
  31     va_end (ap);
  32     fprintf (stderr, ": %s\n", strerror (errno));
  33     exit (exitcode);
  34 }
  35 static void __declspec (noreturn) errx (int exitcode, const char *fmt, ...)
  36 {
  37     va_list ap;
  38
  39     va_start (ap, fmt);
  40     vfprintf (stderr, fmt, ap);
  41     va_end (ap);
  42     fputc ('\n', stderr);
  43     exit (exitcode);
  44 }
  45 static void __declspec (noreturn) sockerr (int exitcode, const char *fmt, ...)
  46 {
  47     va_list ap;
  48
  49     va_start (ap, fmt);
  50     vfprintf (stderr, fmt, ap);
  51     va_end (ap);
  52     fprintf (stderr, ": wsaerror 0x%x\n", WSAGetLastError ());
  53     exit (exitcode);
  54 }
  55 #else
  56 #define FMT_ss "%zd"
  57 #define FMT_s "%zu"
  58 #define _GNU_SOURCE
  59 #include <err.h>
  60 #define sockerr err
  61 #endif
  62 #include <regex.h>
  63 #include <errno.h>
  64 #include <ctype.h>
  65 #include <stdio.h>
  66 #include <stdarg.h>
  67 #include <stdlib.h>
  68 #include <string.h>
  69 #include <limits.h>
  70 #ifndef _WIN32
  71 #include <pthread.h>
  72 #include <sys/time.h>
  73 #include <sys/types.h>
  74 #include <sys/socket.h>
  75 #include <sys/select.h>
  76 #endif
  77
  78 #ifdef __APPLE__
  79 #include <OpenGL/gl.h>
  80 #else
  81 #include <GL/gl.h>
  82 #endif
  83
  84 #ifndef GL_TEXTURE_RECTANGLE_ARB
  85 #define GL_TEXTURE_RECTANGLE_ARB          0x84F5
  86 #endif
  87
  88 #include <caml/fail.h>
  89 #include <caml/alloc.h>
  90 #include <caml/memory.h>
  91 #include <caml/unixsupport.h>
  92
  93 #include <fitz.h>
  94 #include <mupdf.h>
  95
  96 #if 0
  97 #define lprintf printf
  98 #else
  99 #define lprintf(...)
 100 #endif
 101
 102 #define ARSERT(cond) for (;;) {                         \
 103     if (!(cond)) {                                      \
 104         errx (1, "%s:%d " #cond, __FILE__, __LINE__);   \
 105     }                                                   \
 106     break;                                              \
 107 }
 108
 109 struct slice {
 110     int texindex;
 111     int w, h;
 112 };
 113
 114 struct page {
 115     int pageno;
 116     int slicecount;
 117     fz_textspan *text;
 118     fz_pixmap *pixmap;
 119     pdf_page *drawpage;
 120     struct pagedim *pagedim;
 121     struct page *prev;
 122     struct mark {
 123         int i;
 124         fz_textspan *span;
 125     } fmark, lmark;
 126     struct slice slices[];
 127 };
 128
 129 struct pagedim {
 130     int pageno;
 131     int rotate;
 132     fz_rect box;
 133     fz_bbox bbox;
 134     fz_matrix ctm, ctm1;
 135 };
 136
 137 #if !defined _WIN32 && !defined __APPLE__
 138 #define USE_XSEL
 139 #endif
 140
 141 struct {
 142     int sock;
 143     int sliceheight;
 144     struct page *pages;
 145     struct pagedim *pagedims;
 146     int pagecount;
 147     int pagedimcount;
 148     pdf_xref *xref;
 149     fz_glyphcache *cache;
 150     int w, h;
 151
 152     int texindex;
 153     int texcount;
 154     GLuint *texids;
 155
 156     GLenum texform;
 157     GLenum texty;
 158
 159     int lotsamemory;
 160
 161     struct {
 162         int w, h;
 163         struct slice *slice;
 164     } *texowners;
 165
 166     int rotate;
 167
 168 #ifdef _WIN32
 169     HANDLE thread;
 170 #else
 171     pthread_t thread;
 172 #endif
 173     FILE *xselpipe;
 174 } state;
 175
 176 #ifdef _WIN32
 177 static CRITICAL_SECTION critsec;
 178
 179 static void lock (void *unused)
 180 {
 181     (void) unused;
 182     EnterCriticalSection (&critsec);
 183 }
 184
 185 static void unlock (void *unused)
 186 {
 187     (void) unused;
 188     LeaveCriticalSection (&critsec);
 189 }
 190
 191 static int trylock (void *unused)
 192 {
 193     return TryEnterCriticalSection (&critsec) == 0;
 194 }
 195 #else
 196 static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
 197
 198 static void lock (const char *cap)
 199 {
 200     int ret = pthread_mutex_lock (&mutex);
 201     if (ret) {
 202         errx (1, "%s: pthread_mutex_lock: %s", cap, strerror (ret));
 203     }
 204 }
 205
 206 static void unlock (const char *cap)
 207 {
 208     int ret = pthread_mutex_unlock (&mutex);
 209     if (ret) {
 210         errx (1, "%s: pthread_mutex_unlock: %s", cap, strerror (ret));
 211     }
 212 }
 213
 214 static int trylock (const char *cap)
 215 {
 216     int ret = pthread_mutex_trylock (&mutex);
 217
 218     if (ret && ret != EBUSY) {
 219         errx (1, "%s: pthread_mutex_trylock: %s", cap, strerror (ret));
 220     }
 221     return ret == EBUSY;
 222 }
 223 #endif
 224
 225 static void *parse_pointer (const char *cap, const char *s)
 226 {
 227     int ret;
 228     void *ptr;
 229
 230     ret = sscanf (s, "%p", &ptr);
 231     if (ret != 1) {
 232         errx (1, "%s: cannot parse pointer in `%s'", cap, s);
 233     }
 234     return ptr;
 235 }
 236
 237 static int hasdata (int sock)
 238 {
 239     int n;
 240     fd_set s;
 241     struct timeval tv;
 242     FD_ZERO (&s);
 243     FD_SET (sock, &s);
 244     tv.tv_sec = 0;
 245     tv.tv_usec = 0;
 246     n = select (sock + 1, &s, NULL, NULL, &tv);
 247     if (n == 0) return 0;
 248     if (n == 1) return 1;
 249     sockerr (1, "hasdata: select error ret=%d", n);
 250 }
 251
 252 static double now (void)
 253 {
 254     struct timeval tv;
 255
 256     if (gettimeofday (&tv, NULL)) {
 257         err (1, "gettimeofday");
 258     }
 259     return tv.tv_sec + tv.tv_usec*1e-6;
 260 }
 261
 262 static void readdata (int fd, char *p, int size)
 263 {
 264     ssize_t n;
 265
 266     n = recv (fd, p, size, 0);
 267     if (n - size) {
 268         if (!n) errx (1, "EOF while reading");
 269         sockerr (1, "recv (req %d, ret " FMT_ss ")", size, n);
 270     }
 271 }
 272
 273 static void writedata (int fd, char *p, int size)
 274 {
 275     char buf[4];
 276     ssize_t n;
 277
 278     buf[0] = (size >> 24) & 0xff;
 279     buf[1] = (size >> 16) & 0xff;
 280     buf[2] = (size >>  8) & 0xff;
 281     buf[3] = (size >>  0) & 0xff;
 282
 283     n = send (fd, buf, 4, 0);
 284     if (n != 4) {
 285         if (!n) errx (1, "EOF while writing length");
 286         sockerr (1, "send " FMT_ss, n);
 287     }
 288
 289     n = send (fd, p, size, 0);
 290     if (n - size) {
 291         if (!n) errx (1, "EOF while writing data");
 292         sockerr (1, "send (req %d, ret " FMT_ss ")", size, n);
 293     }
 294 }
 295
 296 static void
 297 #ifdef __GNUC__
 298 __attribute__ ((format (printf, 2, 3)))
 299 #endif
 300     printd (int fd, const char *fmt, ...)
 301 {
 302     int len;
 303     va_list ap;
 304     char buf[200];
 305
 306     va_start (ap, fmt);
 307     len = vsnprintf (buf, sizeof (buf), fmt, ap);
 308     va_end (ap);
 309     writedata (fd, buf, len);
 310 }
 311
 312 static void die (fz_error error)
 313 {
 314     fz_catch (error, "aborting");
 315     if (state.xref)
 316        pdf_freexref (state.xref);
 317     exit (1);
 318 }
 319
 320 static void openxref (char *filename)
 321 {
 322     int fd;
 323     fz_error error;
 324     fz_stream *file;
 325
 326     fd = open (filename, O_BINARY | O_RDONLY, 0666);
 327     if (fd < 0)
 328         die (fz_throw ("cannot open file '%s'", filename));
 329
 330     file = fz_openfile (fd);
 331     error = pdf_openxrefwithstream (&state.xref, file, NULL);
 332     if (error)
 333         die (fz_rethrow(error, "cannot open document '%s'", filename));
 334     fz_close (file);
 335
 336     if (pdf_needspassword (state.xref)) {
 337         die (fz_throw ("password protected"));
 338     }
 339
 340     error = pdf_loadpagetree (state.xref);
 341     if (error) {
 342         die (fz_throw ("cannot load page tree"));
 343     }
 344
 345     state.pagecount = pdf_getpagecount (state.xref);
 346 }
 347
 348 static int readlen (int fd)
 349 {
 350     ssize_t n;
 351     char p[4];
 352
 353     n = recv (fd, p, 4, 0);
 354     if (n != 4) {
 355         if (!n) errx (1, "EOF while reading length");
 356         sockerr (1, "recv " FMT_ss, n);
 357     }
 358
 359     return (p[0] << 24) | (p[1] << 16) | (p[2] << 8) | p[3];
 360 }
 361
 362 static void freepage (struct page *page)
 363 {
 364     int i;
 365     struct page *p;
 366
 367     fz_droppixmap (page->pixmap);
 368     for (p = state.pages; p; p = p->prev) {
 369         if (p->prev == page) {
 370             p->prev = page->prev;
 371             break;
 372         }
 373     }
 374     for (i = 0; i < page->slicecount; ++i) {
 375         struct slice *s = &page->slices[i];
 376         if (s->texindex != -1) {
 377             if (state.texowners[s->texindex].slice == s) {
 378                 state.texowners[s->texindex].slice = NULL;
 379                 ARSERT (state.texowners[s->texindex].w == s->w);
 380                 ARSERT (state.texowners[s->texindex].h >= s->h);
 381             }
 382         }
 383     }
 384     if (page->text) {
 385         fz_freetextspan (page->text);
 386     }
 387     if (page->drawpage) {
 388         pdf_freepage (page->drawpage);
 389     }
 390
 391     free (page);
 392 }
 393
 394 static void subdivide (struct page *p)
 395 {
 396     int i;
 397     int h = p->pixmap->h;
 398     int th = MIN (h, state.sliceheight);
 399
 400     for (i = 0; i < p->slicecount; ++i) {
 401         struct slice *s = &p->slices[i];
 402         s->texindex = -1;
 403         s->h = MIN (th, h);
 404         s->w = p->pixmap->w;
 405         h -= th;
 406     }
 407 }
 408
 409 static void *render (int pageno, int pindex)
 410 {
 411     fz_error error;
 412     int slicecount;
 413     fz_obj *pageobj;
 414     struct page *page;
 415     double start, end;
 416     pdf_page *drawpage;
 417     fz_device *idev;
 418     struct pagedim *pagedim;
 419
 420     start = now ();
 421     printd (state.sock, "V rendering %d", pageno);
 422
 423     pagedim = &state.pagedims[pindex];
 424     slicecount = (pagedim->bbox.y1 - pagedim->bbox.y0
 425                   + state.sliceheight - 1) / state.sliceheight;
 426     slicecount += slicecount == 0;
 427
 428     page = calloc (sizeof (*page)
 429                    + (slicecount * sizeof (struct slice)), 1);
 430     if (!page) {
 431         err (1, "calloc page %d\n", pageno);
 432     }
 433     page->slicecount = slicecount;
 434     page->prev = state.pages;
 435     state.pages = page;
 436
 437     pageobj = pdf_getpageobject (state.xref, pageno);
 438     if (!pageobj)
 439         die (fz_throw ("cannot retrieve info from page %d", pageno));
 440
 441     error = pdf_loadpage (&drawpage, state.xref, pageobj);
 442     if (error)
 443         die (error);
 444
 445     page->pixmap = fz_newpixmapwithrect (fz_devicergb, pagedim->bbox);
 446     fz_clearpixmap (page->pixmap, 0xFF);
 447
 448     idev = fz_newdrawdevice (state.cache, page->pixmap);
 449     if (!idev)
 450         die (fz_throw ("fz_newdrawdevice failed"));
 451     error = pdf_runpage (state.xref, drawpage, idev, pagedim->ctm);
 452     fz_freedevice (idev);
 453
 454     page->drawpage = drawpage;
 455     page->pagedim = pagedim;
 456     page->pageno = pageno;
 457     subdivide (page);
 458     end = now ();
 459
 460     if (!state.lotsamemory) {
 461         pdf_agestore(state.xref->store, 3);
 462     }
 463
 464     printd (state.sock, "V rendering %d took %f sec", pageno, end - start);
 465     return page;
 466 }
 467
 468 static void initpdims (void)
 469 {
 470     int pageno;
 471     double start, end;
 472
 473     start = now ();
 474     for (pageno = 0; pageno < state.pagecount; ++pageno) {
 475         int rotate;
 476         fz_rect box;
 477         struct pagedim *p;
 478         fz_obj *obj, *pageobj;
 479
 480         pageobj = pdf_getpageobject (state.xref, pageno + 1);
 481
 482         obj = fz_dictgets (pageobj, "CropBox");
 483         if (!fz_isarray (obj)) {
 484             obj = fz_dictgets (pageobj, "MediaBox");
 485             if (!fz_isarray (obj)) {
 486                 die (fz_throw ("cannot find page bounds %d (%d Rd)",
 487                                fz_tonum (pageobj), fz_togen (pageobj)));
 488             }
 489         }
 490         box = pdf_torect (obj);
 491
 492         obj = fz_dictgets (pageobj, "Rotate");
 493         if (fz_isint (obj)) {
 494             rotate = fz_toint (obj);
 495         }
 496         else  {
 497             rotate = 0;
 498         }
 499         rotate += state.rotate;
 500
 501         p = &state.pagedims[state.pagedimcount - 1];
 502         if ((state.pagedimcount == 0)
 503             || (p->rotate != rotate || memcmp (&p->box, &box, sizeof (box)))) {
 504             size_t size;
 505
 506             size = (state.pagedimcount + 1) * sizeof (*state.pagedims);
 507             state.pagedims = realloc (state.pagedims, size);
 508             if (!state.pagedims) {
 509                 err (1, "realloc pagedims to " FMT_s " (%d elems)",
 510                      size, state.pagedimcount + 1);
 511             }
 512             p = &state.pagedims[state.pagedimcount++];
 513             p->rotate = rotate;
 514             p->box = box;
 515             p->pageno = pageno;
 516         }
 517     }
 518     end = now ();
 519     printd (state.sock, "T Processed %d pages in %f seconds",
 520             state.pagecount, end - start);
 521 }
 522
 523 static void layout (void)
 524 {
 525     int pindex;
 526     fz_matrix ctm;
 527     fz_rect box, box2;
 528     double zoom, w;
 529     struct pagedim *p = state.pagedims;
 530
 531     pindex = 0;
 532     for (pindex = 0; pindex < state.pagedimcount; ++pindex, ++p) {
 533         box.x0 = MIN (p->box.x0, p->box.x1);
 534         box.y0 = MIN (p->box.y0, p->box.y1);
 535         box.x1 = MAX (p->box.x0, p->box.x1);
 536         box.y1 = MAX (p->box.y0, p->box.y1);
 537
 538         ctm = fz_identity;
 539         ctm = fz_concat (ctm, fz_translate (0, -box.y1));
 540         ctm = fz_concat (ctm, fz_rotate (p->rotate));
 541         box2 = fz_transformrect (ctm, box);
 542         w = box2.x1 - box2.x0;
 543
 544         zoom = (state.w / w);
 545         ctm = fz_identity;
 546         ctm = fz_concat (ctm, fz_translate (0, -box.y1));
 547         ctm = fz_concat (ctm, fz_scale (zoom, -zoom));
 548         memcpy (&p->ctm1, &ctm, sizeof (ctm));
 549         ctm = fz_concat (ctm, fz_rotate (p->rotate));
 550         p->bbox = fz_roundrect (fz_transformrect (ctm, box));
 551         memcpy (&p->ctm, &ctm, sizeof (ctm));
 552     }
 553
 554     while (p-- != state.pagedims)  {
 555         printd (state.sock, "l %d %d %d",
 556                 p->pageno, p->bbox.x1 - p->bbox.x0, p->bbox.y1 - p->bbox.y0);
 557     }
 558 }
 559
 560 static void recurse_outline (pdf_outline *outline, int level)
 561 {
 562     while (outline) {
 563         int i;
 564         fz_obj *obj;
 565         int top = 0;
 566         int pageno = -1;
 567
 568         if (!outline->link) goto next;
 569
 570         obj = outline->link->dest;
 571         if (fz_isindirect (obj)) {
 572             obj = fz_resolveindirect (obj);
 573         }
 574         if (fz_isarray (obj)) {
 575             fz_obj *obj2;
 576
 577             obj2 = fz_arrayget (obj, 0);
 578             if (fz_isint (obj2)) {
 579                 pageno = fz_toint (obj2);
 580             }
 581             else {
 582                 pageno = pdf_findpageobject (state.xref, obj2) - 1;
 583             }
 584
 585             if (fz_arraylen (obj) > 3) {
 586                 fz_point p;
 587                 struct pagedim *pagedim = state.pagedims;
 588
 589                 for (i = 0; i < state.pagedimcount; ++i) {
 590                     if (state.pagedims[i].pageno > pageno)
 591                         break;
 592                     pagedim = &state.pagedims[i];
 593                 }
 594
 595                 p.x = fz_toint (fz_arrayget (obj, 2));
 596                 p.y = fz_toint (fz_arrayget (obj, 3));
 597                 p = fz_transformpoint (pagedim->ctm, p);
 598                 top = p.y;
 599             }
 600         }
 601
 602         lprintf ("%*c%s %d\n", level, ' ', outline->title, pageno);
 603         printd (state.sock, "o %d %d %d %s",
 604                 level, pageno, top, outline->title);
 605     next:
 606         if (outline->child) {
 607             recurse_outline (outline->child, level + 1);
 608         }
 609         outline = outline->next;
 610     }
 611 }
 612
 613 static void process_outline (void)
 614 {
 615     pdf_outline *outline;
 616
 617     outline = pdf_loadoutline (state.xref);
 618     if (outline) {
 619         recurse_outline (outline, 0);
 620         pdf_freeoutline (outline);
 621     }
 622 }
 623
 624 static int comparespans (const void *l, const void *r)
 625 {
 626     fz_textspan const *const*ls = l;
 627     fz_textspan const *const*rs = r;
 628     return (*ls)->text->bbox.y0 - (*rs)->text->bbox.y0;
 629 }
 630
 631 /* wishful thinking function */
 632 static void search (regex_t *re, int pageno, int y, int forward)
 633 {
 634     int i, j;
 635     int ret;
 636     char *p;
 637     char buf[256];
 638     fz_matrix ctm;
 639     fz_error error;
 640     fz_obj *pageobj;
 641     fz_device *tdev;
 642     pdf_page *drawpage;
 643     fz_textspan *text, *span, **pspan;
 644     struct pagedim *pdim, *pdimprev;
 645     int stop = 0;
 646     int niters = 0;
 647     int nspans;
 648     double start, end;
 649
 650     start = now ();
 651     while (pageno >= 0 && pageno < state.pagecount && !stop) {
 652         if (niters++ == 5) {
 653             if (!state.lotsamemory) {
 654                 pdf_agestore(state.xref->store, 3);
 655             }
 656             niters = 0;
 657             if (hasdata (state.sock)) {
 658                 printd (state.sock, "T attention requested aborting search at %d",
 659                         pageno);
 660                 stop = 1;
 661             }
 662             else {
 663                 printd (state.sock, "T searching in page %d", pageno);
 664             }
 665         }
 666         pdimprev = NULL;
 667         for (i = 0; i < state.pagedimcount; ++i) {
 668             pdim = &state.pagedims[i];
 669             if (pdim->pageno == pageno)  {
 670                 goto found;
 671             }
 672             if (pdim->pageno > pageno) {
 673                 pdim = pdimprev;
 674                 goto found;
 675             }
 676             pdimprev = pdim;
 677         }
 678         pdim = pdimprev;
 679     found:
 680
 681         pageobj = pdf_getpageobject (state.xref, pageno + 1);
 682         if (!pageobj)
 683             die (fz_throw ("cannot retrieve info from page %d", pageno));
 684
 685         error = pdf_loadpage (&drawpage, state.xref, pageobj);
 686         if (error)
 687             die (error);
 688
 689         ctm = fz_rotate (pdim->rotate);
 690
 691         text = fz_newtextspan ();
 692         tdev = fz_newtextdevice (text);
 693         error = pdf_runpage (state.xref, drawpage, tdev, pdim->ctm1);
 694         if (error) die (error);
 695         fz_freedevice (tdev);
 696
 697         nspans = 0;
 698         for (span = text; span; span = span->next) {
 699             nspans++;
 700         }
 701         pspan = malloc (sizeof (void *) * nspans);
 702         if (!pspan) {
 703             err (1, "malloc span pointers " FMT_s, sizeof (void *) * nspans);
 704         }
 705         for (i = 0, span = text; span; span = span->next, ++i) {
 706             pspan[i] = span;
 707         }
 708         qsort (pspan, nspans, sizeof (fz_textspan *), comparespans);
 709
 710         j = forward ? 0 : nspans - 1;
 711         while (nspans--) {
 712             regmatch_t rm;
 713
 714             span = pspan[j];
 715             j += forward ? 1 : -1;
 716             p = buf;
 717             for (i = 0; i < MIN (span->len, (int) sizeof (buf) - 1); ++i) {
 718                 if (forward) {
 719                     if (span->text[i].bbox.y0 < y + 1) {
 720                         continue;
 721                     }
 722                 }
 723                 else {
 724                     if (span->text[i].bbox.y0 > y - 1) {
 725                         continue;
 726                     }
 727                 }
 728                 if (span->text[i].c < 256) {
 729                     *p++ = span->text[i].c;
 730                 }
 731                 else  {
 732                     *p++ = '?';
 733                 }
 734             }
 735             if (p == buf) {
 736                 continue;
 737             }
 738             *p++ = 0;
 739
 740             ret = regexec (re, buf, 1, &rm, 0);
 741             if (ret)  {
 742                 if (ret != REG_NOMATCH) {
 743                     size_t size;
 744                     char errbuf[80];
 745                     size = regerror (ret, re, errbuf, sizeof (errbuf));
 746                     printd (state.sock,
 747                             "T regexec error `%.*s'",
 748                             (int) size, errbuf);
 749                     fz_freetextspan (text);
 750                     pdf_freepage (drawpage);
 751                     free (pspan);
 752                     return;
 753                 }
 754             }
 755             else  {
 756                 int xoff, yoff;
 757                 fz_bbox *sb, *eb;
 758                 fz_point p1, p2, p3, p4;
 759
 760                 xoff = -pdim->bbox.x0;
 761                 yoff = -pdim->bbox.y0;
 762
 763                 sb = &span->text[rm.rm_so].bbox;
 764                 eb = &span->text[rm.rm_eo - 1].bbox;
 765
 766                 p1.x = sb->x0;
 767                 p1.y = sb->y0;
 768                 p2.x = eb->x1;
 769                 p2.y = sb->y0;
 770                 p3.x = eb->x1;
 771                 p3.y = eb->y1;
 772                 p4.x = sb->x0;
 773                 p4.y = eb->y1;
 774
 775                 p1 = fz_transformpoint (ctm, p1);
 776                 p2 = fz_transformpoint (ctm, p2);
 777                 p3 = fz_transformpoint (ctm, p3);
 778                 p4 = fz_transformpoint (ctm, p4);
 779
 780                 if (!stop) {
 781                     printd (state.sock, "F %d %d %f %f %f %f %f %f %f %f",
 782                             pageno, 1,
 783                             p1.x + xoff, p1.y + yoff,
 784                             p2.x + xoff, p2.y + yoff,
 785                             p3.x + xoff, p3.y + yoff,
 786                             p4.x + xoff, p4.y + yoff);
 787
 788                     printd (state.sock, "T found at %d `%.*s' in %f sec",
 789                             pageno, rm.rm_eo - rm.rm_so, &buf[rm.rm_so],
 790                             now () - start);
 791                 }
 792                 else  {
 793                     printd (state.sock, "R %d %d %f %f %f %f %f %f %f %f",
 794                             pageno, 2,
 795                             p1.x + xoff, p1.y + yoff,
 796                             p2.x + xoff, p2.y + yoff,
 797                             p3.x + xoff, p3.y + yoff,
 798                             p4.x + xoff, p4.y + yoff);
 799                 }
 800                 stop = 1;
 801             }
 802         }
 803         if (forward) {
 804             pageno += 1;
 805             y = 0;
 806         }
 807         else {
 808             pageno -= 1;
 809             y = INT_MAX;
 810         }
 811         fz_freetextspan (text);
 812         pdf_freepage (drawpage);
 813         free (pspan);
 814     }
 815     end = now ();
 816     if (!stop)  {
 817         printd (state.sock, "T no matches %f sec", end - start);
 818     }
 819     printd (state.sock, "D");
 820 }
 821
 822 static
 823 #ifdef _WIN32
 824 DWORD _stdcall
 825 #else
 826 void *
 827 #endif
 828 mainloop (void *unused)
 829 {
 830     char *p = NULL;
 831     int len, ret, oldlen = 0;
 832
 833     for (;;) {
 834         len = readlen (state.sock);
 835         if (len == 0) {
 836             errx (1, "readlen returned 0");
 837         }
 838
 839         if (oldlen < len + 1) {
 840             p = realloc (p, len + 1);
 841             if (!p) {
 842                 err (1, "realloc %d failed", len + 1);
 843             }
 844             oldlen = len + 1;
 845         }
 846         readdata (state.sock, p, len);
 847         p[len] = 0;
 848
 849         if (!strncmp ("open", p, 4)) {
 850             fz_obj *obj;
 851             char *filename = p + 5;
 852
 853             openxref (filename);
 854             initpdims ();
 855
 856             obj = fz_dictgets (state.xref->trailer, "Info");
 857             if (obj) {
 858                 obj = fz_dictgets (obj, "Title");
 859                 if (obj) {
 860                     printd (state.sock, "t %s", pdf_toutf8 (obj));
 861                 }
 862             }
 863         }
 864         else if (!strncmp ("free", p, 4)) {
 865             void *ptr;
 866
 867             ret = sscanf (p + 4, " %p", &ptr);
 868             if (ret != 1) {
 869                 errx (1, "malformed free `%.*s' ret=%d", len, p, ret);
 870             }
 871             lock ("free");
 872             freepage (ptr);
 873             unlock ("free");
 874             printd (state.sock, "d");
 875         }
 876         else if (!strncmp ("search", p, 6)) {
 877             int icase, pageno, y, ret, len2, forward;
 878             char *pattern;
 879             regex_t re;
 880
 881             ret = sscanf (p + 6, " %d %d %d %d,%n",
 882                           &icase, &pageno, &y, &forward, &len2);
 883             if (ret != 4) {
 884                 errx (1, "malformed search `%s' ret=%d", p, ret);
 885             }
 886
 887             pattern = p + 6 + len2;
 888             ret = regcomp (&re, pattern,
 889                            REG_EXTENDED | (icase ? REG_ICASE : 0));
 890             if (ret) {
 891                 char errbuf[80];
 892                 size_t size;
 893
 894                 size = regerror (ret, &re, errbuf, sizeof (errbuf));
 895                 printd (state.sock, "T regcomp failed `%.*s'",
 896                         (int) size, errbuf);
 897             }
 898             else  {
 899                 search (&re, pageno, y, forward);
 900                 regfree (&re);
 901             }
 902         }
 903         else if (!strncmp ("geometry", p, 8)) {
 904             int w, h;
 905
 906             printd (state.sock, "c");
 907             ret = sscanf (p + 8, " %d %d", &w, &h);
 908             if (ret != 2) {
 909                 errx (1, "malformed geometry `%.*s' ret=%d", len, p, ret);
 910             }
 911             state.h = h;
 912             if (w != state.w) {
 913                 int i;
 914                 state.w = w;
 915                 for (i = 0; i < state.texcount; ++i)  {
 916                     state.texowners[i].slice = NULL;
 917                 }
 918             }
 919             lock ("geometry");
 920             layout ();
 921             process_outline ();
 922             unlock ("geometry");
 923             printd (state.sock, "C %d", state.pagecount);
 924         }
 925         else if (!strncmp ("rotate", p, 6)) {
 926             float rotate;
 927
 928             printd (state.sock, "c");
 929             ret = sscanf (p + 6, " %f", &rotate);
 930             if (ret != 1) {
 931                 errx (1, "bad rotate line `%.*s' ret=%d", len, p, ret);
 932             }
 933             state.rotate = rotate;
 934             lock ("rotate");
 935             state.pagedimcount = 0;
 936             free (state.pagedims);
 937             state.pagedims = NULL;
 938             initpdims ();
 939             layout ();
 940             process_outline ();
 941             unlock ("rotate");
 942             printd (state.sock, "C %d", state.pagecount);
 943         }
 944         else if (!strncmp ("render", p, 6)) {
 945             int pageno, pindex, w, h, ret;
 946             struct page *page;
 947
 948             ret = sscanf (p + 6, " %d %d %d %d", &pageno, &pindex, &w, &h);
 949             if (ret != 4) {
 950                 errx (1, "bad render line `%.*s' ret=%d", len, p, ret);
 951             }
 952
 953             page = render (pageno, pindex);
 954             printd (state.sock, "r %d %d %d %d %p\n",
 955                     pageno,
 956                     state.w,
 957                     state.h,
 958                     state.rotate,
 959                     page);
 960         }
 961         else if (!strncmp ("interrupt", p, 8)) {
 962             printd (state.sock, "V interrupted");
 963         }
 964         else {
 965             errx (1, "unknown command %.*s", len, p);
 966         }
 967     }
 968     return 0;
 969 }
 970
 971 static void showsel (struct page *page, int oy)
 972 {
 973     int ox;
 974     fz_bbox bbox;
 975     fz_textspan *span;
 976     struct mark first, last;
 977
 978     first = page->fmark;
 979     last = page->lmark;
 980
 981     if (!first.span || !last.span) return;
 982
 983     glEnable (GL_BLEND);
 984     glBlendFunc (GL_SRC_ALPHA, GL_SRC_ALPHA);
 985     glColor4f (0.5f, 0.5f, 0.0f, 0.6f);
 986
 987     for (span = first.span; span; span = span->next) {
 988         int i, j, k;
 989
 990         bbox.x0 = bbox.y0 = bbox.x1 = bbox.y1 = 0;
 991
 992         j = 0;
 993         k = span->len - 1;
 994
 995         if (span == page->fmark.span && span == page->lmark.span) {
 996             j = MIN (first.i, last.i);
 997             k = MAX (first.i, last.i);
 998         }
 999         else if (span == first.span) {
1000             j = first.i;
1001         }
1002         else if (span == last.span) {
1003             k = last.i;
1004         }
1005
1006         for (i = j; i <= k; ++i) {
1007             bbox = fz_unionbbox (bbox, span->text[i].bbox);
1008         }
1009         oy += page->pixmap->y;
1010         ox = -page->pixmap->x;
1011         lprintf ("%d %d %d %d oy=%d ox=%d\n",
1012                  bbox.x0,
1013                  bbox.y0,
1014                  bbox.x1,
1015                  bbox.y1,
1016                  oy, ox);
1017
1018         glRecti (bbox.x0 + ox, bbox.y0 + oy, bbox.x1 + ox, bbox.y1 + oy);
1019
1020         if (span == last.span) break;
1021     }
1022     glDisable (GL_BLEND);
1023 }
1024
1025 static void upload2 (struct page *page, int slicenum, const char *cap)
1026 {
1027     int i;
1028     int w, h;
1029     double start, end;
1030     struct slice *slice = &page->slices[slicenum];
1031
1032     w = page->pixmap->w;
1033     h = page->pixmap->h;
1034
1035     ARSERT (w == slice->w);
1036     if (slice->texindex != -1
1037         && state.texowners[slice->texindex].slice == slice) {
1038         glBindTexture (GL_TEXTURE_RECTANGLE_ARB, state.texids[slice->texindex]);
1039     }
1040     else  {
1041         int subimage = 0;
1042         int index = (state.texindex++ % state.texcount);
1043         size_t offset = 0;
1044
1045         for (i = 0; i < slicenum; ++i) {
1046             offset += w * page->slices[i].h * 4;
1047         }
1048
1049         if (state.texowners[index].w == slice->w) {
1050             if (state.texowners[index].h >= slice->h ) {
1051                 subimage = 1;
1052             }
1053             else {
1054                 state.texowners[index].h = slice->h;
1055             }
1056         }
1057         else  {
1058             state.texowners[index].h = slice->h;
1059         }
1060
1061         state.texowners[index].slice = slice;
1062         state.texowners[index].w = slice->w;
1063         slice->texindex = index;
1064
1065         glBindTexture (GL_TEXTURE_RECTANGLE_ARB, state.texids[slice->texindex]);
1066         start = now ();
1067         if (subimage) {
1068             {
1069                 GLenum err = glGetError ();
1070                 if (err != GL_NO_ERROR) {
1071                     printf ("\033[0;31mERROR1 %d %d %#x\033[0m\n", w, slice->h, err);
1072                     abort ();
1073                 }
1074             }
1075             glTexSubImage2D (GL_TEXTURE_RECTANGLE_ARB,
1076                              0,
1077                              0,
1078                              0,
1079                              w,
1080                              slice->h,
1081                              state.texform,
1082                              state.texty,
1083                              page->pixmap->samples + offset
1084                 );
1085             {
1086                 GLenum err = glGetError ();
1087                 if (err != GL_NO_ERROR) {
1088                     printf ("\033[0;31mERROR %d %d %#x\033[0m\n", w, slice->h, err);
1089                     abort ();
1090                 }
1091             }
1092         }
1093         else {
1094             glTexImage2D (GL_TEXTURE_RECTANGLE_ARB,
1095                           0,
1096                           GL_RGBA8,
1097                           w,
1098                           slice->h,
1099                           0,
1100                           state.texform,
1101                           state.texty,
1102                           page->pixmap->samples + offset
1103                 );
1104         }
1105
1106         end = now ();
1107         lprintf ("%s[%d] slice=%d(%d,%d) texid=%d %f sec\n",
1108                  subimage ? "sub" : "img",
1109                  page->pageno, slicenum,
1110                  slice->w, slice->h,
1111                  state.texids[slice->texindex],
1112                  end - start);
1113     }
1114 }
1115
1116 CAMLprim value ml_draw (value dispy_v, value w_v, value h_v,
1117                         value py_v, value ptr_v)
1118 {
1119     CAMLparam5 (dispy_v, w_v, h_v, py_v, ptr_v);
1120     int dispy = Int_val (dispy_v);
1121     int w = Int_val (w_v);
1122     int h = Int_val (h_v);
1123     int py = Int_val (py_v);
1124     char *s = String_val (ptr_v);
1125     int ret;
1126     void *ptr;
1127     struct page *page;
1128     int slicenum = 0;
1129
1130     if (trylock ("ml_draw")) {
1131         goto done;
1132     }
1133
1134     ret = sscanf (s, "%p", &ptr);
1135     if (ret != 1) {
1136         errx (1, "cannot parse pointer `%s'", s);
1137     }
1138     page = ptr;
1139
1140     w = page->pixmap->w;
1141
1142     ARSERT (h >= 0 && "ml_draw wrong h");
1143     ARSERT (py <= page->pixmap->h && "ml_draw wrong py");
1144
1145     glEnable (GL_TEXTURE_RECTANGLE_ARB);
1146
1147     for (slicenum = 0; slicenum < page->slicecount; ++slicenum) {
1148         struct slice *slice = &page->slices[slicenum];
1149         if (slice->h > py) {
1150             break;
1151         }
1152         py -= slice->h;
1153     }
1154
1155     h = MIN (state.h, h);
1156     while (h) {
1157         int th;
1158         struct slice *slice = &page->slices[slicenum];
1159
1160         ARSERT (slicenum < page->slicecount && "ml_draw wrong slicenum");
1161
1162         th = MIN (h, slice->h - py);
1163         upload2 (page, slicenum, "upload");
1164
1165         glBegin (GL_QUADS);
1166         {
1167             glTexCoord2i (0, py);
1168             glVertex2i (0, dispy);
1169
1170             glTexCoord2i (w, py);
1171             glVertex2i (w, dispy);
1172
1173             glTexCoord2i (w, py+th);
1174             glVertex2i (w, dispy + th);
1175
1176             glTexCoord2i (0, py+th);
1177             glVertex2i (0, dispy + th);
1178         }
1179         glEnd ();
1180
1181         h -= th;
1182         py = 0;
1183         dispy += th;
1184         slicenum += 1;
1185     }
1186
1187     showsel (page, Int_val (dispy_v) - Int_val (py_v));
1188     glDisable (GL_TEXTURE_RECTANGLE_ARB);
1189
1190     unlock ("ml_draw");
1191  done:
1192     CAMLreturn (Val_unit);
1193 }
1194
1195 static pdf_link *getlink (struct page *page, int x, int y)
1196 {
1197     fz_point p;
1198     fz_matrix ctm;
1199     pdf_link *link;
1200
1201     p.x = x + page->pixmap->x;
1202     p.y = y + page->pixmap->y;
1203
1204     ctm = fz_invertmatrix (page->pagedim->ctm);
1205     p = fz_transformpoint (ctm, p);
1206
1207     for (link = page->drawpage->links; link; link = link->next) {
1208         if (p.x >= link->rect.x0 && p.x <= link->rect.x1) {
1209             if (p.y >= link->rect.y0 && p.y <= link->rect.y1) {
1210                 return link;
1211             }
1212         }
1213     }
1214     return NULL;
1215 }
1216
1217 CAMLprim value ml_highlightlinks (value ptr_v, value yoff_v)
1218 {
1219     CAMLparam2 (ptr_v, yoff_v);
1220     pdf_link *link;
1221     struct page *page;
1222     int xoff, yoff = Int_val (yoff_v);
1223     const char *s = String_val (ptr_v);
1224
1225     if (trylock ("ml_highlightlinks")) {
1226         goto done;
1227     }
1228
1229     page = parse_pointer ("ml_highlightlinks", s);
1230
1231     glPolygonMode (GL_FRONT_AND_BACK, GL_LINE);
1232     glEnable (GL_LINE_STIPPLE);
1233     glLineStipple (0.5, 0xcccc);
1234
1235     xoff = -page->pixmap->x;
1236     yoff -= page->pixmap->y;
1237
1238     glBegin (GL_QUADS);
1239     for (link = page->drawpage->links; link; link = link->next) {
1240         fz_point p1, p2, p3, p4;
1241         fz_matrix ctm = page->pagedim->ctm;
1242
1243         p1.x = link->rect.x0;
1244         p1.y = link->rect.y0;
1245
1246         p2.x = link->rect.x1;
1247         p2.y = link->rect.y0;
1248
1249         p3.x = link->rect.x1;
1250         p3.y = link->rect.y1;
1251
1252         p4.x = link->rect.x0;
1253         p4.y = link->rect.y1;
1254
1255         p1 = fz_transformpoint (ctm, p1);
1256         p2 = fz_transformpoint (ctm, p2);
1257         p3 = fz_transformpoint (ctm, p3);
1258         p4 = fz_transformpoint (ctm, p4);
1259
1260         switch (link->kind) {
1261         case PDF_LGOTO: glColor3ub (255, 0, 0); break;
1262         case PDF_LURI: glColor3ub (0, 0, 255); break;
1263         default: glColor3ub (0, 0, 0); break;
1264         }
1265
1266         glVertex2f (p1.x + xoff, p1.y + yoff);
1267         glVertex2f (p2.x + xoff, p2.y + yoff);
1268         glVertex2f (p3.x + xoff, p3.y + yoff);
1269         glVertex2f (p4.x + xoff, p4.y + yoff);
1270     }
1271     glEnd ();
1272
1273     glPolygonMode (GL_FRONT_AND_BACK, GL_FILL);
1274     glDisable (GL_LINE_STIPPLE);
1275     unlock ("ml_highlightlinks");
1276
1277  done:
1278     CAMLreturn (Val_unit);
1279 }
1280
1281 CAMLprim value ml_getlink (value ptr_v, value x_v, value y_v)
1282 {
1283     CAMLparam3 (ptr_v, x_v, y_v);
1284     CAMLlocal2 (ret_v, tup_v);
1285     pdf_link *link;
1286     struct page *page;
1287     char *s = String_val (ptr_v);
1288
1289     ret_v = Val_int (0);
1290     if (trylock ("ml_getlink")) {
1291         ret_v = Val_int (0);
1292         goto done;
1293     }
1294
1295     page = parse_pointer ("ml_getlink", s);
1296
1297     link = getlink (page, Int_val (x_v), Int_val (y_v));
1298     if (link) {
1299         switch (link->kind) {
1300         case PDF_LGOTO:
1301             {
1302                 int pageno;
1303                 fz_point p;
1304                 fz_obj *obj;
1305
1306                 pageno = -1;
1307                 obj = fz_arrayget (link->dest, 0);
1308                 if (fz_isindirect (obj)) {
1309                     pageno = pdf_findpageobject (state.xref, obj) - 1;
1310                 }
1311                 else if (fz_isint (obj)) {
1312                     pageno = fz_toint (obj);
1313                 }
1314
1315                 p.x = 0.0;
1316                 p.y = 0.0;
1317                 if (fz_arraylen (link->dest) > 3) {
1318                     fz_obj *xo, *yo;
1319
1320                     xo = fz_arrayget (link->dest, 2);
1321                     yo = fz_arrayget (link->dest, 3);
1322                     if (!fz_isnull (xo) && !fz_isnull (yo)) {
1323                         p.x = fz_toint (xo);
1324                         p.y = fz_toint (yo);
1325                         p = fz_transformpoint (page->pagedim->ctm, p);
1326                     }
1327                 }
1328
1329                 tup_v = caml_alloc_tuple (2);
1330                 ret_v = caml_alloc_small (1, 1);
1331                 Field (tup_v, 0) = Val_int (pageno);
1332                 Field (tup_v, 1) = Val_int (p.y);
1333                 Field (ret_v, 0) = tup_v;
1334             }
1335             break;
1336
1337         case PDF_LURI:
1338             ret_v = caml_alloc_small (1, 0);
1339             Field (ret_v, 0) = caml_copy_string (fz_tostrbuf (link->dest));
1340             break;
1341
1342         default:
1343             printd (state.sock, "T unhandled link kind %d", link->kind);
1344             break;
1345         }
1346     }
1347     unlock ("ml_getlink");
1348
1349  done:
1350     CAMLreturn (ret_v);
1351 }
1352
1353 CAMLprim value ml_seltext (value ptr_v, value rect_v, value oy_v)
1354 {
1355     CAMLparam4 (ptr_v, rect_v, oy_v, rect_v);
1356     fz_bbox *b;
1357     struct page *page;
1358     fz_textspan *span;
1359     struct mark first, last;
1360     int i, x0, x1, y0, y1, oy;
1361     char *s = String_val (ptr_v);
1362
1363     if (trylock ("ml_seltext")) {
1364         goto done;
1365     }
1366
1367     page = parse_pointer ("ml_seltext", s);
1368
1369     oy = Int_val (oy_v);
1370     x0 = Int_val (Field (rect_v, 0));
1371     y0 = Int_val (Field (rect_v, 1));
1372     x1 = Int_val (Field (rect_v, 2));
1373     y1 = Int_val (Field (rect_v, 3));
1374
1375     if (0) {
1376         glPolygonMode (GL_FRONT_AND_BACK, GL_LINE);
1377         glColor3ub (128, 128, 128);
1378         glRecti (x0, y0, x1, y1);
1379         glPolygonMode (GL_FRONT_AND_BACK, GL_FILL);
1380     }
1381
1382     if (!page->text) {
1383         fz_error error;
1384         fz_device *tdev;
1385
1386         page->text = fz_newtextspan ();
1387         tdev = fz_newtextdevice (page->text);
1388         error = pdf_runpage (state.xref, page->drawpage, tdev,
1389                              page->pagedim->ctm);
1390         if (error) die (error);
1391         fz_freedevice (tdev);
1392     }
1393
1394     x0 += page->pixmap->x;
1395     y0 += page->pixmap->y - oy;
1396     x1 += page->pixmap->x;
1397     y1 += page->pixmap->y - oy;
1398
1399     first.span = NULL;
1400     last.span = NULL;
1401
1402     first.i = 0;
1403     first.span = page->text;
1404     for (span = page->text; span; span = span->next) {
1405         for (i = 0; i < span->len; ++i) {
1406             b = &span->text[i].bbox;
1407             if (x0 >= b->x0 && x0 <= b->x1 && y0 >= b->y0 && y0 <= b->y1) {
1408                 first.i = i;
1409                 first.span = span;
1410             }
1411             if (x1 >= b->x0 && x1 <= b->x1 && y1 >= b->y0 && y1 <= b->y1) {
1412                 last.i = i;
1413                 last.span = span;
1414             }
1415         }
1416     }
1417
1418     if (y1 < y0 || x1 < x0) {
1419         int swap = 0;
1420
1421         if (first.span == last.span)  {
1422             swap = 1;
1423         }
1424         else {
1425             if (y1 < y0) {
1426                 for (span = first.span; span && span != last.span;
1427                      span = span->next) {
1428                     if (span->eol) {
1429                         swap = 1;
1430                         break;
1431                     }
1432                 }
1433             }
1434         }
1435
1436         if (swap) {
1437             i = first.i;
1438             span = first.span;
1439             first.i = last.i;
1440             first.span = last.span;
1441             last.i = i;
1442             last.span = span;
1443         }
1444     }
1445
1446     page->fmark = first;
1447     page->lmark = last;
1448
1449     unlock ("ml_seltext");
1450
1451  done:
1452     CAMLreturn (Val_unit);
1453 }
1454
1455 static int pipespan (FILE *f, fz_textspan *span, int a, int b)
1456 {
1457     char buf[4];
1458     int i, len, ret;
1459
1460     for (i = a; i <= b; ++i) {
1461         len = runetochar (buf, &span->text[i].c);
1462         ret = fwrite (buf, len, 1, f);
1463
1464         if (ret != 1) {
1465             printd (state.sock, "T failed to write %d bytes ret=%d: %s",
1466                     len, ret, strerror (errno));
1467             return -1;
1468         }
1469     }
1470     return 0;
1471 }
1472
1473 CAMLprim value ml_copysel (value ptr_v)
1474 {
1475     CAMLparam1 (ptr_v);
1476     FILE *f;
1477     struct page *page;
1478     char *s = String_val (ptr_v);
1479
1480     if (trylock ("ml_copysel")) {
1481         goto done;
1482     }
1483
1484     if (!*s)  {
1485     close:
1486 #ifdef USE_XSEL
1487         if (state.xselpipe) {
1488             int ret = pclose (state.xselpipe);
1489             if (ret)  {
1490                 printd (state.sock, "T failed to close xsel pipe `%s'",
1491                         strerror (errno));
1492             }
1493             state.xselpipe = NULL;
1494         }
1495 #else
1496         printf ("========================================\n");
1497 #endif
1498     }
1499     else {
1500         fz_textspan *span;
1501
1502         page = parse_pointer ("ml_sopysel", s);
1503
1504         if (!page->fmark.span || !page->lmark.span) {
1505             printd (state.sock, "T nothing to copy");
1506             goto unlock;
1507         }
1508
1509         f = stdout;
1510 #ifdef USE_XSEL
1511         if (!state.xselpipe) {
1512             state.xselpipe = popen ("xsel -i", "w");
1513             if (!state.xselpipe) {
1514                 printd (state.sock, "T failed to open xsel pipe `%s'",
1515                         strerror (errno));
1516             }
1517             else {
1518                 f = state.xselpipe;
1519             }
1520         }
1521 #endif
1522
1523         for (span = page->fmark.span;
1524              span && span != page->lmark.span->next;
1525              span = span->next) {
1526             int a = span == page->fmark.span ? page->fmark.i : 0;
1527             int b = span == page->lmark.span ? page->lmark.i : span->len - 1;
1528             if (pipespan (f, span, a, b))  {
1529                 goto close;
1530             }
1531             if (span->eol)  {
1532                 if (putc ('\n', f) == EOF) {
1533                     printd (state.sock, "T failed break line on xsel pipe `%s'",
1534                             strerror (errno));
1535                     goto close;
1536                 }
1537             }
1538         }
1539         page->lmark.span = NULL;
1540         page->fmark.span = NULL;
1541     }
1542
1543  unlock:
1544     unlock ("ml_copysel");
1545
1546  done:
1547     CAMLreturn (Val_unit);
1548 }
1549
1550 CAMLprim value ml_getpagewh (value pagedimno_v)
1551 {
1552     CAMLparam1 (pagedimno_v);
1553     CAMLlocal1 (ret_v);
1554     int pagedimno = Int_val (pagedimno_v);
1555
1556     ret_v = caml_alloc_small (4 * Double_wosize, Double_array_tag);
1557     Store_double_field (ret_v, 0, state.pagedims[pagedimno].box.x0);
1558     Store_double_field (ret_v, 1, state.pagedims[pagedimno].box.x1);
1559     Store_double_field (ret_v, 2, state.pagedims[pagedimno].box.y0);
1560     Store_double_field (ret_v, 3, state.pagedims[pagedimno].box.y1);
1561     CAMLreturn (ret_v);
1562 }
1563
1564 CAMLprim value ml_init (value sock_v)
1565 {
1566 #ifndef _WIN32
1567     int ret;
1568 #endif
1569     CAMLparam1 (sock_v);
1570
1571     state.texcount = 256;
1572     state.sliceheight = 24;
1573     state.texform = GL_RGBA;
1574     state.texty = GL_UNSIGNED_BYTE;
1575
1576     fz_accelerate ();
1577     state.texids = calloc (state.texcount * sizeof (*state.texids), 1);
1578     if (!state.texids) {
1579         err (1, "calloc texids " FMT_s,
1580              state.texcount * sizeof (*state.texids));
1581     }
1582
1583     state.texowners = calloc (state.texcount * sizeof (*state.texowners), 1);
1584     if (!state.texowners) {
1585         err (1, "calloc texowners " FMT_s,
1586              state.texcount * sizeof (*state.texowners));
1587     }
1588
1589     glGenTextures (state.texcount, state.texids);
1590
1591 #ifdef _WIN32
1592     state.sock = Socket_val (sock_v);
1593 #else
1594     state.sock = Int_val (sock_v);
1595 #endif
1596
1597     state.cache = fz_newglyphcache ();
1598     if (!state.cache) {
1599         errx (1, "fz_newglyphcache failed");
1600     }
1601
1602 #ifdef _WIN32
1603     InitializeCriticalSection (&critsec);
1604     state.thread = CreateThread (NULL, 0, mainloop, NULL, 0, NULL);
1605     if (state.thread == INVALID_HANDLE_VALUE) {
1606         errx (1, "CreateThread failed: %lx", GetLastError ());
1607     }
1608 #else
1609     ret = pthread_create (&state.thread, NULL, mainloop, NULL);
1610     if (ret) {
1611         errx (1, "pthread_create: %s", strerror (errno));
1612     }
1613 #endif
1614
1615     CAMLreturn (Val_unit);
1616 }