Commit Graph

91 Commits

Author SHA1 Message Date
Tristan B. Velloza Kildaire 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
Tristan B. Velloza Kildaire ad99ef63d9 Added TODO 2021-09-09 16:18:16 +02:00
Tristan B. Velloza Kildaire b58fb718a7 Added some comments 2021-09-09 16:09:27 +02:00
Tristan B. Velloza Kildaire ddd46f3388 Added some comments 2021-09-09 18:02:45 +02:00
Tristan B. Velloza Kildaire 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
Tristan B. Velloza Kildaire 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
Tristan B. Velloza Kildaire 26bdcf7d83 Added comment 2021-09-09 11:30:44 +02:00
Tristan B. Velloza Kildaire c241d06ea9 Added `poll()` which lets user check if the queue is empty or not 2021-09-09 11:21:19 +02:00
Tristan B. Velloza Kildaire 9c7d15dc89 corrected last commit 2021-09-08 22:09:48 +02:00
Tristan B. Velloza Kildaire e1c28d9c11 Added `getSocket()` method to the Manager class 2021-09-08 22:08:03 +02:00
Tristan B. Velloza Kildaire b4bf4d5af5 Fixed bug for shutdowns 2021-09-08 20:54:34 +02:00
Tristan B. Velloza Kildaire e5a0a280bc Changed API 2021-09-08 20:50:22 +02:00
Tristan B. Velloza Kildaire b060b30c44 Added `sendMessage` to bformat encode the final t-encoded message 2021-09-08 20:45:39 +02:00
Tristan B. Velloza Kildaire 1b88d1f8bf Added some exceptional stuff 2021-09-08 20:24:45 +02:00
Tristan B. Velloza Kildaire 88be3d08e3 Added exception class
ALso added `getQueues()` function
2021-09-08 19:21:33 +02:00
Tristan B. Velloza Kildaire d9e5e54477 Added some todos for later 2021-09-08 14:29:27 +02:00
Tristan B. Velloza Kildaire 4f83991baf Added the ability to delete a queue
Updated todo
2021-09-08 14:24:58 +02:00
Tristan B. Velloza Kildaire 6a00c620ec Cleaned up import 2021-09-08 14:07:56 +02:00
Tristan B. Velloza Kildaire a3ca66db2b Added the ability to set a max length for queues 2021-09-08 14:06:38 +02:00
Tristan B. Velloza Kildaire 3ce8bda7de Clean up 2021-09-08 13:51:28 +02:00
Tristan B. Velloza Kildaire 7ba3c9f1f7 Added package.d 2021-09-08 13:49:41 +02:00
Tristan B. Velloza Kildaire 445e008603 `generateQueue()` now uses new `isValidTag(ulong)` 2021-09-08 13:47:53 +02:00
Tristan B. Velloza Kildaire d48cc4267e Clean up 2021-09-08 13:47:04 +02:00
Tristan B. Velloza Kildaire 3103adcb0f Removed uneeded function 2021-09-08 13:46:57 +02:00
Tristan B. Velloza Kildaire e8d4e0ae20 addQueue() now uses recursive mutex capabilities with re-impkemented `isValidTag()` 2021-09-08 13:46:38 +02:00
Tristan B. Velloza Kildaire ea32c7eef4 Re-implemented `isValidTag(ulong)` 2021-09-08 13:46:05 +02:00
Tristan B. Velloza Kildaire 384f286f83 Use recursive mutex capabilities 2021-09-08 13:42:25 +02:00
Tristan B. Velloza Kildaire 7a60a31e0a Added `generateQueue()` to create random queues for those who don't care about reserved ids 2021-09-08 13:40:39 +02:00
Tristan B. Velloza Kildaire bfa4364a99 Added shutdown capability 2021-09-08 11:19:05 +02:00
Tristan B. Velloza Kildaire 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
Tristan B. Kildaire 0f10ba4c41 Identified possible bug 2020-09-28 14:54:05 +02:00
Tristan B. Kildaire 98cd3e8c1e Append notifications to queue 2020-09-25 10:16:14 +02:00
Tristan 🅱. Kildaire db2125782e Corrected module name 2020-09-24 20:57:40 +02:00
Tristan 🅱. Kildaire a0bb8fd477 Added notifcation system 2020-09-24 20:51:57 +02:00