Merge branch '2.0' into 2.1.0

Documentation/About/Limitations.md

@@ -231,5 +231,7 @@ executed in separate parts.
 query will be routed to the first available server. This possibly returns an
 error about database rights instead of a missing database.
 
-* As text protocol prepared statements are relatively rare, prepared statements
+* The preparation of a prepared statement is routed to all servers. The
-are not supported in schemarouter.
+execution of a prepared statement is routed to the first available server or to
+the server pointed by a routing hint attached to the query. In practice this
+means that prepared statements aren't supported by the schemarouter.

Documentation/Release-Notes/MaxScale-2.0.4-Release-Notes.md

@@ -1,4 +1,4 @@
-# MariaDB MaxScale 2.0.4 Release Notes
+# MariaDB MaxScale 2.0.4 Release Notes -- 2017-02-01
 
 Release 2.0.4 is a GA release.
 

include/maxscale/service.h

@@ -90,7 +90,7 @@ typedef struct server_ref_t
 #define SERVICE_MAX_RETRY_INTERVAL 3600 /*< The maximum interval between service start retries */
 
 /** Value of service timeout if timeout checks are disabled */
-#define SERVICE_NO_SESSION_TIMEOUT LONG_MAX
+#define SERVICE_NO_SESSION_TIMEOUT 0
 
 /**
  * Parameters that are automatically detected but can also be configured by the
@@ -145,7 +145,7 @@ typedef struct service
     SERVICE_REFRESH_RATE rate_limit;   /**< The refresh rate limit for users table */
     MXS_FILTER_DEF **filters;          /**< Ordered list of filters */
     int n_filters;                     /**< Number of filters */
-    long conn_idle_timeout;            /**< Session timeout in seconds */
+    uint64_t conn_idle_timeout;            /**< Session timeout in seconds */
     char *weightby;                    /**< Service weighting parameter name */
     struct service *next;              /**< The next service in the linked list */
     bool retry_start;                  /**< If starting of the service should be retried later */

server/core/dcb.c

@@ -3502,7 +3502,9 @@ void dcb_process_idle_sessions(int thr)
             {
                 MXS_SESSION *session = dcb->session;
 
-                if (session->service && session->client_dcb && session->client_dcb->state == DCB_STATE_POLLING &&
+                if (session->service && session->client_dcb &&
+                    session->client_dcb->state == DCB_STATE_POLLING &&
+                    session->service->conn_idle_timeout &&
                     hkheartbeat - session->client_dcb->last_read > session->service->conn_idle_timeout * 10)
                 {
                     poll_fake_hangup_event(dcb);

server/modules/routing/avrorouter/avro_file.c

@@ -68,7 +68,12 @@ bool avro_open_binlog(const char *binlogdir, const char *file, int *dest)
 
     if ((fd = open(path, O_RDONLY)) == -1)
     {
-        MXS_ERROR("Failed to open binlog file %s.", path);
+        if (errno != ENOENT)
+        {
+            char err[STRERROR_BUFLEN];
+            MXS_ERROR("Failed to open binlog file %s: %d, %s", path, errno,
+                      strerror_r(errno, err, sizeof(err)));
+        }
         return false;
     }
 

server/modules/routing/avrorouter/avro_schema.c

@@ -479,7 +479,15 @@ static const char *extract_field_name(const char* ptr, char* dest, size_t size)
     if (ptr > start)
     {
         /** Valid identifier */
-        snprintf(dest, size, "%.*s", (int)(ptr - start), start);
+        size_t bytes = ptr - start;
+
+        if (bt)
+        {
+            bytes--;
+        }
+
+        memcpy(dest, start, bytes);
+        dest[bytes] = '\0';
 
         make_valid_avro_identifier(dest);
         ptr = next_field_definition(ptr);