sigq

Check-in Differences
Login

Check-in Differences

Hide Diff Invert Patch Path Unified Diff

Many hyperlinks are disabled.
Use anonymous login to enable hyperlinks.

Difference From sigq-0.13.0 To sigq-0.13.1

2023-07-26
19:54
Documentation udates. Hide push and pull modules from public. check-in: b485d7b118 user: jan tags: sigq-0.13.2, trunk
2023-07-25
01:49
Release maintenance. check-in: 052111cfd8 user: jan tags: sigq-0.13.1, trunk
01:47
Clear the internal queue when the last Puller is dropped. check-in: 2e05c4ff29 user: jan tags: trunk
00:33
Add missing release date. check-in: 6d69807551 user: jan tags: trunk
00:30
Release maintenance. check-in: 3d150dc1c3 user: jan tags: sigq-0.13.0, trunk
00:28
Typo. check-in: f60eca957a user: jan tags: trunk

Changes to Cargo.toml. 

1
2
3
4
5
6
7
8
9
10

[package]
name = "sigq"
version = "0.13.0"
authors = ["Jan Danielsson <jan.danielsson@qrnch.com>"]
edition = "2021"
license = "0BSD"
categories = [ "asynchronous", "concurrency", "data-structures" ]
keywords = [ "threads", "sync" ]
repository = "https://repos.qrnch.tech/pub/sigq"
description = "Queue that signals waiting consumers about node availability"



|








1
2
3
4
5
6
7
8
9
10

[package]
name = "sigq"
version = "0.13.1"
authors = ["Jan Danielsson <jan.danielsson@qrnch.com>"]
edition = "2021"
license = "0BSD"
categories = [ "asynchronous", "concurrency", "data-structures" ]
keywords = [ "threads", "sync" ]
repository = "https://repos.qrnch.tech/pub/sigq"
description = "Queue that signals waiting consumers about node availability"
︙︙

Changes to src/pull.rs.

︙︙
94
95
96
97
98
99
100







101
102
103
104
105
106
107

  }
}

impl<I> Drop for Puller<I> {
  fn drop(&mut self) {
    let mut inner = self.0.inner.lock();
    inner.npullers -= 1;







  }
}


#[doc(hidden)]
pub struct PopFuture<I> {
  ctx: Arc<super::Shared<I>>,








>
>
>
>
>
>
>








94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114

  }
}

impl<I> Drop for Puller<I> {
  fn drop(&mut self) {
    let mut inner = self.0.inner.lock();
    inner.npullers -= 1;

    // If this is the last puller then remove all thr nodes.
    // The nodes may contain some kind of context that must be notified that
    // the node will never reach its destination.
    if inner.npullers == 0 {
      inner.q.clear();
    }
  }
}


#[doc(hidden)]
pub struct PopFuture<I> {
  ctx: Arc<super::Shared<I>>,
︙︙

Changes to www/changelog.md. 

1
2
3
4
5
6
7
8
9
10
11











12
13
14
15
16
17
18
19

# Change Log

## [Unreleased]

### Added

### Changed

### Removed













## [0.13.0]

### Added

### Changed

- `Pusher::push()` will return `Err(StaleErr)` if there are no more associated
  `Puller`s.












>
>
>
>
>
>
>
>
>
>
>
|








1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

# Change Log

## [Unreleased]

### Added

### Changed

### Removed


## [0.13.1] - 2023-07-25

### Added

### Changed

- When the last `Puller` is dropped, clear the queue.

### Removed


## [0.13.0] - 2023-07-25

### Added

### Changed

- `Pusher::push()` will return `Err(StaleErr)` if there are no more associated
  `Puller`s.
︙︙