M carrera/main.c => carrera/main.c +1 -1
@@ 503,7 503,7 @@ rdbginit(void)
{
uchar *vec;
ulong jba;
-
+return;
/* Only interested in the PC */
Mipsjmpbuf.pc = 0x8001C020;
M port/portfns.h => port/portfns.h +1 -0
@@ 204,6 204,7 @@ int qproduce(Queue*, void*, int);
long qread(Queue*, void*, int);
void qreopen(Queue*);
void qunlock(QLock*);
+int qwindow(Queue*);
long qwrite(Queue*, void*, int, int);
int readnum(ulong, char*, ulong, ulong, int);
int readstr(ulong, char*, ulong, char*);
M port/qio.c => port/qio.c +14 -0
@@ 656,6 656,20 @@ qlen(Queue *q)
}
/*
+ * return space remaining before flow control
+ */
+int
+qwindow(Queue *q)
+{
+ int l;
+
+ l = q->limit - q->len;
+ if(l < 0)
+ l = 0;
+ return l;
+}
+
+/*
* return true if we can read without blocking
*/
int