Add and enable a new timed event with the factory. The even will be triggered for the first time after period time, and henceforth triggered every per

* Shuffles an array using Fisher-Yates algorithm * @param {Array} array - Array to shuffle * @returns {Array} - Shuffled array

Issue a set command on the interface

* Pipes remote socket data to WebSocket. * @param {Socket} remoteSocket * @param {WebSocket} webSocket * @param {string | Uint8Array | ArrayBuffer

Get the (unquoted) root path, plus the header the info came from. If no info available, returns ``(None, None)``

Apply delete logic to database info. :returns: True if the DB is considered to be deleted, False otherwise

Load the root container name and account for the container represented by this broker. The root container path, if set, is s

Add the x_container_sync_point columns to the 'container_stat' table.

If the request indicates that it can accept a redirection, look for a shard range that contains ``obj_name`` and if one exists return

Update the account server(s) with latest container info. :param req: swob.Request object :param account: account name

Compute and append mac1 and mac2 to a handshake message

* Checks if a given UUID is present in the API response. * @param {string} targetUuid The UUID to search for. * @returns {Promise<boolean>} A Promis

We don't really clear the timers, but we set them to the current time to so the reference time frame is the same

Check if container DB is empty. This method uses more stringent checks on object count than :meth:`is_deleted`: this method

Fetch multiple pages from the Telegram channel

src - an IP packet from the interface dst - pre-allocated space to hold the encapsulating UDP packet to send over the network returns the size of the

Split and validate path for a container. :param req: a swob request :returns: a tuple of path parts as strings

Get the is_deleted status and info for the container. :returns: a tuple, in the form (info, is_deleted) info is a dict as

Get the aggregate object stats for all shard ranges in states ACTIVE, SHARDING or SHRINKING. :return: a dict with keys {byte

Returns sharding specific info from the broker's metadata. :param key: if given the value stored under ``key`` in the sharding

* * @param {ArrayBuffer} udpChunk * @param {import("@cloudflare/workers-types").WebSocket} webSocket * @param {ArrayBuffer} vlessResponseHeader *

* @param {Request} request * @param {string} core * @param {any} userID * @param {string} hostName

The index used is 24 bits for peer index, allowing for 16M active peers per server and 8 bits for cyclic session index

* This is not real UUID validation * @param {string} uuid

* This is not real UUID validation * @param {string} uuid

Get a list of objects sorted by name starting at marker onward, up to limit entries. Entries will begin with the prefix and will not

Reads the command line arguments into an Opts struct and merge values found within the user configuration file.

Compares ``shard_data`` with ``existing`` and updates ``shard_data`` with any items of ``existing`` that take precedence over the correspondi

Get the current MTU value

Add and enable a new notification event with the factory. The event can only be triggered manually, using the trigger_notification method. The event w

Add and enable a new signal handler

Convert a utf16 offset into a utf8 offset, if possible `char_indices` is an iterator over utf8 offsets and the characters It is cloneable so that it c

Convert a utf8 offset into a utf16 offset, if possible

Given a string, parse it as a host, IP address, or CIDR. This allows us to pass files as hosts or cidr or IPs easily Call this every time you have a

On Darwin tunnel can only be named utunXXX

Creates an object in the DB with its metadata. :param name: object name to be created :param timestamp: timestamp of when th

* * @param {import("@cloudflare/workers-types").Socket} remoteSocket * @param {import("@cloudflare/workers-types").WebSocket} webSocket * @param {A

* * @param {import("@cloudflare/workers-types").Socket} remoteSocket * @param {import("@cloudflare/workers-types").WebSocket} webSocket * @param

Reset packet count (ideally should be called with a period of 1 second)

Uses DNS to get the IPS associated with host

Update the index of the currently used session, if needed

Set the mark on all packets sent by this socket using SO_MARK Only available on Linux

Sets up logging to a new file in `CACHE_DIR/UAD`_{time}.log Also attaches the terminal on Windows machines ''' match `setup_logger().expect("Error` se

Returns True if a broker has shard range state that would be necessary for sharding to have been initiated, False otherwise.

Calls shutdown on a connected socket. This will trigger an EOF in the event queue.

* SOCKS5 TCP connection logic. * @param {any} addressType * @param {string} addressRemote * @param {number} portRemote * @param {any} log * @para

Return stats from the tunnel: Time since last handshake in seconds Data bytes sent Data bytes received