A collection of lower-level libraries for composable network services.

Actix

Last update: Dec 28, 2022

Overview

Actix Net

A collection of lower-level libraries for composable network services.

Example

See actix-server/examples and actix-tls/examples for some basic examples.

MSRV

This repo's Minimum Supported Rust Version (MSRV) is 1.46.0.

License

The crates in repo are licensed under either of:

Apache License, Version 2.0, (LICENSE-APACHE or http://www.apache.org/licenses/LICENSE-2.0)
MIT license (LICENSE-MIT or http://opensource.org/licenses/MIT)

at your option.

Code of Conduct

Contribution to the actix-net repo is organized under the terms of the Contributor Covenant. The Actix team promises to intervene to uphold that code of conduct.

Comments

actix-rt: leaking memory in every request

I just compiled example from github and run apache benchmarks ab -n 1000000 -c 64 http://127.0.0.1:8001/test/john/index.html and memory was constantly growing. After 1 milion requests it was 3.1 GB of heap.

I could reproduce the same on my catalina macbook pro and linux server. It's like every request is leaking few KB's of memory.

opened by Lesiuk 30
Connection not closed properly

I've been using 1.x version of actix-web for months, had to restart my app every now and then (sometimes after minutes, sometimes after days) since there are a lot of ESTABLISHED connections left there hanging, eventually causing too many open files error (I've increased the limit drastically). I'm using my server with keep-alive disabled, the rest of the settings are the defaults. I have since tried to upgrade to 2.0.0 to see if it solves the problem, but it's the same thing.

The service itself gets around 500-1000 requests per second in production currently.

opened by orangesoup 29
Tracking issue for std::future migration
This issue tracks the migration.

Crates migrated:

[x] - actix-threadpool #46

[x] - actix-rt #47

[x] - actix-codec #48

[x] - actix-service (discussion needed) #57

[x] - actix-server-config (Needs bugfixing)

[x] - actix-server (Needs bugfixing)

[x] - actix-utils

[x] - actix-connect

[x] - actix-ioframe

note: these are in rough dependency order

Decisions:

The old future trait had Item, and Error associated types. This meant it was similar to the Result type, and thus, every function that returned future was fallible. Now, the future has only one associated type, that denotes infallible future output.

Several places return a future with a result, that is not used anywhere, or its error type is (). Which of these occurences should be replaced with Future<Output=Item>, and which with Future<Output=Result<Item,Error>>?

Usage of the Pin<&mut Self> in places similar to future, this means the Service::poll_ready and ActorFuture::poll in actix.

There is a reason for using these Pins in the poll method, should we upgrade our definitions of traits similar to Future to also utilize them ?. Also, maybe not, since these were primarily introduced to support await in the form of generators. Need more info from qualified people.

Usage and form of macros / functions to ease pinning and unpinning.

I am currently working on actix-service, and it is a massive chore to always create unsafe block in order to create or destrucure a Pin<&mut T>. This can be sometimes solved by pin projections from the pin-utils crate, but it does not allow splitting borrows ( Creating multiple pins to multiple fields of a struct), which is a massive pain.

enhancement help wanted
opened by semtexzv 17
WIP: Convert actix-service to use RefCell instead of UnsafeCell
Hi, this is first PoC implementation for gathering feedback to make sure I am on the right path.

For smooth conversion I have added AXCell, which is similar to former Cell but using RefCell under the hood. Also added couple of concurrency tests with delays on first and second service to validate that there are no 2 mutable borrows which would lead to panic with RefCell.

By benchmarks pipeline with new AndThen performing similar to UnsafeCell baseline implementation:

AndThen with UnsafeCell #2 time: [54.157 ns 54.850 ns 55.605 ns] AndThen with RefCell #2 time: [54.976 ns 55.624 ns 56.353 ns] Pipeline::and_then based Rc<RefCell> time: [54.696 ns 55.260 ns 55.866 ns]

Pls let me know if using this approach is ok?
opened by dunnock 15
fix "Can not register server socket" The parameter is incorrect. on windows
PR Type

Bug Fix

PR Checklist

Check your PR fulfills the following:

[ ] Tests for the changes have been added / updated.

[ ] Documentation comments have been added / updated.

[ ] A changelog entry has been made for the appropriate packages.

[x] Format code with the latest stable rustfmt

Overview

This should fix another place where this issue have occured.

Closes #221
opened by danylaporte 13
Refactor LocalWaker

~Simplify LocalWaker register method with replace mutable pointer method~

Refactor LocalWaker: is_registered has no real use because the only use of the registry is to wake up the task it refers to. But wake does not need the registration status, the behavior is the same whether a task is registered or not. So it has been removed in favor of wake. Without this method the use of UnsafeCell is not necessary so I have proposed a later refactor from UnsafeCell to Cell.

opened by botika 12

Limit of max_connections is not enforced on backlog

Here's an example service with max_connections set to 2 and backlog of 16 (actix-web v3.3.0):

const MAX_CONNECTIONS: usize = 2;
const BACKLOG: i32 = 16;
const WORKERS: usize = 1;

const ADDR: &str = "127.0.0.1:8888";

#[actix_web::main]
async fn main() -> std::io::Result<()> {
    simplelog::CombinedLogger::init(vec![simplelog::TermLogger::new(
        simplelog::LevelFilter::Info,
        simplelog::Config::default(),
        simplelog::TerminalMode::Stderr,
    )])
    .expect("logging configuration failed");

    log::info!(
        "Running server with {} workers / {} max connections / {} listen backlog on {}",
        WORKERS,
        MAX_CONNECTIONS,
        BACKLOG,
        ADDR
    );

    actix_web::HttpServer::new(move || {
        actix_web::App::new().route("/", actix_web::web::get().to(greet))
    })
    .on_connect(move |_, _| {
        log::info!(
            "number of open fds = {}",
            procfs::process::Process::myself()
                .expect("creating procfs reader failed")
                .fd_count()
                .expect("getting fd count failed")
        )
    })
    .max_connections(MAX_CONNECTIONS)
    .backlog(BACKLOG)
    .workers(WORKERS)
    .bind(ADDR)?
    .run()
    .await
}

async fn greet() -> impl actix_web::Responder {
    "howdy!\n"
}

One can run it:

$ cargo run

And then use the following go program to create one connection every 100ms without any requests:

package main

import (
	"log"
	"net"
	"time"
)

func main() {
	i := 0
	for {
		i++

		_, err := net.Dial("tcp", "127.0.0.1:8888")
		if err != nil {
			log.Fatalf("Connection #%d failed: %s", i, err)
		}

		log.Printf("Connnection #%d succeded", i)

		time.Sleep(time.Millisecond * 100)
	}
}

The go program will happily churn until the end of ulimit.

What I expect from Actix is to not have more than 2 (limit) + 16 (backlog) connections open at any point, which corresponds to 22 open file descriptors (let's say under 30 for simplicity). What I see is that number gets a lot higher:

01:32:00 [INFO] Running server with 1 workers / 2 max connections / 16 listen backlog on 127.0.0.1:8888
01:32:00 [INFO] Starting 1 workers
01:32:00 [INFO] Starting "actix-web-service-127.0.0.1:8888" service on 127.0.0.1:8888
01:32:06 [INFO] number of open fds = 21
01:32:06 [INFO] number of open fds = 22
01:32:11 [INFO] number of open fds = 23
01:32:11 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:32:11 [INFO] number of open fds = 22
01:32:16 [INFO] number of open fds = 39
01:32:16 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:32:16 [INFO] number of open fds = 38
01:32:21 [INFO] number of open fds = 54
01:32:21 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:32:21 [INFO] number of open fds = 53
01:32:26 [INFO] number of open fds = 69
01:32:26 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:32:26 [INFO] number of open fds = 68
01:32:31 [INFO] number of open fds = 79
01:32:31 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:32:31 [INFO] number of open fds = 78
01:32:36 [INFO] number of open fds = 94
01:32:36 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:32:36 [INFO] number of open fds = 93
01:32:41 [INFO] number of open fds = 103
01:32:41 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:32:41 [INFO] number of open fds = 102
01:32:46 [INFO] number of open fds = 118
01:32:46 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:32:46 [INFO] number of open fds = 117
01:32:51 [INFO] number of open fds = 128
01:32:51 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:32:51 [INFO] number of open fds = 127
01:32:56 [INFO] number of open fds = 143
01:32:56 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:32:56 [INFO] number of open fds = 142
01:33:01 [INFO] number of open fds = 153
01:33:01 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:33:01 [INFO] number of open fds = 152
01:33:06 [INFO] number of open fds = 168
01:33:06 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:33:06 [INFO] number of open fds = 167
01:33:11 [INFO] number of open fds = 177
01:33:11 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:33:11 [INFO] number of open fds = 176
01:33:16 [INFO] number of open fds = 192
01:33:16 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:33:16 [INFO] number of open fds = 191
01:33:21 [INFO] number of open fds = 202
01:33:21 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:33:21 [INFO] number of open fds = 201
01:33:26 [INFO] number of open fds = 217
01:33:26 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:33:26 [INFO] number of open fds = 216
01:33:31 [INFO] number of open fds = 227
01:33:31 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:33:31 [INFO] number of open fds = 226
01:33:36 [INFO] number of open fds = 242
01:33:36 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:33:36 [INFO] number of open fds = 241
01:33:41 [INFO] number of open fds = 251
01:33:41 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:33:41 [INFO] number of open fds = 250
01:33:46 [INFO] number of open fds = 266
01:33:46 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:33:46 [INFO] number of open fds = 265
01:33:51 [INFO] number of open fds = 276
01:33:51 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:33:51 [INFO] number of open fds = 275
01:33:56 [INFO] number of open fds = 291
01:33:56 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:33:56 [INFO] number of open fds = 290
01:34:01 [INFO] number of open fds = 300
01:34:01 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:34:01 [INFO] number of open fds = 299
01:34:06 [INFO] number of open fds = 315
01:34:06 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:34:06 [INFO] number of open fds = 314
01:34:11 [INFO] number of open fds = 325
01:34:11 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:34:11 [INFO] number of open fds = 324
01:34:16 [INFO] number of open fds = 340
01:34:16 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:34:16 [INFO] number of open fds = 339
01:34:21 [INFO] number of open fds = 350
01:34:21 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:34:21 [INFO] number of open fds = 349
01:34:26 [INFO] number of open fds = 365
01:34:26 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:34:26 [INFO] number of open fds = 364
01:34:31 [INFO] number of open fds = 374
01:34:31 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:34:31 [INFO] number of open fds = 373
01:34:36 [INFO] number of open fds = 388
01:34:36 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:34:36 [INFO] number of open fds = 388
01:34:41 [INFO] number of open fds = 399
01:34:41 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:34:41 [INFO] number of open fds = 398
01:34:46 [INFO] number of open fds = 414
01:34:46 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:34:46 [INFO] number of open fds = 413
01:34:51 [INFO] number of open fds = 424
01:34:51 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:34:51 [INFO] number of open fds = 423
01:34:56 [INFO] number of open fds = 439
01:34:56 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:34:56 [INFO] number of open fds = 438
01:35:01 [INFO] number of open fds = 448
01:35:01 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:35:01 [INFO] number of open fds = 447
01:35:06 [INFO] number of open fds = 463
01:35:06 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:35:06 [INFO] number of open fds = 462
01:35:11 [INFO] number of open fds = 472
01:35:11 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:35:11 [INFO] number of open fds = 472
01:35:16 [INFO] number of open fds = 488
01:35:16 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:35:16 [INFO] number of open fds = 487
01:35:21 [INFO] number of open fds = 498
01:35:21 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:35:21 [INFO] number of open fds = 497
01:35:26 [INFO] number of open fds = 513
01:35:26 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:35:26 [INFO] number of open fds = 512
01:35:31 [INFO] number of open fds = 522
01:35:31 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:35:31 [INFO] number of open fds = 521
01:35:36 [INFO] number of open fds = 537
01:35:36 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:35:36 [INFO] number of open fds = 536
01:35:41 [INFO] number of open fds = 547
01:35:41 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:35:41 [INFO] number of open fds = 546
01:35:46 [INFO] number of open fds = 562
01:35:46 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:35:46 [INFO] number of open fds = 561
01:35:51 [INFO] number of open fds = 572
01:35:51 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:35:51 [INFO] number of open fds = 571
01:35:56 [INFO] number of open fds = 587
01:35:56 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:35:56 [INFO] number of open fds = 586
01:36:01 [INFO] number of open fds = 596
01:36:01 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:36:01 [INFO] number of open fds = 595
01:36:06 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:36:06 [INFO] number of open fds = 615
01:36:06 [INFO] number of open fds = 622
01:36:11 [INFO] number of open fds = 621
01:36:11 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:36:11 [INFO] number of open fds = 620
01:36:16 [INFO] number of open fds = 636
01:36:16 [INFO] Accepting connections on 127.0.0.1:8888 has been resumed
01:36:16 [INFO] number of open fds = 635

From what I see, backlog is getting drained faster than it should be. In strace output one can see (this is the very beginning of Go connection generation):

$ sudo strace -Tt -f -p $(pidof actix-conn-limit) -e accept4,close
strace: Process 5159 attached with 3 threads
[pid  5405] 01:38:16 accept4(6, {sa_family=AF_INET, sin_port=htons(35126), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 19 <0.000042>
[pid  5405] 01:38:16 accept4(6, 0x7fe321cf4550, [128], SOCK_CLOEXEC) = -1 EAGAIN (Resource temporarily unavailable) <0.000019>
[pid  5404] 01:38:16 close(21)          = 0 <0.000023>
[pid  5404] 01:38:16 close(20)          = 0 <0.000011>
[pid  5404] 01:38:16 syscall_332(0, 0, 0, 0xfff, 0, 0x10) = -1 (errno 14) <0.000013>
[pid  5404] 01:38:16 syscall_332(0xffffffffffffff9c, 0x7fe31c006b00, 0, 0xfff, 0x7fe321eee620, 0) = 0 <0.000015>
[pid  5404] 01:38:16 close(20)          = 0 <0.000010>
[pid  5405] 01:38:17 accept4(6, {sa_family=AF_INET, sin_port=htons(35128), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 20 <0.000018>
[pid  5405] 01:38:17 accept4(6, 0x7fe321cf4550, [128], SOCK_CLOEXEC) = -1 EAGAIN (Resource temporarily unavailable) <0.000017>
[pid  5404] 01:38:17 close(21)          = 0 <0.000013>
[pid  5404] 01:38:17 syscall_332(0xffffffffffffff9c, 0x7fe31c006240, 0, 0xfff, 0x7fe321eee620, 0) = 0 <0.000025>
[pid  5404] 01:38:17 close(21)          = 0 <0.000010>
[pid  5405] 01:38:17 accept4(6, {sa_family=AF_INET, sin_port=htons(35130), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 21 <0.000029>
[pid  5405] 01:38:17 accept4(6, 0x7fe321cf4550, [128], SOCK_CLOEXEC) = -1 EAGAIN (Resource temporarily unavailable) <0.000012>
[pid  5405] 01:38:17 accept4(6, {sa_family=AF_INET, sin_port=htons(35132), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 22 <0.000017>
[pid  5405] 01:38:17 accept4(6, 0x7fe321cf4550, [128], SOCK_CLOEXEC) = -1 EAGAIN (Resource temporarily unavailable) <0.000015>
[pid  5404] 01:38:21 close(20)          = 0 <0.000056>
[pid  5404] 01:38:21 close(20)          = 0 <0.000029>
[pid  5404] 01:38:21 syscall_332(0xffffffffffffff9c, 0x7fe31c007320, 0, 0xfff, 0x7fe321eee620, 0) = 0 <0.000019>
[pid  5404] 01:38:21 close(20)          = 0 <0.000026>
[pid  5404] 01:38:21 close(19)          = 0 <0.000033>
[pid  5404] 01:38:21 close(19)          = 0 <0.000033>
[pid  5404] 01:38:21 syscall_332(0xffffffffffffff9c, 0x7fe31c02ae30, 0, 0xfff, 0x7fe321eee620, 0) = 0 <0.000018>
[pid  5404] 01:38:21 close(19)          = 0 <0.000021>
[pid  5405] 01:38:21 accept4(6, {sa_family=AF_INET, sin_port=htons(35134), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 19 <0.000039>
[pid  5405] 01:38:21 accept4(6, {sa_family=AF_INET, sin_port=htons(35136), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 20 <0.000035>
[pid  5405] 01:38:21 accept4(6, {sa_family=AF_INET, sin_port=htons(35138), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 23 <0.000021>
[pid  5405] 01:38:21 accept4(6, {sa_family=AF_INET, sin_port=htons(35140), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 24 <0.000022>
[pid  5405] 01:38:21 accept4(6, {sa_family=AF_INET, sin_port=htons(35142), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 25 <0.000020>
[pid  5405] 01:38:21 accept4(6, {sa_family=AF_INET, sin_port=htons(35144), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 26 <0.000021>
[pid  5405] 01:38:21 accept4(6, {sa_family=AF_INET, sin_port=htons(35146), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 27 <0.000021>
[pid  5405] 01:38:21 accept4(6, {sa_family=AF_INET, sin_port=htons(35148), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 28 <0.000021>
[pid  5405] 01:38:21 accept4(6, {sa_family=AF_INET, sin_port=htons(35150), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 29 <0.000021>
[pid  5405] 01:38:21 accept4(6, {sa_family=AF_INET, sin_port=htons(35152), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 30 <0.000020>
[pid  5405] 01:38:21 accept4(6, {sa_family=AF_INET, sin_port=htons(35154), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 31 <0.000020>
[pid  5405] 01:38:21 accept4(6, {sa_family=AF_INET, sin_port=htons(35156), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 32 <0.000015>
[pid  5405] 01:38:21 accept4(6, {sa_family=AF_INET, sin_port=htons(35158), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 33 <0.000017>
[pid  5405] 01:38:21 accept4(6, {sa_family=AF_INET, sin_port=htons(35160), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 34 <0.000031>
[pid  5405] 01:38:21 accept4(6, {sa_family=AF_INET, sin_port=htons(35162), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 35 <0.000018>
[pid  5405] 01:38:21 accept4(6, {sa_family=AF_INET, sin_port=htons(35164), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 36 <0.000016>
[pid  5405] 01:38:21 accept4(6, {sa_family=AF_INET, sin_port=htons(35166), sin_addr=inet_addr("127.0.0.1")}, [128->16], SOCK_CLOEXEC) = 37 <0.000015>
[pid  5405] 01:38:21 accept4(6, 0x7fe321cf4550, [128], SOCK_CLOEXEC) = -1 EAGAIN (Resource temporarily unavailable) <0.000018>

In my mind max_connections should never allow more than 2 consecutive accept4 without a close between them.

opened by bobrik 12

actix-rt: Make the process of running System in existing Runtime more clear
PR Type

Other (Usability enhancement)

PR Checklist

Check your PR fulfills the following:

[x] Tests for the changes have been added / updated.

[x] Documentation comments have been added / updated.

[x] A changelog entry has been made for the appropriate packages.

[x] Format code with the latest stable rustfmt

Overview

When I first tried to start the actix-web server using an existing tokio Runtime, I honestly found the interface a bit unfriendly.

In an attempt to make other folks' life easier I did the following:

Added doc-comments with an example and a note about Arbiters still using their own Runtime objects.

Added a new method which is less flexible but simpler to use to attach a System to a given Runtime.

These changes aren't breaking and hopefully useful.
opened by popzxc 12
rework actix-threadpool
PR Type

Refactor

PR Checklist

Check your PR fulfills the following:

[x] Tests for the changes have been added / updated.

[x] Documentation comments have been added / updated.

[x] A changelog entry has been made for the appropriate packages.

[x] Format code with the latest stable rustfmt

Overview

actix-threadpool would spawn a fixed number of threads in a static pool and stay for the life of whole actix-app lifetime. I feel this is an overkill for majority use case and may bring up confusion.

This PR reworks the pool to use a dynamic strategy with the following behavior:

Rename the worker thread name from "actix-web" to "actix-threadpool-worker".

Start with 1 idle thread and when more jobs goes in it spawn more threads until hitting the upper limit.

Any pool thread kept idle for 5 minutes would de spawn it self.

This PR is still not complete and need some help on tests and benchmarks.
opened by fakeshadow 12
Migrate actix-service to std::future
Originally from @semtexzv.

The big picture starting with actix-service:

Using Pin<&mut Self> in poll_ready since it usually polls futures, not in call, which we might wanna change. There is an issue with the IntoFuture trait not being provided by futures anymore, so I wrote a simple one, and am using it throughout the codebase. This is just a first iteration, and will require some work, also BoxedService impl currently does not work, since it polls a future in call method.

Decisions that we need to make:

The old future trait had Item, and Error associated types. This meant it was similar to the Result type, and thus, every function that returned future was fallible. Now, the future has only one associated type, that denotes infallible future output.

Several places return a future with a result, that is not used anywhere, or its error type is (). Which of these occurences should be replaced with Future<Output=Item>, and which with Future<Output=Result<Item,Error>>?

Usage of the Pin<&mut Self> in places similar to future, this means the Service::poll_ready and ActorFuture::poll in actix.

There is a reason for using these Pins in the poll method, should we upgrade our definitions of traits similar to Future to also utilize them ?. Also, maybe not, since these were primarily introduced to support await in the form of generators. Need more info from qualified people.

Usage and form of macros / functions to ease pinning and unpinning.

I am currently working on actix-service, and it is a massive chore to always create unsafe block in order to create or destrucure a Pin<&mut T>. This can be sometimes solved by pin projections from the pin-utils crate, but it does not allow splitting borrows ( Creating multiple pins to multiple fields of a struct), which is a massive pain.

enhancement help wanted question
opened by cdbattags 12
Start the std::future and tokio 0.2 migration

This PR contains the work to start the migration of actix ecosystem to std::future, and tokio 0.2.

Currently, the actix-rt, actix-codec and actix-threadpool libraries are done. Big part of this migration will be actix-service, and thus, I invite you to help.

@fafhrd91 I'd like you to create a separate branch, so this work can live in this repository instead of my fork.

opened by semtexzv 12

how to close connection immediately?

if client's connection is probably attacking, how can I close it immediately and insert the address into a dynamic blacklist?

    let listener = TcpListener::bind(...).await?;

    while let (socket, addr) = listener.accept().await? {

        if blacklist.contains(&addr) {
            continue;
        }

        tokio::spawn(async move {

            ...

            if connection_is_attacking() {
                blacklist.insert(addr);
                connection.close_immediately();
            }

            ...

        });
    }

opened by lithbitren 0

PoC proxy protocol stream wrapper
PR Type

INSERT_PR_TYPE

PR Checklist

Check your PR fulfills the following:

[ ] Tests for the changes have been added / updated.

[ ] Documentation comments have been added / updated.

[ ] A changelog entry has been made for the appropriate packages.

[ ] Format code with the latest stable rustfmt

Overview
opened by robjtede 0
add MPTCP socket protocol (optional)

PR Type

Feature

Overview

Add the possibility to use the MPTCP protocol at the socket level for users of ServerBuilder.

MPTCP is now more widely available since Linux Kernel version >= 5.6. But it still need to be enabled manually using: sysctl net.mptcp.enabled=1 (of course, MPTCP is only available on Linux).

The new MPTCP struct give the user the option to determine how we'll handle the case where MPTCP is not available on the host, either we crash, or we fallback to regular TCP.

opened by Martichou 1
impl Transform for Option

This topic continues https://github.com/actix/actix-web/pull/2858 , whole goal is to .wrap an optional middleware. Condition middleware exists but requires a transformer even when unused. It seems to me that using an Option is more natural. But as that PR was on a different crate than Transform's, a newtype was introduced, and .into() required an explicit annotation. Sadly this was non-optimal.

@fakeshadow suggested that this feature should rather be moved into Transform's crate, so that .wrap can natively take an Option<SomeMiddleware>. This would mean moving the ConditionMiddleware code too.

opened by KoltesDigital 1

Releases(bytestring-v1.2.1)

bytestring-v1.2.1(Nov 12, 2022)
Fix #[no_std] compatibility. #471

Source code(tar.gz)
Source code(zip)
bytestring-v1.2.0(Nov 7, 2022)
Add ByteString::slice_ref which can safely slice a ByteString into a new one with zero copy. #470

Minimum supported Rust version (MSRV) is now 1.57.

Source code(tar.gz)
Source code(zip)
utils-v3.0.1(Oct 21, 2022)
Minimum supported Rust version (MSRV) is now 1.57.

Source code(tar.gz)
Source code(zip)
bytestring-v1.1.0(Jun 11, 2022)
Implement From<Box<str>> for ByteString. #458

Implement Into<String> for ByteString. #458

Minimum supported Rust version (MSRV) is now 1.49.

Source code(tar.gz)
Source code(zip)
local-waker-v0.1.3(May 3, 2022)
No significant changes since 0.1.2.

Minimum supported Rust version (MSRV) is now 1.49.

Source code(tar.gz)
Source code(zip)
local-channel-v0.1.3(May 3, 2022)
No significant changes since 0.1.2.

Minimum supported Rust version (MSRV) is now 1.49.

Source code(tar.gz)
Source code(zip)
tls-v3.0.4(Mar 15, 2022)
Logs emitted now use the tracing crate with log compatibility. #451

Source code(tar.gz)
Source code(zip)
codec-v0.5.1(Mar 15, 2022)
Logs emitted now use the tracing crate with log compatibility. #451

Minimum supported Rust version (MSRV) is now 1.49.

Source code(tar.gz)
Source code(zip)
server-v2.1.1(Mar 9, 2022)
No significant changes since 2.1.0.

Source code(tar.gz)
Source code(zip)
server-v2.1.0(Mar 9, 2022)
Update tokio-uring dependency to 0.3.0. #448

Logs emitted now use the tracing crate with log compatibility. #448

Wait for accept thread to stop before sending completion signal. #443

Source code(tar.gz)
Source code(zip)
rt-v2.7.0(Mar 9, 2022)
Update tokio-uring dependency to 0.3.0. #448

Minimum supported Rust version (MSRV) is now 1.49.

Source code(tar.gz)
Source code(zip)
tls-v3.0.3(Feb 15, 2022)
No significant changes since 3.0.2.

Source code(tar.gz)
Source code(zip)
server-v2.0.0(Feb 15, 2022)
No significant changes since 2.0.0-rc.4.

Source code(tar.gz)
Source code(zip)
codec-v0.5.0(Feb 15, 2022)
Updated tokio-util dependency to 0.7.0. #446

Source code(tar.gz)
Source code(zip)
tls-v3.0.2(Jan 28, 2022)
Expose connect::Connection::new. #439

Source code(tar.gz)
Source code(zip)
rt-v2.6.0(Jan 12, 2022)
Update tokio-uring dependency to 0.2.0. #436

Source code(tar.gz)
Source code(zip)
server-v2.0.0-rc.4(Jan 12, 2022)
Update tokio-uring dependency to 0.2.0. #436

Source code(tar.gz)
Source code(zip)
tls-v3.0.1(Jan 11, 2022)
No significant changes since 3.0.0.

Source code(tar.gz)
Source code(zip)
rt-v2.5.1(Dec 31, 2021)
Expose System::with_tokio_rt and Arbiter::with_tokio_rt. #430

Source code(tar.gz)
Source code(zip)
codec-v0.4.2(Dec 31, 2021)
No significant changes since 0.4.1.

Source code(tar.gz)
Source code(zip)
server-v2.0.0-rc.3(Dec 31, 2021)
No significant changes since 2.0.0-rc.2.

Source code(tar.gz)
Source code(zip)
server-v2.0.0-rc.2(Dec 27, 2021)
Simplify TestServer. #431

Source code(tar.gz)
Source code(zip)
tls-v3.0.0(Dec 26, 2021)
No significant changes since 3.0.0-rc.2.

Source code(tar.gz)
Source code(zip)
service-v2.0.2(Dec 18, 2021)
Service types can now be Send and 'static regardless of request, response, and config types. #397

Source code(tar.gz)
Source code(zip)
local-waker-v0.1.2(Dec 18, 2021)
Fix crate metadata.

Source code(tar.gz)
Source code(zip)
tls-v3.0.0-rc.2(Dec 10, 2021)
Re-export openssl::SslConnectorBuilder in connect::openssl::reexports. #429

Source code(tar.gz)
Source code(zip)
server-v2.0.0-rc.1(Dec 5, 2021)
Hide implementation details of Server. #424

Server now runs only after awaiting it. #425

Source code(tar.gz)
Source code(zip)
tls-v3.0.0-rc.1(Nov 30, 2021)
Added

Derive Debug for connect::Connection. #422

Implement Display for accept::TlsError. #422

Implement Error for accept::TlsError where both types also implement Error. #422

Implement Default for connect::Resolver. #422

Implement Error for connect::ConnectError. #422

Implement Default for connect::tcp::{TcpConnector, TcpConnectorService}. #423

Implement Default for connect::ConnectorService. #423

Changed

The crate's default features flags no longer include uri. #422

Useful re-exports from underlying TLS crates are exposed in a reexports modules in all acceptors and connectors.

Convert connect::ResolverService from enum to struct. #422

Make ConnectAddrsIter private. #422

Mark tcp::{TcpConnector, TcpConnectorService} structs #[non_exhaustive]. #423

Rename accept::native_tls::{NativeTlsAcceptorService => AcceptorService}. #422

Rename connect::{Address => Host} trait. #422

Rename method connect::Connection::{host => hostname}. #422

Rename struct connect::{Connect => ConnectInfo}. #422

Rename struct connect::{ConnectService => ConnectorService}. #422

Rename struct connect::{ConnectServiceFactory => Connector}. #422

Rename TLS acceptor service future types and hide from docs. #422

Unbox some service futures types. #422

Inline modules in connect::tls to connect module. #422

Removed

Remove connect::{new_connector, new_connector_factory, default_connector, default_connector_factory} methods. #422

Remove connect::native_tls::Connector::service method. #422

Remove redundant connect::Connection::from_parts method. #422

Source code(tar.gz)
Source code(zip)
rt-v2.5.0(Nov 22, 2021)
Add System::run_with_code to allow retrieving the exit code on stop. #411

Source code(tar.gz)
Source code(zip)
tls-v3.0.0-beta.9(Nov 22, 2021)
Add configurable timeout for accepting TLS connection. #393

Added TlsError::Timeout variant. #393

All TLS acceptor services now use TlsError for their error types. #393

Added TlsError::into_service_error. #420

Source code(tar.gz)
Source code(zip)