/*

 * Copyright (c) 2000, 2010, Oracle and/or its affiliates. All rights reserved.

 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.

 *

 * This code is free software; you can redistribute it and/or modify it

 * under the terms of the GNU General Public License version 2 only, as

 * published by the Free Software Foundation.

 *

 * This code is distributed in the hope that it will be useful, but WITHOUT

 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or

 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License

 * version 2 for more details (a copy is included in the LICENSE file that

 * accompanied this code).

 *

 * You should have received a copy of the GNU General Public License version

 * 2 along with this work; if not, write to the Free Software Foundation,

 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.

 *

 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA

 * or visit www.oracle.com if you need additional information or have any

 * questions.

 *

 */

// ==================================================================

// DataLayout

//

// Overlay for generic profiling data.

// Some types of data layouts need a length field.

bool DataLayout::needs_array_len(u1 tag) {

  return (tag == multi_branch_data_tag) || (tag == arg_info_data_tag);

}

// Perform generic initialization of the data.  More specific

// initialization occurs in overrides of ProfileData::post_initialize.

void DataLayout::initialize(u1 tag, u2 bci, int cell_count) {

  _header._bits = (intptr_t)0;

  _header._struct._tag = tag;

  _header._struct._bci = bci;

  for (int i = 0; i < cell_count; i++) {

    set_cell_at(i, (intptr_t)0);

  }

  if (needs_array_len(tag)) {

    set_cell_at(ArrayData::array_len_off_set, cell_count - 1); // -1 for header.

  }

}

void DataLayout::follow_weak_refs(BoolObjectClosure* cl) {

  ResourceMark m;

  data_in()->follow_weak_refs(cl);

}

// ==================================================================

// ProfileData

//

// A ProfileData object is created to refer to a section of profiling

// data in a structured way.

// Constructor for invalid ProfileData.

ProfileData::ProfileData() {

  _data = NULL;

}

#ifndef PRODUCT

void ProfileData::print_shared(outputStream* st, const char* name) {

  st->print("bci: %d", bci());

  st->fill_to(tab_width_one);

  st->print("%s", name);

  tab(st);

  int trap = trap_state();

  if (trap != 0) {

    char buf[100];

    st->print("trap(%s) ", Deoptimization::format_trap_state(buf, sizeof(buf), trap));

  }

  int flags = data()->flags();

  if (flags != 0)

    st->print("flags(%d) ", flags);

}

void ProfileData::tab(outputStream* st) {

  st->fill_to(tab_width_two);

}

#endif // !PRODUCT

// ==================================================================

// BitData

//

// A BitData corresponds to a one-bit flag.  This is used to indicate

// whether a checkcast bytecode has seen a null value.

#ifndef PRODUCT

void BitData::print_data_on(outputStream* st) {

  print_shared(st, "BitData");

}

#endif // !PRODUCT

// ==================================================================

// CounterData

//

// A CounterData corresponds to a simple counter.

#ifndef PRODUCT

void CounterData::print_data_on(outputStream* st) {

  print_shared(st, "CounterData");

  st->print_cr("count(%u)", count());

}

#endif // !PRODUCT

// ==================================================================

// JumpData

//

// A JumpData is used to access profiling information for a direct

// branch.  It is a counter, used for counting the number of branches,

// plus a data displacement, used for realigning the data pointer to

// the corresponding target bci.

void JumpData::post_initialize(BytecodeStream* stream, methodDataOop mdo) {

  assert(stream->bci() == bci(), "wrong pos");

  int target;

  Bytecodes::Code c = stream->code();

  if (c == Bytecodes::_goto_w || c == Bytecodes::_jsr_w) {

    target = stream->dest_w();

  } else {

    target = stream->dest();

  }

  int my_di = mdo->dp_to_di(dp());

  int target_di = mdo->bci_to_di(target);

  int offset = target_di - my_di;

  set_displacement(offset);

}

#ifndef PRODUCT

void JumpData::print_data_on(outputStream* st) {

  print_shared(st, "JumpData");

  st->print_cr("taken(%u) displacement(%d)", taken(), displacement());

}

#endif // !PRODUCT

// ==================================================================

// ReceiverTypeData

//

// A ReceiverTypeData is used to access profiling information about a

// dynamic type check.  It consists of a counter which counts the total times

// that the check is reached, and a series of (klassOop, count) pairs

// which are used to store a type profile for the receiver of the check.

void ReceiverTypeData::follow_contents() {

  // This is a set of weak references that need

  // to be followed at the end of the strong marking

  // phase. Memoize this object so it can be visited

  // in the weak roots processing phase.

  MarkSweep::revisit_mdo(data());

}

#ifndef SERIALGC

void ReceiverTypeData::follow_contents(ParCompactionManager* cm) {

  // This is a set of weak references that need

  // to be followed at the end of the strong marking

  // phase. Memoize this object so it can be visited

  // in the weak roots processing phase.

  PSParallelCompact::revisit_mdo(cm, data());

}

#endif // SERIALGC

void ReceiverTypeData::oop_iterate(OopClosure* blk) {

  if (blk->should_remember_mdo()) {

    // This is a set of weak references that need

    // to be followed at the end of the strong marking

    // phase. Memoize this object so it can be visited

    // in the weak roots processing phase.

    blk->remember_mdo(data());

  } else { // normal scan

    for (uint row = 0; row < row_limit(); row++) {

      if (receiver(row) != NULL) {

        oop* adr = adr_receiver(row);

        blk->do_oop(adr);

      }

    }

  }

}

void ReceiverTypeData::oop_iterate_m(OopClosure* blk, MemRegion mr) {

  // Currently, this interface is called only during card-scanning for

  // a young gen gc, in which case this object cannot contribute anything,

  // since it does not contain any references that cross out of

  // the perm gen. However, for future more general use we allow

  // the possibility of calling for instance from more general

  // iterators (for example, a future regionalized perm gen for G1,

  // or the possibility of moving some references out of perm in

  // the case of other collectors). In that case, you will need

  // to relax or remove some of the assertions below.

#ifdef ASSERT

  // Verify that none of the embedded oop references cross out of

  // this generation.

  for (uint row = 0; row < row_limit(); row++) {

    if (receiver(row) != NULL) {

      oop* adr = adr_receiver(row);

      CollectedHeap* h = Universe::heap();

      assert(h->is_permanent(adr) && h->is_permanent_or_null(*adr), "Not intra-perm");

    }

  }

#endif // ASSERT

  assert(!blk->should_remember_mdo(), "Not expected to remember MDO");

  return;   // Nothing to do, see comment above

#if 0

  if (blk->should_remember_mdo()) {

    // This is a set of weak references that need

    // to be followed at the end of the strong marking

    // phase. Memoize this object so it can be visited

    // in the weak roots processing phase.

    blk->remember_mdo(data());

  } else { // normal scan

    for (uint row = 0; row < row_limit(); row++) {

      if (receiver(row) != NULL) {

        oop* adr = adr_receiver(row);

        if (mr.contains(adr)) {

          blk->do_oop(adr);

        } else if ((HeapWord*)adr >= mr.end()) {

          // Test that the current cursor and the two ends of the range

          // that we may have skipped iterating over are monotonically ordered;

          // this is just a paranoid assertion, just in case represetations

          // should change in the future rendering the short-circuit return

          // here invalid.

          assert((row+1 >= row_limit() || adr_receiver(row+1) > adr) &&

                 (row+2 >= row_limit() || adr_receiver(row_limit()-1) > adr_receiver(row+1)), "Reducing?");

          break; // remaining should be outside this mr too

        }

      }

    }

  }

#endif

}

void ReceiverTypeData::adjust_pointers() {

  for (uint row = 0; row < row_limit(); row++) {

    if (receiver(row) != NULL) {

      MarkSweep::adjust_pointer(adr_receiver(row));

    }

  }

}

void ReceiverTypeData::follow_weak_refs(BoolObjectClosure* is_alive_cl) {

  for (uint row = 0; row < row_limit(); row++) {

    klassOop p = receiver(row);

    if (p != NULL && !is_alive_cl->do_object_b(p)) {

      clear_row(row);

    }

  }

}

#ifndef SERIALGC

void ReceiverTypeData::update_pointers() {

  for (uint row = 0; row < row_limit(); row++) {

    if (receiver_unchecked(row) != NULL) {

      PSParallelCompact::adjust_pointer(adr_receiver(row));

    }

  }

}

void ReceiverTypeData::update_pointers(HeapWord* beg_addr, HeapWord* end_addr) {

  // The loop bounds could be computed based on beg_addr/end_addr and the

  // boundary test hoisted outside the loop (see klassVTable for an example);

  // however, row_limit() is small enough (2) to make that less efficient.

  for (uint row = 0; row < row_limit(); row++) {

    if (receiver_unchecked(row) != NULL) {

      PSParallelCompact::adjust_pointer(adr_receiver(row), beg_addr, end_addr);

    }

  }

}

#endif // SERIALGC

#ifndef PRODUCT

void ReceiverTypeData::print_receiver_data_on(outputStream* st) {

  uint row;

  int entries = 0;

  for (row = 0; row < row_limit(); row++) {

    if (receiver(row) != NULL)  entries++;

  }

  st->print_cr("count(%u) entries(%u)", count(), entries);

  int total = count();

  for (row = 0; row < row_limit(); row++) {

    if (receiver(row) != NULL) {

      total += receiver_count(row);

    }

  }

  for (row = 0; row < row_limit(); row++) {

    if (receiver(row) != NULL) {

      tab(st);

      receiver(row)->print_value_on(st);

      st->print_cr("(%u %4.2f)", receiver_count(row), (float) receiver_count(row) / (float) total);

    }

  }

}

void ReceiverTypeData::print_data_on(outputStream* st) {

  print_shared(st, "ReceiverTypeData");

  print_receiver_data_on(st);

}

void VirtualCallData::print_data_on(outputStream* st) {

  print_shared(st, "VirtualCallData");

  print_receiver_data_on(st);

}

#endif // !PRODUCT

// ==================================================================

// RetData

//

// A RetData is used to access profiling information for a ret bytecode.

// It is composed of a count of the number of times that the ret has

// been executed, followed by a series of triples of the form

// (bci, count, di) which count the number of times that some bci was the

// target of the ret and cache a corresponding displacement.

void RetData::post_initialize(BytecodeStream* stream, methodDataOop mdo) {

  for (uint row = 0; row < row_limit(); row++) {

    set_bci_displacement(row, -1);

    set_bci(row, no_bci);

  }

  // release so other threads see a consistent state.  bci is used as

  // a valid flag for bci_displacement.

  OrderAccess::release();

}

// This routine needs to atomically update the RetData structure, so the

// caller needs to hold the RetData_lock before it gets here.  Since taking

// the lock can block (and allow GC) and since RetData is a ProfileData is a

// wrapper around a derived oop, taking the lock in _this_ method will

// basically cause the 'this' pointer's _data field to contain junk after the

// lock.  We require the caller to take the lock before making the ProfileData

// structure.  Currently the only caller is InterpreterRuntime::update_mdp_for_ret

address RetData::fixup_ret(int return_bci, methodDataHandle h_mdo) {

  // First find the mdp which corresponds to the return bci.

  address mdp = h_mdo->bci_to_dp(return_bci);

  // Now check to see if any of the cache slots are open.

  for (uint row = 0; row < row_limit(); row++) {

    if (bci(row) == no_bci) {

      set_bci_displacement(row, mdp - dp());

      set_bci_count(row, DataLayout::counter_increment);

      // Barrier to ensure displacement is written before the bci; allows

      // the interpreter to read displacement without fear of race condition.

      release_set_bci(row, return_bci);

      break;

    }

  }

  return mdp;

}

#ifndef PRODUCT

void RetData::print_data_on(outputStream* st) {

  print_shared(st, "RetData");

  uint row;

  int entries = 0;

  for (row = 0; row < row_limit(); row++) {

    if (bci(row) != no_bci)  entries++;

  }

  st->print_cr("count(%u) entries(%u)", count(), entries);

  for (row = 0; row < row_limit(); row++) {

    if (bci(row) != no_bci) {

      tab(st);

      st->print_cr("bci(%d: count(%u) displacement(%d))",

                   bci(row), bci_count(row), bci_displacement(row));

    }

  }

}

#endif // !PRODUCT

// ==================================================================

// BranchData

//

// A BranchData is used to access profiling data for a two-way branch.

// It consists of taken and not_taken counts as well as a data displacement

// for the taken case.

void BranchData::post_initialize(BytecodeStream* stream, methodDataOop mdo) {

  assert(stream->bci() == bci(), "wrong pos");

  int target = stream->dest();

  int my_di = mdo->dp_to_di(dp());

  int target_di = mdo->bci_to_di(target);

  int offset = target_di - my_di;

  set_displacement(offset);

}

#ifndef PRODUCT

void BranchData::print_data_on(outputStream* st) {

  print_shared(st, "BranchData");

  st->print_cr("taken(%u) displacement(%d)",

               taken(), displacement());

  tab(st);

  st->print_cr("not taken(%u)", not_taken());

}

#endif

// ==================================================================

// MultiBranchData

//

// A MultiBranchData is used to access profiling information for

// a multi-way branch (*switch bytecodes).  It consists of a series

// of (count, displacement) pairs, which count the number of times each

// case was taken and specify the data displacment for each branch target.

int MultiBranchData::compute_cell_count(BytecodeStream* stream) {

  int cell_count = 0;

  if (stream->code() == Bytecodes::_tableswitch) {

    Bytecode_tableswitch* sw = Bytecode_tableswitch_at(stream->bcp());

    cell_count = 1 + per_case_cell_count * (1 + sw->length()); // 1 for default

  } else {

    Bytecode_lookupswitch* sw = Bytecode_lookupswitch_at(stream->bcp());

    cell_count = 1 + per_case_cell_count * (sw->number_of_pairs() + 1); // 1 for default

  }

  return cell_count;

}

void MultiBranchData::post_initialize(BytecodeStream* stream,

                                      methodDataOop mdo) {

  assert(stream->bci() == bci(), "wrong pos");

  int target;

  int my_di;

  int target_di;

  int offset;

  if (stream->code() == Bytecodes::_tableswitch) {

    Bytecode_tableswitch* sw = Bytecode_tableswitch_at(stream->bcp());

    int len = sw->length();

    assert(array_len() == per_case_cell_count * (len + 1), "wrong len");

    for (int count = 0; count < len; count++) {

      target = sw->dest_offset_at(count) + bci();

      my_di = mdo->dp_to_di(dp());

      target_di = mdo->bci_to_di(target);

      offset = target_di - my_di;

      set_displacement_at(count, offset);

    }

    target = sw->default_offset() + bci();

    my_di = mdo->dp_to_di(dp());

    target_di = mdo->bci_to_di(target);

    offset = target_di - my_di;

    set_default_displacement(offset);

  } else {

    Bytecode_lookupswitch* sw = Bytecode_lookupswitch_at(stream->bcp());

    int npairs = sw->number_of_pairs();

    assert(array_len() == per_case_cell_count * (npairs + 1), "wrong len");

    for (int count = 0; count < npairs; count++) {

      LookupswitchPair *pair = sw->pair_at(count);

      target = pair->offset() + bci();

      my_di = mdo->dp_to_di(dp());

      target_di = mdo->bci_to_di(target);

      offset = target_di - my_di;

      set_displacement_at(count, offset);

    }

    target = sw->default_offset() + bci();

    my_di = mdo->dp_to_di(dp());

    target_di = mdo->bci_to_di(target);

    offset = target_di - my_di;

    set_default_displacement(offset);

  }

}

#ifndef PRODUCT

void MultiBranchData::print_data_on(outputStream* st) {

  print_shared(st, "MultiBranchData");

  st->print_cr("default_count(%u) displacement(%d)",

               default_count(), default_displacement());

  int cases = number_of_cases();

  for (int i = 0; i < cases; i++) {

    tab(st);

    st->print_cr("count(%u) displacement(%d)",

                 count_at(i), displacement_at(i));

  }

}

#endif

#ifndef PRODUCT

void ArgInfoData::print_data_on(outputStream* st) {

  print_shared(st, "ArgInfoData");

  int nargs = number_of_args();

  for (int i = 0; i < nargs; i++) {

    st->print("  0x%x", arg_modified(i));

  }

  st->cr();

}

#endif

// ==================================================================

// methodDataOop

//

// A methodDataOop holds information which has been collected about

// a method.

int methodDataOopDesc::bytecode_cell_count(Bytecodes::Code code) {

  switch (code) {

  case Bytecodes::_checkcast:

  case Bytecodes::_instanceof:

  case Bytecodes::_aastore:

    if (TypeProfileCasts) {

      return ReceiverTypeData::static_cell_count();

    } else {

      return BitData::static_cell_count();

    }

  case Bytecodes::_invokespecial:

  case Bytecodes::_invokestatic:

    return CounterData::static_cell_count();

  case Bytecodes::_goto:

  case Bytecodes::_goto_w:

  case Bytecodes::_jsr: