Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
79 changes: 51 additions & 28 deletions CPUMeter.c
Original file line number Diff line number Diff line change
Expand Up @@ -233,7 +233,7 @@ static void CPUMeter_display(const Object* cast, RichString* out) {
#endif
}

static void AllCPUsMeter_getRange(const Meter* this, int* start, int* count) {
static void AllCPUsMeter_getRange(const Meter* this, unsigned int* start, unsigned int* count) {
unsigned int cpus = this->host->existingCPUs;
switch (Meter_name(this)[0]) {
default:
Expand All @@ -252,47 +252,71 @@ static void AllCPUsMeter_getRange(const Meter* this, int* start, int* count) {
}
}

static void AllCPUsMeter_updateValues(Meter* this) {
CPUMeterData* data = this->meterData;
Meter** meters = data->meters;
int start, count;
AllCPUsMeter_getRange(this, &start, &count);
for (int i = 0; i < count; i++)
Meter_updateValues(meters[i]);
}

static void CPUMeterCommonInit(Meter* this) {
int start, count;
unsigned int start, count, prevCount;
AllCPUsMeter_getRange(this, &start, &count);

CPUMeterData* data = this->meterData;
if (!data) {
data = xCalloc(1, sizeof(CPUMeterData));
data->cpus = this->host->existingCPUs;
data->meters = count ? xCalloc(count, sizeof(Meter*)) : NULL;
data->cpus = 0; /* no meters allocated yet */
data->meters = NULL;
this->meterData = data;
}

prevCount = data->cpus;

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The declaration of prevCount should be moved back here. There's no use of prevCount before this line.

if (count != prevCount) {
/* free meters for CPUs that are no longer in range */
for (unsigned int i = count; i < prevCount; i++)
Meter_delete((Object*)data->meters[i]);

if (count > 0) {
data->meters = xReallocArray(data->meters, count, sizeof(Meter*));
/* zero-fill newly added entries */
if (count > prevCount)
memset(data->meters + prevCount, 0, (count - prevCount) * sizeof(Meter*));
} else {
free(data->meters);
data->meters = NULL;
}
data->cpus = count;
}

Meter** meters = data->meters;
for (int i = 0; i < count; i++) {
for (unsigned int i = 0; i < count; i++) {
if (!meters[i])
meters[i] = Meter_new(this->host, start + i + 1, (const MeterClass*) Class(CPUMeter));

Meter_init(meters[i]);
}
}

static void CPUMeterCommonUpdateMode(Meter* this, MeterModeId mode, int ncol) {
static void AllCPUsMeter_updateValues(Meter* this) {
CPUMeterData* data = this->meterData;
unsigned int start, count;
AllCPUsMeter_getRange(this, &start, &count);
/* Reinit if the number of CPUs changed (e.g. hot-plug) */
if (count != data->cpus)
CPUMeterCommonInit(this);
Comment thread
coderabbitai[bot] marked this conversation as resolved.
data = this->meterData;
Meter** meters = data->meters;
for (unsigned int i = 0; i < count; i++)
Meter_updateValues(meters[i]);
}

static void CPUMeterCommonUpdateMode(Meter* this, MeterModeId mode, unsigned int ncol) {
/* Reinit first in case the CPU count changed since last init */
CPUMeterCommonInit(this);
CPUMeterData* data = this->meterData;
Meter** meters = data->meters;
this->mode = mode;
int start, count;
unsigned int start, count;
AllCPUsMeter_getRange(this, &start, &count);
if (!count) {
this->h = 1;
return;
}
for (int i = 0; i < count; i++) {
for (unsigned int i = 0; i < count; i++) {
Meter_setMode(meters[i], mode);
}
int h = meters[0]->h;
Expand All @@ -303,9 +327,7 @@ static void CPUMeterCommonUpdateMode(Meter* this, MeterModeId mode, int ncol) {
static void AllCPUsMeter_done(Meter* this) {
CPUMeterData* data = this->meterData;
Meter** meters = data->meters;
int start, count;
AllCPUsMeter_getRange(this, &start, &count);
for (int i = 0; i < count; i++)
for (unsigned int i = 0; i < data->cpus; i++)
Meter_delete((Object*)meters[i]);
free(data->meters);
free(data);
Expand All @@ -327,17 +349,18 @@ static void OctoColCPUsMeter_updateMode(Meter* this, MeterModeId mode) {
CPUMeterCommonUpdateMode(this, mode, 8);
}

static void CPUMeterCommonDraw(Meter* this, int x, int y, int w, int ncol) {
static void CPUMeterCommonDraw(Meter* this, int x, int y, int w, unsigned int ncol) {
CPUMeterData* data = this->meterData;
Meter** meters = data->meters;
int start, count;
unsigned int start, count;
AllCPUsMeter_getRange(this, &start, &count);
int colwidth = w / ncol;
int diff = w % ncol;
int nrows = (count + ncol - 1) / ncol;
for (int i = 0; i < count; i++) {
int d = (i / nrows) > diff ? diff : (i / nrows); // dynamic spacer
int xpos = x + ((i / nrows) * colwidth) + d;
unsigned int nrows = (count + ncol - 1) / ncol;
for (unsigned int i = 0; i < count; i++) {
int col = i / nrows;

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

There's an implicit cast from unsigned int to int here.

int d = col > diff ? diff : col; // dynamic spacer
int xpos = x + (col * colwidth) + d;
int ypos = y + ((i % nrows) * meters[0]->h);
meters[i]->draw(meters[i], xpos, ypos, colwidth);
}
Expand All @@ -359,9 +382,9 @@ static void OctoColCPUsMeter_draw(Meter* this, int x, int y, int w) {
static void SingleColCPUsMeter_draw(Meter* this, int x, int y, int w) {
CPUMeterData* data = this->meterData;
Meter** meters = data->meters;
int start, count;
unsigned int start, count;
AllCPUsMeter_getRange(this, &start, &count);
for (int i = 0; i < count; i++) {
for (unsigned int i = 0; i < count; i++) {
meters[i]->draw(meters[i], x, y, w);
y += meters[i]->h;
}
Expand Down
Loading