zishuo/libagent
1
0
Fork 0
mirror of https://github.com/jkstack/libagent.git synced 2025-12-24 12:11:57 +08:00
Code Issues Packages Projects Releases Wiki Activity

修改log内容

Browse Source
This commit is contained in:
lwch
2022-08-03 17:04:25 +08:00
parent 4d49e927e1
commit b341340474
2 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
limit/cgroups_v1.go
View File

@@ -89,22 +89,22 @@ func limitDiskV1(group cgroups.Cgroup, limits diskLimits) {
} }
if disk.ReadBytes > 0 { if disk.ReadBytes > 0 {
block.ThrottleReadBpsDevice = write(disk.ReadBytes, block.ThrottleReadBpsDevice) block.ThrottleReadBpsDevice = write(disk.ReadBytes, block.ThrottleReadBpsDevice)
logging.Info(" - set read_bytes limit by mount_point %s: %s", logging.Info(" - set read_bytes limit by dev [%s]: %s",
disk.Dev, humanize.IBytes(disk.ReadBytes)) disk.Dev, humanize.IBytes(disk.ReadBytes))
} }
if disk.WriteBytes > 0 { if disk.WriteBytes > 0 {
block.ThrottleWriteBpsDevice = write(disk.WriteBytes, block.ThrottleWriteBpsDevice) block.ThrottleWriteBpsDevice = write(disk.WriteBytes, block.ThrottleWriteBpsDevice)
logging.Info(" - set write_bytes limit by mount_point %s: %s", logging.Info(" - set write_bytes limit by dev [%s]: %s",
disk.Dev, humanize.IBytes(disk.WriteBytes)) disk.Dev, humanize.IBytes(disk.WriteBytes))
} }
if disk.ReadIOPS > 0 { if disk.ReadIOPS > 0 {
block.ThrottleReadIOPSDevice = write(disk.ReadIOPS, block.ThrottleReadIOPSDevice) block.ThrottleReadIOPSDevice = write(disk.ReadIOPS, block.ThrottleReadIOPSDevice)
logging.Info(" - set read_iops limit by mount_point %s: %s", logging.Info(" - set read_iops limit by dev [%s]: %s",
disk.Dev, humanize.IBytes(disk.ReadIOPS)) disk.Dev, humanize.IBytes(disk.ReadIOPS))
} }
if disk.WriteIOPS > 0 { if disk.WriteIOPS > 0 {
block.ThrottleWriteIOPSDevice = write(disk.WriteIOPS, block.ThrottleWriteIOPSDevice) block.ThrottleWriteIOPSDevice = write(disk.WriteIOPS, block.ThrottleWriteIOPSDevice)
logging.Info(" - set write_iops limit by mount_point %s: %s", logging.Info(" - set write_iops limit by dev [%s]: %s",
disk.Dev, humanize.IBytes(disk.WriteIOPS)) disk.Dev, humanize.IBytes(disk.WriteIOPS))
} }
} }

8
limit/cgroups_v2.go
View File

@@ -71,22 +71,22 @@ func limitDiskV2(group *v2.Manager, limits diskLimits) {
} }
if disk.ReadBytes > 0 { if disk.ReadBytes > 0 {
write(v2.ReadBPS, disk.ReadBytes) write(v2.ReadBPS, disk.ReadBytes)
logging.Info(" - set read_bytes limit by mount_point %s: %s", logging.Info(" - set read_bytes limit by dev [%s]: %s",
disk.Dev, humanize.IBytes(disk.ReadBytes)) disk.Dev, humanize.IBytes(disk.ReadBytes))
} }
if disk.WriteBytes > 0 { if disk.WriteBytes > 0 {
write(v2.WriteBPS, disk.WriteBytes) write(v2.WriteBPS, disk.WriteBytes)
logging.Info(" - set write_bytes limit by mount_point %s: %s", logging.Info(" - set write_bytes limit by dev [%s]: %s",
disk.Dev, humanize.IBytes(disk.WriteBytes)) disk.Dev, humanize.IBytes(disk.WriteBytes))
} }
if disk.ReadIOPS > 0 { if disk.ReadIOPS > 0 {
write(v2.ReadIOPS, disk.ReadIOPS) write(v2.ReadIOPS, disk.ReadIOPS)
logging.Info(" - set read_iops limit by mount_point %s: %s", logging.Info(" - set read_iops limit by dev [%s]: %s",
disk.Dev, humanize.IBytes(disk.ReadIOPS)) disk.Dev, humanize.IBytes(disk.ReadIOPS))
} }
if disk.WriteIOPS > 0 { if disk.WriteIOPS > 0 {
write(v2.WriteIOPS, disk.WriteIOPS) write(v2.WriteIOPS, disk.WriteIOPS)
logging.Info(" - set write_iops limit by mount_point %s: %s", logging.Info(" - set write_iops limit by dev [%s]: %s",
disk.Dev, humanize.IBytes(disk.WriteIOPS)) disk.Dev, humanize.IBytes(disk.WriteIOPS))
} }
} }