chiark / gitweb /
"trusting" pager collector - do not confirm lack of motion, but do wait 0.5s each...
[ypp-sc-tools.main.git] / pctb / pages.c
index 272e5cff6ab280d8e1dadafbbeff2b7a92b2554c..39690388ebc41589c583653916aaaefc7a8adf3e 100644 (file)
@@ -7,15 +7,27 @@
 #include <X11/extensions/XTest.h>
 #include <X11/keysym.h>
 
-#define NUM_PAGES 25
+CanonImage *page_images[MAX_PAGES];
+int npages;
 
+static Window id;
 static Display *disp;
+static struct timeval tv_startup;
 
 static KeyCode keycode(KeySym sym) {
   return XKeysymToKeycode(disp,sym);
 }
 
-static CanonImage *screenshot_now(Window id) {
+static void check_pclose(FILE *f, char *cmd) {
+  int r;
+  eassert(!ferror(f));
+  r= fgetc(f);  eassert(r==EOF);  eassert(feof(f));
+  r= pclose(f);  eassert(r>=0);  eassert(WIFEXITED(r) && !WEXITSTATUS(r));
+  free(cmd);
+}
+
+#if 0
+static CanonImage *screenshot_now(void) {
   char *cmd;
   CanonImage *ci;
   int r;
@@ -24,20 +36,173 @@ static CanonImage *screenshot_now(Window id) {
   eassert(r>=0);
   FILE *f= popen(cmd,"r");  eassert(f);
   ci= file_read_image(f);
-  r= fgetc(f);  eassert(r==EOF);  eassert(feof(f));
-  r= pclose(f);  eassert(r>=0);  eassert(WIFEXITED(r) && !WEXITSTATUS(r));
-  free(cmd);
+  check_pclose(f, cmd);
   return ci;
 }
+#endif
+
+static void screenshot_startup(void) {
+  int r;
+  disp= XOpenDisplay(0);  eassert(disp);
+  r= gettimeofday(&tv_startup,0);  eassert(!r);
+}
+
+#if 0
+static CanonImage *single_page(void) {
+  int r;
+  r= XRaiseWindow(disp, id);  eassert(r);
+  r= XSync(disp, False);  eassert(r);
+  return screenshot_now();
+}
+#endif
+
+/*---------- pager ----------*/
+
+typedef struct {
+  size_t len;
+  unsigned char d[];
+} Snapshot;
+
+static size_t snapshot_alloc= 1024;
+static double last_input;
+static const double min_update_allowance= 0.5;
+
+static double timestamp(void) {
+  struct timeval tv;
+  int r;
+  
+  r= gettimeofday(&tv,0);  eassert(!r);
+  double t= (tv.tv_sec - tv_startup.tv_sec) +
+            (tv.tv_usec - tv_startup.tv_usec) * 1e-6;
+  fprintf(stderr,"%f\n",t);
+  return t;
+}
+static void delay(double need_sleep) {
+  int r;
+  fprintf(stderr,"PAGING     delay %f\n",need_sleep);
+  r= usleep(need_sleep * 1e6);  eassert(!r);
+}
+
+static void sync_after_input(void) {
+  int r;
+  r= XSync(disp, False);  eassert(r);
+  last_input= timestamp();
+}
+
+static void send_key(KeySym sym) {
+  XTestFakeKeyEvent(disp, keycode(sym),1, 10);
+  XTestFakeKeyEvent(disp, keycode(sym),0, 10);
+}
+
+static void send_pgup_many(void) {
+  int i;
+  for (i=0; i<25; i++)
+    send_key(XK_Prior);
+  fprintf(stderr,"PAGING   PageUp x %d\n",i);
+  sync_after_input();
+}
+static void send_pgdown(void) {
+  send_key(XK_Next);
+  fprintf(stderr,"PAGING   PageDown\n");
+  sync_after_input();
+}
+
+static void snapshot(Snapshot **output) {
+  char *cmd;
+  int r;
+  
+  free(*output);  *output=0;
+
+  fprintf(stderr,"PAGING   snapshot\n");
+
+  r= asprintf(&cmd, "xwd -silent -id 0x%lx", (unsigned long)id); eassert(r>=0);
+  FILE *f= popen(cmd,"r"); eassert(f);
+
+  int need_alloc=1;
+  size_t used=0;
+  for (;;) {
+    size_t allow= snapshot_alloc - used;
+    if (!allow) {
+      snapshot_alloc <<= 1;
+      need_alloc= 1;
+      fprintf(stderr,"PAGING   snapshot   grow %ld\n", (long)snapshot_alloc);
+      continue;
+    }
+    if (need_alloc) {
+      *output= realloc(*output, sizeof(**output) + snapshot_alloc);
+      eassert(*output);
+      need_alloc= 0;
+    }
+    size_t got= fread((*output)->d, 1, allow, f);
+    if (got==0) break;
+    used += got;
+  }
+  check_pclose(f,cmd);
+
+  (*output)->len= used;
+  snapshot_alloc= used+1;
+  *output= realloc(*output, sizeof(**output) + snapshot_alloc);
+  eassert(*output);
+  
+  fprintf(stderr,"PAGING   snapshot len=%ld\n", (long)used);
+}
+
+static int identical(const Snapshot *a, const Snapshot *b) {
+  return !(memcmp(a,    b,    sizeof(*a)) ||
+          memcmp(a->d, b->d, a->len));
+}
+
+static void wait_for_stability(Snapshot **output,
+                              const Snapshot *previously,
+                              void (*with_keypress)(void)) {
+  Snapshot *last=0;
+  /* waits longer if we're going to return an image identical to previously
+   * if previously==0, all images are considered identical to it */
+
+  fprintf(stderr,"PAGING  wait_for_stability"
+         "  last_input=%f previously=%p\n",
+         last_input, previously);
+
+  for (;;) {
+    double at_snapshot= timestamp();
+    double need_sleep= min_update_allowance - (at_snapshot - last_input);
+    if (need_sleep > 0) { delay(need_sleep); continue; }
+
+    snapshot(output);
+
+    if (!with_keypress &&
+       !(previously && identical(*output,previously))) {
+      fprintf(stderr,"PAGING  wait_for_stability  simple\n");
+      break;
+    }
+
+    if (last && identical(*output,last)) {
+      fprintf(stderr,"PAGING  wait_for_stability  stabilised\n");
+      break;
+    }
+    
+    fprintf(stderr,"PAGING  wait_for_stability  retry\n");
+
+    free(last); last=*output; *output=0;
+
+    if (with_keypress)
+      with_keypress();
 
-static void read_pages(Window id) {
+    delay(0.5);
+  }
+
+  free(last);
+  fprintf(stderr,"PAGING  wait_for_stability done.\n");
+}
+
+static void raise_and_set_focus(void) {
   int r;
   XWindowAttributes attr;
   int xpos,ypos, evbase,errbase,majver,minver;
   unsigned width,height,bd,depth;
   Window dummy;
   
-  disp= XOpenDisplay(0);  eassert(disp);
+  fprintf(stderr,"PAGING raise_and_set_focus\n");
 
   r= XTestQueryExtension(disp, &evbase,&errbase,&majver,&minver);
   eassert(r==True);
@@ -55,21 +220,50 @@ static void read_pages(Window id) {
   int screen= XScreenNumberOfScreen(attr.screen);
   XTestFakeMotionEvent(disp,screen, xpos, ypos, 0);
 
-  XTestFakeButtonEvent(disp,1,1, 0);
+  XTestFakeButtonEvent(disp,1,1, 50);
   XTestFakeButtonEvent(disp,1,0, 50);
 
-  XTestFakeKeyEvent(disp, keycode(XK_Next),1, 50);
-  XTestFakeKeyEvent(disp, keycode(XK_Next),0, 50);
-  
-  r= XSync(disp, False);  eassert(r);
+  sync_after_input();
+  fprintf(stderr,"PAGING raise_and_set_focus done.\n");
 }
 
+
+
+static void read_pages(void) {
+  Snapshot *current=0, *last=0;
+
+  raise_and_set_focus();
+
+  /* page to the top - keep pressing page up until the image stops changing */
+  wait_for_stability(&last,0, send_pgup_many);
+
+  /* now to actually page down */
+  for (;;) {
+    fprintf(stderr,"PAGING page %d\n",npages);
+    //eassert(npages < MAX_PAGES);
+    //page_images[npages++]=
+
+    wait_for_stability(&current,last, 0);
+    if (npages &&  /* first pagedown doesn't do much */
+       identical(current,last)) {
+      free(current);
+      break;
+    }
+
+    free(last); last=current; current=0;
+
+    send_pgdown();
+    npages++;
+  }
+  fprintf(stderr,"PAGING all done.\n");
+}    
+
 int main(int argc, char **argv) {
-  Window id;
-  CanonImage *ci;
+  screenshot_startup();
 
   id= strtoul(*++argv,0,0);
-  read_pages(id);
-  ci= screenshot_now(id);
+
+  read_pages();
   return 0;
 }
+