View Javadoc

1   /*
2    * Licensed to the Apache Software Foundation (ASF) under one
3    * or more contributor license agreements.  See the NOTICE file
4    * distributed with this work for additional information
5    * regarding copyright ownership.  The ASF licenses this file
6    * to you under the Apache License, Version 2.0 (the
7    * "License"); you may not use this file except in compliance
8    * with the License.  You may obtain a copy of the License at
9    *
10   *   http://www.apache.org/licenses/LICENSE-2.0
11   *
12   * Unless required by applicable law or agreed to in writing, software
13   * distributed under the License is distributed on an "AS IS" BASIS,
14   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15   * See the License for the specific language governing permissions and
16   * limitations under the License.
17   */
18  package org.apache.omid.tso.client;
19  
20  import org.apache.omid.tso.ProgrammableTSOServer;
21  import org.apache.omid.tso.ProgrammableTSOServer.AbortResponse;
22  import org.apache.omid.tso.ProgrammableTSOServer.CommitResponse;
23  import org.apache.omid.tso.ProgrammableTSOServer.TimestampResponse;
24  import org.testng.annotations.BeforeClass;
25  import org.testng.annotations.BeforeMethod;
26  import org.testng.annotations.Test;
27  
28  import java.io.IOException;
29  import java.util.Collections;
30  import java.util.concurrent.ExecutionException;
31  
32  import static org.testng.Assert.assertEquals;
33  
34  public class TestTSOClientResponseHandling {
35  
36      private static final int TSO_PORT = 4321;
37      private static final long START_TS = 1L;
38      private static final long COMMIT_TS = 2L;
39  
40      private ProgrammableTSOServer tsoServer = new ProgrammableTSOServer(TSO_PORT);
41      // Client under test
42      private TSOClient tsoClient;
43  
44      @BeforeClass
45      public void configureAndCreateClient() throws IOException, InterruptedException {
46  
47          OmidClientConfiguration tsoClientConf = new OmidClientConfiguration();
48          tsoClientConf.setConnectionString("localhost:" + TSO_PORT);
49          tsoClient = TSOClient.newInstance(tsoClientConf);
50      }
51  
52      @BeforeMethod
53      public void reset() {
54          tsoServer.cleanResponses();
55      }
56  
57      @Test
58      public void testTimestampRequestReceivingASuccessfulResponse() throws Exception {
59          // test request timestamp response returns a timestamp
60  
61          // Program the TSO to return an ad-hoc Timestamp response
62          tsoServer.queueResponse(new TimestampResponse(START_TS));
63  
64          long startTS = tsoClient.getNewStartTimestamp().get();
65          assertEquals(startTS, START_TS);
66      }
67  
68      @Test
69      public void testCommitRequestReceivingAnAbortResponse() throws Exception {
70          // test commit request which is aborted on the server side
71          // (e.g. due to conflicts with other transaction) throws an
72          // execution exception with an AbortException as a cause
73  
74          // Program the TSO to return an Abort response
75          tsoServer.queueResponse(new AbortResponse(START_TS));
76  
77          try {
78              tsoClient.commit(START_TS, Collections.<CellId>emptySet()).get();
79          } catch (ExecutionException ee) {
80              assertEquals(ee.getCause().getClass(), AbortException.class);
81          }
82      }
83  
84      @Test
85      public void testCommitRequestReceivingASuccessfulResponse() throws Exception {
86          // test commit request which is successfully committed on the server
87          // side returns a commit timestamp
88  
89          // Program the TSO to return an Commit response (with no required heuristic actions)
90          tsoServer.queueResponse(new CommitResponse(START_TS, COMMIT_TS));
91  
92          long commitTS = tsoClient.commit(START_TS, Collections.<CellId>emptySet()).get();
93          assertEquals(commitTS, COMMIT_TS);
94      }
95  
96  }