com.tailf.maapi

Class MaapiOutputStream

Object

OutputStream

com.tailf.maapi.MaapiOutputStream

All Implemented Interfaces:

Closeable, Flushable

public class MaapiOutputStream
extends OutputStream

Configuration data output stream used to upload configurations. This class is returned as result from Maapi.loadConfigStream(int, java.util.EnumSet).
The application is expected to close the underlying stream socket after usage to assure that background socket is closed use getLocalSocket() to retrieve the socket stream reference.

 String host = "localhost";
 int port = Conf.PORT;
 Socket s = new Socket(host, port);
 Maapi maapi = new Maapi(s);
 maapi.startUserSession("admin",
     InetAddress.getByName("localhost"),
     "maapi",
     new String[] { "admin" },
     MaapiUserSessionFlag.PROTO_TCP);
 int tid = maapi.startTrans(Conf.DB_RUNNING, Conf.MODE_READ_WRITE);

 MaapiOutputStream outstream =
  maapi.loadConfigStream(tid, EnumSet.of(MaapiConfigFlag.XML_FORMAT));

 FileInputStream fis = new FileInputStream(new File("/tmp/config.xml"));


  byte[] buf = new byte[128];
  int n = -1;

    while((n = fis.read(buf)) != -1){
         outstream.write(buf,0,n);
     }

 fis.close();
 outstream.getLocalSocket().close();

 if(outstream.hasWriteAll())
    System.out.println("All data was uploaded successful!");

 maapi.finishTrans(tid);
 s.close();
 

Method Summary

Methods

Modifier and Type	Method and Description
Socket	getLocalSocket() This method is intended to retrieve reference to the underlying stream socket on which the write is performed.
boolean	hasWriteAll() Checks with the server if the complete configuration is uploaded.
void	write(byte[] b, int off, int len) Write a portion of an array of bytes.
void	write(int b) Write a byte from the input stream or -1 if EOF

Methods inherited from class OutputStream

close, flush, write

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getLocalSocket

public Socket getLocalSocket()

This method is intended to retrieve reference to the underlying stream socket on which the write is performed. To call hasWriteAll() the underlying socket must be closed.

Returns:

The Stream socket that this MaapiOutputStream uses.

hasWriteAll

public boolean hasWriteAll()

Checks with the server if the complete configuration is uploaded. This is not performed by reading the stream to EOF but instead a deliberate call to the server. NOTE: Prior to calling this method it is important that the stream socket is closed. Use the getLocalSocket() to retrieve the stream socket or the method will hang until the socket is closed.

Returns:

boolean true if complete configuration is downloaded

write

public void write(byte[] b,
         int off,
         int len)
           throws IOException

Write a portion of an array of bytes.

Overrides:

write in class OutputStream

Parameters:

b - Buffer of byte

off - Offset from which to start writing bytes

len - Number of characters to write

Throws:

IOException

write

public void write(int b)
           throws IOException

Write a byte from the input stream or -1 if EOF

Specified by:

write in class OutputStream

Throws:

IOException