Tristan B. Velloza Kildaire
a51df3b699
Engine
...
- If a `Request` is not expecting a response then do not call `dequeue()` on the `Queue` registered nor `process`byte[])`
- Added a TODO comment
1 month ago
Tristan B. Velloza Kildaire
8387d0ee78
Request
...
- Implemented `expectsResponse()` which returns `false` if no response handler is assigned (implying no response is expected), `true` otherwise
1 month ago
Tristan B. Velloza Kildaire
7af21a909a
Request
...
- Allow constructing WITHOUT a `ResponseHandler` (it remains as `null)
1 month ago
Tristan B. Velloza Kildaire
7072c852dc
Request
...
- Removed now-completed TODO
1 month ago
Tristan B. Velloza Kildaire
93d6d49c20
- Clean up
1 month ago
Tristan B. Velloza Kildaire
bb1dcef991
Engine
...
- `makeRequest(Request)` now cleans up by removing the adhoc `Queue` it registered in the beginning ofd the process
1 month ago
Tristan B. Velloza Kildaire
20da370f0e
- Upgraded to `tristanable` `v3.2.0-beta` which introduces the required `releaseQueue(Queue)` and `releaseQueue_nothrow(Queue)` methods
1 month ago
Tristan B. Velloza Kildaire
4ef69ac670
Engine
...
- Documented `makeRequest(Request req)`
1 month ago
Tristan B. Velloza Kildaire
0b1c8242fd
Engine
...
- Consumes a tristanable `Manager`
- Provides a `makeRequest(Request)` function which will generate a unique tristanable `Queue`, construct a `TaggedMessage` of the queue's ID with the gievn request data, it will then send the message via the tristanable `Manager`'s `sendMessage(TaggedMessage)` method, then await on the queue and lastly run the `Request`'s `ResponseHandler` function with the received data from the dequeued `TaggedMessage`
Request
- Defines a request with data to send and a function to handle a response
1 month ago
Tristan B. Velloza Kildaire
bed096df27
- Removed direct dependency `bformat` and uneeded dependency `eventy`
1 month ago
Tristan B. Velloza Kildaire
b0d0b19a4a
- Added `tasky.engine` module
...
- Added `tasky.engine` module to the `tasky` package
1 month ago
Tristan B. Velloza Kildaire
0051099c1f
- Updated the `.gitignore`
1 month ago
Tristan B. Velloza Kildaire
85a7558d79
- Upgraded tristanable from version `2.6.12` to the new beta `3.0.1-beta`
2 months ago
Tristan B. Velloza Kildaire
1cf310d92a
- Updated `.gitignore`
...
- Removed `libtasky.a`
3 months ago
Tristan B. Velloza Kildaire
958e678ed2
- Removed `dub.selections.json`
3 months ago
Tristan B. Velloza Kildaire
852619f4a0
Dub
...
- Updated package copyright and authors
3 months ago
Tristan B. Velloza Kildaire
b59bbf9c36
Restart
3 months ago
Tristan B. Velloza Kildaire
8e35e282c1
Descriptor must override a method that takes in a TaskyEvent as those will only ever be created, this means you no longer need to do an annoying cast from Event to TaskyEvent
1 year ago
Tristan B. Velloza Kildaire
726ad57706
Make TaskyEvent accessible at the module level
1 year ago
Tristan B. Velloza Kildaire
246adcc1f9
Added some rudimentary unittests that should have their order enforced
...
else stuff can go really wrong, these things run as part of a single process,
no restarts etc. Hence state is persisted across unittests
1 year ago
Tristan B. Velloza Kildaire
0d850d0508
Fixed compilation error by adding an implementation
...
for the DescriptorException used in jobs.d
1 year ago
Tristan B. Velloza Kildaire
a7c18d5e10
Added ability to use a custom descriptor ID, throws exception if the given
...
descriptor ID is in use already
1 year ago
Tristan B. Velloza Kildaire
89347cb6d2
Future: Added addClass(ulong) to add a custom descriptor ID
1 year ago
Tristan B. Velloza Kildaire
2251a00284
Descriptor queue safety fix
...
Fixed a bug whereby if one were to get new Descriptor classes across
several threads then the Mutex for the descriptor queue would be reinitialzied
upon static initialization of the thread as the static initialization block
was not set to __gshared, causing a global re-write of a re-initted Mutex,
never the same Mutex
1 year ago
Tristan B. Velloza Kildaire
8ede79bf49
Future: Add support for fixed descriptor IDs
1 year ago
Tristan B. Velloza Kildaire
bc6c90411a
Added comment
1 year ago
Tristan B. Velloza Kildaire
bfbf02efdb
Added getPayload() method to TaskyEvent class
1 year ago
Tristan B. Velloza Kildaire
4380019665
Upgraded to tristanable v2.6.12
1 year ago
Tristan B. Velloza Kildaire
b8ed656536
Fixed unit test
1 year ago
Tristan B. Velloza Kildaire
e3ecc30497
Running status should be set from within startTasky() and after starting all sub-systems
1 year ago
Tristan B. Velloza Kildaire
92d1b1b900
Upgraded to new Eventy
1 year ago
Tristan B. Velloza Kildaire
8f8a1e724f
Added stub method for future usage along with comments related to it
1 year ago
Tristan B. Velloza Kildaire
743744410c
WIP: Adding some handling exposed via tristanable
1 year ago
Tristan B. Velloza Kildaire
3561ed8fda
Added TODO list
1 year ago
Tristan B. Velloza Kildaire
e64827b770
Upgraded tristanable
1 year ago
Tristan B. Velloza Kildaire
16ae65937a
Added a shutdown() method which should stop tristanable and eventy, along with stopping the tasky main loop
1 year ago
Tristan B. Velloza Kildaire
bcdc6121ca
Cleaned up
1 year ago
Tristan B. Velloza Kildaire
8539485352
On timing out after 4 seconds of not having a task complete, fail the assertion test
1 year ago
Tristan B. Velloza Kildaire
1db1fad397
Cleaned up
1 year ago
Tristan B. Velloza Kildaire
78c22d3b4e
Cleaned up
1 year ago
Tristan B. Velloza Kildaire
d786130427
Removed uneeded function
1 year ago
Tristan B. Velloza Kildaire
dfd0171c67
Pass unit tessts
1 year ago
Tristan B. Velloza Kildaire
da5489a6b7
Using fixed tristanable
1 year ago
Tristan B. Velloza Kildaire
915b0ad115
WIP: GOtta figure out timing and maybe hot loops and shit
1 year ago
Tristan B. Velloza Kildaire
295d9ff672
Removed TODO
...
Don't let socket close
1 year ago
Tristan B. Velloza Kildaire
e65459633c
There are bugs or either timing is off for my test
1 year ago
Tristan B. Velloza Kildaire
20ec129f69
Testing multiple jobs
1 year ago
Tristan B. Velloza Kildaire
20e60a6f30
Works!
1 year ago
Tristan B. Velloza Kildaire
4c798aef6a
WIP: Event dispatching loop
1 year ago
Tristan B. Velloza Kildaire
21e1b91abc
Initialize tristanable, add a new tristanable queue on Descriptor registration
1 year ago