• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 // Copyright 2012 the V8 project authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4 
5 #include "src/debug/liveedit.h"
6 
7 #include "src/assembler-inl.h"
8 #include "src/ast/scopes.h"
9 #include "src/code-stubs.h"
10 #include "src/compilation-cache.h"
11 #include "src/compiler.h"
12 #include "src/debug/debug.h"
13 #include "src/deoptimizer.h"
14 #include "src/frames-inl.h"
15 #include "src/global-handles.h"
16 #include "src/isolate-inl.h"
17 #include "src/messages.h"
18 #include "src/objects-inl.h"
19 #include "src/source-position-table.h"
20 #include "src/v8.h"
21 #include "src/v8memory.h"
22 
23 namespace v8 {
24 namespace internal {
25 
SetElementSloppy(Handle<JSObject> object,uint32_t index,Handle<Object> value)26 void SetElementSloppy(Handle<JSObject> object,
27                       uint32_t index,
28                       Handle<Object> value) {
29   // Ignore return value from SetElement. It can only be a failure if there
30   // are element setters causing exceptions and the debugger context has none
31   // of these.
32   Object::SetElement(object->GetIsolate(), object, index, value, SLOPPY)
33       .Assert();
34 }
35 
36 
37 // A simple implementation of dynamic programming algorithm. It solves
38 // the problem of finding the difference of 2 arrays. It uses a table of results
39 // of subproblems. Each cell contains a number together with 2-bit flag
40 // that helps building the chunk list.
41 class Differencer {
42  public:
Differencer(Comparator::Input * input)43   explicit Differencer(Comparator::Input* input)
44       : input_(input), len1_(input->GetLength1()), len2_(input->GetLength2()) {
45     buffer_ = NewArray<int>(len1_ * len2_);
46   }
~Differencer()47   ~Differencer() {
48     DeleteArray(buffer_);
49   }
50 
Initialize()51   void Initialize() {
52     int array_size = len1_ * len2_;
53     for (int i = 0; i < array_size; i++) {
54       buffer_[i] = kEmptyCellValue;
55     }
56   }
57 
58   // Makes sure that result for the full problem is calculated and stored
59   // in the table together with flags showing a path through subproblems.
FillTable()60   void FillTable() {
61     CompareUpToTail(0, 0);
62   }
63 
SaveResult(Comparator::Output * chunk_writer)64   void SaveResult(Comparator::Output* chunk_writer) {
65     ResultWriter writer(chunk_writer);
66 
67     int pos1 = 0;
68     int pos2 = 0;
69     while (true) {
70       if (pos1 < len1_) {
71         if (pos2 < len2_) {
72           Direction dir = get_direction(pos1, pos2);
73           switch (dir) {
74             case EQ:
75               writer.eq();
76               pos1++;
77               pos2++;
78               break;
79             case SKIP1:
80               writer.skip1(1);
81               pos1++;
82               break;
83             case SKIP2:
84             case SKIP_ANY:
85               writer.skip2(1);
86               pos2++;
87               break;
88             default:
89               UNREACHABLE();
90           }
91         } else {
92           writer.skip1(len1_ - pos1);
93           break;
94         }
95       } else {
96         if (len2_ != pos2) {
97           writer.skip2(len2_ - pos2);
98         }
99         break;
100       }
101     }
102     writer.close();
103   }
104 
105  private:
106   Comparator::Input* input_;
107   int* buffer_;
108   int len1_;
109   int len2_;
110 
111   enum Direction {
112     EQ = 0,
113     SKIP1,
114     SKIP2,
115     SKIP_ANY,
116 
117     MAX_DIRECTION_FLAG_VALUE = SKIP_ANY
118   };
119 
120   // Computes result for a subtask and optionally caches it in the buffer table.
121   // All results values are shifted to make space for flags in the lower bits.
CompareUpToTail(int pos1,int pos2)122   int CompareUpToTail(int pos1, int pos2) {
123     if (pos1 < len1_) {
124       if (pos2 < len2_) {
125         int cached_res = get_value4(pos1, pos2);
126         if (cached_res == kEmptyCellValue) {
127           Direction dir;
128           int res;
129           if (input_->Equals(pos1, pos2)) {
130             res = CompareUpToTail(pos1 + 1, pos2 + 1);
131             dir = EQ;
132           } else {
133             int res1 = CompareUpToTail(pos1 + 1, pos2) +
134                 (1 << kDirectionSizeBits);
135             int res2 = CompareUpToTail(pos1, pos2 + 1) +
136                 (1 << kDirectionSizeBits);
137             if (res1 == res2) {
138               res = res1;
139               dir = SKIP_ANY;
140             } else if (res1 < res2) {
141               res = res1;
142               dir = SKIP1;
143             } else {
144               res = res2;
145               dir = SKIP2;
146             }
147           }
148           set_value4_and_dir(pos1, pos2, res, dir);
149           cached_res = res;
150         }
151         return cached_res;
152       } else {
153         return (len1_ - pos1) << kDirectionSizeBits;
154       }
155     } else {
156       return (len2_ - pos2) << kDirectionSizeBits;
157     }
158   }
159 
get_cell(int i1,int i2)160   inline int& get_cell(int i1, int i2) {
161     return buffer_[i1 + i2 * len1_];
162   }
163 
164   // Each cell keeps a value plus direction. Value is multiplied by 4.
set_value4_and_dir(int i1,int i2,int value4,Direction dir)165   void set_value4_and_dir(int i1, int i2, int value4, Direction dir) {
166     DCHECK((value4 & kDirectionMask) == 0);
167     get_cell(i1, i2) = value4 | dir;
168   }
169 
get_value4(int i1,int i2)170   int get_value4(int i1, int i2) {
171     return get_cell(i1, i2) & (kMaxUInt32 ^ kDirectionMask);
172   }
get_direction(int i1,int i2)173   Direction get_direction(int i1, int i2) {
174     return static_cast<Direction>(get_cell(i1, i2) & kDirectionMask);
175   }
176 
177   static const int kDirectionSizeBits = 2;
178   static const int kDirectionMask = (1 << kDirectionSizeBits) - 1;
179   static const int kEmptyCellValue = ~0u << kDirectionSizeBits;
180 
181   // This method only holds static assert statement (unfortunately you cannot
182   // place one in class scope).
StaticAssertHolder()183   void StaticAssertHolder() {
184     STATIC_ASSERT(MAX_DIRECTION_FLAG_VALUE < (1 << kDirectionSizeBits));
185   }
186 
187   class ResultWriter {
188    public:
ResultWriter(Comparator::Output * chunk_writer)189     explicit ResultWriter(Comparator::Output* chunk_writer)
190         : chunk_writer_(chunk_writer), pos1_(0), pos2_(0),
191           pos1_begin_(-1), pos2_begin_(-1), has_open_chunk_(false) {
192     }
eq()193     void eq() {
194       FlushChunk();
195       pos1_++;
196       pos2_++;
197     }
skip1(int len1)198     void skip1(int len1) {
199       StartChunk();
200       pos1_ += len1;
201     }
skip2(int len2)202     void skip2(int len2) {
203       StartChunk();
204       pos2_ += len2;
205     }
close()206     void close() {
207       FlushChunk();
208     }
209 
210    private:
211     Comparator::Output* chunk_writer_;
212     int pos1_;
213     int pos2_;
214     int pos1_begin_;
215     int pos2_begin_;
216     bool has_open_chunk_;
217 
StartChunk()218     void StartChunk() {
219       if (!has_open_chunk_) {
220         pos1_begin_ = pos1_;
221         pos2_begin_ = pos2_;
222         has_open_chunk_ = true;
223       }
224     }
225 
FlushChunk()226     void FlushChunk() {
227       if (has_open_chunk_) {
228         chunk_writer_->AddChunk(pos1_begin_, pos2_begin_,
229                                 pos1_ - pos1_begin_, pos2_ - pos2_begin_);
230         has_open_chunk_ = false;
231       }
232     }
233   };
234 };
235 
236 
CalculateDifference(Comparator::Input * input,Comparator::Output * result_writer)237 void Comparator::CalculateDifference(Comparator::Input* input,
238                                      Comparator::Output* result_writer) {
239   Differencer differencer(input);
240   differencer.Initialize();
241   differencer.FillTable();
242   differencer.SaveResult(result_writer);
243 }
244 
245 
CompareSubstrings(Handle<String> s1,int pos1,Handle<String> s2,int pos2,int len)246 static bool CompareSubstrings(Handle<String> s1, int pos1,
247                               Handle<String> s2, int pos2, int len) {
248   for (int i = 0; i < len; i++) {
249     if (s1->Get(i + pos1) != s2->Get(i + pos2)) {
250       return false;
251     }
252   }
253   return true;
254 }
255 
256 
257 // Additional to Input interface. Lets switch Input range to subrange.
258 // More elegant way would be to wrap one Input as another Input object
259 // and translate positions there, but that would cost us additional virtual
260 // call per comparison.
261 class SubrangableInput : public Comparator::Input {
262  public:
263   virtual void SetSubrange1(int offset, int len) = 0;
264   virtual void SetSubrange2(int offset, int len) = 0;
265 };
266 
267 
268 class SubrangableOutput : public Comparator::Output {
269  public:
270   virtual void SetSubrange1(int offset, int len) = 0;
271   virtual void SetSubrange2(int offset, int len) = 0;
272 };
273 
274 
min(int a,int b)275 static int min(int a, int b) {
276   return a < b ? a : b;
277 }
278 
279 
280 // Finds common prefix and suffix in input. This parts shouldn't take space in
281 // linear programming table. Enable subranging in input and output.
NarrowDownInput(SubrangableInput * input,SubrangableOutput * output)282 static void NarrowDownInput(SubrangableInput* input,
283     SubrangableOutput* output) {
284   const int len1 = input->GetLength1();
285   const int len2 = input->GetLength2();
286 
287   int common_prefix_len;
288   int common_suffix_len;
289 
290   {
291     common_prefix_len = 0;
292     int prefix_limit = min(len1, len2);
293     while (common_prefix_len < prefix_limit &&
294         input->Equals(common_prefix_len, common_prefix_len)) {
295       common_prefix_len++;
296     }
297 
298     common_suffix_len = 0;
299     int suffix_limit = min(len1 - common_prefix_len, len2 - common_prefix_len);
300 
301     while (common_suffix_len < suffix_limit &&
302         input->Equals(len1 - common_suffix_len - 1,
303         len2 - common_suffix_len - 1)) {
304       common_suffix_len++;
305     }
306   }
307 
308   if (common_prefix_len > 0 || common_suffix_len > 0) {
309     int new_len1 = len1 - common_suffix_len - common_prefix_len;
310     int new_len2 = len2 - common_suffix_len - common_prefix_len;
311 
312     input->SetSubrange1(common_prefix_len, new_len1);
313     input->SetSubrange2(common_prefix_len, new_len2);
314 
315     output->SetSubrange1(common_prefix_len, new_len1);
316     output->SetSubrange2(common_prefix_len, new_len2);
317   }
318 }
319 
320 
321 // A helper class that writes chunk numbers into JSArray.
322 // Each chunk is stored as 3 array elements: (pos1_begin, pos1_end, pos2_end).
323 class CompareOutputArrayWriter {
324  public:
CompareOutputArrayWriter(Isolate * isolate)325   explicit CompareOutputArrayWriter(Isolate* isolate)
326       : array_(isolate->factory()->NewJSArray(10)), current_size_(0) {}
327 
GetResult()328   Handle<JSArray> GetResult() {
329     return array_;
330   }
331 
WriteChunk(int char_pos1,int char_pos2,int char_len1,int char_len2)332   void WriteChunk(int char_pos1, int char_pos2, int char_len1, int char_len2) {
333     Isolate* isolate = array_->GetIsolate();
334     SetElementSloppy(array_,
335                      current_size_,
336                      Handle<Object>(Smi::FromInt(char_pos1), isolate));
337     SetElementSloppy(array_,
338                      current_size_ + 1,
339                      Handle<Object>(Smi::FromInt(char_pos1 + char_len1),
340                                     isolate));
341     SetElementSloppy(array_,
342                      current_size_ + 2,
343                      Handle<Object>(Smi::FromInt(char_pos2 + char_len2),
344                                     isolate));
345     current_size_ += 3;
346   }
347 
348  private:
349   Handle<JSArray> array_;
350   int current_size_;
351 };
352 
353 
354 // Represents 2 strings as 2 arrays of tokens.
355 // TODO(LiveEdit): Currently it's actually an array of charactres.
356 //     Make array of tokens instead.
357 class TokensCompareInput : public Comparator::Input {
358  public:
TokensCompareInput(Handle<String> s1,int offset1,int len1,Handle<String> s2,int offset2,int len2)359   TokensCompareInput(Handle<String> s1, int offset1, int len1,
360                        Handle<String> s2, int offset2, int len2)
361       : s1_(s1), offset1_(offset1), len1_(len1),
362         s2_(s2), offset2_(offset2), len2_(len2) {
363   }
GetLength1()364   virtual int GetLength1() {
365     return len1_;
366   }
GetLength2()367   virtual int GetLength2() {
368     return len2_;
369   }
Equals(int index1,int index2)370   bool Equals(int index1, int index2) {
371     return s1_->Get(offset1_ + index1) == s2_->Get(offset2_ + index2);
372   }
373 
374  private:
375   Handle<String> s1_;
376   int offset1_;
377   int len1_;
378   Handle<String> s2_;
379   int offset2_;
380   int len2_;
381 };
382 
383 
384 // Stores compare result in JSArray. Converts substring positions
385 // to absolute positions.
386 class TokensCompareOutput : public Comparator::Output {
387  public:
TokensCompareOutput(CompareOutputArrayWriter * array_writer,int offset1,int offset2)388   TokensCompareOutput(CompareOutputArrayWriter* array_writer,
389                       int offset1, int offset2)
390         : array_writer_(array_writer), offset1_(offset1), offset2_(offset2) {
391   }
392 
AddChunk(int pos1,int pos2,int len1,int len2)393   void AddChunk(int pos1, int pos2, int len1, int len2) {
394     array_writer_->WriteChunk(pos1 + offset1_, pos2 + offset2_, len1, len2);
395   }
396 
397  private:
398   CompareOutputArrayWriter* array_writer_;
399   int offset1_;
400   int offset2_;
401 };
402 
403 
404 // Wraps raw n-elements line_ends array as a list of n+1 lines. The last line
405 // never has terminating new line character.
406 class LineEndsWrapper {
407  public:
LineEndsWrapper(Handle<String> string)408   explicit LineEndsWrapper(Handle<String> string)
409       : ends_array_(String::CalculateLineEnds(string, false)),
410         string_len_(string->length()) {
411   }
length()412   int length() {
413     return ends_array_->length() + 1;
414   }
415   // Returns start for any line including start of the imaginary line after
416   // the last line.
GetLineStart(int index)417   int GetLineStart(int index) {
418     if (index == 0) {
419       return 0;
420     } else {
421       return GetLineEnd(index - 1);
422     }
423   }
GetLineEnd(int index)424   int GetLineEnd(int index) {
425     if (index == ends_array_->length()) {
426       // End of the last line is always an end of the whole string.
427       // If the string ends with a new line character, the last line is an
428       // empty string after this character.
429       return string_len_;
430     } else {
431       return GetPosAfterNewLine(index);
432     }
433   }
434 
435  private:
436   Handle<FixedArray> ends_array_;
437   int string_len_;
438 
GetPosAfterNewLine(int index)439   int GetPosAfterNewLine(int index) {
440     return Smi::cast(ends_array_->get(index))->value() + 1;
441   }
442 };
443 
444 
445 // Represents 2 strings as 2 arrays of lines.
446 class LineArrayCompareInput : public SubrangableInput {
447  public:
LineArrayCompareInput(Handle<String> s1,Handle<String> s2,LineEndsWrapper line_ends1,LineEndsWrapper line_ends2)448   LineArrayCompareInput(Handle<String> s1, Handle<String> s2,
449                         LineEndsWrapper line_ends1, LineEndsWrapper line_ends2)
450       : s1_(s1), s2_(s2), line_ends1_(line_ends1),
451         line_ends2_(line_ends2),
452         subrange_offset1_(0), subrange_offset2_(0),
453         subrange_len1_(line_ends1_.length()),
454         subrange_len2_(line_ends2_.length()) {
455   }
GetLength1()456   int GetLength1() {
457     return subrange_len1_;
458   }
GetLength2()459   int GetLength2() {
460     return subrange_len2_;
461   }
Equals(int index1,int index2)462   bool Equals(int index1, int index2) {
463     index1 += subrange_offset1_;
464     index2 += subrange_offset2_;
465 
466     int line_start1 = line_ends1_.GetLineStart(index1);
467     int line_start2 = line_ends2_.GetLineStart(index2);
468     int line_end1 = line_ends1_.GetLineEnd(index1);
469     int line_end2 = line_ends2_.GetLineEnd(index2);
470     int len1 = line_end1 - line_start1;
471     int len2 = line_end2 - line_start2;
472     if (len1 != len2) {
473       return false;
474     }
475     return CompareSubstrings(s1_, line_start1, s2_, line_start2,
476                              len1);
477   }
SetSubrange1(int offset,int len)478   void SetSubrange1(int offset, int len) {
479     subrange_offset1_ = offset;
480     subrange_len1_ = len;
481   }
SetSubrange2(int offset,int len)482   void SetSubrange2(int offset, int len) {
483     subrange_offset2_ = offset;
484     subrange_len2_ = len;
485   }
486 
487  private:
488   Handle<String> s1_;
489   Handle<String> s2_;
490   LineEndsWrapper line_ends1_;
491   LineEndsWrapper line_ends2_;
492   int subrange_offset1_;
493   int subrange_offset2_;
494   int subrange_len1_;
495   int subrange_len2_;
496 };
497 
498 
499 // Stores compare result in JSArray. For each chunk tries to conduct
500 // a fine-grained nested diff token-wise.
501 class TokenizingLineArrayCompareOutput : public SubrangableOutput {
502  public:
TokenizingLineArrayCompareOutput(LineEndsWrapper line_ends1,LineEndsWrapper line_ends2,Handle<String> s1,Handle<String> s2)503   TokenizingLineArrayCompareOutput(LineEndsWrapper line_ends1,
504                                    LineEndsWrapper line_ends2,
505                                    Handle<String> s1, Handle<String> s2)
506       : array_writer_(s1->GetIsolate()),
507         line_ends1_(line_ends1), line_ends2_(line_ends2), s1_(s1), s2_(s2),
508         subrange_offset1_(0), subrange_offset2_(0) {
509   }
510 
AddChunk(int line_pos1,int line_pos2,int line_len1,int line_len2)511   void AddChunk(int line_pos1, int line_pos2, int line_len1, int line_len2) {
512     line_pos1 += subrange_offset1_;
513     line_pos2 += subrange_offset2_;
514 
515     int char_pos1 = line_ends1_.GetLineStart(line_pos1);
516     int char_pos2 = line_ends2_.GetLineStart(line_pos2);
517     int char_len1 = line_ends1_.GetLineStart(line_pos1 + line_len1) - char_pos1;
518     int char_len2 = line_ends2_.GetLineStart(line_pos2 + line_len2) - char_pos2;
519 
520     if (char_len1 < CHUNK_LEN_LIMIT && char_len2 < CHUNK_LEN_LIMIT) {
521       // Chunk is small enough to conduct a nested token-level diff.
522       HandleScope subTaskScope(s1_->GetIsolate());
523 
524       TokensCompareInput tokens_input(s1_, char_pos1, char_len1,
525                                       s2_, char_pos2, char_len2);
526       TokensCompareOutput tokens_output(&array_writer_, char_pos1,
527                                           char_pos2);
528 
529       Comparator::CalculateDifference(&tokens_input, &tokens_output);
530     } else {
531       array_writer_.WriteChunk(char_pos1, char_pos2, char_len1, char_len2);
532     }
533   }
SetSubrange1(int offset,int len)534   void SetSubrange1(int offset, int len) {
535     subrange_offset1_ = offset;
536   }
SetSubrange2(int offset,int len)537   void SetSubrange2(int offset, int len) {
538     subrange_offset2_ = offset;
539   }
540 
GetResult()541   Handle<JSArray> GetResult() {
542     return array_writer_.GetResult();
543   }
544 
545  private:
546   static const int CHUNK_LEN_LIMIT = 800;
547 
548   CompareOutputArrayWriter array_writer_;
549   LineEndsWrapper line_ends1_;
550   LineEndsWrapper line_ends2_;
551   Handle<String> s1_;
552   Handle<String> s2_;
553   int subrange_offset1_;
554   int subrange_offset2_;
555 };
556 
557 
CompareStrings(Handle<String> s1,Handle<String> s2)558 Handle<JSArray> LiveEdit::CompareStrings(Handle<String> s1,
559                                          Handle<String> s2) {
560   s1 = String::Flatten(s1);
561   s2 = String::Flatten(s2);
562 
563   LineEndsWrapper line_ends1(s1);
564   LineEndsWrapper line_ends2(s2);
565 
566   LineArrayCompareInput input(s1, s2, line_ends1, line_ends2);
567   TokenizingLineArrayCompareOutput output(line_ends1, line_ends2, s1, s2);
568 
569   NarrowDownInput(&input, &output);
570 
571   Comparator::CalculateDifference(&input, &output);
572 
573   return output.GetResult();
574 }
575 
576 
577 // Unwraps JSValue object, returning its field "value"
UnwrapJSValue(Handle<JSValue> jsValue)578 static Handle<Object> UnwrapJSValue(Handle<JSValue> jsValue) {
579   return Handle<Object>(jsValue->value(), jsValue->GetIsolate());
580 }
581 
582 
583 // Wraps any object into a OpaqueReference, that will hide the object
584 // from JavaScript.
WrapInJSValue(Handle<HeapObject> object)585 static Handle<JSValue> WrapInJSValue(Handle<HeapObject> object) {
586   Isolate* isolate = object->GetIsolate();
587   Handle<JSFunction> constructor = isolate->opaque_reference_function();
588   Handle<JSValue> result =
589       Handle<JSValue>::cast(isolate->factory()->NewJSObject(constructor));
590   result->set_value(*object);
591   return result;
592 }
593 
594 
UnwrapSharedFunctionInfoFromJSValue(Handle<JSValue> jsValue)595 static Handle<SharedFunctionInfo> UnwrapSharedFunctionInfoFromJSValue(
596     Handle<JSValue> jsValue) {
597   Object* shared = jsValue->value();
598   CHECK(shared->IsSharedFunctionInfo());
599   return Handle<SharedFunctionInfo>(SharedFunctionInfo::cast(shared));
600 }
601 
602 
GetArrayLength(Handle<JSArray> array)603 static int GetArrayLength(Handle<JSArray> array) {
604   Object* length = array->length();
605   CHECK(length->IsSmi());
606   return Smi::cast(length)->value();
607 }
608 
SetInitialProperties(Handle<String> name,int start_position,int end_position,int param_num,int parent_index,int function_literal_id)609 void FunctionInfoWrapper::SetInitialProperties(Handle<String> name,
610                                                int start_position,
611                                                int end_position, int param_num,
612                                                int parent_index,
613                                                int function_literal_id) {
614   HandleScope scope(isolate());
615   this->SetField(kFunctionNameOffset_, name);
616   this->SetSmiValueField(kStartPositionOffset_, start_position);
617   this->SetSmiValueField(kEndPositionOffset_, end_position);
618   this->SetSmiValueField(kParamNumOffset_, param_num);
619   this->SetSmiValueField(kParentIndexOffset_, parent_index);
620   this->SetSmiValueField(kFunctionLiteralIdOffset_, function_literal_id);
621 }
622 
SetSharedFunctionInfo(Handle<SharedFunctionInfo> info)623 void FunctionInfoWrapper::SetSharedFunctionInfo(
624     Handle<SharedFunctionInfo> info) {
625   Handle<JSValue> info_holder = WrapInJSValue(info);
626   this->SetField(kSharedFunctionInfoOffset_, info_holder);
627 }
628 
GetSharedFunctionInfo()629 Handle<SharedFunctionInfo> FunctionInfoWrapper::GetSharedFunctionInfo() {
630   Handle<Object> element = this->GetField(kSharedFunctionInfoOffset_);
631   Handle<JSValue> value_wrapper = Handle<JSValue>::cast(element);
632   Handle<Object> raw_result = UnwrapJSValue(value_wrapper);
633   CHECK(raw_result->IsSharedFunctionInfo());
634   return Handle<SharedFunctionInfo>::cast(raw_result);
635 }
636 
SetProperties(Handle<String> name,int start_position,int end_position,Handle<SharedFunctionInfo> info)637 void SharedInfoWrapper::SetProperties(Handle<String> name,
638                                       int start_position,
639                                       int end_position,
640                                       Handle<SharedFunctionInfo> info) {
641   HandleScope scope(isolate());
642   this->SetField(kFunctionNameOffset_, name);
643   Handle<JSValue> info_holder = WrapInJSValue(info);
644   this->SetField(kSharedInfoOffset_, info_holder);
645   this->SetSmiValueField(kStartPositionOffset_, start_position);
646   this->SetSmiValueField(kEndPositionOffset_, end_position);
647 }
648 
649 
GetInfo()650 Handle<SharedFunctionInfo> SharedInfoWrapper::GetInfo() {
651   Handle<Object> element = this->GetField(kSharedInfoOffset_);
652   Handle<JSValue> value_wrapper = Handle<JSValue>::cast(element);
653   return UnwrapSharedFunctionInfoFromJSValue(value_wrapper);
654 }
655 
656 
InitializeThreadLocal(Debug * debug)657 void LiveEdit::InitializeThreadLocal(Debug* debug) {
658   debug->thread_local_.restart_fp_ = 0;
659 }
660 
661 
GatherCompileInfo(Handle<Script> script,Handle<String> source)662 MaybeHandle<JSArray> LiveEdit::GatherCompileInfo(Handle<Script> script,
663                                                  Handle<String> source) {
664   Isolate* isolate = script->GetIsolate();
665 
666   MaybeHandle<JSArray> infos;
667   Handle<Object> original_source =
668       Handle<Object>(script->source(), isolate);
669   script->set_source(*source);
670 
671   {
672     // Creating verbose TryCatch from public API is currently the only way to
673     // force code save location. We do not use this the object directly.
674     v8::TryCatch try_catch(reinterpret_cast<v8::Isolate*>(isolate));
675     try_catch.SetVerbose(true);
676 
677     // A logical 'try' section.
678     infos = Compiler::CompileForLiveEdit(script);
679   }
680 
681   // A logical 'catch' section.
682   Handle<JSObject> rethrow_exception;
683   if (isolate->has_pending_exception()) {
684     Handle<Object> exception(isolate->pending_exception(), isolate);
685     MessageLocation message_location = isolate->GetMessageLocation();
686 
687     isolate->clear_pending_message();
688     isolate->clear_pending_exception();
689 
690     // If possible, copy positions from message object to exception object.
691     if (exception->IsJSObject() && !message_location.script().is_null()) {
692       rethrow_exception = Handle<JSObject>::cast(exception);
693 
694       Factory* factory = isolate->factory();
695       Handle<String> start_pos_key = factory->InternalizeOneByteString(
696           STATIC_CHAR_VECTOR("startPosition"));
697       Handle<String> end_pos_key =
698           factory->InternalizeOneByteString(STATIC_CHAR_VECTOR("endPosition"));
699       Handle<String> script_obj_key =
700           factory->InternalizeOneByteString(STATIC_CHAR_VECTOR("scriptObject"));
701       Handle<Smi> start_pos(
702           Smi::FromInt(message_location.start_pos()), isolate);
703       Handle<Smi> end_pos(Smi::FromInt(message_location.end_pos()), isolate);
704       Handle<JSObject> script_obj =
705           Script::GetWrapper(message_location.script());
706       Object::SetProperty(rethrow_exception, start_pos_key, start_pos, SLOPPY)
707           .Assert();
708       Object::SetProperty(rethrow_exception, end_pos_key, end_pos, SLOPPY)
709           .Assert();
710       Object::SetProperty(rethrow_exception, script_obj_key, script_obj, SLOPPY)
711           .Assert();
712     }
713   }
714 
715   // A logical 'finally' section.
716   script->set_source(*original_source);
717 
718   if (rethrow_exception.is_null()) {
719     return infos.ToHandleChecked();
720   } else {
721     return isolate->Throw<JSArray>(rethrow_exception);
722   }
723 }
724 
725 // Finds all references to original and replaces them with substitution.
ReplaceCodeObject(Handle<Code> original,Handle<Code> substitution)726 static void ReplaceCodeObject(Handle<Code> original,
727                               Handle<Code> substitution) {
728   // Perform a full GC in order to ensure that we are not in the middle of an
729   // incremental marking phase when we are replacing the code object.
730   // Since we are not in an incremental marking phase we can write pointers
731   // to code objects (that are never in new space) without worrying about
732   // write barriers.
733   Heap* heap = original->GetHeap();
734   HeapIterator iterator(heap, HeapIterator::kFilterUnreachable);
735   // Now iterate over all pointers of all objects, including code_target
736   // implicit pointers.
737   for (HeapObject* obj = iterator.next(); obj != NULL; obj = iterator.next()) {
738     if (obj->IsJSFunction()) {
739       JSFunction* fun = JSFunction::cast(obj);
740       if (fun->code() == *original) fun->ReplaceCode(*substitution);
741     } else if (obj->IsSharedFunctionInfo()) {
742       SharedFunctionInfo* info = SharedFunctionInfo::cast(obj);
743       if (info->code() == *original) info->set_code(*substitution);
744     }
745   }
746 }
747 
748 // Patch function feedback vector.
749 // The feedback vector is a cache for complex object boilerplates and for a
750 // native context. We must clean cached values, or if the structure of the
751 // vector itself changes we need to allocate a new one.
752 class FeedbackVectorFixer {
753  public:
PatchFeedbackVector(FunctionInfoWrapper * compile_info_wrapper,Handle<SharedFunctionInfo> shared_info,Isolate * isolate)754   static void PatchFeedbackVector(FunctionInfoWrapper* compile_info_wrapper,
755                                   Handle<SharedFunctionInfo> shared_info,
756                                   Isolate* isolate) {
757     // When feedback metadata changes, we have to create new array instances.
758     // Since we cannot create instances when iterating heap, we should first
759     // collect all functions and fix their literal arrays.
760     Handle<FixedArray> function_instances =
761         CollectJSFunctions(shared_info, isolate);
762 
763     for (int i = 0; i < function_instances->length(); i++) {
764       Handle<JSFunction> fun(JSFunction::cast(function_instances->get(i)));
765       Handle<Cell> new_cell = isolate->factory()->NewManyClosuresCell(
766           isolate->factory()->undefined_value());
767       fun->set_feedback_vector_cell(*new_cell);
768       // Only create feedback vectors if we already have the metadata.
769       if (shared_info->is_compiled()) JSFunction::EnsureLiterals(fun);
770     }
771   }
772 
773  private:
774   // Iterates all function instances in the HEAP that refers to the
775   // provided shared_info.
776   template<typename Visitor>
IterateJSFunctions(Handle<SharedFunctionInfo> shared_info,Visitor * visitor)777   static void IterateJSFunctions(Handle<SharedFunctionInfo> shared_info,
778                                  Visitor* visitor) {
779     HeapIterator iterator(shared_info->GetHeap());
780     for (HeapObject* obj = iterator.next(); obj != NULL;
781         obj = iterator.next()) {
782       if (obj->IsJSFunction()) {
783         JSFunction* function = JSFunction::cast(obj);
784         if (function->shared() == *shared_info) {
785           visitor->visit(function);
786         }
787       }
788     }
789   }
790 
791   // Finds all instances of JSFunction that refers to the provided shared_info
792   // and returns array with them.
CollectJSFunctions(Handle<SharedFunctionInfo> shared_info,Isolate * isolate)793   static Handle<FixedArray> CollectJSFunctions(
794       Handle<SharedFunctionInfo> shared_info, Isolate* isolate) {
795     CountVisitor count_visitor;
796     count_visitor.count = 0;
797     IterateJSFunctions(shared_info, &count_visitor);
798     int size = count_visitor.count;
799 
800     Handle<FixedArray> result = isolate->factory()->NewFixedArray(size);
801     if (size > 0) {
802       CollectVisitor collect_visitor(result);
803       IterateJSFunctions(shared_info, &collect_visitor);
804     }
805     return result;
806   }
807 
808   class CountVisitor {
809    public:
visit(JSFunction * fun)810     void visit(JSFunction* fun) {
811       count++;
812     }
813     int count;
814   };
815 
816   class CollectVisitor {
817    public:
CollectVisitor(Handle<FixedArray> output)818     explicit CollectVisitor(Handle<FixedArray> output)
819         : m_output(output), m_pos(0) {}
820 
visit(JSFunction * fun)821     void visit(JSFunction* fun) {
822       m_output->set(m_pos, fun);
823       m_pos++;
824     }
825    private:
826     Handle<FixedArray> m_output;
827     int m_pos;
828   };
829 };
830 
831 
832 // Marks code that shares the same shared function info or has inlined
833 // code that shares the same function info.
834 class DependentFunctionMarker: public OptimizedFunctionVisitor {
835  public:
836   SharedFunctionInfo* shared_info_;
837   bool found_;
838 
DependentFunctionMarker(SharedFunctionInfo * shared_info)839   explicit DependentFunctionMarker(SharedFunctionInfo* shared_info)
840     : shared_info_(shared_info), found_(false) { }
841 
EnterContext(Context * context)842   virtual void EnterContext(Context* context) { }  // Don't care.
LeaveContext(Context * context)843   virtual void LeaveContext(Context* context)  { }  // Don't care.
VisitFunction(JSFunction * function)844   virtual void VisitFunction(JSFunction* function) {
845     // It should be guaranteed by the iterator that everything is optimized.
846     DCHECK(function->code()->kind() == Code::OPTIMIZED_FUNCTION);
847     if (function->Inlines(shared_info_)) {
848       // Mark the code for deoptimization.
849       function->code()->set_marked_for_deoptimization(true);
850       found_ = true;
851     }
852   }
853 };
854 
855 
DeoptimizeDependentFunctions(SharedFunctionInfo * function_info)856 static void DeoptimizeDependentFunctions(SharedFunctionInfo* function_info) {
857   DisallowHeapAllocation no_allocation;
858   DependentFunctionMarker marker(function_info);
859   // TODO(titzer): need to traverse all optimized code to find OSR code here.
860   Deoptimizer::VisitAllOptimizedFunctions(function_info->GetIsolate(), &marker);
861 
862   if (marker.found_) {
863     // Only go through with the deoptimization if something was found.
864     Deoptimizer::DeoptimizeMarkedCode(function_info->GetIsolate());
865   }
866 }
867 
868 
ReplaceFunctionCode(Handle<JSArray> new_compile_info_array,Handle<JSArray> shared_info_array)869 void LiveEdit::ReplaceFunctionCode(
870     Handle<JSArray> new_compile_info_array,
871     Handle<JSArray> shared_info_array) {
872   Isolate* isolate = new_compile_info_array->GetIsolate();
873 
874   FunctionInfoWrapper compile_info_wrapper(new_compile_info_array);
875   SharedInfoWrapper shared_info_wrapper(shared_info_array);
876 
877   Handle<SharedFunctionInfo> shared_info = shared_info_wrapper.GetInfo();
878   Handle<SharedFunctionInfo> new_shared_info =
879       compile_info_wrapper.GetSharedFunctionInfo();
880 
881   if (shared_info->is_compiled()) {
882     // Take whatever code we can get from the new shared function info. We
883     // expect activations of neither the old bytecode nor old FCG code, since
884     // the lowest activation is going to be restarted.
885     Handle<Code> old_code(shared_info->code());
886     Handle<Code> new_code(new_shared_info->code());
887     // Clear old bytecode. This will trigger self-healing if we do not install
888     // new bytecode.
889     shared_info->ClearBytecodeArray();
890     if (!shared_info->HasBaselineCode()) {
891       // Every function from this SFI is interpreted.
892       if (!new_shared_info->HasBaselineCode()) {
893         // We have newly compiled bytecode. Simply replace the old one.
894         shared_info->set_bytecode_array(new_shared_info->bytecode_array());
895       } else {
896         // Rely on self-healing for places that used to run bytecode.
897         shared_info->ReplaceCode(*new_code);
898       }
899     } else {
900       // Functions from this SFI can be either interpreted or running FCG.
901       DCHECK(old_code->kind() == Code::FUNCTION);
902       if (new_shared_info->HasBytecodeArray()) {
903         // Start using new bytecode everywhere.
904         shared_info->set_bytecode_array(new_shared_info->bytecode_array());
905         ReplaceCodeObject(old_code,
906                           isolate->builtins()->InterpreterEntryTrampoline());
907       } else {
908         // Start using new FCG code everywhere.
909         // Rely on self-healing for places that used to run bytecode.
910         DCHECK(new_code->kind() == Code::FUNCTION);
911         ReplaceCodeObject(old_code, new_code);
912       }
913     }
914 
915     if (shared_info->HasDebugInfo()) {
916       // Existing break points will be re-applied. Reset the debug info here.
917       isolate->debug()->RemoveDebugInfoAndClearFromShared(
918           handle(shared_info->GetDebugInfo()));
919     }
920     shared_info->set_scope_info(new_shared_info->scope_info());
921     shared_info->set_outer_scope_info(new_shared_info->outer_scope_info());
922     shared_info->DisableOptimization(kLiveEdit);
923     // Update the type feedback vector, if needed.
924     Handle<FeedbackMetadata> new_feedback_metadata(
925         new_shared_info->feedback_metadata());
926     shared_info->set_feedback_metadata(*new_feedback_metadata);
927   } else {
928     shared_info->set_feedback_metadata(
929         FeedbackMetadata::cast(isolate->heap()->empty_fixed_array()));
930   }
931 
932   int start_position = compile_info_wrapper.GetStartPosition();
933   int end_position = compile_info_wrapper.GetEndPosition();
934   shared_info->set_start_position(start_position);
935   shared_info->set_end_position(end_position);
936 
937   FeedbackVectorFixer::PatchFeedbackVector(&compile_info_wrapper, shared_info,
938                                            isolate);
939 
940   DeoptimizeDependentFunctions(*shared_info);
941   isolate->compilation_cache()->Remove(shared_info);
942 }
943 
FunctionSourceUpdated(Handle<JSArray> shared_info_array,int new_function_literal_id)944 void LiveEdit::FunctionSourceUpdated(Handle<JSArray> shared_info_array,
945                                      int new_function_literal_id) {
946   SharedInfoWrapper shared_info_wrapper(shared_info_array);
947   Handle<SharedFunctionInfo> shared_info = shared_info_wrapper.GetInfo();
948 
949   shared_info->set_function_literal_id(new_function_literal_id);
950   DeoptimizeDependentFunctions(*shared_info);
951   shared_info_array->GetIsolate()->compilation_cache()->Remove(shared_info);
952 }
953 
FixupScript(Handle<Script> script,int max_function_literal_id)954 void LiveEdit::FixupScript(Handle<Script> script, int max_function_literal_id) {
955   Isolate* isolate = script->GetIsolate();
956   Handle<FixedArray> old_infos(script->shared_function_infos(), isolate);
957   Handle<FixedArray> new_infos(
958       isolate->factory()->NewFixedArray(max_function_literal_id + 1));
959   script->set_shared_function_infos(*new_infos);
960   SharedFunctionInfo::ScriptIterator iterator(isolate, old_infos);
961   while (SharedFunctionInfo* shared = iterator.Next()) {
962     // We can't use SharedFunctionInfo::SetScript(info, undefined_value()) here,
963     // as we severed the link from the Script to the SharedFunctionInfo above.
964     Handle<SharedFunctionInfo> info(shared, isolate);
965     info->set_script(isolate->heap()->undefined_value());
966     Handle<Object> new_noscript_list = WeakFixedArray::Add(
967         isolate->factory()->noscript_shared_function_infos(), info);
968     isolate->heap()->SetRootNoScriptSharedFunctionInfos(*new_noscript_list);
969 
970     // Put the SharedFunctionInfo at its new, correct location.
971     SharedFunctionInfo::SetScript(info, script);
972   }
973 }
974 
SetFunctionScript(Handle<JSValue> function_wrapper,Handle<Object> script_handle)975 void LiveEdit::SetFunctionScript(Handle<JSValue> function_wrapper,
976                                  Handle<Object> script_handle) {
977   Handle<SharedFunctionInfo> shared_info =
978       UnwrapSharedFunctionInfoFromJSValue(function_wrapper);
979   Isolate* isolate = function_wrapper->GetIsolate();
980   CHECK(script_handle->IsScript() || script_handle->IsUndefined(isolate));
981   SharedFunctionInfo::SetScript(shared_info, script_handle);
982   shared_info->DisableOptimization(kLiveEdit);
983 
984   function_wrapper->GetIsolate()->compilation_cache()->Remove(shared_info);
985 }
986 
987 namespace {
988 // For a script text change (defined as position_change_array), translates
989 // position in unchanged text to position in changed text.
990 // Text change is a set of non-overlapping regions in text, that have changed
991 // their contents and length. It is specified as array of groups of 3 numbers:
992 // (change_begin, change_end, change_end_new_position).
993 // Each group describes a change in text; groups are sorted by change_begin.
994 // Only position in text beyond any changes may be successfully translated.
995 // If a positions is inside some region that changed, result is currently
996 // undefined.
TranslatePosition(int original_position,Handle<JSArray> position_change_array)997 static int TranslatePosition(int original_position,
998                              Handle<JSArray> position_change_array) {
999   int position_diff = 0;
1000   int array_len = GetArrayLength(position_change_array);
1001   Isolate* isolate = position_change_array->GetIsolate();
1002   // TODO(635): binary search may be used here
1003   for (int i = 0; i < array_len; i += 3) {
1004     HandleScope scope(isolate);
1005     Handle<Object> element =
1006         JSReceiver::GetElement(isolate, position_change_array, i)
1007             .ToHandleChecked();
1008     CHECK(element->IsSmi());
1009     int chunk_start = Handle<Smi>::cast(element)->value();
1010     if (original_position < chunk_start) {
1011       break;
1012     }
1013     element = JSReceiver::GetElement(isolate, position_change_array, i + 1)
1014                   .ToHandleChecked();
1015     CHECK(element->IsSmi());
1016     int chunk_end = Handle<Smi>::cast(element)->value();
1017     // Position mustn't be inside a chunk.
1018     DCHECK(original_position >= chunk_end);
1019     element = JSReceiver::GetElement(isolate, position_change_array, i + 2)
1020                   .ToHandleChecked();
1021     CHECK(element->IsSmi());
1022     int chunk_changed_end = Handle<Smi>::cast(element)->value();
1023     position_diff = chunk_changed_end - chunk_end;
1024   }
1025 
1026   return original_position + position_diff;
1027 }
1028 
TranslateSourcePositionTable(Handle<AbstractCode> code,Handle<JSArray> position_change_array)1029 void TranslateSourcePositionTable(Handle<AbstractCode> code,
1030                                   Handle<JSArray> position_change_array) {
1031   Isolate* isolate = code->GetIsolate();
1032   Zone zone(isolate->allocator(), ZONE_NAME);
1033   SourcePositionTableBuilder builder(&zone);
1034 
1035   Handle<ByteArray> source_position_table(code->source_position_table());
1036   for (SourcePositionTableIterator iterator(*source_position_table);
1037        !iterator.done(); iterator.Advance()) {
1038     SourcePosition position = iterator.source_position();
1039     position.SetScriptOffset(
1040         TranslatePosition(position.ScriptOffset(), position_change_array));
1041     builder.AddPosition(iterator.code_offset(), position,
1042                         iterator.is_statement());
1043   }
1044 
1045   Handle<ByteArray> new_source_position_table(
1046       builder.ToSourcePositionTable(isolate, code));
1047   code->set_source_position_table(*new_source_position_table);
1048 }
1049 }  // namespace
1050 
PatchFunctionPositions(Handle<JSArray> shared_info_array,Handle<JSArray> position_change_array)1051 void LiveEdit::PatchFunctionPositions(Handle<JSArray> shared_info_array,
1052                                       Handle<JSArray> position_change_array) {
1053   SharedInfoWrapper shared_info_wrapper(shared_info_array);
1054   Handle<SharedFunctionInfo> info = shared_info_wrapper.GetInfo();
1055 
1056   int old_function_start = info->start_position();
1057   int new_function_start = TranslatePosition(old_function_start,
1058                                              position_change_array);
1059   int new_function_end = TranslatePosition(info->end_position(),
1060                                            position_change_array);
1061   int new_function_token_pos =
1062       TranslatePosition(info->function_token_position(), position_change_array);
1063 
1064   info->set_start_position(new_function_start);
1065   info->set_end_position(new_function_end);
1066   info->set_function_token_position(new_function_token_pos);
1067 
1068   if (info->HasBytecodeArray()) {
1069     TranslateSourcePositionTable(
1070         Handle<AbstractCode>(AbstractCode::cast(info->bytecode_array())),
1071         position_change_array);
1072   }
1073   if (info->code()->kind() == Code::FUNCTION) {
1074     TranslateSourcePositionTable(
1075         Handle<AbstractCode>(AbstractCode::cast(info->code())),
1076         position_change_array);
1077   }
1078   if (info->HasDebugInfo()) {
1079     // Existing break points will be re-applied. Reset the debug info here.
1080     info->GetIsolate()->debug()->RemoveDebugInfoAndClearFromShared(
1081         handle(info->GetDebugInfo()));
1082   }
1083 }
1084 
1085 
CreateScriptCopy(Handle<Script> original)1086 static Handle<Script> CreateScriptCopy(Handle<Script> original) {
1087   Isolate* isolate = original->GetIsolate();
1088 
1089   Handle<String> original_source(String::cast(original->source()));
1090   Handle<Script> copy = isolate->factory()->NewScript(original_source);
1091 
1092   copy->set_name(original->name());
1093   copy->set_line_offset(original->line_offset());
1094   copy->set_column_offset(original->column_offset());
1095   copy->set_type(original->type());
1096   copy->set_context_data(original->context_data());
1097   copy->set_eval_from_shared(original->eval_from_shared());
1098   copy->set_eval_from_position(original->eval_from_position());
1099 
1100   Handle<FixedArray> infos(isolate->factory()->NewFixedArray(
1101       original->shared_function_infos()->length()));
1102   copy->set_shared_function_infos(*infos);
1103 
1104   // Copy all the flags, but clear compilation state.
1105   copy->set_flags(original->flags());
1106   copy->set_compilation_state(Script::COMPILATION_STATE_INITIAL);
1107 
1108   return copy;
1109 }
1110 
ChangeScriptSource(Handle<Script> original_script,Handle<String> new_source,Handle<Object> old_script_name)1111 Handle<Object> LiveEdit::ChangeScriptSource(Handle<Script> original_script,
1112                                             Handle<String> new_source,
1113                                             Handle<Object> old_script_name) {
1114   Isolate* isolate = original_script->GetIsolate();
1115   Handle<Object> old_script_object;
1116   if (old_script_name->IsString()) {
1117     Handle<Script> old_script = CreateScriptCopy(original_script);
1118     old_script->set_name(String::cast(*old_script_name));
1119     old_script_object = old_script;
1120     isolate->debug()->OnAfterCompile(old_script);
1121   } else {
1122     old_script_object = isolate->factory()->null_value();
1123   }
1124 
1125   original_script->set_source(*new_source);
1126 
1127   // Drop line ends so that they will be recalculated.
1128   original_script->set_line_ends(isolate->heap()->undefined_value());
1129 
1130   return old_script_object;
1131 }
1132 
1133 
1134 
ReplaceRefToNestedFunction(Handle<JSValue> parent_function_wrapper,Handle<JSValue> orig_function_wrapper,Handle<JSValue> subst_function_wrapper)1135 void LiveEdit::ReplaceRefToNestedFunction(
1136     Handle<JSValue> parent_function_wrapper,
1137     Handle<JSValue> orig_function_wrapper,
1138     Handle<JSValue> subst_function_wrapper) {
1139 
1140   Handle<SharedFunctionInfo> parent_shared =
1141       UnwrapSharedFunctionInfoFromJSValue(parent_function_wrapper);
1142   Handle<SharedFunctionInfo> orig_shared =
1143       UnwrapSharedFunctionInfoFromJSValue(orig_function_wrapper);
1144   Handle<SharedFunctionInfo> subst_shared =
1145       UnwrapSharedFunctionInfoFromJSValue(subst_function_wrapper);
1146 
1147   for (RelocIterator it(parent_shared->code()); !it.done(); it.next()) {
1148     if (it.rinfo()->rmode() == RelocInfo::EMBEDDED_OBJECT) {
1149       if (it.rinfo()->target_object() == *orig_shared) {
1150         it.rinfo()->set_target_object(*subst_shared);
1151       }
1152     }
1153   }
1154 }
1155 
1156 
1157 // Check an activation against list of functions. If there is a function
1158 // that matches, its status in result array is changed to status argument value.
CheckActivation(Handle<JSArray> shared_info_array,Handle<JSArray> result,StackFrame * frame,LiveEdit::FunctionPatchabilityStatus status)1159 static bool CheckActivation(Handle<JSArray> shared_info_array,
1160                             Handle<JSArray> result,
1161                             StackFrame* frame,
1162                             LiveEdit::FunctionPatchabilityStatus status) {
1163   if (!frame->is_java_script()) return false;
1164 
1165   Handle<JSFunction> function(JavaScriptFrame::cast(frame)->function());
1166 
1167   Isolate* isolate = shared_info_array->GetIsolate();
1168   int len = GetArrayLength(shared_info_array);
1169   for (int i = 0; i < len; i++) {
1170     HandleScope scope(isolate);
1171     Handle<Object> element =
1172         JSReceiver::GetElement(isolate, shared_info_array, i).ToHandleChecked();
1173     Handle<JSValue> jsvalue = Handle<JSValue>::cast(element);
1174     Handle<SharedFunctionInfo> shared =
1175         UnwrapSharedFunctionInfoFromJSValue(jsvalue);
1176 
1177     if (function->Inlines(*shared)) {
1178       SetElementSloppy(result, i, Handle<Smi>(Smi::FromInt(status), isolate));
1179       return true;
1180     }
1181   }
1182   return false;
1183 }
1184 
1185 // Describes a set of call frames that execute any of listed functions.
1186 // Finding no such frames does not mean error.
1187 class MultipleFunctionTarget {
1188  public:
MultipleFunctionTarget(Handle<JSArray> old_shared_array,Handle<JSArray> new_shared_array,Handle<JSArray> result)1189   MultipleFunctionTarget(Handle<JSArray> old_shared_array,
1190                          Handle<JSArray> new_shared_array,
1191                          Handle<JSArray> result)
1192       : old_shared_array_(old_shared_array),
1193         new_shared_array_(new_shared_array),
1194         result_(result) {}
MatchActivation(StackFrame * frame,LiveEdit::FunctionPatchabilityStatus status)1195   bool MatchActivation(StackFrame* frame,
1196       LiveEdit::FunctionPatchabilityStatus status) {
1197     return CheckActivation(old_shared_array_, result_, frame, status);
1198   }
GetNotFoundMessage() const1199   const char* GetNotFoundMessage() const {
1200     return NULL;
1201   }
FrameUsesNewTarget(StackFrame * frame)1202   bool FrameUsesNewTarget(StackFrame* frame) {
1203     if (!frame->is_java_script()) return false;
1204     JavaScriptFrame* jsframe = JavaScriptFrame::cast(frame);
1205     Handle<SharedFunctionInfo> old_shared(jsframe->function()->shared());
1206     Isolate* isolate = old_shared->GetIsolate();
1207     int len = GetArrayLength(old_shared_array_);
1208     // Find corresponding new shared function info and return whether it
1209     // references new.target.
1210     for (int i = 0; i < len; i++) {
1211       HandleScope scope(isolate);
1212       Handle<Object> old_element =
1213           JSReceiver::GetElement(isolate, old_shared_array_, i)
1214               .ToHandleChecked();
1215       if (!old_shared.is_identical_to(UnwrapSharedFunctionInfoFromJSValue(
1216               Handle<JSValue>::cast(old_element)))) {
1217         continue;
1218       }
1219 
1220       Handle<Object> new_element =
1221           JSReceiver::GetElement(isolate, new_shared_array_, i)
1222               .ToHandleChecked();
1223       if (new_element->IsUndefined(isolate)) return false;
1224       Handle<SharedFunctionInfo> new_shared =
1225           UnwrapSharedFunctionInfoFromJSValue(
1226               Handle<JSValue>::cast(new_element));
1227       if (new_shared->scope_info()->HasNewTarget()) {
1228         SetElementSloppy(
1229             result_, i,
1230             Handle<Smi>(
1231                 Smi::FromInt(
1232                     LiveEdit::FUNCTION_BLOCKED_NO_NEW_TARGET_ON_RESTART),
1233                 isolate));
1234         return true;
1235       }
1236       return false;
1237     }
1238     return false;
1239   }
1240 
set_status(LiveEdit::FunctionPatchabilityStatus status)1241   void set_status(LiveEdit::FunctionPatchabilityStatus status) {
1242     Isolate* isolate = old_shared_array_->GetIsolate();
1243     int len = GetArrayLength(old_shared_array_);
1244     for (int i = 0; i < len; ++i) {
1245       Handle<Object> old_element =
1246           JSReceiver::GetElement(isolate, result_, i).ToHandleChecked();
1247       if (!old_element->IsSmi() ||
1248           Smi::cast(*old_element)->value() ==
1249               LiveEdit::FUNCTION_AVAILABLE_FOR_PATCH) {
1250         SetElementSloppy(result_, i,
1251                          Handle<Smi>(Smi::FromInt(status), isolate));
1252       }
1253     }
1254   }
1255 
1256  private:
1257   Handle<JSArray> old_shared_array_;
1258   Handle<JSArray> new_shared_array_;
1259   Handle<JSArray> result_;
1260 };
1261 
1262 
1263 // Drops all call frame matched by target and all frames above them.
1264 template <typename TARGET>
DropActivationsInActiveThreadImpl(Isolate * isolate,TARGET & target,bool do_drop)1265 static const char* DropActivationsInActiveThreadImpl(Isolate* isolate,
1266                                                      TARGET& target,  // NOLINT
1267                                                      bool do_drop) {
1268   Debug* debug = isolate->debug();
1269   Zone zone(isolate->allocator(), ZONE_NAME);
1270   Vector<StackFrame*> frames = CreateStackMap(isolate, &zone);
1271 
1272   int top_frame_index = -1;
1273   int frame_index = 0;
1274   for (; frame_index < frames.length(); frame_index++) {
1275     StackFrame* frame = frames[frame_index];
1276     if (frame->id() == debug->break_frame_id()) {
1277       top_frame_index = frame_index;
1278       break;
1279     }
1280     if (target.MatchActivation(
1281             frame, LiveEdit::FUNCTION_BLOCKED_UNDER_NATIVE_CODE)) {
1282       // We are still above break_frame. It is not a target frame,
1283       // it is a problem.
1284       return "Debugger mark-up on stack is not found";
1285     }
1286   }
1287 
1288   if (top_frame_index == -1) {
1289     // We haven't found break frame, but no function is blocking us anyway.
1290     return target.GetNotFoundMessage();
1291   }
1292 
1293   bool target_frame_found = false;
1294   int bottom_js_frame_index = top_frame_index;
1295   bool non_droppable_frame_found = false;
1296   LiveEdit::FunctionPatchabilityStatus non_droppable_reason;
1297 
1298   for (; frame_index < frames.length(); frame_index++) {
1299     StackFrame* frame = frames[frame_index];
1300     if (frame->is_exit() || frame->is_builtin_exit()) {
1301       non_droppable_frame_found = true;
1302       non_droppable_reason = LiveEdit::FUNCTION_BLOCKED_UNDER_NATIVE_CODE;
1303       break;
1304     }
1305     if (frame->is_java_script()) {
1306       SharedFunctionInfo* shared =
1307           JavaScriptFrame::cast(frame)->function()->shared();
1308       if (IsResumableFunction(shared->kind())) {
1309         non_droppable_frame_found = true;
1310         non_droppable_reason = LiveEdit::FUNCTION_BLOCKED_UNDER_GENERATOR;
1311         break;
1312       }
1313     }
1314     if (target.MatchActivation(
1315             frame, LiveEdit::FUNCTION_BLOCKED_ON_ACTIVE_STACK)) {
1316       target_frame_found = true;
1317       bottom_js_frame_index = frame_index;
1318     }
1319   }
1320 
1321   if (non_droppable_frame_found) {
1322     // There is a C or generator frame on stack.  We can't drop C frames, and we
1323     // can't restart generators.  Check that there are no target frames below
1324     // them.
1325     for (; frame_index < frames.length(); frame_index++) {
1326       StackFrame* frame = frames[frame_index];
1327       if (frame->is_java_script()) {
1328         if (target.MatchActivation(frame, non_droppable_reason)) {
1329           // Fail.
1330           return NULL;
1331         }
1332         if (non_droppable_reason ==
1333                 LiveEdit::FUNCTION_BLOCKED_UNDER_GENERATOR &&
1334             !target_frame_found) {
1335           // Fail.
1336           target.set_status(non_droppable_reason);
1337           return NULL;
1338         }
1339       }
1340     }
1341   }
1342 
1343   // We cannot restart a frame that uses new.target.
1344   if (target.FrameUsesNewTarget(frames[bottom_js_frame_index])) return NULL;
1345 
1346   if (!do_drop) {
1347     // We are in check-only mode.
1348     return NULL;
1349   }
1350 
1351   if (!target_frame_found) {
1352     // Nothing to drop.
1353     return target.GetNotFoundMessage();
1354   }
1355 
1356   if (!LiveEdit::kFrameDropperSupported) {
1357     return "Stack manipulations are not supported in this architecture.";
1358   }
1359 
1360   debug->ScheduleFrameRestart(frames[bottom_js_frame_index]);
1361   return NULL;
1362 }
1363 
1364 
1365 // Fills result array with statuses of functions. Modifies the stack
1366 // removing all listed function if possible and if do_drop is true.
DropActivationsInActiveThread(Handle<JSArray> old_shared_array,Handle<JSArray> new_shared_array,Handle<JSArray> result,bool do_drop)1367 static const char* DropActivationsInActiveThread(
1368     Handle<JSArray> old_shared_array, Handle<JSArray> new_shared_array,
1369     Handle<JSArray> result, bool do_drop) {
1370   MultipleFunctionTarget target(old_shared_array, new_shared_array, result);
1371   Isolate* isolate = old_shared_array->GetIsolate();
1372 
1373   const char* message =
1374       DropActivationsInActiveThreadImpl(isolate, target, do_drop);
1375   if (message) {
1376     return message;
1377   }
1378 
1379   int array_len = GetArrayLength(old_shared_array);
1380 
1381   // Replace "blocked on active" with "replaced on active" status.
1382   for (int i = 0; i < array_len; i++) {
1383     Handle<Object> obj =
1384         JSReceiver::GetElement(isolate, result, i).ToHandleChecked();
1385     if (*obj == Smi::FromInt(LiveEdit::FUNCTION_BLOCKED_ON_ACTIVE_STACK)) {
1386       Handle<Object> replaced(
1387           Smi::FromInt(LiveEdit::FUNCTION_REPLACED_ON_ACTIVE_STACK), isolate);
1388       SetElementSloppy(result, i, replaced);
1389     }
1390   }
1391   return NULL;
1392 }
1393 
1394 
FindActiveGenerators(Handle<FixedArray> shared_info_array,Handle<FixedArray> result,int len)1395 bool LiveEdit::FindActiveGenerators(Handle<FixedArray> shared_info_array,
1396                                     Handle<FixedArray> result,
1397                                     int len) {
1398   Isolate* isolate = shared_info_array->GetIsolate();
1399   bool found_suspended_activations = false;
1400 
1401   DCHECK_LE(len, result->length());
1402 
1403   FunctionPatchabilityStatus active = FUNCTION_BLOCKED_ACTIVE_GENERATOR;
1404 
1405   Heap* heap = isolate->heap();
1406   HeapIterator iterator(heap, HeapIterator::kFilterUnreachable);
1407   HeapObject* obj = NULL;
1408   while ((obj = iterator.next()) != NULL) {
1409     if (!obj->IsJSGeneratorObject()) continue;
1410 
1411     JSGeneratorObject* gen = JSGeneratorObject::cast(obj);
1412     if (gen->is_closed()) continue;
1413 
1414     HandleScope scope(isolate);
1415 
1416     for (int i = 0; i < len; i++) {
1417       Handle<JSValue> jsvalue = Handle<JSValue>::cast(
1418           FixedArray::get(*shared_info_array, i, isolate));
1419       Handle<SharedFunctionInfo> shared =
1420           UnwrapSharedFunctionInfoFromJSValue(jsvalue);
1421 
1422       if (gen->function()->shared() == *shared) {
1423         result->set(i, Smi::FromInt(active));
1424         found_suspended_activations = true;
1425       }
1426     }
1427   }
1428 
1429   return found_suspended_activations;
1430 }
1431 
1432 
1433 class InactiveThreadActivationsChecker : public ThreadVisitor {
1434  public:
InactiveThreadActivationsChecker(Handle<JSArray> old_shared_array,Handle<JSArray> result)1435   InactiveThreadActivationsChecker(Handle<JSArray> old_shared_array,
1436                                    Handle<JSArray> result)
1437       : old_shared_array_(old_shared_array),
1438         result_(result),
1439         has_blocked_functions_(false) {}
VisitThread(Isolate * isolate,ThreadLocalTop * top)1440   void VisitThread(Isolate* isolate, ThreadLocalTop* top) {
1441     for (StackFrameIterator it(isolate, top); !it.done(); it.Advance()) {
1442       has_blocked_functions_ |=
1443           CheckActivation(old_shared_array_, result_, it.frame(),
1444                           LiveEdit::FUNCTION_BLOCKED_ON_OTHER_STACK);
1445     }
1446   }
HasBlockedFunctions()1447   bool HasBlockedFunctions() {
1448     return has_blocked_functions_;
1449   }
1450 
1451  private:
1452   Handle<JSArray> old_shared_array_;
1453   Handle<JSArray> result_;
1454   bool has_blocked_functions_;
1455 };
1456 
1457 
CheckAndDropActivations(Handle<JSArray> old_shared_array,Handle<JSArray> new_shared_array,bool do_drop)1458 Handle<JSArray> LiveEdit::CheckAndDropActivations(
1459     Handle<JSArray> old_shared_array, Handle<JSArray> new_shared_array,
1460     bool do_drop) {
1461   Isolate* isolate = old_shared_array->GetIsolate();
1462   int len = GetArrayLength(old_shared_array);
1463 
1464   DCHECK(old_shared_array->HasFastElements());
1465   Handle<FixedArray> old_shared_array_elements(
1466       FixedArray::cast(old_shared_array->elements()));
1467 
1468   Handle<JSArray> result = isolate->factory()->NewJSArray(len);
1469   result->set_length(Smi::FromInt(len));
1470   JSObject::EnsureWritableFastElements(result);
1471   Handle<FixedArray> result_elements =
1472       handle(FixedArray::cast(result->elements()), isolate);
1473 
1474   // Fill the default values.
1475   for (int i = 0; i < len; i++) {
1476     FunctionPatchabilityStatus status = FUNCTION_AVAILABLE_FOR_PATCH;
1477     result_elements->set(i, Smi::FromInt(status));
1478   }
1479 
1480   // Scan the heap for active generators -- those that are either currently
1481   // running (as we wouldn't want to restart them, because we don't know where
1482   // to restart them from) or suspended.  Fail if any one corresponds to the set
1483   // of functions being edited.
1484   if (FindActiveGenerators(old_shared_array_elements, result_elements, len)) {
1485     return result;
1486   }
1487 
1488   // Check inactive threads. Fail if some functions are blocked there.
1489   InactiveThreadActivationsChecker inactive_threads_checker(old_shared_array,
1490                                                             result);
1491   isolate->thread_manager()->IterateArchivedThreads(
1492       &inactive_threads_checker);
1493   if (inactive_threads_checker.HasBlockedFunctions()) {
1494     return result;
1495   }
1496 
1497   // Try to drop activations from the current stack.
1498   const char* error_message = DropActivationsInActiveThread(
1499       old_shared_array, new_shared_array, result, do_drop);
1500   if (error_message != NULL) {
1501     // Add error message as an array extra element.
1502     Handle<String> str =
1503         isolate->factory()->NewStringFromAsciiChecked(error_message);
1504     SetElementSloppy(result, len, str);
1505   }
1506   return result;
1507 }
1508 
1509 
1510 // Describes a single callframe a target. Not finding this frame
1511 // means an error.
1512 class SingleFrameTarget {
1513  public:
SingleFrameTarget(JavaScriptFrame * frame)1514   explicit SingleFrameTarget(JavaScriptFrame* frame)
1515       : m_frame(frame),
1516         m_saved_status(LiveEdit::FUNCTION_AVAILABLE_FOR_PATCH) {}
1517 
MatchActivation(StackFrame * frame,LiveEdit::FunctionPatchabilityStatus status)1518   bool MatchActivation(StackFrame* frame,
1519       LiveEdit::FunctionPatchabilityStatus status) {
1520     if (frame->fp() == m_frame->fp()) {
1521       m_saved_status = status;
1522       return true;
1523     }
1524     return false;
1525   }
GetNotFoundMessage() const1526   const char* GetNotFoundMessage() const {
1527     return "Failed to found requested frame";
1528   }
saved_status()1529   LiveEdit::FunctionPatchabilityStatus saved_status() {
1530     return m_saved_status;
1531   }
set_status(LiveEdit::FunctionPatchabilityStatus status)1532   void set_status(LiveEdit::FunctionPatchabilityStatus status) {
1533     m_saved_status = status;
1534   }
1535 
FrameUsesNewTarget(StackFrame * frame)1536   bool FrameUsesNewTarget(StackFrame* frame) {
1537     if (!frame->is_java_script()) return false;
1538     JavaScriptFrame* jsframe = JavaScriptFrame::cast(frame);
1539     Handle<SharedFunctionInfo> shared(jsframe->function()->shared());
1540     return shared->scope_info()->HasNewTarget();
1541   }
1542 
1543  private:
1544   JavaScriptFrame* m_frame;
1545   LiveEdit::FunctionPatchabilityStatus m_saved_status;
1546 };
1547 
1548 
1549 // Finds a drops required frame and all frames above.
1550 // Returns error message or NULL.
RestartFrame(JavaScriptFrame * frame)1551 const char* LiveEdit::RestartFrame(JavaScriptFrame* frame) {
1552   SingleFrameTarget target(frame);
1553 
1554   const char* result =
1555       DropActivationsInActiveThreadImpl(frame->isolate(), target, true);
1556   if (result != NULL) {
1557     return result;
1558   }
1559   if (target.saved_status() == LiveEdit::FUNCTION_BLOCKED_UNDER_NATIVE_CODE) {
1560     return "Function is blocked under native code";
1561   }
1562   if (target.saved_status() == LiveEdit::FUNCTION_BLOCKED_UNDER_GENERATOR) {
1563     return "Function is blocked under a generator activation";
1564   }
1565   return NULL;
1566 }
1567 
Collect(FunctionLiteral * node,Handle<Script> script,Zone * zone,Isolate * isolate)1568 Handle<JSArray> LiveEditFunctionTracker::Collect(FunctionLiteral* node,
1569                                                  Handle<Script> script,
1570                                                  Zone* zone, Isolate* isolate) {
1571   LiveEditFunctionTracker visitor(script, zone, isolate);
1572   visitor.VisitFunctionLiteral(node);
1573   return visitor.result_;
1574 }
1575 
LiveEditFunctionTracker(Handle<Script> script,Zone * zone,Isolate * isolate)1576 LiveEditFunctionTracker::LiveEditFunctionTracker(Handle<Script> script,
1577                                                  Zone* zone, Isolate* isolate)
1578     : AstTraversalVisitor<LiveEditFunctionTracker>(isolate) {
1579   current_parent_index_ = -1;
1580   isolate_ = isolate;
1581   len_ = 0;
1582   result_ = isolate->factory()->NewJSArray(10);
1583   script_ = script;
1584   zone_ = zone;
1585 }
1586 
VisitFunctionLiteral(FunctionLiteral * node)1587 void LiveEditFunctionTracker::VisitFunctionLiteral(FunctionLiteral* node) {
1588   // FunctionStarted is called in pre-order.
1589   FunctionStarted(node);
1590   // Recurse using the regular traversal.
1591   AstTraversalVisitor::VisitFunctionLiteral(node);
1592   // FunctionDone are called in post-order.
1593   Handle<SharedFunctionInfo> info =
1594       script_->FindSharedFunctionInfo(isolate_, node).ToHandleChecked();
1595   FunctionDone(info, node->scope());
1596 }
1597 
FunctionStarted(FunctionLiteral * fun)1598 void LiveEditFunctionTracker::FunctionStarted(FunctionLiteral* fun) {
1599   HandleScope handle_scope(isolate_);
1600   FunctionInfoWrapper info = FunctionInfoWrapper::Create(isolate_);
1601   info.SetInitialProperties(fun->name(), fun->start_position(),
1602                             fun->end_position(), fun->parameter_count(),
1603                             current_parent_index_, fun->function_literal_id());
1604   current_parent_index_ = len_;
1605   SetElementSloppy(result_, len_, info.GetJSArray());
1606   len_++;
1607 }
1608 
1609 // Saves full information about a function: its code, its scope info
1610 // and a SharedFunctionInfo object.
FunctionDone(Handle<SharedFunctionInfo> shared,Scope * scope)1611 void LiveEditFunctionTracker::FunctionDone(Handle<SharedFunctionInfo> shared,
1612                                            Scope* scope) {
1613   HandleScope handle_scope(isolate_);
1614   FunctionInfoWrapper info = FunctionInfoWrapper::cast(
1615       *JSReceiver::GetElement(isolate_, result_, current_parent_index_)
1616            .ToHandleChecked());
1617   info.SetSharedFunctionInfo(shared);
1618 
1619   Handle<Object> scope_info_list = SerializeFunctionScope(scope);
1620   info.SetFunctionScopeInfo(scope_info_list);
1621 
1622   current_parent_index_ = info.GetParentIndex();
1623 }
1624 
SerializeFunctionScope(Scope * scope)1625 Handle<Object> LiveEditFunctionTracker::SerializeFunctionScope(Scope* scope) {
1626   Handle<JSArray> scope_info_list = isolate_->factory()->NewJSArray(10);
1627   int scope_info_length = 0;
1628 
1629   // Saves some description of scope. It stores name and indexes of
1630   // variables in the whole scope chain. Null-named slots delimit
1631   // scopes of this chain.
1632   Scope* current_scope = scope;
1633   while (current_scope != NULL) {
1634     HandleScope handle_scope(isolate_);
1635     for (Variable* var : *current_scope->locals()) {
1636       if (!var->IsContextSlot()) continue;
1637       int context_index = var->index() - Context::MIN_CONTEXT_SLOTS;
1638       int location = scope_info_length + context_index * 2;
1639       SetElementSloppy(scope_info_list, location, var->name());
1640       SetElementSloppy(scope_info_list, location + 1,
1641                        handle(Smi::FromInt(var->index()), isolate_));
1642     }
1643     scope_info_length += current_scope->ContextLocalCount() * 2;
1644     SetElementSloppy(scope_info_list, scope_info_length,
1645                      isolate_->factory()->null_value());
1646     scope_info_length++;
1647 
1648     current_scope = current_scope->outer_scope();
1649   }
1650 
1651   return scope_info_list;
1652 }
1653 
1654 }  // namespace internal
1655 }  // namespace v8
1656