+++ /dev/null
-Upstream-Status: Pending
-
---- tslib/plugins/linear.c~multievent
-+++ tslib/plugins/linear.c
-@@ -39,14 +39,12 @@
- linear_read(struct tslib_module_info *info, struct ts_sample *samp, int nr)
- {
- struct tslib_linear *lin = (struct tslib_linear *)info;
-- int ret;
-+ int ret, i = 0;
- int xtemp,ytemp;
-
- ret = info->next->ops->read(info->next, samp, nr);
- if (ret >= 0) {
-- int nr;
--
-- for (nr = 0; nr < ret; nr++, samp++) {
-+ for (i = 0; i < ret; i++, samp++) {
- #ifdef DEBUG
- fprintf(stderr,"BEFORE CALIB--------------------> %d %d %d\n",samp->x, samp->y, samp->pressure);
- #endif /*DEBUG*/
-@@ -66,6 +64,7 @@
- samp->y = tmp;
- }
- }
-+ ret = i;
- }
-
- return ret;
---- tslib/plugins/dejitter.c~multievent
-+++ tslib/plugins/dejitter.c
-@@ -24,7 +24,6 @@
-
- struct tslib_threshold {
- struct tslib_module_info module;
-- int pthreshold;
- int xdelta;
- int ydelta;
- int delta2;
-@@ -36,40 +35,28 @@
- static int threshold_read(struct tslib_module_info *info, struct ts_sample *samp, int nr)
- {
- struct tslib_threshold *thr = (struct tslib_threshold *)info;
-- struct ts_sample *s;
-- int ret;
-+ struct ts_sample *src = samp, *dest = samp;
-+ int ret, i = 0;
-
- ret = info->next->ops->read(info->next, samp, nr);
- if (ret >= 0) {
-- int nr = 0;
--
-- for (s = samp; s < samp + ret; s++) {
-+ for (i = 0; i < ret; i++, samp++) {
- int dr2;
- #ifdef DEBUG
-- fprintf(stderr,"BEFORE DEJITTER---------------> %d %d %d\n",s->x,s->y,s->pressure);
-+ fprintf(stderr,"BEFORE DEJITTER---------------> %d %d %d\n", samp->x, samp->y, samp->pressure);
- #endif /*DEBUG*/
-- thr->down = (s->pressure >= thr->pthreshold);
-- if (thr->down) {
-- dr2 = (thr->x - s->x)*(thr->x - s->x)
-- + (thr->y - s->y)*(thr->y - s->y);
-- if(dr2 < thr->delta2) {
-- s->x = thr->x;
-- s->y = thr->y;
-- } else {
-- thr->x = s->x;
-- thr->y = s->y;
-- }
--
-+ dr2 = (thr->x - samp->x)*(thr->x - samp->x)
-+ + (thr->y - samp->y)*(thr->y - samp->y);
-+ if(dr2 < thr->delta2) {
-+ samp->x = thr->x;
-+ samp->y = thr->y;
- } else {
-- s->x = thr->x;
-- s->y = thr->y;
-+ thr->x = samp->x;
-+ thr->y = samp->y;
- }
--
--
-- samp[nr++] = *s;
- }
-
-- ret = nr;
-+ ret = i;
- }
- return ret;
- }
-@@ -106,10 +93,6 @@
- thr->ydelta = v;
- break;
-
-- case 3:
-- thr->pthreshold = v;
-- break;
--
- default:
- return -1;
- }
-@@ -120,7 +103,6 @@
- {
- { "xdelta", (void *)1, threshold_limit },
- { "ydelta", (void *)2, threshold_limit },
-- { "pthreshold", (void *)3, threshold_limit }
- };
-
- //#define NR_VARS (sizeof(threshold_vars) / sizeof(threshold_vars[0]))
-@@ -138,7 +120,6 @@
-
- thr->xdelta = 10;
- thr->ydelta = 10;
-- thr->pthreshold = 100;
-
- if (tslib_parse_vars(&thr->module, threshold_vars, NR_VARS, params)) {
- free(thr);
---- tslib/plugins/variance.c~multievent
-+++ tslib/plugins/variance.c
-@@ -9,25 +9,36 @@
- * $Id: variance.c,v 1.3 2002/11/08 23:28:55 dlowder Exp $
- *
- * Variance filter for touchscreen values
-+ *
-+ * Policy question (applies to all tslib modules that consume events):
-+ * 1) User requests a read of 5 events using nr.
-+ * 2) Lower layers return us 4 events.
-+ * 3) Perform variance calculation, we now only have _1_ event.
-+ * 4) Do we, a) duplicate this data across the user requested 4 events,
-+ * b) push up the single event
-+ * c) loop on the read from the lower layers to obtain
-+ * the user's requested number of events, unless we hit
-+ * a pen_up.
- */
-+
- #include <errno.h>
- #include <stdlib.h>
- #include <string.h>
- #include <limits.h>
--
- #include <stdio.h>
-
- #include "tslib.h"
- #include "tslib-filter.h"
-
-+#define NR_INIT -1
- #define NR_LAST 4
-
- struct tslib_variance {
- struct tslib_module_info module;
- int nr;
-- unsigned int pthreshold;
- unsigned int xlimit;
- unsigned int ylimit;
-+ unsigned int pthreshold;
- struct ts_sample last[NR_LAST];
- };
-
-@@ -37,8 +48,7 @@
- * least variance, and average them.
- */
- static int
--variance_calculate(struct tslib_variance *var, struct ts_sample *samp,
-- struct ts_sample *s)
-+variance_calculate(struct tslib_variance *var, struct ts_sample *dest, struct ts_sample *src)
- {
- int i, j;
- int diff_x, min_x, i_x, j_x;
-@@ -100,11 +110,11 @@
- }
- }
-
-- samp->x = (var->last[i_x].x + var->last[j_x].x) / 2;
-- samp->y = (var->last[i_y].y + var->last[j_y].y) / 2;
-- samp->pressure = (var->last[i_p].pressure + var->last[j_p].pressure) / 2;
-- samp->tv.tv_sec = s->tv.tv_sec;
-- samp->tv.tv_usec = s->tv.tv_usec;
-+ dest->x = (var->last[i_x].x + var->last[j_x].x) / 2;
-+ dest->y = (var->last[i_y].y + var->last[j_y].y) / 2;
-+ dest->pressure = (var->last[i_p].pressure + var->last[j_p].pressure) / 2;
-+ dest->tv.tv_sec = src->tv.tv_sec;
-+ dest->tv.tv_usec = src->tv.tv_usec;
-
- return 1;
- }
-@@ -112,55 +122,57 @@
- static int variance_read(struct tslib_module_info *info, struct ts_sample *samp, int nr)
- {
- struct tslib_variance *var = (struct tslib_variance *)info;
-- struct ts_sample *s;
-- int ret;
--
-- ret = info->next->ops->read(info->next, samp, nr);
-- if (ret >= 0) {
-- int nr = 0;
--
-- for (s = samp; s < samp + ret; s++) {
-- if (s->pressure < var->pthreshold) {
-- /*
-- * Pen was released. Reset our state and
-- * pass up the release information.
-- */
--// samp[nr].x = 0;
--// samp[nr].y = 0;
-- samp[nr].pressure = s->pressure;
-- samp[nr].tv.tv_sec = s->tv.tv_sec;
-- samp[nr].tv.tv_usec = s->tv.tv_usec;
--
-- nr++;
--
-- var->nr = 0;
-- continue;
-- } else if (var->nr == -1) {
-- /*
-- * Pen was pressed. Inform upper layers
-- * immediately.
-- */
-- samp[nr] = *s;
-- nr++;
-- }
--
-- if (var->nr >= 0) {
-- var->last[var->nr].x = s->x;
-- var->last[var->nr].y = s->y;
-- var->last[var->nr].pressure = s->pressure;
-- }
--
-- var->nr++;
-+ struct ts_sample *src = samp, *dest = samp;
-+ int ret, i = 0;
-
-- if (var->nr == NR_LAST) {
-- if (variance_calculate(var, samp + nr, s))
-- nr++;
-- var->nr = 0;
-+ /*
-+ * NOTES:
-+ *
-+ * Loop on read, collecting events until we hit nr, unless
-+ * we hit a pen up or encounter a failure.
-+ */
-+ while ((i < nr) && (ret != -1)) {
-+ ret = info->next->ops->read(info->next, dest + i, nr - i);
-+ if (ret >= 0) {
-+ for (src = dest + i; src < dest + ret; src++) {
-+ if (src->pressure < var->pthreshold) {
-+ /* pen released, reset var->nr,
-+ * do a calc based on what we have so
-+ * far, and let this event flow up */
-+ if (variance_calculate(var, dest + i, src))
-+ i++;
-+ var->nr = NR_INIT;
-+ ret = -1; /* break outer loop, push up event */
-+ break;
-+ } else if (var->nr == NR_INIT) {
-+ /*
-+ * First pen down event. Inform upper layers
-+ * immediately for responsiveness.
-+ */
-+ var->nr = 0;
-+ i++;
-+ ret = -1; /* break outer loop */
-+ break;
-+ }
-+
-+ if (var->nr >= 0) {
-+ var->last[var->nr].x = src->x;
-+ var->last[var->nr].y = src->y;
-+ var->last[var->nr].pressure = src->pressure;
-+ }
-+
-+ var->nr++;
-+
-+ if (var->nr == NR_LAST) {
-+ if (variance_calculate(var, dest + i, src))
-+ i++;
-+ var->nr = 0;
-+ }
- }
- }
--
-- ret = nr;
- }
-+ /* if we've collected at least one event, send it up */
-+ if (i != 0) ret = i;
- return ret;
- }
-
-@@ -196,10 +208,6 @@
- var->ylimit = v;
- break;
-
-- case 3:
-- var->pthreshold = v;
-- break;
--
- default:
- return -1;
- }
-@@ -210,7 +218,6 @@
- {
- { "xlimit", (void *)1, variance_limit },
- { "ylimit", (void *)2, variance_limit },
-- { "pthreshold", (void *)3, variance_limit }
- };
-
- #define NR_VARS (sizeof(variance_vars) / sizeof(variance_vars[0]))
-@@ -218,6 +225,7 @@
- struct tslib_module_info *mod_init(struct tsdev *dev, const char *params)
- {
- struct tslib_variance *var;
-+ char *pthresvar;
-
- var = malloc(sizeof(struct tslib_variance));
- if (var == NULL)
-@@ -225,10 +233,15 @@
-
- var->module.ops = &variance_ops;
-
-- var->nr = -1;
-+ var->nr = NR_INIT;
- var->xlimit = 160;
- var->ylimit = 160;
- var->pthreshold = 100;
-+ pthresvar = getenv("TSLIB_PTHRES");
-+ if (pthresvar != NULL) {
-+ int p = strtol(pthresvar, (char **)NULL, 10);
-+ if (p != -1) var->pthreshold = p;
-+ }
-
- if (tslib_parse_vars(&var->module, variance_vars, NR_VARS, params)) {
- free(var);
---- tslib/README~multievent
-+++ tslib/README
-@@ -36,6 +36,19 @@
- usages. They are by no means exhaustive, nor probably even good examples.
- They are basically the programs I used to test this library.
-
-+Module Creation Notes
-+=====================
-+
-+For those creating tslib modules, it is important to note a couple things with
-+regard to handling of the ability for a user to request more than one ts event
-+at a time. The first thing to note is that the lower layers may send up less
-+events than the user requested, but only if that was a result of a pen release.
-+Next, your module should send up just as many events as the user requested in
-+nr. If your module is one that consumes events, such as variance, then you
-+loop on the read from the lower layers, and only send the events up when
-+1) you have the number of events requested by the user, or 2) one of the events
-+from the lower layers was a pen release.
-+
-
- Module Parameters
- =================
---- tslib/src/ts_read_raw.c~multievent
-+++ tslib/src/ts_read_raw.c
-@@ -14,10 +14,10 @@
- *
- * Read raw pressure, x, y, and timestamp from a touchscreen device.
- */
-+
- #include "config.h"
-
- #include <stdio.h>
--
- #include <stdlib.h>
- #ifdef HAVE_UNISTD_H
- #include <unistd.h>
-@@ -25,79 +25,27 @@
- #include <sys/time.h>
- #include <sys/types.h>
-
--#ifdef USE_INPUT_API
--#include <linux/input.h>
--#else
--struct ts_event { /* Used in UCB1x00 style touchscreens (the default) */
-- unsigned short pressure;
-- unsigned short x;
-- unsigned short y;
-- unsigned short pad;
-- struct timeval stamp;
--};
--struct h3600_ts_event { /* Used in the Compaq IPAQ */
-- unsigned short pressure;
-- unsigned short x;
-- unsigned short y;
-- unsigned short pad;
--};
--struct mk712_ts_event { /* Used in the Hitachi Webpad */
-- unsigned int header;
-- unsigned int x;
-- unsigned int y;
-- unsigned int reserved;
--};
--struct arctic2_ts_event { /* Used in the IBM Arctic II */
-- signed short pressure;
-- signed int x;
-- signed int y;
-- int millisecs;
-- int flags;
--};
--struct collie_ts_event { /* Used in the Sharp Zaurus SL-5000d and SL-5500 */
-- long y;
-- long x;
-- long pressure;
-- long long millisecs;
--};
--struct corgi_ts_event { /* Used in the Sharp Zaurus SL-C700 */
-- short pressure;
-- short x;
-- short y;
-- short millisecs;
--};
--#endif /* USE_INPUT_API */
--
- #include "tslib-private.h"
-
--int ts_read_raw(struct tsdev *ts, struct ts_sample *samp, int nr)
--{
- #ifdef USE_INPUT_API
-+#include <linux/input.h>
-+
-+static inline int get_input_event(struct tsdev *ts, struct ts_sample *samp) {
- struct input_event ev;
--#else
-- struct ts_event *evt;
-- struct h3600_ts_event *hevt;
-- struct mk712_ts_event *mevt;
-- struct arctic2_ts_event *aevt;
-- struct collie_ts_event *collie_evt;
-- struct corgi_ts_event *corgi_evt;
--#endif /* USE_INPUT_API */
-- int ret;
-- int total = 0;
-+ struct timeval tv = {0, 0};
-+ fd_set fdset;
-+ int ret = 0;
-
-- char *tseventtype=NULL;
-- char *defaulttseventtype="UCB1x00";
-+ /* event vars */
-+ static int curr_x = 0, curr_y = 0;
-+ int curr_p = 0, next_x = 0, next_y = 0;
-
--#ifdef USE_INPUT_API
-- /* warning: maybe those static vars should be part of the tsdev struct? */
-- static int curr_x = 0, curr_y = 0, curr_p = 0;
-- static int got_curr_x = 0, got_curr_y = 0;
-- int got_curr_p = 0;
-- int next_x, next_y;
-+ /* state variables */
-+ int got_curr_x = 0, got_curr_y = 0, got_curr_p = 0;
- int got_next_x = 0, got_next_y = 0;
- int got_tstamp = 0;
-
-- while (total < nr) {
-+ while (1) {
- ret = read(ts->fd, &ev, sizeof(struct input_event));
- if (ret < sizeof(struct input_event)) break;
-
-@@ -146,177 +94,231 @@
- samp->tv = ev.time;
- }
-
-- if ( (!got_curr_x || !got_curr_y) && !got_curr_p &&
-- !got_next_x && !got_next_y ) {
-- /*
-- * The current event is not complete yet.
-- * Give the kernel a chance to feed us more.
-- */
-- struct timeval tv = {0, 0};
-- fd_set fdset;
-- FD_ZERO(&fdset);
-- FD_SET(ts->fd, &fdset);
-- ret = select(ts->fd+1, &fdset, NULL, NULL, &tv);
-- if (ret == 1) continue;
-- if (ret == -1) break;
-+ if (got_curr_x && got_curr_y && got_curr_p) {
-+ /* we have a complete event */
-+ samp->x = curr_x;
-+ samp->y = curr_y;
-+ samp->pressure = curr_p;
-+ ret = 0; /* indicate success */
-+ if (got_next_x) curr_x = next_x;
-+ if (got_next_y) curr_y = next_y;
-+ break;
- }
-
-- /* We consider having a complete ts event */
-- samp->x = curr_x;
-- samp->y = curr_y;
-- samp->pressure = curr_p;
--#ifdef DEBUG
-- fprintf(stderr,"RAW---------------------------> %d %d %d\n",samp->x,samp->y,samp->pressure);
--#endif /*DEBUG*/
-- samp++;
-- total++;
--
-- /* get ready for next event */
-- if (got_next_x) curr_x = next_x; else got_curr_x = 0;
-- if (got_next_y) curr_y = next_y; else got_curr_y = 0;
-- got_next_x = got_next_y = got_tstamp = 0;
-+ /*
-+ * The current event is not complete yet.
-+ * Give the kernel a chance to feed us more.
-+ */
-+ FD_ZERO(&fdset);
-+ FD_SET(ts->fd, &fdset);
-+ ret = select(ts->fd+1, &fdset, NULL, NULL, &tv);
-+ if (ret == 1) continue;
-+ if (ret == -1) break;
- }
-
-- if (ret) ret = -1;
-- if (total) ret = total;
-+// fprintf(stdout, "%s: returning %d\n", __FUNCTION__, ret);
-+ if (ret != 0) ret = -1;
-+ return ret;
-+}
-+
- #else
-+
-+struct ucb1x00_ts_event { /* Used in UCB1x00 style touchscreens (the default) */
-+ unsigned short pressure;
-+ unsigned short x;
-+ unsigned short y;
-+ unsigned short pad;
-+ struct timeval stamp;
-+};
-+struct h3600_ts_event { /* Used in the Compaq IPAQ */
-+ unsigned short pressure;
-+ unsigned short x;
-+ unsigned short y;
-+ unsigned short pad;
-+};
-+struct mk712_ts_event { /* Used in the Hitachi Webpad */
-+ unsigned int header;
-+ unsigned int x;
-+ unsigned int y;
-+ unsigned int reserved;
-+};
-+struct arctic2_ts_event { /* Used in the IBM Arctic II */
-+ signed short pressure;
-+ signed int x;
-+ signed int y;
-+ int millisecs;
-+ int flags;
-+};
-+struct collie_ts_event { /* Used in the Sharp Zaurus SL-5000d and SL-5500 */
-+ long y;
-+ long x;
-+ long pressure;
-+ long long millisecs;
-+};
-+struct corgi_ts_event { /* Used in the Sharp Zaurus SL-C700 */
-+ short pressure;
-+ short x;
-+ short y;
-+ short millisecs;
-+};
-+
-+static inline int get_ucb1x00_event(struct tsdev *ts, struct ts_sample *samp) {
-+ struct ucb1x00_ts_event evt;
-+ int ret = read(ts->fd, &evt, sizeof(struct ucb1x00_ts_event));
-+ if (ret > 0) {
-+ samp->x = evt.x;
-+ samp->y = evt.y;
-+ samp->pressure = evt.pressure;
-+ samp->tv.tv_usec = evt.stamp.tv_usec;
-+ samp->tv.tv_sec = evt.stamp.tv_sec;
-+ ret = 0; /* success */
-+ }
-+ return ret;
-+}
-+
-+static inline int get_h3600_event(struct tsdev *ts, struct ts_sample *samp) {
-+ struct h3600_ts_event evt;
-+ int ret = read(ts->fd, &evt, sizeof(struct h3600_ts_event));
-+ if (ret > 0) {
-+ samp->x = evt.x;
-+ samp->y = evt.y;
-+ samp->pressure = evt.pressure;
-+ gettimeofday(&samp->tv, NULL);
-+ ret = 0; /* success */
-+ }
-+ return ret;
-+}
-+
-+static inline int get_mk712_event(struct tsdev *ts, struct ts_sample *samp) {
-+ struct mk712_ts_event evt;
-+ int ret = read(ts->fd, &evt, sizeof(struct mk712_ts_event));
-+ if (ret > 0) {
-+ samp->x = (short)evt.x;
-+ samp->y = (short)evt.y;
-+ if(evt.header==0)
-+ samp->pressure=1;
-+ else
-+ samp->pressure=0;
-+ gettimeofday(&samp->tv, NULL);
-+ ret = 0; /* success */
-+ }
-+ return ret;
-+}
-+
-+static inline int get_arctic2_event(struct tsdev *ts, struct ts_sample *samp) {
-+ struct arctic2_ts_event evt;
-+ int ret = read(ts->fd, &evt, sizeof(struct arctic2_ts_event));
-+ if (ret > 0) {
-+ samp->x = (short)evt.x;
-+ samp->y = (short)evt.y;
-+ samp->pressure = evt.pressure;
-+ gettimeofday(&samp->tv, NULL);
-+ ret = 0; /* success */
-+ }
-+ return ret;
-+}
-+
-+static inline int get_collie_event(struct tsdev *ts, struct ts_sample *samp) {
-+ struct collie_ts_event evt;
-+ int ret = read(ts->fd, &evt, sizeof(struct collie_ts_event));
-+ if (ret > 0) {
-+ samp->x = evt.x;
-+ samp->y = evt.y;
-+ samp->pressure = evt.pressure;
-+ samp->tv.tv_usec = evt.millisecs % 1000;
-+ samp->tv.tv_sec = evt.millisecs / 1000;
-+ ret = 0; /* success */
-+ }
-+ return ret;
-+}
-+
-+static inline int get_corgi_event(struct tsdev *ts, struct ts_sample *samp) {
-+ struct corgi_ts_event evt;
-+ int ret = read(ts->fd, &evt, sizeof(struct corgi_ts_event));
-+ if (ret > 0) {
-+ samp->x = evt.x;
-+ samp->y = evt.y;
-+ samp->pressure = evt.pressure;
-+ samp->tv.tv_usec = evt.millisecs % 1000;
-+ samp->tv.tv_sec = evt.millisecs / 1000;
-+ ret = 0; /* success */
-+ }
-+ return ret;
-+}
-+
-+#endif
-+
-+int ts_read_raw(struct tsdev *ts, struct ts_sample *samp, int nr)
-+{
-+ int ret;
-+ int total = 0;
-+ int pen_down = 1;
-+ static short x_save = 0, y_save = 0;
-+ static int pthres = -1;
-+
-+#ifndef USE_INPUT_API
-+ char *tseventtype=NULL;
-+ char *defaulttseventtype="UCB1x00";
- tseventtype = getenv("TSLIB_TSEVENTTYPE");
- if(tseventtype==NULL) tseventtype=defaulttseventtype;
-+#endif
-
-- if( strcmp(tseventtype,"H3600") == 0) { /* iPAQ style h3600 touchscreen events */
-- hevt = alloca(sizeof(*hevt) * nr);
-- ret = read(ts->fd, hevt, sizeof(*hevt) * nr);
-- if(ret > 0) {
-- int nr = ret / sizeof(*hevt);
-- while(ret >= sizeof(*hevt)) {
-- samp->x = hevt->x;
-- samp->y = hevt->y;
-- samp->pressure = hevt->pressure;
--#ifdef DEBUG
-- fprintf(stderr,"RAW---------------------------> %d %d %d\n",samp->x,samp->y,samp->pressure);
--#endif /*DEBUG*/
-- gettimeofday(&samp->tv,NULL);
-- samp++;
-- hevt++;
-- ret -= sizeof(*hevt);
-- }
-- } else {
-- return -1;
-- }
-- } else if( strcmp(tseventtype,"MK712") == 0) { /* Hitachi Webpad events */
-- mevt = alloca(sizeof(*mevt) * nr);
-- ret = read(ts->fd, mevt, sizeof(*mevt) * nr);
-- if(ret > 0) {
-- int nr = ret / sizeof(*mevt);
-- while(ret >= sizeof(*mevt)) {
-- samp->x = (short)mevt->x;
-- samp->y = (short)mevt->y;
-- if(mevt->header==0)
-- samp->pressure=1;
-- else
-- samp->pressure=0;
--#ifdef DEBUG
-- fprintf(stderr,"RAW---------------------------> %d %d %d\n",samp->x,samp->y,samp->pressure);
--#endif /*DEBUG*/
-- gettimeofday(&samp->tv,NULL);
-- samp++;
-- mevt++;
-- ret -= sizeof(*mevt);
-- }
-- } else {
-- return -1;
-- }
--
-- } else if( strcmp(tseventtype,"ARCTIC2") == 0) { /* IBM Arctic II events */
-- aevt = alloca(sizeof(*aevt) * nr);
-- ret = read(ts->fd, aevt, sizeof(*aevt) * nr);
-- if(ret > 0) {
-- int nr = ret / sizeof(*aevt);
-- while(ret >= sizeof(*aevt)) {
-- samp->x = (short)aevt->x;
-- samp->y = (short)aevt->y;
-- samp->pressure = aevt->pressure;
--#ifdef DEBUG
-- fprintf(stderr,"RAW---------------------------> %d %d %d\n",samp->x,samp->y,samp->pressure);
--#endif /*DEBUG*/
-- gettimeofday(&samp->tv,NULL);
-- samp++;
-- aevt++;
-- ret -= sizeof(*aevt);
-- }
-+ while ((total < nr) && pen_down) {
-+// fprintf(stdout, "total: %d, nr: %d\n", total, nr);
-+#ifdef USE_INPUT_API
-+ ret = get_input_event(ts, samp);
-+#else
-+ if (strcmp(tseventtype, "H3600") == 0) {
-+ /* iPAQ style h3600 touchscreen events */
-+ ret = get_h3600_event(ts, samp);
-+ } else if (strcmp(tseventtype, "MK712") == 0) {
-+ /* Hitachi Webpad events */
-+ ret = get_mk712_event(ts, samp);
-+ } else if (strcmp(tseventtype, "ARCTIC2") == 0) {
-+ /* IBM Arctic II events */
-+ ret = get_arctic2_event(ts, samp);
-+ } else if (strcmp(tseventtype, "COLLIE") == 0) {
-+ /* Sharp Zaurus SL-5000d/5500 events */
-+ ret = get_collie_event(ts, samp);
-+ } else if (strcmp(tseventtype,"CORGI") == 0) {
-+ /* Sharp Zaurus SL-C700 events */
-+ ret = get_corgi_event(ts, samp);
- } else {
-- return -1;
-+ /* Use normal UCB1x00 type events */
-+ ret = get_ucb1x00_event(ts, samp);
- }
-+#endif
-+ if (ret != 0) break;
-
-- } else if( strcmp(tseventtype,"COLLIE") == 0) { /* Sharp Zaurus SL-5000d/5500 events */
-- collie_evt = alloca(sizeof(*collie_evt) * nr);
-- ret = read(ts->fd, collie_evt, sizeof(*collie_evt) * nr);
-- if(ret > 0) {
-- int nr = ret / sizeof(*collie_evt);
-- while(ret >= sizeof(*collie_evt)) {
-- samp->x = collie_evt->x;
-- samp->y = collie_evt->y;
-- samp->pressure = collie_evt->pressure;
--#ifdef DEBUG
-- fprintf(stderr,"RAW---------------------------> %d %d %d\n",samp->x,samp->y,samp->pressure);
--#endif /*DEBUG*/
-- samp->tv.tv_usec = collie_evt->millisecs % 1000;
-- samp->tv.tv_sec = collie_evt->millisecs / 1000;
-- samp++;
-- collie_evt++;
-- ret -= sizeof(*collie_evt);
-+ if (pthres == -1) {
-+ char *pthresvar = getenv("TSLIB_PTHRES");
-+ pthres = 100;
-+ if (pthresvar != NULL) {
-+ int p = strtol(pthresvar, (char **)NULL, 10);
-+ if (p != -1) pthres = p;
- }
-- } else {
-- return -1;
- }
-
-- } else if( strcmp(tseventtype,"CORGI") == 0) { /* Sharp Zaurus SL-C700 events */
-- corgi_evt = alloca(sizeof(*corgi_evt) * nr);
-- ret = read(ts->fd, corgi_evt, sizeof(*corgi_evt) * nr);
-- if(ret > 0) {
-- int nr = ret / sizeof(*corgi_evt);
-- while(ret >= sizeof(*corgi_evt)) {
-- samp->x = corgi_evt->x;
-- samp->y = corgi_evt->y;
-- samp->pressure = corgi_evt->pressure;
--#ifdef DEBUG
-- fprintf(stderr,"RAW---------------------------> %d %d %d\n",samp->x,samp->y,samp->pressure);
--#endif /*DEBUG*/
-- samp->tv.tv_usec = corgi_evt->millisecs % 1000;
-- samp->tv.tv_sec = corgi_evt->millisecs / 1000;
-- samp++;
-- corgi_evt++;
-- ret -= sizeof(*corgi_evt);
-- }
-+ if (samp->pressure < pthres) {
-+ /* pen released, send events up */
-+ pen_down = 0;
-+ /* set x and y to previous values */
-+ samp->x = x_save;
-+ samp->y = y_save;
- } else {
-- return -1;
-+ pen_down = 1;
-+ x_save = samp->x;
-+ y_save = samp->y;
- }
--
-- } else { /* Use normal UCB1x00 type events */
-- evt = alloca(sizeof(*evt) * nr);
-- ret = read(ts->fd, evt, sizeof(*evt) * nr);
-- if(ret > 0) {
-- int nr = ret / sizeof(*evt);
-- while(ret >= sizeof(*evt)) {
-- samp->x = evt->x;
-- samp->y = evt->y;
-- samp->pressure = evt->pressure;
- #ifdef DEBUG
-- fprintf(stderr,"RAW---------------------------> %d %d %d\n",samp->x,samp->y,samp->pressure);
-+ fprintf(stderr,"RAW---------------------------> %d %d %d\n",samp->x, samp->y, samp->pressure);
- #endif /*DEBUG*/
-- samp->tv.tv_usec = evt->stamp.tv_usec;
-- samp->tv.tv_sec = evt->stamp.tv_sec;
-- samp++;
-- evt++;
-- ret -= sizeof(*evt);
-- }
-- } else {
-- return -1;
-- }
-+ samp++;
-+ total++;
- }
-- ret = nr;
--#endif /* USE_INPUT_API */
-
-+ if (ret != 0) ret = -1;
-+ if (total) ret = total;
- return ret;
- }
-
