Package com.orientechnologies.orient.enterprise.channel.binary

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

290
291
292
293
294
295
296
297
298
299
300
        final OChannelBinaryClient network = beginRequest(OChannelBinaryProtocol.REQUEST_RECORD_UPDATE);
        try {
          network.writeRID(iRid);
          network.writeBytes(iContent);
          network.writeInt(iVersion);
          network.writeByte(iRecordType);
        } finally {
          endRequest(network);
        }

        try {
View Full Code Here
513
514
515
516
517
518
519
520
521
522
523
        final boolean asynch = iCommand instanceof OCommandRequestAsynch;

        final OChannelBinaryClient network = beginRequest(OChannelBinaryProtocol.REQUEST_COMMAND);
        try {
          network.writeByte((byte) (asynch ? 'a' : 's')); // ASYNC / SYNC
          network.writeBytes(OStreamSerializerAnyStreamable.INSTANCE.toStream(iCommand.getDatabase(), command));
        } finally {
          endRequest(network);
        }
View Full Code Here
636
637
638
639
640
641
642
643
644
645
646
              tmpEntries.clear();
            }
          }

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

          // SEND INDEX ENTRIES
          network.writeBytes(iTx.getIndexChanges().toStream());
        } finally {
          endRequest(network);
View Full Code Here
208
209
210
211
212
213
214
215
216
217
218
        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
285
286
287
288
289
290
291
292
293
294
295
        final OChannelBinaryClient network = beginRequest(OChannelBinaryProtocol.REQUEST_RECORD_UPDATE);
        try {
          network.writeRID(iRid);
          network.writeBytes(iContent);
          network.writeInt(iVersion);
          network.writeByte(iRecordType);
        } finally {
          endRequest(network);
        }

        try {
View Full Code Here
487
488
489
490
491
492
493
494
495
496
497
        final boolean asynch = iCommand instanceof OCommandRequestAsynch;

        final OChannelBinaryClient network = beginRequest(OChannelBinaryProtocol.REQUEST_COMMAND);
        try {
          network.writeByte((byte) (asynch ? 'a' : 's')); // ASYNC / SYNC
          network.writeBytes(OStreamSerializerAnyStreamable.INSTANCE.toStream(iCommand.getDatabase(), command));
        } finally {
          endRequest(network);
        }
View Full Code Here
601
602
603
604
605
606
607
608
609
610
611
              allEntries.addAll(tmpEntries);
              tmpEntries.clear();
            }
          }

          network.writeByte((byte) 0);

        } finally {
          endRequest(network);
        }
View Full Code Here
795
796
797
798
799
800
801
802
803
804
805
        final ORID rid = iRecord.getIdentity();

        final OChannelBinaryClient network = beginRequest(OChannelBinaryProtocol.REQUEST_INDEX_PUT);
        try {
          network.writeString(iKey);
          network.writeByte(iRecord.getRecordType());
          network.writeRID(rid);
        } finally {
          endRequest(network);
        }
View Full Code Here
1167
1168
1169
1170
1171
1172
1173
1174
1175
1176
1177
     
    } finally {
      lock.releaseSharedLock(locked);
    }

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

    return network;
  }
View Full Code Here
171
172
173
174
175
176
177
178
179
180
181
      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
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.