Merge TinyOS 2.1.1 into master.

[tinyos-2.x.git] / support / sdk / c / blip / libtcp / test_circ.c

diff --git a/support/sdk/c/blip/libtcp/test_circ.c b/support/sdk/c/blip/libtcp/test_circ.c
new file mode 100644 (file)
index 0000000..a8a6edd
--- /dev/null
+++ b/support/sdk/c/blip/libtcp/test_circ.c
@@ -0,0 +1,124 @@
+/*
+ * "Copyright (c) 2008, 2009 The Regents of the University  of California.
+ * All rights reserved."
+ *
+ * Permission to use, copy, modify, and distribute this software and its
+ * documentation for any purpose, without fee, and without written agreement is
+ * hereby granted, provided that the above copyright notice, the following
+ * two paragraphs and the author appear in all copies of this software.
+ *
+ * IN NO EVENT SHALL THE UNIVERSITY OF CALIFORNIA BE LIABLE TO ANY PARTY FOR
+ * DIRECT, INDIRECT, SPECIAL, INCIDENTAL, OR CONSEQUENTIAL DAMAGES ARISING OUT
+ * OF THE USE OF THIS SOFTWARE AND ITS DOCUMENTATION, EVEN IF THE UNIVERSITY OF
+ * CALIFORNIA HAS BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ *
+ * THE UNIVERSITY OF CALIFORNIA SPECIFICALLY DISCLAIMS ANY WARRANTIES,
+ * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
+ * AND FITNESS FOR A PARTICULAR PURPOSE.  THE SOFTWARE PROVIDED HEREUNDER IS
+ * ON AN "AS IS" BASIS, AND THE UNIVERSITY OF CALIFORNIA HAS NO OBLIGATION TO
+ * PROVIDE MAINTENANCE, SUPPORT, UPDATES, ENHANCEMENTS, OR MODIFICATIONS."
+ *
+ */
+
+#include <stdio.h>
+#include <string.h>
+#include "circ.h"
+
+/* void do_head_read(void *buf) { */
+/*   char *read_data; */
+/*   int i, data_len; */
+/*   data_len = circ_buf_read_head(buf, (void **)&read_data); */
+/*   printf("buf_read_head: %i\n", data_len); */
+/*   for (i = 0; i < data_len; i++) */
+/*     putc(((char *)read_data)[i], stdout); */
+/*   putc('\n', stdout); */
+/* } */
+
+void do_read(void *buf, uint32_t sseqno) {
+  char data[20];
+  int data_len, i;
+  data_len = circ_buf_read(buf, sseqno, data, 20);
+
+  printf("buf_read: %i\n", data_len);
+  for (i = 0; i < data_len; i++)
+    putc(((char *)data)[i], stdout);
+  putc('\n', stdout);
+
+}
+
+int main(int argc, char **argv) {
+  char buf[200];
+  char data[20], readbuf[30];
+  int i = 20, data_len;
+  char *read_data;
+  memset(buf, 0, sizeof(buf));
+
+  if (circ_buf_init(buf, 200, 0) < 0)
+    printf("cir_buf_init: error\n");
+
+  for (i=0;i<20;i++)
+    data[i] = 'a' + i;
+
+  if (circ_buf_write(buf, 0, data, 20) < 0)
+    printf("circ_buf_write: error\n");
+
+  circ_buf_dump(buf);
+
+  if (circ_buf_write(buf, 10, data, 20) < 0)
+    printf("circ_buf_write: error\n");
+
+  circ_buf_dump(buf);
+
+
+  if (circ_buf_write(buf, 50, data, 20) < 0)
+    printf("circ_buf_write: error\n");
+
+  // circ_buf_dump(buf);
+
+  // do_head_read(buf);
+  // circ_buf_dump(buf);
+
+  if (circ_buf_write(buf, 30, data, 20) < 0)
+    printf("circ_buf_write: error\n");
+
+  // circ_buf_dump(buf);
+
+  if (circ_buf_write(buf, 70, data, 20) < 0)
+    printf("circ_buf_write: error\n");
+
+  circ_buf_dump(buf);
+
+  circ_shorten_head(buf, 10);
+  circ_buf_dump(buf);
+
+  memset(buf, 0, sizeof(buf));
+
+  if (circ_buf_init(buf, 200, 0) < 0)
+    printf("cir_buf_init: error\n");
+
+  printf("\n\nRESTART\n\n");
+  
+  for (i = 0; i < 25; i++) {
+    circ_buf_write(buf, i * 20, data, 20);
+    do_read(buf, i * 20);
+    circ_shorten_head(buf, (i > 0) ? (i - 1) * 20 : 0 * 10);
+    circ_buf_dump(buf);
+  }
+
+  // do_read(buf, 50);
+
+/*   do_head_read(buf); */
+/*   circ_buf_dump(buf); */
+
+/*   if (circ_buf_write(buf, 90, data, 20) < 0) */
+/*     printf("circ_buf_write: error\n"); */
+/*   if (circ_buf_write(buf, 110, data, 20) < 0) */
+/*     printf("circ_buf_write: error\n"); */
+/*   if (circ_buf_write(buf, 130, data, 20) < 0) */
+/*     printf("circ_buf_write: error\n"); */
+
+/*   circ_buf_dump(buf); */
+/*   do_head_read(buf); */
+/*   do_head_read(buf); */
+/*   circ_buf_dump(buf); */
+}