ax.antpick.k2hdkc

Class Session

java.lang.Object

ax.antpick.k2hdkc.Session

All Implemented Interfaces:

AutoCloseable

public class Session
extends Object
implements AutoCloseable

Holds a Cluster object and a connection handle with a chmpx slave process.

Author:

Hirotaka Wakabayashi

An Usage Example:

Following code will open a connection with a chmpx slave process and close it.

 import ax.antpick.k2hdkc.*;
 import com.sun.jna.*;
 import com.sun.jna.ptr.*;
 import java.io.IOException;

 public class App {
     private static final String CHMPX_SLAVE_CONFIG = "cluster/slave.yaml";
     public static void main(String[] args) {
     try (Cluster c = Cluster.of(CHMPX_SLAVE_CONFIG);
        Session s = Session.of(c); ) {
       System.out.println(s.toString()); // prints session information.
     } catch (IOException ex) {
       System.out.println(ex.getMessage());
       assert (false);
     }
   }
 }
 

Before running the code above, You should run three processes.

1. A chmpx server process
2. A chmpx slave process
3. A k2hdkc server process

The following commands in this repository will run all processes you need in localhost.

 $ cd cluster
 $ sh start_server.sh
 

, Hirotaka Wakabayashi

Field Summary

Fields

Modifier and Type	Field and Description
static long	K2HASH_INVALID_HANDLE k2hash default handle
static long	K2HDKC_INVALID_HANDLE k2hdkc default handle

Method Summary

Modifier and Type	Method and Description
void	close() Closes a connection with a chmpx slave process.
long	getHandle() Returns a k2hash data handle.
static Session	of(Cluster cluster) Creates a Session instance.
String	toString() Returns full of members as a string.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

K2HDKC_INVALID_HANDLE

public static final long K2HDKC_INVALID_HANDLE

k2hdkc default handle

See Also:

Constant Field Values

K2HASH_INVALID_HANDLE

public static final long K2HASH_INVALID_HANDLE

k2hash default handle

See Also:

Constant Field Values

Method Detail

toString

public String toString()

Returns full of members as a string.

Overrides:

toString in class Object

Returns:

full of members as a string in a key=value manner

of

public static Session of(Cluster cluster)
                  throws IOException

Creates a Session instance.

Parameters:

cluster - a k2hdkc cluster instance

Returns:

a k2hdkc instance

Throws:

IllegalArgumentException - if pathname should not be null

IOException - if creating a chmpx configuration file failed

getHandle

public long getHandle()

Returns a k2hash data handle.

Returns:

a k2hash data handle.

close

public void close()
           throws IOException

Closes a connection with a chmpx slave process.

Specified by:

close in interface AutoCloseable

Throws:

IOException - will not be thrown from this class even if k2hdkc_close_chmpx_ex returns false because it's not critical.