Merge branch 'dev' of github.com:fwsGonzo/IncludeOS into dev

Author: fwsGonzo

api/fs/common.hpp

@@ -28,9 +28,8 @@
 
 namespace fs {
 
-  // Generic structure for directory entries
   struct Dirent;
-
+  struct File_system;
 
   /**
    * @brief Type used as a building block to represent buffers
@@ -185,24 +184,23 @@ namespace fs {
   /** @var no_error: Always returns boolean false when used in expressions */
   extern error_t no_error;
 
-    /** Async function types **/
-  using on_init_func  = delegate<void(error_t)>;
+  /** Async function types **/
+  using on_init_func  = delegate<void(error_t, File_system&)>;
   using on_ls_func    = delegate<void(error_t, dirvec_t)>;
   using on_read_func  = delegate<void(error_t, buffer_t, uint64_t)>;
   using on_stat_func  = delegate<void(error_t, const Dirent&)>;
 
 
-  struct List {
+  struct List
+  {
     error_t  error;
     dirvec_t entries;
     auto begin() { return entries->begin(); }
     auto end() { return entries->end(); }
     auto cbegin() { return entries->cbegin(); }
     auto cend() { return entries->cend(); }
-
   };
 
+} //< fs
 
-} //< namespace fs
-
-#endif //< FS_ERROR_HPP
+#endif //< FS_COMMON_HPP

api/fs/disk.hpp

@@ -42,7 +42,7 @@ namespace fs {
 
     struct Partition;
     using on_parts_func = delegate<void(fs::error_t, std::vector<Partition>&)>;
-    using on_init_func = delegate<void(fs::error_t)>;
+    using on_init_func  = delegate<void(fs::error_t, File_system&)>;
     using lba_t = uint32_t;
 
     enum partition_t {

api/fs/filesystem.hpp

@@ -27,10 +27,6 @@ namespace fs {
   struct Dirent;
 
   struct File_system {
-
-    /** Initialize this filesystem with LBA at @base_sector */
-    virtual void init(uint64_t lba, uint64_t size, on_init_func on_init) = 0;
-
     /** Get unique (per device type) device id for underlying device.*/
     virtual Device_id device_id() = 0;
 
@@ -76,6 +72,9 @@ namespace fs {
     /** Returns the name of this filesystem */
     virtual std::string name() const = 0;
 
+    /** Initialize this filesystem with LBA at @base_sector */
+    virtual void init(uint64_t lba, uint64_t size, on_init_func on_init) = 0;
+
     /** Default destructor */
     virtual ~File_system() noexcept = default;
   }; //< class File_system

api/net/buffer_store.hpp

@@ -82,9 +82,10 @@ namespace net
     std::vector<buffer_t> available_;
     int                  cpu;
     static bool          smp_enabled_;
+#ifndef INCLUDEOS_SINGLE_THREADED
     // has strict alignment reqs, so put at end
     spinlock_t           plock;
-
+#endif
     BufferStore(BufferStore&)  = delete;
     BufferStore(BufferStore&&) = delete;
     BufferStore& operator=(BufferStore&)  = delete;

api/net/http/connection.hpp

@@ -67,7 +67,7 @@ namespace http {
     inline TCP_conn release();
 
     /**
-     * @brief      Wether the underlying TCP connection has been released or not
+     * @brief      Whether the underlying TCP connection has been released or not
      *
      * @return     true if the underlying TCP connection is released
      */

api/net/http/message.hpp

@@ -99,7 +99,7 @@ class Message {
    *
    * @param[in]  len   The length of the content
    *
-   * @return     Outcome of wether the field got updated or not
+   * @return     Outcome of whether the field got updated or not
    */
   inline bool set_content_length(size_t len);
 

api/net/inet.hpp

@@ -100,6 +100,7 @@ namespace net {
     virtual void force_start_send_queues() = 0;
 
     virtual void move_to_this_cpu() = 0;
+    virtual int  get_cpu_id() const noexcept = 0;
 
   }; //< class Inet<LINKLAYER, IPV>
 } //< namespace net

api/net/inet4.hpp

@@ -194,6 +194,10 @@ namespace net {
 
     void move_to_this_cpu() override;
 
+    int  get_cpu_id() const noexcept override {
+      return this->cpu_id;
+    }
+
     /** Return the stack on the given Nic */
     template <int N = 0>
     static auto&& stack()
@@ -248,6 +252,7 @@ namespace net {
 
     std::shared_ptr<net::DHClient> dhcp_{};
 
+    int   cpu_id;
     const uint16_t MTU_;
 
     friend class Super_stack;

api/net/tcp/connection.hpp

@@ -642,7 +642,7 @@ class Connection : public std::enable_shared_from_this<Connection> {
   void writeq_reset();
 
   /*
-    Mark wether the Connection is in TCP write queue or not.
+    Mark whether the Connection is in TCP write queue or not.
   */
   void set_queued(bool queued)
   { queued_ = queued; }
@@ -888,7 +888,7 @@ class Connection : public std::enable_shared_from_this<Connection> {
   void timewait_timeout()
   { signal_close(); }
 
-  /** Wether to use Delayed ACK or not */
+  /** Whether to use Delayed ACK or not */
   bool use_dack() const;
 
   /**

api/net/tcp/rttm.hpp

@@ -60,7 +60,7 @@ struct RTTM {
   {}
 
   /**
-   * @brief      Returns wether the RTTM is currently "measuring" (time is set)
+   * @brief      Returns whether the RTTM is currently "measuring" (time is set)
    *
    * @return     True if the RTTM is active (measuring)
    */