|
C++ Actor Framework 0.18
|
State for a path to an upstream actor (source). More...
#include <inbound_path.hpp>
Classes | |
| struct | metrics_t |
| Wraps optional actor metrics collected by this path. More... | |
Public Types | |
| using | regular_shutdown = upstream_msg::drop |
| Message type for propagating graceful shutdowns. | |
| using | irregular_shutdown = upstream_msg::forced_drop |
| Message type for propagating errors. | |
| using | time_point = typename actor_clock::time_point |
| Discrete point in time, as reported by the actor clock. | |
| using | duration_type = typename actor_clock::duration_type |
| Time interval, as reported by the actor clock. | |
Public Member Functions | |
| template<class T > | |
| inbound_path (stream_manager *mgr, stream< T > in) | |
| void | init (strong_actor_ptr source_hdl, stream_slots id) |
| bool | up_to_date () const noexcept |
Returns whether the path received no input since last emitting ack_batch , i.e., last_acked_batch_id == last_batch_id . | |
| scheduled_actor * | self () const noexcept |
| Returns a pointer to the parent actor. | |
| int32_t | available_credit () const noexcept |
| Returns currently unassigned credit that we could assign to the source. | |
| const settings & | config () const noexcept |
| Returns the system-wide configuration. | |
| void | handle (downstream_msg::batch &x) |
Updates last_batch_id and assigned_credit before dispatching to the manager. | |
| void | handle (downstream_msg::close &x) |
Forward the close message to the manager. | |
| void | handle (downstream_msg::forced_close &x) |
Forward the forced_close message to the manager. | |
| void | tick (time_point now, duration_type max_batch_delay) |
| Forces an ACK message after receiving no input for a considerable amount of time. | |
| void | emit_ack_open (local_actor *self, actor_addr rebind_from) |
Emits an upstream_msg::ack_batch . | |
| void | emit_ack_batch (local_actor *self, int32_t new_credit) |
Sends an upstream_msg::ack_batch for granting new credit. | |
| void | emit_regular_shutdown (local_actor *self) |
Sends an upstream_msg::drop on this path. | |
| void | emit_irregular_shutdown (local_actor *self, error reason) |
Sends an upstream_msg::forced_drop on this path. | |
Static Public Member Functions | |
| static void | emit_irregular_shutdown (local_actor *self, stream_slots slots, const strong_actor_ptr &hdl, error reason) |
Sends an upstream_msg::forced_drop . | |
Public Attributes | |
| stream_manager * | mgr |
| Points to the manager responsible for incoming traffic. | |
| strong_actor_ptr | hdl |
| Handle to the source. | |
| stream_slots | slots |
| Stores slot IDs for sender (hdl) and receiver (self). | |
| metrics_t | metrics |
| Stores pointers to optional telemetry objects. | |
| int32_t | desired_batch_size = 0 |
| Stores the last computed desired batch size. | |
| int32_t | assigned_credit = 0 |
| Amount of credit we have signaled upstream. | |
| int32_t | max_credit = 0 |
| Maximum amount of credit that the path may signal upstream. | |
| int32_t | calibration_countdown = 10 |
| Decremented whenever receiving a batch. | |
| stream_priority | prio = stream_priority::normal |
| Priority of incoming batches from this source. | |
| int64_t | last_acked_batch_id = 0 |
| ID of the last acknowledged batch ID. | |
| int64_t | last_batch_id = 0 |
| ID of the last received batch. | |
| std::unique_ptr< credit_controller > | controller_ |
| Controller for assigning credit to the source. | |
| time_point | last_ack_time |
| Stores when the last ACK was emitted. | |
Related Functions | |
(Note that these are not member functions.) | |
| template<class Inspector > | |
| bool | inspect (Inspector &f, inbound_path &x) |
State for a path to an upstream actor (source).
| void caf::inbound_path::emit_ack_batch | ( | local_actor * | self, |
| int32_t | new_credit | ||
| ) |
Sends an upstream_msg::ack_batch
for granting new credit.
| self | Points to the parent actor, i.e., sender of the message. |
| new_credit | Amount of new credit to assign to the source. |
| int32_t caf::inbound_path::calibration_countdown = 10 |
Decremented whenever receiving a batch.
Triggers a re-calibration by the controller when reaching zero.
| int32_t caf::inbound_path::desired_batch_size = 0 |
Stores the last computed desired batch size.
Adjusted at run-time by the controller.
| int32_t caf::inbound_path::max_credit = 0 |
Maximum amount of credit that the path may signal upstream.
Adjusted at run-time by the controller.


Constructor
new RVRlauncher(VRpageID, mobileOnlyopt, hoverTextopt)
- Source:
Parameters:
| Name | Type | Attributes | Default | Description |
|---|---|---|---|---|
VRpageID |
String | id of the page that has the VR setup |
||
mobileOnly |
Boolean |
<optional> |
false
|
whether to show this button only on mobile browsers (exclude desktops) |
hoverText |
String |
<optional> |
'Launch this page in AR/VR mode'
|
tooltip to show when a user hovers a button (desktop only) |
Methods
(static) createHTML(hoverTextopt) → {HTMLSpanElement}
- Source:
Creates the HTML for the VR button
Parameters:
| Name | Type | Attributes | Description |
|---|---|---|---|
hoverText |
String |
<optional> |
tooltip to show when a user hovers a button (desktop only) |
Returns:
Returns a span.RVRlauncher
button
- Type
- HTMLSpanElement
(static) locationDeserialize(locationopt) → {Object}
- Source:
turns window.location
object into an object with params as named keys necessary to reconstruct the URL
Parameters:
| Name | Type | Attributes | Default | Description |
|---|---|---|---|---|
location |
Object |
<optional> |
window.location
|
a window.location object, by default of the host window where the script is executed |
Returns:
a location
object
- Type
- Object
(static) locationSerialize(location) → {String}
- Source:
Turns a location
object (result of locationDeserialize
) into a URL
Parameters:
| Name | Type | Description |
|---|---|---|
location |
Object | an object with params and a url |
Returns:
- a URL string
- Type
- String
(static) notDesktop() → {Boolean}
- Source:
Checks if the browser is not a Desktop browser, but a tablet or a smartphone
Returns:
whether the browser is mobile
- Type
- Boolean
(static) setupListener(target, VRpageID)
- Source:
Adds a click listener to the button and sets window.location to the URL of the VR page
Parameters:
| Name | Type | Description |
|---|---|---|
target |
HTMLElement | the element to attach listener to |
VRpageID |
String | the PageId of the VR page |


range genetic (.) population extension Group tetricus Tasmania individuals distribution diversity sites Ecol. historical Octopus marine coast analysis gene loci structure Mol. east species {border-style using px;} #ffffff;} Supplementary collection common detected flow number populations Australia Nambucca S). alleles distinct shifts zone Genetic Merimbula Table connectivity (Table ./j.-...x Biol. history scenario used change comprised data rates Ovul Tasmanian allele bottleneck clusters different differentiation level mainland size test Cape Heads high polewards scenarios significant Australia. Cluster L-shaped Mallacoota Population Sci. Swansea climate estimated Australian Conran Eden based bottlenecks edge indicated recent sub-group (). (n = ; ./j.-X...x DAPC Evol. Fig. Glob. PCR capacity changes effect evolutionary groups heterozygosity levels microsatellite migration observed posterior px; samples study {font-family ′′, (Supplementary (n = ); ABC Proc. Res. Tables approach conditions demographic font-size founder frequency including likely method null only, relatively selected software statistics values vulgaris warming ′′) (Fig. Bayesian Migration Sub-group Ulladulla admixture areas assigned collected data. diverged double; early excess frequencies inbreeding larval life model new patterns rapid self-recruitment signatures site sites, variability waters zone. <. (n = ) ... . µL Arlequin Chang. Current DNA East Heads, However, Ot, Resour. Structure Strugnell Swansea, Tasmania. Ulladulla, [], analyses. assumed bold border-color border-width cluster confidence dispersal effective environmental equilibrium geographic global group help implemented included increase invasive leading monitoring north-eastern ocean parameter performed program provided sample similar solid; step sub-groups suggested version year {font-style {font-weight ./s--- Acad. Analysis Australia, Commons Creative Discriminant Excoffier Genet. Genetics Heterozygosity Lond., Microsatellite Mutation N(TG) NSW Natl. Notes Pecl Principal Ramos Research SMM Soc. Therefore, USA algorithm associated average commonly community corrected courier; eastern effects em; entire events expansion expected extended genotypes highest i.e. impacts include indicate inferred influence information material migrants moderate molecular octopus paralarvae paralarval persistence planktonic population. predominately present probability provide pt;} reef related reproductive responses results seven shift sites. sizes southern step, studies successive suggest summary supported tests tissue value variation years


Amazon's Alexa script prompts the user how his/her day is going, then depending on the sentiment expressed by the user, it produces a list of regularly-updated Spotify playlists tailored to his/her mood. Worked in incorporating the AlchemyAPI to the response from Alexa, then sorting a list of playlist in accordance to the sentiment in the person's day. Check the Devpost here!
File receives an article (or any body of text) and produces a summary around what sentences have the most value. Reduces big bodies of text to a 70-80% of it's original length. Written in Python using the library NLTK. Project inspired by the auto TL;DR bot used in some subreddits.
Website scrapes news articles from multiple reliable prominent sources and categorizes such articles by mood/tone of the information. I developed the Watson® Tone Analyzer processor for the articles, a web scrapper for BBC news, and the website’s CSS using Materialize. Processor and web scrapper coded in Python. Check the website here!
App eases the complexity of a web process to submit reimbursement forms for State Farm® employees. Developed with Ionic and AngularJS (Compatible with iOS and Android). I worked on the code for the ionic framework, and the basis for the AngularJS back end.