Skip to content
Snippets Groups Projects
Verified Commit 27f8a4eb authored by Timm Fitschen's avatar Timm Fitschen
Browse files

DOC: add more doc strings

parent ab08dc9b
Branches
Tags
3 merge requests!44Release 0.6,!43Merge f-GRPC-main to dev,!35F grpc f mixed write transactions
Pipeline #14161 passed
...@@ -470,6 +470,13 @@ public class EntityTransactionServiceImpl extends EntityTransactionServiceImplBa ...@@ -470,6 +470,13 @@ public class EntityTransactionServiceImpl extends EntityTransactionServiceImplBa
return Integer.parseInt(id); return Integer.parseInt(id);
} }
/**
* Handle read-only transactions.
*
* @param request
* @return
* @throws Exception
*/
public MultiTransactionResponse retrieve(final MultiTransactionRequest request) throws Exception { public MultiTransactionResponse retrieve(final MultiTransactionRequest request) throws Exception {
final MultiTransactionResponse.Builder builder = MultiTransactionResponse.newBuilder(); final MultiTransactionResponse.Builder builder = MultiTransactionResponse.newBuilder();
final RetrieveContainer container = final RetrieveContainer container =
...@@ -570,14 +577,25 @@ public class EntityTransactionServiceImpl extends EntityTransactionServiceImplBa ...@@ -570,14 +577,25 @@ public class EntityTransactionServiceImpl extends EntityTransactionServiceImplBa
return System.currentTimeMillis(); return System.currentTimeMillis();
} }
/**
* Handle all entity transactions.
*
* @param request
* @return
* @throws Exception
*/
public MultiTransactionResponse transaction(final MultiTransactionRequest request) public MultiTransactionResponse transaction(final MultiTransactionRequest request)
throws Exception { throws Exception {
if (request.getRequestsCount() > 0) { if (request.getRequestsCount() > 0) {
// we only test the first request and raise errors when subsequent sub-transactions do not
// fit.
final WrappedRequestsCase requestCase = request.getRequests(0).getWrappedRequestsCase(); final WrappedRequestsCase requestCase = request.getRequests(0).getWrappedRequestsCase();
switch (requestCase) { switch (requestCase) {
case RETRIEVE_REQUEST: case RETRIEVE_REQUEST:
// Handle read-only transactions.
return retrieve(request); return retrieve(request);
default: default:
// Handle mixed-writed transactions.
return write(request); return write(request);
} }
} else { } else {
...@@ -586,6 +604,13 @@ public class EntityTransactionServiceImpl extends EntityTransactionServiceImplBa ...@@ -586,6 +604,13 @@ public class EntityTransactionServiceImpl extends EntityTransactionServiceImplBa
} }
} }
/**
* Handle mixed-write transactions.
*
* @param requests
* @return
* @throws Exception
*/
private MultiTransactionResponse write(final MultiTransactionRequest requests) throws Exception { private MultiTransactionResponse write(final MultiTransactionRequest requests) throws Exception {
final MultiTransactionResponse.Builder builder = MultiTransactionResponse.newBuilder(); final MultiTransactionResponse.Builder builder = MultiTransactionResponse.newBuilder();
final WritableContainer container = final WritableContainer container =
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment