Examples of com.orientechnologies.orient.enterprise.channel.binary.OChannelBinaryClient.writeByte()

com.orientechnologies.orient.enterprise.channel.binary.OChannelBinaryClient.writeByte()

      try {
        network.writeString(iDatabaseName);
        network.writeString(iDatabaseUserName);
        network.writeString(iDatabaseUserPassword);
        network.writeString(iRemoteName);
        network.writeByte((byte) (iSynchronousMode ? 1 : 0));
      } finally {
        storage.endRequest(network);
      }


      storage.getResponse(network);

View Full Code Here

        try {
          network = beginRequest(OChannelBinaryProtocol.REQUEST_RECORD_CREATE);


          network.writeShort((short) iRid.clusterId);
          network.writeBytes(iContent);
          network.writeByte(iRecordType);


        } finally {
          endRequest(network);
        }

View Full Code Here

          network = beginRequest(OChannelBinaryProtocol.REQUEST_RECORD_UPDATE);


          network.writeRID(iRid);
          network.writeBytes(iContent);
          network.writeInt(iVersion);
          network.writeByte(iRecordType);


        } finally {
          endRequest(network);
        }

View Full Code Here


        OChannelBinaryClient network = null;
        try {
          network = beginRequest(OChannelBinaryProtocol.REQUEST_COMMAND);


          network.writeByte((byte) (asynch ? 'a' : 's')); // ASYNC / SYNC
          network.writeBytes(OStreamSerializerAnyStreamable.INSTANCE.toStream(iCommand.getDatabase(), command));


        } finally {
          endRequest(network);
        }

View Full Code Here

        OChannelBinaryClient network = null;
        try {
          network = beginRequest(OChannelBinaryProtocol.REQUEST_TX_COMMIT);


          network.writeInt(((OTransaction) iTx).getId());
          network.writeByte((byte) (((OTransaction) iTx).isUsingLog() ? 1 : 0));


          final List<OTransactionRecordEntry> tmpEntries = new ArrayList<OTransactionRecordEntry>();


          while (iTx.getCurrentRecordEntries().iterator().hasNext()) {
            for (OTransactionRecordEntry txEntry : iTx.getCurrentRecordEntries())

View Full Code Here

                commitEntry(network, txEntry);


          }


          // END OF RECORD ENTRIES
          network.writeByte((byte) 0);


          // SEND INDEX ENTRIES
          network.writeBytes(iTx.getIndexChanges().toStream());
        } finally {
          endRequest(network);

View Full Code Here

          }
        }
      }
    }


    network.writeByte(iCommand);
    network.writeInt(getSessionId());


    return network;
  }

View Full Code Here


    } finally {
      lock.releaseSharedLock();
    }


    network.writeByte(iCommand);
    network.writeInt(getSessionId());


    return network;
  }

View Full Code Here

      try {
        network.writeString(iDatabaseName);
        network.writeString(iDatabaseUserName);
        network.writeString(iDatabaseUserPassword);
        network.writeString(iRemoteName);
        network.writeByte((byte) (iSynchronousMode ? 1 : 0));
      } finally {
        storage.endRequest(network);
      }


      storage.getResponse(network);

View Full Code Here


        final OChannelBinaryClient network = beginRequest(OChannelBinaryProtocol.REQUEST_RECORD_CREATE);
        try {
          network.writeShort((short) iRid.clusterId);
          network.writeBytes(iContent);
          network.writeByte(iRecordType);
        } finally {
          endRequest(network);
        }


        try {

View Full Code Here

0 1

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.