Commit f06c72f6 authored by unknown's avatar unknown
Browse files

Fix testDict -n FragmentTypeSingle T1 

Init KeyDescriptor before sending to DIH, 
  make sure that its always inited
parent cb04d581

ndb/src/kernel/blocks/dbdict/Dbdict.cpp

+38 −38
Original line number Diff line number Diff line
@@ -4346,6 +4346,44 @@ Dbdict::createTab_dih(Signal* signal, 


  sendSignal(DBDIH_REF, GSN_DIADDTABREQ, signal, 

	     DiAddTabReq::SignalLength, JBB);



  /**

   * Create KeyDescriptor

   */

  KeyDescriptor* desc= g_key_descriptor_pool.getPtr(tabPtr.i);

  new (desc) KeyDescriptor();



  Uint32 key = 0;

  Uint32 tAttr = tabPtr.p->firstAttribute;

  while (tAttr != RNIL) 

  {

    jam();

    AttributeRecord* aRec = c_attributeRecordPool.getPtr(tAttr);

    if (aRec->tupleKey) 

    {

      desc->noOfKeyAttr ++;

      desc->keyAttr[key].attributeDescriptor = aRec->attributeDescriptor;

      

      Uint32 csNumber = (aRec->extPrecision >> 16);

      if(csNumber)

      {

	desc->keyAttr[key].charsetInfo = all_charsets[csNumber];

	ndbrequire(all_charsets[csNumber]);

	desc->hasCharAttr = 1;

      }

      else

      {

	desc->keyAttr[key].charsetInfo = 0;	  

      }

      if(AttributeDescriptor::getDKey(aRec->attributeDescriptor))

      {

	desc->noOfDistrKeys ++;

      }

      key++;

    }

    tAttr = aRec->nextAttrInTable;

  }

  ndbrequire(key == tabPtr.p->noOfPrimkey);

}



static
@@ -4448,44 +4486,6 @@ Dbdict::execADD_FRAGREQ(Signal* signal) { 
    sendSignal(DBLQH_REF, GSN_LQHFRAGREQ, signal, 

	       LqhFragReq::SignalLength, JBB);

  }



  /**

   * Create KeyDescriptor

   */

  KeyDescriptor* desc= g_key_descriptor_pool.getPtr(tabPtr.i);

  new (desc) KeyDescriptor();



  Uint32 key = 0;

  Uint32 tAttr = tabPtr.p->firstAttribute;

  while (tAttr != RNIL) 

  {

    jam();

    AttributeRecord* aRec = c_attributeRecordPool.getPtr(tAttr);

    if (aRec->tupleKey) 

    {

      desc->noOfKeyAttr ++;

      desc->keyAttr[key].attributeDescriptor = aRec->attributeDescriptor;

      

      Uint32 csNumber = (aRec->extPrecision >> 16);

      if(csNumber)

      {

	desc->keyAttr[key].charsetInfo = all_charsets[csNumber];

	ndbrequire(all_charsets[csNumber]);

	desc->hasCharAttr = 1;

      }

      else

      {

	desc->keyAttr[key].charsetInfo = 0;	  

      }

      if(AttributeDescriptor::getDKey(aRec->attributeDescriptor))

      {

	desc->noOfDistrKeys ++;

      }

      key++;

    }

    tAttr = aRec->nextAttrInTable;

  }

  ndbrequire(key == tabPtr.p->noOfPrimkey);

}



void