Package com.orientechnologies.common.io

Examples of com.orientechnologies.common.io.OIOException

93
94
95
96
97
98
99
100
  public boolean ready() {
    try {
      return current < end || input.ready();
    } catch (IOException e) {
      throw new OIOException("Error in ready", e);
    }
  }
View Full Code Here
214
215
216
217
218
219
220
221
222
223
224
            maxMemory);
      }
    } while (entry == null && maxMemory > MIN_MEMORY);

    if (entry == null)
      throw new OIOException("You can't access to the file portion " + iBeginOffset + "-" + iBeginOffset + iSize + " bytes");

    totalMemory += bufferSize;
    bufferPoolLRU.add(entry);

    p = (position + 2) * -1;
 
View Full Code Here
288
289
290
291
292
293
294
295
296
297
    return offset;
  }

  protected long checkRegions(final long iOffset, final int iLength) {
    if (iOffset + iLength > filledUpTo)
      throw new OIOException("You can't access outside the file size (" + filledUpTo + " bytes). You've requested portion "
          + iOffset + "-" + (iOffset + iLength) + " bytes. File: " + toString());

    return iOffset;// + HEADER_SIZE;
  }
View Full Code Here
287
288
289
290
291
292
293
294
295
296
    return offset;
  }

  protected long checkRegions(final long iOffset, final int iLength) {
    if (iOffset + iLength > filledUpTo)
      throw new OIOException("You can't access outside the file size (" + filledUpTo + " bytes). You've requested portion "
          + iOffset + "-" + (iOffset + iLength) + " bytes. File: " + toString());

    return iOffset;// + HEADER_SIZE;
  }
View Full Code Here
219
220
221
222
223
224
225
226
227
228
229
            maxMemory);
      }
    } while (entry == null && maxMemory > MIN_MEMORY);

    if (entry == null)
      throw new OIOException("You can't access to the file portion " + iBeginOffset + "-" + iBeginOffset + iSize + " bytes");

    totalMemory += bufferSize;
    bufferPoolLRU.add(entry);

    p = (position + 2) * -1;
 
View Full Code Here
1155
1156
1157
1158
1159
1160
1161
1162
1163
1164
1165
          } // end if: quartet built
        } // end if: equals sign or better
      } // end if: white space, equals sign or better
      else {
        // There's a bad input character in the Base64 stream.
        throw new OIOException(String.format("Bad Base64 input character decimal %d in array position %d", (source[i]) & 0xFF, i));
      } // end else:
    } // each input character

    byte[] out = new byte[outBuffPosn];
    System.arraycopy(outBuff, 0, out, 0, outBuffPosn);
View Full Code Here
230
231
232
233
234
235
236
237
      try {
        final ODocument clusterConfig = getClusterConfiguration(iConnection.database.getName());
        byte[] serializedDocument = clusterConfig != null ? clusterConfig.toStream() : null;
        ((OChannelBinary) iConnection.protocol.getChannel()).writeBytes(serializedDocument);
      } catch (IOException e) {
        throw new OIOException("Error on marshalling of cluster configuration", e);
      }
  }
View Full Code Here
295
296
297
298
299
300
301
302
303
304
    return offset;
  }

  protected long checkRegions(final long iOffset, final int iLength) {
    if (iOffset + iLength > filledUpTo)
      throw new OIOException("You can't access outside the file size (" + filledUpTo + " bytes). You've requested portion "
          + iOffset + "-" + (iOffset + iLength) + " bytes. File: " + toString());

    return iOffset;// + HEADER_SIZE;
  }
View Full Code Here
190
191
192
193
194
195
196
197
198
199
200
     } else {
       ODatabaseRecordThreadLocal.INSTANCE.remove();
       if (requestType != OChannelBinaryProtocol.REQUEST_DB_CLOSE && requestType != OChannelBinaryProtocol.REQUEST_SHUTDOWN) {
         OLogManager.instance().debug(this, "Found unknown session %d, shutdown current connection", clientTxId);
         shutdown();
         throw new OIOException("Found unknown session " + clientTxId);
       }
     }

     OServerPluginHelper.invokeHandlerCallbackOnBeforeClientRequest(server, connection, (byte) requestType);
   }
View Full Code Here
1579
1580
1581
1582
1583
1584
1585
1586
1587
1588
1589
          } // end if: quartet built
        } // end if: equals sign or better
      } // end if: white space, equals sign or better
      else {
        // There's a bad input character in the Base64 stream.
        throw new OIOException(String.format("Bad Base64 input character decimal %d in array position %d", (source[i]) & 0xFF, i));
      } // end else:
    } // each input character

    byte[] out = new byte[outBuffPosn];
    System.arraycopy(outBuff, 0, out, 0, outBuffPosn);
View Full Code Here
TOP

Related Classes of com.orientechnologies.common.io.OIOException

  • com.orientechnologies.common.parser.OStringForwardReader
  • com.orientechnologies.orient.client.remote.ORemoteConnectionManager
  • com.orientechnologies.orient.client.remote.OStorageRemote
  • com.orientechnologies.orient.core.serialization.OBase64Utils
  • com.orientechnologies.orient.core.storage.fs.OAbstractFile
  • com.orientechnologies.orient.core.storage.fs.OFile
  • com.orientechnologies.orient.core.storage.fs.OMMapManager
  • com.orientechnologies.orient.server.handler.distributed.ODistributedServerDiscoveryListener
  • com.orientechnologies.orient.server.handler.distributed.ODistributedServerManager
  • com.orientechnologies.orient.server.network.protocol.binary.ONetworkProtocolBinary
    • Copyright © 2018 www.massapicom. 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.