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
// Licensed to the Apache Software Foundation (ASF) under one // or more contributor license agreements. See the NOTICE file // distributed with this work for additional information // regarding copyright ownership. The ASF licenses this file // to you under the Apache License, Version 2.0 (the // "License"); you may not use this file except in compliance // with the License. You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, // software distributed under the License is distributed on an // "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. /// \file /// Internal (but not private) interface for implementing /// alternate network transports in Flight. /// /// To implement a transport, implement ServerTransport and /// ClientTransport, and register the desired URI schemes with /// TransportRegistry. Flight takes care of most of the per-RPC /// details; transports only handle connections and providing a I/O /// stream implementation (TransportDataStream). /// /// On the server side: /// /// 1. Applications subclass FlightServerBase and override RPC handlers. /// 2. FlightServerBase::Init will look up and create a ServerTransport /// based on the scheme of the Location given to it. /// 3. The ServerTransport will start the actual server. (For instance, /// for gRPC, it creates a gRPC server and registers a gRPC service.) /// That server will handle connections. /// 4. The transport should forward incoming calls to the server to the RPC /// handlers defined on ServerTransport, which implements the actual /// RPC handler using the interfaces here. Any I/O the RPC handler needs /// to do is managed by transport-specific implementations of /// TransportDataStream. /// 5. ServerTransport calls FlightServerBase for the actual application /// logic. /// /// On the client side: /// /// 1. Applications create a FlightClient with a Location. /// 2. FlightClient will look up and create a ClientTransport based on /// the scheme of the Location given to it. /// 3. When calling a method on FlightClient, FlightClient will delegate to /// the ClientTransport. There is some indirection, e.g. for DoGet, /// FlightClient only requests that the ClientTransport start the /// call and provide it with an I/O stream. The "Flight implementation" /// itself still lives in FlightClient. #pragma once #include #include #include #include #include #include #include "arrow/flight/type_fwd.h" #include "arrow/flight/types.h" #include "arrow/flight/visibility.h" #include "arrow/ipc/options.h" #include "arrow/type_fwd.h" namespace arrow { namespace ipc { class Message; } namespace flight { class FlightStatusDetail; namespace internal { /// Internal, not user-visible type used for memory-efficient reads struct FlightData { /// Used only for puts, may be null std::unique_ptr descriptor; /// Non-length-prefixed Message header as described in format/Message.fbs std::shared_ptr metadata; /// Application-defined metadata std::shared_ptr app_metadata; /// Message body std::shared_ptr body; /// Open IPC message from the metadata and body ::arrow::Result> OpenMessage(); }; /// \brief A transport-specific interface for reading/writing Arrow data. /// /// New transports will implement this to read/write IPC payloads to /// the underlying stream. class ARROW_FLIGHT_EXPORT TransportDataStream { public: virtual ~TransportDataStream() = default; /// \brief Attempt to read the next FlightData message. /// /// \return success true if data was populated, false if there was /// an error. For clients, the error can be retrieved from /// Finish(Status). virtual bool ReadData(FlightData* data); /// \brief Attempt to write a FlightPayload. /// /// \param[in] payload The data to write. /// \return true if the message was accepted by the transport, false /// if not (e.g. due to client/server disconnect), Status if there /// was an error (e.g. with the payload itself). virtual arrow::Result WriteData(const FlightPayload& payload); /// \brief Indicate that there are no more writes on this stream. /// /// This is only a hint for the underlying transport and may not /// actually do anything. virtual Status WritesDone(); }; /// \brief A transport-specific interface for reading/writing Arrow /// data for a client. class ARROW_FLIGHT_EXPORT ClientDataStream : public TransportDataStream { public: /// \brief Attempt to read a non-data message. /// /// Only implemented for DoPut; mutually exclusive with /// ReadData(FlightData*). virtual bool ReadPutMetadata(std::shared_ptr* out); /// \brief Attempt to cancel the call. /// /// This is only a hint and may not take effect immediately. The /// client should still finish the call with Finish(Status) as usual. virtual void TryCancel() {} /// \brief Finish the call, reporting the server-sent status and/or /// any client-side errors as appropriate. /// /// Implies WritesDone() and DoFinish(). /// /// \param[in] st A client-side status to combine with the /// server-side error. That is, if an error occurs on the /// client-side, call Finish(Status) to finish the server-side /// call, get the server-side status, and merge the statuses /// together so context is not lost. Status Finish(Status st); protected: /// \brief End the call, returning the final server status. /// /// For implementors: should imply WritesDone() (even if it does not /// directly call it). /// /// Implies WritesDone(). virtual Status DoFinish() = 0; }; /// An implementation of a Flight client for a particular transport. /// /// Transports should override the methods they are capable of /// supporting. The default method implementations return an error. class ARROW_FLIGHT_EXPORT ClientTransport { public: virtual ~ClientTransport() = default; /// Initialize the client. virtual Status Init(const FlightClientOptions& options, const Location& location, const arrow::util::Uri& uri) = 0; /// Close the client. Once this returns, the client is no longer usable. virtual Status Close() = 0; virtual Status Authenticate(const FlightCallOptions& options, std::unique_ptr auth_handler); virtual arrow::Result> AuthenticateBasicToken( const FlightCallOptions& options, const std::string& username, const std::string& password); virtual Status DoAction(const FlightCallOptions& options, const Action& action, std::unique_ptr* results); virtual Status ListActions(const FlightCallOptions& options, std::vector* actions); virtual Status GetFlightInfo(const FlightCallOptions& options, const FlightDescriptor& descriptor, std::unique_ptr* info); virtual void GetFlightInfoAsync(const FlightCallOptions& options, const FlightDescriptor& descriptor, std::shared_ptr> listener); virtual Status PollFlightInfo(const FlightCallOptions& options, const FlightDescriptor& descriptor, std::unique_ptr* info); virtual arrow::Result> GetSchema( const FlightCallOptions& options, const FlightDescriptor& descriptor); virtual Status ListFlights(const FlightCallOptions& options, const Criteria& criteria, std::unique_ptr* listing); virtual Status DoGet(const FlightCallOptions& options, const Ticket& ticket, std::unique_ptr* stream); virtual Status DoPut(const FlightCallOptions& options, std::unique_ptr* stream); virtual Status DoExchange(const FlightCallOptions& options, std::unique_ptr* stream); bool supports_async() const { return CheckAsyncSupport().ok(); } virtual Status CheckAsyncSupport() const { return Status::NotImplemented( "this Flight transport does not support async operations"); } static void SetAsyncRpc(AsyncListenerBase* listener, std::unique_ptr&& rpc); static AsyncRpc* GetAsyncRpc(AsyncListenerBase* listener); static std::unique_ptr ReleaseAsyncRpc(AsyncListenerBase* listener); }; /// A registry of transport implementations. class ARROW_FLIGHT_EXPORT TransportRegistry { public: using ClientFactory = std::function>()>; using ServerFactory = std::function>( FlightServerBase*, std::shared_ptr memory_manager)>; TransportRegistry(); ~TransportRegistry(); arrow::Result> MakeClient( const std::string& scheme) const; arrow::Result> MakeServer( const std::string& scheme, FlightServerBase* base, std::shared_ptr memory_manager) const; Status RegisterClient(const std::string& scheme, ClientFactory factory); Status RegisterServer(const std::string& scheme, ServerFactory factory); private: class Impl; std::unique_ptr impl_; }; /// \brief Get the registry of transport implementations. ARROW_FLIGHT_EXPORT TransportRegistry* GetDefaultTransportRegistry(); //------------------------------------------------------------ // Async APIs /// \brief Transport-specific state for an async RPC. /// /// Transport implementations may subclass this to store their own /// state, and stash an instance in a user-supplied AsyncListener via /// ClientTransport::GetAsyncRpc and ClientTransport::SetAsyncRpc. class ARROW_FLIGHT_EXPORT AsyncRpc { public: virtual ~AsyncRpc() = default; /// \brief Request cancellation of the RPC. virtual void TryCancel() {} /// Only needed for DoPut/DoExchange virtual void Begin(const FlightDescriptor& descriptor, std::shared_ptr schema) { } /// Only needed for DoPut/DoExchange virtual void Write(arrow::flight::FlightStreamChunk chunk) {} /// Only needed for DoPut/DoExchange virtual void DoneWriting() {} }; //------------------------------------------------------------ // Error propagation helpers /// \brief Abstract error status. /// /// Transport implementations may use side channels (e.g. HTTP /// trailers) to convey additional information to reconstruct the /// original C++ status for implementations that can use it. struct ARROW_FLIGHT_EXPORT TransportStatus { TransportStatusCode code; std::string message; /// \brief Convert a C++ status to an abstract transport status. static TransportStatus FromStatus(const Status& arrow_status); /// \brief Reconstruct a string-encoded TransportStatus. static TransportStatus FromCodeStringAndMessage(const std::string& code_str, std::string message); /// \brief Convert an abstract transport status to a C++ status. Status ToStatus() const; }; /// \brief Convert the string representation of an Arrow status code /// back to an Arrow status. ARROW_FLIGHT_EXPORT Status ReconstructStatus(const std::string& code_str, const Status& current_status, std::optional message, std::optional detail_message, std::optional detail_bin, std::shared_ptr detail); } // namespace internal } // namespace flight } // namespace arrow