Skip to content
GitLab
Menu
Projects
Groups
Snippets
/
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
Menu
Open sidebar
dCache
cta
Commits
100d3ce8
Commit
100d3ce8
authored
Sep 10, 2018
by
Eric Cano
Browse files
Renamed repacktape to repackrequest in protobuf.
parent
7b25c191
Changes
2
Hide whitespace changes
Inline
Side-by-side
objectstore/RepackIndex.cpp
View file @
100d3ce8
...
...
@@ -82,7 +82,7 @@ void RepackIndex::garbageCollect(const std::string &presumedOwner, AgentReferenc
//------------------------------------------------------------------------------
std
::
string
RepackIndex
::
getRepackRequestAddress
(
const
std
::
string
&
vid
)
{
checkPayloadReadable
();
for
(
auto
&
rt
:
m_payload
.
repack
tape
pointers
())
{
for
(
auto
&
rt
:
m_payload
.
repack
request
pointers
())
{
if
(
rt
.
vid
()
==
vid
)
return
rt
.
address
();
}
...
...
@@ -96,7 +96,7 @@ std::string RepackIndex::getRepackRequestAddress(const std::string& vid) {
std
::
list
<
RepackIndex
::
RepackRequestAddress
>
RepackIndex
::
getRepackRequestsAddresses
()
{
checkHeaderReadable
();
std
::
list
<
RepackRequestAddress
>
ret
;
for
(
auto
&
rt
:
m_payload
.
repack
tape
pointers
())
{
for
(
auto
&
rt
:
m_payload
.
repack
request
pointers
())
{
ret
.
push_back
(
RepackRequestAddress
());
ret
.
back
().
driveStateAddress
=
rt
.
address
();
ret
.
back
().
vid
=
rt
.
vid
();
...
...
@@ -109,7 +109,7 @@ std::list<RepackIndex::RepackRequestAddress> RepackIndex::getRepackRequestsAddre
//------------------------------------------------------------------------------
bool
RepackIndex
::
isEmpty
()
{
checkPayloadReadable
();
return
m_payload
.
repack
tape
pointers
().
empty
();
return
m_payload
.
repack
request
pointers
().
empty
();
}
//------------------------------------------------------------------------------
...
...
@@ -118,10 +118,10 @@ bool RepackIndex::isEmpty() {
void
RepackIndex
::
removeRepackRequest
(
const
std
::
string
&
vid
)
{
checkPayloadWritable
();
bool
found
=
false
;
auto
vidToRemove
=
m_payload
.
mutable_repack
tape
pointers
()
->
begin
();
while
(
vidToRemove
!=
m_payload
.
mutable_repack
tape
pointers
()
->
end
())
{
auto
vidToRemove
=
m_payload
.
mutable_repack
request
pointers
()
->
begin
();
while
(
vidToRemove
!=
m_payload
.
mutable_repack
request
pointers
()
->
end
())
{
if
(
vidToRemove
->
vid
()
==
vid
)
{
vidToRemove
=
m_payload
.
mutable_repack
tape
pointers
()
->
erase
(
vidToRemove
);
vidToRemove
=
m_payload
.
mutable_repack
request
pointers
()
->
erase
(
vidToRemove
);
found
=
true
;
}
else
{
vidToRemove
++
;
...
...
@@ -140,13 +140,13 @@ void RepackIndex::removeRepackRequest(const std::string& vid) {
void
RepackIndex
::
addRepackRequestAddress
(
const
std
::
string
&
vid
,
const
std
::
string
&
repackTapeAddress
)
{
checkPayloadWritable
();
for
(
int
i
=
0
;
i
<
m_payload
.
mutable_repack
tape
pointers
()
->
size
();
i
++
)
{
auto
rt
=
m_payload
.
mutable_repack
tape
pointers
(
i
);
for
(
int
i
=
0
;
i
<
m_payload
.
mutable_repack
request
pointers
()
->
size
();
i
++
)
{
auto
rt
=
m_payload
.
mutable_repack
request
pointers
(
i
);
if
(
rt
->
vid
()
==
vid
)
{
throw
VidAlreadyRegistered
(
"In RepackIndex::addRepackRequestAddress(): VID already has a repack request."
);
}
}
auto
rt
=
m_payload
.
mutable_repack
tape
pointers
()
->
Add
();
auto
rt
=
m_payload
.
mutable_repack
request
pointers
()
->
Add
();
rt
->
set_vid
(
vid
);
rt
->
set_address
(
repackTapeAddress
);
return
;
...
...
objectstore/cta.proto
View file @
100d3ce8
...
...
@@ -465,5 +465,5 @@ message RepackRequestPointer {
}
message
RepackIndex
{
repeated
RepackRequestPointer
repack
tape
pointers
=
12100
;
repeated
RepackRequestPointer
repack
request
pointers
=
12100
;
}
Write
Preview
Supports
Markdown
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment