Added Deluge and tests for it.

2009-02-25 17:00:00 +00:00 · 2009-02-25 17:00:00 +00:00 · 31bc37a043
commit 31bc37a043
parent 5b258ce104
8 changed files with 1109 additions and 0 deletions
--- a/examples/sky/test-deluge.c
+++ b/examples/sky/test-deluge.c
@ -0,0 +1,108 @@
+/*
+ * Copyright (c) 2007, Swedish Institute of Computer Science.
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * 1. Redistributions of source code must retain the above copyright
+ *    notice, this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ *    notice, this list of conditions and the following disclaimer in the
+ *    documentation and/or other materials provided with the distribution.
+ * 3. Neither the name of the Institute nor the names of its contributors
+ *    may be used to endorse or promote products derived from this software
+ *    without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE INSTITUTE AND CONTRIBUTORS ``AS IS'' AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED.  IN NO EVENT SHALL THE INSTITUTE OR CONTRIBUTORS BE LIABLE
+ * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+ * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
+ * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+ * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
+ * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
+ * SUCH DAMAGE.
+ *
+ * This file is part of the Contiki operating system.
+ *
+ * $Id: test-deluge.c,v 1.1 2009/02/25 17:00:00 nvt-se Exp $
+ */
+
+/**
+ * \file
+ *         A test program for Deluge.
+ * \author
+ *         Nicolas Tsiftes <nvt@sics.se>
+ */
+
+#include "contiki.h"
+#include "cfs/cfs.h"
+#include "deluge.h"
+#include "node-id.h"
+
+#include <stdio.h>
+#include <string.h>
+
+#ifndef SINK_ID
+#define SINK_ID	1
+#endif
+
+PROCESS(cfs_process, "Test CFS process");
+AUTOSTART_PROCESSES(&cfs_process);
+/*---------------------------------------------------------------------------*/
+PROCESS_THREAD(cfs_process, ev, data)
+{
+  int fd, r;
+  char buf[32];
+  static struct etimer et;
+
+  PROCESS_BEGIN();
+
+  memset(buf, 0, sizeof(buf));
+  if(node_id == SINK_ID) {
+    strcpy(buf, "This is version 1 of the file");
+  } else {
+    strcpy(buf, "This is version 0 of the file");
+  }
+
+  cfs_remove("test");
+  fd = cfs_open("test", CFS_WRITE);
+  if(fd < 0) {
+    process_exit(NULL);
+  }
+  if(cfs_write(fd, buf, sizeof(buf)) != sizeof(buf)) {
+    cfs_close(fd);
+    process_exit(NULL);
+  }
+  cfs_close(fd);
+
+  deluge_disseminate("test", node_id == SINK_ID);
+
+  etimer_set(&et, CLOCK_SECOND);
+  for(;;) {
+    PROCESS_WAIT_EVENT_UNTIL(etimer_expired(&et));
+    if(node_id != SINK_ID) {
+      fd = cfs_open("test", CFS_READ);
+      if(fd < 0) {
+        printf("failed to open the test file\n");
+      } else {
+        r = cfs_read(fd, buf, sizeof(buf));
+	buf[sizeof(buf) - 1] = '\0';
+	if(r <= 0) {
+	  printf("failed to read data from the file\n");
+	} else {
+	  printf("File contents: %s\n", buf);
+	}
+	cfs_close(fd);
+      }
+    }
+    etimer_reset(&et);
+  }
+
+
+  PROCESS_END();
+}
+/*---------------------------------------------------------------------------*/