N-sim Emulation and simulation of Wireless Sensor Networks    Home    Project Page    Download    CVS    Installation    Configuration    Plug-ins  Hosted by

/home/brennan/n-sim/OrbisQuartus/server/l4/tftp_client-l4.c Go to the documentation of this file. /* * Copyright 2007. Los Alamos National Security, LLC. This material * was produced under U.S. Government contract DE-AC52-06NA25396 for * Los Alamos National Laboratory (LANL), which is operated by Los * Alamos National Security, LLC, for the Department of Energy. The * U.S. Government has rights to use, reproduce, and distribute this * software. NEITHER THE GOVERNMENT NOR LOS ALAMOS NATIONAL SECURITY, * LLC, MAKES ANY WARRANTY, EXPRESS OR IMPLIED, OR ASSUMES ANY LEGAL * LIABILITY FOR THE USE OF THIS SOFTWARE. If software is modified to * produce derivative works, such modified software should be clearly * marked, so as not to confuse it with the version available from LANL. * * Additionally, this program is free software; you can redistribute * it and/or modify it under the terms of the GNU General Public * License as published by the Free Software Foundation; version 2 of * the License. Accordingly, this program is distributed in the hope * it will be useful, but WITHOUT ANY WARRANTY; without even the * implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR * PURPOSE. See the GNU General Public License for more details. */ #include <stdio.h> #include <string.h> #include <stdlib.h> #include <l4/sys/types.h> #include <l4/env/errno.h> #include <l4/sys/syscalls.h> #include <l4/log/l4log.h> #include <l4/l4rm/l4rm.h> #include <l4/util/util.h> #include <l4/env/env.h> #include <l4/names/libnames.h> #include <l4/generic_fprov/generic_fprov-server.h> //#include <l4/sys/consts.h> #include <l4/dm_mem/dm_mem.h> #include <l4/thread/thread.h> //#include <l4/util/getopt.h> //#include <l4/util/macros.h> #include <l4/generic_io/libio.h> #include <l4/sys/kdebug.h> #if 0 #define TIMEOUT 5 int rexmtval = TIMEOUT; int maxtimeout = 5 * TIMEOUT; #endif static char tftp_stack[2*L4_PAGESIZE]; static struct in_addr peeraddr; extern int disp_filesizebarrier; extern int disp_filesize; extern char tftp_orename[16]; long l4fprov_file_open_component (CORBA_Object _dice_corba_obj, const char* fname, const l4_threadid_t *dm, unsigned long flags, l4dm_dataspace_t *ds, l4_size_t *size, CORBA_Server_Environment *_dice_corba_env) { int read_size; int error; char *addr; char buf[L4DM_DS_NAME_MAX_LEN]; const char *ptr; if (!netboot_open((char*)fname)) { /* file not found */ printf("File not found: \"%s\"\n", fname); return -L4_ENOTFOUND; } /* after succesful open of file, netboot_filemax consists of * the length of the file */ *size = netboot_filemax; ptr = strrchr(fname, '/'); if (!ptr) ptr=fname; else ptr++; snprintf(buf, L4DM_DS_NAME_MAX_LEN, "tftp image: %s", ptr); if (!(addr = l4dm_mem_ds_allocate_named_dsm(*size, flags, buf, *dm, (l4dm_dataspace_t *)ds))) { printf("Allocating dataspace of size %d failed\n", *size); netboot_close(); return -L4_ENOMEM; } printf("Loading %s [%dkB]\n", fname, (*size + 1023) / 1024); /* Reset display file position */ disp_filesizebarrier = disp_filesize = 0; read_size = netboot_read((char*) addr, *size); netboot_close(); /* file image is not mapped to our address space anymore */ if ((error = l4rm_detach((void *)addr))) { printf("Error %d detaching dataspace\n", error); l4dm_close((l4dm_dataspace_t*)ds); return -L4_ENOMEM; } if (!read_size) { printf("Error reading file %s\n" "TFTP error was %d (%s)\n", fname, netboot_errnum, err_list[netboot_errnum]); l4dm_close((l4dm_dataspace_t*)ds); return -L4_EIO; } /* set dataspace owner to client */ if ((error = l4dm_transfer((l4dm_dataspace_t *)ds,*_dice_corba_obj))) { printf("Error transfering dataspace ownership: %s (%d)\n", l4env_errstr(error), error); l4dm_close((l4dm_dataspace_t*)ds); return -L4_EINVAL; } return 0; } void tftp_client(void *unused) { l4_addr_t netbuf, gunzipbuf; /* get dataspace for the net buffer */ netbuf = (l4_addr_t) l4dm_mem_allocate_named(NETBUF_SIZE,0,"tftp netbuff"); if (netbuf == 0) { printf("Allocate netbuff failed\n"); exit(-1); } /* get dataspace for gunzip allocator buffer */ gunzipbuf = (l4_addr_t) l4dm_mem_allocate_named(GUNZIP_SIZE,0,"tftp gunzip"); if (gunzipbuf == 0) { printf("Allocate gunzip buffer failed\n"); exit(-1); } if (!names_register("TFTP")) { printf("failed to register at name server\n"); exit(-1); } l4fprov_file_server_loop(NULL); } void tftp_init(char *host) { l4io_info_t *io_info_addr = (l4io_info_t*)-1; /* set TFTP server (head node) */ if (!inet_aton(host, &tftp_server_addr)) printf("Invalid TFTP server address: %s!\n", host); else printf("Using TFTP server %s (0x%08x)\n", host, tftp_server_addr.s_addr); /* invoke L4 IO server */ if (l4io_init(&io_info_addr, L4IO_DRV_INVALID)) enter_kdebug("Couldn't connect to L4 IO server!"); #if 0 strncpy(tftp_orename, host, sizeof(tftp_orename)); tftp_orename[sizeof(tftp_orename)-1] = 0; #endif if ((ret = l4thread_create_long(L4THREAD_INVALID_ID, tftp_client, ".tftp_client", (unsigned)tftp_stack + sizeof(tftp_stack), sizeof(tftp_stack), L4THREAD_DEFAULT_PRIO, 0, L4THREAD_CREATE_ASYNC)) < 0) { Panic("Error %d creating tftp_client thread", ret); } } void tftp_get(char *file) { int error; l4_threadid_t tftp_id; l4_threadid_t dm_id; l4dm_dataspace_t ds; void *addr; l4_size_t size; CORBA_Environment _env = dice_default_environment; if (!names_waitfor_name("TFTP", &tftp_id, 10000)) { printf("TFTP not found\n"); return -1; } dm_id = l4env_get_default_dsm(); if (l4_is_invalid_id(dm_id)) { printf("No dataspace manager found\n"); return -1; } if ((error = l4fprov_file_open_call(&tftp_id, file, &dm_id, 0, &ds, &size, &_env))) { printf("Error opening file from tftp\n"); return -1; } if ((error = l4rm_attach(&ds, size, 0, L4DM_RO | L4RM_MAP, &addr))) { printf("Error %d attaching dataspace\n", error); return -L4_ENOMEM; } } void tftp_put(char *file) { } void tftp_mode(enum TFTP_mode unused) { /* no mode switching in L4 */ }

© 2007, Los Alamos National Security, LLC.