f8aa3b92cf
Package
...
- Added imports that should be publically imported (exported into the user)
2023-03-03 17:47:23 +02:00
8828e3ffdd
Manager
...
- Added an array of `Queue`(s) to the manager
Queue
- Added comments
- Initialize the libsnooze `Event` during construction of the `Queue` type
Dub
- Upgraded libsnooze from `0.2.7` to `0.2.9`
Repository
- Removed `dub.selections.json` file
- Added `dub.selections.json` to the `.gitignore`
2023-03-03 17:44:51 +02:00
e7f93cd78a
- Upgraded to working version of libsnooze
(compilation-wise)
...
- Fixed imports and missing definitions in `queue` module
2023-02-26 22:24:49 +02:00
17da826d07
Restarting project
2023-02-26 21:55:13 +02:00
e59dca0c4d
this.flags was not set, resulting in the default .init for QueuePolicy being used and enforcing LENGHT_CAPPING by default even when default behaviour should be not to, per the constructors (this()'s) parameters
2022-03-19 13:29:32 +02:00
ad99ef63d9
Added TODO
2021-09-09 16:18:16 +02:00
b58fb718a7
Added some comments
2021-09-09 16:09:27 +02:00
ddd46f3388
Added some comments
2021-09-09 18:02:45 +02:00
df4d479e54
Throw an exception when trying to remove a queue with an id not in use by any queue
2021-09-09 18:01:14 +02:00
0c43e80cf6
Throw an exception when trying to add a queue with an id already in use by another queue
2021-09-09 18:00:59 +02:00
26bdcf7d83
Added comment
2021-09-09 11:30:44 +02:00
c241d06ea9
Added poll()
which lets user check if the queue is empty or not
2021-09-09 11:21:19 +02:00
9c7d15dc89
corrected last commit
2021-09-08 22:09:48 +02:00
e1c28d9c11
Added getSocket()
method to the Manager class
2021-09-08 22:08:03 +02:00
b4bf4d5af5
Fixed bug for shutdowns
2021-09-08 20:54:34 +02:00
e5a0a280bc
Changed API
2021-09-08 20:50:22 +02:00
b060b30c44
Added sendMessage
to bformat encode the final t-encoded message
2021-09-08 20:45:39 +02:00
1b88d1f8bf
Added some exceptional stuff
2021-09-08 20:24:45 +02:00
88be3d08e3
Added exception class
...
ALso added `getQueues()` function
2021-09-08 19:21:33 +02:00
d9e5e54477
Added some todos for later
2021-09-08 14:29:27 +02:00
4f83991baf
Added the ability to delete a queue
...
Updated todo
2021-09-08 14:24:58 +02:00
6a00c620ec
Cleaned up import
2021-09-08 14:07:56 +02:00
a3ca66db2b
Added the ability to set a max length for queues
2021-09-08 14:06:38 +02:00
3ce8bda7de
Clean up
2021-09-08 13:51:28 +02:00
7ba3c9f1f7
Added package.d
2021-09-08 13:49:41 +02:00
445e008603
generateQueue()
now uses new isValidTag(ulong)
2021-09-08 13:47:53 +02:00
d48cc4267e
Clean up
2021-09-08 13:47:04 +02:00
3103adcb0f
Removed uneeded function
2021-09-08 13:46:57 +02:00
e8d4e0ae20
addQueue() now uses recursive mutex capabilities with re-impkemented isValidTag()
2021-09-08 13:46:38 +02:00
ea32c7eef4
Re-implemented isValidTag(ulong)
2021-09-08 13:46:05 +02:00
384f286f83
Use recursive mutex capabilities
2021-09-08 13:42:25 +02:00
7a60a31e0a
Added generateQueue()
to create random queues for those who don't care about reserved ids
2021-09-08 13:40:39 +02:00
bfa4364a99
Added shutdown capability
2021-09-08 11:19:05 +02:00
5f16e8d5b0
Use DList
2021-09-08 11:14:03 +02:00
Tristan B. Kildaire
ca63a218c8
Undid that shit
2021-01-30 12:18:45 +02:00
Tristan B. Kildaire
e7e82c5491
Fixed visibility issues
2021-01-30 12:18:23 +02:00
Tristan B. Kildaire
848d1b7a63
Start watcher
2020-10-16 17:11:32 +02:00
Tristan B. Kildaire
984261a394
Added missing watcher
2020-10-16 17:11:26 +02:00
Tristan B. Kildaire
2c5d871378
Added comment
2020-10-15 11:34:03 +02:00
Tristan B. Kildaire
73322667fa
Added missing imports
2020-09-29 19:19:34 +02:00
Tristan B. Kildaire
98d672434a
Added missing imports
2020-09-29 19:18:59 +02:00
Tristan B. Kildaire
41199e96fc
Renamed
2020-09-29 19:18:53 +02:00
Tristan B. Kildaire
96e755d3cc
Added getTag()
and getData()
and made instance variables private
2020-09-29 19:18:45 +02:00
Tristan B. Kildaire
24d56c93a9
Added new changes
2020-09-29 19:13:36 +02:00
Tristan B. Kildaire
176310761c
Deleted old code
2020-09-29 19:13:21 +02:00
Tristan B. Kildaire
1f07b06316
WIP: tristanable-ng
2020-09-29 11:57:25 +02:00
Tristan B. Kildaire
02a29b5293
Made reservedTags queue thread safe
2020-09-29 08:47:04 +02:00
Tristan B. Kildaire
90835f3c97
Don't go further if the receive failed
2020-09-28 20:43:46 +02:00
Tristan B. Kildaire
b0b7f69778
re-ordered, send after enqueue, a slight conc bug would appear whereby the thread switch to watcher occurs after send (suppose) and then it locks list mjtex, seees no request, says it is an error, this ensures it is a request then sends it so when thread switch to watcher occurs, it MUST be in the list and therefore a valid request
2020-09-28 19:17:21 +02:00
Tristan B. Kildaire
7c44f04066
Identified possible bug (revert)
2020-09-28 14:55:19 +02:00