Skip to content

rebase#2

Merged
rustopian merged 364 commits intocreate-prefunded-accountfrom
master
Aug 6, 2025
Merged

rebase#2
rustopian merged 364 commits intocreate-prefunded-accountfrom
master

Conversation

@rustopian
Copy link
Copy Markdown
Owner

No description provided.

puhtaytow and others added 30 commits July 16, 2025 00:50
)

- Ran cargo clippy with Rust 1.88.0 set in rust-toolchain.toml
- Ran cargo fmt with format_strings = true in rustfmt.toml
* increase max ingest

* fix tests
explicitly use vote state v3 everywhere
Bumps [systemstat](https://github.com/valpackett/systemstat) from 0.2.4 to 0.2.5.
- [Commits](valpackett/systemstat@v0.2.4...v0.2.5)

---
updated-dependencies:
- dependency-name: systemstat
  dependency-version: 0.2.5
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
* Resolve race condition in remove_dead_accounts
…#7003)

- Ran cargo clippy with Rust 1.88.0 set in rust-toolchain.toml
- Ran cargo fmt with format_strings = true in rustfmt.toml
…za-xyz#7002)

- Ran cargo clippy with Rust 1.88.0 set in rust-toolchain.toml
- Ran cargo fmt with format_strings = true in rustfmt.toml
…#7001)

- Ran cargo clippy with Rust 1.88.0 set in rust-toolchain.toml
- Ran cargo fmt with format_strings = true in rustfmt.toml
* convert benchmarks bencher 0.1.5
* add #[allow(clippy::arithmetic_side_effects)] on benches
* swap bloom bench to criterion
* remove obsolete cfg args
* allow arithmetics_side_effects for benches
…anza-xyz#6994)

Adds missing resize at loader-v1 deserialization if direct mapping is enabled.
Places MockCallerAccount at MM_INPUT_START.
…y checks are expensive (anza-xyz#7007)

* Use RWLock for shrink map as map should be small, and dashmap is empty checks are expensive

* Format

* Updating to use IntMap
roryharr and others added 24 commits August 4, 2025 19:25
…nza-xyz#7313)

* Removed sleep from test_submit_exceed_max_rate
* Changed test expectations to expect only 100 entries
* xdp: use AsRef for addresses too

This allows passing Arc<Vec<_>> when sending to a static list of peers.

* xdp: tx_loop: allow overriding MACs and IP

This is useful for sending via bonded NICs, skipping the bond device and
targeting the slaved NICs directly so they can be used in zero copy
mode.

Slaved NICs don't have an IP assigned to them, so the source IP can't be
discovered but must be passed explicitly (eg the bond IP).

Overriding MACs can be useful while testing to ensure frames don't leave
the switch/metro.
* fix test_get_slot_entries_with_shred_count_corruption
* fix test_merkle_root_metas_data
#### Problem

As outlined in anza-xyz#7256, we need to get Agave off of crates that depend
back on Agave.

spl-token-2022 is one of those crates

#### Summary of changes

Use spl-token-2022-interface instead. To go with this, we had to also
upgrade to confidential-transfer-proof-extract v0.4.0, which requires
modifications to some tests.

Everything should be very straightforward otherwise, and we get to see
some red lines in the lockfile!
#### Problem

After anza-xyz#7291 landed, anza-xyz#7298 didn't mention any conflicts. However, since
the first one migrated away from spl-memo, and so did anza-xyz#7298, there was
an entry not cleaned up between the two PRs.

#### Summary of changes

Remove the unneeded entry for spl-memo in all lockfiles.
* greedy_scheduler: cache Batches

This avoids a bunch of allocations/deallocations in the hot path

* banking: move Batches to SchedulingCommon

* banking: clean up send_batch(es)
* turbine: move standard_broadcast_run to non-overlapping ports

* turbine: move benchmark broadcast_shreds_bench to non-overlapping ports
)

Renaming UPSERT_POPULATE_RECLAIMS to UPSERT_RECLAIM_TEST_DEFAULT
* Renames bpf_account_data_direct_mapping => stricter_abi_and_runtime_constraints.

* Adds InvokeContext::account_data_direct_mapping.

* Separates stricter_abi_and_runtime_constraints from account_data_direct_mapping.

* Rekeys stricter_abi_and_runtime_constraints.

* Adjusts test_serialize_parameters_with_many_accounts().
* move cluster_info::Node to separate module
* update the use path in other files to refer to the new location
…x tests (anza-xyz#7312)

Changing tests to use u64 rather than bool for T during accounts index tests
spl-token dependency replaced with spl-token-interface.
@rustopian rustopian merged commit c2c327d into create-prefunded-account Aug 6, 2025
rustopian pushed a commit that referenced this pull request Oct 22, 2025
* Apply the retry code to the async pubsub client

Create a test server

```ts
import http from "http";

import { WebSocketServer } from "ws";

let attemptCount = 0;

const server = http.createServer();
const wss = new WebSocketServer({ noServer: true });

wss.on("connection", (ws) => {
  ws.send("Connection accepted.");
  ws.on("message", (msg) => console.log(`Received: ${msg}`));
});

server.on("upgrade", (req, socket, head) => {
  attemptCount += 1;

  if (attemptCount <= 4) {
    socket.write("HTTP/1.1 429 Too Many Requests\r\n\r\n");
    socket.destroy();
    console.log(`Rejected connection #${attemptCount} (429)`);
    return;
  }

  wss.handleUpgrade(req, socket, head, (ws) => {
    wss.emit("connection", ws, req);
    console.log("Connection accepted on attempt", attemptCount);
  });
});

server.listen(8080, () => {
  console.log("Server listening on port 8080");
});
```

Run `test_slot_subscription_async`:

```
Rejected connection #1 (429)
Rejected connection #2 (429)
Rejected connection #3 (429)
Rejected connection #4 (429)
Connection accepted on attempt 5
Received: {"id":1,"jsonrpc":"2.0","method":"slotSubscribe","params":[]}
```

* `s/async_with_retry/with_retry/`
rustopian added a commit that referenced this pull request Nov 20, 2025
# This is the 1st commit message:

Merge branch 'master' into nonblocking-rpc-for-cli
# The commit message #2 will be skipped:

# rm stray worker_threads
rustopian added a commit that referenced this pull request Nov 20, 2025
# This is the 1st commit message:

Merge branch 'master' into nonblocking-rpc-for-cli
# The commit message #2 will be skipped:

# clean up test-validator file
rustopian added a commit that referenced this pull request Nov 20, 2025
# This is the 1st commit message:

Merge branch 'master' into nonblocking-rpc-for-cli

# The commit message #2 will be skipped:

# fix conflicts typo
rustopian pushed a commit that referenced this pull request Nov 20, 2025
* Apply the retry code to the async pubsub client

Create a test server

```ts
import http from "http";

import { WebSocketServer } from "ws";

let attemptCount = 0;

const server = http.createServer();
const wss = new WebSocketServer({ noServer: true });

wss.on("connection", (ws) => {
  ws.send("Connection accepted.");
  ws.on("message", (msg) => console.log(`Received: ${msg}`));
});

server.on("upgrade", (req, socket, head) => {
  attemptCount += 1;

  if (attemptCount <= 4) {
    socket.write("HTTP/1.1 429 Too Many Requests\r\n\r\n");
    socket.destroy();
    console.log(`Rejected connection #${attemptCount} (429)`);
    return;
  }

  wss.handleUpgrade(req, socket, head, (ws) => {
    wss.emit("connection", ws, req);
    console.log("Connection accepted on attempt", attemptCount);
  });
});

server.listen(8080, () => {
  console.log("Server listening on port 8080");
});
```

Run `test_slot_subscription_async`:

```
Rejected connection #1 (429)
Rejected connection #2 (429)
Rejected connection #3 (429)
Rejected connection #4 (429)
Connection accepted on attempt 5
Received: {"id":1,"jsonrpc":"2.0","method":"slotSubscribe","params":[]}
```

* `s/async_with_retry/with_retry/`
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.