Sébastien
0775d05a23
fix: http range request return status 500 ( #5251 )
When volume server unavailable for at least one chunk; was returning status 206.
Split `StreamContent` in two parts,
- first prepare, to get chunk info and return stream function
- then write chunk, with that stream function
That allow to catch error in first step before setting response status code in `processRangeRequest`
11 months ago
chrislu
0b2e5ddc7c
wait 3 seconds before shutting down publish client, to wait for all messages to be received
11 months ago
chrislu
545d5fbdf6
unused code
11 months ago
chrislu
a507069d19
lock for creating local partition
11 months ago
chrislu
9e6ea80dff
read existing topic conf
11 months ago
chrislu
a297247137
wait for each publish clients
11 months ago
chrislu
b6c5e57c30
read will block if no items
11 months ago
chrislu
0bf5424a2e
adjust visibility
11 months ago
chrislu
dedfd31dfb
refactor
11 months ago
chrislu
cbf750a31f
refactor
11 months ago
chrislu
b51dfe2bff
wait for publishing clients
11 months ago
chrislu
f8c55f101e
clean up
11 months ago
chrislu
d40225ecd2
return the lookup results
11 months ago
chrislu
841fafd0a8
publish to input buffer
currently, the input buffer may not exist when start to publish
11 months ago
chrislu
5dc1362bdc
close the input
11 months ago
chrislu
fa835c9319
Update buffered_queue_test.go
11 months ago
Chris Lu
b6de35cdb2
moved. there are some deadlock. WIP
11 months ago
chrislu
91af1f3069
schedule jobs
11 months ago
Benoît Knecht
f6e39139d8
weed/storage: Fix volume info file permissions ( #5246 )
11 months ago
chrislu
08c5fba825
adds a buffered queue
11 months ago
chrislu
cb50b720fd
Revert "Fix weed fix"
This reverts commit 6c1ce18541
.
11 months ago
Benoît Knecht
1f08010ef0
weed/shell: Cleanup volume balance logic ( #5241 )
11 months ago
Konstantin Lebedev
0f8e76bbd6
fix: clean metric MasterReplicaPlacementMismatch for unregister volume ( #5239 )
11 months ago
Benoît Knecht
a6aee847b9
weed/shell: Fix volume.balance logic ( #5238 )
11 months ago
Konstantin Lebedev
0b71fae2e3
fix: s3tests test_get_object_ifnonematch_good ( #5237 )
11 months ago
chrislu
025f8eb37b
return dir assign counter
fix https://github.com/seaweedfs/seaweedfs/issues/5231
11 months ago
chrislu
d4e66cc140
return dir assign counter
fix https://github.com/seaweedfs/seaweedfs/issues/5231
11 months ago
chrislu
49fcb48e04
same logic as grpc assign
fix https://github.com/seaweedfs/seaweedfs/issues/5213
11 months ago
chrislu
d268fbe18a
when configure, cancel existing assignments
11 months ago
chrislu
3ff6b31d94
sub broker wait for partition
11 months ago
chrislu
2beaa2d0b3
pub/sub brokers check filer for assigned partitions
11 months ago
chrislu
c3f8530f97
refactor
11 months ago
chrislu
5f35857cd0
no need to assign partitions explicitly
11 months ago
chrislu
428fea45f3
updated and added assignments
11 months ago
chrislu
e8b05ecc91
add/remove assigned partitions
11 months ago
chrislu
861ad732ca
refactor
11 months ago
chrislu
47924afa1c
refactor
11 months ago
chrislu
581cf6644c
lookup reads from filer instead of local memory
11 months ago
chrislu
7121ae9617
separate out read topic conf and ensure topic active assignments
11 months ago
chrislu
c77d35313e
pub/sub broker only check local assigned partitions
11 months ago
chrislu
b0a2e9aea3
fix assignments if brokers changed
11 months ago
chrislu
9ce7c482b3
refactor
11 months ago
chrislu
a5b906c0dd
refactor
11 months ago
chrislu
34839237ab
refactor
11 months ago
chrislu
2828ccbb30
refactor
11 months ago
chrislu
541140f735
rename
11 months ago
chrislu
bb867694d8
skip updating multipart .upload files
11 months ago
chrislu
4ca6b1be3c
skip updating the .upload multipart files
11 months ago
chrislu
d848efed1b
skip updating multipart .upload files
11 months ago
chrislu
aca3c33bab
skip updating the .upload multipart files
11 months ago