Mongoose MSVC2015 warnings cleanup, part1

PUBLISHED_FROM=9e173215ed69464d1aa421d43a8fda814f36f96d

CONTRIBUTING.md

@@ -0,0 +1,8 @@
+People who have agreed to the
+[Cesanta CLA](https://docs.cesanta.com/contributors_la.shtml)
+can make contributions. Note that the CLA isn't a copyright
+_assigment_ but rather a copyright _license_.
+You retain the copyright on your contributions.
+
+We follow the Google C/C++ style guide: https://google.github.io/styleguide/cppguide.html
+We'd appreciate if your contribution follows the same style guide.

LICENSE

@@ -1,5 +1,5 @@
 Copyright (c) 2004-2013 Sergey Lyubka <valenok@gmail.com>
-Copyright (c) 2013-2015 Cesanta Software Limited
+Copyright (c) 2013-2016 Cesanta Software Limited
 All rights reserved
 
 This software is dual-licensed: you can redistribute it and/or modify

README.md

@@ -1,12 +1,9 @@
-# <img src="http://www.cesanta.com/hubfs/www.cesanta.com/Images/mongoose_library.png" width="64" height="64"> Mongoose - Embedded Web Server
-
-[![Join the chat at https://gitter.im/cesanta/mongoose](https://badges.gitter.im/Join%20Chat.svg)](https://gitter.im/cesanta/mongoose?utm_source=badge&utm_medium=badge&utm_campaign=pr-badge&utm_content=badge)
+# <img src="http://www.cesanta.com/hubfs/www.cesanta.com/Images/mongoose_library.png" width="64" height="64"> Mongoose - Embedded Web Server / Embedded Networking Library
 
 ![](https://img.shields.io/badge/license-GPL_2-green.svg "License")
 
-
-Mongoose is ideal for embedded environments, it has been designed as an open
-source platform for connecting devices and bringing them online.
+Mongoose is ideal for embedded environments. It has been designed
+for connecting devices and bringing them online.
 [Mongoose](https://www.cesanta.com/products)
 has been on the market since 2004 and attracted
 over 1 million cumulative downloads.
@@ -16,20 +13,32 @@ network protocols or scalable network applications  with little effort.
 Mongoose helps developers to manage the complexity of network programming
 and let them concentrate on the logic, saving time and money.
 
-[Download Mongoose Source Code here](http://hubs.ly/H01bWvx0)
+- [Download Mongoose Source Code here](http://hubs.ly/H01bWvx0)
+- [Check our latest releases] (https://github.com/cesanta/mongoose/releases)
+- [Read User Guide and API reference](https://docs.cesanta.com/mongoose)
+- [Study mongoose example code](https://github.com/cesanta/mongoose/tree/master/examples)
 
 > Nothing overdone. Nothing less. So unbelievably easy to use.
 > Just how good software should be! -- Pritin Tyagaraj, SAP
 
+If you are looking for a complete IoT platform with firmware and cloud compotent, check out [Smart.js.] (https://github.com/cesanta/smart.js)
+
+# Support
+- [Support Forum - Ask your technical questions here] (http://forum.cesanta.com/index.php?p=/categories/smart-js)
+- [Chat - Visit www.cesanta.com for our live chat] (http://www.cesanta.com)
+- [Commercial one-to-one support - Available to all commercial license holders] (https://www.cesanta.com/services-support)
 
 # Features
 
-* Cross-platform: works on Linux/UNIX, QNX, eCos, Windows, Android, iPhone, etc
+* Cross-platform: works on Linux/UNIX, MacOS, QNX, eCos, Windows, Android,
+  iPhone, FreeRTOS (TI CC3200, ESP8266), etc
 * Single-threaded, asynchronous, non-blocking core with simple event-based API
+* Native support for [PicoTCP embedded TCP/IP stack](http://www.picotcp.com),
+  [LWIP embedded TCP/IP stack](https://en.wikipedia.org/wiki/LwIP)
 * Builtin protocols:
    - plain TCP, plain UDP, SSL/TLS (over TCP, one-way or two-way)
    - HTTP client, HTTP server
-   - Websocket client, Websocket server
+   - WebSocket client, WebSocket server
    - JSON-RPC client, JSON-RPC server
    - MQTT client, MQTT broker
    - CoAP client, CoAP server
@@ -40,13 +49,16 @@ and let them concentrate on the logic, saving time and money.
   [mongoose.c](https://raw.githubusercontent.com/cesanta/mongoose/master/mongoose.c) and
   [mongoose.h](https://raw.githubusercontent.com/cesanta/mongoose/master/mongoose.h)
   files to your build tree
-* Extensively tested and production-ready, trusted by many blue chip businesses
 
-# Examples & Documentation
+# Licensing
 
-- [User Guide](https://docs.cesanta.com/mongoose) - Detailed User Guide and API reference
-- [examples](examples) - Collection of well-commented examples. To build any example,
-go into respective directory and type `make`
+Mongoose is released under commercial and [GNU GPL v.2](http://www.gnu.org/licenses/old-licenses/gpl-2.0.html) open source licenses.
+
+Commercial Projects:
+Once your project becomes commercialised GPLv2 licensing dictates that you need to either open your source fully or purchase a commercial license. Cesanta offer full, royalty-free commercial licenses without any GPL restrictions. If your needs require a custom license, we’d be happy to work on a solution with you. [Contact us for pricing.] (https://www.cesanta.com/contact)
+
+Prototyping:
+While your project is still in prototyping stage and not for sale, you can use Mongoose’s open source code without license restrictions.
 
 # Dashboard Example
 
@@ -61,47 +73,6 @@ the functionality:
 
 # Contributions
 
-People who have agreed to the
-[Cesanta CLA](https://docs.cesanta.com/contributors_la.shtml)
-can make contributions. Note that the CLA isn't a copyright
-_assigment_ but rather a copyright _license_.
-You retain the copyright on your contributions.
+People who have agreed to the [Cesanta CLA] (https://docs.cesanta.com/contributors_la.shtml) can make contributions. Note that the CLA isn't a copyright assigment but rather a copyright license. You retain the copyright on your contributions.
 
-# Licensing
-
-You are using Mongoose under
-[GPLv2](http://www.gnu.org/licenses/old-licenses/gpl-2.0.en.html)
-and until you commercialize your
-application, can continue to use Mongoose free of charge.
-
-Once you commercialize your product, in order to comply with GPLv2
-you need to either open the source code of your product fully or
-alternatively purchase a commercial license.
-We offer [three levels of commercial licensing](https://www.cesanta.com/products):
-
-- Mongoose Lite: cross platform integration, SSL/TLS, HTTP support
-- Mongoose: Mongoose Lite + HTTP CGI, HTTP SSI, HTTP Digest Auth,
-  WebSocket support
-- Mongoose Premium: Mongoose + Plain TCP, UDP, JSON-RPC, MQTT, DNS,
-  CoAP support
-
-
-[Enquire about commercial licensing here](https://www.cesanta.com/contact)
-
-# Mongoose Binary
-
-This is our easy to use web server for web developers (PHP, Ruby, Python, etc)
-and web designers. Available in three editions to suit your needs: free, pro
-(USD 5) and dev edition (from USD 8). To install, simply download, double-click
-to start and run browser - that's all!
-
-[Download Mongoose Binary here](https://www.cesanta.com/products#binary)
-
-# Other products by Cesanta
-
-- [Smart.js](https://github.com/cesanta/smart.js) -
-    Generic, hardware independent, full-stack IoT software platform
-- [V7](https://github.com/cesanta/v7) - Embedded JavaScript engine
-- [Frozen](https://github.com/cesanta/frozen) - JSON parser and generator
-- [SLRE](https://github.com/cesanta/slre) - Super Light Regular Expression
-  library
+[![Analytics](https://ga-beacon.appspot.com/UA-42732794-5/project-page)](https://github.com/cesanta/mongoose)

examples/ESP8266_RTOS/Makefile

@@ -55,7 +55,7 @@ LINKFLAGS_eagle.app.v6 = \
     -u call_user_start	\
 	-Wl,-static						\
 	-Wl,--start-group					\
-	-lcirom \
+	-lc \
 	-lgcc					\
 	-lhal					\
 	-lphy	\

examples/ESP8266_RTOS/user/Makefile

@@ -1,47 +1,50 @@
-
-#############################################################
-# Required variables for each makefile
-# Discard this section from all parent makefiles
-# Expected variables (with automatic defaults):
-#   CSRCS (all "C" files in the dir)
-#   SUBDIRS (all subdirs with a Makefile)
-#   GEN_LIBS - list of libs to be generated ()
-#   GEN_IMAGES - list of images to be generated ()
-#   COMPONENTS_xxx - a list of libs/objs in the form
-#     subdir/lib to be extracted and rolled up into
-#     a generated lib/image xxx.a ()
-#
-ifndef PDIR
-GEN_LIBS = libuser.a
-endif
-
-
-#############################################################
-# Configuration i.e. compile options etc.
-# Target specific stuff (defines etc.) goes in here!
-# Generally values applying to a tree are captured in the
-#   makefile at its root level - these are then overridden
-#   for a subtree within the makefile rooted therein
-#
-DEFINES += -DMG_DISABLE_DAV -DMG_DISABLE_SYNC_RESOLVER -DMG_DISABLE_CGI \
-           -DMG_DISABLE_SOCKETPAIR -DMG_DISABLE_DIRECTORY_LISTING \
-           -DMG_MAX_HTTP_HEADERS=20 -DMG_MAX_HTTP_REQUEST_SIZE=1024 \
-           -DMG_MAX_PATH=40 -DMG_MAX_HTTP_SEND_IOBUF=1024 \
-           -DMG_ESP8266 -DRTOS_SDK -DMG_LWIP
-
-#############################################################
-# Recursion Magic - Don't touch this!!
-#
-# Each subtree potentially has an include directory
-#   corresponding to the common APIs applicable to modules
-#   rooted at that subtree. Accordingly, the INCLUDE PATH
-#   of a module can only contain the include directories up
-#   its parent path, and not its siblings
-#
-# Required for each makefile to inherit from the parent
-#
-
-INCLUDES += -I ./
-PDIR := ../$(PDIR)
-sinclude $(PDIR)Makefile
-
+
+#############################################################
+# Required variables for each makefile
+# Discard this section from all parent makefiles
+# Expected variables (with automatic defaults):
+#   CSRCS (all "C" files in the dir)
+#   SUBDIRS (all subdirs with a Makefile)
+#   GEN_LIBS - list of libs to be generated ()
+#   GEN_IMAGES - list of images to be generated ()
+#   COMPONENTS_xxx - a list of libs/objs in the form
+#     subdir/lib to be extracted and rolled up into
+#     a generated lib/image xxx.a ()
+#
+ifndef PDIR
+GEN_LIBS = libuser.a
+endif
+
+
+#############################################################
+# Configuration i.e. compile options etc.
+# Target specific stuff (defines etc.) goes in here!
+# Generally values applying to a tree are captured in the
+#   makefile at its root level - these are then overridden
+#   for a subtree within the makefile rooted therein
+#
+DEFINES += -DMG_LOCALS \
+           -DMG_NO_BSD_SOCKETS \
+           -DMG_DISABLE_FILESYSTEM \
+           -DMG_DISABLE_STDIO \
+           -DMG_MAX_HTTP_HEADERS=20 -DMG_MAX_HTTP_REQUEST_SIZE=1024 \
+           -DMG_MAX_PATH=40 -DMG_MAX_HTTP_SEND_MBUF=1024 \
+           -DRTOS_SDK -DMG_LWIP -DLWIP_TIMEVAL_PRIVATE=0 \
+           -DMG_INTERNAL=
+
+#############################################################
+# Recursion Magic - Don't touch this!!
+#
+# Each subtree potentially has an include directory
+#   corresponding to the common APIs applicable to modules
+#   rooted at that subtree. Accordingly, the INCLUDE PATH
+#   of a module can only contain the include directories up
+#   its parent path, and not its siblings
+#
+# Required for each makefile to inherit from the parent
+#
+
+INCLUDES += -I ./
+PDIR := ../$(PDIR)
+sinclude $(PDIR)Makefile
+

examples/ESP8266_RTOS/user/esp_libc.c

@@ -16,6 +16,7 @@
 #include "esp_common.h"
 
 /* Makes fprintf(stdout) and stderr work. */
+/*
 _ssize_t _write_r(struct _reent *r, int fd, void *buf, size_t len) {
   if (fd == 1 || fd == 2) {
     size_t i;
@@ -26,6 +27,7 @@ _ssize_t _write_r(struct _reent *r, int fd, void *buf, size_t len) {
   }
   return -1;
 }
+*/
 
 /*
  * You'll need to implement _open_r and friends if you want file operations. See
@@ -42,7 +44,6 @@ void abort(void) {
 }
 
 void _exit(int status) {
-  printf("_exit(%d)\n", status);
   abort();
 }
 
@@ -52,3 +53,7 @@ int _gettimeofday_r(struct _reent *r, struct timeval *tp, void *tzp) {
   tp->tv_usec = time % 1000000;
   return 0;
 }
+
+long int random(void) {
+  return os_random();
+}

examples/ESP8266_RTOS/user/user_main.c

@@ -37,6 +37,7 @@ void ev_handler(struct mg_connection *nc, int ev, void *p) {
     case MG_EV_HTTP_REQUEST: {
       char addr[32];
       struct http_message *hm = (struct http_message *) p;
+      (void) hm;
       mg_sock_addr_to_str(&nc->sa, addr, sizeof(addr),
                           MG_SOCK_STRINGIFY_IP | MG_SOCK_STRINGIFY_PORT);
       LOG(LL_INFO,
@@ -100,9 +101,13 @@ xTaskHandle s_mg_task_handle;
 void user_init(void) {
   uart_div_modify(0, UART_CLK_FREQ / 115200);
 
-  setvbuf(stdout, NULL, _IONBF, 0);
-  setvbuf(stderr, NULL, _IONBF, 0);
+//  setvbuf(stdout, NULL, _IONBF, 0);
+//  setvbuf(stderr, NULL, _IONBF, 0);
 
   xTaskCreate(mg_task, (const signed char *) "mongoose", MG_TASK_STACK_SIZE,
               NULL, MG_TASK_PRIORITY, &s_mg_task_handle);
 }
+
+void call_user_start(void) {
+  user_init();
+}

examples/api_server/api_server.c

@@ -10,9 +10,9 @@ static struct mg_serve_http_opts s_http_server_opts;
 static int s_sig_num = 0;
 static void *s_db_handle = NULL;
 static const char *s_db_path = "api_server.db";
-static const struct mg_str s_get_method = MG_STR("GET");
-static const struct mg_str s_put_method = MG_STR("PUT");
-static const struct mg_str s_delele_method = MG_STR("DELETE");
+static const struct mg_str s_get_method = MG_MK_STR("GET");
+static const struct mg_str s_put_method = MG_MK_STR("PUT");
+static const struct mg_str s_delele_method = MG_MK_STR("DELETE");
 
 static void signal_handler(int sig_num) {
   signal(sig_num, signal_handler);
@@ -28,7 +28,7 @@ static int is_equal(const struct mg_str *s1, const struct mg_str *s2) {
 }
 
 static void ev_handler(struct mg_connection *nc, int ev, void *ev_data) {
-  static const struct mg_str api_prefix = MG_STR("/api/v1");
+  static const struct mg_str api_prefix = MG_MK_STR("/api/v1");
   struct http_message *hm = (struct http_message *) ev_data;
   struct mg_str key;
 

examples/big_upload/Makefile

@@ -1,2 +1,3 @@
 PROG = big_upload
+MODULE_CFLAGS = -DMG_ENABLE_HTTP_STREAMING_MULTIPART
 include ../examples.mk

examples/big_upload/big_upload.c

@@ -13,12 +13,11 @@ static const char *s_http_port = "8000";
 
 struct file_writer_data {
   FILE *fp;
-  size_t bytes_left;
+  size_t bytes_written;
 };
 
 static void handle_request(struct mg_connection *nc) {
-  // This handler gets called only when we don't reset proto_handler in
-  // handle_recv, so we just return a page unconditionally.
+  // This handler gets for all endpoints but /upload
   mg_printf(nc, "%s",
             "HTTP/1.1 200 OK\r\n"
             "Content-Type: text/html\r\n"
@@ -33,66 +32,40 @@ static void handle_request(struct mg_connection *nc) {
   nc->flags |= MG_F_SEND_AND_CLOSE;
 }
 
-static void handle_recv(struct mg_connection *nc) {
+static void handle_upload(struct mg_connection *nc, int ev, void *p) {
   struct file_writer_data *data = (struct file_writer_data *) nc->user_data;
+  struct mg_http_multipart_part *mp = (struct mg_http_multipart_part*)p;
 
-  if (data == NULL) {
-    // This is a new connection, try to parse HTTP request.
-    struct http_message hm;
-    int req_len = mg_parse_http(nc->recv_mbuf.buf, nc->recv_mbuf.len, &hm,
-                                1 /* is_req */);
+  switch (ev) {
+    case MG_EV_HTTP_PART_BEGIN: {
+      if (data == NULL) {
+        data = calloc(1, sizeof(struct file_writer_data));
+        data->fp = tmpfile();
+        data->bytes_written = 0;
 
-    if (req_len < 0 ||
-        (req_len == 0 && nc->recv_mbuf.len >= MG_MAX_HTTP_REQUEST_SIZE)) {
-      nc->flags |= MG_F_CLOSE_IMMEDIATELY;
-    } else if (req_len == 0) {
-      // Request is not complete yet, do nothing.
-    } else if (mg_vcasecmp(&hm.method, "POST") == 0 &&
-               mg_vcmp(&hm.uri, "/upload") == 0) {
-      // This is the request that we don't want to buffer in memory.
-
-      if (hm.body.len == (size_t) ~0 || hm.body.len == 0) {
-        mg_printf(nc, "%s",
-                  "HTTP/1.1 411 Content-Length required\r\n"
-                  "Content-Length: 0\r\n\r\n");
-        nc->flags |= MG_F_SEND_AND_CLOSE;
-        return;
+        if (data->fp == NULL) {
+          mg_printf(nc, "%s",
+                    "HTTP/1.1 500 Failed to open a file\r\n"
+                    "Content-Length: 0\r\n\r\n");
+          nc->flags |= MG_F_SEND_AND_CLOSE;
+          return;
+        }
+        nc->user_data = (void *) data;
       }
-
-      // Reset proto_handler so Mongoose's http_handler() won't get confused
-      // once we start removing data from the buffer.
-      nc->proto_handler = NULL;
-
-      // Headers will be inaccessible later, so put everything we need into
-      // user_data.
-      data = calloc(1, sizeof(struct file_writer_data));
-      data->bytes_left = hm.body.len;
-      data->fp = tmpfile();
-      if (data->fp == NULL) {
-        mg_printf(nc, "%s",
-                  "HTTP/1.1 500 Failed to open a file\r\n"
-                  "Content-Length: 0\r\n\r\n");
-        nc->flags |= MG_F_SEND_AND_CLOSE;
-        return;
-      }
-      nc->user_data = (void *) data;
-
-      // Remove the headers from the buffer.
-      mbuf_remove(&nc->recv_mbuf, hm.body.p - nc->recv_mbuf.buf);
-
-      // Invoke itself again to write the piece of the body that is already in
-      // the buffer.
-      handle_recv(nc);
+      break;
     }
-  } else {  // data != NULL
-    size_t to_write = data->bytes_left, written = 0;
-    if (nc->recv_mbuf.len < to_write) to_write = nc->recv_mbuf.len;
-    written = fwrite(nc->recv_mbuf.buf, 1, to_write, data->fp);
-    mbuf_remove(&nc->recv_mbuf, written);
-    data->bytes_left -= written;
-    if (data->bytes_left <= 0) {
-      // Request is complete, do something meaningful here.
-
+    case MG_EV_HTTP_PART_DATA: {
+      if (fwrite(mp->data.p, 1, mp->data.len, data->fp) != mp->data.len) {
+        mg_printf(nc, "%s",
+                  "HTTP/1.1 500 Failed to write to a file\r\n"
+                  "Content-Length: 0\r\n\r\n");
+        nc->flags |= MG_F_SEND_AND_CLOSE;
+        return;
+      }
+      data->bytes_written += mp->data.len;
+      break;
+    }
+    case MG_EV_HTTP_PART_END: {
       mg_printf(nc,
                 "HTTP/1.1 200 OK\r\n"
                 "Content-Type: text/plain\r\n"
@@ -100,22 +73,14 @@ static void handle_recv(struct mg_connection *nc) {
                 "Written %ld of POST data to a temp file\n\n",
                 (long) ftell(data->fp));
       nc->flags |= MG_F_SEND_AND_CLOSE;
-      // handle_close will free the resources.
+      fclose(data->fp);
+      free(data);
+      nc->user_data = NULL;
+      break;
     }
   }
 }
 
-// Make sure we free all allocated resources
-static void handle_close(struct mg_connection *nc) {
-  struct file_writer_data *data = (struct file_writer_data *) nc->user_data;
-
-  if (data != NULL) {
-    fclose(data->fp);
-    free(data);
-    nc->user_data = NULL;
-  }
-}
-
 static void ev_handler(struct mg_connection *nc, int ev, void *ev_data) {
   (void) ev_data;
   switch (ev) {
@@ -123,13 +88,6 @@ static void ev_handler(struct mg_connection *nc, int ev, void *ev_data) {
       // Invoked when the full HTTP request is in the buffer (including body).
       handle_request(nc);
       break;
-    case MG_EV_RECV:
-      // Invoked every time new data arrives.
-      handle_recv(nc);
-      break;
-    case MG_EV_CLOSE:
-      handle_close(nc);
-      break;
   }
 }
 
@@ -140,6 +98,7 @@ int main(void) {
   mg_mgr_init(&mgr, NULL);
   nc = mg_bind(&mgr, s_http_port, ev_handler);
 
+  mg_register_http_endpoint(nc, "/upload", handle_upload);
   // Set up HTTP server parameters
   mg_set_protocol_http_websocket(nc);
 

examples/coap_client/coap_client.c

@@ -2,14 +2,14 @@
  * Copyright (c) 2015 Cesanta Software Limited
  * All rights reserved
  *
- * This program sends CoAP CON-message to server (coap.me by default) 
+ * This program sends CoAP CON-message to server (coap.me by default)
  * and waits for answer.
  */
 
 #include "mongoose.h"
 
 static int s_time_to_exit = 0;
-static char* s_default_address = "udp://coap.me:5683";
+static char *s_default_address = "udp://coap.me:5683";
 
 static void coap_handler(struct mg_connection *nc, int ev, void *p) {
   switch (ev) {
@@ -31,17 +31,16 @@ static void coap_handler(struct mg_connection *nc, int ev, void *p) {
       break;
     }
     case MG_EV_COAP_ACK:
-    case MG_EV_COAP_RST:  {
-      struct mg_coap_message *cm = (struct mg_coap_message *)p;
-      printf("ACK/RST for message with msg_id = %d received\n",
-             cm->msg_id);
+    case MG_EV_COAP_RST: {
+      struct mg_coap_message *cm = (struct mg_coap_message *) p;
+      printf("ACK/RST for message with msg_id = %d received\n", cm->msg_id);
       s_time_to_exit = 1;
       break;
     }
   }
 }
 
-int main(int argc, char* argv[]) {
+int main(int argc, char *argv[]) {
   struct mg_mgr mgr;
   struct mg_connection *nc;
   char *address = s_default_address;
@@ -50,7 +49,7 @@ int main(int argc, char* argv[]) {
     address = argv[1];
   }
 
-  printf("Using %s as CoAP server\n", address); 
+  printf("Using %s as CoAP server\n", address);
 
   mg_mgr_init(&mgr, 0);
 
@@ -63,10 +62,10 @@ int main(int argc, char* argv[]) {
   mg_set_protocol_coap(nc);
 
   while (!s_time_to_exit) {
-    mg_mgr_poll(&mgr, 1);
+    mg_mgr_poll(&mgr, 1000000);
   }
 
   mg_mgr_free(&mgr);
-  
+
   return 0;
 }

examples/coap_server/coap_server.c

@@ -2,18 +2,18 @@
  * Copyright (c) 2015 Cesanta Software Limited
  * All rights reserved
  *
- * This program listens on 5683 for CoAP messages, 
+ * This program listens on 5683 for CoAP messages,
  * sends ACK is nessesary and dump everything received.
  * It is possible to use ../coap_client to send message.
  */
 
 #include "mongoose.h"
 
-static char* s_default_address = "udp://:5683";
+static char *s_default_address = "udp://:5683";
 static int s_sig_received = 0;
 
 static void signal_handler(int sig_num) {
-  signal(sig_num, signal_handler); 
+  signal(sig_num, signal_handler);
   s_sig_received = sig_num;
 }
 
@@ -21,7 +21,7 @@ static void coap_handler(struct mg_connection *nc, int ev, void *p) {
   switch (ev) {
     case MG_EV_COAP_CON: {
       uint32_t res;
-      struct mg_coap_message *cm = (struct mg_coap_message *)p;
+      struct mg_coap_message *cm = (struct mg_coap_message *) p;
       printf("CON with msg_id = %d received\n", cm->msg_id);
       res = mg_coap_send_ack(nc, cm->msg_id);
       if (res == 0) {
@@ -34,10 +34,9 @@ static void coap_handler(struct mg_connection *nc, int ev, void *p) {
     }
     case MG_EV_COAP_NOC:
     case MG_EV_COAP_ACK:
-    case MG_EV_COAP_RST:  {
-      struct mg_coap_message *cm = (struct mg_coap_message *)p;
-      printf("ACK/RST/NOC with msg_id = %d received\n",
-             cm->msg_id);
+    case MG_EV_COAP_RST: {
+      struct mg_coap_message *cm = (struct mg_coap_message *) p;
+      printf("ACK/RST/NOC with msg_id = %d received\n", cm->msg_id);
       break;
     }
   }
@@ -58,12 +57,12 @@ int main() {
     return -1;
   }
 
-  printf("Listening for CoAP messages at %s\n", s_default_address); 
+  printf("Listening for CoAP messages at %s\n", s_default_address);
 
   mg_set_protocol_coap(nc);
 
   while (!s_sig_received) {
-    mg_mgr_poll(&mgr, 1);
+    mg_mgr_poll(&mgr, 1000000);
   }
 
   printf("Exiting on signal %d\n", s_sig_received);

examples/examples.mk

@@ -1,5 +1,5 @@
 SOURCES = $(PROG).c ../../mongoose.c
-CFLAGS = -W -Wall -I../.. -Wno-unused-function $(CFLAGS_EXTRA) $(MODULE_CFLAGS)
+CFLAGS = -g -W -Wall -I../.. -Wno-unused-function $(CFLAGS_EXTRA) $(MODULE_CFLAGS)
 
 all: $(PROG)
 

examples/load_balancer/load_balancer.c

@@ -233,6 +233,12 @@ static void forward(struct conn_data *conn, struct http_message *hm,
     /* We always rewrite the connection header depending on the settings. */
     if (mg_vcasecmp(&hn, "Connection") == 0) continue;
 
+    /* Don't pass chunked transfer encoding to the client */
+    if (mg_vcasecmp(&hn, "Transfer-encoding") == 0 &&
+        mg_vcasecmp(&hv, "chunked") == 0) {
+      continue;
+    }
+
     mg_printf(dst, "%.*s: %.*s\r\n", (int) hn.len, hn.p, (int) hv.len, hv.p);
   }
 
@@ -272,7 +278,7 @@ static int connect_backend(struct conn_data *conn, struct http_message *hm) {
   struct http_backend *be = choose_backend(hm);
 
   write_log("%.*s %.*s backend=%s\n", (int) hm->method.len, hm->method.p,
-            (int) hm->uri.len, hm->uri.p, be->host_port);
+            (int) hm->uri.len, hm->uri.p, be ? be->host_port : "not defined");
 
   if (be == NULL) return 0;
   if (be->redirect != 0) {
@@ -413,7 +419,9 @@ static void ev_handler(struct mg_connection *nc, int ev, void *ev_data) {
       }
       return;
     } else {
-      nc->flags |= MG_F_CLOSE_IMMEDIATELY;
+      if (ev != MG_EV_POLL) {
+        nc->flags |= MG_F_CLOSE_IMMEDIATELY;
+      }
       return;
     }
   }

examples/restful_client/restful_client.c

@@ -6,8 +6,8 @@
 #include "mongoose.h"
 
 /* RESTful server host and request URI */
-static const char *s_target_address = "ajax.googleapis.com:80";
-static const char *s_request = "/ajax/services/search/web?v=1.0&q=cesanta";
+static const char *s_url =
+    "http://ajax.googleapis.com/ajax/services/search/web?v=1.0&q=cesanta";
 
 static int s_exit_flag = 0;
 
@@ -17,14 +17,9 @@ static void ev_handler(struct mg_connection *nc, int ev, void *ev_data) {
 
   switch (ev) {
     case MG_EV_CONNECT:
-      connect_status = * (int *) ev_data;
-      if (connect_status == 0) {
-        printf("Connected to %s, sending request...\n", s_target_address);
-        mg_printf(nc, "GET %s HTTP/1.0\r\nHost: %s\r\n\r\n",
-                  s_request, s_target_address);
-      } else {
-        printf("Error connecting to %s: %s\n",
-               s_target_address, strerror(connect_status));
+      connect_status = *(int *) ev_data;
+      if (connect_status != 0) {
+        printf("Error connecting to %s: %s\n", s_url, strerror(connect_status));
         s_exit_flag = 1;
       }
       break;
@@ -43,10 +38,10 @@ int main(void) {
   struct mg_connection *nc;
 
   mg_mgr_init(&mgr, NULL);
-  nc = mg_connect(&mgr, s_target_address, ev_handler);
+  nc = mg_connect_http(&mgr, ev_handler, s_url, NULL, NULL);
   mg_set_protocol_http_websocket(nc);
 
-  printf("Starting RESTful client against %s\n", s_target_address);
+  printf("Starting RESTful client against %s\n", s_url);
   while (s_exit_flag == 0) {
     mg_mgr_poll(&mgr, 1000);
   }

examples/simplest_web_server/Makefile

@@ -1,6 +1,7 @@
 PROG = simplest_web_server
 SOURCES = $(PROG).c ../../mongoose.c
-CFLAGS = -W -Wall -I../.. $(CFLAGS_EXTRA)
+CFLAGS = -W -Wall -I../.. $(CFLAGS_EXTRA) -DMG_DISABLE_DAV_AUTH \
+				 -DMG_ENABLE_FAKE_DAVLOCK
 
 all: $(PROG)
 

examples/simplest_web_server/simplest_web_server.c

@@ -8,7 +8,7 @@ static struct mg_serve_http_opts s_http_server_opts;
 
 static void ev_handler(struct mg_connection *nc, int ev, void *p) {
   if (ev == MG_EV_HTTP_REQUEST) {
-    mg_serve_http(nc, p, s_http_server_opts);
+    mg_serve_http(nc, (struct http_message *) p, s_http_server_opts);
   }
 }
 
@@ -22,6 +22,7 @@ int main(void) {
   // Set up HTTP server parameters
   mg_set_protocol_http_websocket(nc);
   s_http_server_opts.document_root = ".";  // Serve current directory
+  s_http_server_opts.dav_document_root = ".";  // Allow access via WebDav
   s_http_server_opts.enable_directory_listing = "yes";
 
   printf("Starting web server on port %s\n", s_http_port);