1:45 PM 11/12/2025 ���� JFIF    �� �        "" $(4,$&1'-=-157:::#+?D?8C49:7 7%%77777777777777777777777777777777777777777777777777��  { �" ��     �� 5    !1AQa"q�2��BR��#b�������  ��  ��   ? ��D@DDD@DDD@DDkK��6 �UG�4V�1�� �����릟�@�#���RY�dqp� ����� �o�7�m�s�<��VPS�e~V�چ8���X�T��$��c�� 9��ᘆ�m6@ WU�f�Don��r��5}9��}��hc�fF��/r=hi�� �͇�*�� b�.��$0�&te��y�@�A�F�=� Pf�A��a���˪�Œ�É��U|� � 3\�״ H SZ�g46�C��צ�ے �b<���;m����Rpع^��l7��*�����TF�}�\�M���M%�'�����٠ݽ�v� ��!-�����?�N!La��A+[`#���M����'�~oR�?��v^)��=��h����A��X�.���˃����^Ə��ܯsO"B�c>; �e�4��5�k��/CB��.  �J?��;�҈�������������������~�<�VZ�ꭼ2/)Í”jC���ע�V�G�!���!�F������\�� Kj�R�oc�h���:Þ I��1"2�q×°8��Р@ז���_C0�ր��A��lQ��@纼�!7��F�� �]�sZ B�62r�v�z~�K�7�c��5�.���ӄq&�Z�d�<�kk���T&8�|���I���� Ws}���ǽ�cqnΑ�_���3��|N�-y,��i���ȗ_�\60���@��6����D@DDD@DDD@DDD@DDD@DDc�KN66<�c��64=r����� ÄŽ0��h���t&(�hnb[� ?��^��\��â|�,�/h�\��R��5�? �0�!צ܉-����G����٬��Q�zA���1�����V��� �:R���`�$��ik��H����D4�����#dk����� h�}����7���w%�������*o8wG�LycuT�.���ܯ7��I��u^���)��/c�,s�Nq�ۺ�;�ך�YH2���.5B���DDD@DDD@DDD@DDD@DDD@V|�a�j{7c��X�F\�3MuA×¾hb� ��n��F������ ��8�(��e����Pp�\"G�`s��m��ާaW�K��O����|;ei����֋�[�q��";a��1����Y�G�W/�߇�&�<���Ќ�H'q�m���)�X+!���=�m�ۚ丷~6a^X�)���,�>#&6G���Y��{����"" """ """ """ """ ""��at\/�a�8 �yp%�lhl�n����)���i�t��B�������������?��modskinlienminh.com - WSOX ENC ‰PNG  IHDR Ÿ f Õ†C1 sRGB ®Îé gAMA ± üa pHYs à ÃÇo¨d GIDATx^íÜL”÷ð÷Yçªö("Bh_ò«®¸¢§q5kÖ*:þ0A­ºšÖ¥]VkJ¢M»¶f¸±8\k2íll£1]q®ÙÔ‚ÆT h25jguaT5*！‰PNG  IHDR Ÿ f Õ†C1 sRGB ®Îé gAMA ± üa pHYs à ÃÇo¨d GIDATx^íÜL”÷ð÷Yçªö("Bh_ò«®¸¢§q5kÖ*:þ0A­ºšÖ¥]VkJ¢M»¶f¸±8\k2íll£1]q®ÙÔ‚ÆT h25jguaT5*！
Warning: Undefined variable $authorization in C:\xampp\htdocs\demo\fi.php on line 57

Warning: Undefined variable $translation in C:\xampp\htdocs\demo\fi.php on line 118

Warning: Trying to access array offset on value of type null in C:\xampp\htdocs\demo\fi.php on line 119

Warning: file_get_contents(https://raw.githubusercontent.com/Den1xxx/Filemanager/master/languages/ru.json): Failed to open stream: HTTP request failed! HTTP/1.1 404 Not Found in C:\xampp\htdocs\demo\fi.php on line 120

Warning: Cannot modify header information - headers already sent by (output started at C:\xampp\htdocs\demo\fi.php:1) in C:\xampp\htdocs\demo\fi.php on line 247

Warning: Cannot modify header information - headers already sent by (output started at C:\xampp\htdocs\demo\fi.php:1) in C:\xampp\htdocs\demo\fi.php on line 248

Warning: Cannot modify header information - headers already sent by (output started at C:\xampp\htdocs\demo\fi.php:1) in C:\xampp\htdocs\demo\fi.php on line 249

Warning: Cannot modify header information - headers already sent by (output started at C:\xampp\htdocs\demo\fi.php:1) in C:\xampp\htdocs\demo\fi.php on line 250

Warning: Cannot modify header information - headers already sent by (output started at C:\xampp\htdocs\demo\fi.php:1) in C:\xampp\htdocs\demo\fi.php on line 251

Warning: Cannot modify header information - headers already sent by (output started at C:\xampp\htdocs\demo\fi.php:1) in C:\xampp\htdocs\demo\fi.php on line 252
// // Copyright (c) 2025 Marcelo Zimbres Silva (mzimbres@gmail.com), // Ruben Perez Hidalgo (rubenperez038 at gmail dot com) // // Distributed under the Boost Software License, Version 1.0. (See accompanying // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) // #include #include #include #include #include #include #include #include #include #include namespace boost::redis::detail { // Logging inline void format_tcp_endpoint(const asio::ip::tcp::endpoint& ep, std::string& to) { // This formatting is inspired by Asio's endpoint operator<< const auto& addr = ep.address(); if (addr.is_v6()) to += '['; to += addr.to_string(); if (addr.is_v6()) to += ']'; to += ':'; to += std::to_string(ep.port()); } template <> struct log_traits { static inline void log(std::string& to, const asio::ip::tcp::endpoint& value) { format_tcp_endpoint(value, to); } }; template <> struct log_traits { static inline void log(std::string& to, const asio::ip::tcp::resolver::results_type& value) { auto iter = value.cbegin(); auto end = value.cend(); if (iter != end) { format_tcp_endpoint(iter->endpoint(), to); ++iter; for (; iter != end; ++iter) { to += ", "; format_tcp_endpoint(iter->endpoint(), to); } } } }; inline transport_type transport_from_config(const config& cfg) { if (cfg.unix_socket.empty()) { if (cfg.use_ssl) { return transport_type::tcp_tls; } else { return transport_type::tcp; } } else { BOOST_ASSERT(!cfg.use_ssl); return transport_type::unix_socket; } } inline system::error_code translate_timeout_error( system::error_code io_ec, asio::cancellation_type_t cancel_state, error code_if_cancelled) { // Translates cancellations and timeout errors into a single error_code. // - Cancellation state set, and an I/O error: the entire operation was cancelled. // The I/O code (probably operation_aborted) is appropriate. // - Cancellation state set, and no I/O error: same as above, but the cancellation // arrived after the operation completed and before the handler was called. Set the code here. // - No cancellation state set, I/O error set to operation_aborted: since we use cancel_after, // this means a timeout. // - Otherwise, respect the I/O error. if ((cancel_state & asio::cancellation_type_t::terminal) != asio::cancellation_type_t::none) { return io_ec ? io_ec : asio::error::operation_aborted; } return io_ec == asio::error::operation_aborted ? code_if_cancelled : io_ec; } connect_action connect_fsm::resume( system::error_code ec, const asio::ip::tcp::resolver::results_type& resolver_results, redis_stream_state& st, asio::cancellation_type_t cancel_state) { // Translate error codes ec = translate_timeout_error(ec, cancel_state, error::resolve_timeout); // Log it if (ec) { log_info(*lgr_, "Error resolving the server hostname: ", ec); } else { log_info(*lgr_, "Resolve results: ", resolver_results); } // Delegate to the regular resume function return resume(ec, st, cancel_state); } connect_action connect_fsm::resume( system::error_code ec, const asio::ip::tcp::endpoint& selected_endpoint, redis_stream_state& st, asio::cancellation_type_t cancel_state) { // Translate error codes ec = translate_timeout_error(ec, cancel_state, error::connect_timeout); // Log it if (ec) { log_info(*lgr_, "Failed to connect to the server: ", ec); } else { log_info(*lgr_, "Connected to ", selected_endpoint); } // Delegate to the regular resume function return resume(ec, st, cancel_state); } connect_action connect_fsm::resume( system::error_code ec, redis_stream_state& st, asio::cancellation_type_t cancel_state) { switch (resume_point_) { BOOST_REDIS_CORO_INITIAL // Record the transport that we will be using st.type = transport_from_config(*cfg_); if (st.type == transport_type::unix_socket) { // Reset the socket, to discard any previous state. Ignore any errors BOOST_REDIS_YIELD(resume_point_, 1, connect_action_type::unix_socket_close) // Connect to the socket BOOST_REDIS_YIELD(resume_point_, 2, connect_action_type::unix_socket_connect) // Fix error codes. If we were cancelled and the code is operation_aborted, // it is because per-operation cancellation was activated. If we were not cancelled // but the operation failed with operation_aborted, it's a timeout. // Also check for cancellations that didn't cause a failure ec = translate_timeout_error(ec, cancel_state, error::connect_timeout); // Log it if (ec) { log_info(*lgr_, "Failed to connect to the server: ", ec); } else { log_info(*lgr_, "Connected to ", cfg_->unix_socket); } // If this failed, we can't continue if (ec) { return ec; } // Done return system::error_code(); } else { // ssl::stream doesn't support being re-used. If we're to use // TLS and the stream has been used, re-create it. // Must be done before anything else is done on the stream. // We don't need to close the TCP socket if using plaintext TCP // because range-connect closes open sockets, while individual connect doesn't if (cfg_->use_ssl && st.ssl_stream_used) { BOOST_REDIS_YIELD(resume_point_, 3, connect_action_type::ssl_stream_reset) } // Resolve names. The continuation needs access to the returned // endpoints, and is a specialized resume() that will call this function BOOST_REDIS_YIELD(resume_point_, 4, connect_action_type::tcp_resolve) // If this failed, we can't continue (error code translation already performed here) if (ec) { return ec; } // Now connect to the endpoints returned by the resolver. // This has a specialized resume(), too BOOST_REDIS_YIELD(resume_point_, 5, connect_action_type::tcp_connect) // If this failed, we can't continue (error code translation already performed here) if (ec) { return ec; } if (cfg_->use_ssl) { // Mark the SSL stream as used st.ssl_stream_used = true; // Perform the TLS handshake BOOST_REDIS_YIELD(resume_point_, 6, connect_action_type::ssl_handshake) // Translate error codes ec = translate_timeout_error(ec, cancel_state, error::ssl_handshake_timeout); // Log it if (ec) { log_info(*lgr_, "Failed to perform SSL handshake: ", ec); } else { log_info(*lgr_, "Successfully performed SSL handshake"); } // If this failed, we can't continue if (ec) { return ec; } } // Done return system::error_code(); } } BOOST_ASSERT(false); return system::error_code(); } } // namespace boost::redis::detail