mirror of
https://github.com/upa/mscp.git
synced 2026-02-14 17:24:42 +08:00
29 lines
762 B
C
29 lines
762 B
C
/* SPDX-License-Identifier: GPL-3.0-only */
|
|
#ifndef _BWLIMIT_H_
|
|
#define _BWLIMIT_H_
|
|
|
|
#include <stdbool.h>
|
|
#include <stdint.h>
|
|
#include <sys/types.h>
|
|
#include <time.h>
|
|
#include <semaphore.h>
|
|
|
|
struct bwlimit {
|
|
sem_t *sem; /* semaphore */
|
|
size_t bps; /* limit bit-rate (bps) */
|
|
size_t win; /* window size (msec) */
|
|
size_t amt; /* amount of bytes can be sent in a window */
|
|
|
|
ssize_t credit; /* remaining bytes can be sent in a window */
|
|
struct timespec wstart, wend; /* window start time and end time */
|
|
};
|
|
|
|
int bwlimit_init(struct bwlimit *bw, uint64_t bps, uint64_t win);
|
|
/* if bps is 0, it means that bwlimit is not active. If so,
|
|
* bwlimit_wait() returns immediately. */
|
|
|
|
int bwlimit_wait(struct bwlimit *bw, size_t nr_bytes);
|
|
|
|
|
|
#endif /* _BWLIMIT_H_ */
|