Skip to content
This repository was archived by the owner on Jul 3, 2020. It is now read-only.

Commit f854db6

Browse files
committed
[block] Minor code style fixes
1 parent 606ffcf commit f854db6

File tree

4 files changed

+26
-15
lines changed

4 files changed

+26
-15
lines changed

js/core/block/block-device-interface.js

+19-6
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,12 @@
1414

1515
'use strict';
1616

17+
const typeutils = require('typeutils');
18+
1719
const busHandle = Symbol('bus');
1820
const formatInfoHandle = Symbol('formatInfo');
21+
const nameHandle = Symbol('name');
22+
const setNameHandle = Symbol('setName');
1923

2024
class BlockDeviceInterface {
2125
constructor(bus = '', init = {}) {
@@ -24,24 +28,30 @@ class BlockDeviceInterface {
2428
this.onread = null;
2529
this.onwrite = null;
2630
this.ongetonline = null;
27-
if (typeof init === 'object' && init !== null) {
28-
if (typeof init.read === 'function') {
31+
if (typeutils.isObject(init)) {
32+
if (typeutils.isFunction(init.read)) {
2933
this.onread = init.read;
3034
}
31-
if (typeof init.write === 'function') {
35+
if (typeutils.isFunction(init.write)) {
3236
this.write = init.write;
3337
}
34-
if (typeof init.formatInfo === 'object') {
38+
if (typeutils.isObject(init.formatInfo)) {
3539
this[formatInfoHandle] = init.formatInfo;
3640
}
37-
if (typeof init.isOnline === 'function') {
41+
if (typeutils.isFunction(init.isOnline)) {
3842
this.ongetonline = init.isOnline;
3943
}
4044
}
4145
}
46+
get name() {
47+
return this[nameHandle];
48+
}
4249
get bus() {
4350
return this[busHandle];
4451
}
52+
[setNameHandle](newName) {
53+
this[nameHandle] = newName;
54+
}
4555
read(sector, u8) {
4656
if (!this.onread) {
4757
throw new Error('driver was not initialized');
@@ -65,4 +75,7 @@ class BlockDeviceInterface {
6575
}
6676
}
6777

68-
module.exports = BlockDeviceInterface;
78+
module.exports = {
79+
BlockDeviceInterface,
80+
setNameHandle,
81+
};

js/core/block/devices.js

+3-5
Original file line numberDiff line numberDiff line change
@@ -13,18 +13,16 @@
1313
// limitations under the License.
1414

1515
'use strict';
16+
17+
const { setNameHandle } = require('./block-device-interface');
1618
const availableBuses = Object.create(null); // not using a Map because the buses should be easy to access directly
1719
const availableDevices = [];
1820

1921
module.exports = {
2022
registerDevice(device) {
2123
if (!availableBuses[device.bus]) availableBuses[device.bus] = [];
2224
const i = availableDevices.push(device) - 1;
23-
Object.assign(device, {
24-
get name() {
25-
return `${device.bus}${i}`;
26-
},
27-
});
25+
device[setNameHandle](`${device.bus}${i}`);
2826
availableBuses[device.bus].push(device);
2927

3028
console.log(`[block] registered block device ${device.name}`);

js/core/block/index.js

+2-2
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
// limitations under the License.
1414

1515
'use strict';
16-
const BlockDeviceInterface = require('./block-device-interface');
16+
const { BlockDeviceInterface } = require('./block-device-interface');
1717
const { registerDevice, getDevices, getBuses } = require('./devices');
1818

1919
module.exports = {
@@ -24,5 +24,5 @@ module.exports = {
2424
},
2525
get buses() {
2626
return getBuses();
27-
}
27+
},
2828
};

js/driver/virtio/blk.js

+2-2
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ function initializeBlockDevice(pciDevice) {
8181
}
8282
const status = new Uint8Array(1);
8383
promiseQueue.push([resolve, reject, VIRTIO_BLK_T_IN, data, status]);
84-
reqQueue.placeBuffers([buildHeader(VIRTIO_BLK_T_IN, sector), data, status], null, [false, true, true]);
84+
reqQueue.placeBuffers([buildHeader(VIRTIO_BLK_T_IN, sector), data, status], false, [false, true, true]);
8585

8686
if (reqQueue.isNotificationNeeded()) {
8787
dev.queueNotify(QUEUE_ID_REQ);
@@ -92,7 +92,7 @@ function initializeBlockDevice(pciDevice) {
9292
return new Promise((resolve, reject) => {
9393
const status = new Uint8Array(1);
9494
promiseQueue.push([resolve, reject, VIRTIO_BLK_T_OUT, data, status]);
95-
reqQueue.placeBuffers([buildHeader(VIRTIO_BLK_T_OUT, sector), data, status], null, [false, false, true]);
95+
reqQueue.placeBuffers([buildHeader(VIRTIO_BLK_T_OUT, sector), data, status], false, [false, false, true]);
9696

9797
if (reqQueue.isNotificationNeeded()) {
9898
dev.queueNotify(QUEUE_ID_REQ);

0 commit comments

Comments
 (0)