Merge branch 'master' of github.com:ClickHouse/ClickHouse into divanik/add_some_more_convenient_metadata_resolving_settings

Author: divanik

.github/workflows/master.yml

@@ -928,8 +928,8 @@ jobs:
           fi
 
   unit_tests_asan:
-    runs-on: [self-hosted, builder-aarch64]
-    needs: [config_workflow, build_arm_asan]
+    runs-on: [self-hosted, builder]
+    needs: [config_workflow, build_amd_asan]
     if: ${{ !failure() && !cancelled() && !contains(fromJson(needs.config_workflow.outputs.data).cache_success_base64, 'VW5pdCB0ZXN0cyAoYXNhbik=') }}
     name: "Unit tests (asan)"
     outputs:

.github/workflows/pull_request.yml

@@ -1120,8 +1120,8 @@ jobs:
           fi
 
   unit_tests_asan:
-    runs-on: [self-hosted, builder-aarch64]
-    needs: [config_workflow, dockers_build_amd_and_merge, build_arm_asan]
+    runs-on: [self-hosted, builder]
+    needs: [config_workflow, dockers_build_amd_and_merge, build_amd_asan]
     if: ${{ !failure() && !cancelled() && !contains(fromJson(needs.config_workflow.outputs.data).cache_success_base64, 'VW5pdCB0ZXN0cyAoYXNhbik=') }}
     name: "Unit tests (asan)"
     outputs:

README.md

@@ -54,6 +54,7 @@ Upcoming meetups
 * [Kuala Lumper Meetup with CNCF](https://www.meetup.com/clickhouse-malaysia-meetup-group/events/306697678/) - April 16, 2025
 * [Jakarta Meetup with AWS](https://www.meetup.com/clickhouse-indonesia-user-group/events/306973747/) - April 22, 2025
 * [London Meetup](https://www.meetup.com/clickhouse-london-user-group/events/306047172/) - May 14, 2025
+* [Istanbul Meetup](https://www.meetup.com/clickhouse-turkiye-meetup-group/events/306978337/) - May 15, 2025
 
 Recent meetups
 * [Washington DC Meetup](https://www.meetup.com/clickhouse-dc-user-group/events/306439995) - March 27, 2025

base/base/defines.h

@@ -28,12 +28,6 @@
 #define NO_INLINE __attribute__((__noinline__))
 #define MAY_ALIAS __attribute__((__may_alias__))
 
-#if defined(__x86_64__) || defined(__aarch64__)
-#    define PRESERVE_MOST __attribute__((preserve_most))
-#else
-#    define PRESERVE_MOST
-#endif
-
 #if !defined(__x86_64__) && !defined(__aarch64__) && !defined(__PPC__) && !defined(__s390x__) && !(defined(__loongarch64)) && !(defined(__riscv) && (__riscv_xlen == 64))
 #    error "The only supported platforms are x86_64 and AArch64, PowerPC (work in progress), s390x (work in progress), loongarch64 (experimental) and RISC-V 64 (experimental)"
 #endif

base/poco/Net/include/Poco/Net/StreamSocket.h

@@ -72,6 +72,9 @@ namespace Net
         /// attaches the SocketImpl from the other socket and
         /// increments the reference count of the SocketImpl.
 
+        void bind(const SocketAddress& address, bool reuseAddress);
+        /// Binds the socket to the given address
+
         void connect(const SocketAddress & address);
         /// Initializes the socket and establishes a connection to
         /// the TCP server at the given address.

base/poco/Net/src/StreamSocket.cpp

@@ -72,6 +72,11 @@ StreamSocket& StreamSocket::operator = (const Socket& socket)
 	return *this;
 }
 
+void StreamSocket::bind(const SocketAddress& address, bool reuseAddress)
+{
+       static_cast<StreamSocketImpl*>(impl())->bind(address, reuseAddress);
+}
+
 
 void StreamSocket::connect(const SocketAddress& address)
 {

base/poco/NetSSL_OpenSSL/include/Poco/Net/SecureStreamSocket.h

@@ -157,6 +157,9 @@ namespace Net
         void setPeerHostName(const std::string & hostName);
         /// Sets the peer's host name used for certificate validation.
 
+        void bind(const SocketAddress& address, bool reuseAddress);
+        /// Binds the socket to the given address
+
         const std::string & getPeerHostName() const;
         /// Returns the peer's host name used for certificate validation.
 

base/poco/NetSSL_OpenSSL/include/Poco/Net/SecureStreamSocketImpl.h

@@ -66,10 +66,30 @@ namespace Net
         /// the TCP server at the given address. Prior to opening the
         /// connection the socket is set to nonblocking mode.
 
-        void bind(const SocketAddress & address, bool reuseAddress = false, bool reusePort = false);
-        /// Not supported by a SecureStreamSocket.
+        void bind(const SocketAddress& address, bool reuseAddress);
+        /// Bind a local address to the socket.
         ///
         /// Throws a Poco::InvalidAccessException.
+        /// This is usually only done when establishing a server
+        /// socket.
+        ///
+        /// TCP clients normally do not bind to a local address,
+        /// but in some special advanced cases it may be useful to have
+        /// this type of functionality.  (e.g. in multihoming situations
+        /// where the traffic will be sent through a particular interface;
+        /// or in computer clustered environments with active/standby
+        /// servers and it is desired to make the traffic from either
+        /// active host present the same source IP address).
+        ///
+        /// Note:  Practical use of client source IP address binding
+        ///        may require OS networking setup outside the scope of
+        ///        the Poco library.
+        ///
+        /// If reuseAddress is true, sets the SO_REUSEADDR
+        /// socket option.
+        ///
+        /// TODO: implement IPv6 version
+        ///
 
         void listen(int backlog = 64);
         /// Not supported by a SecureStreamSocket.

base/poco/NetSSL_OpenSSL/src/SecureStreamSocket.cpp

@@ -140,7 +140,12 @@ void SecureStreamSocket::setPeerHostName(const std::string& hostName)
 	static_cast<SecureStreamSocketImpl*>(impl())->setPeerHostName(hostName);
 }
 
-	
+void SecureStreamSocket::bind(const SocketAddress& address, bool reuseAddress)
+{
+       static_cast<SecureStreamSocketImpl*>(impl())->bind(address, reuseAddress);
+}
+
+
 const std::string& SecureStreamSocket::getPeerHostName() const
 {
 	return static_cast<SecureStreamSocketImpl*>(impl())->getPeerHostName();

base/poco/NetSSL_OpenSSL/src/SecureStreamSocketImpl.cpp

@@ -102,11 +102,11 @@ void SecureStreamSocketImpl::connectSSL()
 }
 
 
-void SecureStreamSocketImpl::bind(const SocketAddress& address, bool reuseAddress, bool reusePort)
+void SecureStreamSocketImpl::bind(const SocketAddress& address, bool reuseAddress)
 {
-	throw Poco::InvalidAccessException("Cannot bind() a SecureStreamSocketImpl");
+       _impl.bind(address, reuseAddress);
+       reset(_impl.sockfd());
 }
-
 
 void SecureStreamSocketImpl::listen(int backlog)
 {