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

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

647
648
649
650
651
652
653
654
655
656
657
        try {
          ch.acquireExclusiveLock();

          try {
            ch.writeByte(OChannelBinaryProtocol.PUSH_DATA);
            ch.writeInt(Integer.MIN_VALUE);
            ch.writeByte(OChannelDistributedProtocol.PUSH_DISTRIBUTED_CONFIG);
            ch.writeBytes(clusterDbConfigurations.get(iDatabaseName).toStream());

          } catch (IOException e) {
View Full Code Here
649
650
651
652
653
654
655
656
657
658
659
          ch.acquireExclusiveLock();

          try {
            ch.writeByte(OChannelBinaryProtocol.PUSH_DATA);
            ch.writeInt(Integer.MIN_VALUE);
            ch.writeByte(OChannelDistributedProtocol.PUSH_DISTRIBUTED_CONFIG);
            ch.writeBytes(clusterDbConfigurations.get(iDatabaseName).toStream());

          } catch (IOException e) {
            e.printStackTrace();
          } finally {
View Full Code Here
138
139
140
141
142
143
144
145
146
147
148
          if (c.database != null && c.database.getName().equals(dbName))
            synchronized (c.records2Push) {
              channel.acquireExclusiveLock();
              try {
                channel.writeByte(OChannelBinaryProtocol.PUSH_DATA);
                channel.writeInt(Integer.MIN_VALUE);
                channel.writeByte(OChannelBinaryProtocol.REQUEST_PUSH_RECORD);
                p.writeIdentifiable(iRecord);
              } finally {
                channel.releaseExclusiveLock();
View Full Code Here
140
141
142
143
144
145
146
147
148
149
150
            synchronized (c.records2Push) {
              channel.acquireExclusiveLock();
              try {
                channel.writeByte(OChannelBinaryProtocol.PUSH_DATA);
                channel.writeInt(Integer.MIN_VALUE);
                channel.writeByte(OChannelBinaryProtocol.REQUEST_PUSH_RECORD);
                p.writeIdentifiable(iRecord);
              } finally {
                channel.releaseExclusiveLock();
              }
            }
View Full Code Here
584
585
586
587
588
589
590
591
592
593
594
        try {
          ch.acquireExclusiveLock();

          try {
            ch.writeByte(OChannelBinaryProtocol.PUSH_DATA);
            ch.writeInt(-10);
            ch.writeByte(OChannelDistributedProtocol.PUSH_DISTRIBUTED_CONFIG);
            ch.writeBytes(clusterDbConfigurations.get(iDatabaseName).toStream());

          } catch (IOException e) {
View Full Code Here
586
587
588
589
590
591
592
593
594
595
596
          ch.acquireExclusiveLock();

          try {
            ch.writeByte(OChannelBinaryProtocol.PUSH_DATA);
            ch.writeInt(-10);
            ch.writeByte(OChannelDistributedProtocol.PUSH_DISTRIBUTED_CONFIG);
            ch.writeBytes(clusterDbConfigurations.get(iDatabaseName).toStream());

          } catch (IOException e) {
            e.printStackTrace();
          } finally {
View Full Code Here
578
579
580
581
582
583
584
585
586
587
588
        try {
          ch.acquireExclusiveLock();

          try {
            ch.writeByte(OChannelBinaryProtocol.PUSH_DATA);
            ch.writeInt(-10);
            ch.writeByte(OChannelDistributedProtocol.PUSH_DISTRIBUTED_CONFIG);
            ch.writeBytes(clusterDbConfigurations.get(iDatabaseName).toStream());

          } catch (IOException e) {
View Full Code Here
580
581
582
583
584
585
586
587
588
589
590
          ch.acquireExclusiveLock();

          try {
            ch.writeByte(OChannelBinaryProtocol.PUSH_DATA);
            ch.writeInt(-10);
            ch.writeByte(OChannelDistributedProtocol.PUSH_DISTRIBUTED_CONFIG);
            ch.writeBytes(clusterDbConfigurations.get(iDatabaseName).toStream());

          } catch (IOException e) {
            e.printStackTrace();
          } finally {
View Full Code Here
274
275
276
277
278
279
280
281
282
283
284
      final OChannelBinary channel = (OChannelBinary) p.getChannel();

      try {
        channel.acquireWriteLock();
        try {
          channel.writeByte(OChannelBinaryProtocol.PUSH_DATA);
          channel.writeInt(Integer.MIN_VALUE);
          channel.writeByte(OChannelBinaryProtocol.REQUEST_PUSH_DISTRIB_CONFIG);
          channel.writeBytes(content);
          channel.flush();
View Full Code Here
276
277
278
279
280
281
282
283
284
285
286
      try {
        channel.acquireWriteLock();
        try {
          channel.writeByte(OChannelBinaryProtocol.PUSH_DATA);
          channel.writeInt(Integer.MIN_VALUE);
          channel.writeByte(OChannelBinaryProtocol.REQUEST_PUSH_DISTRIB_CONFIG);
          channel.writeBytes(content);
          channel.flush();

          pushed.add(c.getRemoteAddress());
          OLogManager.instance().info(this, "Sent updated cluster configuration to the remote client %s", c.getRemoteAddress());
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.