Review dari perubahan terbaru pada rotor (v0.10 ... v0.14)

rotor adalah microformwork aktor C ++ yang tidak mengganggu dengan kemampuan untuk membuat hierarki supervisor, mirip dengan kakak laki-lakinya - caf dan sobjectizer . Dalam rilis terbaru, sejak pengumuman terakhir , peningkatan signifikan telah terakumulasi yang ingin saya soroti.

Antarmuka umum untuk pengatur waktu (v0.10)

, . . . v0.10



API , ; (event loop) API, . : API , API rotor', . , , .

v0.10



rotor', - :

namespace r = rotor;

struct some_actor_t: r::actor_base_t {
    void on_start() noexcept {
        timer_request = start_timer(timeout, *this, &some_actor_t::on_timer);
    }

    void on_timer(r::request_id_t, bool cancelled) noexcept {
        ...;
    }

    void some_method() noexcept {
        ...
        cancel_timer(timer_id);
    }

    r::request_id_t timer_id;
};
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
    

, (shutdown_finish), , (undefined behavior).

(v0.10)

- , caf "-", sobjectizer' "--" ("fire-and-forget") . rotor , - "--", "-" .

, caf sobjectizer, , , , . , rotor' , , . "-" , "" , - (I/O), . , HTTP-, , . : , , , .

, , .. - , , - .

rotor', , , , - , , , , -, , , "". , - , . . .

namespace r = rotor;

namespace payload {
struct pong_t {};
struct ping_t {
    using response_t = pong_t;
};
} // namespace payload

namespace message {
using ping_request_t = r::request_traits_t<payload::ping_t>::request::message_t;
using ping_response_t = r::request_traits_t<payload::ping_t>::response::message_t;
using ping_cancel_t = r::request_traits_t<payload::ping_t>::cancel::message_t;
} // namespace message

struct some_actor_t: r::actor_base_t {
    using ping_ptr_t = r::intrusive_ptr_t<message::ping_request_t>;

    void on_ping(ping_request_t& req) noexcept {
        // just store request for further processing
        ping_req.reset(&req);
    }

    void on_cancel(ping_cancel_t&) noexcept {
        if (req) {
            // make_error is v0.14 feature
            make_response(*req, make_error(r::make_error_code(r::error_code_t::cancelled)));
            req.reset();
        }
    }

    //  ""   .
    ping_ptr_t ping_req;
};
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
    

, sobjectizer', , , -, "-", , -, , sobjectizer', . . . , - , "-" sobjectizer', , , , , .

std::thread backend/supervisor (v0.12)

, rotor sobjectizer: , . , .

, . , , . , ; , , , . , , , .. , , sha512 1TB, , . .

, std::thread



, . , , , rotor' , "" (), . , ..:

struct sha_actor_t : public r::actor_base_t {
    ...
    void configure(r::plugin::plugin_base_t &plugin) noexcept override {
        r::actor_base_t::configure(plugin);
        plugin.with_casted<r::plugin::starter_plugin_t>([&](auto &p) {
            p.subscribe_actor(&sha_actor_t::on_process)->tag_io(); // 
        });
    }
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
    

, sha512



, CTRL+c



, .

(v0.14)

— ( rotor' , sobjectizer' mbox



'). , , , :

struct my_supervisor_t : public r::supervisor_t {
    void on_child_shutdown(actor_base_t *actor) noexcept override {
        std::cout << "actor " << (void*) actor->get_address().get() << " died \n";
    }
}
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
    

, . , , , , on_start()



. , , std::string identity



actor_base_t



. , address_maker_plugin_t



:

struct some_actor_t : public t::actor_baset_t {
    void configure(r::plugin::plugin_base_t &plugin) noexcept override {
        plugin.with_casted<r::plugin::address_maker_plugin_t>([&](auto &p) {
            p.set_identity("my-actor-name", false);
        });
        ...
    }
};
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
    

:

struct my_supervisor_t : public r::supervisor_t {
    void on_child_shutdown(actor_base_t *actor) noexcept override {
        std::cout << actor->get_identity() << " died \n";
    }
}
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
    

, . , . bool



set_identity(name, append_addr)



.

- actor 0x7fd918016d70



supervisor 0x7fd218016d70



. rotor' v0.14



.

Extended Error std::error_code, shutdown reason (v0.14)

- , v0.14



, std::error_code



. , , , rotor', . : , . , . . . , , , , , . , std::error_code



.

Oleh karena itu, diputuskan untuk memperkenalkan kelas kesalahan tambahan kita sendiri rotor::extended_error_t



, yang berisi std::error_code



, std::string



sebagai konteks (biasanya identitas aktor), serta penunjuk cerdas ke kesalahan tambahan berikutnya yang menyebabkan kesalahan saat ini. Sekarang runtuhnya hierarki aktor dapat diwakili oleh rangkaian kesalahan yang diperpanjang, di mana alasan penutupan setiap aktor dapat dilacak:

struct my_supervisor_t : public r::supervisor_t {
    void on_child_shutdown(actor_base_t *actor) noexcept override {
        std::cout << actor->get_identity() << " died, reason :: " << actor->get_shutdown_reason()->message();
    }
}
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
    

akan menghasilkan sesuatu seperti:

actor-2 due to supervisor shutdown has been requested by supervisor <- actor-1 due initialization failed
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
    

Bersama dengan identifikasi aktor, fitur ini menyediakan lebih banyak alat diagnostik untuk pengembang yang menggunakan rotor .