deavmi/tristanable
deavmi
/
tristanable
mirror of https://github.com/deavmi/tristanable.git
1
0
Fork 0
Code Issues 2 Projects Releases Wiki Activity

Next gen #3

New Issue
Open
opened 2023-03-30 17:28:54 +01:00 by deavmi · 14 comments
deavmi commented 2023-03-30 17:28:54 +01:00
Owner
Copy Link

What is this?

Re-write of Tristanable, mainly with a performance boost in mind due to the use of libsnooze.

Todo

Todo list:

  • Watcher

    • shutdown method
    • safe bformat receiveMessage(Socket, ref byte[])

  • Watcher queuing

    • default queue
    • testing default queue
    • testing normal queue
    • receiveMessage(Socket, ref byte[])
      • check returned value for error handling
      • ensure watcher dies properly
    • Listener support for when any queue gets updated (see #4)

  • Queue

    • Queue policy
    • Replace QueueItem with just TaggedMessage
    • enqueue (with notify)
    • dequeue (with wake)
    • On construction we might need to reserve using libsnooze (see #5)
    • eventy exception handling etc
      • in notifyAll()
      • in wait()

  • Manager

    • Add a method which can automatically find the next available unused queue id, generate said queue with id and return it
    • testing API
      • register queue (registerQueue(Queue))
        • positive cases
        • negative cases
      • fetching a queue (getQueue(ulong) and getQueue_nothrow(ulong))
        • positive cases
        • negative cases

  • Queue

    • Decide on good wake up interval
    • Add a dequeue(Duration)
      • Because we have wakeup, we must have a stopwatch then or modifythe algo of what wakeup is as well.
## What is this? Re-write of Tristanable, mainly with a performance boost in mind due to the use of `libsnooze`. ## Todo Todo list: - [x] Watcher - [x] shutdown method - [x] safe bformat `receiveMessage(Socket, ref byte[])` - [ ] Watcher queuing - [x] default queue - [x] testing default queue - [x] testing normal queue - [x] `receiveMessage(Socket, ref byte[])` - [x] check returned value for error handling - [x] ensure watcher dies properly - [ ] Listener support for when **any** queue gets updated (see #4) - [ ] Queue - [ ] Queue policy - [x] Replace `QueueItem` with just `TaggedMessage` - [x] enqueue (with notify) - [x] dequeue (with wake) - [x] On construction we might need to reserve using `libsnooze` (see #5) - [ ] ~~eventy exception handling etc~~ - [ ] ~~in `notifyAll()`~~ - [ ] ~~in `wait()`~~ - [ ] Manager - [ ] Add a method which can automatically find the next available unused queue id, generate said queue with id and return it - [ ] testing API - [x] register queue (`registerQueue(Queue)`) - [x] positive cases - [x] negative cases - [x] fetching a queue (`getQueue(ulong)` and `getQueue_nothrow(ulong)`) - [x] positive cases - [x] negative cases - [ ] Queue - [ ] Decide on good wake up interval - [ ] Add a `dequeue(Duration)` * Because we have wakeup, we must have a stopwatch then or modifythe algo of what wakeup is as well.
deavmi added reference nextgen 2023-03-30 17:29:00 +01:00
deavmi self-assigned this 2023-03-30 17:29:07 +01:00
deavmi added this to the Next-gen milestone 2023-03-30 17:29:09 +01:00
deavmi added the
enhancement
todo
 labels 2023-03-30 17:29:15 +01:00
deavmi started working 2023-03-30 17:31:11 +01:00
deavmi added the due date 2023-04-09 2023-03-30 17:36:22 +01:00
deavmi added a new dependency 2023-03-30 17:36:52 +01:00
#2 Add cross-platform encoding
deavmi stopped working 2023-03-30 17:37:17 +01:00
6 minutes 6 seconds
deavmi started working 2023-03-30 17:37:22 +01:00
deavmi commented 2023-04-05 07:42:40 +01:00
Author
Owner
Copy Link

Good progress made now, just testing a few things. I should be able to check most of these off by the end of this week.

Hoping to make the 9th of April deadline.

Good progress made now, just testing a few things. I should be able to check most of these off by the end of this week. Hoping to make the 9th of April deadline.
deavmi commented 2023-04-05 07:45:24 +01:00
Author
Owner
Copy Link

Publishing a beta version now v3.0.0-beta

Publishing a beta version now `v3.0.0-beta`
deavmi commented 2023-04-06 07:52:55 +01:00
Author
Owner
Copy Link

I should probably work on finishing up the unit tests today.

I should probably work on finishing up the unit tests today.
deavmi commented 2023-04-06 07:53:23 +01:00
Author
Owner
Copy Link

Added a configuration option for Manager. First option is to allow a user to auto-register a queue on the invocation of sendMessage(TaggedMessage) based on the tagged message's tag.

Added a configuration option for `Manager`. First option is to allow a user to auto-register a queue on the invocation of `sendMessage(TaggedMessage)` based on the tagged message's tag.
deavmi added a new dependency 2023-04-06 11:09:39 +01:00
#4 Listener support
deavmi added a new dependency 2023-04-06 11:09:44 +01:00
#5 libsnooze event reservation
deavmi commented 2023-04-06 12:14:38 +01:00
Author
Owner
Copy Link

Added safe bformat receive(Socket, ref byte[]) usage as of commit 375a611a827cf0856b4c73f2dc47ee82581a0433

Added safe bformat `receive(Socket, ref byte[])` usage as of commit `375a611a827cf0856b4c73f2dc47ee82581a0433`
deavmi commented 2023-04-06 12:14:50 +01:00
Author
Owner
Copy Link

Added a proper shutdown method as of commit 375a611a827cf0856b4c73f2dc47ee82581a0433

Added a proper shutdown method as of commit `375a611a827cf0856b4c73f2dc47ee82581a0433`
deavmi commented 2023-04-06 12:15:22 +01:00
Author
Owner
Copy Link

Wow, were actually almost done.

Wow, were actually almost done.
deavmi stopped working 2023-04-17 16:01:25 +01:00
2 weeks 3 days
deavmi added spent time 2023-10-01 18:48:44 +01:00
10 minutes
deavmi removed the due date 2023-04-09 2023-10-01 18:48:47 +01:00
deavmi added the due date 2023-10-06 2023-10-01 18:48:59 +01:00
deavmi started working 2023-10-01 18:49:01 +01:00
deavmi commented 2023-10-01 18:49:20 +01:00
Author
Owner
Copy Link

We might want to open a seperate issue, but make sure everything if isnished here first?

We might want to open a seperate issue, but make sure everything if isnished here first?
deavmi added a new dependency 2023-10-01 18:50:10 +01:00
#7 Migrate from libsnooze
deavmi stopped working 2023-10-01 18:50:12 +01:00
1 minute 11 seconds
deavmi started working 2023-10-01 19:52:40 +01:00
deavmi stopped working 2023-10-01 19:59:19 +01:00
6 minutes 38 seconds
deavmi started working 2023-10-02 13:37:05 +01:00
deavmi stopped working 2023-10-02 13:39:05 +01:00
2 minutes
deavmi removed a dependency 2023-10-02 13:40:18 +01:00
#4 Listener support
deavmi started working 2023-10-02 13:40:20 +01:00
deavmi commented 2023-10-02 14:06:48 +01:00
Author
Owner
Copy Link

Working on migrating to niknaks real quick...

Working on migrating to niknaks real quick...
deavmi commented 2023-10-02 14:38:48 +01:00
Author
Owner
Copy Link

Working on migrating to niknaks real quick...

Almost done

> Working on migrating to niknaks real quick... Almost done
deavmi commented 2023-10-02 14:39:41 +01:00
Author
Owner
Copy Link

Working on migrating to niknaks real quick...

Almost done

Merged ✅

> > Working on migrating to niknaks real quick... > > Almost done Merged ✅
deavmi stopped working 2023-10-02 14:39:44 +01:00
59 minutes 24 seconds
deavmi started working 2023-10-02 14:43:02 +01:00
deavmi commented 2023-10-02 14:43:12 +01:00
Author
Owner
Copy Link

What is this?

Re-write of Tristanable, mainly with a performance boost in mind due to the use of libsnooze.

Todo

Todo list:

  • Watcher

    • shutdown method
    • safe bformat receiveMessage(Socket, ref byte[])

  • Watcher queuing

    • default queue
    • testing default queue
    • testing normal queue
    • receiveMessage(Socket, ref byte[])
      • check returned value for error handling
      • ensure watcher dies properly
    • Listener support for when any queue gets updated (see #4)

  • Queue

    • Queue policy
    • Replace QueueItem with just TaggedMessage
    • enqueue (with notify)
    • dequeue (with wake)
    • On construction we might need to reserve using libsnooze (see #5)
    • eventy exception handling etc
      • in notifyAll()
      • in wait()

  • Manager

    • Add a method which can automatically find the next available unused queue id, generate said queue with id and return it
    • testing API
      • register queue (registerQueue(Queue))
        • positive cases
        • negative cases
      • fetching a queue (getQueue(ulong) and getQueue_nothrow(ulong))
        • positive cases
        • negative cases

  • Queue

    • Decide on good wake up interval
    • Add a dequeue(Duration)
      * Because we have wakeup, we must have a stopwatch then or modifythe algo of what wakeup is as well.

Just default queue testing we need to work on.

> ## What is this? > > Re-write of Tristanable, mainly with a performance boost in mind due to the use of `libsnooze`. > > ## Todo > > Todo list: > > - [x] Watcher > - [x] shutdown method > - [x] safe bformat `receiveMessage(Socket, ref byte[])` > - [ ] Watcher queuing > - [ ] default queue > - [ ] testing default queue > - [x] testing normal queue > - [x] `receiveMessage(Socket, ref byte[])` > - [x] check returned value for error handling > - [x] ensure watcher dies properly > - [ ] Listener support for when **any** queue gets updated (see #4) > - [ ] Queue > - [ ] Queue policy > - [x] Replace `QueueItem` with just `TaggedMessage` > - [x] enqueue (with notify) > - [x] dequeue (with wake) > - [x] On construction we might need to reserve using `libsnooze` (see #5) > - [ ] eventy exception handling etc > - [ ] in `notifyAll()` > - [ ] in `wait()` > - [ ] Manager > - [ ] Add a method which can automatically find the next available unused queue id, generate said queue with id and return it > - [ ] testing API > - [x] register queue (`registerQueue(Queue)`) > - [x] positive cases > - [x] negative cases > - [x] fetching a queue (`getQueue(ulong)` and `getQueue_nothrow(ulong)`) > - [x] positive cases > - [x] negative cases > > - [ ] Queue > - [ ] Decide on good wake up interval > - [ ] Add a `dequeue(Duration)` > * Because we have wakeup, we must have a stopwatch then or modifythe algo of what wakeup is as well. Just default queue testing we need to work on.
deavmi commented 2023-10-02 14:48:52 +01:00
Author
Owner
Copy Link

What is this?

Re-write of Tristanable, mainly with a performance boost in mind due to the use of libsnooze.

Todo

Todo list:

  • Watcher

    • shutdown method
    • safe bformat receiveMessage(Socket, ref byte[])

  • Watcher queuing

    • default queue
    • testing default queue
    • testing normal queue
    • receiveMessage(Socket, ref byte[])
      • check returned value for error handling
      • ensure watcher dies properly
    • Listener support for when any queue gets updated (see #4)

  • Queue

    • Queue policy
    • Replace QueueItem with just TaggedMessage
    • enqueue (with notify)
    • dequeue (with wake)
    • On construction we might need to reserve using libsnooze (see #5)
    • eventy exception handling etc
      • in notifyAll()
      • in wait()

  • Manager

    • Add a method which can automatically find the next available unused queue id, generate said queue with id and return it
    • testing API
      • register queue (registerQueue(Queue))
        • positive cases
        • negative cases
      • fetching a queue (getQueue(ulong) and getQueue_nothrow(ulong))
        • positive cases
        • negative cases

  • Queue

    • Decide on good wake up interval
    • Add a dequeue(Duration)
      * Because we have wakeup, we must have a stopwatch then or modifythe algo of what wakeup is as well.

Default queue works

> ## What is this? > > Re-write of Tristanable, mainly with a performance boost in mind due to the use of `libsnooze`. > > ## Todo > > Todo list: > > - [x] Watcher > - [x] shutdown method > - [x] safe bformat `receiveMessage(Socket, ref byte[])` > - [ ] Watcher queuing > - [x] default queue > - [x] testing default queue > - [x] testing normal queue > - [x] `receiveMessage(Socket, ref byte[])` > - [x] check returned value for error handling > - [x] ensure watcher dies properly > - [ ] Listener support for when **any** queue gets updated (see #4) > - [ ] Queue > - [ ] Queue policy > - [x] Replace `QueueItem` with just `TaggedMessage` > - [x] enqueue (with notify) > - [x] dequeue (with wake) > - [x] On construction we might need to reserve using `libsnooze` (see #5) > - [ ] eventy exception handling etc > - [ ] in `notifyAll()` > - [ ] in `wait()` > - [ ] Manager > - [ ] Add a method which can automatically find the next available unused queue id, generate said queue with id and return it > - [ ] testing API > - [x] register queue (`registerQueue(Queue)`) > - [x] positive cases > - [x] negative cases > - [x] fetching a queue (`getQueue(ulong)` and `getQueue_nothrow(ulong)`) > - [x] positive cases > - [x] negative cases > > - [ ] Queue > - [ ] Decide on good wake up interval > - [ ] Add a `dequeue(Duration)` > * Because we have wakeup, we must have a stopwatch then or modifythe algo of what wakeup is as well. Default queue works
deavmi stopped working 2023-10-02 14:49:06 +01:00
6 minutes 4 seconds
deavmi started working 2023-10-02 14:49:57 +01:00
deavmi commented 2023-10-02 14:50:10 +01:00
Author
Owner
Copy Link

Merging...

But issue stays open as I still want to work on it.

Merging... But issue stays open as I still want to work on it.
deavmi stopped working 2023-10-02 14:57:41 +01:00
7 minutes 43 seconds
deavmi changed reference from nextgen to master 2023-10-02 15:04:03 +01:00
Sign in to join this conversation.
master
Branches Tags
Clear current reference
master
hotfix/unblock_queues_on_shutdown
nextgen_listener
nextgen
hotfix/niknaks
libsnooze_deprecate
nextgen_queue_remove
nextgen_river
onRecvQeue
select
modular
develop
list_improvement
exceptions
newFuncs
queuePolicy
queue_sys
reserved_tags
Clear current reference
v4.1.2-beta
v4.1.1-beta
v4.1.0-beta
v4.0.2-beta
v4.0.1-beta
v4.0.0-beta
v3.2.4-beta
v3.2.3-beta
v3.2.2-beta
v3.2.1-beta
v3.2.0-beta
v3.1.9-beta
v3.1.9.beta
v3.1.8-beta
v3.1.7-beta
v3.1.6-beta
v3.1.5-beta
v3.1.4-beta
v3.1.3-beta
v3.1.2-beta
v3.1.1-beta
v3.1.0-beta
v3.0.1-beta
v3.0.0-beta
v2.6.12
v2.6.11
v2.6.10
v2.6.9
v2.6.8
v2.6.7
v2.6.6
v2.6.5
v2.6.4
v2.6.3
v2.6.2
v2.6.1
v2.4.1
v2.4.0
v0.2.0
v2.6.0
v2.3.15
v2.3.14
v2.3.13
v2.3.12
v2.3.11
v2.3.10
v2.3.9
v2.3.8
v2.3.7
v2.3.6
v2.3.5
v2.3.4
v2.3.3
v2.3.2
v2.3.1
v2.3.0
v2.2.1
v2.2.0
v2.1.0
v1.0.0
v0.1.1
v0.1.0
v0.0.33
v0.0.32
v0.0.31
v0.0.30
v0.0.29
v0.0.28
v0.0.27
v0.0.26
v0.0.25
v0.0.24
v0.0.23
v0.0.22
v0.0.21
v0.0.20
v0.0.19
v0.0.18
v0.0.17
v0.0.16
v0.0.15
v0.0.14
v0.0.13
v0.0.12
v0.0.11
v0.0.10
v0.0.9
v0.0.8
v0.0.7
v0.0.6
v0.0.4
v0.0.3
v0.0.2
v0.0.1
v0.0.0
Labels
Clear labels   
bug

Something is not working

  
duplicate

This issue or pull request already exists

  
enhancement

New feature

  
help wanted

Need some help

  
invalid

Something is wrong

  
question

More information is needed

  
todo

Something that just needs to be done

  
wontfix

This won't be fixed

No Label
bug
duplicate
enhancement
help wanted
invalid
question
todo
wontfix
Milestone
Clear milestone
No items
No Milestone
Next-gen
Projects
Clear projects
No project
Assignees
Clear assignees
No Assignees
deavmi
1 Participants
Notifications
Total Time Spent: 2 weeks 4 days
deavmi
2 weeks 4 days
Due Date
The due date is invalid or out of range. Please use the format 'yyyy-mm-dd'.

2023-10-06

Depends on
#7 Migrate from libsnooze
deavmi/tristanable
You do not have permission to read 2 dependencies
Reference: deavmi/tristanable#3
No description provided.
Delete Branch "%!s(<nil>)"

Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?